postgres

package

v0.2.2 Latest Latest Go to latest Published: May 23, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

View Source

const DefaultCheckpointHistoryTable = "agentflow_run_checkpoint_history"

View Source

const DefaultTableName = "agentflow_run_snapshots"

This section is empty.

This section is empty.

type CheckpointHistory struct {
	// contains filtered or unexported fields
}

func NewCheckpointHistory(db *sql.DB, opts ...CheckpointHistoryOption) (*CheckpointHistory, error)

func (h *CheckpointHistory) Append(ctx context.Context, snapshot runstate.RunSnapshot) error

func (h *CheckpointHistory) List(ctx context.Context, runID string, limit int) ([]runstate.CheckpointSummary, error)

func (h *CheckpointHistory) Load(ctx context.Context, runID string, version int64) (runstate.RunSnapshot, error)

type CheckpointHistoryOption func(*CheckpointHistory) error

func WithCheckpointHistoryTable(name string) CheckpointHistoryOption

type Option func(*Repository) error

func WithTableName(name string) Option

type Repository struct {
	// contains filtered or unexported fields
}

func NewRepository(db *sql.DB, opts ...Option) (*Repository, error)

func (r *Repository) Delete(ctx context.Context, runID string) error

func (r *Repository) List(ctx context.Context, filter runstate.ListFilter) ([]runstate.RunSnapshot, error)

func (r *Repository) Load(ctx context.Context, runID string) (runstate.RunSnapshot, error)

func (r *Repository) Save(ctx context.Context, snapshot *runstate.RunSnapshot, expectedVersion int64) error