Struct phron_finality::network::session::discovery::Discovery

pub struct Discovery<A: AddressingInformation> {
    cooldown: Duration,
    last_broadcast: HashMap<NodeIndex, Instant>,
    _phantom: PhantomData<A>,
}

Handles creating and rebroadcasting discovery messages.

Fields

cooldown: Duration

last_broadcast: HashMap<NodeIndex, Instant>

_phantom: PhantomData<A>

Implementations

impl<A: AddressingInformation> Discovery<A>

pub fn new(cooldown: Duration) -> Self

Create a new discovery handler with the given response/broadcast cooldown.

pub fn discover_authorities( &mut self, handler: &SessionHandler<A> ) -> Option<Authentication<A>>

Returns a message that should be sent as part of authority discovery at this moment.

fn should_rebroadcast(&self, node_id: &NodeIndex) -> bool

pub fn handle_authentication( &mut self, authentication: Authentication<A>, handler: &mut SessionHandler<A> ) -> (Option<A>, Option<Authentication<A>>)

Processes the provided authentication and returns any new address we should be connected to if we want to stay connected to the committee and an optional message that we should send as a result of it.