Documentation ¶
Index ¶
- type Badger
- func (b *Badger) Close() error
- func (b *Badger) DeleteLogsFrom(minLogIndex uint64) error
- func (b *Badger) GetCurrentTerm() (uint64, error)
- func (b *Badger) GetLog(logIndex uint64) (*konsen.Log, error)
- func (b *Badger) GetLogTerm(logIndex uint64) (uint64, error)
- func (b *Badger) GetLogsFrom(minLogIndex uint64) ([]*konsen.Log, error)
- func (b *Badger) GetValue(key []byte) ([]byte, error)
- func (b *Badger) GetVotedFor() (string, error)
- func (b *Badger) LastLogIndex() (uint64, error)
- func (b *Badger) LastLogTerm() (uint64, error)
- func (b *Badger) SetCurrentTerm(term uint64) error
- func (b *Badger) SetValue(key []byte, value []byte) error
- func (b *Badger) SetVotedFor(candidateID string) error
- func (b *Badger) WriteLog(log *konsen.Log) error
- func (b *Badger) WriteLogs(logs []*konsen.Log) error
- type BadgerConfig
- type BoltDB
- func (b *BoltDB) Close() error
- func (b *BoltDB) DeleteLogsFrom(minLogIndex uint64) error
- func (b *BoltDB) GetCurrentTerm() (uint64, error)
- func (b *BoltDB) GetLog(logIndex uint64) (*konsen.Log, error)
- func (b *BoltDB) GetLogTerm(logIndex uint64) (uint64, error)
- func (b *BoltDB) GetLogsFrom(minLogIndex uint64) ([]*konsen.Log, error)
- func (b *BoltDB) GetValue(key []byte) ([]byte, error)
- func (b *BoltDB) GetVotedFor() (string, error)
- func (b *BoltDB) LastLogIndex() (uint64, error)
- func (b *BoltDB) LastLogTerm() (uint64, error)
- func (b *BoltDB) SetCurrentTerm(term uint64) error
- func (b *BoltDB) SetValue(key []byte, value []byte) error
- func (b *BoltDB) SetVotedFor(candidateID string) error
- func (b *BoltDB) WriteLog(log *konsen.Log) error
- func (b *BoltDB) WriteLogs(logs []*konsen.Log) error
- type BoltDBConfig
- type Storage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Badger ¶
type Badger struct {
// contains filtered or unexported fields
}
func NewBadger ¶
func NewBadger(config BadgerConfig) (*Badger, error)
func (*Badger) DeleteLogsFrom ¶
func (*Badger) GetCurrentTerm ¶
func (*Badger) GetLogsFrom ¶
func (*Badger) GetVotedFor ¶
func (*Badger) LastLogIndex ¶
func (*Badger) LastLogTerm ¶
func (*Badger) SetCurrentTerm ¶
func (*Badger) SetVotedFor ¶
type BadgerConfig ¶
type BoltDB ¶
type BoltDB struct {
// contains filtered or unexported fields
}
BoltDB is a storage implementation utilizing Bolt file database.
func NewBoltDB ¶
func NewBoltDB(config BoltDBConfig) (*BoltDB, error)
func (*BoltDB) DeleteLogsFrom ¶
func (*BoltDB) GetCurrentTerm ¶
func (*BoltDB) GetLogsFrom ¶
func (*BoltDB) GetVotedFor ¶
func (*BoltDB) LastLogIndex ¶
func (*BoltDB) LastLogTerm ¶
func (*BoltDB) SetCurrentTerm ¶
func (*BoltDB) SetVotedFor ¶
type BoltDBConfig ¶
type BoltDBConfig struct {
FilePath string
}
type Storage ¶
type Storage interface { // GetCurrentTerm returns the latest term server has seen (initialized to 0 on first boot, increases monotonically). GetCurrentTerm() (uint64, error) // SetCurrentTerm sets the current term. SetCurrentTerm(term uint64) error // GetVotedFor returns the candidate ID that received a vote in current term, empty/blank if none. GetVotedFor() (string, error) // SetVotedFor sets the candidate ID that received a vote in current term. SetVotedFor(candidateID string) error // GetLog returns the log entry on given index. GetLog(logIndex uint64) (*konsen.Log, error) // GetLogsFrom returns log entries with index greater equal than given index. GetLogsFrom(minLogIndex uint64) ([]*konsen.Log, error) // GetLogTerm returns the log term at given index. GetLogTerm(logIndex uint64) (uint64, error) // WriteLog writes the given log entry into storage. WriteLog(log *konsen.Log) error // WriteLogs writes the given log entries into storage. WriteLogs(logs []*konsen.Log) error // LastLogIndex returns the last(newest) log entry's index. LastLogIndex() (uint64, error) // LastLogTerm returns the last(newest) log entry's term. LastLogTerm() (uint64, error) // DeleteLogsFrom deletes logs with index greater equal than given index. DeleteLogsFrom(minLogIndex uint64) error // SetValue stores a key-value pair. SetValue(key []byte, value []byte) error // GetValue returns value of a key. GetValue(key []byte) ([]byte, error) }
Storage provides an interface for a set of local persistent storage operations.
Click to show internal directories.
Click to hide internal directories.