mock_natsio

Documentation

Overview

Package mock_natsio is a generated GoMock package.

Index

• type MockInterface
  • func NewMockInterface(ctrl *gomock.Controller) *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

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

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

func (m *MockInterface) RequestWithContext(ctx context.Context, msg *natsio.Msg) ([]byte, error)

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

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

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.