🥮 mooncakes.io

    zlhahaha/moonsim/models does not have a README file

    Backoff

    source

    EventFailureCase

    source

    EventKind

    source

    Built-in event categories for deterministic model traces.

    EventMutationPolicy

    source

    EventRecord

    source

    EventReplayResult

    source

    EventStream

    source

    EventStreamSnapshot

    source

    InvariantCheck

    source

    InvariantReport

    source

    MessageBus

    source

    Sim

    source

    Deterministic simulation state.

    TimerPlan

    source

    TraceEntry

    source

    A deterministic record of an action observed during a simulation run.

    ValidationIssue

    source

    ValidationReport

    source

    CircuitBreaker

    source
    pub(all) struct CircuitBreaker {
      name : String
      config : CircuitBreakerConfig
      state : String
      failures : Int
      opened_tick : Int
      trial_successes : Int
    }

    CircuitBreaker::allow

    source

    CircuitBreaker::new

    source
    fn CircuitBreaker::new(name : String, config? : CircuitBreakerConfig) -> CircuitBreaker

    CircuitBreaker::record_failure

    source
    fn CircuitBreaker::record_failure(self : CircuitBreaker, sim : 
    Sim    ) -> Unit

    CircuitBreaker::record_success

    source
    fn CircuitBreaker::record_success(self : CircuitBreaker, sim : 
    Sim    ) -> Unit

    CircuitBreaker::state

    source
    fn CircuitBreaker::state(self : CircuitBreaker) -> String

    CircuitBreakerConfig

    source
    pub(all) struct CircuitBreakerConfig {
      failure_threshold : Int
      reset_timeout : Int
      half_open_successes : Int
    }

    CircuitBreakerResult

    source
    pub(all) struct CircuitBreakerResult {
      state : String
      allowed : Int
      rejected : Int
      successes : Int
      failures : Int
      final_tick : Int
      digest : UInt64
    }

    CircuitBreakerResult::summary

    source

    HttpFailureCase

    source
    pub(all) struct HttpFailureCase {
      scenario : String
      policy : HttpReliabilityPolicy
      seed : UInt64
      failed_rule : String
      digest : UInt64
      exchanges : Array[RecordedHttpExchange]
      options : HttpReplayOptions
    }

    A reproducible failing sample that can be checked after a policy change.

    HttpFailureCase::replay

    source

    Replay the exact recording, seed, policy, and variation settings.

    HttpFailureCase::verify_fixed_policy

    source
    fn HttpFailureCase::verify_fixed_policy(self : HttpFailureCase, policy : HttpReliabilityPolicy) -> HttpReplayResult

    Recheck a failing recording with a revised policy and the original seed.

    HttpOutcome

    source
    pub(all) enum HttpOutcome {
      Response(HttpResponse)
      ConnectionFailure(String)
      Cancelled
    }

    The externally observed terminal result of an HTTP exchange.

    HttpReliabilityPolicy

    source
    pub(all) struct HttpReliabilityPolicy {
      seed : UInt64
      timeout_ticks : Int
      retry_limit : Int
      backoff_ticks : Int
      rate_limit_per_tick : Int
      circuit_failure_threshold : Int
      circuit_reset_ticks : Int
      deadline_ticks : Int
      accept_late_success : Bool
    }

    Retry and reliability rules evaluated during a deterministic replay.

    HttpReplayOptions

    source
    pub(all) struct HttpReplayOptions {
      latency_jitter : Int
      injected_failure_percent : Int
      reverse_same_tick_order : Bool
    }

    Optional deterministic changes applied to a recorded transport.

    HttpReplayResult

    source
    pub(all) struct HttpReplayResult {
      policy : HttpReliabilityPolicy
      http_successes : Int
      on_time_successes : Int
      late_successes : Int
      late_success_accepted : Int
      failed : Int
      timed_out : Int
      connection_failures : Int
      cancelled : Int
      duplicate_processed : Int
      retry_limit_violations : Int
      rate_limited : Int
      circuit_rejected : Int
      deadline_misses : Int
      digest : UInt64
      invariants : 
    InvariantReport
      trace : Array[
    TraceEntry    ]
    }

    Aggregate result and evidence from a recorded HTTP replay.

    HttpRequest

    source
    pub(all) struct HttpRequest {
      id : String
      http_method : String
      path : String
      attempt : Int
    }

    The request metadata captured by an external HTTP integration test.

    HttpResponse

    source
    pub(all) struct HttpResponse {
      status : Int
      body_summary : String
    }

    A compact response summary. Bodies are deliberately not retained by default.

    LoadBalancerConfig

    source
    pub(all) struct LoadBalancerConfig {
      seed : UInt64
      jobs : Int
      workers : Int
      max_arrival_gap : Int
      min_service : Int
      max_service : Int
      strategy : String
    }

    LoadBalancerResult

    source
    pub(all) struct LoadBalancerResult {
      jobs : Int
      workers : Int
      strategy : String
      final_tick : Int
      max_queue_depth : Int
      total_wait : Int
      events_executed : Int
      digest : UInt64
    }

    ModelSummary

    source
    pub(all) struct ModelSummary {
      name : String
      digest : UInt64
      final_tick : Int
      events : Int
    }

    ModelSummary::line

    source
    fn ModelSummary::line(self : ModelSummary) -> String

    NetworkConfig

    source
    pub(all) struct NetworkConfig {
      seed : UInt64
      messages : Int
      latency_min : Int
      latency_max : Int
      drop_percent : Int
      retry_delay : Int
    }

    NetworkResult

    source
    pub(all) struct NetworkResult {
      messages : Int
      delivered : Int
      dropped : Int
      retries : Int
      pending : Int
      final_tick : Int
      digest : UInt64
      trace : Array[
    TraceEntry    ]
    }

    QueueConfig

    source
    pub(all) struct QueueConfig {
      seed : UInt64
      customers : Int
      max_arrival_gap : Int
      service_time : Int
    }

    QueueResult

    source
    pub(all) struct QueueResult {
      customers : Int
      events_executed : Int
      final_tick : Int
      min_arrival : Int
      max_arrival : Int
      digest : UInt64
      trace : Array[
    TraceEntry    ]
    }

    QueueResult::event_stream

    source

    Projects queue arrivals and completions into the shared message event stream.

    RecordedHttpExchange

    source
    pub(all) struct RecordedHttpExchange {
      request : HttpRequest
      outcome : HttpOutcome
      started_tick : Int
      latency_ticks : Int
    }

    One HTTP exchange recorded outside the simulator.

    RecordedHttpTransport

    source
    pub(all) struct RecordedHttpTransport {
      scenario : String
      exchanges : Array[RecordedHttpExchange]
      options : HttpReplayOptions
    }

    A pure replay transport. It never opens a socket or invokes a real service.

    RecordedHttpTransport::event_stream

    source

    Projects recorded calls into the common external-call event representation.

    RecordedHttpTransport::failure_case

    source

    Return the first failed invariant as replayable evidence, if any.

    RecordedHttpTransport::replay

    source

    Replay the recording with virtual time and a deterministic seed.

    RecordedHttpTransport::to_json

    source
    fn RecordedHttpTransport::to_json(self : RecordedHttpTransport, policy? : HttpReliabilityPolicy) -> String

    Emit stable JSON evidence. This encoder only serializes the compact model types.

    ReliabilityConfig

    source
    pub(all) struct ReliabilityConfig {
      seed : UInt64
      operations : Int
      fail_percent : Int
      retry_limit : Int
      backoff : Int
    }

    ReliabilityResult

    source
    pub(all) struct ReliabilityResult {
      operations : Int
      successes : Int
      failures : Int
      retries : Int
      exhausted : Int
      final_tick : Int
      digest : UInt64
      trace : Array[
    TraceEntry    ]
    }

    ReliabilityResult::line

    source
    fn ReliabilityResult::line(self : ReliabilityResult) -> String

    ReliabilityResult::success_rate_percent

    source
    fn ReliabilityResult::success_rate_percent(self : ReliabilityResult) -> Int

    ReliabilityResult::summary

    source

    RetryConfig

    source
    pub(all) struct RetryConfig {
      seed : UInt64
      max_attempts : Int
      fail_until : Int
      initial_backoff : Int
      jitter : Int
    }

    RetryResult

    source
    pub(all) struct RetryResult {
      attempts : Int
      retries : Int
      success : Bool
      final_tick : Int
      digest : UInt64
      trace : Array[
    TraceEntry    ]
    }

    SeedMatrix

    source
    pub(all) struct SeedMatrix {
      name : String
      runs : Array[SeedRun]
    }

    SeedMatrix::add

    source
    fn SeedMatrix::add(self : SeedMatrix, run : SeedRun) -> SeedMatrix

    SeedMatrix::combined_digest

    source
    fn SeedMatrix::combined_digest(self : SeedMatrix) -> UInt64

    SeedMatrix::count

    source
    fn SeedMatrix::count(self : SeedMatrix) -> Int

    SeedMatrix::fastest

    source
    fn SeedMatrix::fastest(self : SeedMatrix) -> SeedRun?

    SeedMatrix::has_seed

    source
    fn SeedMatrix::has_seed(self : SeedMatrix, seed : UInt64) -> Bool

    SeedMatrix::is_empty

    source
    fn SeedMatrix::is_empty(self : SeedMatrix) -> Bool

    SeedMatrix::lines

    source
    fn SeedMatrix::lines(self : SeedMatrix) -> Array[String]

    SeedMatrix::max_final_tick

    source
    fn SeedMatrix::max_final_tick(self : SeedMatrix) -> Int

    SeedMatrix::new

    source
    fn SeedMatrix::new(name : String) -> SeedMatrix

    SeedMatrix::render

    source
    fn SeedMatrix::render(self : SeedMatrix) -> String

    SeedMatrix::slowest

    source
    fn SeedMatrix::slowest(self : SeedMatrix) -> SeedRun?

    SeedMatrix::summary_line

    source
    fn SeedMatrix::summary_line(self : SeedMatrix) -> String

    SeedMatrix::tick_span

    source
    fn SeedMatrix::tick_span(self : SeedMatrix) -> Int

    SeedMatrix::total_events

    source
    fn SeedMatrix::total_events(self : SeedMatrix) -> Int

    SeedMatrix::unique_digests

    source
    fn SeedMatrix::unique_digests(self : SeedMatrix) -> Int

    SeedMatrixComparison

    source
    pub(all) struct SeedMatrixComparison {
      left_name : String
      right_name : String
      same_digest : Bool
      same_count : Bool
      left_digest : UInt64
      right_digest : UInt64
      left_count : Int
      right_count : Int
    }

    SeedMatrixComparison::count_changed

    source
    fn SeedMatrixComparison::count_changed(self : SeedMatrixComparison) -> Bool

    SeedMatrixComparison::digest_changed

    source
    fn SeedMatrixComparison::digest_changed(self : SeedMatrixComparison) -> Bool

    SeedMatrixComparison::fully_changed

    source
    fn SeedMatrixComparison::fully_changed(self : SeedMatrixComparison) -> Bool

    SeedMatrixComparison::is_stable

    source
    fn SeedMatrixComparison::is_stable(self : SeedMatrixComparison) -> Bool

    SeedMatrixComparison::matched

    source
    fn SeedMatrixComparison::matched(self : SeedMatrixComparison) -> Bool

    SeedMatrixComparison::summary

    source
    fn SeedMatrixComparison::summary(self : SeedMatrixComparison) -> String

    SeedRun

    source
    pub(all) struct SeedRun {
      seed : UInt64
      summary : ModelSummary
    }

    ServiceResilienceConfig

    source
    pub(all) struct ServiceResilienceConfig {
      seed : UInt64
      requests : Int
      workers : Int
      queue_limit : Int
      timeout_ticks : Int
      retry_limit : Int
      base_latency : Int
      jitter : Int
      fail_percent : Int
      drop_percent : Int
      rate_limit_capacity : Int
      rate_limit_refill : Int
      rate_limit_interval : Int
      min_success_percent : Int
    }

    ServiceResilienceResult

    source
    pub(all) struct ServiceResilienceResult {
      config : ServiceResilienceConfig
      accepted : Int
      rejected : Int
      completed : Int
      failed : Int
      timed_out : Int
      late_successes : Int
      retried : Int
      rate_limited : Int
      circuit_rejected : Int
      max_queue_depth : Int
      final_tick : Int
      slo_passed : Bool
      latency_count : Int
      latency_min : Int
      latency_max : Int
      latency_sum : Int
      digest : UInt64
      invariants : 
    InvariantReport
      trace : Array[
    TraceEntry    ]
    }

    ServiceResilienceResult::average_latency

    source
    fn ServiceResilienceResult::average_latency(self : ServiceResilienceResult) -> Int

    ServiceResilienceResult::line

    source

    ServiceResilienceResult::success_percent

    source
    fn ServiceResilienceResult::success_percent(self : ServiceResilienceResult) -> Int

    ServiceResilienceResult::summary

    source

    TokenBucket

    source
    pub(all) struct TokenBucket {
      name : String
      capacity : Int
      refill : Int
      interval : Int
      tokens : Int
      last_refill_tick : Int
    }

    TokenBucket::allow

    source
    fn TokenBucket::allow(self : TokenBucket, sim : 
    Sim    , cost? : Int) -> Bool

    TokenBucket::new

    source
    fn TokenBucket::new(name : String, capacity? : Int, refill? : Int, interval? : Int) -> TokenBucket

    TokenBucket::refill_to

    source
    fn TokenBucket::refill_to(self : TokenBucket, tick : Int) -> Unit

    TokenBucketResult

    source
    pub(all) struct TokenBucketResult {
      allowed : Int
      rejected : Int
      final_tokens : Int
      final_tick : Int
      digest : UInt64
    }

    TokenBucketResult::summary

    source

    TrafficConfig

    source
    pub(all) struct TrafficConfig {
      seed : UInt64
      cycles : Int
      cars : Int
      cycle_ticks : Int
    }

    TrafficResult

    source
    pub(all) struct TrafficResult {
      cars : Int
      green_phases : Int
      red_phases : Int
      events_executed : Int
      final_tick : Int
      digest : UInt64
    }

    WorkflowPlan

    source
    pub(all) struct WorkflowPlan {
      worker_count : Int
      tasks : Array[WorkflowTask]
    }

    WorkflowPlan::add

    source
    fn WorkflowPlan::add(self : WorkflowPlan, name : String, duration : Int, deps? : Array[Int]) -> WorkflowPlan

    WorkflowPlan::new

    source
    fn WorkflowPlan::new(worker_count? : Int) -> WorkflowPlan

    WorkflowPlan::task_count

    source
    fn WorkflowPlan::task_count(self : WorkflowPlan) -> Int

    WorkflowPlan::validate

    source

    WorkflowResult

    source
    pub(all) struct WorkflowResult {
      tasks : Int
      workers : Int
      final_tick : Int
      critical_path : Int
      runs : Array[WorkflowTaskRun]
      digest : UInt64
    }

    WorkflowResult::event_stream

    source

    Projects completed workflow runs into the shared task event stream.

    WorkflowResult::render

    source
    fn WorkflowResult::render(self : WorkflowResult) -> String

    WorkflowResult::summary

    source

    WorkflowTask

    source
    pub(all) struct WorkflowTask {
      id : Int
      name : String
      duration : Int
      deps : Array[Int]
    }

    WorkflowTaskRun

    source
    pub(all) struct WorkflowTaskRun {
      id : Int
      name : String
      worker : Int
      start_tick : Int
      finish_tick : Int
    }

    check_sim_invariants

    source

    circuit_breaker_config

    source
    fn circuit_breaker_config(failure_threshold? : Int, reset_timeout? : Int, half_open_successes? : Int) -> CircuitBreakerConfig

    compare_seed_matrices

    source
    fn compare_seed_matrices(left : SeedMatrix, right : SeedMatrix) -> SeedMatrixComparison

    http_reliability_policy

    source
    fn http_reliability_policy(seed? : UInt64, timeout_ticks? : Int, retry_limit? : Int, backoff_ticks? : Int, rate_limit_per_tick? : Int, circuit_failure_threshold? : Int, circuit_reset_ticks? : Int, deadline_ticks? : Int, accept_late_success? : Bool) -> HttpReliabilityPolicy

    Build a replay policy. A zero rate limit disables rate limiting.

    http_replay_options

    source
    fn http_replay_options(latency_jitter? : Int, injected_failure_percent? : Int, reverse_same_tick_order? : Bool) -> HttpReplayOptions

    Build deterministic variation settings for a recorded transport.

    http_request

    source
    fn http_request(id : String, http_method? : String, path? : String, attempt? : Int) -> HttpRequest

    Build a recorded request. Attempts start at one.

    http_response

    source
    fn http_response(status : Int, body_summary? : String) -> HttpResponse

    Build a response summary suitable for deterministic replay.

    invariant_check

    source
    fn invariant_check(name : String, passed : Bool, detail? : String) -> 
    InvariantCheck

    load_balancer_config

    source
    fn load_balancer_config(seed? : UInt64, jobs? : Int, workers? : Int, max_arrival_gap? : Int, min_service? : Int, max_service? : Int, strategy? : String) -> LoadBalancerConfig

    load_balancer_seed_matrix

    source
    fn load_balancer_seed_matrix(seeds : Array[UInt64], strategy? : String) -> SeedMatrix

    load_balancer_summary

    source
    fn load_balancer_summary(result : LoadBalancerResult) -> ModelSummary

    network_config

    source
    fn network_config(seed? : UInt64, messages? : Int, latency_min? : Int, latency_max? : Int, drop_percent? : Int, retry_delay? : Int) -> NetworkConfig

    network_seed_matrix

    source
    fn network_seed_matrix(seeds : Array[UInt64]) -> SeedMatrix

    network_summary

    source
    fn network_summary(result : NetworkResult) -> ModelSummary

    package_name

    source
    fn package_name() -> String

    queue_config

    source
    fn queue_config(seed? : UInt64, customers? : Int, max_arrival_gap? : Int, service_time? : Int) -> QueueConfig

    queue_summary

    source
    fn queue_summary(result : QueueResult) -> ModelSummary

    recorded_http_exchange

    source
    fn recorded_http_exchange(request : HttpRequest, outcome : HttpOutcome, started_tick? : Int, latency_ticks? : Int) -> RecordedHttpExchange

    Build an externally recorded exchange.

    recorded_http_transport

    source
    fn recorded_http_transport(scenario : String, exchanges : Array[RecordedHttpExchange], options? : HttpReplayOptions) -> RecordedHttpTransport

    Create a transport from HTTP exchanges captured by an external test.

    reliability_config

    source
    fn reliability_config(seed? : UInt64, operations? : Int, fail_percent? : Int, retry_limit? : Int, backoff? : Int) -> ReliabilityConfig

    render_service_resilience_report

    source
    fn render_service_resilience_report(result : ServiceResilienceResult) -> String

    retry_config

    source
    fn retry_config(seed? : UInt64, max_attempts? : Int, fail_until? : Int, initial_backoff? : Int, jitter? : Int) -> RetryConfig

    retry_seed_matrix

    source
    fn retry_seed_matrix(seeds : Array[UInt64]) -> SeedMatrix

    retry_summary

    source
    fn retry_summary(result : RetryResult) -> ModelSummary

    retry_timeout_fault_policy

    source
    fn retry_timeout_fault_policy() -> HttpReliabilityPolicy

    A deliberately unsafe policy used to demonstrate a detected invariant failure.

    retry_timeout_fixed_policy

    source
    fn retry_timeout_fixed_policy() -> HttpReliabilityPolicy

    The corrected policy rejects an original success that arrived after its deadline.

    retry_timeout_recording

    source
    fn retry_timeout_recording() -> RecordedHttpTransport

    A small fixture showing a retry whose original request succeeds after its deadline.

    run_circuit_breaker_model

    source
    fn run_circuit_breaker_model(seed? : UInt64, calls? : Int) -> CircuitBreakerResult

    run_load_balancer_model

    source
    fn run_load_balancer_model(config : LoadBalancerConfig) -> LoadBalancerResult

    run_network_model

    source
    fn run_network_model(config : NetworkConfig) -> NetworkResult

    run_queue_model

    source
    fn run_queue_model(config : QueueConfig) -> QueueResult

    run_reliability_model

    source
    fn run_reliability_model(config : ReliabilityConfig) -> ReliabilityResult

    run_retry_model

    source
    fn run_retry_model(config : RetryConfig) -> RetryResult

    run_service_resilience_suite

    source
    fn run_service_resilience_suite(config? : ServiceResilienceConfig) -> ServiceResilienceResult

    run_token_bucket_model

    source
    fn run_token_bucket_model(seed? : UInt64, requests? : Int) -> TokenBucketResult

    run_traffic_model

    source
    fn run_traffic_model(config : TrafficConfig) -> TrafficResult

    run_workflow_model

    source
    fn run_workflow_model(plan : WorkflowPlan, seed? : UInt64) -> WorkflowResult

    seed_run

    source
    fn seed_run(seed : UInt64, summary : ModelSummary) -> SeedRun

    service_resilience_config

    source
    fn service_resilience_config(seed? : UInt64, requests? : Int, workers? : Int, queue_limit? : Int, timeout_ticks? : Int, retry_limit? : Int, base_latency? : Int, jitter? : Int, fail_percent? : Int, drop_percent? : Int, rate_limit_capacity? : Int, rate_limit_refill? : Int, rate_limit_interval? : Int, min_success_percent? : Int) -> ServiceResilienceConfig

    service_resilience_seed_matrix

    source
    fn service_resilience_seed_matrix(seeds : Array[UInt64]) -> SeedMatrix

    timer_plan

    source
    fn timer_plan(name : String, start_after? : Int, interval? : Int, times? : Int, priority? : Int) -> 
    TimerPlan

    trace_digest

    source
    fn trace_digest(entries : Array[
    TraceEntry    ]) -> UInt64

    trace_entry

    source
    fn trace_entry(tick : Int, event_id : Int, kind : String, detail : String) -> 
    TraceEntry

    traffic_config

    source
    fn traffic_config(seed? : UInt64, cycles? : Int, cars? : Int, cycle_ticks? : Int) -> TrafficConfig

    traffic_summary

    source
    fn traffic_summary(result : TrafficResult) -> ModelSummary

    validation_issue

    source
    fn validation_issue(code : String, message : String, severity? : String) -> 
    ValidationIssue

    version

    source
    fn version() -> String

    workflow_critical_path

    source
    fn workflow_critical_path(plan : WorkflowPlan) -> Int

    Source Files

    Powered by MoonBit

    Site sourceReport issuePackagesBuild queueSkillsStatistics

    © 2026 mooncakes.io