Struct WebhookLifecycle 

pub struct WebhookLifecycle { /* private fields */ }

Subscription lifecycle hooks that call external HTTP endpoints.

Implementations

impl WebhookLifecycle

pub fn new( on_connect_url: Option<String>, on_disconnect_url: Option<String>, on_subscribe_url: Option<String>, on_unsubscribe_url: Option<String>, timeout_ms: u64, ) -> Self

Create a new webhook lifecycle from configured URLs.

timeout_ms controls the maximum time to wait for on_connect and on_subscribe responses. on_disconnect and on_unsubscribe are fire-and-forget (timeout is irrelevant for those hooks).

pub fn from_config(config: &SubscriptionsConfig) -> Option<Self>

Build from typed subscriptions configuration.

Returns None if no hooks are configured.

pub fn from_schema_json(subscriptions: &Value) -> Option<Self>

Build from compiled schema JSON (subscriptions.hooks section).

Returns None if no hooks are configured.

Trait Implementations

impl SubscriptionLifecycle for WebhookLifecycle

fn on_connect<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, params: &'life1 Value, connection_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Errors

Returns an error string if the HTTP POST to the on_connect webhook URL fails or returns a non-2xx status code.

fn on_subscribe<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, subscription_name: &'life1 str, variables: &'life2 Value, connection_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Errors

Returns an error string if the HTTP POST to the on_subscribe webhook URL fails or returns a non-2xx status code.

fn on_disconnect<'life0, 'life1, 'async_trait>( &'life0 self, connection_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when the WebSocket connection closes (for any reason).

fn on_unsubscribe<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, subscription_id: &'life1 str, connection_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a client sends complete for a subscription.