store

Documentation

Index

• type Store
  • func NewStore(dir, address string, logger hclog.Logger) *Store
  • func (s *Store) Delete(key string) error
  • func (s *Store) Get(key string) (string, error)
  • func (s *Store) IsLeader() bool
  • func (s *Store) Join(nodeID, nodeAddress string) error
  • func (s *Store) LeadershipTransfer() error
  • func (s *Store) Nodes() ([]raft.Server, error)
  • func (s *Store) Set(key, value string) error
  • func (s *Store) Start(id string, bootstrap bool) error
  • func (s *Store) Stop() error

Types

type Store

type Store struct {
	RaftID      string
	RaftDir     string
	BindAddress string
	Logger      hclog.Logger

	// ResponseTimeout is the duration after which a non-reachable node is removed
	ResponseTimeout time.Duration
	// contains filtered or unexported fields
}

func NewStore

func NewStore(dir, address string, logger hclog.Logger) *Store

func (*Store) Delete

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

func (*Store) Get

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

func (*Store) IsLeader

func (s *Store) IsLeader() bool

func (*Store) Join

func (s *Store) Join(nodeID, nodeAddress string) error

func (*Store) LeadershipTransfer

func (s *Store) LeadershipTransfer() error

func (*Store) Nodes

func (s *Store) Nodes() ([]raft.Server, error)

func (*Store) Set

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

func (*Store) Start

func (s *Store) Start(id string, bootstrap bool) error

func (*Store) Stop

func (s *Store) Stop() error