Struct ExpirationManager 

pub struct ExpirationManager { /* private fields */ }

The expiration manager is resposible for revoking and renewing leases.

Implementations

impl ExpirationManager

pub fn new(router: Arc<Router>, repos: Repos, clock: impl Clock) -> Self

Create a new expiration manager.

pub async fn register(&self, le: LeaseEntry) -> Result<(), Error>

Register a new LeaseEntry.

This is the only way to register new leases, leases should not be inserted directly to the [LeaseStore] without going throught the expiration manager.

pub async fn revoke_leases_by_mount_prefix( &self, prefix: &str, namespace_id: &str, ) -> Result<Vec<LeaseEntry>, Error>

Revoke all leases issued by mounts under a given path prefix.

pub async fn list_by_mount_prefix( &self, prefix: &str, namespace_id: &str, ) -> Result<Vec<LeaseEntry>, Error>

List all leases issued by mounts under a given path prefix.

pub async fn lookup( &self, lease_id: &str, namespace_id: &str, ) -> Result<Option<LeaseEntry>, Error>

Lookup a lease by its id.

pub async fn revoke_lease_entry_by_id( &self, lease_id: &str, namespace_id: &str, ) -> Result<LeaseEntry, Error>

Revoke a lease by its id.

pub async fn renew_lease_entry( &self, lease_id: &str, namespace_id: &str, ttl: Option<Duration>, ) -> Result<LeaseEntry, Error>

Renew a lease by its id.

pub async fn start(&self) -> Result<(), Error>

Start the revocation worker.

pub async fn stop(&self)

Shutdown the expiration manager.