badgerLocal

Documentation

Index

• type Config
  • func DefaultConfig(dataPath string) Config
• type SnapshotBuilder
  • func (s SnapshotBuilder) Persist(sink raft.SnapshotSink) error
  • func (s SnapshotBuilder) Release()
• type Store
  • func New(cfg Config) (*Store, error)
  • func (s *Store) Apply(log *raft.Log) interface{}
  • func (s *Store) DB() *store.LocalDB
  • func (s *Store) Restore(closer io.ReadCloser) error
  • func (s *Store) Shutdown()
  • func (s *Store) Snapshot() (raft.FSMSnapshot, error)
  • func (s *Store) Update(fn func(store.Txn) error) error
  • func (s *Store) UpdateLocal(fn func(txn *store.LTxn) error) error
  • func (s *Store) View(fn func(store.Txn) error) error
  • func (s *Store) ViewLocal(fn func(txn *store.LTxn) error) error

Types

type Config

type Config struct {
	DirPath             string
	ConflictRetries     int
	ConflictMaxInterval time.Duration
	BatchWorkers        int
	BatchSize           int
}

func DefaultConfig

func DefaultConfig(dataPath string) Config

type SnapshotBuilder

type SnapshotBuilder struct{}

SnapshotBuilder is used for snapshot of Raft logs

func (SnapshotBuilder) Persist

func (s SnapshotBuilder) Persist(sink raft.SnapshotSink) error

func (SnapshotBuilder) Release

func (s SnapshotBuilder) Release()

type Store

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

func New

func New(cfg Config) (*Store, error)

func (*Store) Apply

func (s *Store) Apply(log *raft.Log) interface{}

func (*Store) DB

func (s *Store) DB() *store.LocalDB

func (*Store) Restore

func (s *Store) Restore(closer io.ReadCloser) error

func (*Store) Shutdown

func (s *Store) Shutdown()

func (*Store) Snapshot

func (s *Store) Snapshot() (raft.FSMSnapshot, error)

func (*Store) Update

func (s *Store) Update(fn func(store.Txn) error) error

func (*Store) UpdateLocal

func (s *Store) UpdateLocal(fn func(txn *store.LTxn) error) error

func (*Store) View

func (s *Store) View(fn func(store.Txn) error) error

func (*Store) ViewLocal

func (s *Store) ViewLocal(fn func(txn *store.LTxn) error) error