pub struct WasmSourceBindAcks { /* private fields */ }Expand description
Crate-global per-bind public-exposure acknowledgements for wasm:
source routes (ADR-0061 Rule 4). Mirrors the mcp registry’s bind-ack
store (McpServerRegistry, camel-component-mcp/src/registry.rs): the
CLI installs this map from CamelConfig.binds
(allow_public_exposure) so the bind gate in
WasmSourceConsumer::start() fails closed on non-loopback binds until
acknowledged. The wasm: gate runs inside the consumer (no shared
listener registry to hang it on), so the store lives here instead.
Implementations§
Source§impl WasmSourceBindAcks
impl WasmSourceBindAcks
Sourcepub fn set(&self, acks: HashMap<String, bool>)
pub fn set(&self, acks: HashMap<String, bool>)
Install per-bind public-exposure acknowledgements. Replaces the whole map (interior mutability; no reset hook — tests install a fresh map or use distinct ephemeral ports).
Sourcepub fn acknowledged(&self, bind: &str) -> bool
pub fn acknowledged(&self, bind: &str) -> bool
Whether the operator acknowledged public exposure for bind
(bind address string, e.g. "0.0.0.0:8080"). Absent or never
installed → false (fail-closed).
Auto Trait Implementations§
impl !Freeze for WasmSourceBindAcks
impl RefUnwindSafe for WasmSourceBindAcks
impl Send for WasmSourceBindAcks
impl Sync for WasmSourceBindAcks
impl Unpin for WasmSourceBindAcks
impl UnsafeUnpin for WasmSourceBindAcks
impl UnwindSafe for WasmSourceBindAcks
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
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 more