arctonyx

package module

v0.0.0-...-baba337 Latest Latest Go to latest Published: Feb 24, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Details

An embeddable raft implementation of the badger key-value store.

The compiled protocol files are not included in this repository. To create them cd to the directory and run make protos.

View Source

const (
	SequenceRangeSize   = 1000
	SequencePartitions  = 5
	SequencePreretrieve = 50
)

View Source

var (
	ErrNotLeader = errors.New("the current node is not the leader and cannot fulfill your request")
)

This section is empty.

type KeyValue struct {
	Key   []byte
	Value []byte
}

type SequenceChunk struct {
	Store
	// contains filtered or unexported fields
}

func (sequence *SequenceChunk) GetSequenceIndex() uint64

func (sequence *SequenceChunk) Next() (*uint64, error)

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

func CreateStore(directory string, listen string, joinAddr string) (*Store, error)

Creates and possibly joins a cluster.

func (store *Store) ChangeKey(currentKey []byte, newKey []byte) error

func (store *Store) Close()

func (store *Store) Delete(key []byte) (err error)

func (store *Store) Get(key []byte) (value []byte, err error)

func (store *Store) GetKeyOnlyPrefix(prefix []byte) (keys [][]byte, err error)

func (store *Store) GetPrefix(prefix []byte) (values []KeyValue, err error)

func (store *Store) GetPrefixWithPredicate(prefix []byte, predicate func(kv KeyValue) (bool, error)) (kv KeyValue, found bool, err error)

func (store *Store) IsLeader() bool

func (store *Store) ListenAddr() string

func (store *Store) NextSequenceValueById(sequenceName string) (*uint64, error)

func (store *Store) NodeID() uint64

func (store *Store) SequenceIndexById(sequenceName string) (uint64, error)

func (store *Store) Set(key, value []byte) (err error)

Path	Synopsis
example
demo command