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

// Requires: live HTTP endpoint for webhook delivery.
use fraiseql_core::runtime::subscription::{
    WebhookAdapter, WebhookTransportConfig, SubscriptionEvent, TransportAdapter,
};

let config = WebhookTransportConfig::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: WebhookTransportConfig) -> Result<Self, SubscriptionError>

Create a new webhook adapter.

Errors

Returns an error if the URL targets a private/reserved IP (SSRF protection), or if the underlying HTTP client cannot be initialized.

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.