beam_store
beam_store persists the execution hierarchy.
beam_store = { path = "../riverbeam/crates/beam_store" }
BeamStore
| Group | Methods |
|---|---|
| Catalog | checkin_agents, checkin_models |
| Sessions | ensure_session, update_session_activity, get_session |
| Interactions | create_interaction, complete_interaction, get_interaction |
| Runs | create_run, complete_run, get_run |
| Messages | save_message, next_sequence, list_messages |
| Actions | create_action, get_action, resolve_action |
Row types: AgentRow, ModelRow, SessionRow, InteractionRow, RunRow, MessageRow,
ActionRow. Status enums: InteractionStatus, RunStatus, ActionStatus.
agent_id_for(name) derives an agent's UUID (version 5) from its name.
Implementations
| Store | Notes |
|---|---|
InMemoryStore::new() | The default in RiverBeam |
PgBeamStore::connect(url) | Builds a pool and creates its tables in ref_beam if missing |
PgBeamStore::new(pool) | Uses your pool; creates nothing. Call ensure_schema() if you need the tables. |
There are no feature flags; Diesel and Postgres support are always compiled.
The tables are listed in Database schema.