Enum kitsune_p2p_types::transport::TransportListener

source · [−]

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.

Enum kitsune_p2p_types::transport::TransportListener

Variants

Debug

Fields

BoundUrl

Fields

CreateChannel

Fields

Trait Implementations

impl Debug for TransportListener

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

impl<H: TransportListenerHandler> GhostDispatch<H> for TransportListener

fn ghost_actor_dispatch(self, h: &mut H)

impl GhostEvent for TransportListener

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

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for T where U: From<T>,

pub fn into(self) -> U

impl<T> Pointable for T

pub const ALIGN: usize

type Init = T

pub unsafe fn init(init: <T as Pointable>::Init) -> usize

pub unsafe fn deref<'a>(ptr: usize) -> &'a T

pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

pub unsafe fn drop(ptr: usize)

impl<T> Same<T> for T

type Output = T

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

`Debug`

`BoundUrl`

`CreateChannel`

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,