Struct NoopCoordinatedStateStore 

pub struct NoopCoordinatedStateStore;

Trait Implementations

impl Clone for NoopCoordinatedStateStore

fn clone(&self) -> NoopCoordinatedStateStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CoordinatedStateStore for NoopCoordinatedStateStore

type Error = Infallible

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,

impl Debug for NoopCoordinatedStateStore

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

Formats the value using the given formatter.

impl Default for NoopCoordinatedStateStore

fn default() -> NoopCoordinatedStateStore

Returns the “default value” for a type.

impl Copy for NoopCoordinatedStateStore