mocks

Documentation

Overview

Package mocks is a generated GoMock package.

Index

• type MockNATSClient
  • func NewMockNATSClient(ctrl *gomock.Controller) *MockNATSClient
  • func (m *MockNATSClient) Close()
  • func (m *MockNATSClient) EXPECT() *MockNATSClientMockRecorder
  • func (m *MockNATSClient) Flush() error
  • func (m *MockNATSClient) IsConnected() bool
  • func (m *MockNATSClient) IsReconnecting() bool
  • func (m *MockNATSClient) Publish(arg0 string, arg1 []byte) error
  • func (m *MockNATSClient) QueueSubscribe(arg0, arg1 string, arg2 go_nats.MsgHandler) (*go_nats.Subscription, error)
  • func (m *MockNATSClient) RequestWithContext(arg0 context.Context, arg1 string, arg2 []byte) (*go_nats.Msg, error)
  • func (m *MockNATSClient) Subscribe(arg0 string, arg1 go_nats.MsgHandler) (*go_nats.Subscription, error)
• type MockNATSClientMockRecorder
  • func (mr *MockNATSClientMockRecorder) Close() *gomock.Call
  • func (mr *MockNATSClientMockRecorder) Flush() *gomock.Call
  • func (mr *MockNATSClientMockRecorder) IsConnected() *gomock.Call
  • func (mr *MockNATSClientMockRecorder) IsReconnecting() *gomock.Call
  • func (mr *MockNATSClientMockRecorder) Publish(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockNATSClientMockRecorder) QueueSubscribe(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (mr *MockNATSClientMockRecorder) RequestWithContext(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (mr *MockNATSClientMockRecorder) Subscribe(arg0, arg1 interface{}) *gomock.Call

Types

type MockNATSClient

type MockNATSClient struct {
	// contains filtered or unexported fields
}

MockNATSClient is a mock of NATSClient interface

func NewMockNATSClient

func NewMockNATSClient(ctrl *gomock.Controller) *MockNATSClient

NewMockNATSClient creates a new mock instance

func (*MockNATSClient) Close

func (m *MockNATSClient) Close()

Close mocks base method

func (*MockNATSClient) EXPECT

func (m *MockNATSClient) EXPECT() *MockNATSClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockNATSClient) Flush

func (m *MockNATSClient) Flush() error

Flush mocks base method

func (*MockNATSClient) IsConnected

func (m *MockNATSClient) IsConnected() bool

IsConnected mocks base method

func (*MockNATSClient) IsReconnecting

func (m *MockNATSClient) IsReconnecting() bool

IsReconnecting mocks base method

func (*MockNATSClient) Publish

func (m *MockNATSClient) Publish(arg0 string, arg1 []byte) error

Publish mocks base method

func (*MockNATSClient) QueueSubscribe

func (m *MockNATSClient) QueueSubscribe(arg0, arg1 string, arg2 go_nats.MsgHandler) (*go_nats.Subscription, error)

QueueSubscribe mocks base method

func (*MockNATSClient) RequestWithContext

func (m *MockNATSClient) RequestWithContext(arg0 context.Context, arg1 string, arg2 []byte) (*go_nats.Msg, error)

RequestWithContext mocks base method

func (*MockNATSClient) Subscribe

func (m *MockNATSClient) Subscribe(arg0 string, arg1 go_nats.MsgHandler) (*go_nats.Subscription, error)

Subscribe mocks base method

type MockNATSClientMockRecorder

type MockNATSClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockNATSClientMockRecorder is the mock recorder for MockNATSClient

func (*MockNATSClientMockRecorder) Close

func (mr *MockNATSClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockNATSClientMockRecorder) Flush

func (mr *MockNATSClientMockRecorder) Flush() *gomock.Call

Flush indicates an expected call of Flush

func (*MockNATSClientMockRecorder) IsConnected

func (mr *MockNATSClientMockRecorder) IsConnected() *gomock.Call

IsConnected indicates an expected call of IsConnected

func (*MockNATSClientMockRecorder) IsReconnecting

func (mr *MockNATSClientMockRecorder) IsReconnecting() *gomock.Call

IsReconnecting indicates an expected call of IsReconnecting

func (*MockNATSClientMockRecorder) Publish

func (mr *MockNATSClientMockRecorder) Publish(arg0, arg1 interface{}) *gomock.Call

Publish indicates an expected call of Publish

func (*MockNATSClientMockRecorder) QueueSubscribe

func (mr *MockNATSClientMockRecorder) QueueSubscribe(arg0, arg1, arg2 interface{}) *gomock.Call

QueueSubscribe indicates an expected call of QueueSubscribe

func (*MockNATSClientMockRecorder) RequestWithContext

func (mr *MockNATSClientMockRecorder) RequestWithContext(arg0, arg1, arg2 interface{}) *gomock.Call

RequestWithContext indicates an expected call of RequestWithContext

func (*MockNATSClientMockRecorder) Subscribe

func (mr *MockNATSClientMockRecorder) Subscribe(arg0, arg1 interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe