Struct WirePollingStrategy 

pub struct WirePollingStrategy {
    pub kind: u8,
    pub value: u64,
}

Polling strategy for consuming messages.

Wire format: [kind:1][value:8] = 9 bytes fixed.

• Offset(1): resume from a specific offset
• Timestamp(2): resume from a specific timestamp (microseconds)
• First(3): start from the beginning
• Last(4): start from the end
• Next(5): continue from last stored offset

Fields

kind: u8

value: u64

Implementations

impl WirePollingStrategy

pub const fn offset(value: u64) -> Self

pub const fn timestamp(value: u64) -> Self

pub const fn first() -> Self

pub const fn last() -> Self

pub const fn next() -> Self

Trait Implementations

impl Clone for WirePollingStrategy

fn clone(&self) -> WirePollingStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WirePollingStrategy

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

Formats the value using the given formatter.

impl Eq for WirePollingStrategy

impl PartialEq for WirePollingStrategy

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for WirePollingStrategy

impl WireDecode for WirePollingStrategy

fn decode(buf: &[u8]) -> Result<(Self, usize), WireError>

Decode from buf, consuming exactly the bytes needed. Returns the decoded value and the number of bytes consumed.

fn decode_from(buf: &[u8]) -> Result<Self, WireError>

Convenience: decode from the entire buffer, ignoring trailing bytes.

impl WireEncode for WirePollingStrategy

fn encoded_size(&self) -> usize

Return the exact encoded size in bytes.

fn encode(&self, buf: &mut BytesMut)

Write the encoded representation into buf.

fn to_bytes(&self) -> Bytes

Convenience: allocate a new Bytes and encode into it.