Documentation ¶
Index ¶
- func CloseListener(lis *net.Listener)
- func CreateRaftDirectory(raftDirectory string) string
- func GenerateNewUUID() string
- func GetLeader(cluster []*raft.NetworkServer) *raft.NetworkServer
- func GetLeaderTimeout(cluster []*raft.NetworkServer, timeoutSeconds int) *raft.NetworkServer
- func IsLeader(server *raft.NetworkServer) bool
- func RemoveRaftDirectory(raftDirectory string, raftServer *raft.NetworkServer)
- func SetUpNode(name, ip, port, commonName string) raft.Node
- func StartListener() (*net.Listener, string)
- func StopRaftServer(raftServer *raft.NetworkServer)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseListener ¶
CloseListener closes the given net listener
func CreateRaftDirectory ¶
CreateRaftDirectory clears the specified directory
func GetLeader ¶
func GetLeader(cluster []*raft.NetworkServer) *raft.NetworkServer
GetLeader from a list of servers
func GetLeaderTimeout ¶
func GetLeaderTimeout(cluster []*raft.NetworkServer, timeoutSeconds int) *raft.NetworkServer
GetLeaderTimeout gets a leader, if the leader is not found it tires again after the timeout
func IsLeader ¶
func IsLeader(server *raft.NetworkServer) bool
IsLeader checks if the local raft server is the raft leader
func RemoveRaftDirectory ¶
func RemoveRaftDirectory(raftDirectory string, raftServer *raft.NetworkServer)
RemoveRaftDirectory removes the raft directory when the server is finished
func StartListener ¶
StartListener starts a new listener on a random port
func StopRaftServer ¶
func StopRaftServer(raftServer *raft.NetworkServer)
StopRaftServer stops the given raft server
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.