mooncakes.io

src

vicTop-cw/fist-mbt/src/store does not have a README file

Store

pub trait Store {
  fn create_task(Self, @vicTop-cw/fist-mbt/src/core.Task
Task) -> Result[Unit, String]
  fn get_task(Self, String) -> @vicTop-cw/fist-mbt/src/core.Task
Task?
  fn update_task(Self, @vicTop-cw/fist-mbt/src/core.Task
Task) -> Result[Unit, String]
  fn list_tasks(Self) -> Array[@vicTop-cw/fist-mbt/src/core.Task
Task]
  fn delete_task(Self, String) -> Result[Unit, String]
  fn clear(Self) -> Unit
}

仓库统一接口

ExecutionRecord

source

pub struct ExecutionRecord {
  id : String
  task_id : String
  executor : String
  model : String
  tokens_in : Int
  tokens_out : Int
  cost : Double
  duration_ms : Int
  rate_limited : Bool
  failure_reason : String
  created_at : String
}

执行记录结构体

MemoryStore

source

pub struct MemoryStore {
  tasks : Map[String, @vicTop-cw/fist-mbt/src/core.Task
Task]
  specs : Map[String, SpecRecord]
  default_ns : String
}

内存实现：进程内 Map，简单可靠，配合单机 MCP server 足够。

MemoryStore::clear

source

fn MemoryStore::clear(self : MemoryStore) -> Unit

提升声明：允许通过具体类型直接调用 trait 方法（避免 deprecated 隐式提升）。

MemoryStore::create_task

source

fn MemoryStore::create_task(self : MemoryStore, task : @vicTop-cw/fist-mbt/src/core.Task
Task) -> Result[Unit, String]

提升声明：允许通过具体类型直接调用 trait 方法（避免 deprecated 隐式提升）。

MemoryStore::delete_task

source

fn MemoryStore::delete_task(self : MemoryStore, id : String) -> Result[Unit, String]

提升声明：允许通过具体类型直接调用 trait 方法（避免 deprecated 隐式提升）。

MemoryStore::get_spec

source

fn MemoryStore::get_spec(self : MemoryStore, id : String) -> SpecRecord?

按 id 读取单条语料记录。

MemoryStore::get_task

source

fn MemoryStore::get_task(self : MemoryStore, id : String) -> @vicTop-cw/fist-mbt/src/core.Task
Task?

提升声明：允许通过具体类型直接调用 trait 方法（避免 deprecated 隐式提升）。

MemoryStore::list_specs_by_task

source

fn MemoryStore::list_specs_by_task(self : MemoryStore, task_id : String) -> Array[SpecRecord]

列出某任务的全部语料 / 复验记录。

MemoryStore::list_tasks

source

fn MemoryStore::list_tasks(self : MemoryStore) -> Array[@vicTop-cw/fist-mbt/src/core.Task
Task]

提升声明：允许通过具体类型直接调用 trait 方法（避免 deprecated 隐式提升）。

MemoryStore::list_tasks_in

source

fn MemoryStore::list_tasks_in(self : MemoryStore, ns_filter : String) -> Array[@vicTop-cw/fist-mbt/src/core.Task
Task]

列出指定命名空间的任务

MemoryStore::new

source

fn MemoryStore::new() -> MemoryStore

MemoryStore::update_spec_status

source

fn MemoryStore::update_spec_status(self : MemoryStore, id : String, status : String, content : String, updated_at : String) -> Result[Unit, String]

更新语料状态（可同时更新内容与时间戳）。

MemoryStore::update_task

source

fn MemoryStore::update_task(self : MemoryStore, task : @vicTop-cw/fist-mbt/src/core.Task
Task) -> Result[Unit, String]

提升声明：允许通过具体类型直接调用 trait 方法（避免 deprecated 隐式提升）。

MemoryStore::upsert_spec

source

fn MemoryStore::upsert_spec(self : MemoryStore, rec : SpecRecord) -> Result[Unit, String]

写入 / 覆盖一条语料记录（主键 id）。

MultiStore

source

pub struct MultiStore {
  stores : Map[String, SqliteStore]
  data_dir : String
}

FIST-Mbt store: 命名空间多库持久化管理器。按 ns 路由到独立 SQLite 文件 {data_dir}/{ns}.db，惰性打开（首次访问才建库）。每个 ns 拥有独立的物理库文件，实现多租户/多项目隔离；路径完全由参数传入，不做任何绝对路径硬编码。

