Struct ServiceLicenceLinks 

pub struct ServiceLicenceLinks {
    pub counters: ServiceLinksCounters,
    /* private fields */
}

The licence exchange’s mesh in service mode.

Fields

counters: ServiceLinksCounters

Counters.

Implementations

impl ServiceLicenceLinks

pub fn new( sender: Arc<dyn PeerSender>, directory: Arc<dyn PeerDirectory>, ) -> Arc<Self>

Links that send through sender and read peers from directory.

pub fn with_reply_caps( sender: Arc<dyn PeerSender>, directory: Arc<dyn PeerDirectory>, total: usize, per_peer: usize, ) -> Arc<Self>

Self::new with explicit reply caps (in flight overall, per peer).

pub fn holder(&self) -> Option<bool>

Whether this daemon holds the service’s reserved licence topics, as of the last refresh (None: unknown, the last refresh failed or the service did not say).

pub fn holder_uid(&self) -> Option<u32>

The uid the service named as the licence holder at the last refresh.

pub fn subscribe_holder(&self) -> Receiver<Option<bool>>

Changes of Self::holder.

pub async fn refresh(&self) -> Result<(), String>

Read the service’s peer view; raise Joined for each peer that became licensed since the last refresh.

pub fn spawn_refresh( self: &Arc<Self>, every: Duration, ) -> Option<JoinHandle<()>>

Self::refresh now and every every while the links are alive.

pub async fn deliver(&self, from: &PeerCtx, msg: KernelMessage) -> bool

Take a licence delivery. Returns false when msg is not on a licence topic (the caller passes it on); true when it was consumed, handled or not.

Trait Implementations

impl LicenceLinks for ServiceLicenceLinks

fn set_control_sink(&self, topic: &str, sink: Arc<dyn PeerControlSink>)

Receive topic with sink (first registration wins).

fn peer_ids(&self) -> Vec<String>

Peers to ask for a catch-up sync (the answering side checks admission).

fn peer_licensed(&self, peer: &str) -> bool

True when peer may be sent bindings and grants: verified by admission and of class node.

fn route_to_remote<'life0, 'life1, 'async_trait>( &'life0 self, peer: &'life1 str, msg: KernelMessage, ) -> Pin<Box<dyn Future<Output = KernelResult<()>> + Send + 'async_trait>>

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

Send msg to peer.

fn subscribe_peer_events(&self) -> Option<Receiver<MeshPeerEvent>>

Peer-join events, for the sync on connect (None: this mesh has none and only the periodic sync runs).