Struct StaticServiceLeadershipGuard 

pub struct StaticServiceLeadershipGuard { /* private fields */ }

In-memory service lease guard for embedded hosts and tests.

Implementations

impl StaticServiceLeadershipGuard

pub fn new(leases: impl IntoIterator<Item = ServiceLeaderLease>) -> Self

Creates a guard from zero or more independently scoped leases.

pub fn set_service_lease( &self, service_id: ServiceId, lease: Option<ServiceLeaderLease>, ) -> ControlPlaneResult<()>

Adds, renews, or removes the lease for one service.

Trait Implementations

impl Clone for StaticServiceLeadershipGuard

fn clone(&self) -> StaticServiceLeadershipGuard

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StaticServiceLeadershipGuard

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

Formats the value using the given formatter.

impl Default for StaticServiceLeadershipGuard

fn default() -> StaticServiceLeadershipGuard

Returns the “default value” for a type.

impl ServiceLeadershipGuard for StaticServiceLeadershipGuard

fn current_service_lease( &self, service_id: &ServiceId, ) -> Option<ServiceLeaderLease>

Returns the current lease for service_id, when one is known.

fn check_service_write_permission( &self, service_id: &ServiceId, tenant_id: &TenantId, cluster_id: &ClusterId, core_id: &CoreId, min_epoch: Option<u64>, now_ms: u64, ) -> LeadershipDecision

Checks whether core_id may write for service_id at now_ms.