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

// Requires: live transport destination (webhook/NATS/etc).
use fraiseql_core::runtime::subscription::{
    TransportManager, WebhookAdapter, WebhookTransportConfig, SubscriptionEvent,
};

let mut manager = TransportManager::new();

// Add webhook adapter
let webhook = WebhookAdapter::new(WebhookTransportConfig::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: BoxDynTransportAdapter)

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. Delivery failures are accumulated in DeliveryResult::errors rather than propagated as Err.

Errors

Currently infallible — always returns Ok. Individual adapter failures are captured in DeliveryResult::errors and do not short-circuit the method.

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.