Enum sea_streamer::SeaMessage

pub enum SeaMessage<'a> {
    Kafka(KafkaMessage<'a>),
    Stdio(SharedMessage),
}

Available on crate feature sea-streamer-socket only.

sea-streamer-socket concrete type of Message.

Variants

Kafka(KafkaMessage<'a>)

Stdio(SharedMessage)

Trait Implementations

impl<'a> Debug for SeaMessage<'a>

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

Formats the value using the given formatter.

impl<'a> Message for SeaMessage<'a>

fn stream_key(&self) -> StreamKey

fn shard_id(&self) -> ShardId

fn sequence(&self) -> u64

fn timestamp(&self) -> OffsetDateTime

fn message(&self) -> Payload<'_>

fn to_owned(&self) -> SharedMessage

fn identifier(&self) -> (StreamKey, ShardId, u64)

impl<'a> SeaStreamerBackend for SeaMessage<'a>

type Kafka = KafkaMessage<'a>

type Stdio = SharedMessage

fn backend(&self) -> Backend

Identifies the underlying backend

fn get_kafka(&mut self) -> Option<&mut KafkaMessage<'a>>

Get the concrete type for the Kafka backend. None if it’s another Backend

fn get_stdio(&mut self) -> Option<&mut SharedMessage>

Get the concrete type for the Stdio backend. None if it’s another Backend