Enum AnySender 

pub enum AnySender {
    Grpc(GrpcTransport),
    Memory(MemoryTransport),
    Pipe(PipeTransport),
    File(FileTransport),
    Http(HttpTransport),
    Redis(RedisTransport),
}

Available on crate feature transport only.

Type-erased transport sender.

Wraps any concrete transport sender behind an enum for runtime dispatch. Created by the transport factory from config.

Uses enum dispatch (not trait objects) because TransportSender has impl Future return types which prevent dyn dispatch.

Variants

Grpc(GrpcTransport)

Available on crate feature transport-grpc only.

Memory(MemoryTransport)

Available on crate feature transport-memory only.

Pipe(PipeTransport)

Available on crate feature transport-pipe only.

File(FileTransport)

Available on crate feature transport-file only.

Http(HttpTransport)

Available on crate feature transport-http only.

Redis(RedisTransport)

Available on crate feature transport-redis only.

Implementations

impl AnySender

pub async fn from_config(key: &str) -> TransportResult<Self>

Create a sender from config cascade.

Reads the transport config from the given key in the config cascade and creates the appropriate sender.

Example config

transport:
  output:
    type: kafka
    kafka:
      brokers: ["kafka:9092"]

let sender = AnySender::from_config("transport.output").await?;

pub async fn from_transport_config( config: &TransportConfig, ) -> TransportResult<Self>

Create a sender from an explicit TransportConfig.

Trait Implementations

impl TransportBase for AnySender

async fn close(&self) -> TransportResult<()>

Shutdown the transport gracefully.

fn is_healthy(&self) -> bool

Check if the transport is healthy and connected.

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

Get transport name for logging/metrics.

impl TransportSender for AnySender

async fn send_batch(&self, records: &[Record]) -> SendResult

Forward send_batch to the active backend. gRPC uses its native single-RPC RouteBatch override; every other backend uses the trait’s per-record default (see the at-least-once partial-send caveat on the trait method).

async fn send(&self, key: &str, payload: Bytes) -> SendResult

Send raw bytes to a key/destination.