Documentation ¶
Overview ¶
Package mock_peermgr is a generated GoMock package.
Index ¶
- type MockDHTManager
- type MockDHTManagerMockRecorder
- type MockPeerManager
- func (m *MockPeerManager) AsyncSend(arg0 peer_mgr.KeyType, arg1 *pb.Message) error
- func (m *MockPeerManager) AsyncSendWithStream(arg0 network.Stream, arg1 *pb.Message) error
- func (m *MockPeerManager) Connect(info *peer.AddrInfo) (string, error)
- func (m *MockPeerManager) ConnectedPeerIDs() []string
- func (m *MockPeerManager) CountConnectedPeers() uint64
- func (m *MockPeerManager) EXPECT() *MockPeerManagerMockRecorder
- func (m *MockPeerManager) FindProviders(id string) (string, error)
- func (m *MockPeerManager) Peers() map[string]*peer.AddrInfo
- func (m *MockPeerManager) Provider(arg0 string, arg1 bool) error
- func (m *MockPeerManager) RegisterConnectHandler(arg0 func(string)) error
- func (m *MockPeerManager) RegisterMsgHandler(arg0 pb.Message_Type, arg1 func(network.Stream, *pb.Message)) error
- func (m *MockPeerManager) RegisterMultiMsgHandler(arg0 []pb.Message_Type, arg1 func(network.Stream, *pb.Message)) error
- func (m *MockPeerManager) Send(arg0 peer_mgr.KeyType, arg1 *pb.Message) (*pb.Message, error)
- func (m *MockPeerManager) Start() error
- func (m *MockPeerManager) Stop() error
- type MockPeerManagerMockRecorder
- func (mr *MockPeerManagerMockRecorder) AsyncSend(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerManagerMockRecorder) AsyncSendWithStream(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerManagerMockRecorder) Connect(info interface{}) *gomock.Call
- func (mr *MockPeerManagerMockRecorder) ConnectedPeerIDs() *gomock.Call
- func (mr *MockPeerManagerMockRecorder) CountConnectedPeers() *gomock.Call
- func (mr *MockPeerManagerMockRecorder) FindProviders(id interface{}) *gomock.Call
- func (mr *MockPeerManagerMockRecorder) Peers() *gomock.Call
- func (mr *MockPeerManagerMockRecorder) Provider(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerManagerMockRecorder) RegisterConnectHandler(arg0 interface{}) *gomock.Call
- func (mr *MockPeerManagerMockRecorder) RegisterMsgHandler(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerManagerMockRecorder) RegisterMultiMsgHandler(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerManagerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerManagerMockRecorder) Start() *gomock.Call
- func (mr *MockPeerManagerMockRecorder) Stop() *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockDHTManager ¶ added in v1.4.0
type MockDHTManager struct {
// contains filtered or unexported fields
}
MockDHTManager is a mock of DHTManager interface.
func NewMockDHTManager ¶ added in v1.4.0
func NewMockDHTManager(ctrl *gomock.Controller) *MockDHTManager
NewMockDHTManager creates a new mock instance.
func (*MockDHTManager) EXPECT ¶ added in v1.4.0
func (m *MockDHTManager) EXPECT() *MockDHTManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDHTManager) FindProviders ¶ added in v1.4.0
func (m *MockDHTManager) FindProviders(id string) (string, error)
FindProviders mocks base method.
type MockDHTManagerMockRecorder ¶ added in v1.4.0
type MockDHTManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockDHTManagerMockRecorder is the mock recorder for MockDHTManager.
func (*MockDHTManagerMockRecorder) FindProviders ¶ added in v1.4.0
func (mr *MockDHTManagerMockRecorder) FindProviders(id interface{}) *gomock.Call
FindProviders indicates an expected call of FindProviders.
func (*MockDHTManagerMockRecorder) Provider ¶ added in v1.4.0
func (mr *MockDHTManagerMockRecorder) Provider(arg0, arg1 interface{}) *gomock.Call
Provider indicates an expected call of Provider.
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) AsyncSendWithStream ¶ added in v1.4.0
AsyncSendWithStream mocks base method.
func (*MockPeerManager) Connect ¶ added in v1.4.0
func (m *MockPeerManager) Connect(info *peer.AddrInfo) (string, error)
Connect mocks base method.
func (*MockPeerManager) ConnectedPeerIDs ¶ added in v1.18.0
func (m *MockPeerManager) ConnectedPeerIDs() []string
ConnectedPeerIDs mocks base method.
func (*MockPeerManager) CountConnectedPeers ¶ added in v1.14.0
func (m *MockPeerManager) CountConnectedPeers() uint64
CountConnectedPeers 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) FindProviders ¶ added in v1.4.0
func (m *MockPeerManager) FindProviders(id string) (string, error)
FindProviders mocks base method.
func (*MockPeerManager) Peers ¶
func (m *MockPeerManager) Peers() map[string]*peer.AddrInfo
Peers mocks base method.
func (*MockPeerManager) Provider ¶ added in v1.4.0
func (m *MockPeerManager) Provider(arg0 string, arg1 bool) error
Provider mocks base method.
func (*MockPeerManager) RegisterConnectHandler ¶
func (m *MockPeerManager) RegisterConnectHandler(arg0 func(string)) error
RegisterConnectHandler mocks base method.
func (*MockPeerManager) RegisterMsgHandler ¶
func (m *MockPeerManager) RegisterMsgHandler(arg0 pb.Message_Type, arg1 func(network.Stream, *pb.Message)) error
RegisterMsgHandler mocks base method.
func (*MockPeerManager) RegisterMultiMsgHandler ¶
func (m *MockPeerManager) RegisterMultiMsgHandler(arg0 []pb.Message_Type, arg1 func(network.Stream, *pb.Message)) error
RegisterMultiMsgHandler mocks base method.
type MockPeerManagerMockRecorder ¶
type MockPeerManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockPeerManagerMockRecorder is the mock recorder for MockPeerManager.
func (*MockPeerManagerMockRecorder) AsyncSend ¶
func (mr *MockPeerManagerMockRecorder) AsyncSend(arg0, arg1 interface{}) *gomock.Call
AsyncSend indicates an expected call of AsyncSend.
func (*MockPeerManagerMockRecorder) AsyncSendWithStream ¶ added in v1.4.0
func (mr *MockPeerManagerMockRecorder) AsyncSendWithStream(arg0, arg1 interface{}) *gomock.Call
AsyncSendWithStream indicates an expected call of AsyncSendWithStream.
func (*MockPeerManagerMockRecorder) Connect ¶ added in v1.4.0
func (mr *MockPeerManagerMockRecorder) Connect(info interface{}) *gomock.Call
Connect indicates an expected call of Connect.
func (*MockPeerManagerMockRecorder) ConnectedPeerIDs ¶ added in v1.18.0
func (mr *MockPeerManagerMockRecorder) ConnectedPeerIDs() *gomock.Call
ConnectedPeerIDs indicates an expected call of ConnectedPeerIDs.
func (*MockPeerManagerMockRecorder) CountConnectedPeers ¶ added in v1.14.0
func (mr *MockPeerManagerMockRecorder) CountConnectedPeers() *gomock.Call
CountConnectedPeers indicates an expected call of CountConnectedPeers.
func (*MockPeerManagerMockRecorder) FindProviders ¶ added in v1.4.0
func (mr *MockPeerManagerMockRecorder) FindProviders(id interface{}) *gomock.Call
FindProviders indicates an expected call of FindProviders.
func (*MockPeerManagerMockRecorder) Peers ¶
func (mr *MockPeerManagerMockRecorder) Peers() *gomock.Call
Peers indicates an expected call of Peers.
func (*MockPeerManagerMockRecorder) Provider ¶ added in v1.4.0
func (mr *MockPeerManagerMockRecorder) Provider(arg0, arg1 interface{}) *gomock.Call
Provider indicates an expected call of Provider.
func (*MockPeerManagerMockRecorder) RegisterConnectHandler ¶
func (mr *MockPeerManagerMockRecorder) RegisterConnectHandler(arg0 interface{}) *gomock.Call
RegisterConnectHandler indicates an expected call of RegisterConnectHandler.
func (*MockPeerManagerMockRecorder) RegisterMsgHandler ¶
func (mr *MockPeerManagerMockRecorder) RegisterMsgHandler(arg0, arg1 interface{}) *gomock.Call
RegisterMsgHandler indicates an expected call of RegisterMsgHandler.
func (*MockPeerManagerMockRecorder) RegisterMultiMsgHandler ¶
func (mr *MockPeerManagerMockRecorder) RegisterMultiMsgHandler(arg0, arg1 interface{}) *gomock.Call
RegisterMultiMsgHandler indicates an expected call of RegisterMultiMsgHandler.
func (*MockPeerManagerMockRecorder) Send ¶
func (mr *MockPeerManagerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call
Send indicates an expected call of Send.
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.