weave-swarm · runtime::registry
Source declarations, signatures and documentation for runtime::registry.
Source: sigil/weave/network/weave-swarm/src/runtime/registry.rs. SHA-256: 373f4dee20eb7b9ba48d37a8e711fd0a979b1d935e8009069f96eb3fc53c1aa9.
This reference follows declared source modules, retains conditional attributes, and includes public declarations and implementation methods. Private-module re-exports and trait resolution require the compiler; this is a source reference, not a claim that every listed item is a root import. Function bodies and constant values are omitted.
runtime::registry::ConnectionRegistry
Registry shared by DHT, liveness, bans, limits, and application stream events.
#[derive(Debug)]
pub struct ConnectionRegistry {
}Source line: 17.
runtime::registry::ConnectionRegistry::new
pub fn new(limits: RuntimeLimits) -> Self;Source line: 26.
runtime::registry::ConnectionRegistry::register_authenticated
pub fn register_authenticated(
&mut self,
peer_id: PeerId,
connection_id: ConnectionId,
) -> Result<(), RuntimeError>;Source line: 36.
runtime::registry::ConnectionRegistry::remove
pub fn remove(
&mut self,
peer_id: PeerId,
connection_id: ConnectionId,
) -> Result<(), RuntimeError>;Source line: 74.
runtime::registry::ConnectionRegistry::register_stream
pub fn register_stream(
&mut self,
peer_id: PeerId,
connection_id: ConnectionId,
stream_id: StreamId,
) -> Result<(), RuntimeError>;Source line: 106.
runtime::registry::ConnectionRegistry::remove_stream
pub fn remove_stream(
&mut self,
peer_id: PeerId,
connection_id: ConnectionId,
stream_id: StreamId,
) -> Result<(), RuntimeError>;Source line: 142.
runtime::registry::ConnectionRegistry::require_shared_connection
pub fn require_shared_connection(
&self,
peer_id: PeerId,
connection_id: ConnectionId,
) -> Result<(), RuntimeError>;Source line: 173.
runtime::registry::ConnectionRegistry::has_stream
pub fn has_stream(&self, connection_id: ConnectionId, stream_id: StreamId) -> bool;Source line: 186.
runtime::registry::ConnectionRegistry::block
pub fn block(&mut self, peer_id: PeerId) -> Vec<ConnectionId>;Source line: 192.
runtime::registry::ConnectionRegistry::unblock
pub fn unblock(&mut self, peer_id: PeerId);Source line: 204.
runtime::registry::ConnectionRegistry::is_blocked
pub fn is_blocked(&self, peer_id: PeerId) -> bool;Source line: 208.
runtime::registry::ConnectionRegistry::is_connected
pub fn is_connected(&self, peer_id: PeerId) -> bool;Source line: 212.
