datastore

package
v2.0.0-...-90431d4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 16, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

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) Close

func (b *Badger) Close() error

func (*Badger) DeleteLogsFrom

func (b *Badger) DeleteLogsFrom(minLogIndex uint64) error

func (*Badger) GetCurrentTerm

func (b *Badger) GetCurrentTerm() (uint64, error)

func (*Badger) GetLog

func (b *Badger) GetLog(logIndex uint64) (*konsen.Log, error)

func (*Badger) GetLogTerm

func (b *Badger) GetLogTerm(logIndex uint64) (uint64, error)

func (*Badger) GetLogsFrom

func (b *Badger) GetLogsFrom(minLogIndex uint64) ([]*konsen.Log, error)

func (*Badger) GetValue

func (b *Badger) GetValue(key []byte) ([]byte, error)

func (*Badger) GetVotedFor

func (b *Badger) GetVotedFor() (string, error)

func (*Badger) LastLogIndex

func (b *Badger) LastLogIndex() (uint64, error)

func (*Badger) LastLogTerm

func (b *Badger) LastLogTerm() (uint64, error)

func (*Badger) SetCurrentTerm

func (b *Badger) SetCurrentTerm(term uint64) error

func (*Badger) SetValue

func (b *Badger) SetValue(key []byte, value []byte) error

func (*Badger) SetVotedFor

func (b *Badger) SetVotedFor(candidateID string) error

func (*Badger) WriteLog

func (b *Badger) WriteLog(log *konsen.Log) error

func (*Badger) WriteLogs

func (b *Badger) WriteLogs(logs []*konsen.Log) error

type BadgerConfig

type BadgerConfig struct {
	LogDir   string
	StateDir string
}

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) Close

func (b *BoltDB) Close() error

func (*BoltDB) DeleteLogsFrom

func (b *BoltDB) DeleteLogsFrom(minLogIndex uint64) error

func (*BoltDB) GetCurrentTerm

func (b *BoltDB) GetCurrentTerm() (uint64, error)

func (*BoltDB) GetLog

func (b *BoltDB) GetLog(logIndex uint64) (*konsen.Log, error)

func (*BoltDB) GetLogTerm

func (b *BoltDB) GetLogTerm(logIndex uint64) (uint64, error)

func (*BoltDB) GetLogsFrom

func (b *BoltDB) GetLogsFrom(minLogIndex uint64) ([]*konsen.Log, error)

func (*BoltDB) GetValue

func (b *BoltDB) GetValue(key []byte) ([]byte, error)

func (*BoltDB) GetVotedFor

func (b *BoltDB) GetVotedFor() (string, error)

func (*BoltDB) LastLogIndex

func (b *BoltDB) LastLogIndex() (uint64, error)

func (*BoltDB) LastLogTerm

func (b *BoltDB) LastLogTerm() (uint64, error)

func (*BoltDB) SetCurrentTerm

func (b *BoltDB) SetCurrentTerm(term uint64) error

func (*BoltDB) SetValue

func (b *BoltDB) SetValue(key []byte, value []byte) error

func (*BoltDB) SetVotedFor

func (b *BoltDB) SetVotedFor(candidateID string) error

func (*BoltDB) WriteLog

func (b *BoltDB) WriteLog(log *konsen.Log) error

func (*BoltDB) WriteLogs

func (b *BoltDB) WriteLogs(logs []*konsen.Log) error

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL