Struct phron_finality::session_map::SessionMapUpdater

pub struct SessionMapUpdater<AP, FN>
where
    AP: AuthorityProvider,
    FN: FinalityNotifier,
{
    session_map: SharedSessionMap,
    authority_provider: AP,
    finality_notifier: FN,
    session_info: SessionBoundaryInfo,
}

Struct responsible for updating session map

Fields

session_map: SharedSessionMap

authority_provider: AP

finality_notifier: FN

session_info: SessionBoundaryInfo

Implementations

impl<AP, FN> SessionMapUpdater<AP, FN>

where AP: AuthorityProvider, FN: FinalityNotifier,

pub fn new( authority_provider: AP, finality_notifier: FN, period: SessionPeriod ) -> Self

pub fn readonly_session_map(&self) -> ReadOnlySessionMap

returns readonly view of the session map

async fn handle_first_block_of_session(&mut self, session_id: SessionId)

Puts authority data for the next session into the session map

fn authorities_for_session( &mut self, session_id: SessionId ) -> Option<SessionAuthorityData>

async fn catch_up(&mut self) -> SessionId

Puts current and next session authorities in the session map. If previous authorities are still available in AuthorityProvider, also puts them in the session map.

pub async fn run(self)