rafttestutil

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)

Functions

func CloseListener

func CloseListener(lis *net.Listener)

CloseListener closes the given net listener

func CreateRaftDirectory

func CreateRaftDirectory(raftDirectory string) string

CreateRaftDirectory clears the specified directory

func GenerateNewUUID

func GenerateNewUUID() string

GenerateNewUUID creates a new UUID

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 SetUpNode

func SetUpNode(name, ip, port, commonName string) raft.Node

SetUpNode sets up a new node

func StartListener

func StartListener() (*net.Listener, string)

StartListener starts a new listener on a random port

func StopRaftServer

func StopRaftServer(raftServer *raft.NetworkServer)

StopRaftServer stops the given raft server