可变性模式与 AuditLog 一致：通过 self.stores.set / self.stores.remove 原地修改，无需在调用方重新赋值。这样可被模块级不可变绑定持有，供 MCP 工具闭包安全调用。

MultiStore::close

source

fn MultiStore::close(self : MultiStore, ns : String) -> Unit

关闭并移除某个命名空间（不删除物理文件，可重新 open 恢复）。

MultiStore::close_all

source

fn MultiStore::close_all(self : MultiStore) -> Unit

关闭全部命名空间。

MultiStore::get

source

fn MultiStore::get(self : MultiStore, ns : String) -> SqliteStore?

获取某 ns 的存储；惰性打开：尚未打开时按当前 data_dir 首次创建/打开。打开失败返回 None。

MultiStore::new

source

fn MultiStore::new(data_dir? : String) -> MultiStore

构造：仅记录根目录，不打开任何库（惰性）。

MultiStore::ns_list

source

fn MultiStore::ns_list(self : MultiStore) -> Array[String]

列出已打开的命名空间（Map 遍历顺序，不保证稳定）。

MultiStore::ns_stats

source

fn MultiStore::ns_stats(self : MultiStore) -> Json

每个已打开 ns 的任务数统计（直接用该 ns 库的 tasks 表 COUNT）。返回 Json 数组，元素形如 {"ns": "...", "total": N}。

MultiStore::open

source

fn MultiStore::open(self : MultiStore, ns~ : String, data_dir~ : String) -> Bool

打开（或复用已打开的）某个命名空间对应的库文件 {data_dir}/{ns}.db。失败返回 false，成功返回 true。

SpecRecord

source

