Struct ServerFlowConfiguration 

pub struct ServerFlowConfiguration<T: IdentityType + Clone, AE: AsyncExecutor> { /* private fields */ }

Configuration for a single server flow manager.

Implementations

impl<T: IdentityType + Clone + 'static, AE: AsyncExecutor + 'static> ServerFlowConfiguration<T, AE>

pub fn new(config: FlowConfig, socket: Socket) -> Self

Create a configuration with a pre-built socket.

pub fn with_address(config: FlowConfig, address: SocketAddr) -> Self

Create a configuration that will bind a socket to the given address.

pub fn with_reader_count(self, count: usize) -> Self

Set the number of SO_REUSEPORT reader sockets (Linux only). The kernel distributes incoming datagrams across all sockets by 4-tuple hash, enabling N concurrent recv_from drain tasks with no per-packet locking. Has no effect (silently clamped to 1) on non-Linux platforms.

pub fn with_decoy_factory(self, factory: DecoyFactory<T, AE>) -> Self

Override the decoy provider factory for this flow. When not set, the listener’s default factory (random selection) is used.

pub fn with_decoy<DP: DecoyCommunicationMode<T, AE> + 'static>(self) -> Self

Override the decoy provider for this flow using a concrete type.

pub fn with_probe_factory(self, factory: ProbeFactory<AE>) -> Self

Override the active probe handler factory for this flow.

pub fn with_probe<PM: ActiveProbeHandler<AE> + Default + 'static>(self) -> Self

Override the active probe handler type for this flow.