pub struct K2KSubBroker { /* private fields */ }Expand description
Per-tenant sub-broker.
Each K2KSubBroker is an independent routing domain: its endpoint map and
indirect-routing table are not visible to any other tenant. Cross-tenant
sends therefore have no possible route and are rejected by the parent
K2KBroker before they reach any sub-broker.
Implementations§
Source§impl K2KSubBroker
impl K2KSubBroker
Sourcepub fn endpoint_count(&self) -> usize
pub fn endpoint_count(&self) -> usize
Number of kernels registered in this sub-broker.
Sourcepub fn messages_delivered(&self) -> u64
pub fn messages_delivered(&self) -> u64
Number of messages successfully delivered by this sub-broker.
Sourcepub fn knows(&self, kernel_id: &KernelId) -> bool
pub fn knows(&self, kernel_id: &KernelId) -> bool
Returns true if this sub-broker has a route (direct or indirect)
for kernel_id.
Sourcepub fn audit_tag_for(&self, kernel_id: &KernelId) -> AuditTag
pub fn audit_tag_for(&self, kernel_id: &KernelId) -> AuditTag
Get the audit tag associated with a kernel at registration time, or
AuditTag::unspecified if none was set.
Auto Trait Implementations§
impl !Freeze for K2KSubBroker
impl !RefUnwindSafe for K2KSubBroker
impl Send for K2KSubBroker
impl Sync for K2KSubBroker
impl Unpin for K2KSubBroker
impl UnsafeUnpin for K2KSubBroker
impl UnwindSafe for K2KSubBroker
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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<F, W, T, D> Deserialize<With<T, W>, D> for F
impl<F, W, T, D> Deserialize<With<T, W>, D> for F
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> 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>
Gets the layout of the type.