mock_peermgr

Documentation

Overview

Package mock_peermgr is a generated GoMock package.

Index

• type MockPeerManager
  • func NewMockPeerManager(ctrl *gomock.Controller) *MockPeerManager
  • func (m *MockPeerManager) AddNode(newNodeID uint64, vpInfo *pb.VpInfo)
  • func (m *MockPeerManager) AsyncSend(arg0 uint64, arg1 *pb.Message) error
  • func (m *MockPeerManager) Broadcast(arg0 *pb.Message) error
  • func (m *MockPeerManager) CountConnectedPeers() uint64
  • func (m *MockPeerManager) DelNode(delID uint64)
  • func (m *MockPeerManager) Disconnect(vpInfos map[uint64]*pb.VpInfo)
  • func (m *MockPeerManager) EXPECT() *MockPeerManagerMockRecorder
  • func (m *MockPeerManager) OtherPeers() map[uint64]*peer.AddrInfo
  • func (m *MockPeerManager) Peers() map[uint64]*pb.VpInfo
  • func (m *MockPeerManager) Send(arg0 uint64, arg1 *pb.Message) (*pb.Message, error)
  • func (m *MockPeerManager) SendWithStream(arg0 network.Stream, arg1 *pb.Message) error
  • func (m *MockPeerManager) Start() error
  • func (m *MockPeerManager) Stop() error
  • func (m *MockPeerManager) SubscribeOrderMessage(ch chan<- events.OrderMessageEvent) event.Subscription
  • func (m *MockPeerManager) UpdateRouter(vpInfos map[uint64]*pb.VpInfo, isNew bool) bool
• type MockPeerManagerMockRecorder
  • func (mr *MockPeerManagerMockRecorder) AddNode(newNodeID, vpInfo interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) AsyncSend(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) Broadcast(arg0 interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) CountConnectedPeers() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) DelNode(delID interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) Disconnect(vpInfos interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) OtherPeers() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) Peers() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) SendWithStream(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) Start() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) Stop() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) SubscribeOrderMessage(ch interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) UpdateRouter(vpInfos, isNew interface{}) *gomock.Call

Types

type MockPeerManager

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

MockPeerManager is a mock of PeerManager interface

func NewMockPeerManager

func NewMockPeerManager(ctrl *gomock.Controller) *MockPeerManager

NewMockPeerManager creates a new mock instance

func (*MockPeerManager) AddNode

func (m *MockPeerManager) AddNode(newNodeID uint64, vpInfo *pb.VpInfo)

AddNode mocks base method

func (*MockPeerManager) AsyncSend

func (m *MockPeerManager) AsyncSend(arg0 uint64, arg1 *pb.Message) error

AsyncSend mocks base method

func (*MockPeerManager) Broadcast

func (m *MockPeerManager) Broadcast(arg0 *pb.Message) error

Broadcast mocks base method

func (*MockPeerManager) CountConnectedPeers

func (m *MockPeerManager) CountConnectedPeers() uint64

CountConnectedPeers mocks base method

func (*MockPeerManager) DelNode

func (m *MockPeerManager) DelNode(delID uint64)

DelNode mocks base method

func (*MockPeerManager) Disconnect

func (m *MockPeerManager) Disconnect(vpInfos map[uint64]*pb.VpInfo)

Disconnect mocks base method

func (*MockPeerManager) EXPECT

func (m *MockPeerManager) EXPECT() *MockPeerManagerMockRecorder

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

func (*MockPeerManager) OtherPeers

func (m *MockPeerManager) OtherPeers() map[uint64]*peer.AddrInfo

OtherPeers mocks base method

func (*MockPeerManager) Peers

func (m *MockPeerManager) Peers() map[uint64]*pb.VpInfo

Peers mocks base method

func (*MockPeerManager) Send

func (m *MockPeerManager) Send(arg0 uint64, arg1 *pb.Message) (*pb.Message, error)

Send mocks base method

func (*MockPeerManager) SendWithStream

func (m *MockPeerManager) SendWithStream(arg0 network.Stream, arg1 *pb.Message) error

SendWithStream mocks base method

func (*MockPeerManager) Start

func (m *MockPeerManager) Start() error

Start mocks base method

func (*MockPeerManager) Stop

func (m *MockPeerManager) Stop() error

Stop mocks base method

func (*MockPeerManager) SubscribeOrderMessage

func (m *MockPeerManager) SubscribeOrderMessage(ch chan<- events.OrderMessageEvent) event.Subscription

SubscribeOrderMessage mocks base method

func (*MockPeerManager) UpdateRouter

func (m *MockPeerManager) UpdateRouter(vpInfos map[uint64]*pb.VpInfo, isNew bool) bool

UpdateRouter mocks base method

type MockPeerManagerMockRecorder

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

MockPeerManagerMockRecorder is the mock recorder for MockPeerManager

func (*MockPeerManagerMockRecorder) AddNode

func (mr *MockPeerManagerMockRecorder) AddNode(newNodeID, vpInfo interface{}) *gomock.Call

AddNode indicates an expected call of AddNode

func (*MockPeerManagerMockRecorder) AsyncSend

func (mr *MockPeerManagerMockRecorder) AsyncSend(arg0, arg1 interface{}) *gomock.Call

AsyncSend indicates an expected call of AsyncSend

func (*MockPeerManagerMockRecorder) Broadcast

func (mr *MockPeerManagerMockRecorder) Broadcast(arg0 interface{}) *gomock.Call

Broadcast indicates an expected call of Broadcast

func (*MockPeerManagerMockRecorder) CountConnectedPeers

func (mr *MockPeerManagerMockRecorder) CountConnectedPeers() *gomock.Call

CountConnectedPeers indicates an expected call of CountConnectedPeers

func (*MockPeerManagerMockRecorder) DelNode

func (mr *MockPeerManagerMockRecorder) DelNode(delID interface{}) *gomock.Call

DelNode indicates an expected call of DelNode

func (*MockPeerManagerMockRecorder) Disconnect

func (mr *MockPeerManagerMockRecorder) Disconnect(vpInfos interface{}) *gomock.Call

Disconnect indicates an expected call of Disconnect

func (*MockPeerManagerMockRecorder) OtherPeers

func (mr *MockPeerManagerMockRecorder) OtherPeers() *gomock.Call

OtherPeers indicates an expected call of OtherPeers

func (*MockPeerManagerMockRecorder) Peers

func (mr *MockPeerManagerMockRecorder) Peers() *gomock.Call

Peers indicates an expected call of Peers

func (*MockPeerManagerMockRecorder) Send

func (mr *MockPeerManagerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockPeerManagerMockRecorder) SendWithStream

func (mr *MockPeerManagerMockRecorder) SendWithStream(arg0, arg1 interface{}) *gomock.Call

SendWithStream indicates an expected call of SendWithStream

func (*MockPeerManagerMockRecorder) Start

func (mr *MockPeerManagerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockPeerManagerMockRecorder) Stop

func (mr *MockPeerManagerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

func (*MockPeerManagerMockRecorder) SubscribeOrderMessage

func (mr *MockPeerManagerMockRecorder) SubscribeOrderMessage(ch interface{}) *gomock.Call

SubscribeOrderMessage indicates an expected call of SubscribeOrderMessage

func (*MockPeerManagerMockRecorder) UpdateRouter

func (mr *MockPeerManagerMockRecorder) UpdateRouter(vpInfos, isNew interface{}) *gomock.Call

UpdateRouter indicates an expected call of UpdateRouter