Documentation
¶
Overview ¶
Package mock_natsio is a generated GoMock package.
Index ¶
- type MockInterface
- func (m *MockInterface) Close()
- func (m *MockInterface) EXPECT() *MockInterfaceMockRecorder
- func (m *MockInterface) InitConn(stopCh <-chan struct{}) error
- func (m *MockInterface) Publish(msg *natsio.Msg) error
- func (m *MockInterface) QueueSubscribe(subj, queue string, handler nats.MsgHandler) error
- func (m *MockInterface) Request(msg *natsio.Msg, timeoutHandler natsio.TimeoutHandler) ([]byte, error)
- func (m *MockInterface) RequestAsync(msg *natsio.Msg, handler natsio.ReplyHandler, ...) error
- func (m *MockInterface) RequestWithContext(ctx context.Context, msg *natsio.Msg) ([]byte, error)
- func (m *MockInterface) RunServer(stopCh <-chan struct{}) error
- func (m *MockInterface) SetClosedHandler(handler nats.ConnHandler)
- func (m *MockInterface) SetDisconnectErrHandler(handler nats.ConnErrHandler)
- func (m *MockInterface) SetErrorHandler(handler nats.ErrHandler)
- func (m *MockInterface) SetReconnectHandler(handler nats.ConnHandler)
- func (m *MockInterface) Subscribe(subj string, handler nats.MsgHandler) error
- type MockInterfaceMockRecorder
- func (mr *MockInterfaceMockRecorder) Close() *gomock.Call
- func (mr *MockInterfaceMockRecorder) InitConn(stopCh interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) Publish(msg interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) QueueSubscribe(subj, queue, handler interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) Request(msg, timeoutHandler interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) RequestAsync(msg, handler, timeoutHandler interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) RequestWithContext(ctx, msg interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) RunServer(stopCh interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) SetClosedHandler(handler interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) SetDisconnectErrHandler(handler interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) SetErrorHandler(handler interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) SetReconnectHandler(handler interface{}) *gomock.Call
- func (mr *MockInterfaceMockRecorder) Subscribe(subj, handler interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockInterface ¶
type MockInterface struct {
// contains filtered or unexported fields
}
MockInterface is a mock of Interface interface.
func NewMockInterface ¶
func NewMockInterface(ctrl *gomock.Controller) *MockInterface
NewMockInterface creates a new mock instance.
func (*MockInterface) Close ¶ added in v1.3.1
func (m *MockInterface) Close()
Close mocks base method.
func (*MockInterface) EXPECT ¶
func (m *MockInterface) EXPECT() *MockInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockInterface) InitConn ¶
func (m *MockInterface) InitConn(stopCh <-chan struct{}) error
InitConn mocks base method.
func (*MockInterface) Publish ¶
func (m *MockInterface) Publish(msg *natsio.Msg) error
Publish mocks base method.
func (*MockInterface) QueueSubscribe ¶
func (m *MockInterface) QueueSubscribe(subj, queue string, handler nats.MsgHandler) error
QueueSubscribe mocks base method.
func (*MockInterface) Request ¶
func (m *MockInterface) Request(msg *natsio.Msg, timeoutHandler natsio.TimeoutHandler) ([]byte, error)
Request mocks base method.
func (*MockInterface) RequestAsync ¶
func (m *MockInterface) RequestAsync(msg *natsio.Msg, handler natsio.ReplyHandler, timeoutHandler natsio.TimeoutHandler) error
RequestAsync mocks base method.
func (*MockInterface) RequestWithContext ¶ added in v1.3.1
RequestWithContext mocks base method.
func (*MockInterface) RunServer ¶
func (m *MockInterface) RunServer(stopCh <-chan struct{}) error
RunServer mocks base method.
func (*MockInterface) SetClosedHandler ¶
func (m *MockInterface) SetClosedHandler(handler nats.ConnHandler)
SetClosedHandler mocks base method.
func (*MockInterface) SetDisconnectErrHandler ¶
func (m *MockInterface) SetDisconnectErrHandler(handler nats.ConnErrHandler)
SetDisconnectErrHandler mocks base method.
func (*MockInterface) SetErrorHandler ¶
func (m *MockInterface) SetErrorHandler(handler nats.ErrHandler)
SetErrorHandler mocks base method.
func (*MockInterface) SetReconnectHandler ¶
func (m *MockInterface) SetReconnectHandler(handler nats.ConnHandler)
SetReconnectHandler mocks base method.
func (*MockInterface) Subscribe ¶
func (m *MockInterface) Subscribe(subj string, handler nats.MsgHandler) error
Subscribe mocks base method.
type MockInterfaceMockRecorder ¶
type MockInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockInterfaceMockRecorder is the mock recorder for MockInterface.
func (*MockInterfaceMockRecorder) Close ¶ added in v1.3.1
func (mr *MockInterfaceMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockInterfaceMockRecorder) InitConn ¶
func (mr *MockInterfaceMockRecorder) InitConn(stopCh interface{}) *gomock.Call
InitConn indicates an expected call of InitConn.
func (*MockInterfaceMockRecorder) Publish ¶
func (mr *MockInterfaceMockRecorder) Publish(msg interface{}) *gomock.Call
Publish indicates an expected call of Publish.
func (*MockInterfaceMockRecorder) QueueSubscribe ¶
func (mr *MockInterfaceMockRecorder) QueueSubscribe(subj, queue, handler interface{}) *gomock.Call
QueueSubscribe indicates an expected call of QueueSubscribe.
func (*MockInterfaceMockRecorder) Request ¶
func (mr *MockInterfaceMockRecorder) Request(msg, timeoutHandler interface{}) *gomock.Call
Request indicates an expected call of Request.
func (*MockInterfaceMockRecorder) RequestAsync ¶
func (mr *MockInterfaceMockRecorder) RequestAsync(msg, handler, timeoutHandler interface{}) *gomock.Call
RequestAsync indicates an expected call of RequestAsync.
func (*MockInterfaceMockRecorder) RequestWithContext ¶ added in v1.3.1
func (mr *MockInterfaceMockRecorder) RequestWithContext(ctx, msg interface{}) *gomock.Call
RequestWithContext indicates an expected call of RequestWithContext.
func (*MockInterfaceMockRecorder) RunServer ¶
func (mr *MockInterfaceMockRecorder) RunServer(stopCh interface{}) *gomock.Call
RunServer indicates an expected call of RunServer.
func (*MockInterfaceMockRecorder) SetClosedHandler ¶
func (mr *MockInterfaceMockRecorder) SetClosedHandler(handler interface{}) *gomock.Call
SetClosedHandler indicates an expected call of SetClosedHandler.
func (*MockInterfaceMockRecorder) SetDisconnectErrHandler ¶
func (mr *MockInterfaceMockRecorder) SetDisconnectErrHandler(handler interface{}) *gomock.Call
SetDisconnectErrHandler indicates an expected call of SetDisconnectErrHandler.
func (*MockInterfaceMockRecorder) SetErrorHandler ¶
func (mr *MockInterfaceMockRecorder) SetErrorHandler(handler interface{}) *gomock.Call
SetErrorHandler indicates an expected call of SetErrorHandler.
func (*MockInterfaceMockRecorder) SetReconnectHandler ¶
func (mr *MockInterfaceMockRecorder) SetReconnectHandler(handler interface{}) *gomock.Call
SetReconnectHandler indicates an expected call of SetReconnectHandler.
func (*MockInterfaceMockRecorder) Subscribe ¶
func (mr *MockInterfaceMockRecorder) Subscribe(subj, handler interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe.
Source Files