pub struct RestHookChannel { /* private fields */ }Expand description
REST-hook channel implementation.
Uses an HTTP client to POST notification bundles to subscriber endpoints. Supports custom headers and TLS enforcement for full-resource payloads.
Implementations§
Source§impl RestHookChannel
impl RestHookChannel
Sourcepub fn with_client(client: Client) -> Self
pub fn with_client(client: Client) -> Self
Creates a new REST-hook channel with a custom HTTP client.
Trait Implementations§
Source§impl ChannelDispatcher for RestHookChannel
impl ChannelDispatcher for RestHookChannel
Source§fn dispatch<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
subscription: &'life1 ActiveSubscription,
notification_bundle: &'life2 Value,
) -> Pin<Box<dyn Future<Output = Result<DispatchResult, SubscriptionError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn dispatch<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
subscription: &'life1 ActiveSubscription,
notification_bundle: &'life2 Value,
) -> Pin<Box<dyn Future<Output = Result<DispatchResult, SubscriptionError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Deliver a notification bundle to the subscriber’s endpoint.
Source§fn handshake<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
subscription: &'life1 ActiveSubscription,
handshake_bundle: &'life2 Value,
) -> Pin<Box<dyn Future<Output = Result<DispatchResult, SubscriptionError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn handshake<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
subscription: &'life1 ActiveSubscription,
handshake_bundle: &'life2 Value,
) -> Pin<Box<dyn Future<Output = Result<DispatchResult, SubscriptionError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Perform the handshake sequence for a newly activated subscription.
Auto Trait Implementations§
impl !RefUnwindSafe for RestHookChannel
impl !UnwindSafe for RestHookChannel
impl Freeze for RestHookChannel
impl Send for RestHookChannel
impl Sync for RestHookChannel
impl Unpin for RestHookChannel
impl UnsafeUnpin for RestHookChannel
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more