Struct GetConsumerGroups 

pub struct GetConsumerGroups {
    pub stream_id: Identifier,
    pub topic_id: Identifier,
}

GetConsumerGroups command retrieves the consumer groups from the topic. It has additional payload:

• stream_id - unique stream ID (numeric or name).
• topic_id - unique topic ID (numeric or name).

Fields

stream_id: Identifier

Unique stream ID (numeric or name).

topic_id: Identifier

Unique topic ID (numeric or name).

Trait Implementations

impl BytesSerializable for GetConsumerGroups

fn to_bytes(&self) -> Bytes

Serializes the struct to bytes.

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

fn code(&self) -> u32

impl Debug for GetConsumerGroups

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

Formats the value using the given formatter.

impl Default for GetConsumerGroups

fn default() -> GetConsumerGroups

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for GetConsumerGroups

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for GetConsumerGroups

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

Formats the value using the given formatter.

impl PartialEq for GetConsumerGroups

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

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 GetConsumerGroups

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

impl StructuralPartialEq for GetConsumerGroups