Documentation ¶
Overview ¶
Package mock_peermgr is a generated GoMock package.
Index ¶
- type 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) PierManager() peermgr.PierManager
- func (m *MockPeerManager) ReConfig(config interface{}) error
- 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) PierManager() *gomock.Call
- func (mr *MockPeerManagerMockRecorder) ReConfig(config interface{}) *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
- type MockPierManager
- type MockPierManagerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) PierManager ¶ added in v1.5.0
func (m *MockPeerManager) PierManager() peermgr.PierManager
PierManager mocks base method.
func (*MockPeerManager) ReConfig ¶ added in v1.6.3
func (m *MockPeerManager) ReConfig(config interface{}) error
ReConfig mocks base method.
func (*MockPeerManager) SendWithStream ¶
SendWithStream mocks base method.
func (*MockPeerManager) SubscribeOrderMessage ¶
func (m *MockPeerManager) SubscribeOrderMessage(ch chan<- events.OrderMessageEvent) event.Subscription
SubscribeOrderMessage mocks base method.
func (*MockPeerManager) UpdateRouter ¶
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) PierManager ¶ added in v1.5.0
func (mr *MockPeerManagerMockRecorder) PierManager() *gomock.Call
PierManager indicates an expected call of PierManager.
func (*MockPeerManagerMockRecorder) ReConfig ¶ added in v1.6.3
func (mr *MockPeerManagerMockRecorder) ReConfig(config interface{}) *gomock.Call
ReConfig indicates an expected call of ReConfig.
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.
type MockPierManager ¶ added in v1.5.0
type MockPierManager struct {
// contains filtered or unexported fields
}
MockPierManager is a mock of PierManager interface.
func NewMockPierManager ¶ added in v1.5.0
func NewMockPierManager(ctrl *gomock.Controller) *MockPierManager
NewMockPierManager creates a new mock instance.
func (*MockPierManager) AskPierMaster ¶ added in v1.5.0
func (m *MockPierManager) AskPierMaster(arg0 string) (bool, error)
AskPierMaster mocks base method.
func (*MockPierManager) EXPECT ¶ added in v1.5.0
func (m *MockPierManager) EXPECT() *MockPierManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPierManager) Piers ¶ added in v1.5.0
func (m *MockPierManager) Piers() *peermgr.Piers
Piers mocks base method.
type MockPierManagerMockRecorder ¶ added in v1.5.0
type MockPierManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockPierManagerMockRecorder is the mock recorder for MockPierManager.
func (*MockPierManagerMockRecorder) AskPierMaster ¶ added in v1.5.0
func (mr *MockPierManagerMockRecorder) AskPierMaster(arg0 interface{}) *gomock.Call
AskPierMaster indicates an expected call of AskPierMaster.
func (*MockPierManagerMockRecorder) Piers ¶ added in v1.5.0
func (mr *MockPierManagerMockRecorder) Piers() *gomock.Call
Piers indicates an expected call of Piers.