pub struct EmbeddedTransport<R, O, F> { /* private fields */ }Expand description
Items cross a channel that the host of an embedded program implements however it likes (a
network connection, an in-memory queue, …), keeping the retries R, ordering O, and
failure policy F that follow from what the channel declares about each anomaly (() until
declared).
Trait Implementations§
Source§impl<R: EmbeddedRetries, O: EmbeddedOrdering, F: EmbeddedFailPolicy> TransportKind for EmbeddedTransport<R, O, F>
impl<R: EmbeddedRetries, O: EmbeddedOrdering, F: EmbeddedFailPolicy> TransportKind for EmbeddedTransport<R, O, F>
Source§type OrderingGuarantee = <F as EmbeddedFailPolicy>::Ordering<O>
type OrderingGuarantee = <F as EmbeddedFailPolicy>::Ordering<O>
The ordering guarantee provided by this transport.
Source§type RetriesGuarantee = R
type RetriesGuarantee = R
The retry guarantee provided by this transport:
ExactlyOnce if it never delivers a
message more than once.Source§type ConsistencyGuarantee = <F as EmbeddedFailPolicy>::ConsistencyGuarantee
type ConsistencyGuarantee = <F as EmbeddedFailPolicy>::ConsistencyGuarantee
The consistency guarantee this transport can preserve for replicated outputs
(see
NetworkFor::ConsistencyGuarantee).Source§fn networking_info() -> NetworkingInfo
fn networking_info() -> NetworkingInfo
Returns the
NetworkingInfo describing this transport’s configuration.Auto Trait Implementations§
impl<R, O, F> Freeze for EmbeddedTransport<R, O, F>
impl<R, O, F> RefUnwindSafe for EmbeddedTransport<R, O, F>
impl<R, O, F> Send for EmbeddedTransport<R, O, F>
impl<R, O, F> Sync for EmbeddedTransport<R, O, F>
impl<R, O, F> Unpin for EmbeddedTransport<R, O, F>
impl<R, O, F> UnsafeUnpin for EmbeddedTransport<R, O, F>
impl<R, O, F> UnwindSafe for EmbeddedTransport<R, O, F>
Blanket Implementations§
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<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> 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 moreCreates a shared type from an unshared type.