Struct Behaviour 

pub struct Behaviour<T: ClusterKey> {
    pub gossipsub: Behaviour,
    pub manager: TopologyManager<T>,
    pub heartbeat_interval: Interval,
    pub timeout_check_interval: Interval,
    pub heartbeat_topic: IdentTopic,
    pub ownership_topic: IdentTopic,
    pub pending_events: VecDeque<PartitionBehaviourEvent<T>>,
    pub heartbeat_bytes: Box<[u8]>,
}

Fields

gossipsub: Behaviour

manager: TopologyManager<T>

heartbeat_interval: Interval

timeout_check_interval: Interval

heartbeat_topic: IdentTopic

ownership_topic: IdentTopic

pending_events: VecDeque<PartitionBehaviourEvent<T>>

heartbeat_bytes: Box<[u8]>

Implementations

impl<T: ClusterKey> Behaviour<T>

pub fn new( gossipsub: Behaviour, manager: TopologyManager<T>, heartbeat_interval_duration: Duration, ) -> Self

pub fn add_explicit_peer(&mut self, peer_id: PeerId)

Trait Implementations

impl<T: ClusterKey> NetworkBehaviour for Behaviour<T>

type ConnectionHandler = <Behaviour as NetworkBehaviour>::ConnectionHandler

Handler for all the protocols the network behaviour supports.

type ToSwarm = PartitionBehaviourEvent<T>

Event generated by the NetworkBehaviour and that the swarm will report back.

fn handle_pending_inbound_connection( &mut self, connection_id: ConnectionId, local_addr: &Multiaddr, remote_addr: &Multiaddr, ) -> Result<(), ConnectionDenied>

Callback that is invoked for every new inbound connection.

fn handle_established_inbound_connection( &mut self, connection_id: ConnectionId, peer: PeerId, local_addr: &Multiaddr, remote_addr: &Multiaddr, ) -> Result<THandler<Self>, ConnectionDenied>

Callback that is invoked for every established inbound connection.

fn handle_pending_outbound_connection( &mut self, connection_id: ConnectionId, maybe_peer: Option<PeerId>, addresses: &[Multiaddr], effective_role: Endpoint, ) -> Result<Vec<Multiaddr>, ConnectionDenied>

Callback that is invoked for every outbound connection attempt.

fn handle_established_outbound_connection( &mut self, connection_id: ConnectionId, peer: PeerId, addr: &Multiaddr, role_override: Endpoint, port_use: PortUse, ) -> Result<THandler<Self>, ConnectionDenied>

Callback that is invoked for every established outbound connection.

fn on_swarm_event(&mut self, event: FromSwarm<'_>)

Informs the behaviour about an event from the Swarm.

fn on_connection_handler_event( &mut self, peer_id: PeerId, connection_id: ConnectionId, event: THandlerOutEvent<Self>, )

Informs the behaviour about an event generated by the ConnectionHandler dedicated to the peer identified by peer_id. for the behaviour.

fn poll( &mut self, cx: &mut Context<'_>, ) -> Poll<ToSwarm<Self::ToSwarm, THandlerInEvent<Self>>>

Polls for things that swarm should do.