Struct DatagramForwardService 

pub struct DatagramForwardService { /* private fields */ }

Available on crate features std and udp only.

Per-association memory and metadata policy.

Implementations

impl DatagramForwardService

pub const fn new( buffer_bytes: NonZero<usize>, ecn: EcnPolicy, ) -> DatagramForwardService

Bound each direction’s receive buffer and select an explicit ECN policy. There is no implicit metadata loss or unbounded default allocation.

pub fn with_buffer_bytes(self, bytes: NonZero<usize>) -> DatagramForwardService

Maximum receive-buffer bytes per direction, including a GRO group. Two buffers are retained at most; oversized input fails as truncated.

pub fn set_buffer_bytes( &mut self, bytes: NonZero<usize>, ) -> &mut DatagramForwardService

Maximum receive-buffer bytes per direction, including a GRO group. Two buffers are retained at most; oversized input fails as truncated.

pub fn with_ecn(self, policy: EcnPolicy) -> DatagramForwardService

Select whether both directions preserve ECN or explicitly discard it.

pub fn set_ecn(&mut self, policy: EcnPolicy) -> &mut DatagramForwardService

Select whether both directions preserve ECN or explicitly discard it.

pub fn with_packet_errors( self, policy: PacketErrorPolicy, ) -> DatagramForwardService

Select whether an error concerning one datagram ends forwarding.

pub fn set_packet_errors( &mut self, policy: PacketErrorPolicy, ) -> &mut DatagramForwardService

Select whether an error concerning one datagram ends forwarding.

pub fn with_close_timeout(self, timeout: Duration) -> DatagramForwardService

Bound the remaining direction after a send reports a closed destination. Defaults to five seconds. A closed receive side ends the association immediately. The deadline starts at the first directional end and traffic cannot extend it.

pub fn set_close_timeout( &mut self, timeout: Duration, ) -> &mut DatagramForwardService

Bound the remaining direction after a send reports a closed destination. Defaults to five seconds. A closed receive side ends the association immediately. The deadline starts at the first directional end and traffic cannot extend it.

Trait Implementations

impl Clone for DatagramForwardService

fn clone(&self) -> DatagramForwardService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for DatagramForwardService

impl Debug for DatagramForwardService

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<A, B> Service<BridgeIo<A, B>> for DatagramForwardService

where A: DatagramSocket, B: DatagramSocket,

Forward between two connected sockets, as Peer::connected makes them: a DatagramToProxyBridge association, for example.

type Output = ()

The type of the output returned by the service.

type Error = DatagramForwardError

The type of error returned by the service.

async fn serve( &self, __arg1: BridgeIo<A, B>, ) -> Result<(), <DatagramForwardService as Service<BridgeIo<A, B>>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.

impl<A, B> Service<BridgeIo<Peer<A>, Peer<B>>> for DatagramForwardService

where A: DatagramSocket, B: DatagramSocket,

async fn serve( &self, __arg1: BridgeIo<Peer<A>, Peer<B>>, ) -> Result<(), DatagramForwardError>

Forward both directions. A closed destination drains the sibling for at most the close timeout; a closed receive side ends the association after its buffered input. Other I/O or preservation errors cancel both directions. Dropping the future drops its socket owners and pending send handles. Apply association admission, idle expiration and shutdown in the caller.

type Output = ()

The type of the output returned by the service.

type Error = DatagramForwardError

The type of error returned by the service.

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.