postgresql

Documentation

Index

• type Snapshot
  • func New(pool *pgxpool.Pool, threshold int, c snapshot.Codec) *Snapshot
  • func (s *Snapshot) Load(ctx context.Context, sid stream.ID, st stream.Type) (stream.Stream, error)
  • func (s *Snapshot) Remove(ctx context.Context, st stream.Type, sid stream.ID) error
  • func (s *Snapshot) Reset(ctx context.Context, st stream.Type) error
  • func (s *Snapshot) Should(_ context.Context, es stream.Stream) bool
  • func (s *Snapshot) Take(ctx context.Context, es stream.Stream) error

Types

type Snapshot

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

func New

func New(pool *pgxpool.Pool, threshold int, c snapshot.Codec) *Snapshot

func (*Snapshot) Load

func (s *Snapshot) Load(ctx context.Context, sid stream.ID, st stream.Type) (stream.Stream, error)

func (*Snapshot) Remove

func (s *Snapshot) Remove(ctx context.Context, st stream.Type, sid stream.ID) error

func (*Snapshot) Reset

func (s *Snapshot) Reset(ctx context.Context, st stream.Type) error

func (*Snapshot) Should

func (s *Snapshot) Should(_ context.Context, es stream.Stream) bool

func (*Snapshot) Take

func (s *Snapshot) Take(ctx context.Context, es stream.Stream) error