Struct DeleteConsumerOffset 

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

DeleteConsumerOffset command deletes the offset of a consumer from a given partition on the server. It has additional payload:

• consumer - the consumer that is deleting 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).

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).

Trait Implementations

impl BytesSerializable for DeleteConsumerOffset

fn to_bytes(&self) -> Bytes

Serializes the struct to bytes.

fn from_bytes(bytes: Bytes) -> Result<DeleteConsumerOffset, 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 DeleteConsumerOffset

fn code(&self) -> u32

impl Debug for DeleteConsumerOffset

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

Formats the value using the given formatter.

impl Default for DeleteConsumerOffset

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for DeleteConsumerOffset

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for DeleteConsumerOffset

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

Formats the value using the given formatter.

impl PartialEq for DeleteConsumerOffset

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

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 DeleteConsumerOffset

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

impl StructuralPartialEq for DeleteConsumerOffset