Documentation
¶
Overview ¶
Package postgres provides a Postgres implementation of github.com/justinush/maestro/pkg/run.Store.
Workflow run state is stored in the workflow_runs table (JSONB column state). Canonical DDL lives in schema.sql (SchemaDDL returns the same bytes).
The table and column names are intended to remain stable across v0.x releases for this adapter.
Usage ¶
pool, err := pgxpool.New(ctx, databaseURL)
if err != nil { ... }
store := postgres.NewStore(pool)
Store implements run.Store: Create, Get, Save with optimistic locking via revision. Store is safe for concurrent use when backed by a shared *pgxpool.Pool.
Schema management ¶
Store expects workflow_runs to exist. Two supported approaches:
- ApplySchema - optional helper for examples, tests, and quick local setup (idempotent).
- Your migration tool - copy schema.sql or use SchemaDDL in goose / golang-migrate / Atlas / etc.
Scope ¶
This package persists workflow runs only. Application-owned tables (users, applicants, etc.) remain the embedder's responsibility and are not coordinated in a single transaction with run.Store operations in v0.1.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ApplySchema ¶
ApplySchema creates the workflow_runs table and indexes (idempotent).
Optional convenience for examples, local development, and integration tests. Production applications may prefer SchemaDDL with their own migration pipeline instead.
Store requires the schema to exist before use; how you apply it is up to the embedder.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store implements run.Store with Postgres (state as JSONB).
func NewStore ¶
NewStore returns a Store backed by pool.
The caller owns pool lifecycle. workflow_runs must exist before use (see ApplySchema or SchemaDDL).
func (*Store) Get ¶
Get returns a deep copy of the run or run.ErrNotFound.
Source Files