preamble

Documentation

Index

• func WithClock(clock clock.Clock) func(store *Store)
• func WithDirectory(directory string) func(store *Store)
• func WithGetStateFunc(f func() map[int]map[string]internal.KeyData) func(store *Store)
• func WithReadWriter(rw ReadWriter) func(store *Store)
• func WithSetKeyDataFunc(f func(database int, key string, data internal.KeyData)) func(store *Store)
• type ReadWriter
• type Store
  • func NewPreambleStore(options ...func(store *Store)) (*Store, error)
  • func (store *Store) Close() error
  • func (store *Store) CreatePreamble() error
  • func (store *Store) Restore() error

Functions

func WithClock

func WithClock(clock clock.Clock) func(store *Store)

func WithDirectory

func WithDirectory(directory string) func(store *Store)

func WithGetStateFunc

func WithGetStateFunc(f func() map[int]map[string]internal.KeyData) func(store *Store)

func WithReadWriter

func WithReadWriter(rw ReadWriter) func(store *Store)

func WithSetKeyDataFunc

func WithSetKeyDataFunc(f func(database int, key string, data internal.KeyData)) func(store *Store)

Types

type ReadWriter

type ReadWriter interface {
	io.ReadWriteSeeker
	io.Closer
	Truncate(size int64) error
	Sync() error
}

type Store

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

func NewPreambleStore

func NewPreambleStore(options ...func(store *Store)) (*Store, error)

func (*Store) Close

func (store *Store) Close() error

func (*Store) CreatePreamble

func (store *Store) CreatePreamble() error

func (*Store) Restore

func (store *Store) Restore() error