Skip to main content

Module factory

Module factory 

Source
Available on crate feature transport only.
Expand description

Transport factory for runtime transport selection.

Creates transport senders from configuration, enabling apps to swap between Kafka, gRPC, file, pipe, HTTP, or Redis via config change.

§Usage

# settings.yaml
transport:
  output:
    type: kafka
    kafka:
      brokers: ["kafka:9092"]
use hyperi_rustlib::transport::factory::AnySender;

let sender = AnySender::from_config("transport.output").await?;
sender.send("events.land", payload).await;

Enums§

AnyReceiver
Type-erased transport receiver.
AnySender
Type-erased transport sender.
AnyToken
Type-erased commit token produced by AnyReceiver.