Struct JobRuntime 

pub struct JobRuntime {

    pub job_id: Uuid,
    pub user_id: Uuid,
    pub strategy_name: String,
    pub base_sim_config: String,
    pub sentinel_config: String,
    pub payload_bytes: Vec<u8>,
    pub work_context_hash: WorkContextHash,
    pub status: JobRuntimeStatus,
    pub priority: i32,
    strategy: RuntimeStrategyState,
    in_flight: FastMap<ClaimToken, ClaimRecord>,
    pending_reclaims: VecDeque<RuntimeWorkItem>,
    recent_completions: CompletionLog,
    failed_items: u32,
    next_chunk_id: u64,
    next_item_id: u64,
}

Fields

job_id: Uuid

user_id: Uuid

strategy_name: String

base_sim_config: String

sentinel_config: String

payload_bytes: Vec<u8>

Encoded TournamentPayload, empty for non-tournament jobs.

work_context_hash: WorkContextHash

status: JobRuntimeStatus

priority: i32

strategy: RuntimeStrategyState

in_flight: FastMap<ClaimToken, ClaimRecord>

pending_reclaims: VecDeque<RuntimeWorkItem>

recent_completions: CompletionLog

failed_items: u32

next_chunk_id: u64

next_item_id: u64

Implementations

impl JobRuntime

fn new( init: JobRuntimeInit, strategy_name: &str, strategy: RuntimeStrategyState, ) -> Self

pub fn tournament( init: JobRuntimeInit, phases: Vec<Phase>, to_test: RoaringBitmap, ) -> Self

pub fn tournament_with_factorial( init: JobRuntimeInit, phases: Vec<Phase>, factorial: FactorialRuntime, ) -> Self

pub fn single(init: JobRuntimeInit, chunk_iterations: &[u32]) -> Self

pub fn stat_weights(init: JobRuntimeInit, runs: &[(u64, Vec<u32>)]) -> Self

Tag 0 is the full-fidelity baseline.

pub fn in_flight_len(&self) -> usize

pub fn in_flight_claims(&self) -> impl Iterator<Item = &ClaimRecord>

pub fn suggested_batch_size(&self) -> usize

pub fn progress_snapshot(&self) -> Option<ProgressSnapshot>

None for non-tournament jobs.

pub fn claim_batch( &mut self, node_public_key: &str, max_items: usize, now_ms: u64, ) -> Option<AssignedBatch>

Reassigns reclaimed work before fresh work.

pub fn authorize_context( &self, claim_token: &ClaimToken, hash: &WorkContextHash, node_public_key: &str, ) -> bool

pub fn reclaim_stale( &mut self, now_ms: u64, timeout_ms: u64, max_attempts: u32, ) -> ReclaimOutcome

pub fn has_failures(&self) -> bool

pub fn has_outstanding_work(&self) -> bool

pub fn is_complete(&self) -> bool

pub fn memory_breakdown(&self) -> RuntimeMemoryBreakdown

pub(in scheduler) fn claim_batch_with<F>( &mut self, node_public_key: &str, max_items: usize, now_ms: u64, claim_token: F, ) -> Option<AssignedBatch>

where F: FnOnce() -> ClaimToken,

pub(crate) fn complete( &mut self, chunk_id: RuntimeChunkId, claim_token: &ClaimToken, work_context_hash: &WorkContextHash, node_public_key: &str, results: &[RuntimeWorkResult], ) -> Result<CompletionOutcome, StrategyError>

pub(crate) fn finalize(&self) -> Result<FinalOutput, StrategyError>

Trait Implementations

impl Debug for JobRuntime

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

Formats the value using the given formatter.