Struct WebhookAdapter 

pub struct WebhookAdapter { /* private fields */ }

Webhook transport adapter for HTTP POST delivery.

Delivers subscription events via HTTP POST with:

• HMAC-SHA256 signature (X-FraiseQL-Signature header)
• Exponential backoff retry logic
• Configurable timeouts

Example

use fraiseql_core::runtime::subscription::{WebhookAdapter, WebhookConfig};

let config = WebhookConfig::new("https://api.example.com/webhooks")
    .with_secret("my_secret_key")
    .with_max_retries(3);

let adapter = WebhookAdapter::new(config);
adapter.deliver(&event, "orderCreated").await?;

Implementations

impl WebhookAdapter

pub fn new(config: WebhookConfig) -> Self

Create a new webhook adapter.

Panics

Panics if the HTTP client cannot be built (should not happen in practice).

Trait Implementations

impl Debug for WebhookAdapter

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

Formats the value using the given formatter.

impl TransportAdapter for WebhookAdapter

fn deliver<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, event: &'life1 SubscriptionEvent, subscription_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), SubscriptionError>> + Send + 'async_trait>>

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

Deliver an event to the transport.

fn name(&self) -> &'static str

Get the adapter name for logging/metrics.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

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

Check if the adapter is healthy/connected.