Struct EvaluationJobsRepository 

pub struct EvaluationJobsRepository<'a> { /* private fields */ }

Implementations

impl EvaluationJobsRepository<'_>

pub async fn claim_next( &self, worker_id: &str, accelerators: WorkerAccelerators, ) -> Result<Option<EvaluationJobRecord>>

pub async fn refresh_claim( &self, job_id: &EvaluationJobId, worker_id: &str, attempt_count: i32, ) -> Result<bool>

pub async fn runner_claim( &self, job_id: &EvaluationJobId, stale_minutes: i32, ) -> Result<Option<RunnerJobClaimRecord>>

pub async fn requeue_for_capacity( &self, job_id: &EvaluationJobId, worker_id: &str, attempt_count: i32, last_error: &str, ) -> Result<bool>

pub async fn mark_ready(&self, job_id: &EvaluationJobId) -> Result<()>

pub async fn queue( &self, input: &QueueEvaluationJobInput, ) -> Result<EvaluationJobRecord>

pub async fn count_active(&self, eval_type: ScoringMode) -> Result<i64>

pub async fn mark_started( &self, input: &MarkEvaluationStartedInput, ) -> Result<bool>

pub async fn mark_finished( &self, input: &PersistedEvaluationResult, ) -> Result<bool>

Trait Implementations

impl<'a> Clone for EvaluationJobsRepository<'a>

fn clone(&self) -> EvaluationJobsRepository<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for EvaluationJobsRepository<'a>

impl<'a> Debug for EvaluationJobsRepository<'a>

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

Formats the value using the given formatter.