Struct TransportManager 

pub struct TransportManager { /* private fields */ }

Multi-transport delivery manager.

Manages multiple transport adapters and delivers events to all configured destinations in parallel.

Example

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

let mut manager = TransportManager::new();

// Add webhook adapter
let webhook = WebhookAdapter::new(WebhookConfig::new("https://api.example.com/events"));
manager.add_adapter(Box::new(webhook));

// Deliver to all transports
manager.deliver_all(&event, "orderCreated").await?;

Implementations

impl TransportManager

pub fn new() -> Self

Create a new transport manager.

pub fn add_adapter(&mut self, adapter: Box<dyn TransportAdapter>)

Add a transport adapter.

pub fn adapter_count(&self) -> usize

Get the number of configured adapters.

pub fn is_empty(&self) -> bool

Check if there are no adapters configured.

pub async fn deliver_all( &self, event: &SubscriptionEvent, subscription_name: &str, ) -> Result<DeliveryResult, SubscriptionError>

Deliver an event to all configured transports.

Delivers in parallel and collects results. Returns Ok if at least one delivery succeeded, or the last error if all failed.

pub async fn health_check_all(&self) -> Vec<(String, bool)>

Check health of all adapters.

Trait Implementations

impl Debug for TransportManager

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

Formats the value using the given formatter.

impl Default for TransportManager

fn default() -> Self

Returns the “default value” for a type.