Struct MutationLeaseManager 

pub struct MutationLeaseManager { /* private fields */ }

In-memory lease authority for one daemon session namespace.

Implementations

impl MutationLeaseManager

pub fn acquire( &mut self, session_id: &str, owner_id: &str, now_ms: u64, ttl_ms: u64, ) -> Result<MutationLease, LeaseError>

Acquire the only mutation lease for a session.

pub fn renew( &mut self, session_id: &str, owner_id: &str, token: &str, now_ms: u64, ttl_ms: u64, ) -> Result<MutationLease, LeaseError>

Renew a lease without allowing a different owner to take it over.

pub fn release( &mut self, session_id: &str, owner_id: &str, token: &str, ) -> Result<(), LeaseError>

Release a lease only when the owner and token match.

pub fn validate( &self, session_id: &str, owner_id: &str, token: &str, now_ms: u64, ) -> Result<(), LeaseError>

Verify that a mutation request is still owned by the given client.

pub fn release_owner(&mut self, owner_id: &str)

Release every lease held by a disconnected client owner.

pub fn current_owner(&self, session_id: &str, now_ms: u64) -> Option<String>

Return the current owner for a session without exposing its token.

Trait Implementations

impl Debug for MutationLeaseManager

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

Formats the value using the given formatter.

impl Default for MutationLeaseManager

fn default() -> MutationLeaseManager

Returns the “default value” for a type.