pub struct SpecRecord {
  id : String
  task_id : String
  spec_type : String
  content : String
  status : String
  created_at : String
  updated_at : String
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

语料 / 复验记录（跨后端统一结构）。

SpecRecord::new

source

fn SpecRecord::new(id~ : String, task_id~ : String, spec_type? : String, content? : String, status? : String, created_at? : String, updated_at? : String) -> SpecRecord

便捷构造（仅 id / task_id 必填，其余带默认值）。

SpecRecord::to_json

source

fn SpecRecord::to_json(self : SpecRecord) -> Json

记录转 JSON（供 MCP 工具输出，content 不展开以免撑爆响应）。

SqliteStore

source

pub struct SqliteStore {
  db : @mizchi/sqlite.Database
Database?
}

SQLite 后端：持有打开的 Database（Option 以承载 open 失败场景）。

SqliteStore::archive_task

source

fn SqliteStore::archive_task(self : SqliteStore, t : @vicTop-cw/fist-mbt/src/core.Task
Task, archived_at~ : String) -> Result[Unit, String]

将已归档任务写入 archive 表快照。

SqliteStore::clear

source

fn SqliteStore::clear(self : SqliteStore) -> Unit

提升声明：允许通过具体类型直接调用 trait 方法。

SqliteStore::create_task

source

fn SqliteStore::create_task(self : SqliteStore, task : @vicTop-cw/fist-mbt/src/core.Task
Task) -> Result[Unit, String]

提升声明：允许通过具体类型直接调用 trait 方法。

SqliteStore::delete_heartbeat

source

fn SqliteStore::delete_heartbeat(self : SqliteStore, task_id : String) -> Result[Unit, String]

删除心跳记录。

SqliteStore::delete_task

source

fn SqliteStore::delete_task(self : SqliteStore, id : String) -> Result[Unit, String]

提升声明：允许通过具体类型直接调用 trait 方法。

SqliteStore::ensure_specs_table

source

fn SqliteStore::ensure_specs_table(self : SqliteStore) -> Bool

确保 specs 表存在（幂等；旧库自动补齐）。

SqliteStore::get_spec

source

fn SqliteStore::get_spec(self : SqliteStore, id : String) -> SpecRecord?

按 id 读取单条语料记录。

SqliteStore::get_task

source

fn SqliteStore::get_task(self : SqliteStore, id : String) -> @vicTop-cw/fist-mbt/src/core.Task
Task?

提升声明：允许通过具体类型直接调用 trait 方法。

SqliteStore::list_all_heartbeats

source

fn SqliteStore::list_all_heartbeats(self : SqliteStore) -> Array[(String, String, String, String)]

列出全部心跳记录（供启动时加载）。

SqliteStore::list_archived

source

fn SqliteStore::list_archived(self : SqliteStore) -> Array[(String, String)]

列出全部归档快照（id -> 原 task_json）。

SqliteStore::list_specs_by_task

source

fn SqliteStore::list_specs_by_task(self : SqliteStore, task_id : String) -> Array[SpecRecord]

列出某任务的全部语料 / 复验记录（按 created_at、id 升序）。

SqliteStore::list_tasks

source

fn SqliteStore::list_tasks(self : SqliteStore) -> Array[@vicTop-cw/fist-mbt/src/core.Task
Task]

提升声明：允许通过具体类型直接调用 trait 方法。

SqliteStore::list_tasks_in

source

fn SqliteStore::list_tasks_in(self : SqliteStore, ns_filter : String) -> Array[@vicTop-cw/fist-mbt/src/core.Task
Task]

列出指定命名空间的任务

SqliteStore::new

source

fn SqliteStore::new() -> SqliteStore?

以默认路径（fist-mbt.db，随运行目录）打开的便捷构造。

SqliteStore::open

source

fn SqliteStore::open(db_path : String) -> SqliteStore?

打开数据库并初始化五表 schema。失败返回 None（调用方决定是否 abort / 回退内存）。

SqliteStore::read_heartbeat

source

fn SqliteStore::read_heartbeat(self : SqliteStore, task_id : String) -> (String, String, String)

读取指定任务的心跳记录。

SqliteStore::record_execution

source

fn SqliteStore::record_execution(self : SqliteStore, task_id~ : String, executor~ : String, model~ : String, tokens_in~ : Int, tokens_out~ : Int, cost~ : Double, duration_ms~ : Int, rate_limited~ : Bool, failure_reason~ : String, created_at~ : String) -> Result[Unit, String]

写入执行记录（供 execute 工具调用）。

SqliteStore::update_spec_status

source

fn SqliteStore::update_spec_status(self : SqliteStore, id : String, status : String, content : String, updated_at : String) -> Result[Unit, String]

更新语料状态（可同时更新内容与时间戳）。

SqliteStore::update_task

source

fn SqliteStore::update_task(self : SqliteStore, task : @vicTop-cw/fist-mbt/src/core.Task
Task) -> Result[Unit, String]

提升声明：允许通过具体类型直接调用 trait 方法。

SqliteStore::upsert_spec

source

fn SqliteStore::upsert_spec(self : SqliteStore, rec : SpecRecord) -> Result[Unit, String]

写入 / 覆盖一条语料记录（UPSERT，主键 id）。

SqliteStore::write_heartbeat

source

fn SqliteStore::write_heartbeat(self : SqliteStore, agent_id~ : String, task_id~ : String, last_seen~ : String, status~ : String) -> Result[Unit, String]

写入心跳记录（UPSERT：存在则更新 last_seen / status，不存在则插入）。

StoreBackend

source

pub enum StoreBackend {
  Mem(MemoryStore)
  Sql(SqliteStore)
}

后端路由：内存版（默认，测试/演示）或 SQLite 持久化（运行时内建数据库）。 FistEngine 持此类型，业务层不感知具体后端。

StoreBackend::clear

source

fn StoreBackend::clear(self : StoreBackend) -> Unit

StoreBackend::cost_stats

source

fn StoreBackend::cost_stats(self : StoreBackend) -> Json

成本聚合统计：SQLite 后端从 executions 表聚合，内存后端返回零值。

StoreBackend::create_task

source

fn StoreBackend::create_task(self : StoreBackend, task : @vicTop-cw/fist-mbt/src/core.Task
Task) -> Result[Unit, String]

StoreBackend::delete_heartbeat

source

fn StoreBackend::delete_heartbeat(self : StoreBackend, task_id : String) -> Result[Unit, String]

删除心跳记录。

StoreBackend::delete_task

source

fn StoreBackend::delete_task(self : StoreBackend, id : String) -> Result[Unit, String]

StoreBackend::get_spec

source

fn StoreBackend::get_spec(self : StoreBackend, id : String) -> SpecRecord?

按 id 读取单条语料记录。

StoreBackend::get_task

source

fn StoreBackend::get_task(self : StoreBackend, id : String) -> @vicTop-cw/fist-mbt/src/core.Task
Task?

StoreBackend::list_all_heartbeats

source

fn StoreBackend::list_all_heartbeats(self : StoreBackend) -> Array[(String, String, String, String)]

列出全部心跳记录（供启动时加载）。

StoreBackend::list_specs_by_task

source

fn StoreBackend::list_specs_by_task(self : StoreBackend, task_id : String) -> Array[SpecRecord]

列出某任务的全部语料 / 复验记录。

StoreBackend::list_tasks

source

fn StoreBackend::list_tasks(self : StoreBackend) -> Array[@vicTop-cw/fist-mbt/src/core.Task
Task]

StoreBackend::list_tasks_in

source

fn StoreBackend::list_tasks_in(self : StoreBackend, ns : String) -> Array[@vicTop-cw/fist-mbt/src/core.Task
Task]

列出指定命名空间的任务（跨后端）

StoreBackend::memory

source

fn StoreBackend::memory() -> StoreBackend

后端工厂（跨包构造 StoreBackend 需经 pub 函数）

StoreBackend::read_heartbeat

source

fn StoreBackend::read_heartbeat(self : StoreBackend, task_id : String) -> (String, String, String)

读取心跳记录（返回 (agent_id, last_seen, status)，无记录返回 ("", "", "")）。

StoreBackend::record_execution

source

fn StoreBackend::record_execution(self : StoreBackend, task_id~ : String, executor~ : String, model~ : String, tokens_in~ : Int, tokens_out~ : Int, cost~ : Double, duration_ms~ : Int, rate_limited~ : Bool, failure_reason~ : String, created_at~ : String) -> Result[Unit, String]

执行元数据记录（可选参数，供 execute 工具写入 executions 表）。 MemoryStore 为 no-op，SqliteStore 写入 executions 表。

StoreBackend::set_namespace

source

fn StoreBackend::set_namespace(self : StoreBackend, ns : String) -> Unit

设置默认命名空间

StoreBackend::sqlite

source

fn StoreBackend::sqlite(s : SqliteStore) -> StoreBackend

StoreBackend::update_spec_status

source

fn StoreBackend::update_spec_status(self : StoreBackend, id : String, status : String, content : String, updated_at : String) -> Result[Unit, String]

更新语料状态。

StoreBackend::update_task

source

fn StoreBackend::update_task(self : StoreBackend, task : @vicTop-cw/fist-mbt/src/core.Task
Task) -> Result[Unit, String]

StoreBackend::upsert_spec

source

fn StoreBackend::upsert_spec(self : StoreBackend, rec : SpecRecord) -> Result[Unit, String]

写入 / 覆盖一条语料记录（内存与 SQLite 后端均真实落库）。

StoreBackend::write_heartbeat

source

fn StoreBackend::write_heartbeat(self : StoreBackend, agent_id~ : String, task_id~ : String, last_seen~ : String, status~ : String) -> Result[Unit, String]

写入心跳记录（SQLite 落库，内存后端为 no-op）。

aggregate_stats

source

fn aggregate_stats(db : @mizchi/sqlite.Database
Database) -> Json

聚合统计：总成本 / 总 token / 执行次数 / 按执行器分组

executions_table_sql

source

fn executions_table_sql() -> String

executions 表 CREATE TABLE SQL（使用 \n 避免跨行字面量）

init_executions_table

source

fn init_executions_table(db : @mizchi/sqlite.Database
Database) -> Bool

初始化 executions 表

insert_execution

source

fn insert_execution(db : @mizchi/sqlite.Database
Database, rec : ExecutionRecord) -> Result[Unit, String]

写入执行记录

list_all_executions

source

fn list_all_executions(db : @mizchi/sqlite.Database
Database) -> Array[ExecutionRecord]

列出全部执行记录（按 created_at DESC）

specs_table_sql

source

fn specs_table_sql() -> String

specs 表 CREATE TABLE SQL（幂等，兼容旧库）。

Source Files

Site source Report issue Packages Build queue Skills Statistics

#Store

#ExecutionRecord

#MemoryStore

#MemoryStore::clear

#MemoryStore::create_task

#MemoryStore::delete_task

#MemoryStore::get_spec

#MemoryStore::get_task

#MemoryStore::list_specs_by_task

#MemoryStore::list_tasks

#MemoryStore::list_tasks_in

#MemoryStore::new

#MemoryStore::update_spec_status

#MemoryStore::update_task

#MemoryStore::upsert_spec

#MultiStore

#MultiStore::close

#MultiStore::close_all

#MultiStore::get

#MultiStore::new

#MultiStore::ns_list

#MultiStore::ns_stats

#MultiStore::open

#SpecRecord

#SpecRecord::new

#SpecRecord::to_json

#SqliteStore

#SqliteStore::archive_task

#SqliteStore::clear

#SqliteStore::create_task

#SqliteStore::delete_heartbeat

#SqliteStore::delete_task

#SqliteStore::ensure_specs_table

#SqliteStore::get_spec

#SqliteStore::get_task

#SqliteStore::list_all_heartbeats

#SqliteStore::list_archived

#SqliteStore::list_specs_by_task

#SqliteStore::list_tasks

#SqliteStore::list_tasks_in

#SqliteStore::new

#SqliteStore::open

#SqliteStore::read_heartbeat

#SqliteStore::record_execution

#SqliteStore::update_spec_status

#SqliteStore::update_task

#SqliteStore::upsert_spec

#SqliteStore::write_heartbeat

#StoreBackend

#StoreBackend::clear

#StoreBackend::cost_stats

#StoreBackend::create_task

#StoreBackend::delete_heartbeat

#StoreBackend::delete_task

#StoreBackend::get_spec

#StoreBackend::get_task

#StoreBackend::list_all_heartbeats

#StoreBackend::list_specs_by_task

#StoreBackend::list_tasks

#StoreBackend::list_tasks_in

#StoreBackend::memory

#StoreBackend::read_heartbeat

#StoreBackend::record_execution

#StoreBackend::set_namespace

#StoreBackend::sqlite

#StoreBackend::update_spec_status

#StoreBackend::update_task

#StoreBackend::upsert_spec

#StoreBackend::write_heartbeat

#aggregate_stats

#executions_table_sql

#init_executions_table

#insert_execution

#list_all_executions

#specs_table_sql

Source Files

Store

ExecutionRecord

MemoryStore

MemoryStore::clear

MemoryStore::create_task

MemoryStore::delete_task

MemoryStore::get_spec

MemoryStore::get_task

MemoryStore::list_specs_by_task

MemoryStore::list_tasks

MemoryStore::list_tasks_in

MemoryStore::new

MemoryStore::update_spec_status

MemoryStore::update_task

MemoryStore::upsert_spec

MultiStore

MultiStore::close

MultiStore::close_all

MultiStore::get

MultiStore::new

MultiStore::ns_list

MultiStore::ns_stats

MultiStore::open

SpecRecord

SpecRecord::new

SpecRecord::to_json

SqliteStore

SqliteStore::archive_task

SqliteStore::clear

SqliteStore::create_task

SqliteStore::delete_heartbeat

SqliteStore::delete_task

SqliteStore::ensure_specs_table

SqliteStore::get_spec

SqliteStore::get_task

SqliteStore::list_all_heartbeats

SqliteStore::list_archived

SqliteStore::list_specs_by_task

SqliteStore::list_tasks

SqliteStore::list_tasks_in

SqliteStore::new

SqliteStore::open

SqliteStore::read_heartbeat

SqliteStore::record_execution

SqliteStore::update_spec_status

SqliteStore::update_task

SqliteStore::upsert_spec

SqliteStore::write_heartbeat

StoreBackend

StoreBackend::clear

StoreBackend::cost_stats

StoreBackend::create_task

StoreBackend::delete_heartbeat

StoreBackend::delete_task

StoreBackend::get_spec

StoreBackend::get_task

StoreBackend::list_all_heartbeats

StoreBackend::list_specs_by_task

StoreBackend::list_tasks

StoreBackend::list_tasks_in

StoreBackend::memory

StoreBackend::read_heartbeat

StoreBackend::record_execution

StoreBackend::set_namespace

StoreBackend::sqlite

StoreBackend::update_spec_status

StoreBackend::update_task

StoreBackend::upsert_spec

StoreBackend::write_heartbeat

aggregate_stats

executions_table_sql

init_executions_table

insert_execution

list_all_executions

specs_table_sql