Struct FlowDescriptorBuilder 

pub struct FlowDescriptorBuilder<K> { /* private fields */ }

Builds a FlowDescriptor, which defines the schema of a flow.

The builder is mutable, to allow for the addition of channels to the flow descriptor while the descriptor itself is immuatble, ensuring that the described flow will be constructed correctly.

Implementations

impl<K> FlowDescriptorBuilder<K>

where K: Eq + Hash,

pub fn new( ingestion_config_id: impl Into<String>, name: impl Into<String>, ) -> Self

Initializes a new FlowDescriptorBuilder with the provided ingestion config ID and flow name.

pub fn add(&mut self, key: K, field_type: ChannelDataType) -> ChannelIndex

Adds a new channel to the flow.

This returns the index of the channel in the flow. This index can then be used to access the value at the given channel index when building a new flow.

pub fn build(self) -> FlowDescriptor<K>

Builds the FlowDescriptor from the builder.