Trait Encodeable 

pub trait Encodeable {
    type Output: Send + Sync;
    type Encoder: Encoder<Message = Self::Output>;

    // Required method
    fn encode(
        self,
        encoder: &mut Self::Encoder,
        stream_id: &Uuid,
        run: Option<&Run>,
    ) -> Option<Self::Output>;
}

Implemented by types that can be encoded and sent via SiftStream::send.

The two concrete implementations are Flow and FlowBuilder. The associated Encoder type links each encodeable to the specific encoder implementation that processes it — external types cannot implement this trait because Encoder is sealed.

Required Associated Types

type Output: Send + Sync

type Encoder: Encoder<Message = Self::Output>

Required Methods

fn encode( self, encoder: &mut Self::Encoder, stream_id: &Uuid, run: Option<&Run>, ) -> Option<Self::Output>

Implementors

impl Encodeable for Flow

type Output = IngestWithConfigDataStreamRequest

type Encoder = IngestionConfigEncoder

impl<K> Encodeable for FlowBuilder<'_, K>

where K: Eq + Hash,

type Output = IngestWithConfigDataStreamRequest

type Encoder = IngestionConfigEncoder