Struct vector_lib::config::TransformOutput

pub struct TransformOutput {
    pub port: Option<String>,
    pub ty: DataType,
    pub log_schema_definitions: HashMap<OutputId, Definition>,
}

Fields

port: Option<String>

ty: DataType

log_schema_definitions: HashMap<OutputId, Definition>

For transforms if Datatype is DataType::Log, if schema is enabled, at least one definition should be output. If the transform has multiple connected sources, it is possible to have multiple output definitions - one for each input.

Implementations

impl TransformOutput

pub fn new( ty: DataType, schema_definitions: HashMap<OutputId, Definition>, ) -> TransformOutput

Create a TransformOutput of the given data type that contains multiple schema::Definitions. Designed for use in transforms.

pub fn with_port(self, name: impl Into<String>) -> TransformOutput

Set the port name for this Output.

pub fn schema_definitions( &self, schema_enabled: bool, ) -> HashMap<OutputId, Definition>

Return the schema schema::Definition from this output.

Takes a schema_enabled flag to determine if the full definition including the fields and associated types should be returned, or if a simple definition should be returned. A simple definition is just the default for the namespace. For the Vector namespace the meanings are included. Schema enabled is set in the users configuration.

Trait Implementations

impl Clone for TransformOutput

fn clone(&self) -> TransformOutput

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TransformOutput

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

Formats the value using the given formatter.

impl Display for TransformOutput

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

Formats the value using the given formatter.

impl PartialEq for TransformOutput

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for TransformOutput