Struct WebhookSubscription 

pub struct WebhookSubscription { /* private fields */ }

Static config for one webhook subscriber, plus convenience methods to register the delivery handler and dispatch events.

Keep one of these per subscription. Cheap to clone.

Implementations

impl WebhookSubscription

pub fn new(target_url: impl Into<String>, secret: impl Into<String>) -> Self

pub fn signature_format(self, fmt: SignatureFormat) -> Self

pub fn header(self, name: impl Into<String>, value: impl Into<String>) -> Self

pub fn timeout(self, t: Duration) -> Self

pub fn retry_status_codes(self, codes: impl IntoIterator<Item = u16>) -> Self

Add status codes that should be retried in addition to the defaults (408, 429, 5xx).

pub async fn register<Q: JobQueue>(queue: &Q)

Register the delivery Job on queue. Idempotent — call once per process at startup before Self::dispatch.

pub async fn dispatch<Q: JobQueue>( &self, queue: &Q, event_name: impl Into<String>, payload: impl Serialize, ) -> Result<String, JobError>

Build a WebhookEvent and enqueue it. Returns immediately — delivery happens asynchronously on a worker.

Errors

Returns the underlying JobError::Queue when the enqueue fails (DB unavailable, channel closed, payload not serializable).

Trait Implementations

impl Clone for WebhookSubscription

fn clone(&self) -> WebhookSubscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WebhookSubscription

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

Formats the value using the given formatter.