Enum kitsune_p2p_types::transport::TransportListener [−][src]
pub enum TransportListener {
Debug {
span_context: Context,
respond: GhostRespond<TransportListenerHandlerResult<Value>>,
},
BoundUrl {
span_context: Context,
respond: GhostRespond<TransportListenerHandlerResult<Url2>>,
},
CreateChannel {
span_context: Context,
respond: GhostRespond<TransportListenerHandlerResult<(Url2, TransportChannelWrite, TransportChannelRead)>>,
url: Url2,
},
}
Expand description
Represents a transport binding for establishing connections. This api was designed mainly around supporting the QUIC transport. It should be applicable to other transports, but with some assumptions:
- Keep alive logic should be handled internally.
- Transport encryption is handled internally.
- See light-weight comments below on
create_channel
api.
Variants
Debug
Fields
span_context: Context
Tracing span from request invocation.
respond: GhostRespond<TransportListenerHandlerResult<Value>>
Response callback - respond to the request.
Grab a debugging internal state dump.
BoundUrl
Fields
span_context: Context
Tracing span from request invocation.
respond: GhostRespond<TransportListenerHandlerResult<Url2>>
Response callback - respond to the request.
Retrieve the current url (address) this listener is bound to.
CreateChannel
Fields
span_context: Context
Tracing span from request invocation.
respond: GhostRespond<TransportListenerHandlerResult<(Url2, TransportChannelWrite, TransportChannelRead)>>
Response callback - respond to the request.
url: Url2
Input parameter.
Attempt to establish an outgoing channel to a remote. Channels are expected to be very light-weight. This API was designed around QUIC bi-streams. If your low-level channels are not light-weight, consider implementing pooling/multiplex virtual channels to make this api light weight.
Trait Implementations
Process a dispatch event with a given GhostHandler.
Auto Trait Implementations
impl !RefUnwindSafe for TransportListener
impl Send for TransportListener
impl Sync for TransportListener
impl Unpin for TransportListener
impl !UnwindSafe for TransportListener
Blanket Implementations
Mutably borrows from an owned value. Read more
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>
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more