Struct 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>, 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

pub fn to_owned_message(self) -> OwnedMessage

This will attempt to convert self into an OwnedMessage without copying, if the bytes are not shared with any other.

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

fn from_msg(msg: &SeaMessage<'_>, _app: &App) -> Self

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)

tuple to uniquely identify a message

impl PartialEq for SharedMessage

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl Eq for SharedMessage

impl StructuralPartialEq for SharedMessage