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.