Struct WebhookOutboundManager 

pub struct WebhookOutboundManager { /* private fields */ }

The runtime manager for outbound webhooks.

Implementations

impl WebhookOutboundManager

pub fn new(handler: Arc<dyn OutboundWebhookHandler>) -> Self

Create a new webhook manager with a handler.

pub const fn with_max_attempts(self, max_attempts: u32) -> Self

Set the number of delivery attempts per webhook. Default: 5. A value of 0 is read as 1. The last failed attempt moves the delivery to the DLQ.

This does not change the autumn_webhook_delivery job. That job needs 2 job attempts per delivery attempt. Use OutboundWebhookPlugin::with_max_attempts, which sets both.

pub const fn max_attempts(&self) -> u32

The number of delivery attempts per webhook.

pub const fn with_initial_backoff_ms(self, ms: u64) -> Self

Set a custom initial backoff for retries.

pub fn store(&self) -> &Arc<dyn OutboundWebhookHandler>

Access the underlying webhook handler (compatibility/actuator support).

pub const fn client(&self) -> &Client

Access the underlying http client.

pub async fn dispatch<T: Serialize + Sync>( &self, state: &AppState, topic: &str, payload: &T, ) -> AutumnResult<()>

Dispatch a signed webhook payload to all subscriptions interested in topic.

Errors

Returns AutumnError if payload serialization or queueing fails.

pub async fn dispatch_in_tx<T: Serialize + Sync + ?Sized>( &self, state: &AppState, conn: &mut RuntimeConnection, topic: &str, payload: &T, ) -> AutumnResult<String>

Dispatch through the transactional outbox, on the connection of the open transaction. Returns the outbox message id.

The relay calls dispatch after commit. See Outbox::dispatch_webhook.

Errors

Returns AutumnError if serialization or the outbox insert fails.

Trait Implementations

impl Clone for WebhookOutboundManager

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.