core

Documentation

Index

• Variables
• type Event
• type EventType
• type KeyValueStore
  • func NewKeyValueStore() *KeyValueStore
  • func (store *KeyValueStore) Delete(key string) error
  • func (store *KeyValueStore) Get(key string) (string, error)
  • func (store *KeyValueStore) Put(key string, value string) error
  • func (store *KeyValueStore) Restore() error
  • func (store *KeyValueStore) WithTransactionLogger(tl TransactionLogger) *KeyValueStore
• type TransactionLogger
• type ZeroTransactionLogger
  • func (z ZeroTransactionLogger) Close() error
  • func (z ZeroTransactionLogger) Err() <-chan error
  • func (z ZeroTransactionLogger) LastSequence() uint64
  • func (z ZeroTransactionLogger) ReadEvents() (<-chan Event, <-chan error)
  • func (z ZeroTransactionLogger) Run()
  • func (z ZeroTransactionLogger) Wait()
  • func (z ZeroTransactionLogger) WriteDelete(key string)
  • func (z ZeroTransactionLogger) WritePut(key, value string)

Variables

var ErrorNoSuchKey = errors.New("no such key")

Types

type Event

type Event struct {
	Sequence  uint64
	EventType EventType
	Key       string
	Value     string
}

type EventType

type EventType byte

const (
	EventDelete EventType = iota // iota == 1
	EventPut                     // iota == 2; implicitly repeat last
)

type KeyValueStore

type KeyValueStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewKeyValueStore

func NewKeyValueStore() *KeyValueStore

func (*KeyValueStore) Delete

func (store *KeyValueStore) Delete(key string) error

func (*KeyValueStore) Get

func (store *KeyValueStore) Get(key string) (string, error)

func (*KeyValueStore) Put

func (store *KeyValueStore) Put(key string, value string) error

func (*KeyValueStore) Restore

func (store *KeyValueStore) Restore() error

func (*KeyValueStore) WithTransactionLogger

func (store *KeyValueStore) WithTransactionLogger(tl TransactionLogger) *KeyValueStore

type TransactionLogger

type TransactionLogger interface {
	WriteDelete(key string)
	WritePut(key, value string)
	Err() <-chan error

	LastSequence() uint64

	Run()
	Wait()
	Close() error

	ReadEvents() (<-chan Event, <-chan error)
}

type ZeroTransactionLogger

type ZeroTransactionLogger struct{}

func (ZeroTransactionLogger) Close

func (z ZeroTransactionLogger) Close() error

func (ZeroTransactionLogger) Err

func (z ZeroTransactionLogger) Err() <-chan error

func (ZeroTransactionLogger) LastSequence

func (z ZeroTransactionLogger) LastSequence() uint64

func (ZeroTransactionLogger) ReadEvents

func (z ZeroTransactionLogger) ReadEvents() (<-chan Event, <-chan error)

func (ZeroTransactionLogger) Run

func (z ZeroTransactionLogger) Run()

func (ZeroTransactionLogger) Wait

func (z ZeroTransactionLogger) Wait()

func (ZeroTransactionLogger) WriteDelete

func (z ZeroTransactionLogger) WriteDelete(key string)

func (ZeroTransactionLogger) WritePut

func (z ZeroTransactionLogger) WritePut(key, value string)