cluster

Documentation

Index

• type Cluster
• type Member
• type Mode
• type Raft
• type ReplicaMessageHandler

Types

type Cluster

type Cluster interface {
	Raft
	Start()
	Members() []Member
	Join(addr ...string) (int, error)
	Shutdown()
	ReplicaSet() uint64
	SetGatewayAddrs(addrs []string) error
	Addr() string
}

type Member

type Member interface {
	Proto(info *rony.NodeInfo) *rony.NodeInfo
	ServerID() string
	RaftState() rony.RaftState
	ReplicaSet() uint64
	GatewayAddr() []string
	RaftPort() int
}

type Mode

type Mode string

const (
	NoReplica     Mode = "noReplica"
	SingleReplica Mode = "singleReplica"
	MultiReplica  Mode = "multiReplica"
)

type Raft

type Raft interface {
	RaftMembers(replicaSet uint64) []Member
	RaftState() raft.RaftState
	RaftApply(cmd []byte) raft.ApplyFuture
	RaftLeaderID() string
	RaftConfigs() raft.ConfigurationFuture
}

type ReplicaMessageHandler

type ReplicaMessageHandler func(raftCmd *rony.RaftCommand) error