Struct HandlerCtx 

pub struct HandlerCtx<'a> {
    pub event_id: &'a str,
    pub topic_name: &'a str,
    pub topic_key: Option<&'a str>,
    pub seq: i64,
}

Delivery metadata for a single handler invocation.

Inject as a trailing parameter on a #[photon::subscribe] handler (after actor and payload), alone or alongside &Event:

#[photon::subscribe(topic = "orders", durable = "worker")]
async fn on_order(
    _actor: Box<dyn Actor>,
    order: OrderPlaced,
    ctx: HandlerCtx<'_>,
) -> photon::Result<()> {
    tracing::info!(event_id = %ctx.event_id, seq = ctx.seq, "handling");
    Ok(())
}

Values borrow from the transport crate::models::Event passed to the generated invoker for the duration of the handler future.

Fields

event_id: &'a str

Unique event ID (UUID string from the transport event).

topic_name: &'a str

Topic name the event was published on.

topic_key: Option<&'a str>

Partition / routing key when the topic is keyed.

seq: i64

Monotonic sequence number for this topic (and key, when keyed).

Implementations

impl<'a> HandlerCtx<'a>

pub fn from_event(event: &'a Event) -> Self

Build from a transport crate::models::Event.

Trait Implementations

impl<'a> Clone for HandlerCtx<'a>

fn clone(&self) -> HandlerCtx<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for HandlerCtx<'a>

impl<'a> Debug for HandlerCtx<'a>

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

Formats the value using the given formatter.