Skip to main content

Module sqlite

mlua_swarm::store::output

Module sqlite 

Source
Expand description

SqliteOutputStore — SQLite-backed OutputStore.

One row per emit (OutputRecord). event and parent_refs are stored as JSON blobs (both types already carry Serialize + Deserialize), so adding a new OutputEvent variant does not require a schema migration.

Ordering guarantees:

  • list_for_attempt returns rows in insertion order (per the trait contract) via an autoincrementing seq column.
  • get_latest_by_name picks the row with the largest seq for a given producer_agent.
  • get_latest_by_name_in_run (GH #23 Layer 2) is the same query additionally filtered to one (task_id, attempt) run — see ix_outputs_producer_run, applied idempotently via CREATE INDEX IF NOT EXISTS on every open/open_in_memory call, so no migration step is needed for pre-existing databases.

Structs§

SqliteOutputStore
SQLite-backed OutputStore.