Versions in this module Expand all Collapse all v0 v0.61.0 Nov 10, 2026 v0.60.0 Nov 4, 2026 Changes in this version + func SchemaSQL(name string) (string, error) + type Config struct + Pool *pgxpool.Pool + Prepare func(run.Batch) (Mutation, error) + Schema string + Timeout time.Duration + type Mutation struct + Apply func(context.Context, Writer) error + type Store struct + func New(ctx context.Context, config Config) (*Store, error) + func (s *Store) Append(ctx context.Context, batch run.Batch) (err error) + func (s *Store) Close() + func (s *Store) Load(ctx context.Context, root run.ProcessID) (run.Log, bool, error) + func (s *Store) Read(ctx context.Context, root run.ProcessID, after run.LSN) iter.Seq2[run.Entry, error] + type Writer interface + Exec func(context.Context, string, ...any) (pgconn.CommandTag, error)
Go to main page