replica

Documentation

Index

• Variables
• 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) DeleteRange(min string, max string) (uint64, error)
  • func (n *Node) Get(key string) (string, error)
  • func (n *Node) GetRange(min string, max string) (db.KeyValueIterator, 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 Raftukki
  • func NewRaftukki(db *db.Database) *Raftukki
  • func (t *Raftukki) DeleteRange(min uint64, max uint64) error
  • func (t *Raftukki) FirstIndex() (uint64, error)
  • func (t *Raftukki) Get(key []byte) ([]byte, error)
  • func (t *Raftukki) GetLog(index uint64, log *raft.Log) error
  • func (t *Raftukki) GetUint64(key []byte) (uint64, error)
  • func (t *Raftukki) LastIndex() (uint64, error)
  • func (t *Raftukki) Set(key []byte, val []byte) error
  • func (t *Raftukki) SetUint64(key []byte, val uint64) error
  • func (t *Raftukki) StoreLog(log *raft.Log) error
  • func (t *Raftukki) StoreLogs(logs []*raft.Log) error
• type SstableIterator
  • func (i *SstableIterator) Next() (keyvalue.IteratorEntry, error)

Variables

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

Types

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

func (n *Node) DeleteRange(min string, max string) (uint64, error)

DeleteRange implements kv.DB.

func (*Node) Get

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

Get returns the value for the given key.

func (*Node) GetRange

func (n *Node) GetRange(min string, max string) (db.KeyValueIterator, error)

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 Raftukki

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

func NewRaftukki

func NewRaftukki(db *db.Database) *Raftukki

func (*Raftukki) DeleteRange

func (t *Raftukki) DeleteRange(min uint64, max uint64) error

DeleteRange implements raft.LogStore.

func (*Raftukki) FirstIndex

func (t *Raftukki) FirstIndex() (uint64, error)

FirstIndex implements raft.LogStore.

func (*Raftukki) Get

func (t *Raftukki) Get(key []byte) ([]byte, error)

Get implements raft.StableStore.

func (*Raftukki) GetLog

func (t *Raftukki) GetLog(index uint64, log *raft.Log) error

GetLog implements raft.LogStore.

func (*Raftukki) GetUint64

func (t *Raftukki) GetUint64(key []byte) (uint64, error)

GetUint64 implements raft.StableStore.

func (*Raftukki) LastIndex

func (t *Raftukki) LastIndex() (uint64, error)

LastIndex implements raft.LogStore.

func (*Raftukki) Set

func (t *Raftukki) Set(key []byte, val []byte) error

Set implements raft.StableStore.

func (*Raftukki) SetUint64

func (t *Raftukki) SetUint64(key []byte, val uint64) error

SetUint64 implements raft.StableStore.

func (*Raftukki) StoreLog

func (t *Raftukki) StoreLog(log *raft.Log) error

StoreLog implements raft.LogStore.

func (*Raftukki) StoreLogs

func (t *Raftukki) StoreLogs(logs []*raft.Log) error

StoreLogs implements raft.LogStore.

type SstableIterator

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

func (*SstableIterator) Next

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