Struct ChainedSessionsBackend 

struct ChainedSessionsBackend {
    ctx: YiviCtx,
    sessions: HashMap<Id, ChainedSessionState>,
    expiry_queue: VecDeque<(Instant, Id)>,
}

Backend to ChainedSessionsCtl.

Fields

ctx: YiviCtx

sessions: HashMap<Id, ChainedSessionState>

expiry_queue: VecDeque<(Instant, Id)>

Session ids ordered by expiry instant. The session that will expire soonest is in the front. May contain ids already removed from Self::sessions (namely, sessions that completed normally before expiry).

Implementations

impl ChainedSessionsBackend

fn new(ctx: YiviCtx) -> Self

async fn handle_cmd(&mut self, cmd: CscCommand)

fn respond_to<T>(resp_sender: Sender<T>, resp: T, chained_session_id: Id)

async fn handle_create_session(&mut self, resp_sender: Sender<Result<Id>>)

async fn handle_wait_for_result( &mut self, chained_session_id: Id, resp_sender: Sender<Result<YiviWaitForResultResp>>, )

async fn handle_wait_for_next_session( &mut self, chained_session_id: Id, request_id: Id, disclosure: JWT, resp_sender: Sender<Result<Option<ExtendedSessionRequest>>>, )

async fn handle_abort_wait_for_next_session( &mut self, chained_session_id: Id, request_id: Id, )

async fn handle_release_next_session( &mut self, chained_session_id: Id, next_session_request: Option<ExtendedSessionRequest>, stale_after: Option<u16>, resp_sender: Sender<Result<YiviReleaseNextSessionResp>>, )

async fn sleep_until_next_expiry(&self)

fn expire_next(&mut self)