Enum SeaMessage 

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

sea-streamer-socket concrete type of Message.

Variants

Stdio(StdioMessage)

Available on crate feature backend-stdio only.

None(PhantomData<&'a ()>)

Available on non-crate feature backend-kafka only.

Trait Implementations

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

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

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) -> SeqNo

fn timestamp(&self) -> Timestamp

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

Available on crate feature backend-stdio only.

fn backend(&self) -> Backend

Identifies the underlying backend

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

Available on crate feature backend-stdio only.

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