Trait CoordinatedStateStore 

pub trait CoordinatedStateStore {
    type Error: Error + Send + Sync + 'static;

    // Required methods
    fn load_or_initialize(
        &self,
        job_id: &str,
        initial_state: JobState,
    ) -> impl Future<Output = Result<CoordinatedRuntimeState, Self::Error>> + Send;
    fn save_state(
        &self,
        job_id: &str,
        revision: u64,
        state: &JobState,
    ) -> impl Future<Output = Result<bool, Self::Error>> + Send;
    fn reclaim_inflight(
        &self,
        job_id: &str,
        resource_id: &str,
        lease_config: CoordinatedLeaseConfig,
    ) -> impl Future<Output = Result<Option<CoordinatedClaim>, Self::Error>> + Send;
    fn claim_trigger(
        &self,
        job_id: &str,
        resource_id: &str,
        revision: u64,
        trigger: CoordinatedPendingTrigger,
        next_state: &JobState,
        lease_config: CoordinatedLeaseConfig,
        scope: ExecutionGuardScope,
    ) -> impl Future<Output = Result<Option<CoordinatedClaim>, Self::Error>> + Send;
    fn renew(
        &self,
        lease: &ExecutionLease,
        lease_config: CoordinatedLeaseConfig,
    ) -> impl Future<Output = Result<ExecutionGuardRenewal, Self::Error>> + Send;
    fn complete(
        &self,
        job_id: &str,
        lease: &ExecutionLease,
        completion: CoordinatedCompletion,
    ) -> impl Future<Output = Result<bool, Self::Error>> + Send;
    fn delete(
        &self,
        job_id: &str,
    ) -> impl Future<Output = Result<(), Self::Error>> + Send;
    fn pause(
        &self,
        job_id: &str,
    ) -> impl Future<Output = Result<bool, Self::Error>> + Send;
    fn resume(
        &self,
        job_id: &str,
    ) -> impl Future<Output = Result<bool, Self::Error>> + Send;

    // Provided methods
    fn classify_store_error(_error: &Self::Error) -> StoreErrorKind
       where Self: Sized { ... }
    fn classify_guard_error(_error: &Self::Error) -> ExecutionGuardErrorKind
       where Self: Sized { ... }
}

Required Associated Types

type Error: Error + Send + Sync + 'static

Required Methods

fn load_or_initialize( &self, job_id: &str, initial_state: JobState, ) -> impl Future<Output = Result<CoordinatedRuntimeState, Self::Error>> + Send

fn save_state( &self, job_id: &str, revision: u64, state: &JobState, ) -> impl Future<Output = Result<bool, Self::Error>> + Send

fn reclaim_inflight( &self, job_id: &str, resource_id: &str, lease_config: CoordinatedLeaseConfig, ) -> impl Future<Output = Result<Option<CoordinatedClaim>, Self::Error>> + Send

fn claim_trigger( &self, job_id: &str, resource_id: &str, revision: u64, trigger: CoordinatedPendingTrigger, next_state: &JobState, lease_config: CoordinatedLeaseConfig, scope: ExecutionGuardScope, ) -> impl Future<Output = Result<Option<CoordinatedClaim>, Self::Error>> + Send

fn renew( &self, lease: &ExecutionLease, lease_config: CoordinatedLeaseConfig, ) -> impl Future<Output = Result<ExecutionGuardRenewal, Self::Error>> + Send

fn complete( &self, job_id: &str, lease: &ExecutionLease, completion: CoordinatedCompletion, ) -> impl Future<Output = Result<bool, Self::Error>> + Send

fn delete( &self, job_id: &str, ) -> impl Future<Output = Result<(), Self::Error>> + Send

fn pause( &self, job_id: &str, ) -> impl Future<Output = Result<bool, Self::Error>> + Send

fn resume( &self, job_id: &str, ) -> impl Future<Output = Result<bool, Self::Error>> + Send

Provided Methods

fn classify_store_error(_error: &Self::Error) -> StoreErrorKind

where Self: Sized,

fn classify_guard_error(_error: &Self::Error) -> ExecutionGuardErrorKind

where Self: Sized,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<T> CoordinatedStateStore for Arc<T>

where T: CoordinatedStateStore + Send + Sync,

type Error = <T as CoordinatedStateStore>::Error

async fn load_or_initialize( &self, job_id: &str, initial_state: JobState, ) -> Result<CoordinatedRuntimeState, Self::Error>

async fn save_state( &self, job_id: &str, revision: u64, state: &JobState, ) -> Result<bool, Self::Error>

async fn reclaim_inflight( &self, job_id: &str, resource_id: &str, lease_config: CoordinatedLeaseConfig, ) -> Result<Option<CoordinatedClaim>, Self::Error>

async fn claim_trigger( &self, job_id: &str, resource_id: &str, revision: u64, trigger: CoordinatedPendingTrigger, next_state: &JobState, lease_config: CoordinatedLeaseConfig, scope: ExecutionGuardScope, ) -> Result<Option<CoordinatedClaim>, Self::Error>

async fn renew( &self, lease: &ExecutionLease, lease_config: CoordinatedLeaseConfig, ) -> Result<ExecutionGuardRenewal, Self::Error>

async fn complete( &self, job_id: &str, lease: &ExecutionLease, completion: CoordinatedCompletion, ) -> Result<bool, Self::Error>

async fn delete(&self, job_id: &str) -> Result<(), Self::Error>

async fn pause(&self, job_id: &str) -> Result<bool, Self::Error>

async fn resume(&self, job_id: &str) -> Result<bool, Self::Error>

fn classify_store_error(error: &Self::Error) -> StoreErrorKind

where Self: Sized,

fn classify_guard_error(error: &Self::Error) -> ExecutionGuardErrorKind

where Self: Sized,

Implementors

impl CoordinatedStateStore for NoopCoordinatedStateStore

type Error = Infallible

impl CoordinatedStateStore for ValkeyCoordinatedStateStore

type Error = ValkeyStoreError