stores

Documentation

Index

• Constants
• Variables
• type Reader
• type Record
  • func (r Record) String() string
• type RecordKind
• type Store
  • func FromPersistence(ctx context.Context, reader Reader, store Store) (Store, error)
  • func NewInMemoryStore() Store
  • func WithPersistence(writer Writer, store Store) Store
• type Writer

Constants

const (
	RecordKindSet    RecordKind = "SET"
	RecordKindDelete            = "DEL"
	RecordKindCommit            = "COMMIT"
)

Variables

var ContextKeyTransactionID = contextKey{"TXID"}

ContextKeyTransactionID is a context key for the transaction ID.

Types

type Reader

type Reader interface {
	Read(ctx context.Context, records chan<- Record) error
}

type Record

type Record struct {
	Kind          RecordKind
	TransactionID int64
	Key           string
	Value         string
}

func (Record) String

func (r Record) String() string

type RecordKind

type RecordKind string

type Store

type Store interface {
	Set(ctx context.Context, key, value string) error
	Get(ctx context.Context, key string) (string, error)
	Delete(ctx context.Context, key string) error
	Keys(ctx context.Context) ([]string, error)
	Release(ctx context.Context)
}

func FromPersistence

func FromPersistence(ctx context.Context, reader Reader, store Store) (Store, error)

func NewInMemoryStore

func NewInMemoryStore() Store

func WithPersistence

func WithPersistence(writer Writer, store Store) Store

type Writer

type Writer interface {
	Write(ctx context.Context, record Record) error
}