raftenginemock

Documentation

Overview

Package raftenginemock is a generated GoMock package.

Index

• type MockEngine
  • func NewMockEngine(ctrl *gomock.Controller) *MockEngine
  • func (m *MockEngine) CreateSnapshot() (raftpb0.Snapshot, error)
  • func (m *MockEngine) EXPECT() *MockEngineMockRecorder
  • func (m *MockEngine) LinearizableRead(ctx context.Context) error
  • func (m_2 *MockEngine) ProposeConfChange(ctx context.Context, m *raftpb.Member, t raftpb0.ConfChangeType) error
  • func (m *MockEngine) ProposeReplicate(ctx context.Context, data []byte) error
  • func (m_2 *MockEngine) Push(m raftpb0.Message) error
  • func (m *MockEngine) ReportShutdown(id uint64)
  • func (m *MockEngine) ReportSnapshot(id uint64, status raft.SnapshotStatus)
  • func (m *MockEngine) ReportUnreachable(id uint64)
  • func (m *MockEngine) Shutdown(arg0 context.Context) error
  • func (m *MockEngine) Start(addr string, oprs ...raftengine.Operator) error
  • func (m *MockEngine) Status() (raft.Status, error)
  • func (m *MockEngine) TransferLeadership(arg0 context.Context, arg1 uint64) error
• type MockEngineMockRecorder
  • func (mr *MockEngineMockRecorder) CreateSnapshot() *gomock.Call
  • func (mr *MockEngineMockRecorder) LinearizableRead(ctx interface{}) *gomock.Call
  • func (mr *MockEngineMockRecorder) ProposeConfChange(ctx, m, t interface{}) *gomock.Call
  • func (mr *MockEngineMockRecorder) ProposeReplicate(ctx, data interface{}) *gomock.Call
  • func (mr *MockEngineMockRecorder) Push(m interface{}) *gomock.Call
  • func (mr *MockEngineMockRecorder) ReportShutdown(id interface{}) *gomock.Call
  • func (mr *MockEngineMockRecorder) ReportSnapshot(id, status interface{}) *gomock.Call
  • func (mr *MockEngineMockRecorder) ReportUnreachable(id interface{}) *gomock.Call
  • func (mr *MockEngineMockRecorder) Shutdown(arg0 interface{}) *gomock.Call
  • func (mr *MockEngineMockRecorder) Start(addr interface{}, oprs ...interface{}) *gomock.Call
  • func (mr *MockEngineMockRecorder) Status() *gomock.Call
  • func (mr *MockEngineMockRecorder) TransferLeadership(arg0, arg1 interface{}) *gomock.Call

Types

type MockEngine

type MockEngine struct {
	// contains filtered or unexported fields
}

MockEngine is a mock of Engine interface.

func NewMockEngine

func NewMockEngine(ctrl *gomock.Controller) *MockEngine

NewMockEngine creates a new mock instance.

func (*MockEngine) CreateSnapshot

func (m *MockEngine) CreateSnapshot() (raftpb0.Snapshot, error)

CreateSnapshot mocks base method.

func (*MockEngine) EXPECT

func (m *MockEngine) EXPECT() *MockEngineMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEngine) LinearizableRead

func (m *MockEngine) LinearizableRead(ctx context.Context) error

LinearizableRead mocks base method.

func (*MockEngine) ProposeConfChange

func (m_2 *MockEngine) ProposeConfChange(ctx context.Context, m *raftpb.Member, t raftpb0.ConfChangeType) error

ProposeConfChange mocks base method.

func (*MockEngine) ProposeReplicate

func (m *MockEngine) ProposeReplicate(ctx context.Context, data []byte) error

ProposeReplicate mocks base method.

func (*MockEngine) Push

func (m_2 *MockEngine) Push(m raftpb0.Message) error

Push mocks base method.

func (*MockEngine) ReportShutdown

func (m *MockEngine) ReportShutdown(id uint64)

ReportShutdown mocks base method.

func (*MockEngine) ReportSnapshot

func (m *MockEngine) ReportSnapshot(id uint64, status raft.SnapshotStatus)

ReportSnapshot mocks base method.

func (*MockEngine) ReportUnreachable

func (m *MockEngine) ReportUnreachable(id uint64)

ReportUnreachable mocks base method.

func (*MockEngine) Shutdown

func (m *MockEngine) Shutdown(arg0 context.Context) error

Shutdown mocks base method.

func (*MockEngine) Start

func (m *MockEngine) Start(addr string, oprs ...raftengine.Operator) error

Start mocks base method.

func (*MockEngine) Status

func (m *MockEngine) Status() (raft.Status, error)

Status mocks base method.

func (*MockEngine) TransferLeadership

func (m *MockEngine) TransferLeadership(arg0 context.Context, arg1 uint64) error

TransferLeadership mocks base method.

type MockEngineMockRecorder

type MockEngineMockRecorder struct {
	// contains filtered or unexported fields
}

MockEngineMockRecorder is the mock recorder for MockEngine.

func (*MockEngineMockRecorder) CreateSnapshot

func (mr *MockEngineMockRecorder) CreateSnapshot() *gomock.Call

CreateSnapshot indicates an expected call of CreateSnapshot.

func (*MockEngineMockRecorder) LinearizableRead

func (mr *MockEngineMockRecorder) LinearizableRead(ctx interface{}) *gomock.Call

LinearizableRead indicates an expected call of LinearizableRead.

func (*MockEngineMockRecorder) ProposeConfChange

func (mr *MockEngineMockRecorder) ProposeConfChange(ctx, m, t interface{}) *gomock.Call

ProposeConfChange indicates an expected call of ProposeConfChange.

func (*MockEngineMockRecorder) ProposeReplicate

func (mr *MockEngineMockRecorder) ProposeReplicate(ctx, data interface{}) *gomock.Call

ProposeReplicate indicates an expected call of ProposeReplicate.

func (*MockEngineMockRecorder) Push

func (mr *MockEngineMockRecorder) Push(m interface{}) *gomock.Call

Push indicates an expected call of Push.

func (*MockEngineMockRecorder) ReportShutdown

func (mr *MockEngineMockRecorder) ReportShutdown(id interface{}) *gomock.Call

ReportShutdown indicates an expected call of ReportShutdown.

func (*MockEngineMockRecorder) ReportSnapshot

func (mr *MockEngineMockRecorder) ReportSnapshot(id, status interface{}) *gomock.Call

ReportSnapshot indicates an expected call of ReportSnapshot.

func (*MockEngineMockRecorder) ReportUnreachable

func (mr *MockEngineMockRecorder) ReportUnreachable(id interface{}) *gomock.Call

ReportUnreachable indicates an expected call of ReportUnreachable.

func (*MockEngineMockRecorder) Shutdown

func (mr *MockEngineMockRecorder) Shutdown(arg0 interface{}) *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockEngineMockRecorder) Start

func (mr *MockEngineMockRecorder) Start(addr interface{}, oprs ...interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockEngineMockRecorder) Status

func (mr *MockEngineMockRecorder) Status() *gomock.Call

Status indicates an expected call of Status.

func (*MockEngineMockRecorder) TransferLeadership

func (mr *MockEngineMockRecorder) TransferLeadership(arg0, arg1 interface{}) *gomock.Call

TransferLeadership indicates an expected call of TransferLeadership.