Enum MessageInner

pub enum MessageInner<M> {
    Chunk(StreamChunk),
    Barrier(BarrierInner<M>),
    Watermark(Watermark),
}

Variants

Chunk(StreamChunk)

Barrier(BarrierInner<M>)

Watermark(Watermark)

Implementations

impl<M> MessageInner<M>

pub fn is_chunk(&self) -> bool

Returns true if this is a MessageInner::Chunk, otherwise false

pub fn as_chunk_mut(&mut self) -> Option<&mut StreamChunk>

Optionally returns mutable references to the inner fields if this is a MessageInner::Chunk, otherwise None

pub fn as_chunk(&self) -> Option<&StreamChunk>

Optionally returns references to the inner fields if this is a MessageInner::Chunk, otherwise None

pub fn into_chunk(self) -> Result<StreamChunk, Self>

Returns the inner fields if this is a MessageInner::Chunk, otherwise returns back the enum in the Err case of the result

pub fn is_barrier(&self) -> bool

Returns true if this is a MessageInner::Barrier, otherwise false

pub fn as_barrier_mut(&mut self) -> Option<&mut BarrierInner<M>>

Optionally returns mutable references to the inner fields if this is a MessageInner::Barrier, otherwise None

pub fn as_barrier(&self) -> Option<&BarrierInner<M>>

Optionally returns references to the inner fields if this is a MessageInner::Barrier, otherwise None

pub fn into_barrier(self) -> Result<BarrierInner<M>, Self>

Returns the inner fields if this is a MessageInner::Barrier, otherwise returns back the enum in the Err case of the result

pub fn is_watermark(&self) -> bool

Returns true if this is a MessageInner::Watermark, otherwise false

pub fn as_watermark_mut(&mut self) -> Option<&mut Watermark>

Optionally returns mutable references to the inner fields if this is a MessageInner::Watermark, otherwise None

pub fn as_watermark(&self) -> Option<&Watermark>

Optionally returns references to the inner fields if this is a MessageInner::Watermark, otherwise None

pub fn into_watermark(self) -> Result<Watermark, Self>

Returns the inner fields if this is a MessageInner::Watermark, otherwise returns back the enum in the Err case of the result

impl<M> MessageInner<M>

pub fn map_mutation<M2>(self, f: impl FnOnce(M) -> M2) -> MessageInner<M2>

impl MessageInner<()>

pub fn to_protobuf(&self) -> PbStreamMessage

pub fn from_protobuf(prost: &PbStreamMessage) -> StreamExecutorResult<Self>

pub fn get_encoded_len(msg: &impl Message) -> usize

Trait Implementations

impl<M: Clone> Clone for MessageInner<M>

fn clone(&self) -> MessageInner<M>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<M: Debug> Debug for MessageInner<M>

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

Formats the value using the given formatter.

impl<M: PartialEq> PartialEq for MessageInner<M>

fn eq(&self, other: &MessageInner<M>) -> 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<'a> TryFrom<&'a MessageInner<Option<Arc<Mutation>>>> for &'a Barrier

type Error = ()

The type returned in the event of a conversion error.

fn try_from(m: &'a Message) -> Result<Self, Self::Error>

Performs the conversion.

impl<M> StructuralPartialEq for MessageInner<M>