Trait sea_streamer::Message

pub trait Message: Send {
    // Required methods
    fn stream_key(&self) -> StreamKey;
    fn shard_id(&self) -> ShardId;
    fn sequence(&self) -> u64;
    fn timestamp(&self) -> OffsetDateTime;
    fn message(&self) -> Payload<'_>;

    // Provided methods
    fn to_owned(&self) -> SharedMessage { ... }
    fn identifier(&self) -> (StreamKey, ShardId, u64) { ... }
}

Common interface of messages, to be implemented by all backends.

Required Methods

fn stream_key(&self) -> StreamKey

fn shard_id(&self) -> ShardId

fn sequence(&self) -> u64

fn timestamp(&self) -> OffsetDateTime

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

Provided Methods

fn to_owned(&self) -> SharedMessage

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

Implementations on Foreign Types

impl<'a> Message for KafkaMessage<'a>

fn stream_key(&self) -> StreamKey

fn shard_id(&self) -> ShardId

fn sequence(&self) -> u64

fn timestamp(&self) -> OffsetDateTime

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

Implementors

impl Message for OwnedMessage

impl Message for SharedMessage

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