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.