Struct xstack::SwitchBuilder

pub struct SwitchBuilder { /* private fields */ }

A builder to create the Switch instance.

Implementations

impl SwitchBuilder

pub fn connector<C>(self, value: C) -> Self

where C: DriverConnector + 'static,

/// Replace default ConnPool.

pub fn event_mediator<K>(self, value: K) -> Self

where K: DriverEventMediator + 'static,

Replace default SyncEventMediator.

pub fn keystore<K>(self, value: K) -> Self

where K: DriverKeyStore + 'static,

Replace default MemoryKeyStore.

pub fn stream_dispatcher<K>(self, value: K) -> Self

where K: DriverStreamDispatcher + 'static,

Replace default MutexStreamDispatcher.

pub fn peer_book<R>(self, value: R) -> Self

where R: DriverPeerBook + 'static,

Replace default MemoryPeerBook.

pub fn timeout(self, duration: Duration) -> Self

Set the protocol timeout, the default value is 10s

pub fn max_observed_addrs_len(self, value: usize) -> Self

Set the maximum length of observed addresses buffer.

pub fn max_packet_size(self, value: usize) -> Self

Set the maximum length of incoming rpc packets. the default value is 1024 * 1024 * 4

pub fn connect_replication(self, value: usize) -> Self

Set the maximum number of concurrent connection tasks launched to a peer, the default value is 5

pub fn transport<T>(self, value: T) -> Self

where T: DriverTransport + 'static,

Register a new transport driver for the switch.

pub fn transport_bind<I, E>(self, laddrs: I) -> Self

where I: IntoIterator, I::Item: TryInto<Multiaddr, Error = E>, Error: From<E>,

pub async fn create(self) -> Result<Switch>

Consume the builder and create a new Switch instance.