Ag108/MoonReduce/reducer/project

reducer

Ag108/MoonReduce/reducer/project does not have a README file

Candidate

pub(all) struct Candidate {
  id : Int
  snapshot : @Ag108/MoonReduce/workspace/manifest.Snapshot
Snapshot
}

Snapshot request with a stable run-local sequence number.

ResultSummary

source

pub(all) struct ResultSummary {
  best : @Ag108/MoonReduce/workspace/manifest.Snapshot
Snapshot
  status : @Ag108/MoonReduce/model.RunStatus
RunStatus
  evaluations : Int
  cache_hits : Int
  baseline_passed : Int
  final_passed : Int
}

Session

source

pub struct Session {
  // private fields
}

Pure deterministic project session. Batch width is always four regardless of worker count; all replies are committed together, by score then id.

Session::baseline_statistics

source

fn Session::baseline_statistics(self : Session) -> @Ag108/MoonReduce/predicate/stability.Statistics
Statistics

Baseline success rate and confidence from actual command observations.

Session::checkpoint

source

fn Session::checkpoint(self : Session, original : @Ag108/MoonReduce/workspace/manifest.Snapshot
Snapshot, context : String) -> Result[Json, String]

Serialize a settled batch boundary. The caller supplies a canonical context containing predicate configuration and toolchain identity. Pending work must finish or use the previously saved boundary; it is never marked evaluated.

Session::final_statistics

source

fn Session::final_statistics(self : Session) -> @Ag108/MoonReduce/predicate/stability.Statistics
Statistics

Final success rate; restored sessions re-collect this evidence uncached.

Session::new

source

fn Session::new(original : @Ag108/MoonReduce/workspace/manifest.Snapshot
Snapshot, includes : Array[String], protects : Array[String], ignores : Array[String], max_tests? : Int, repeat? : Int, quorum? : Int, consecutive? : Bool, final_repeat? : Int, final_quorum? : Int, command_cost? : Int, score? : String, pass_include? : Array[String], pass_exclude? : Array[String], extra_passes? : Array[&@Ag108/MoonReduce/passes/api.ReductionPass
ReductionPass]) -> Result[Session, String]

Session::next_batch

source

fn Session::next_batch(self : Session) -> Array[Candidate]

Get the stable pending batch. Native drivers may evaluate it sequentially or with workers, but must return every issued result before the next batch.

Session::phase

source

fn Session::phase(self : Session) -> String

Session::record

source

fn Session::record(self : Session, id : Int, matched : Bool) -> Result[Unit, String]

Compatibility adapter for deterministic evaluators. In repeated mode the caller is responsible for evaluating the configured number of commands.

Session::record_result

source

fn Session::record_result(self : Session, id : Int, matched : Bool?, cost? : Int) -> Result[Unit, String]

Reject unknown/duplicate replies. A batch's completion order never decides its winner; the smallest score wins, then the first stable candidate id.

Session::restore

source

fn Session::restore(document : Json, original : @Ag108/MoonReduce/workspace/manifest.Snapshot
Snapshot, includes : Array[String], protects : Array[String], ignores : Array[String], context : String, max_tests? : Int, repeat? : Int, quorum? : Int, consecutive? : Bool, final_repeat? : Int, final_quorum? : Int, command_cost? : Int, score? : String, pass_include? : Array[String], pass_exclude? : Array[String], extra_passes? : Array[&@Ag108/MoonReduce/passes/api.ReductionPass
ReductionPass]) -> Result[Session, String]

Restore validated state and rebuild its lazy pass iterator. Completed cache entries suppress re-execution; final verification is always performed anew. The supplied total budget may be enlarged, but must cover work already done.

Session::result

source

fn Session::result(self : Session) -> ResultSummary

Session::stop

source

fn Session::stop(self : Session, status : @Ag108/MoonReduce/model.RunStatus
RunStatus) -> Unit

default_passes

source

fn default_passes() -> Array[&@Ag108/MoonReduce/passes/api.ReductionPass
ReductionPass]

Default pure passes in deterministic order; formatting and manifest edits are excluded unless explicitly enabled. Callers can compose these with extensions.