🥮 mooncakes.io

    vectie/moontown/core does not have a README file

    BookProvider

    source
    pub(open) trait BookProvider {
      fn books(self : Self) -> Array[BookRef]
    }

    AssignmentPlan

    source
    pub struct AssignmentPlan {
      task_id : String
      worker_id : String
      book_id : String
      isolation : IsolationMode
      reason : String
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    AssignmentPlan::new

    source
    fn AssignmentPlan::new(task_id~ : String, worker_id~ : String, book_id~ : String, isolation~ : IsolationMode, reason~ : String) -> AssignmentPlan

    BookRef

    source
    pub struct BookRef {
      id : String
      name : String
      purpose : String
      workspace_root : String
      memory_scope : MemoryScope
      tags : Array[String]
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    impl Show for BookRef

    BookRef::new

    source
    fn BookRef::new(id~ : String, name~ : String, purpose~ : String, workspace_root~ : String, memory_scope? : MemoryScope, tags? : Array[String]) -> BookRef

    IsolationMode

    source
    pub(all) enum IsolationMode {
      SharedWorkspace
      BookWorkspace
      Worktree
      Sandboxed
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    MemoryScope

    source
    pub(all) enum MemoryScope {
      SharedTown
      BookPrivate
      TaskEphemeral
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    impl Show for MemoryScope

    StandingGoal

    source
    pub struct StandingGoal {
      id : String
      title : String
      prompt : String
      target_book_id : String?
      cadence_ticks : Int
      next_due_tick : Int
      last_run_tick : Int?
      enabled : Bool
      source_policy : String
      quality_threshold : Int
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    StandingGoal::is_due

    source
    fn StandingGoal::is_due(self : StandingGoal, tick : Int) -> Bool

    StandingGoal::mark_dispatched

    source
    fn StandingGoal::mark_dispatched(self : StandingGoal, tick : Int) -> StandingGoal

    StandingGoal::mark_watcher_decision

    source
    fn StandingGoal::mark_watcher_decision(self : StandingGoal, tick : Int, decision : WatcherDecisionKind, no_change_streak? : Int) -> StandingGoal

    StandingGoal::new

    source
    fn StandingGoal::new(id~ : String, title~ : String, prompt~ : String, target_book_id? : String?, cadence_ticks? : Int, next_due_tick? : Int, last_run_tick? : Int?, enabled? : Bool, source_policy? : String, quality_threshold? : Int) -> StandingGoal

    StandingGoal::next_due_after_watcher_decision

    source
    fn StandingGoal::next_due_after_watcher_decision(self : StandingGoal, tick : Int, decision : WatcherDecisionKind, no_change_streak? : Int) -> Int

    StaticBookProvider

    source
    pub struct StaticBookProvider {
      entries : Array[BookRef]
    } derive(Eq, 
    Debug    )

    StaticBookProvider::new

    source

    TaskExecutionRecord

    source
    pub struct TaskExecutionRecord {
      task_id : String
      book_id : String
      packet_id : String
      packet_path : String
      proposal_id : String?
      run_id : String?
      status : TaskExecutionStatus
      summary : String
      output_contract : String
      context_pages : Array[String]
      skill_paths : Array[String]
      last_command : String?
      assigned_worker_id : String?
      attempt : Int
      heartbeat_tick : Int
      stale_after_tick : Int
      next_retry_tick : Int?
      result_decision : String
      requires_review : Bool
      notify_town : Bool
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    TaskExecutionRecord::new

    source
    fn TaskExecutionRecord::new(task_id~ : String, book_id~ : String, packet_id~ : String, packet_path~ : String, proposal_id? : String?, run_id? : String?, status~ : TaskExecutionStatus, summary~ : String, output_contract~ : String, context_pages? : Array[String], skill_paths? : Array[String], last_command? : String?, assigned_worker_id? : String?, attempt? : Int, heartbeat_tick? : Int, stale_after_tick? : Int, next_retry_tick? : Int?, result_decision? : String, requires_review? : Bool, notify_town? : Bool) -> TaskExecutionRecord

    TaskExecutionStatus

    source
    pub(all) enum TaskExecutionStatus {
      PacketReady
      ProposalImported
      RunConfirmed
      Running
      AwaitingPersistence
      ReviewQueued
      Completed
      Stale
      Failed
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    TownConfig

    source
    pub struct TownConfig {
      id : String
      name : String
      heartbeat_seconds : Int
      max_concurrent_tasks : Int
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    impl Show for TownConfig

    TownConfig::new

    source
    fn TownConfig::new(id~ : String, name~ : String, heartbeat_seconds? : Int, max_concurrent_tasks? : Int) -> TownConfig

    TownEvent

    source
    pub struct TownEvent {
      id : String
      kind : String
      detail : String
      related_task_id : String?
      related_book_id : String?
      related_proposal_id : String?
      related_run_id : String?
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    impl Show for TownEvent

    TownEvent::new

    source
    fn TownEvent::new(id~ : String, kind~ : String, detail~ : String, related_task_id? : String?, related_book_id? : String?, related_proposal_id? : String?, related_run_id? : String?) -> TownEvent

    TownState

    source

    impl Show for TownState

    TownState::enqueue_task

    source
    fn TownState::enqueue_task(self : TownState, task : TownTask) -> Unit

    TownState::record_event

    source
    fn TownState::record_event(self : TownState, event : TownEvent) -> Unit

    TownState::register_book

    source
    fn TownState::register_book(self : TownState, book : BookRef) -> Unit

    TownState::register_execution

    source
    fn TownState::register_execution(self : TownState, execution : TaskExecutionRecord) -> Unit

    TownState::register_worker

    source
    fn TownState::register_worker(self : TownState, worker : WorkerRef) -> Unit

    TownState::replace_execution

    source
    fn TownState::replace_execution(self : TownState, execution : TaskExecutionRecord) -> Unit

    TownState::replace_task

    source
    fn TownState::replace_task(self : TownState, task : TownTask) -> Unit

    TownState::set_worker_status

    source
    fn TownState::set_worker_status(self : TownState, worker_id : String, status : WorkerStatus) -> Unit

    TownTask

    source
    pub struct TownTask {
      id : String
      book_id : String
      title : String
      prompt : String
      domain : WorkDomain
      required_role : WorkerRole?
      required_capabilities : Array[String]
      status : TownTaskStatus
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    impl Show for TownTask

    TownTask::new

    source
    fn TownTask::new(id~ : String, book_id~ : String, title~ : String, prompt~ : String, domain~ : WorkDomain, required_role? : WorkerRole?, required_capabilities? : Array[String], status? : TownTaskStatus) -> TownTask

    TownTaskStatus

    source
    pub(all) enum TownTaskStatus {
      Pending
      Planned
      Assigned
      Running
      Blocked
      Done
      Failed
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    WatcherDecisionKind

    source
    pub(all) enum WatcherDecisionKind {
      Update
      NoChange
      NeedsReview
      Failed
      Deferred
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    WatcherRunRecord

    source
    pub struct WatcherRunRecord {
      goal_id : String
      tick : Int
      target_book_id : String
      decision : WatcherDecisionKind
      delta_score : Int
      new_source_count : Int
      detail : String
      task_id : String?
      run_id : String?
      next_due_tick : Int
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    WatcherRunRecord::new

    source
    fn WatcherRunRecord::new(goal_id~ : String, tick~ : Int, target_book_id~ : String, decision~ : WatcherDecisionKind, delta_score? : Int, new_source_count? : Int, detail? : String, task_id? : String?, run_id? : String?, next_due_tick? : Int) -> WatcherRunRecord

    WorkDomain

    source
    pub(all) enum WorkDomain {
      Coding
      Finance
      Research
      Operations
      SocialExperiment
      Custom(String)
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    impl Show for WorkDomain

    WorkerRef

    source
    pub struct WorkerRef {
      id : String
      name : String
      book_id : String
      role : WorkerRole
      capabilities : Array[String]
      status : WorkerStatus
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    impl Show for WorkerRef

    WorkerRef::new

    source
    fn WorkerRef::new(id~ : String, name~ : String, book_id~ : String, role~ : WorkerRole, capabilities? : Array[String], status? : WorkerStatus) -> WorkerRef

    WorkerRole

    source
    pub(all) enum WorkerRole {
      Harness
      Planner
      Specialist
      Reviewer
      MemoryKeeper
      Watcher
      Operator
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    impl Show for WorkerRole

    WorkerStatus

    source
    pub(all) enum WorkerStatus {
      Idle
      Running
      Waiting
      Blocked
      Offline
    } derive(Eq, ToJson, 
    Debug    , 
    FromJson    )

    absolute_path_from_base

    source
    fn absolute_path_from_base(base : String, path : String) -> String

    active_work_execution_status

    source
    fn active_work_execution_status(status : TaskExecutionStatus) -> Bool

    copy_task_with_status

    source
    fn copy_task_with_status(task : TownTask, status : TownTaskStatus) -> TownTask

    empty_state

    source
    fn empty_state(config : TownConfig) -> TownState

    execution_status_rank

    source
    fn execution_status_rank(status : TaskExecutionStatus) -> Int

    external_execution_stale_window_ticks

    source
    fn external_execution_stale_window_ticks() -> Int

    find_execution

    source
    fn find_execution(town : TownState, task_id : String) -> TaskExecutionRecord?

    find_task

    source
    fn find_task(town : TownState, task_id : String) -> TownTask?

    has_active_work_executions

    source
    fn has_active_work_executions(state : TownState) -> Bool

    has_live_executions

    source
    fn has_live_executions(state : TownState) -> Bool

    has_retry_pending_executions

    source
    fn has_retry_pending_executions(state : TownState, tick : Int) -> Bool

    json_object_copy

    source
    fn json_object_copy(value : Json?) -> Map[String, Json]

    live_execution_status

    source
    fn live_execution_status(status : TaskExecutionStatus) -> Bool

    live_external_execution_count

    source
    fn live_external_execution_count(state : TownState) -> Int

    max_live_external_executions

    source
    fn max_live_external_executions() -> Int

    no_run_id_live_execution_stale

    source
    fn no_run_id_live_execution_stale(execution : TaskExecutionRecord, tick : Int) -> Bool

    pollable_execution_status

    source
    fn pollable_execution_status(status : TaskExecutionStatus) -> Bool

    polled_execution_stale_window_ticks

    source
    fn polled_execution_stale_window_ticks(execution : TaskExecutionRecord) -> Int

    schedulable_task_status

    source
    fn schedulable_task_status(status : TownTaskStatus) -> Bool

    standing_goal_registry_find

    source
    fn standing_goal_registry_find(goals : Array[StandingGoal], goal_id : String) -> StandingGoal?

    standing_goal_registry_merge_updates

    source
    fn standing_goal_registry_merge_updates(latest : Array[StandingGoal], updated : Array[StandingGoal]) -> Array[StandingGoal]

    standing_goal_registry_replace_or_append

    source
    fn standing_goal_registry_replace_or_append(goals : Array[StandingGoal], replacement : StandingGoal) -> Array[StandingGoal]

    terminal_execution_status

    source
    fn terminal_execution_status(status : TaskExecutionStatus) -> Bool

    tick_from_task_id

    source
    fn tick_from_task_id(task_id : String) -> Int

    town_task_status_for_execution

    source
    fn town_task_status_for_execution(status : TaskExecutionStatus) -> TownTaskStatus

    upsert_moonclaw_job_profile_json

    source
    fn upsert_moonclaw_job_profile_json(config : Json, profile_id : String, profile : Json) -> Json

    upsert_nested_object_entry_json

    source
    fn upsert_nested_object_entry_json(config : Json, section_key~ : String, collection_key~ : String, entry_key~ : String, entry~ : Json) -> Json

    Source Files

    Powered by MoonBit

    Site sourceReport issueModulesSkillsCLIBuild queueStatistics

    © 2026 mooncakes.io