Module Trading_engine.External_replay

Replay runners driven by one supervised external strategy process.

type result = private {
  1. account : Account.t;
  2. orders : Order.t list;
  3. valuation : Account.valuation;
  4. audits : Audit.t list;
  5. strategy : Strategy_protocol.identity;
}
type streamed_result = private {
  1. run_id : Id.Run.t;
  2. scenario_sha256 : string;
  3. instrument_count : int;
  4. account : Account.t;
  5. orders : Order.t list;
  6. valuation : Account.valuation;
  7. audit_count : int64;
  8. slice_count : int64;
  9. strategy : Strategy_protocol.identity;
}
val run : ?durability:Artifact_writer.durability -> env:Eio_unix.Stdenv.base -> scenario_sha256:string -> journal_path:string -> transcript_path:string -> strategy_command:string list -> strategy_timeout:float -> Scenario.t -> (result, Diagnostic.t) Stdlib.result
val run_stream : ?durability:Artifact_writer.durability -> env:Eio_unix.Stdenv.base -> journal_path:string -> transcript_path:string -> strategy_command:string list -> strategy_timeout:float -> string -> (streamed_result, Diagnostic.t) Stdlib.result