raft

package
v1.2.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 1, 2026 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.