Enum SeaMessage

pub enum SeaMessage<'a> {
    Stdio(SharedMessage),
    None(PhantomData<&'a ()>),
}

sea-streamer-socket concrete type of Message.

Variants

Stdio(SharedMessage)

None(PhantomData<&'a ()>)

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)

tuple to uniquely identify a message

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

type Stdio = SharedMessage

fn backend(&self) -> Backend

Identifies the underlying backend

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

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