Struct QuicEndpointConnector
pub struct QuicEndpointConnector<C> { /* private fields */ }Available on crate features
quic and std only.Expand description
Builds one QUIC endpoint on each datagram socket its inner connector establishes, such as a connected UDP socket or a UDP tunnel through a proxy: one socket and endpoint per connection.
The endpoint applies the request’s QuicProfile, keeps its packets within what the
socket carries, and opens its connection to the socket’s peer. The socket’s extensions,
such as an established proxy route, become the endpoint’s.
Implementations§
§impl<C> QuicEndpointConnector<C>
impl<C> QuicEndpointConnector<C>
pub fn new(inner: C, executor: Executor) -> QuicEndpointConnector<C>
pub fn new(inner: C, executor: Executor) -> QuicEndpointConnector<C>
Endpoints on the sockets inner establishes; executor runs their drivers.
Trait Implementations§
§impl<C> Clone for QuicEndpointConnector<C>where
C: Clone,
impl<C> Clone for QuicEndpointConnector<C>where
C: Clone,
§fn clone(&self) -> QuicEndpointConnector<C>
fn clone(&self) -> QuicEndpointConnector<C>
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read more§impl<C> Debug for QuicEndpointConnector<C>where
C: Debug,
impl<C> Debug for QuicEndpointConnector<C>where
C: Debug,
§impl<C> Service<ConnectRequest> for QuicEndpointConnector<C>where
C: ConnectorService<ConnectRequest>,
<C as ConnectorService<ConnectRequest>>::Connection: DatagramSocket,
impl<C> Service<ConnectRequest> for QuicEndpointConnector<C>where
C: ConnectorService<ConnectRequest>,
<C as ConnectorService<ConnectRequest>>::Connection: DatagramSocket,
§type Output = EstablishedClientConnection<ClientEndpoint, ConnectRequest>
type Output = EstablishedClientConnection<ClientEndpoint, ConnectRequest>
The type of the output returned by the service.
§type Error = ConnectionError
type Error = ConnectionError
The type of error returned by the service.
§async fn serve(
&self,
input: ConnectRequest,
) -> Result<<QuicEndpointConnector<C> as Service<ConnectRequest>>::Output, <QuicEndpointConnector<C> as Service<ConnectRequest>>::Error>
async fn serve( &self, input: ConnectRequest, ) -> Result<<QuicEndpointConnector<C> as Service<ConnectRequest>>::Output, <QuicEndpointConnector<C> as Service<ConnectRequest>>::Error>
Serve an output or an error for the given input
§fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>
fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>
Box this service to allow for dynamic dispatch.
Auto Trait Implementations§
impl<C> Freeze for QuicEndpointConnector<C>where
C: Freeze,
impl<C> RefUnwindSafe for QuicEndpointConnector<C>where
C: RefUnwindSafe,
impl<C> Send for QuicEndpointConnector<C>where
C: Send,
impl<C> Sync for QuicEndpointConnector<C>where
C: Sync,
impl<C> Unpin for QuicEndpointConnector<C>where
C: Unpin,
impl<C> UnsafeUnpin for QuicEndpointConnector<C>where
C: UnsafeUnpin,
impl<C> UnwindSafe for QuicEndpointConnector<C>where
C: UnwindSafe,
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<S, Input, Connection> ConnectorService<Input> for Swhere
S: Service<Input, Output = EstablishedClientConnection<Connection, Input>>,
<S as Service<Input>>::Error: Into<ConnectionError>,
Connection: Send + ExtensionsRef,
impl<S, Input, Connection> ConnectorService<Input> for Swhere
S: Service<Input, Output = EstablishedClientConnection<Connection, Input>>,
<S as Service<Input>>::Error: Into<ConnectionError>,
Connection: Send + ExtensionsRef,
§type Connection = Connection
type Connection = Connection
Connection returned by the
ConnectorService§fn connect(
&self,
input: Input,
) -> impl Future<Output = Result<EstablishedClientConnection<<S as ConnectorService<Input>>::Connection, Input>, ConnectionError>> + Send
fn connect( &self, input: Input, ) -> impl Future<Output = Result<EstablishedClientConnection<<S as ConnectorService<Input>>::Connection, Input>, ConnectionError>> + Send
Establish a connection, which often involves some kind of handshake,
or connection revival. Read more
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a rama_grpc::Request§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Create a new
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more