Trait sea_streamer_types::Message

source ·

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

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