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 DefaultTableName = "agentflow_runtime_events"

This section is empty.

This section is empty.

type Config struct {
	DB              *sql.DB
	TableName       string
	SkipSchemaSetup bool
}

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

func NewStore(ctx context.Context, config Config) (*Store, error)

func (store *Store) Append(ctx context.Context, event core.Event) (obspkg.EventRecord, error)

func (store *Store) EnsureSchema(ctx context.Context) error

func (store *Store) ListEvents(ctx context.Context, runID string, query obspkg.EventQuery) ([]obspkg.EventRecord, error)

func (store *Store) ListRuns(ctx context.Context, query obspkg.RunQuery) ([]obspkg.RunSummary, error)