pub struct MeshForwarder { /* private fields */ }Expand description
Forwards to a remote owner over a kept connection (reconnects once on a transport failure).
Implementations§
Source§impl MeshForwarder
impl MeshForwarder
Sourcepub fn new(
key: SigningKey,
owner_node: &str,
owner_key: [u8; 32],
addr: &str,
connector: Arc<dyn CtlConnector>,
) -> Self
pub fn new( key: SigningKey, owner_node: &str, owner_key: [u8; 32], addr: &str, connector: Arc<dyn CtlConnector>, ) -> Self
Forwarder signing as key’s node to the owner owner_node (whose
key must be owner_key) at addr.
Trait Implementations§
Source§impl Forwarder for MeshForwarder
impl Forwarder for MeshForwarder
Source§fn forward<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
b: &'life1 InstanceBinding,
batch: &'life2 IngestBatch,
) -> Pin<Box<dyn Future<Output = Result<IngestOutcome, IngestError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn forward<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
b: &'life1 InstanceBinding,
batch: &'life2 IngestBatch,
) -> Pin<Box<dyn Future<Output = Result<IngestOutcome, IngestError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Forward
batch for the instance b.Auto Trait Implementations§
impl !Freeze for MeshForwarder
impl !RefUnwindSafe for MeshForwarder
impl !UnwindSafe for MeshForwarder
impl Send for MeshForwarder
impl Sync for MeshForwarder
impl Unpin for MeshForwarder
impl UnsafeUnpin for MeshForwarder
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
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> ⓘ
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