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, created by the factory, mirroring AnySender.
AnySender
Type-erased transport sender, created by the factory from config.
AnyToken
Type-erased commit token produced by AnyReceiver.