Struct OpenAI Stream Sink | NVIDIA NeMo Fabric

Generated from cargo doc --no-deps -p nemo-fabric-core.

pub struct OpenAiStreamSink {
    pub protocol_version: OpenAiStreamProtocolVersion,
    pub profile: OpenAiStreamProfile,
    pub host: OpenAiStreamHost,
    pub port: u16,
    pub token: String,
    pub runtime_id: String,
    pub invocation_id: String,
    pub request_id: String,
}

Adapter-facing stream sink with invocation identity generated by NVIDIA NeMo Fabric.

Fields

`protocol_version: OpenAiStreamProtocolVersion`

Southbound stream protocol version.

`profile: OpenAiStreamProfile`

OpenAI event profile emitted on this stream.

`host: OpenAiStreamHost`

Loopback host owned by the SDK listener.

`port: u16`

Loopback TCP port owned by the SDK listener.

`token: String`

Single-use bearer token. Adapters must not log or persist this value.

`runtime_id: String`

Runtime id for stream correlation.

`invocation_id: String`

Invocation id for stream correlation.

`request_id: String`

Request id for stream correlation.

Trait Implementations

`impl Clone for OpenAiStreamSink`

impl Clone for OpenAiStreamSink

`clone`

fn clone(&self) -> OpenAiStreamSink

`clone_from`

fn clone_from(&mut self, source: &Self)

`impl Debug for OpenAiStreamSink`

impl Debug for OpenAiStreamSink

`fmt`

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

`impl<'de> Deserialize<'de> for OpenAiStreamSink`

impl<'de> Deserialize<'de> for OpenAiStreamSink

`deserialize`

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
    __D: Deserializer<'de>,

`impl JsonSchema for OpenAiStreamSink`

impl JsonSchema for OpenAiStreamSink

`schema_name`

fn schema_name() -> Cow<'static, str>

`schema_id`

fn schema_id() -> Cow<'static, str>

`json_schema`

fn json_schema(generator: &mut SchemaGenerator) -> Schema

`inline_schema`

fn inline_schema() -> bool

`impl PartialEq for OpenAiStreamSink`

impl PartialEq for OpenAiStreamSink

`eq`

fn eq(&self, other: &OpenAiStreamSink) -> bool

`ne`

fn ne(&self, other: &Rhs) -> bool

`impl Serialize for OpenAiStreamSink`

impl Serialize for OpenAiStreamSink

`serialize`

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
    __S: Serializer,

`impl StructuralPartialEq for OpenAiStreamSink`

impl StructuralPartialEq for OpenAiStreamSink