Struct TopicTracker 

pub struct TopicTracker {
    pub node_id: NodeId,
    /* private fields */
}

Fields

node_id: NodeId

Implementations

impl TopicTracker

pub const ALPN: &'static [u8] = b"iroh/topictracker/1"

pub const MAX_TOPIC_LIST_SIZE: usize = 10usize

pub const MAX_NODE_IDS_PER_TOPIC: usize = 100usize

pub const BOOTSTRAP_NODES: &str = "abcdef4df4d74587095d071406c2a8462bde5079cbbc0c50051b9b2e84d67691"

pub const MAX_MSG_SIZE_BYTES: u64 = 1_048_576u64

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

pub async fn spawn_optional(self) -> Result<Self>

pub async fn get_topic_nodes(self, topic: &Topic) -> Result<Vec<NodeId>>

pub async fn memory_footprint(&self) -> usize

Trait Implementations

impl Clone for TopicTracker

fn clone(&self) -> TopicTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopicTracker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ProtocolHandler for TopicTracker

fn accept( &self, conn: Connection, ) -> impl Future<Output = Result<(), AcceptError>> + Send

Handle an incoming connection.

fn on_connecting( &self, connecting: Connecting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Connecting state.

fn shutdown(&self) -> impl Future<Output = ()> + Send

Called when the router shuts down.