Struct SessionAffinity 

pub struct SessionAffinity { /* private fields */ }

Mapping of a session to its assigned consumer.

Session affinity ensures that all messages for a given session are processed by the same consumer, maintaining ordering and state consistency.

Examples

use queue_runtime::sessions::SessionAffinity;
use queue_runtime::message::SessionId;
use std::time::{SystemTime, Duration};

let session_id = SessionId::new("order-789".to_string()).unwrap();
let affinity = SessionAffinity::new(
    session_id.clone(),
    "worker-3".to_string(),
    Duration::from_secs(300)
);

assert_eq!(affinity.session_id(), &session_id);
assert_eq!(affinity.consumer_id(), "worker-3");
assert!(!affinity.is_expired());

Implementations

impl SessionAffinity

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

Create a new session affinity mapping.

Arguments

• session_id - The session being tracked
• consumer_id - Identifier of the consumer assigned to this session
• affinity_duration - How long the affinity is valid

Returns

A new SessionAffinity instance

pub fn session_id(&self) -> &SessionId

Get the session ID.

pub fn consumer_id(&self) -> &str

Get the consumer ID.

pub fn affinity_duration(&self) -> Duration

Get the affinity duration.

pub fn assigned_at(&self) -> Instant

Get when the affinity was assigned.

pub fn is_expired(&self) -> bool

Check if the affinity has expired.

Returns

true if the affinity has expired, false otherwise

pub fn time_remaining(&self) -> Duration

Get the remaining time before expiration.

Returns

Duration remaining, or zero if expired

pub fn touch(&mut self)

Update the last activity time.

This is called when a message is processed for the session, keeping the affinity fresh.

pub fn idle_time(&self) -> Duration

Get the time since last activity.

pub fn extend(&self, additional_duration: Duration) -> Self

Extend the affinity expiration.

Arguments

• additional_duration - Additional time to add to expiration

Returns

A new SessionAffinity with extended expiration

Trait Implementations

impl Clone for SessionAffinity

fn clone(&self) -> SessionAffinity

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionAffinity

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

Formats the value using the given formatter.