pub struct SinkMiddleware { /* private fields */ }Expand description
Data-plane SpawnerLayer. Config: the store to reference plus the
endpoint hint.
The endpoint hint is the literal URL a SubAgent will POST a Big EMIT to
(for example "http://127.0.0.1:7785/v1/data/emit"). The actual HTTP
endpoint lives on the mlua-swarm-server side (carry); this layer only routes
the hint value into ctx.
Implementations§
Source§impl SinkMiddleware
impl SinkMiddleware
Sourcepub fn new(
store: Arc<dyn OutputStore>,
endpoint_hint: impl Into<String>,
) -> Self
pub fn new( store: Arc<dyn OutputStore>, endpoint_hint: impl Into<String>, ) -> Self
Build a new layer. store is the Data owner (the real home for Big
bodies); endpoint_hint is the URL literal the SubAgent should POST
to.
Sourcepub fn store(&self) -> &Arc<dyn OutputStore> ⓘ
pub fn store(&self) -> &Arc<dyn OutputStore> ⓘ
Borrow the inner store (tests / observers).
Trait Implementations§
Source§impl SpawnerLayer for SinkMiddleware
impl SpawnerLayer for SinkMiddleware
Source§fn wrap(&self, inner: Arc<dyn SpawnerAdapter>) -> Arc<dyn SpawnerAdapter> ⓘ
fn wrap(&self, inner: Arc<dyn SpawnerAdapter>) -> Arc<dyn SpawnerAdapter> ⓘ
Wraps
inner in this layer’s behaviour, returning a new
SpawnerAdapter that delegates to inner (directly or via
wrap_join) while adding this layer’s cross-cutting effect.Auto Trait Implementations§
impl !RefUnwindSafe for SinkMiddleware
impl !UnwindSafe for SinkMiddleware
impl Freeze for SinkMiddleware
impl Send for SinkMiddleware
impl Sync for SinkMiddleware
impl Unpin for SinkMiddleware
impl UnsafeUnpin for SinkMiddleware
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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
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