Struct ConsumerConnection 

pub struct ConsumerConnection { /* private fields */ }

Represents a consumer connection with subscription information.

This struct is serialization-compatible with Java’s ConsumerConnection class. It contains consumer connection details, subscription data, and consumption configuration.

Implementations

impl ConsumerConnection

pub fn new() -> Self

Creates a new ConsumerConnection instance.

pub fn compute_min_version(&self) -> i32

Computes the minimum version across all connections.

This method iterates through all connections and finds the minimum version number. Returns i32::MAX if there are no connections.

Returns

The minimum version number, or i32::MAX if connection set is empty

pub fn get_connection_set(&self) -> &HashSet<Connection>

Gets a clone of the connection set.

Returns

A cloned HashSet of all connections

pub fn set_connection_set(&mut self, connection_set: HashSet<Connection>)

Sets the connection set.

Arguments

• connection_set - The new set of connections

pub fn insert_connection(&mut self, connection: Connection) -> bool

Inserts a connection into the connection set.

Arguments

• connection - The connection to insert

Returns

true if the connection was newly inserted, false if it already existed

pub fn get_subscription_table( &self, ) -> &HashMap<CheetahString, SubscriptionData>

Gets a reference to the subscription table.

Returns

Reference to the subscription table (Topic -> SubscriptionData mapping)

pub fn get_subscription_table_mut( &mut self, ) -> &mut HashMap<CheetahString, SubscriptionData>

Gets a mutable reference to the subscription table.

Returns

Mutable reference to the subscription table

pub fn set_subscription_table( &mut self, subscription_table: HashMap<CheetahString, SubscriptionData>, )

Sets the subscription table.

Arguments

• subscription_table - The new subscription table

pub fn get_consume_type(&self) -> Option<ConsumeType>

Gets the consume type.

Returns

The consume type, or None if not set

pub fn set_consume_type(&mut self, consume_type: ConsumeType)

Sets the consume type.

Arguments

• consume_type - The consume type (push/pull)

pub fn get_message_model(&self) -> Option<MessageModel>

Gets the message model.

Returns

The message model, or None if not set

pub fn set_message_model(&mut self, message_model: MessageModel)

Sets the message model.

Arguments

• message_model - The message model (clustering/broadcasting)

pub fn get_consume_from_where(&self) -> Option<ConsumeFromWhere>

Gets the consume from where setting.

Returns

The consume from where setting, or None if not set

pub fn set_consume_from_where(&mut self, consume_from_where: ConsumeFromWhere)

Sets the consume from where setting.

Arguments

• consume_from_where - Where to start consuming from

Trait Implementations

impl Clone for ConsumerConnection

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerConnection

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

Formats the value using the given formatter.

impl Default for ConsumerConnection

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ConsumerConnection

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ConsumerConnection

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

where __S: Serializer,

Serialize this value into the given Serde serializer.