Documentation ¶
Index ¶
- type MockHandlerClient
- func (_m *MockHandlerClient) Close()
- func (_m *MockHandlerClient) CreateConsumer(ctx context.Context, opts *handler.ConsumerOptions) (consumer.Consumer, error)
- func (_m *MockHandlerClient) CreateProducer(ctx context.Context, opts *handler.ProducerOptions) (producer.Producer, error)
- func (_m *MockHandlerClient) EXPECT() *MockHandlerClient_Expecter
- type MockHandlerClient_Close_Call
- type MockHandlerClient_CreateConsumer_Call
- func (_c *MockHandlerClient_CreateConsumer_Call) Return(_a0 consumer.Consumer, _a1 error) *MockHandlerClient_CreateConsumer_Call
- func (_c *MockHandlerClient_CreateConsumer_Call) Run(run func(ctx context.Context, opts *handler.ConsumerOptions)) *MockHandlerClient_CreateConsumer_Call
- func (_c *MockHandlerClient_CreateConsumer_Call) RunAndReturn(run func(context.Context, *handler.ConsumerOptions) (consumer.Consumer, error)) *MockHandlerClient_CreateConsumer_Call
- type MockHandlerClient_CreateProducer_Call
- func (_c *MockHandlerClient_CreateProducer_Call) Return(_a0 producer.Producer, _a1 error) *MockHandlerClient_CreateProducer_Call
- func (_c *MockHandlerClient_CreateProducer_Call) Run(run func(ctx context.Context, opts *handler.ProducerOptions)) *MockHandlerClient_CreateProducer_Call
- func (_c *MockHandlerClient_CreateProducer_Call) RunAndReturn(run func(context.Context, *handler.ProducerOptions) (producer.Producer, error)) *MockHandlerClient_CreateProducer_Call
- type MockHandlerClient_Expecter
- func (_e *MockHandlerClient_Expecter) Close() *MockHandlerClient_Close_Call
- func (_e *MockHandlerClient_Expecter) CreateConsumer(ctx interface{}, opts interface{}) *MockHandlerClient_CreateConsumer_Call
- func (_e *MockHandlerClient_Expecter) CreateProducer(ctx interface{}, opts interface{}) *MockHandlerClient_CreateProducer_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockHandlerClient ¶
MockHandlerClient is an autogenerated mock type for the HandlerClient type
func NewMockHandlerClient ¶
func NewMockHandlerClient(t interface { mock.TestingT Cleanup(func()) }) *MockHandlerClient
NewMockHandlerClient creates a new instance of MockHandlerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockHandlerClient) Close ¶
func (_m *MockHandlerClient) Close()
Close provides a mock function with given fields:
func (*MockHandlerClient) CreateConsumer ¶
func (_m *MockHandlerClient) CreateConsumer(ctx context.Context, opts *handler.ConsumerOptions) (consumer.Consumer, error)
CreateConsumer provides a mock function with given fields: ctx, opts
func (*MockHandlerClient) CreateProducer ¶
func (_m *MockHandlerClient) CreateProducer(ctx context.Context, opts *handler.ProducerOptions) (producer.Producer, error)
CreateProducer provides a mock function with given fields: ctx, opts
func (*MockHandlerClient) EXPECT ¶
func (_m *MockHandlerClient) EXPECT() *MockHandlerClient_Expecter
type MockHandlerClient_Close_Call ¶
MockHandlerClient_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MockHandlerClient_Close_Call) Return ¶
func (_c *MockHandlerClient_Close_Call) Return() *MockHandlerClient_Close_Call
func (*MockHandlerClient_Close_Call) Run ¶
func (_c *MockHandlerClient_Close_Call) Run(run func()) *MockHandlerClient_Close_Call
func (*MockHandlerClient_Close_Call) RunAndReturn ¶
func (_c *MockHandlerClient_Close_Call) RunAndReturn(run func()) *MockHandlerClient_Close_Call
type MockHandlerClient_CreateConsumer_Call ¶
MockHandlerClient_CreateConsumer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateConsumer'
func (*MockHandlerClient_CreateConsumer_Call) Return ¶
func (_c *MockHandlerClient_CreateConsumer_Call) Return(_a0 consumer.Consumer, _a1 error) *MockHandlerClient_CreateConsumer_Call
func (*MockHandlerClient_CreateConsumer_Call) Run ¶
func (_c *MockHandlerClient_CreateConsumer_Call) Run(run func(ctx context.Context, opts *handler.ConsumerOptions)) *MockHandlerClient_CreateConsumer_Call
func (*MockHandlerClient_CreateConsumer_Call) RunAndReturn ¶
func (_c *MockHandlerClient_CreateConsumer_Call) RunAndReturn(run func(context.Context, *handler.ConsumerOptions) (consumer.Consumer, error)) *MockHandlerClient_CreateConsumer_Call
type MockHandlerClient_CreateProducer_Call ¶
MockHandlerClient_CreateProducer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateProducer'
func (*MockHandlerClient_CreateProducer_Call) Return ¶
func (_c *MockHandlerClient_CreateProducer_Call) Return(_a0 producer.Producer, _a1 error) *MockHandlerClient_CreateProducer_Call
func (*MockHandlerClient_CreateProducer_Call) Run ¶
func (_c *MockHandlerClient_CreateProducer_Call) Run(run func(ctx context.Context, opts *handler.ProducerOptions)) *MockHandlerClient_CreateProducer_Call
func (*MockHandlerClient_CreateProducer_Call) RunAndReturn ¶
func (_c *MockHandlerClient_CreateProducer_Call) RunAndReturn(run func(context.Context, *handler.ProducerOptions) (producer.Producer, error)) *MockHandlerClient_CreateProducer_Call
type MockHandlerClient_Expecter ¶
type MockHandlerClient_Expecter struct {
// contains filtered or unexported fields
}
func (*MockHandlerClient_Expecter) Close ¶
func (_e *MockHandlerClient_Expecter) Close() *MockHandlerClient_Close_Call
Close is a helper method to define mock.On call
func (*MockHandlerClient_Expecter) CreateConsumer ¶
func (_e *MockHandlerClient_Expecter) CreateConsumer(ctx interface{}, opts interface{}) *MockHandlerClient_CreateConsumer_Call
CreateConsumer is a helper method to define mock.On call
- ctx context.Context
- opts *handler.ConsumerOptions
func (*MockHandlerClient_Expecter) CreateProducer ¶
func (_e *MockHandlerClient_Expecter) CreateProducer(ctx interface{}, opts interface{}) *MockHandlerClient_CreateProducer_Call
CreateProducer is a helper method to define mock.On call
- ctx context.Context
- opts *handler.ProducerOptions