// Code generated by MockGen. DO NOT EDIT. // Source: peermgr.go // Package mock_peermgr is a generated GoMock package. package mock_peermgr import ( reflect "reflect" gomock "github.com/golang/mock/gomock" peer "github.com/libp2p/go-libp2p-core/peer" peermgr "github.com/link33/sidecar/internal/peermgr" port "github.com/link33/sidecar/internal/port" pb "github.com/link33/sidecar/model/pb" ) // MockPeerManager is a mock of PeerManager interface. type MockPeerManager struct { ctrl *gomock.Controller recorder *MockPeerManagerMockRecorder } // MockPeerManagerMockRecorder is the mock recorder for MockPeerManager. type MockPeerManagerMockRecorder struct { mock *MockPeerManager } // NewMockPeerManager creates a new mock instance. func NewMockPeerManager(ctrl *gomock.Controller) *MockPeerManager { mock := &MockPeerManager{ctrl: ctrl} mock.recorder = &MockPeerManagerMockRecorder{mock} return mock } // EXPECT returns an object that allows the caller to indicate expected use. func (m *MockPeerManager) EXPECT() *MockPeerManagerMockRecorder { return m.recorder } // AsyncSendByID mocks base method. func (m *MockPeerManager) AsyncSendByID(arg0 string, arg1 *pb.Message) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "AsyncSendByID", arg0, arg1) ret0, _ := ret[0].(error) return ret0 } // AsyncSendByID indicates an expected call of AsyncSendByID. func (mr *MockPeerManagerMockRecorder) AsyncSendByID(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AsyncSendByID", reflect.TypeOf((*MockPeerManager)(nil).AsyncSendByID), arg0, arg1) } // AsyncSendWithPort mocks base method. func (m *MockPeerManager) AsyncSendWithPort(arg0 port.Port, arg1 *pb.Message) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "AsyncSendWithPort", arg0, arg1) ret0, _ := ret[0].(error) return ret0 } // AsyncSendWithPort indicates an expected call of AsyncSendWithPort. func (mr *MockPeerManagerMockRecorder) AsyncSendWithPort(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AsyncSendWithPort", reflect.TypeOf((*MockPeerManager)(nil).AsyncSendWithPort), arg0, arg1) } // Connect mocks base method. func (m *MockPeerManager) Connect(info *peer.AddrInfo) (string, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Connect", info) ret0, _ := ret[0].(string) ret1, _ := ret[1].(error) return ret0, ret1 } // Connect indicates an expected call of Connect. func (mr *MockPeerManagerMockRecorder) Connect(info interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Connect", reflect.TypeOf((*MockPeerManager)(nil).Connect), info) } // FindProviders mocks base method. func (m *MockPeerManager) FindProviders(id string) (string, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "FindProviders", id) ret0, _ := ret[0].(string) ret1, _ := ret[1].(error) return ret0, ret1 } // FindProviders indicates an expected call of FindProviders. func (mr *MockPeerManagerMockRecorder) FindProviders(id interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "FindProviders", reflect.TypeOf((*MockPeerManager)(nil).FindProviders), id) } // GetRemotePeerInfo mocks base method. func (m *MockPeerManager) GetRemotePeerInfo(id string) (*pb.PeerInfo, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "GetRemotePeerInfo", id) ret0, _ := ret[0].(*pb.PeerInfo) ret1, _ := ret[1].(error) return ret0, ret1 } // GetRemotePeerInfo indicates an expected call of GetRemotePeerInfo. func (mr *MockPeerManagerMockRecorder) GetRemotePeerInfo(id interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetRemotePeerInfo", reflect.TypeOf((*MockPeerManager)(nil).GetRemotePeerInfo), id) } // Provider mocks base method. func (m *MockPeerManager) Provider(arg0 string, arg1 bool) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Provider", arg0, arg1) ret0, _ := ret[0].(error) return ret0 } // Provider indicates an expected call of Provider. func (mr *MockPeerManagerMockRecorder) Provider(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Provider", reflect.TypeOf((*MockPeerManager)(nil).Provider), arg0, arg1) } // RegisterConnectHandler mocks base method. func (m *MockPeerManager) RegisterConnectHandler(arg0 peermgr.ConnectHandler) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "RegisterConnectHandler", arg0) ret0, _ := ret[0].(error) return ret0 } // RegisterConnectHandler indicates an expected call of RegisterConnectHandler. func (mr *MockPeerManagerMockRecorder) RegisterConnectHandler(arg0 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RegisterConnectHandler", reflect.TypeOf((*MockPeerManager)(nil).RegisterConnectHandler), arg0) } // RegisterMsgHandler mocks base method. func (m *MockPeerManager) RegisterMsgHandler(arg0 pb.Message_Type, arg1 peermgr.MessageHandler) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "RegisterMsgHandler", arg0, arg1) ret0, _ := ret[0].(error) return ret0 } // RegisterMsgHandler indicates an expected call of RegisterMsgHandler. func (mr *MockPeerManagerMockRecorder) RegisterMsgHandler(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RegisterMsgHandler", reflect.TypeOf((*MockPeerManager)(nil).RegisterMsgHandler), arg0, arg1) } // RegisterMultiMsgHandler mocks base method. func (m *MockPeerManager) RegisterMultiMsgHandler(arg0 []pb.Message_Type, arg1 peermgr.MessageHandler) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "RegisterMultiMsgHandler", arg0, arg1) ret0, _ := ret[0].(error) return ret0 } // RegisterMultiMsgHandler indicates an expected call of RegisterMultiMsgHandler. func (mr *MockPeerManagerMockRecorder) RegisterMultiMsgHandler(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RegisterMultiMsgHandler", reflect.TypeOf((*MockPeerManager)(nil).RegisterMultiMsgHandler), arg0, arg1) } // SendByID mocks base method. func (m *MockPeerManager) SendByID(arg0 string, arg1 *pb.Message) (*pb.Message, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "SendByID", arg0, arg1) ret0, _ := ret[0].(*pb.Message) ret1, _ := ret[1].(error) return ret0, ret1 } // SendByID indicates an expected call of SendByID. func (mr *MockPeerManagerMockRecorder) SendByID(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendByID", reflect.TypeOf((*MockPeerManager)(nil).SendByID), arg0, arg1) } // SendWithPort mocks base method. func (m *MockPeerManager) SendWithPort(s port.Port, msg *pb.Message) (*pb.Message, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "SendWithPort", s, msg) ret0, _ := ret[0].(*pb.Message) ret1, _ := ret[1].(error) return ret0, ret1 } // SendWithPort indicates an expected call of SendWithPort. func (mr *MockPeerManagerMockRecorder) SendWithPort(s, msg interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SendWithPort", reflect.TypeOf((*MockPeerManager)(nil).SendWithPort), s, msg) } // Start mocks base method. func (m *MockPeerManager) Start() error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Start") ret0, _ := ret[0].(error) return ret0 } // Start indicates an expected call of Start. func (mr *MockPeerManagerMockRecorder) Start() *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Start", reflect.TypeOf((*MockPeerManager)(nil).Start)) } // Stop mocks base method. func (m *MockPeerManager) Stop() error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Stop") ret0, _ := ret[0].(error) return ret0 } // Stop indicates an expected call of Stop. func (mr *MockPeerManagerMockRecorder) Stop() *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Stop", reflect.TypeOf((*MockPeerManager)(nil).Stop)) } // MockHandler is a mock of Handler interface. type MockHandler struct { ctrl *gomock.Controller recorder *MockHandlerMockRecorder } // MockHandlerMockRecorder is the mock recorder for MockHandler. type MockHandlerMockRecorder struct { mock *MockHandler } // NewMockHandler creates a new mock instance. func NewMockHandler(ctrl *gomock.Controller) *MockHandler { mock := &MockHandler{ctrl: ctrl} mock.recorder = &MockHandlerMockRecorder{mock} return mock } // EXPECT returns an object that allows the caller to indicate expected use. func (m *MockHandler) EXPECT() *MockHandlerMockRecorder { return m.recorder } // RegisterConnectHandler mocks base method. func (m *MockHandler) RegisterConnectHandler(arg0 peermgr.ConnectHandler) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "RegisterConnectHandler", arg0) ret0, _ := ret[0].(error) return ret0 } // RegisterConnectHandler indicates an expected call of RegisterConnectHandler. func (mr *MockHandlerMockRecorder) RegisterConnectHandler(arg0 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RegisterConnectHandler", reflect.TypeOf((*MockHandler)(nil).RegisterConnectHandler), arg0) } // RegisterMsgHandler mocks base method. func (m *MockHandler) RegisterMsgHandler(arg0 pb.Message_Type, arg1 peermgr.MessageHandler) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "RegisterMsgHandler", arg0, arg1) ret0, _ := ret[0].(error) return ret0 } // RegisterMsgHandler indicates an expected call of RegisterMsgHandler. func (mr *MockHandlerMockRecorder) RegisterMsgHandler(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RegisterMsgHandler", reflect.TypeOf((*MockHandler)(nil).RegisterMsgHandler), arg0, arg1) } // RegisterMultiMsgHandler mocks base method. func (m *MockHandler) RegisterMultiMsgHandler(arg0 []pb.Message_Type, arg1 peermgr.MessageHandler) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "RegisterMultiMsgHandler", arg0, arg1) ret0, _ := ret[0].(error) return ret0 } // RegisterMultiMsgHandler indicates an expected call of RegisterMultiMsgHandler. func (mr *MockHandlerMockRecorder) RegisterMultiMsgHandler(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RegisterMultiMsgHandler", reflect.TypeOf((*MockHandler)(nil).RegisterMultiMsgHandler), arg0, arg1) } // MockDHTManager is a mock of DHTManager interface. type MockDHTManager struct { ctrl *gomock.Controller recorder *MockDHTManagerMockRecorder } // MockDHTManagerMockRecorder is the mock recorder for MockDHTManager. type MockDHTManagerMockRecorder struct { mock *MockDHTManager } // NewMockDHTManager creates a new mock instance. func NewMockDHTManager(ctrl *gomock.Controller) *MockDHTManager { mock := &MockDHTManager{ctrl: ctrl} mock.recorder = &MockDHTManagerMockRecorder{mock} return mock } // EXPECT returns an object that allows the caller to indicate expected use. func (m *MockDHTManager) EXPECT() *MockDHTManagerMockRecorder { return m.recorder } // FindProviders mocks base method. func (m *MockDHTManager) FindProviders(id string) (string, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "FindProviders", id) ret0, _ := ret[0].(string) ret1, _ := ret[1].(error) return ret0, ret1 } // FindProviders indicates an expected call of FindProviders. func (mr *MockDHTManagerMockRecorder) FindProviders(id interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "FindProviders", reflect.TypeOf((*MockDHTManager)(nil).FindProviders), id) } // Provider mocks base method. func (m *MockDHTManager) Provider(arg0 string, arg1 bool) error { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "Provider", arg0, arg1) ret0, _ := ret[0].(error) return ret0 } // Provider indicates an expected call of Provider. func (mr *MockDHTManagerMockRecorder) Provider(arg0, arg1 interface{}) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Provider", reflect.TypeOf((*MockDHTManager)(nil).Provider), arg0, arg1) }