Struct SessionInfo 

pub struct SessionInfo { /* private fields */ }

Information about an active session’s lifecycle state.

Tracks activity metrics used for determining when to close sessions based on duration limits, message counts, or inactivity timeouts.

Examples

use queue_runtime::{SessionInfo, SessionId};
use std::time::Duration;

let session_id = SessionId::new("order-123".to_string()).unwrap();
let mut info = SessionInfo::new(session_id.clone(), "worker-1".to_string());

// Record message processing
info.increment_message_count();
info.increment_message_count();

// Check duration
assert!(info.duration() < Duration::from_secs(1));

// Check message count
assert_eq!(info.message_count(), 2);

Implementations

impl SessionInfo

pub fn new(session_id: SessionId, consumer_id: String) -> Self

Create a new session info tracker.

pub fn session_id(&self) -> &SessionId

Get the session ID.

pub fn consumer_id(&self) -> &str

Get the consumer ID.

pub fn started_at(&self) -> Instant

Get the time when this session was started.

pub fn last_activity(&self) -> Instant

Get the time of last activity in this session.

pub fn message_count(&self) -> u32

Get the number of messages processed in this session.

pub fn duration(&self) -> Duration

Calculate how long this session has been active.

pub fn idle_time(&self) -> Duration

Calculate how long since last activity.

pub fn increment_message_count(&mut self)

Record message processing activity.

pub fn touch(&mut self)

Update last activity timestamp without incrementing message count.

Trait Implementations

impl Clone for SessionInfo

fn clone(&self) -> SessionInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionInfo

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.