Struct GroupOpts 

pub struct GroupOpts {
    pub group_id: String,
    pub shard_count: Option<u32>,
    pub instance_id: Option<String>,
}

Options specific to consumer-group subscriptions.

Used with SubscribeOpts::consumer_group. Checkpoints are owned by group_id × shard, not per-instance subscription names.

Fields

group_id: String

Stable consumer group identifier (shared across replicas).

shard_count: Option<u32>

Override virtual shard count (defaults to topic #[photon::topic(shards = ...)]).

instance_id: Option<String>

Fleet member id for lease coordination (static env assignment when unset).

Implementations

impl GroupOpts

pub fn new(group_id: impl Into<String>) -> GroupOpts

Create group options with the given group_id.

pub const fn shards(self, count: u32) -> GroupOpts

Override virtual shard count for this subscription.

pub fn instance_id(self, id: impl Into<String>) -> GroupOpts

Set fleet member instance id for lease-based assignment.

Trait Implementations

impl Clone for GroupOpts

fn clone(&self) -> GroupOpts

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GroupOpts

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

Formats the value using the given formatter.