Struct BusBuilder 

pub struct BusBuilder<E: Clone + Send + 'static> { /* private fields */ }

Implementations

impl<E: Clone + Send + 'static> BusBuilder<E>

pub fn name(self, n: impl Into<String>) -> Self

pub fn cluster( self, local: Arc<DistributedPubSub>, cluster: Arc<ClusterPubSub>, ) -> Self

Available on crate feature bus-cluster only.

Enable cluster fan-out via atomr_cluster_tools::ClusterPubSub. The caller supplies a local atomr_cluster_tools::DistributedPubSub and a cluster wrapper already constructed against a transport. Combine with Self::topic, Self::type_id, and Self::codec to finish the wiring.

pub fn topic(self, topic: impl Into<String>) -> Self

Available on crate feature bus-cluster only.

Set the cluster-wide topic name. Defaults to the bus name. No-op unless cluster() was called first.

pub fn type_id(self, id: impl Into<String>) -> Self

Available on crate feature bus-cluster only.

Set the cross-node type tag used to dispatch incoming PDUs. Defaults to the topic.

pub fn codec<EncFn, DecFn>(self, encode: EncFn, decode: DecFn) -> Self

where EncFn: Fn(&E) -> Vec<u8> + Send + Sync + 'static, DecFn: Fn(&[u8]) -> Result<E, String> + Send + Sync + 'static,

Available on crate feature bus-cluster only.

Provide encode/decode closures for cross-node delivery. encode is called for each publish; decode runs on inbound PDUs from peer nodes.

pub fn build(self) -> BusTopology<E>