raft

Documentation

Index

• type IPeer
• type KV
  • func NewKV() *KV
  • func (k *KV) Add(key, value string) (new bool)
  • func (k *KV) Del(key, value string) (empty bool)
  • func (k *KV) DelByValue(value string) int
  • func (k *KV) Get(key string) []string
  • func (k *KV) GetAll() *data

Types

type IPeer

type IPeer interface {
	Join(nodeID, addr string) error
	Leave(nodeID string) error
	Propose(msg *message.Message) error
	Lookup(key string) []string
	IsApplyRight() bool
	GetLeader() (addr, id string)
	GenPeersFile(file string) error
	Stop()
}

type KV

type KV struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewKV

func NewKV() *KV

func (*KV) Add

func (k *KV) Add(key, value string) (new bool)

Add return true if key is set for the first time

func (*KV) Del

func (k *KV) Del(key, value string) (empty bool)

Del return true if the array corresponding to key is deleted If the value is "", the key-values pair is deleted

func (*KV) DelByValue

func (k *KV) DelByValue(value string) int

DelByValue delete the specified value from the key-values array and delete the key-value pair if the key-values array is empty

func (*KV) Get

func (k *KV) Get(key string) []string

func (*KV) GetAll

func (k *KV) GetAll() *data