pub enum RelayCommand<T> {
RegisterService {
name: String,
target: T,
},
Accepted {
token: u64,
peer: Did,
service: String,
},
Untrack {
peer: Did,
session: SessionId,
initiator: Initiator,
},
Abort {
peer: Did,
session: SessionId,
initiator: Initiator,
},
}Expand description
A local control command, re-injected by the provider (provenance = self; never sent by
peers). Generic over the service target T.
Variants§
RegisterService
Map a service name to a local target that Open may dial.
Fields
target: TLocal target (SocketAddr natively, WebTransport URL in browser).
Accepted
Engine→protocol feedback: a local connection/datagram-flow was accepted, pending
under engine-local token, destined for peer’s service. The pure step mints
the session id (so id allocation lives in the core, not the shell), records it, and
replies with RelayEffect::OpenAccepted to bind the pending resource. The engine
never mints or decides identity — it only reports the raw accept and executes effects.
Fields
Untrack
Engine→protocol feedback: a session was torn down by the engine (any side); forget it. The single point through which every teardown reaches the pure state.
Fields
Abort
Engine→protocol feedback: the current backend failed under an ordered
effect. Forget it and emit exactly one peer-facing Close.
Trait Implementations§
Source§impl<T: Clone> Clone for RelayCommand<T>
impl<T: Clone> Clone for RelayCommand<T>
Source§fn clone(&self) -> RelayCommand<T>
fn clone(&self) -> RelayCommand<T>
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl<T: Debug> Debug for RelayCommand<T>
impl<T: Debug> Debug for RelayCommand<T>
Source§impl<'de, T> Deserialize<'de> for RelayCommand<T>where
T: Deserialize<'de>,
impl<'de, T> Deserialize<'de> for RelayCommand<T>where
T: Deserialize<'de>,
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
impl<T: Eq> Eq for RelayCommand<T>
Source§impl<T: PartialEq> PartialEq for RelayCommand<T>
impl<T: PartialEq> PartialEq for RelayCommand<T>
Source§impl<T> Serialize for RelayCommand<T>where
T: Serialize,
impl<T> Serialize for RelayCommand<T>where
T: Serialize,
impl<T: PartialEq> StructuralPartialEq for RelayCommand<T>
Auto Trait Implementations§
impl<T> Freeze for RelayCommand<T>where
T: Freeze,
impl<T> RefUnwindSafe for RelayCommand<T>where
T: RefUnwindSafe,
impl<T> Send for RelayCommand<T>where
T: Send,
impl<T> Sync for RelayCommand<T>where
T: Sync,
impl<T> Unpin for RelayCommand<T>where
T: Unpin,
impl<T> UnsafeUnpin for RelayCommand<T>where
T: UnsafeUnpin,
impl<T> UnwindSafe for RelayCommand<T>where
T: UnwindSafe,
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.impl<T> ErasedDestructor for Twhere
T: 'static,
impl<A, B, T> HttpServerConnExec<A, B> for Twhere
B: Body,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§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> ⓘ
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> ⓘ
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 moreSource§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
impl<T> MaybeSend for T
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
out indicating that a T is niched.