Struct ConnectionOrientedSocketSpecification 

pub struct ConnectionOrientedSocketSpecification { /* private fields */ }

Specification for a connection-oriented network listener.

Creates a ConnectionOrientedListener, which accepts connections on TCP or Unix stream addresses only.

Only the listen address identifies the resource. The accept backoff is applied when the listener is first created and has no effect on a later acquisition of the same address, since the socket is already bound. The registry logs a warning if a subsequent specification disagrees.

Implementations

impl ConnectionOrientedSocketSpecification

pub fn new(address: ListenAddress) -> Self

Creates a specification for the given listen address.

pub fn with_accept_backoff( self, accept_backoff: Option<ExponentialBackoff>, ) -> Self

Sets the backoff the listener applies when accepting fails for want of a system resource.

None keeps the listener’s default. See ConnectionOrientedListener::with_accept_backoff.

pub fn listen_address(&self) -> &ListenAddress

Returns the listen address this specification names.

Trait Implementations

impl Clone for ConnectionOrientedSocketSpecification

fn clone(&self) -> ConnectionOrientedSocketSpecification

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionOrientedSocketSpecification

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

Formats the value using the given formatter.

impl From<ListenAddress> for ConnectionOrientedSocketSpecification

fn from(address: ListenAddress) -> Self

Converts to this type from the input type.

impl ResourceSpecification for ConnectionOrientedSocketSpecification

const KIND: ResourceKind = ResourceKind::Socket

Kind of the resource this specification names.

type Resource = ConnectionOrientedListener

Type of the resource this specification creates.

fn key(&self) -> MetaString

Returns the key for the resource this specification names.

fn create<'life0, 'async_trait>( &'life0 self, _subleases: Subleases, ) -> Pin<Box<dyn Future<Output = Result<Self::Resource, GenericError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Creates the resource.

fn reset(listener: &mut Self::Resource)

Prepares a returning resource for its next holder.