Struct Hooks 

pub struct Hooks { /* private fields */ }

Handle held by the platform. Cloneable so the writer thread’s copy costs nothing; the delivery thread lives as long as the process.

Implementations

impl Hooks

pub fn start(config: PathBuf, log: PathBuf) -> Result<Self, String>

Starts the delivery thread for the subscriptions in config, writing delivery records to log.

Errors

Returns a message when the subscription file cannot be read or does not parse. Fatal at startup by design: an operator who asked for webhooks and got a typo should be told now, not by silence later.

pub fn offer(&self, event: RefEvent)

Offers an event to the delivery thread. Never blocks: this runs on the sequencer’s writer thread, where waiting on a receiver would put a stranger’s latency in front of op admission (invariant 5). A full queue drops the event and counts it.

pub fn dropped(&self) -> u64

Events dropped because the queue was full (or the delivery thread was gone). Also written to the delivery log; exposed for tests and for anything that wants the count without parsing it back.

Trait Implementations

impl Clone for Hooks

fn clone(&self) -> Hooks

Returns a duplicate of the value.

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

Performs copy-assignment from source.