Struct RemoteOutcomes 

pub struct RemoteOutcomes<C> { /* private fields */ }

Stage 8 over HooksService.Outcome: any 2xx acknowledges, everything else leaves the outcome queued for kind 8’s backoff.

Implementations

impl<C> RemoteOutcomes<C>

pub fn new(client: Arc<HookClient<C>>) -> Self

The role over a shared client, with the default 5 s timeout.

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

Bound each call by timeout.

Trait Implementations

impl<C> Clone for RemoteOutcomes<C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C> Debug for RemoteOutcomes<C>

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

Formats the value using the given formatter.

impl<C: HookChannel> OutcomeSink for RemoteOutcomes<C>

async fn deliver(&self, outcome: &Outcome) -> Result<(), DeliveryError>

Deliver one terminal outcome. Every error leaves it queued for retry.

fn deliver_batch( &self, outcomes: &[Outcome], ) -> impl Future<Output = Vec<Result<(), DeliveryError>>> + MaybeSend

Deliver a batch sequentially by default; each result is independent.