Struct Dispatcher 

pub struct Dispatcher { /* private fields */ }

Sends webhook deliveries (cheap to clone).

Implementations

impl Dispatcher

pub fn from_config(config: &Config) -> Result<Dispatcher>

pub fn new(public_url: &str, config: &WebhookConfig) -> Result<Dispatcher>

pub fn with_lookup( public_url: &str, config: &WebhookConfig, lookup: Lookup, ) -> Result<Dispatcher>

A dispatcher whose connections resolve host names with lookup (tests; Dispatcher::new uses the system resolver).

pub fn policy(&self) -> &TargetPolicy

pub async fn run_once(&self, pool: &PgPool) -> AppResult<Report>

Sends the due deliveries (up to BATCH at once).

pub async fn deliver_now( &self, pool: &PgPool, delivery_id: Uuid, ) -> AppResult<Option<Outcome>>

Sends one due delivery now (“Send test”, “Retry” – both make it due at once). None if it is not pending, or another sender holds it: a claimed row is leased (next_attempt_at in the future) and must not be sent a second time while that attempt may still be running.

Trait Implementations

impl Clone for Dispatcher

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.