db

Documentation

Index

• Variables
• func InitDB()
• type LevelDB
  • func NewLevelDB(path string) *LevelDB
  • func (level *LevelDB) Close() error
  • func (db *LevelDB) PrintLog(fileName string)
  • func (level *LevelDB) ReadLog(index int) (*paxos.LogEntry, error)
  • func (level *LevelDB) Restore(p *paxos.Proposer, a *paxos.Acceptor, statMachine sm.StatMachine) error
  • func (level *LevelDB) WriteLog(index int, entry *paxos.LogEntry) error
• type MyComparator
  • func (cmp MyComparator) Compare(a, b []byte) int
  • func (cmp MyComparator) Name() string
  • func (cmp MyComparator) Separator(dst, a, b []byte) []byte
  • func (cmp MyComparator) Successor(dst, b []byte) []byte

Variables

var ErrorBadLogFormat = errors.New("bad log format")

Functions

func InitDB

func InitDB()

Types

type LevelDB

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

func NewLevelDB

func NewLevelDB(path string) *LevelDB

func (*LevelDB) Close

func (level *LevelDB) Close() error

func (*LevelDB) PrintLog

func (db *LevelDB) PrintLog(fileName string)

func (*LevelDB) ReadLog

func (level *LevelDB) ReadLog(index int) (*paxos.LogEntry, error)

func (*LevelDB) Restore

func (level *LevelDB) Restore(p *paxos.Proposer, a *paxos.Acceptor, statMachine sm.StatMachine) error

func (*LevelDB) WriteLog

func (level *LevelDB) WriteLog(index int, entry *paxos.LogEntry) error

type MyComparator

type MyComparator struct {
}

func (MyComparator) Compare

func (cmp MyComparator) Compare(a, b []byte) int

func (MyComparator) Name

func (cmp MyComparator) Name() string

func (MyComparator) Separator

func (cmp MyComparator) Separator(dst, a, b []byte) []byte

func (MyComparator) Successor

func (cmp MyComparator) Successor(dst, b []byte) []byte