cluster

package

v0.1.8 Latest Latest Go to latest Published: Jan 6, 2021 License: BSD-3-Clause Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ronaksoft/rony

Links

Open Source Insights

Documentation ¶

Index ¶

type Cluster
type Member
type Mode
type Raft
type ReplicaMessageHandler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v0.1.5

type Mode string

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

type Raft ¶ added in v0.1.5

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

Source Files ¶

View all Source files

cluster.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL