postgres

Documentation

Index

• type Store
  • func New(pool *pgxpool.Pool) *Store
  • func (s *Store) Append(ctx context.Context, sessionID string, evs []store.PendingEvent) (firstSeq int64, err error)
  • func (s *Store) LatestSeq(ctx context.Context, sessionID string) (int64, error)
  • func (s *Store) Replay(ctx context.Context, sessionID string, afterSeq int64, ...) (err error)

Types

type Store

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

func New

func New(pool *pgxpool.Pool) *Store

func (*Store) Append

func (s *Store) Append(ctx context.Context, sessionID string, evs []store.PendingEvent) (firstSeq int64, err error)

func (*Store) LatestSeq

func (s *Store) LatestSeq(ctx context.Context, sessionID string) (int64, error)

func (*Store) Replay

func (s *Store) Replay(ctx context.Context, sessionID string, afterSeq int64, fn func(store.Event) error) (err error)