store

package

v0.4.0 Latest Latest Go to latest Published: Mar 14, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewKVS(dir string, valueDir string, logger *log.Logger) (*KVS, error)

func (b *KVS) Close() error

func (b *KVS) Delete(key []byte) error

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

func (b *KVS) Set(key []byte, value []byte) error

func (b *KVS) SnapshotItems() <-chan *kvs.KeyValuePair

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

func NewKVSFSM(path string, logger *log.Logger) (*KVSFSM, error)

func (f *KVSFSM) Apply(l *raft.Log) interface{}

func (f *KVSFSM) Close() error

func (f *KVSFSM) Get(key []byte) ([]byte, error)

func (f *KVSFSM) Restore(rc io.ReadCloser) error

func (f *KVSFSM) Snapshot() (raft.FSMSnapshot, error)

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

func (f *KVSFSMSnapshot) Persist(sink raft.SnapshotSink) error

func (f *KVSFSMSnapshot) Release()

type KeyValueStore struct {
	BindAddr string
	DataDir  string
	// contains filtered or unexported fields
}

func NewKeyValueStore(bindAddr string, dataDir string, logger *log.Logger) (*KeyValueStore, error)

func (s *KeyValueStore) Close() error

func (s *KeyValueStore) Delete(key []byte) error

func (s *KeyValueStore) Get(key []byte) ([]byte, error)

func (s *KeyValueStore) Join(nodeId string, addr string) error

func (s *KeyValueStore) Leave(nodeId string) error

func (s *KeyValueStore) Open(bootstrap bool, localID string) error

func (s *KeyValueStore) Set(key []byte, value []byte) error

func (s *KeyValueStore) Snapshot() error