Struct StoreConsumerOffset 

pub struct StoreConsumerOffset {
    pub consumer: Consumer,
    pub stream_id: Identifier,
    pub topic_id: Identifier,
    pub partition_id: Option<u32>,
    pub offset: u64,
}

StoreConsumerOffset command stores the offset of a consumer for a given partition on the server. It has additional payload:

• consumer - the consumer that is storing the offset, either the regular consumer or the consumer group.
• stream_id - unique stream ID (numeric or name).
• topic_id - unique topic ID (numeric or name).
• partition_id - partition ID on which the offset is stored. Has to be specified for the regular consumer. For consumer group it is ignored (use None).
• offset - offset to store.

Fields

consumer: Consumer

The consumer that is storing the offset, either the regular consumer or the consumer group.

stream_id: Identifier

Unique stream ID (numeric or name).

topic_id: Identifier

Unique topic ID (numeric or name).

partition_id: Option<u32>

Partition ID on which the offset is stored. Has to be specified for the regular consumer. For consumer group it is ignored (use None).

offset: u64

Offset to store.

Trait Implementations

impl BytesSerializable for StoreConsumerOffset

fn to_bytes(&self) -> Bytes

Serializes the struct to bytes.

fn from_bytes(bytes: Bytes) -> Result<StoreConsumerOffset, IggyError>

Deserializes the struct from bytes.

fn write_to_buffer(&self, _buf: &mut BytesMut)

Write the struct to a buffer.

fn get_buffer_size(&self) -> usize

Get the byte-size of the struct.

impl Command for StoreConsumerOffset

fn code(&self) -> u32

impl Debug for StoreConsumerOffset

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

Formats the value using the given formatter.

impl Default for StoreConsumerOffset

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StoreConsumerOffset

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for StoreConsumerOffset

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

Formats the value using the given formatter.

impl PartialEq for StoreConsumerOffset

fn eq(&self, other: &StoreConsumerOffset) -> 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 Serialize for StoreConsumerOffset

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Validatable<IggyError> for StoreConsumerOffset

fn validate(&self) -> Result<(), IggyError>

impl StructuralPartialEq for StoreConsumerOffset