Versions in this module Expand all Collapse all v1 v1.12.0 Jul 26, 2016 Changes in this version + func AddRaftNode(t *testing.T, clockSource *fakeclock.FakeClock, nodes map[uint64]*TestNode, ...) + func AdvanceTicks(clockSource *fakeclock.FakeClock, ticks int) + func CheckNoValue(t *testing.T, clockSource *fakeclock.FakeClock, raftNode *TestNode) + func CheckValue(t *testing.T, clockSource *fakeclock.FakeClock, raftNode *TestNode, ...) + func CheckValuesOnNodes(t *testing.T, clockSource *fakeclock.FakeClock, ...) + func GetAllValuesOnNode(t *testing.T, clockSource *fakeclock.FakeClock, raftNode *TestNode) ([]string, []*api.Node) + func NewRaftCluster(t *testing.T, tc *cautils.TestCA, config ...*api.RaftConfig) (map[uint64]*TestNode, *fakeclock.FakeClock) + func PollFunc(clockSource *fakeclock.FakeClock, f func() error) error + func PollFuncWithTimeout(clockSource *fakeclock.FakeClock, f func() error, timeout time.Duration) error + func ProposeValue(t *testing.T, raftNode *TestNode, nodeID ...string) (*api.Node, error) + func ShutdownNode(node *TestNode) + func TeardownCluster(t *testing.T, nodes map[uint64]*TestNode) + func WaitForCluster(t *testing.T, clockSource *fakeclock.FakeClock, nodes map[uint64]*TestNode) + func WaitForPeerNumber(t *testing.T, clockSource *fakeclock.FakeClock, nodes map[uint64]*TestNode, ...) + type TestNode struct + Listener *WrappedListener + SecurityConfig *ca.SecurityConfig + func Leader(nodes map[uint64]*TestNode) *TestNode + func NewInitNode(t *testing.T, tc *cautils.TestCA, raftConfig *api.RaftConfig, ...) (*TestNode, *fakeclock.FakeClock) + func NewJoinNode(t *testing.T, clockSource *fakeclock.FakeClock, join string, ...) *TestNode + func NewNode(t *testing.T, clockSource *fakeclock.FakeClock, tc *cautils.TestCA, ...) *TestNode + func RestartNode(t *testing.T, clockSource *fakeclock.FakeClock, oldNode *TestNode, ...) *TestNode + type WrappedListener struct + func NewWrappedListener(l net.Listener) *WrappedListener + func RecycleWrappedListener(old *WrappedListener) *WrappedListener + func (l *WrappedListener) Accept() (net.Conn, error) + func (l *WrappedListener) Close() error
Go to main page