Enum Relay Atof Sink Config | NVIDIA NeMo Fabric

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

pub enum RelayAtofSinkConfig {
    File {
        output_directory: Option<PathBuf>,
        filename: Option<String>,
        mode: RelayAtofMode,
        extensions: BTreeMap<String, Value>,
    },
    Stream {
        url: String,
        transport: RelayAtofStreamTransport,
        headers: BTreeMap<String, String>,
        header_env: BTreeMap<String, String>,
        timeout_millis: u64,
        field_name_policy: RelayAtofStreamFieldNamePolicy,
        name: Option<String>,
        extensions: BTreeMap<String, Value>,
    },
}

Relay ATOF sink configuration.

Variants

`File`

File

Write ATOF records to a local file.

Fields

`output_directory: Option<PathBuf>`

Directory used for ATOF files.

`filename: Option<String>`

ATOF file name.

`mode: RelayAtofMode`

File write mode.

`extensions: BTreeMap<String, Value>`

Additive file sink fields.

`Stream`

Stream

Send ATOF records to a remote stream.

Fields

`url: String`

Stream URL.

`transport: RelayAtofStreamTransport`

Stream transport.

`headers: BTreeMap<String, String>`

Static stream headers.

`header_env: BTreeMap<String, String>`

Environment-variable-backed stream headers.

`timeout_millis: u64`

Request timeout in milliseconds.

`field_name_policy: RelayAtofStreamFieldNamePolicy`

Field-name handling policy.

`name: Option<String>`

Optional stream sink name.

`extensions: BTreeMap<String, Value>`

Additive stream sink fields.

Trait Implementations

`impl Clone for RelayAtofSinkConfig`

impl Clone for RelayAtofSinkConfig

`clone`

fn clone(&self) -> RelayAtofSinkConfig

`clone_from`

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

`impl Debug for RelayAtofSinkConfig`

impl Debug for RelayAtofSinkConfig

`fmt`

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

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

impl<'de> Deserialize<'de> for RelayAtofSinkConfig

`deserialize`

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

`impl JsonSchema for RelayAtofSinkConfig`

impl JsonSchema for RelayAtofSinkConfig

`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 RelayAtofSinkConfig`

impl PartialEq for RelayAtofSinkConfig

`eq`

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

`ne`

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

`impl Serialize for RelayAtofSinkConfig`

impl Serialize for RelayAtofSinkConfig

`serialize`

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

`impl StructuralPartialEq for RelayAtofSinkConfig`

impl StructuralPartialEq for RelayAtofSinkConfig