storeCluster

Feb 27, 2021

Changes in this version

+ var ErrKeyNotFound = errors.New("not found")

+ type BadgerStore struct

+ func (b *BadgerStore) DeleteRange(min, max uint64) error

+ func (b *BadgerStore) FirstIndex() (uint64, error)

+ func (b *BadgerStore) Get(key []byte) ([]byte, error)

+ func (b *BadgerStore) GetLog(index uint64, log *raft.Log) error

+ func (b *BadgerStore) GetUint64(key []byte) (uint64, error)

+ func (b *BadgerStore) LastIndex() (uint64, error)

+ func (b *BadgerStore) Set(key []byte, val []byte) error

+ func (b *BadgerStore) SetUint64(key []byte, val uint64) error

+ func (b *BadgerStore) StoreLog(log *raft.Log) error

+ func (b *BadgerStore) StoreLogs(logs []*raft.Log) error

+ type Cluster struct

+ func (c *Cluster) Addr() string

+ func (c *Cluster) Join(addr ...string) (int, error)

+ func (c *Cluster) Members() []cluster.Member

+ func (c *Cluster) RaftApply(cmd []byte) raft.ApplyFuture

+ func (c *Cluster) RaftEnabled() bool

+ func (c *Cluster) RaftLeaderID() string

+ func (c *Cluster) RaftMembers(replicaSet uint64) []cluster.Member

+ func (c *Cluster) RaftState() raft.RaftState

+ func (c *Cluster) ReplicaSet() uint64

+ func (c *Cluster) SetGatewayAddrs(hostPorts []string) error

+ func (c *Cluster) SetTunnelAddrs(hostPorts []string) error

+ func (c *Cluster) Shutdown()

+ func (c *Cluster) Start()

+ func (c *Cluster) TotalReplicas() int

+ type Config struct

+ Bootstrap bool

+ DataPath string

+ GossipPort int

+ Mode cluster.Mode

+ RaftPort int

+ ReplicaSet uint64

+ ServerID []byte

+ type Member struct

+ ClusterAddr net.IP

+ ClusterPort uint16

+ func (m *Member) GatewayAddr() []string

+ func (m *Member) Proto(p *rony.Edge) *rony.Edge

+ func (m *Member) RaftPort() int

+ func (m *Member) RaftState() rony.RaftState

+ func (m *Member) ReplicaSet() uint64

+ func (m *Member) ServerID() string

+ func (m *Member) TunnelAddr() []string