rafttest

Documentation

Index

• func CheckConfiguration(c *gc.C, r *raft.Raft, expectedServers []raft.Server)
• type RaftFixture
  • func (s *RaftFixture) DefaultConfig(id raft.ServerID) *raft.Config
  • func (s *RaftFixture) NewRaft(c *gc.C, id raft.ServerID, fsm raft.FSM) (*raft.Raft, *raft.Config, *raft.InmemTransport, *raft.InmemStore, ...)
  • func (s *RaftFixture) SetUpTest(c *gc.C)

Functions

func CheckConfiguration

func CheckConfiguration(c *gc.C, r *raft.Raft, expectedServers []raft.Server)

CheckConfiguration waits some time for the Raft to have the expected server configuration.

Types

type RaftFixture

type RaftFixture struct {
	testing.IsolationSuite

	FSM           raft.FSM
	Config        *raft.Config
	Transport     *raft.InmemTransport
	Store         *raft.InmemStore
	SnapshotStore *raft.InmemSnapshotStore
	Raft          *raft.Raft
}

RaftFixture is a fixture to embed into test suites, providing a raft.Raft and in-memory transport.

func (*RaftFixture) DefaultConfig

func (s *RaftFixture) DefaultConfig(id raft.ServerID) *raft.Config

func (*RaftFixture) NewRaft

func (s *RaftFixture) NewRaft(c *gc.C, id raft.ServerID, fsm raft.FSM) (
	*raft.Raft,
	*raft.Config,
	*raft.InmemTransport,
	*raft.InmemStore,
	*raft.InmemSnapshotStore,
)

func (*RaftFixture) SetUpTest

func (s *RaftFixture) SetUpTest(c *gc.C)