persist

Documentation

Index

• type Memory
  • func (s *Memory) Close() error
  • func (s *Memory) Range(_ context.Context, cb PersistCallbackFn) error
  • func (s *Memory) Store(ctx context.Context, d hitlist.Domain, r hitlist.Recipient, ...) error
• type PersistCallbackFn
• type Persister
  • func New(db *sql.DB, logger logrus.FieldLogger) Persister
  • func NewMemory() Persister
• type Postgres
  • func (p *Postgres) Close() error
  • func (p *Postgres) Range(ctx context.Context, cb PersistCallbackFn) error
  • func (p *Postgres) Store(ctx context.Context, d hitlist.Domain, r hitlist.Recipient, ...) error

Types

type Memory

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

func (*Memory) Close

func (s *Memory) Close() error

func (*Memory) Range

func (s *Memory) Range(_ context.Context, cb PersistCallbackFn) error

func (*Memory) Store

func (s *Memory) Store(ctx context.Context, d hitlist.Domain, r hitlist.Recipient, vr validator.Result) error

type PersistCallbackFn

type PersistCallbackFn func(d hitlist.Domain, r hitlist.Recipient, vr validator.Result) error

type Persister

type Persister interface {

	// Store stores the parts and vr. The implementation decides what key to use, although it should use a similar one
	// use to restore data using the Get or Range implementations
	Store(ctx context.Context, d hitlist.Domain, r hitlist.Recipient, vr validator.Result) error

	// Range reads all data back and invokes the callback, until all data is read back, or until the callback returns
	// a non-nil error. The implementation decides on the most optimal strategy.
	Range(ctx context.Context, cb PersistCallbackFn) error

	io.Closer
}

func New

func New(db *sql.DB, logger logrus.FieldLogger) Persister

func NewMemory

func NewMemory() Persister

type Postgres

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

func (*Postgres) Close

func (p *Postgres) Close() error

func (*Postgres) Range

func (p *Postgres) Range(ctx context.Context, cb PersistCallbackFn) error

func (*Postgres) Store

func (p *Postgres) Store(ctx context.Context, d hitlist.Domain, r hitlist.Recipient, vr validator.Result) error