Struct PackageCatalog 

pub struct PackageCatalog { /* private fields */ }

Gossip-backed discovery for publicly published package manifests.

Implementations

impl PackageCatalog

pub fn new(gossip: &GossipService, endpoint: &Endpoint) -> Self

pub async fn subscribe(&self, bootstrap: Vec<PublicKey>) -> Result<GossipTopic>

Subscribe to the public package catalog.

The caller must retain the returned topic while receiving announcements.

Errors

Returns an error if the gossip subscription cannot be created.

pub async fn subscribe_and_join( &self, bootstrap: Vec<PublicKey>, ) -> Result<GossipTopic>

Subscribe to the public package catalog and wait for a bootstrap connection.

Errors

Returns an error if the gossip subscription cannot join its bootstrap peers.

pub async fn announce( &self, sender: &GossipSender, announcement: &PackageAnnouncement, ) -> Result<()>

Broadcast an announcement to the public catalog.

The announcement is Ed25519-signed so receivers can cryptographically verify its origin.

Errors

Returns an error if the announcement is invalid or cannot be sent.

pub async fn subscribe_channel( &self, channel: &Channel, bootstrap: Vec<PublicKey>, ) -> Result<GossipTopic>

Subscribe to a specific editorial channel.

Errors

Returns an error if the gossip subscription cannot be created.

pub async fn subscribe_channel_and_join( &self, channel: &Channel, bootstrap: Vec<PublicKey>, ) -> Result<GossipTopic>

Subscribe to a channel and block until at least one bootstrap peer is connected.

Errors

Returns an error if the gossip subscription cannot join its bootstrap peers.

pub async fn search( &self, topic: &mut GossipTopic, query: Option<&str>, timeout: Duration, ) -> Result<Vec<PackageAnnouncement>>

Collect matching announcements until the timeout expires.

Each announcement is verified: the Ed25519 signature is checked and the claimed publisher field must match the signing key. A timeout is a normal end condition because gossip has no finite response boundary.

Errors

Returns an error if a received announcement fails signature verification.

pub fn register_ticket_endpoint( lookup: &MemoryLookup, announcement: &PackageAnnouncement, ) -> Result<()>

Add the endpoint address for a discovered ticket to a memory lookup.

This helper is useful to callers that construct a node with a shared MemoryLookup and want to fetch an announcement immediately.

Errors

Returns an error if the announcement’s manifest ticket is invalid.

Trait Implementations

impl Clone for PackageCatalog

fn clone(&self) -> PackageCatalog

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.