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,
    ) -> 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,
        revision: u64,
        lease: &ExecutionLease,
        state: &JobState,
    ) -> impl Future<Output = Result<bool, Self::Error>> + Send;
    fn delete(
        &self,
        job_id: &str,
    ) -> impl Future<Output = Result<(), 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, ) -> 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, revision: u64, lease: &ExecutionLease, state: &JobState, ) -> impl Future<Output = Result<bool, Self::Error>> + Send

fn delete( &self, job_id: &str, ) -> impl Future<Output = Result<(), 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", so this trait is not object safe.

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, ) -> 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, revision: u64, lease: &ExecutionLease, state: &JobState, ) -> Result<bool, Self::Error>

async fn delete(&self, job_id: &str) -> Result<(), 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