store

package

v0.0.0-...-bc5e729 Latest Latest Go to latest Published: Dec 9, 2017 License: MPL-2.0 Imports: 12 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Focinfi/oncekv

Links

Open Source Insights

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.

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

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) Add ¶

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

Add adds the key/value, if the key has been added, do nothing.

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) Leader ¶

func (s *Store) Leader() string

Leader returns current leader of this raft cluster

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) Peers ¶

func (s *Store) Peers() ([]string, error)

Peers returns the raft peers

func (*Store) Set ¶

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

Set sets the value for the given key.

func (*Store) Stats ¶

func (s *Store) Stats() map[string]string

Stats return this raft status

Source Files ¶

View all Source files

store.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL