Struct HandlerDescriptor 

pub struct HandlerDescriptor {
    pub topic_name: &'static str,
    pub subscription_name: &'static str,
    pub registry_key: &'static str,
    pub invoke: HandlerInvoker,
    pub consumer_group: Option<&'static str>,
    pub group_shard_count: Option<u32>,
}

Descriptor for a #[photon::subscribe] handler (inventory + executor dispatch).

Fields

topic_name: &'static str

Topic this handler listens on.

subscription_name: &'static str

Durable subscription name for broadcast handlers (empty for group handlers).

registry_key: &'static str

Stable registry key ({topic}:{subscription} or {topic}:group:{group}).

invoke: HandlerInvoker

Async dispatch entry point generated by the proc macro.

consumer_group: Option<&'static str>

Consumer group id when load-balanced (mutually exclusive with durable name).

group_shard_count: Option<u32>

Override virtual shard count for group handlers.

Implementations

impl HandlerDescriptor

pub const fn new( topic_name: &'static str, subscription_name: &'static str, registry_key: &'static str, invoke: HandlerInvoker, ) -> Self

Create a broadcast handler descriptor for inventory submission.

pub const fn new_group( topic_name: &'static str, consumer_group: &'static str, group_shard_count: Option<u32>, registry_key: &'static str, invoke: HandlerInvoker, ) -> Self

Create a consumer-group handler descriptor.

pub const fn is_consumer_group(&self) -> bool

Whether this handler uses consumer-group delivery.

Trait Implementations

impl Clone for HandlerDescriptor

fn clone(&self) -> HandlerDescriptor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Collect for HandlerDescriptor

impl Copy for HandlerDescriptor

impl Registrable for HandlerDescriptor

fn registry_key(&self) -> &str

Return the unique lookup key used by the registry.