Struct CogMesh 

pub struct CogMesh {
    pub counters: CogMeshCounters,
    /* private fields */
}

One node’s cog mesh: tunnel, optional steward relay, requester side.

Fields

counters: CogMeshCounters

Counters.

Implementations

impl CogMesh

pub fn new( exchange: Arc<ArtifactExchange>, store: Arc<CheckoutGrantStore>, sender: Arc<dyn PeerSender>, relay: Option<Arc<CheckoutRelay>>, ) -> Arc<Self>

A node’s cog mesh. relay is Some only on the steward.

pub fn tunnel(&self) -> &Arc<ArtifactTunnel>

The artifact tunnel (its ArtifactTunnel::dialer is the production crate::mesh_swarm_fetch::PeerDialer).

pub fn set_relay(&self, relay: Option<Arc<CheckoutRelay>>)

Install (or with None remove) the steward relay.

pub fn relay(&self) -> Option<Arc<CheckoutRelay>>

The steward relay, when this node runs one.

pub async fn checkout_as( &self, principal: &str, req: &CheckoutWire, ) -> Result<SignedGrant, CheckoutRefusal>

An RPC caller on the steward asks for a checkout, as principal.

pub async fn checkout_local( &self, req: &CheckoutWire, ) -> Result<SignedGrant, CheckoutRefusal>

The steward’s own kernel asks for a checkout.

pub async fn request_checkout( &self, steward: &str, req: CheckoutWire, timeout: Duration, ) -> Result<SignedGrant, CheckoutRefusal>

Ask steward (a verified node) for a checkout. The returned grant is verified and registered here, so this node can fetch and share bytes.

pub async fn on_delivery( self: &Arc<Self>, from: &PeerCtx, msg: KernelMessage, ) -> bool

Route one delivery on a feature topic. Returns false when the topic is not one of ours (the caller passes it on).