Struct polkadot_node_subsystem_util::rolling_session_window::RollingSessionWindow

pub struct RollingSessionWindow { /* private fields */ }

A rolling window of sessions and cached session info.

Implementations

impl RollingSessionWindow

pub async fn new<Sender>(
    sender: Sender,
    window_size: SessionWindowSize,
    block_hash: Hash
) -> Result<Self, SessionsUnavailable>where
    Sender: SubsystemSender<RuntimeApiMessage>,

Initialize a new session info cache with the given window size.

pub fn with_session_info(
    window_size: SessionWindowSize,
    earliest_session: SessionIndex,
    session_info: Vec<SessionInfo>
) -> Self

Initialize a new session info cache with the given window size and initial data.

pub fn session_info(&self, index: SessionIndex) -> Option<&SessionInfo>

Access the session info for the given session index, if stored within the window.

pub fn earliest_session(&self) -> SessionIndex

Access the index of the earliest session.

pub fn latest_session(&self) -> SessionIndex

Access the index of the latest session.

pub async fn cache_session_info_for_head(
    &mut self,
    sender: &mut impl SubsystemSender<RuntimeApiMessage>,
    block_hash: Hash
) -> Result<SessionWindowUpdate, SessionsUnavailable>

When inspecting a new import notification, updates the session info cache to match the session of the imported block’s child.

this only needs to be called on heads where we are directly notified about import, as sessions do not change often and import notifications are expected to be typically increasing in session number.

some backwards drift in session index is acceptable.