Struct ChannelProgress 

pub struct ChannelProgress {
    pub participant_id: u64,
    pub source_name: String,
    pub input_channel: Vec<u8>,
    pub watermark: Option<i64>,
    pub idle: bool,
}

Watermark and idleness state for one stable input channel.

Fields

participant_id: u64

Participant owning this channel state.

source_name: String

Stable registered source name.

input_channel: Vec<u8>

Reserved logical singleton or opaque physical input-channel identity.

watermark: Option<i64>

Watermark when initialized; None before the channel emits one.

idle: bool

Whether the channel is excluded from the active watermark minimum.

Trait Implementations

impl Clone for ChannelProgress

fn clone(&self) -> ChannelProgress

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChannelProgress

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ChannelProgress

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ChannelProgress

impl PartialEq for ChannelProgress

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ChannelProgress

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ChannelProgress