Struct sea_streamer::SharedMessage

pub struct SharedMessage { /* private fields */ }

It uses an Arc to hold the bytes, so is cheap to clone.

Implementations

impl SharedMessage

pub fn new( header: MessageHeader, bytes: Vec<u8, Global>, offset: usize, length: usize ) -> SharedMessage

pub fn touch(&mut self)

Touch the timestamp to now

pub fn header(&self) -> &MessageHeader

pub fn take_header(self) -> MessageHeader

Trait Implementations

impl Clone for SharedMessage

fn clone(&self) -> SharedMessage

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SharedMessage

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

Formats the value using the given formatter.

impl Hash for SharedMessage

fn hash<__H>(&self, state: &mut __H)where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Message for SharedMessage

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 PartialEq<SharedMessage> for SharedMessage

fn eq(&self, other: &SharedMessage) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for SharedMessage

impl StructuralEq for SharedMessage

impl StructuralPartialEq for SharedMessage