Struct mas_handlers::ActivityTracker

pub struct ActivityTracker { /* private fields */ }

Implementations

impl ActivityTracker

pub fn new(pool: PgPool, flush_interval: Duration) -> Self

Create a new activity tracker, spawning the worker.

pub fn bind(self, ip: Option<IpAddr>) -> Bound

Bind the activity tracker to an IP address.

pub async fn record_oauth2_session( &self, clock: &dyn Clock, session: &Session, ip: Option<IpAddr>, )

Record activity in an OAuth 2.0 session.

pub async fn record_compat_session( &self, clock: &dyn Clock, compat_session: &CompatSession, ip: Option<IpAddr>, )

Record activity in a compat session.

pub async fn record_browser_session( &self, clock: &dyn Clock, browser_session: &BrowserSession, ip: Option<IpAddr>, )

Record activity in a browser session.

pub async fn flush(&self)

Manually flush the activity tracker.

pub async fn shutdown(&self)

Shutdown the activity tracker.

This will wait for all pending messages to be processed.

Trait Implementations

impl Clone for ActivityTracker

fn clone(&self) -> ActivityTracker

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.