Versions in this module Expand all Collapse all v0 v0.3.1 Aug 21, 2026 Changes in this version + var ErrManifestNotFound = manifest.ErrNotFound + var ErrRunNotFound = run.ErrNotFound + var ErrSnapshotNotFound = snapshot.ErrNotFound + var ErrTagNotFound = tag.ErrNotFound + func Migrate(db *sql.DB) error + func Open(path string) (*sql.DB, error) + type ManifestStore struct + DB *sql.DB + func NewManifestStore(db *sql.DB) *ManifestStore + func (s *ManifestStore) Create(ctx context.Context, m manifest.Manifest) error + func (s *ManifestStore) Get(ctx context.Context, manifestID string) (manifest.Manifest, error) + func (s *ManifestStore) GetByIDOrRun(ctx context.Context, idOrRun string) (manifest.Manifest, error) + type MaterializationStore struct + DB *sql.DB + func NewMaterializationStore(db *sql.DB) *MaterializationStore + func (s *MaterializationStore) Create(ctx context.Context, m materialization.Materialization) error + func (s *MaterializationStore) Get(ctx context.Context, id string) (materialization.Materialization, error) + func (s *MaterializationStore) GetBySnapshot(ctx context.Context, snapshotID string, strategy materialization.Strategy) (materialization.Materialization, bool, error) + type ResourceStore struct + DB *sql.DB + func NewResourceStore(db *sql.DB) *ResourceStore + func (s *ResourceStore) Create(ctx context.Context, r resource.Resource) error + func (s *ResourceStore) Get(ctx context.Context, uri string) (resource.Resource, error) + func (s *ResourceStore) List(ctx context.Context) ([]resource.Resource, error) + func (s *ResourceStore) UpdateCurrentSnapshot(ctx context.Context, uri, snapshotID string) error + type RunStore struct + DB *sql.DB + func NewRunStore(db *sql.DB) *RunStore + func (s *RunStore) AppendMount(ctx context.Context, runID string, e run.MountEntry) error + func (s *RunStore) GetRun(ctx context.Context, runID string) (run.Run, error) + func (s *RunStore) ListMounts(ctx context.Context, runID string) ([]run.MountEntry, error) + func (s *RunStore) MarkCommitted(ctx context.Context, runID, manifestID string) error + func (s *RunStore) StartRun(ctx context.Context, runID string) error + type SnapshotStore struct + DB *sql.DB + func NewSnapshotStore(db *sql.DB) *SnapshotStore + func (s *SnapshotStore) Create(ctx context.Context, snap snapshot.Snapshot) error + func (s *SnapshotStore) Get(ctx context.Context, id string) (snapshot.Snapshot, error) + func (s *SnapshotStore) ListByResource(ctx context.Context, uri string) ([]snapshot.Snapshot, error) + type TagStore struct + DB *sql.DB + func NewTagStore(db *sql.DB) *TagStore + func (s *TagStore) Delete(ctx context.Context, uri, name string) error + func (s *TagStore) Get(ctx context.Context, uri, name string) (tag.Tag, error) + func (s *TagStore) List(ctx context.Context, uri string) ([]tag.Tag, error) + func (s *TagStore) Set(ctx context.Context, t tag.Tag) error
Go to main page