Struct HookEventBroadcaster 

pub struct HookEventBroadcaster { /* private fields */ }

In-process pub/sub broker for hook events. Lives on GrpcLocalService so every handler shares the same broker and a subscribe_hook_events stream and a respond_to_hook reply meet on the same correlator.

Implementations

impl HookEventBroadcaster

pub fn new() -> Self

pub fn subscribe(&self) -> Receiver<ProtoHookEvent>

Subscribe a fresh stream. Each call returns its own mpsc::Receiver backed by a forwarding task that drains the underlying broadcast::Receiver. The mpsc shape lets us close the stream cleanly when the subscriber drops, and lets the Lagged error close the stream rather than panicking.

pub fn emit( &self, event_name: impl Into<String>, payload_json: impl Into<String>, ) -> String

Emit a fresh hook event. Returns the hook_event_id the caller should pass to Self::await_response. The id is a stringified UUIDv4 so it survives JSON round-trips intact.

payload_json is delivered verbatim — schema validation lives in the catalog (see GetHookEventSchema) and is the caller’s responsibility for now.

pub fn emit_and_wait( &self, event_name: impl Into<String>, payload_json: impl Into<String>, timeout: Duration, ) -> (String, EmitWaiter)

Register a single-shot response slot for hook_event_id and emit at the same time. Returns the id and a future that resolves to the hook’s reply (or times out).

Use this from the capture/merge code paths when you both want to fire the event and wait for the reply atomically.

pub async fn await_response( &self, hook_event_id: &str, timeout: Duration, ) -> Option<HookResponse>

Await a reply for hook_event_id with a deadline. Returns None when the deadline elapses before a hook responds (the emit caller’s “no hook acted on this in time” branch).

The slot must have been reserved via Self::emit_and_wait — calling this for a never-registered id resolves to None immediately.

pub fn deliver_response( &self, hook_event_id: &str, response: HookResponse, ) -> bool

Deliver a hook reply to the in-flight emit waiting on hook_event_id. Called by the RespondToHook handler. Returns true when the reply was delivered (a waiter was present); false when no waiter is registered (timed out, or already replied).

Trait Implementations

impl Clone for HookEventBroadcaster

fn clone(&self) -> HookEventBroadcaster

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for HookEventBroadcaster

fn default() -> Self

Returns the “default value” for a type.