replica

Documentation

Index

• Variables
• type BadgerWrapper
  • func NewBadgerWrapper(db *raftbadger.Storage) *BadgerWrapper
  • func (b *BadgerWrapper) DeleteRange(min uint64, max uint64) error
  • func (b *BadgerWrapper) FirstIndex() (uint64, error)
  • func (b *BadgerWrapper) Get(key []byte) ([]byte, error)
  • func (b *BadgerWrapper) GetLog(index uint64, log *raft.Log) error
  • func (b *BadgerWrapper) GetUint64(key []byte) (uint64, error)
  • func (b *BadgerWrapper) LastIndex() (uint64, error)
  • func (b *BadgerWrapper) Set(key []byte, val []byte) error
  • func (b *BadgerWrapper) SetUint64(key []byte, val uint64) error
  • func (b *BadgerWrapper) StoreLog(log *raft.Log) error
  • func (b *BadgerWrapper) StoreLogs(logs []*raft.Log) error
• type Node
  • func New(inmem bool, peers []Peer, db *db.Database, dbDir, raftDir, raftBind string) *Node
  • func (n *Node) Delete(key string) error
  • func (n *Node) Get(key string) (string, error)
  • func (n *Node) Join(nodeID, addr string) error
  • func (n *Node) Open(localID string, enableSingle bool, peers []Peer) error
  • func (n *Node) Set(key, value string) error
• type Peer
• type SstableIterator
  • func (i *SstableIterator) Next() (keyvalue.IteratorEntry, error)

Variables

var (
	ErrKeyNotFound = errors.New("not found")
)

Types

type BadgerWrapper

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

func NewBadgerWrapper

func NewBadgerWrapper(db *raftbadger.Storage) *BadgerWrapper

func (*BadgerWrapper) DeleteRange

func (b *BadgerWrapper) DeleteRange(min uint64, max uint64) error

DeleteRange implements raft.LogStore.

func (*BadgerWrapper) FirstIndex

func (b *BadgerWrapper) FirstIndex() (uint64, error)

FirstIndex implements raft.LogStore.

func (*BadgerWrapper) Get

func (b *BadgerWrapper) Get(key []byte) ([]byte, error)

Get implements raft.StableStore.

func (*BadgerWrapper) GetLog

func (b *BadgerWrapper) GetLog(index uint64, log *raft.Log) error

GetLog implements raft.LogStore.

func (*BadgerWrapper) GetUint64

func (b *BadgerWrapper) GetUint64(key []byte) (uint64, error)

GetUint64 implements raft.StableStore.

func (*BadgerWrapper) LastIndex

func (b *BadgerWrapper) LastIndex() (uint64, error)

LastIndex implements raft.LogStore.

func (*BadgerWrapper) Set

func (b *BadgerWrapper) Set(key []byte, val []byte) error

Set implements raft.StableStore.

func (*BadgerWrapper) SetUint64

func (b *BadgerWrapper) SetUint64(key []byte, val uint64) error

SetUint64 implements raft.StableStore.

func (*BadgerWrapper) StoreLog

func (b *BadgerWrapper) StoreLog(log *raft.Log) error

StoreLog implements raft.LogStore.

func (*BadgerWrapper) StoreLogs

func (b *BadgerWrapper) StoreLogs(logs []*raft.Log) error

StoreLogs implements raft.LogStore.

type Node

type Node struct {
	RaftDir  string
	RaftBind string
	// contains filtered or unexported fields
}

func New

func New(inmem bool, peers []Peer, db *db.Database, dbDir, raftDir, raftBind string) *Node

New returns a new Store.

func (*Node) Delete

func (n *Node) Delete(key string) error

Delete deletes the given key.

func (*Node) Get

func (n *Node) Get(key string) (string, error)

Get returns the value for the given key.

func (*Node) Join

func (n *Node) Join(nodeID, addr string) error

Join joins a node, identified by nodeID and located at addr, to this store. The node must be ready to respond to Raft communications at that address.

func (*Node) Open

func (n *Node) Open(localID string, enableSingle bool, peers []Peer) error

Open opens the store. If enableSingle is set, and there are no existing peers, then this node becomes the first node, and therefore leader, of the cluster. localID should be the server identifier for this node.

func (*Node) Set

func (n *Node) Set(key, value string) error

Set sets the value for the given key.

type Peer

type Peer struct {
	Id   string
	Addr string
}

type SstableIterator

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

func (*SstableIterator) Next

func (i *SstableIterator) Next() (keyvalue.IteratorEntry, error)