🥮 mooncakes.io
README

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 issuePackagesBuild queueSkillsStatistics

© 2026 mooncakes.io