store

Documentation

Overview

Package store provides a simple distributed key-value store. The keys and associated values are changed via distributed consensus, meaning that the values are changed only when a majority of nodes in the cluster agree on the new value.

Distributed consensus is provided via the Raft algorithm.

Index

• type InMemDatastore
  • func NewInMemDatastore() *InMemDatastore
  • func (im *InMemDatastore) Delete(key string) error
  • func (im *InMemDatastore) Get(key string) (string, error)
  • func (im *InMemDatastore) Set(key, value string) error
  • func (im *InMemDatastore) Snapshot() *InMemDatastore
• type Store
  • func New() *Store
  • func (s *Store) Delete(key string) error
  • func (s *Store) Get(key string) (string, error)
  • func (s *Store) Join(addr string) error
  • func (s *Store) Open(enableSingle bool) error
  • func (s *Store) Set(key, value string) error

Types

type InMemDatastore

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

The key-value store for the system.

func NewInMemDatastore

func NewInMemDatastore() *InMemDatastore

func (*InMemDatastore) Delete

func (im *InMemDatastore) Delete(key string) error

func (*InMemDatastore) Get

func (im *InMemDatastore) Get(key string) (string, error)

func (*InMemDatastore) Set

func (im *InMemDatastore) Set(key, value string) error

func (*InMemDatastore) Snapshot

func (im *InMemDatastore) Snapshot() *InMemDatastore

Clone datastore by copying current data to a new instance and return the new instance

type Store

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

Store is a simple key-value store, where all changes are made via Raft consensus.

func New

func New() *Store

New returns a new Store.

func (*Store) Delete

func (s *Store) Delete(key string) error

Delete deletes the given key.

func (*Store) Get

func (s *Store) Get(key string) (string, error)

Get returns the value for the given key.

func (*Store) Join

func (s *Store) Join(addr string) error

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

func (*Store) Open

func (s *Store) Open(enableSingle bool) 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.

func (*Store) Set

func (s *Store) Set(key, value string) error

Set sets the value for the given key.