Struct CogMeshDelivery 

pub struct CogMeshDelivery { /* private fields */ }

The router in front of inner that takes the cog mesh topics.

Implementations

impl CogMeshDelivery

pub fn new(inner: Arc<dyn LocalDelivery>, slot: Arc<CogMeshSlot>) -> Self

Wrap inner; feature topics go to whatever slot holds.

pub fn with_licence(self, links: Arc<ServiceLicenceLinks>) -> Self

Also take the licence control topics, for links (service mode).

Trait Implementations

impl LocalDelivery for CogMeshDelivery

fn deliver<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, from: &'life1 PeerCtx, dest_scope: Option<&'life2 Scope>, msg: KernelMessage, ) -> Pin<Box<dyn Future<Output = KernelResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Deliver msg from from. dest_scope is the envelope’s dest_scope as supplied by the peer: untrusted. Implementations that have no tenants ignore it.

fn authorize_subscribe<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, from: &'life1 PeerCtx, topic: &'life2 str, dest_scope: Option<&'life3 Scope>, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

May from subscribe to topic (a mesh.subscribe control message, which is consumed before delivery)? Default: yes.