Struct SessionPool 

pub struct SessionPool { /* private fields */ }

A bounded collection of reusable crawler sessions.

use millipede_core::session::{SessionPool, SessionPoolOptions};
let pool = SessionPool::new(SessionPoolOptions::default());

Implementations

impl SessionPool

pub fn new(options: SessionPoolOptions) -> Self

Creates an empty pool. Persistence can be attached once storage opens.

pub fn attach_persistence(&self, kvs: Arc<dyn KeyValueStore>)

Attaches the key-value store used by Self::persist and Self::restore.

pub async fn session(&self, sticky: Option<&SessionId>) -> Arc<Session>

Checks out a sticky usable session, creates one while below capacity, or rotates at random.

pub async fn retire_session(&self, id: &SessionId)

Retires the session with id when it exists.

pub async fn session_count(&self) -> usize

Returns the number of currently retained entries.

pub async fn persist(&self) -> Result<(), CrawlError>

Persists IDs, cookies, scores, usage, retirement, and original expiry.

pub async fn restore(&self) -> Result<(), CrawlError>

Replaces pool contents from persisted state, skipping entries with corrupt cookie JSON.