Struct UnixConnector 

pub struct UnixConnector<ConnectorFactory = (), T = UnixTarget> { /* private fields */ }

Available on target_family="unix" only.

A connector which can be used to establish a Unix connection to a server.

Implementations

impl UnixConnector

pub fn fixed(path: impl Into<PathBuf>) -> Self

Create a new UnixConnector, which is used to establish a connection to a server at a fixed path.

You can use middleware around the UnixConnector or add connection pools, retry logic and more.

impl<T> UnixConnector<(), T>

pub fn with_connector<Connector>( self, connector: Connector, ) -> UnixConnector<UnixStreamConnectorCloneFactory<Connector>, T>

Consume self to attach the given Connector (a UnixStreamConnector) as a new UnixConnector.

pub fn with_connector_factory<Factory>( self, factory: Factory, ) -> UnixConnector<Factory, T>

Consume self to attach the given Factory (a UnixStreamConnectorFactory) as a new UnixConnector.

Trait Implementations

impl<ConnectorFactory: Clone, UnixTarget: Clone> Clone for UnixConnector<ConnectorFactory, UnixTarget>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<ConnectorFactory: Debug, UnixTarget: Debug> Debug for UnixConnector<ConnectorFactory, UnixTarget>

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

Formats the value using the given formatter.

impl<State, Request, ConnectorFactory> Service<State, Request> for UnixConnector<ConnectorFactory>

where State: Clone + Send + Sync + 'static, Request: Send + 'static, ConnectorFactory: UnixStreamConnectorFactory<State, Connector: UnixStreamConnector<Error: Into<BoxError> + Send + 'static>, Error: Into<BoxError> + Send + 'static> + Clone,

type Response = EstablishedClientConnection<UnixStream, State, Request>

The type of response returned by the service.

type Error = Box<dyn Error + Sync + Send>

The type of error returned by the service.

async fn serve( &self, ctx: Context<State>, req: Request, ) -> Result<Self::Response, Self::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<S, Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.