fsmdb

Documentation

Index

• Constants
• func SnapshotID(index uint64) string
• type BackupDumper
• type DB
  • func Open(dataDir string) (*DB, error)
  • func (d *DB) Create(version raft.SnapshotVersion, index, term uint64, ...) (raft.SnapshotSink, error)
  • func (d *DB) List() (ret []*raft.SnapshotMeta, err error)
  • func (d *DB) Open(id string) (*raft.SnapshotMeta, io.ReadCloser, error)
  • func (d *DB) Update(f func(tx *Tx) error) error
  • func (d *DB) View(f func(tx *Tx) error) error
• type Tx
  • func (tx *Tx) Inc(key []byte) (old uint64, err error)
  • func (tx *Tx) Iter(prefix []byte, withValues bool) *badger.Iterator
  • func (tx *Tx) Uint64(key, dst []byte) (uint64, error)

Constants

const (
	SnapDir        = "snaps"
	MetaFileSuffix = ".meta.json"
	SnapFileSuffix = ".badger.bak"
	TimeFileSuffix = ".badger.time"
)

const StateDir = "states"

Functions

func SnapshotID

func SnapshotID(index uint64) string

Types

type BackupDumper

type BackupDumper interface {
	Backup() error
}

type DB

type DB struct {
	*badger.DB
	// contains filtered or unexported fields
}

func Open

func Open(dataDir string) (*DB, error)

func (*DB) Create

func (d *DB) Create(
	version raft.SnapshotVersion,
	index, term uint64,
	configuration raft.Configuration,
	configurationIndex uint64,
	_ raft.Transport,
) (raft.SnapshotSink, error)

func (*DB) List

func (d *DB) List() (ret []*raft.SnapshotMeta, err error)

func (*DB) Open

func (d *DB) Open(id string) (*raft.SnapshotMeta, io.ReadCloser, error)

func (*DB) Update

func (d *DB) Update(f func(tx *Tx) error) error

func (*DB) View

func (d *DB) View(f func(tx *Tx) error) error

type Tx

type Tx struct {
	*badger.Txn
	// contains filtered or unexported fields
}

func (*Tx) Inc

func (tx *Tx) Inc(key []byte) (old uint64, err error)

func (*Tx) Iter

func (tx *Tx) Iter(prefix []byte, withValues bool) *badger.Iterator

func (*Tx) Uint64

func (tx *Tx) Uint64(key, dst []byte) (uint64, error)