mocks

package
v0.0.0-...-dc7611c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 6, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Bus 

type Bus struct {
	mock.Mock
}

Bus is an autogenerated mock type for the Bus type

func NewBus 

func NewBus(t interface {
	mock.TestingT
	Cleanup(func())
}) *Bus

NewBus creates a new instance of Bus. 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 (*Bus) ConnectConsumer 

func (_m *Bus) ConnectConsumer(messageType types.IMessage, _a1 consumer.Consumer) error

ConnectConsumer provides a mock function with given fields: messageType, _a1

func (*Bus) ConnectConsumerHandler 

func (_m *Bus) ConnectConsumerHandler(messageType types.IMessage, consumerHandler consumer.ConsumerHandler) error

ConnectConsumerHandler provides a mock function with given fields: messageType, consumerHandler

func (*Bus) EXPECT 

func (_m *Bus) EXPECT() *Bus_Expecter

func (*Bus) IsConsumed 

func (_m *Bus) IsConsumed(_a0 func(types.IMessage))

AddMessageConsumedHandler provides a mock function with given fields: _a0

func (*Bus) IsProduced 

func (_m *Bus) IsProduced(_a0 func(types.IMessage))

AddMessageProducedHandler provides a mock function with given fields: _a0

func (*Bus) PublishMessage 

func (_m *Bus) PublishMessage(ctx context.Context, message types.IMessage, meta metadata.Metadata) error

PublishMessage provides a mock function with given fields: ctx, message, meta

func (*Bus) PublishMessageWithTopicName 

func (_m *Bus) PublishMessageWithTopicName(ctx context.Context, message types.IMessage, meta metadata.Metadata, topicOrExchangeName string) error

PublishMessageWithTopicName provides a mock function with given fields: ctx, message, meta, topicOrExchangeName

func (*Bus) Start 

func (_m *Bus) Start(ctx context.Context) error

Start provides a mock function with given fields: ctx

func (*Bus) Stop 

func (_m *Bus) Stop() error

Stop provides a mock function with given fields:

type BusControl 

type BusControl struct {
	mock.Mock
}

BusControl is an autogenerated mock type for the BusControl type

func NewBusControl 

func NewBusControl(t interface {
	mock.TestingT
	Cleanup(func())
}) *BusControl

NewBusControl creates a new instance of BusControl. 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 (*BusControl) EXPECT 

func (_m *BusControl) EXPECT() *BusControl_Expecter

func (*BusControl) IsConsumed 

func (_m *BusControl) IsConsumed(_a0 func(types.IMessage))

AddMessageConsumedHandler provides a mock function with given fields: _a0

func (*BusControl) Start 

func (_m *BusControl) Start(ctx context.Context) error

Start provides a mock function with given fields: ctx

func (*BusControl) Stop 

func (_m *BusControl) Stop() error

Stop provides a mock function with given fields:

type BusControl_AddMessageConsumedHandler_Call 

type BusControl_AddMessageConsumedHandler_Call struct {
	*mock.Call
}

BusControl_AddMessageConsumedHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsConsumed'

func (*BusControl_AddMessageConsumedHandler_Call) Return 

func (_c *BusControl_AddMessageConsumedHandler_Call) Return() *BusControl_AddMessageConsumedHandler_Call

func (*BusControl_AddMessageConsumedHandler_Call) Run 

func (_c *BusControl_AddMessageConsumedHandler_Call) Run(run func(_a0 func(types.IMessage))) *BusControl_AddMessageConsumedHandler_Call

func (*BusControl_AddMessageConsumedHandler_Call) RunAndReturn 

func (_c *BusControl_AddMessageConsumedHandler_Call) RunAndReturn(run func(func(types.IMessage))) *BusControl_AddMessageConsumedHandler_Call

type BusControl_Expecter 

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

func (*BusControl_Expecter) AddMessageConsumedHandler 

func (_e *BusControl_Expecter) AddMessageConsumedHandler(_a0 interface{}) *BusControl_AddMessageConsumedHandler_Call

AddMessageConsumedHandler is a helper method to define mock.On call

  • _a0 func(types.IMessage)

func (*BusControl_Expecter) Start 

func (_e *BusControl_Expecter) Start(ctx interface{}) *BusControl_Start_Call

Start is a helper method to define mock.On call

  • ctx context.Context

func (*BusControl_Expecter) Stop 

func (_e *BusControl_Expecter) Stop() *BusControl_Stop_Call

Stop is a helper method to define mock.On call

type BusControl_Start_Call 

type BusControl_Start_Call struct {
	*mock.Call
}

BusControl_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*BusControl_Start_Call) Return 

func (_c *BusControl_Start_Call) Return(_a0 error) *BusControl_Start_Call

func (*BusControl_Start_Call) Run 

func (_c *BusControl_Start_Call) Run(run func(ctx context.Context)) *BusControl_Start_Call

func (*BusControl_Start_Call) RunAndReturn 

func (_c *BusControl_Start_Call) RunAndReturn(run func(context.Context) error) *BusControl_Start_Call

type BusControl_Stop_Call 

type BusControl_Stop_Call struct {
	*mock.Call
}

BusControl_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*BusControl_Stop_Call) Return 

func (_c *BusControl_Stop_Call) Return(_a0 error) *BusControl_Stop_Call

func (*BusControl_Stop_Call) Run 

func (_c *BusControl_Stop_Call) Run(run func()) *BusControl_Stop_Call

func (*BusControl_Stop_Call) RunAndReturn 

func (_c *BusControl_Stop_Call) RunAndReturn(run func() error) *BusControl_Stop_Call

type Bus_AddMessageConsumedHandler_Call 

type Bus_AddMessageConsumedHandler_Call struct {
	*mock.Call
}

Bus_AddMessageConsumedHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsConsumed'

func (*Bus_AddMessageConsumedHandler_Call) Return 

func (_c *Bus_AddMessageConsumedHandler_Call) Return() *Bus_AddMessageConsumedHandler_Call

func (*Bus_AddMessageConsumedHandler_Call) Run 

func (_c *Bus_AddMessageConsumedHandler_Call) Run(run func(_a0 func(types.IMessage))) *Bus_AddMessageConsumedHandler_Call

func (*Bus_AddMessageConsumedHandler_Call) RunAndReturn 

func (_c *Bus_AddMessageConsumedHandler_Call) RunAndReturn(run func(func(types.IMessage))) *Bus_AddMessageConsumedHandler_Call

type Bus_AddMessageProducedHandler_Call 

type Bus_AddMessageProducedHandler_Call struct {
	*mock.Call
}

Bus_AddMessageProducedHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsProduced'

func (*Bus_AddMessageProducedHandler_Call) Return 

func (_c *Bus_AddMessageProducedHandler_Call) Return() *Bus_AddMessageProducedHandler_Call

func (*Bus_AddMessageProducedHandler_Call) Run 

func (_c *Bus_AddMessageProducedHandler_Call) Run(run func(_a0 func(types.IMessage))) *Bus_AddMessageProducedHandler_Call

func (*Bus_AddMessageProducedHandler_Call) RunAndReturn 

func (_c *Bus_AddMessageProducedHandler_Call) RunAndReturn(run func(func(types.IMessage))) *Bus_AddMessageProducedHandler_Call

type Bus_ConnectConsumerHandler_Call 

type Bus_ConnectConsumerHandler_Call struct {
	*mock.Call
}

Bus_ConnectConsumerHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConnectConsumerHandler'

func (*Bus_ConnectConsumerHandler_Call) Return 

func (_c *Bus_ConnectConsumerHandler_Call) Return(_a0 error) *Bus_ConnectConsumerHandler_Call

func (*Bus_ConnectConsumerHandler_Call) Run 

func (_c *Bus_ConnectConsumerHandler_Call) Run(run func(messageType types.IMessage, consumerHandler consumer.ConsumerHandler)) *Bus_ConnectConsumerHandler_Call

func (*Bus_ConnectConsumerHandler_Call) RunAndReturn 

func (_c *Bus_ConnectConsumerHandler_Call) RunAndReturn(run func(types.IMessage, consumer.ConsumerHandler) error) *Bus_ConnectConsumerHandler_Call

type Bus_ConnectConsumer_Call 

type Bus_ConnectConsumer_Call struct {
	*mock.Call
}

Bus_ConnectConsumer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConnectConsumer'

func (*Bus_ConnectConsumer_Call) Return 

func (_c *Bus_ConnectConsumer_Call) Return(_a0 error) *Bus_ConnectConsumer_Call

func (*Bus_ConnectConsumer_Call) Run 

func (_c *Bus_ConnectConsumer_Call) Run(run func(messageType types.IMessage, _a1 consumer.Consumer)) *Bus_ConnectConsumer_Call

func (*Bus_ConnectConsumer_Call) RunAndReturn 

func (_c *Bus_ConnectConsumer_Call) RunAndReturn(run func(types.IMessage, consumer.Consumer) error) *Bus_ConnectConsumer_Call

type Bus_Expecter 

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

func (*Bus_Expecter) AddMessageConsumedHandler 

func (_e *Bus_Expecter) AddMessageConsumedHandler(_a0 interface{}) *Bus_AddMessageConsumedHandler_Call

AddMessageConsumedHandler is a helper method to define mock.On call

  • _a0 func(types.IMessage)

func (*Bus_Expecter) AddMessageProducedHandler 

func (_e *Bus_Expecter) AddMessageProducedHandler(_a0 interface{}) *Bus_AddMessageProducedHandler_Call

AddMessageProducedHandler is a helper method to define mock.On call

  • _a0 func(types.IMessage)

func (*Bus_Expecter) ConnectConsumer 

func (_e *Bus_Expecter) ConnectConsumer(messageType interface{}, _a1 interface{}) *Bus_ConnectConsumer_Call

ConnectConsumer is a helper method to define mock.On call

  • messageType types.IMessage
  • _a1 consumer.Consumer

func (*Bus_Expecter) ConnectConsumerHandler 

func (_e *Bus_Expecter) ConnectConsumerHandler(messageType interface{}, consumerHandler interface{}) *Bus_ConnectConsumerHandler_Call

ConnectConsumerHandler is a helper method to define mock.On call

  • messageType types.IMessage
  • consumerHandler consumer.ConsumerHandler

func (*Bus_Expecter) PublishMessage 

func (_e *Bus_Expecter) PublishMessage(ctx interface{}, message interface{}, meta interface{}) *Bus_PublishMessage_Call

PublishMessage is a helper method to define mock.On call

  • ctx context.Context
  • message types.IMessage
  • meta metadata.Metadata

func (*Bus_Expecter) PublishMessageWithTopicName 

func (_e *Bus_Expecter) PublishMessageWithTopicName(ctx interface{}, message interface{}, meta interface{}, topicOrExchangeName interface{}) *Bus_PublishMessageWithTopicName_Call

PublishMessageWithTopicName is a helper method to define mock.On call

  • ctx context.Context
  • message types.IMessage
  • meta metadata.Metadata
  • topicOrExchangeName string

func (*Bus_Expecter) Start 

func (_e *Bus_Expecter) Start(ctx interface{}) *Bus_Start_Call

Start is a helper method to define mock.On call

  • ctx context.Context

func (*Bus_Expecter) Stop 

func (_e *Bus_Expecter) Stop() *Bus_Stop_Call

Stop is a helper method to define mock.On call

type Bus_PublishMessageWithTopicName_Call 

type Bus_PublishMessageWithTopicName_Call struct {
	*mock.Call
}

Bus_PublishMessageWithTopicName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishMessageWithTopicName'

func (*Bus_PublishMessageWithTopicName_Call) Return 

func (_c *Bus_PublishMessageWithTopicName_Call) Return(_a0 error) *Bus_PublishMessageWithTopicName_Call

func (*Bus_PublishMessageWithTopicName_Call) Run 

func (_c *Bus_PublishMessageWithTopicName_Call) Run(run func(ctx context.Context, message types.IMessage, meta metadata.Metadata, topicOrExchangeName string)) *Bus_PublishMessageWithTopicName_Call

func (*Bus_PublishMessageWithTopicName_Call) RunAndReturn 

func (_c *Bus_PublishMessageWithTopicName_Call) RunAndReturn(run func(context.Context, types.IMessage, metadata.Metadata, string) error) *Bus_PublishMessageWithTopicName_Call

type Bus_PublishMessage_Call 

type Bus_PublishMessage_Call struct {
	*mock.Call
}

Bus_PublishMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishMessage'

func (*Bus_PublishMessage_Call) Return 

func (_c *Bus_PublishMessage_Call) Return(_a0 error) *Bus_PublishMessage_Call

func (*Bus_PublishMessage_Call) Run 

func (_c *Bus_PublishMessage_Call) Run(run func(ctx context.Context, message types.IMessage, meta metadata.Metadata)) *Bus_PublishMessage_Call

func (*Bus_PublishMessage_Call) RunAndReturn 

func (_c *Bus_PublishMessage_Call) RunAndReturn(run func(context.Context, types.IMessage, metadata.Metadata) error) *Bus_PublishMessage_Call

type Bus_Start_Call 

type Bus_Start_Call struct {
	*mock.Call
}

Bus_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*Bus_Start_Call) Return 

func (_c *Bus_Start_Call) Return(_a0 error) *Bus_Start_Call

func (*Bus_Start_Call) Run 

func (_c *Bus_Start_Call) Run(run func(ctx context.Context)) *Bus_Start_Call

func (*Bus_Start_Call) RunAndReturn 

func (_c *Bus_Start_Call) RunAndReturn(run func(context.Context) error) *Bus_Start_Call

type Bus_Stop_Call 

type Bus_Stop_Call struct {
	*mock.Call
}

Bus_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*Bus_Stop_Call) Return 

func (_c *Bus_Stop_Call) Return(_a0 error) *Bus_Stop_Call

func (*Bus_Stop_Call) Run 

func (_c *Bus_Stop_Call) Run(run func()) *Bus_Stop_Call

func (*Bus_Stop_Call) RunAndReturn 

func (_c *Bus_Stop_Call) RunAndReturn(run func() error) *Bus_Stop_Call

type Consumer 

type Consumer struct {
	mock.Mock
}

Consumer is an autogenerated mock type for the Consumer type

func NewConsumer 

func NewConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *Consumer

NewConsumer creates a new instance of Consumer. 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 (*Consumer) ConnectHandler 

func (_m *Consumer) ConnectHandler(handler consumer.ConsumerHandler)

ConnectHandler provides a mock function with given fields: handler

func (*Consumer) EXPECT 

func (_m *Consumer) EXPECT() *Consumer_Expecter

func (*Consumer) IsConsumed 

func (_m *Consumer) IsConsumed(_a0 func(types.IMessage))

AddMessageConsumedHandler provides a mock function with given fields: _a0

func (*Consumer) Start 

func (_m *Consumer) Start(ctx context.Context) error

Start provides a mock function with given fields: ctx

func (*Consumer) Stop 

func (_m *Consumer) Stop() error

Stop provides a mock function with given fields:

type ConsumerBuilderFucT 

type ConsumerBuilderFucT[T interface{}] struct {
	mock.Mock
}

ConsumerBuilderFucT is an autogenerated mock type for the ConsumerBuilderFucT type

func NewConsumerBuilderFucT 

func NewConsumerBuilderFucT[T interface{}](t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerBuilderFucT[T]

NewConsumerBuilderFucT creates a new instance of ConsumerBuilderFucT. 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 (*ConsumerBuilderFucT[T]) EXPECT 

func (_m *ConsumerBuilderFucT[T]) EXPECT() *ConsumerBuilderFucT_Expecter[T]

func (*ConsumerBuilderFucT[T]) Execute 

func (_m *ConsumerBuilderFucT[T]) Execute(builder T)

Execute provides a mock function with given fields: builder

type ConsumerBuilderFucT_Execute_Call 

type ConsumerBuilderFucT_Execute_Call[T interface{}] struct {
	*mock.Call
}

ConsumerBuilderFucT_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'

func (*ConsumerBuilderFucT_Execute_Call[T]) Return 

func (_c *ConsumerBuilderFucT_Execute_Call[T]) Return() *ConsumerBuilderFucT_Execute_Call[T]

func (*ConsumerBuilderFucT_Execute_Call[T]) Run 

func (_c *ConsumerBuilderFucT_Execute_Call[T]) Run(run func(builder T)) *ConsumerBuilderFucT_Execute_Call[T]

func (*ConsumerBuilderFucT_Execute_Call[T]) RunAndReturn 

func (_c *ConsumerBuilderFucT_Execute_Call[T]) RunAndReturn(run func(T)) *ConsumerBuilderFucT_Execute_Call[T]

type ConsumerBuilderFucT_Expecter 

type ConsumerBuilderFucT_Expecter[T interface{}] struct {
	// contains filtered or unexported fields
}

func (*ConsumerBuilderFucT_Expecter[T]) Execute 

func (_e *ConsumerBuilderFucT_Expecter[T]) Execute(builder interface{}) *ConsumerBuilderFucT_Execute_Call[T]

Execute is a helper method to define mock.On call

  • builder T

type ConsumerConnector 

type ConsumerConnector struct {
	mock.Mock
}

ConsumerConnector is an autogenerated mock type for the ConsumerConnector type

func NewConsumerConnector 

func NewConsumerConnector(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerConnector

NewConsumerConnector creates a new instance of ConsumerConnector. 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 (*ConsumerConnector) ConnectConsumer 

func (_m *ConsumerConnector) ConnectConsumer(messageType types.IMessage, _a1 consumer.Consumer) error

ConnectConsumer provides a mock function with given fields: messageType, _a1

func (*ConsumerConnector) ConnectConsumerHandler 

func (_m *ConsumerConnector) ConnectConsumerHandler(messageType types.IMessage, consumerHandler consumer.ConsumerHandler) error

ConnectConsumerHandler provides a mock function with given fields: messageType, consumerHandler

func (*ConsumerConnector) EXPECT 

func (_m *ConsumerConnector) EXPECT() *ConsumerConnector_Expecter

type ConsumerConnector_ConnectConsumerHandler_Call 

type ConsumerConnector_ConnectConsumerHandler_Call struct {
	*mock.Call
}

ConsumerConnector_ConnectConsumerHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConnectConsumerHandler'

func (*ConsumerConnector_ConnectConsumerHandler_Call) Return 

func (_c *ConsumerConnector_ConnectConsumerHandler_Call) Return(_a0 error) *ConsumerConnector_ConnectConsumerHandler_Call

func (*ConsumerConnector_ConnectConsumerHandler_Call) Run 

func (_c *ConsumerConnector_ConnectConsumerHandler_Call) Run(run func(messageType types.IMessage, consumerHandler consumer.ConsumerHandler)) *ConsumerConnector_ConnectConsumerHandler_Call

func (*ConsumerConnector_ConnectConsumerHandler_Call) RunAndReturn 

func (_c *ConsumerConnector_ConnectConsumerHandler_Call) RunAndReturn(run func(types.IMessage, consumer.ConsumerHandler) error) *ConsumerConnector_ConnectConsumerHandler_Call

type ConsumerConnector_ConnectConsumer_Call 

type ConsumerConnector_ConnectConsumer_Call struct {
	*mock.Call
}

ConsumerConnector_ConnectConsumer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConnectConsumer'

func (*ConsumerConnector_ConnectConsumer_Call) Return 

func (_c *ConsumerConnector_ConnectConsumer_Call) Return(_a0 error) *ConsumerConnector_ConnectConsumer_Call

func (*ConsumerConnector_ConnectConsumer_Call) Run 

func (_c *ConsumerConnector_ConnectConsumer_Call) Run(run func(messageType types.IMessage, _a1 consumer.Consumer)) *ConsumerConnector_ConnectConsumer_Call

func (*ConsumerConnector_ConnectConsumer_Call) RunAndReturn 

func (_c *ConsumerConnector_ConnectConsumer_Call) RunAndReturn(run func(types.IMessage, consumer.Consumer) error) *ConsumerConnector_ConnectConsumer_Call

type ConsumerConnector_Expecter 

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

func (*ConsumerConnector_Expecter) ConnectConsumer 

func (_e *ConsumerConnector_Expecter) ConnectConsumer(messageType interface{}, _a1 interface{}) *ConsumerConnector_ConnectConsumer_Call

ConnectConsumer is a helper method to define mock.On call

  • messageType types.IMessage
  • _a1 consumer.Consumer

func (*ConsumerConnector_Expecter) ConnectConsumerHandler 

func (_e *ConsumerConnector_Expecter) ConnectConsumerHandler(messageType interface{}, consumerHandler interface{}) *ConsumerConnector_ConnectConsumerHandler_Call

ConnectConsumerHandler is a helper method to define mock.On call

  • messageType types.IMessage
  • consumerHandler consumer.ConsumerHandler

type ConsumerHandler 

type ConsumerHandler struct {
	mock.Mock
}

ConsumerHandler is an autogenerated mock type for the ConsumerHandler type

func NewConsumerHandler 

func NewConsumerHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerHandler

NewConsumerHandler creates a new instance of ConsumerHandler. 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 (*ConsumerHandler) EXPECT 

func (_m *ConsumerHandler) EXPECT() *ConsumerHandler_Expecter

func (*ConsumerHandler) Handle 

func (_m *ConsumerHandler) Handle(ctx context.Context, consumeContext types.MessageConsumeContext) error

Handle provides a mock function with given fields: ctx, consumeContext

type ConsumerHandlerConfigurationBuilder 

type ConsumerHandlerConfigurationBuilder struct {
	mock.Mock
}

ConsumerHandlerConfigurationBuilder is an autogenerated mock type for the ConsumerHandlerConfigurationBuilder type

func NewConsumerHandlerConfigurationBuilder 

func NewConsumerHandlerConfigurationBuilder(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerHandlerConfigurationBuilder

NewConsumerHandlerConfigurationBuilder creates a new instance of ConsumerHandlerConfigurationBuilder. 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 (*ConsumerHandlerConfigurationBuilder) AddHandler 

func (_m *ConsumerHandlerConfigurationBuilder) AddHandler(handler consumer.ConsumerHandler) consumer.ConsumerHandlerConfigurationBuilder

AddHandler provides a mock function with given fields: handler

func (*ConsumerHandlerConfigurationBuilder) Build 

func (_m *ConsumerHandlerConfigurationBuilder) Build() *consumer.ConsumerHandlersConfiguration

Build provides a mock function with given fields:

func (*ConsumerHandlerConfigurationBuilder) EXPECT 

func (_m *ConsumerHandlerConfigurationBuilder) EXPECT() *ConsumerHandlerConfigurationBuilder_Expecter

type ConsumerHandlerConfigurationBuilderFunc 

type ConsumerHandlerConfigurationBuilderFunc struct {
	mock.Mock
}

ConsumerHandlerConfigurationBuilderFunc is an autogenerated mock type for the ConsumerHandlerConfigurationBuilderFunc type

func NewConsumerHandlerConfigurationBuilderFunc 

func NewConsumerHandlerConfigurationBuilderFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerHandlerConfigurationBuilderFunc

NewConsumerHandlerConfigurationBuilderFunc creates a new instance of ConsumerHandlerConfigurationBuilderFunc. 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 (*ConsumerHandlerConfigurationBuilderFunc) EXPECT 

func (_m *ConsumerHandlerConfigurationBuilderFunc) EXPECT() *ConsumerHandlerConfigurationBuilderFunc_Expecter

func (*ConsumerHandlerConfigurationBuilderFunc) Execute 

func (_m *ConsumerHandlerConfigurationBuilderFunc) Execute(_a0 consumer.ConsumerHandlerConfigurationBuilder)

Execute provides a mock function with given fields: _a0

type ConsumerHandlerConfigurationBuilderFunc_Execute_Call 

type ConsumerHandlerConfigurationBuilderFunc_Execute_Call struct {
	*mock.Call
}

ConsumerHandlerConfigurationBuilderFunc_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'

func (*ConsumerHandlerConfigurationBuilderFunc_Execute_Call) Return 

func (_c *ConsumerHandlerConfigurationBuilderFunc_Execute_Call) Return() *ConsumerHandlerConfigurationBuilderFunc_Execute_Call

func (*ConsumerHandlerConfigurationBuilderFunc_Execute_Call) Run 

func (_c *ConsumerHandlerConfigurationBuilderFunc_Execute_Call) Run(run func(_a0 consumer.ConsumerHandlerConfigurationBuilder)) *ConsumerHandlerConfigurationBuilderFunc_Execute_Call

func (*ConsumerHandlerConfigurationBuilderFunc_Execute_Call) RunAndReturn 

func (_c *ConsumerHandlerConfigurationBuilderFunc_Execute_Call) RunAndReturn(run func(consumer.ConsumerHandlerConfigurationBuilder)) *ConsumerHandlerConfigurationBuilderFunc_Execute_Call

type ConsumerHandlerConfigurationBuilderFunc_Expecter 

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

func (*ConsumerHandlerConfigurationBuilderFunc_Expecter) Execute 

func (_e *ConsumerHandlerConfigurationBuilderFunc_Expecter) Execute(_a0 interface{}) *ConsumerHandlerConfigurationBuilderFunc_Execute_Call

Execute is a helper method to define mock.On call

  • _a0 consumer.ConsumerHandlerConfigurationBuilder

type ConsumerHandlerConfigurationBuilder_AddHandler_Call 

type ConsumerHandlerConfigurationBuilder_AddHandler_Call struct {
	*mock.Call
}

ConsumerHandlerConfigurationBuilder_AddHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddHandler'

func (*ConsumerHandlerConfigurationBuilder_AddHandler_Call) Return 

func (_c *ConsumerHandlerConfigurationBuilder_AddHandler_Call) Return(_a0 consumer.ConsumerHandlerConfigurationBuilder) *ConsumerHandlerConfigurationBuilder_AddHandler_Call

func (*ConsumerHandlerConfigurationBuilder_AddHandler_Call) Run 

func (_c *ConsumerHandlerConfigurationBuilder_AddHandler_Call) Run(run func(handler consumer.ConsumerHandler)) *ConsumerHandlerConfigurationBuilder_AddHandler_Call

func (*ConsumerHandlerConfigurationBuilder_AddHandler_Call) RunAndReturn 

func (_c *ConsumerHandlerConfigurationBuilder_AddHandler_Call) RunAndReturn(run func(consumer.ConsumerHandler) consumer.ConsumerHandlerConfigurationBuilder) *ConsumerHandlerConfigurationBuilder_AddHandler_Call

type ConsumerHandlerConfigurationBuilder_Build_Call 

type ConsumerHandlerConfigurationBuilder_Build_Call struct {
	*mock.Call
}

ConsumerHandlerConfigurationBuilder_Build_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Build'

func (*ConsumerHandlerConfigurationBuilder_Build_Call) Return 

func (_c *ConsumerHandlerConfigurationBuilder_Build_Call) Return(_a0 *consumer.ConsumerHandlersConfiguration) *ConsumerHandlerConfigurationBuilder_Build_Call

func (*ConsumerHandlerConfigurationBuilder_Build_Call) Run 

func (_c *ConsumerHandlerConfigurationBuilder_Build_Call) Run(run func()) *ConsumerHandlerConfigurationBuilder_Build_Call

func (*ConsumerHandlerConfigurationBuilder_Build_Call) RunAndReturn 

func (_c *ConsumerHandlerConfigurationBuilder_Build_Call) RunAndReturn(run func() *consumer.ConsumerHandlersConfiguration) *ConsumerHandlerConfigurationBuilder_Build_Call

type ConsumerHandlerConfigurationBuilder_Expecter 

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

func (*ConsumerHandlerConfigurationBuilder_Expecter) AddHandler 

func (_e *ConsumerHandlerConfigurationBuilder_Expecter) AddHandler(handler interface{}) *ConsumerHandlerConfigurationBuilder_AddHandler_Call

AddHandler is a helper method to define mock.On call

  • handler consumer.ConsumerHandler

func (*ConsumerHandlerConfigurationBuilder_Expecter) Build 

func (_e *ConsumerHandlerConfigurationBuilder_Expecter) Build() *ConsumerHandlerConfigurationBuilder_Build_Call

Build is a helper method to define mock.On call

type ConsumerHandlerFunc 

type ConsumerHandlerFunc struct {
	mock.Mock
}

ConsumerHandlerFunc is an autogenerated mock type for the ConsumerHandlerFunc type

func NewConsumerHandlerFunc 

func NewConsumerHandlerFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerHandlerFunc

NewConsumerHandlerFunc creates a new instance of ConsumerHandlerFunc. 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 (*ConsumerHandlerFunc) EXPECT 

func (_m *ConsumerHandlerFunc) EXPECT() *ConsumerHandlerFunc_Expecter

func (*ConsumerHandlerFunc) Execute 

func (_m *ConsumerHandlerFunc) Execute() error

Execute provides a mock function with given fields:

type ConsumerHandlerFunc_Execute_Call 

type ConsumerHandlerFunc_Execute_Call struct {
	*mock.Call
}

ConsumerHandlerFunc_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'

func (*ConsumerHandlerFunc_Execute_Call) Return 

func (_c *ConsumerHandlerFunc_Execute_Call) Return(_a0 error) *ConsumerHandlerFunc_Execute_Call

func (*ConsumerHandlerFunc_Execute_Call) Run 

func (_c *ConsumerHandlerFunc_Execute_Call) Run(run func()) *ConsumerHandlerFunc_Execute_Call

func (*ConsumerHandlerFunc_Execute_Call) RunAndReturn 

func (_c *ConsumerHandlerFunc_Execute_Call) RunAndReturn(run func() error) *ConsumerHandlerFunc_Execute_Call

type ConsumerHandlerFunc_Expecter 

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

func (*ConsumerHandlerFunc_Expecter) Execute 

func (_e *ConsumerHandlerFunc_Expecter) Execute() *ConsumerHandlerFunc_Execute_Call

Execute is a helper method to define mock.On call

type ConsumerHandler_Expecter 

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

func (*ConsumerHandler_Expecter) Handle 

func (_e *ConsumerHandler_Expecter) Handle(ctx interface{}, consumeContext interface{}) *ConsumerHandler_Handle_Call

Handle is a helper method to define mock.On call

  • ctx context.Context
  • consumeContext types.MessageConsumeContext

type ConsumerHandler_Handle_Call 

type ConsumerHandler_Handle_Call struct {
	*mock.Call
}

ConsumerHandler_Handle_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Handle'

func (*ConsumerHandler_Handle_Call) Return 

func (_c *ConsumerHandler_Handle_Call) Return(_a0 error) *ConsumerHandler_Handle_Call

func (*ConsumerHandler_Handle_Call) Run 

func (_c *ConsumerHandler_Handle_Call) Run(run func(ctx context.Context, consumeContext types.MessageConsumeContext)) *ConsumerHandler_Handle_Call

func (*ConsumerHandler_Handle_Call) RunAndReturn 

func (_c *ConsumerHandler_Handle_Call) RunAndReturn(run func(context.Context, types.MessageConsumeContext) error) *ConsumerHandler_Handle_Call

type ConsumerPipeline 

type ConsumerPipeline struct {
	mock.Mock
}

ConsumerPipeline is an autogenerated mock type for the ConsumerPipeline type

func NewConsumerPipeline 

func NewConsumerPipeline(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerPipeline

NewConsumerPipeline creates a new instance of ConsumerPipeline. 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 (*ConsumerPipeline) EXPECT 

func (_m *ConsumerPipeline) EXPECT() *ConsumerPipeline_Expecter

func (*ConsumerPipeline) Handle 

func (_m *ConsumerPipeline) Handle(ctx context.Context, consumerContext types.MessageConsumeContext, next pipeline.ConsumerHandlerFunc) error

Handle provides a mock function with given fields: ctx, consumerContext, next

type ConsumerPipelineConfigurationBuilder 

type ConsumerPipelineConfigurationBuilder struct {
	mock.Mock
}

ConsumerPipelineConfigurationBuilder is an autogenerated mock type for the ConsumerPipelineConfigurationBuilder type

func NewConsumerPipelineConfigurationBuilder 

func NewConsumerPipelineConfigurationBuilder(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerPipelineConfigurationBuilder

NewConsumerPipelineConfigurationBuilder creates a new instance of ConsumerPipelineConfigurationBuilder. 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 (*ConsumerPipelineConfigurationBuilder) AddPipeline 

func (_m *ConsumerPipelineConfigurationBuilder) AddPipeline(_a0 pipeline.ConsumerPipeline) pipeline.ConsumerPipelineConfigurationBuilder

AddPipeline provides a mock function with given fields: _a0

func (*ConsumerPipelineConfigurationBuilder) Build 

func (_m *ConsumerPipelineConfigurationBuilder) Build() *pipeline.ConsumerPipelineConfiguration

Build provides a mock function with given fields:

func (*ConsumerPipelineConfigurationBuilder) EXPECT 

func (_m *ConsumerPipelineConfigurationBuilder) EXPECT() *ConsumerPipelineConfigurationBuilder_Expecter

type ConsumerPipelineConfigurationBuilderFunc 

type ConsumerPipelineConfigurationBuilderFunc struct {
	mock.Mock
}

ConsumerPipelineConfigurationBuilderFunc is an autogenerated mock type for the ConsumerPipelineConfigurationBuilderFunc type

func NewConsumerPipelineConfigurationBuilderFunc 

func NewConsumerPipelineConfigurationBuilderFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerPipelineConfigurationBuilderFunc

NewConsumerPipelineConfigurationBuilderFunc creates a new instance of ConsumerPipelineConfigurationBuilderFunc. 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 (*ConsumerPipelineConfigurationBuilderFunc) EXPECT 

func (_m *ConsumerPipelineConfigurationBuilderFunc) EXPECT() *ConsumerPipelineConfigurationBuilderFunc_Expecter

func (*ConsumerPipelineConfigurationBuilderFunc) Execute 

func (_m *ConsumerPipelineConfigurationBuilderFunc) Execute(_a0 pipeline.ConsumerPipelineConfigurationBuilder)

Execute provides a mock function with given fields: _a0

type ConsumerPipelineConfigurationBuilderFunc_Execute_Call 

type ConsumerPipelineConfigurationBuilderFunc_Execute_Call struct {
	*mock.Call
}

ConsumerPipelineConfigurationBuilderFunc_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'

func (*ConsumerPipelineConfigurationBuilderFunc_Execute_Call) Return 

func (_c *ConsumerPipelineConfigurationBuilderFunc_Execute_Call) Return() *ConsumerPipelineConfigurationBuilderFunc_Execute_Call

func (*ConsumerPipelineConfigurationBuilderFunc_Execute_Call) Run 

func (_c *ConsumerPipelineConfigurationBuilderFunc_Execute_Call) Run(run func(_a0 pipeline.ConsumerPipelineConfigurationBuilder)) *ConsumerPipelineConfigurationBuilderFunc_Execute_Call

func (*ConsumerPipelineConfigurationBuilderFunc_Execute_Call) RunAndReturn 

func (_c *ConsumerPipelineConfigurationBuilderFunc_Execute_Call) RunAndReturn(run func(pipeline.ConsumerPipelineConfigurationBuilder)) *ConsumerPipelineConfigurationBuilderFunc_Execute_Call

type ConsumerPipelineConfigurationBuilderFunc_Expecter 

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

func (*ConsumerPipelineConfigurationBuilderFunc_Expecter) Execute 

func (_e *ConsumerPipelineConfigurationBuilderFunc_Expecter) Execute(_a0 interface{}) *ConsumerPipelineConfigurationBuilderFunc_Execute_Call

Execute is a helper method to define mock.On call

  • _a0 pipeline.ConsumerPipelineConfigurationBuilder

type ConsumerPipelineConfigurationBuilder_AddPipeline_Call 

type ConsumerPipelineConfigurationBuilder_AddPipeline_Call struct {
	*mock.Call
}

ConsumerPipelineConfigurationBuilder_AddPipeline_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddPipeline'

func (*ConsumerPipelineConfigurationBuilder_AddPipeline_Call) Return 

func (_c *ConsumerPipelineConfigurationBuilder_AddPipeline_Call) Return(_a0 pipeline.ConsumerPipelineConfigurationBuilder) *ConsumerPipelineConfigurationBuilder_AddPipeline_Call

func (*ConsumerPipelineConfigurationBuilder_AddPipeline_Call) Run 

func (_c *ConsumerPipelineConfigurationBuilder_AddPipeline_Call) Run(run func(_a0 pipeline.ConsumerPipeline)) *ConsumerPipelineConfigurationBuilder_AddPipeline_Call

func (*ConsumerPipelineConfigurationBuilder_AddPipeline_Call) RunAndReturn 

func (_c *ConsumerPipelineConfigurationBuilder_AddPipeline_Call) RunAndReturn(run func(pipeline.ConsumerPipeline) pipeline.ConsumerPipelineConfigurationBuilder) *ConsumerPipelineConfigurationBuilder_AddPipeline_Call

type ConsumerPipelineConfigurationBuilder_Build_Call 

type ConsumerPipelineConfigurationBuilder_Build_Call struct {
	*mock.Call
}

ConsumerPipelineConfigurationBuilder_Build_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Build'

func (*ConsumerPipelineConfigurationBuilder_Build_Call) Return 

func (_c *ConsumerPipelineConfigurationBuilder_Build_Call) Return(_a0 *pipeline.ConsumerPipelineConfiguration) *ConsumerPipelineConfigurationBuilder_Build_Call

func (*ConsumerPipelineConfigurationBuilder_Build_Call) Run 

func (_c *ConsumerPipelineConfigurationBuilder_Build_Call) Run(run func()) *ConsumerPipelineConfigurationBuilder_Build_Call

func (*ConsumerPipelineConfigurationBuilder_Build_Call) RunAndReturn 

func (_c *ConsumerPipelineConfigurationBuilder_Build_Call) RunAndReturn(run func() *pipeline.ConsumerPipelineConfiguration) *ConsumerPipelineConfigurationBuilder_Build_Call

type ConsumerPipelineConfigurationBuilder_Expecter 

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

func (*ConsumerPipelineConfigurationBuilder_Expecter) AddPipeline 

func (_e *ConsumerPipelineConfigurationBuilder_Expecter) AddPipeline(_a0 interface{}) *ConsumerPipelineConfigurationBuilder_AddPipeline_Call

AddPipeline is a helper method to define mock.On call

  • _a0 pipeline.ConsumerPipeline

func (*ConsumerPipelineConfigurationBuilder_Expecter) Build 

func (_e *ConsumerPipelineConfigurationBuilder_Expecter) Build() *ConsumerPipelineConfigurationBuilder_Build_Call

Build is a helper method to define mock.On call

type ConsumerPipeline_Expecter 

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

func (*ConsumerPipeline_Expecter) Handle 

func (_e *ConsumerPipeline_Expecter) Handle(ctx interface{}, consumerContext interface{}, next interface{}) *ConsumerPipeline_Handle_Call

Handle is a helper method to define mock.On call

  • ctx context.Context
  • consumerContext types.MessageConsumeContext
  • next pipeline.ConsumerHandlerFunc

type ConsumerPipeline_Handle_Call 

type ConsumerPipeline_Handle_Call struct {
	*mock.Call
}

ConsumerPipeline_Handle_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Handle'

func (*ConsumerPipeline_Handle_Call) Return 

func (_c *ConsumerPipeline_Handle_Call) Return(_a0 error) *ConsumerPipeline_Handle_Call

func (*ConsumerPipeline_Handle_Call) Run 

func (_c *ConsumerPipeline_Handle_Call) Run(run func(ctx context.Context, consumerContext types.MessageConsumeContext, next pipeline.ConsumerHandlerFunc)) *ConsumerPipeline_Handle_Call

func (*ConsumerPipeline_Handle_Call) RunAndReturn 

func (_c *ConsumerPipeline_Handle_Call) RunAndReturn(run func(context.Context, types.MessageConsumeContext, pipeline.ConsumerHandlerFunc) error) *ConsumerPipeline_Handle_Call

type Consumer_AddMessageConsumedHandler_Call 

type Consumer_AddMessageConsumedHandler_Call struct {
	*mock.Call
}

Consumer_AddMessageConsumedHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsConsumed'

func (*Consumer_AddMessageConsumedHandler_Call) Return 

func (_c *Consumer_AddMessageConsumedHandler_Call) Return() *Consumer_AddMessageConsumedHandler_Call

func (*Consumer_AddMessageConsumedHandler_Call) Run 

func (_c *Consumer_AddMessageConsumedHandler_Call) Run(run func(_a0 func(types.IMessage))) *Consumer_AddMessageConsumedHandler_Call

func (*Consumer_AddMessageConsumedHandler_Call) RunAndReturn 

func (_c *Consumer_AddMessageConsumedHandler_Call) RunAndReturn(run func(func(types.IMessage))) *Consumer_AddMessageConsumedHandler_Call

type Consumer_ConnectHandler_Call 

type Consumer_ConnectHandler_Call struct {
	*mock.Call
}

Consumer_ConnectHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConnectHandler'

func (*Consumer_ConnectHandler_Call) Return 

func (_c *Consumer_ConnectHandler_Call) Return() *Consumer_ConnectHandler_Call

func (*Consumer_ConnectHandler_Call) Run 

func (_c *Consumer_ConnectHandler_Call) Run(run func(handler consumer.ConsumerHandler)) *Consumer_ConnectHandler_Call

func (*Consumer_ConnectHandler_Call) RunAndReturn 

func (_c *Consumer_ConnectHandler_Call) RunAndReturn(run func(consumer.ConsumerHandler)) *Consumer_ConnectHandler_Call

type Consumer_Expecter 

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

func (*Consumer_Expecter) AddMessageConsumedHandler 

func (_e *Consumer_Expecter) AddMessageConsumedHandler(_a0 interface{}) *Consumer_AddMessageConsumedHandler_Call

AddMessageConsumedHandler is a helper method to define mock.On call

  • _a0 func(types.IMessage)

func (*Consumer_Expecter) ConnectHandler 

func (_e *Consumer_Expecter) ConnectHandler(handler interface{}) *Consumer_ConnectHandler_Call

ConnectHandler is a helper method to define mock.On call

  • handler consumer.ConsumerHandler

func (*Consumer_Expecter) Start 

func (_e *Consumer_Expecter) Start(ctx interface{}) *Consumer_Start_Call

Start is a helper method to define mock.On call

  • ctx context.Context

func (*Consumer_Expecter) Stop 

func (_e *Consumer_Expecter) Stop() *Consumer_Stop_Call

Stop is a helper method to define mock.On call

type Consumer_Start_Call 

type Consumer_Start_Call struct {
	*mock.Call
}

Consumer_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*Consumer_Start_Call) Return 

func (_c *Consumer_Start_Call) Return(_a0 error) *Consumer_Start_Call

func (*Consumer_Start_Call) Run 

func (_c *Consumer_Start_Call) Run(run func(ctx context.Context)) *Consumer_Start_Call

func (*Consumer_Start_Call) RunAndReturn 

func (_c *Consumer_Start_Call) RunAndReturn(run func(context.Context) error) *Consumer_Start_Call

type Consumer_Stop_Call 

type Consumer_Stop_Call struct {
	*mock.Call
}

Consumer_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*Consumer_Stop_Call) Return 

func (_c *Consumer_Stop_Call) Return(_a0 error) *Consumer_Stop_Call

func (*Consumer_Stop_Call) Run 

func (_c *Consumer_Stop_Call) Run(run func()) *Consumer_Stop_Call

func (*Consumer_Stop_Call) RunAndReturn 

func (_c *Consumer_Stop_Call) RunAndReturn(run func() error) *Consumer_Stop_Call

type IMessage 

type IMessage struct {
	mock.Mock
}

IMessage is an autogenerated mock type for the IMessage type

func NewIMessage 

func NewIMessage(t interface {
	mock.TestingT
	Cleanup(func())
}) *IMessage

NewIMessage creates a new instance of IMessage. 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 (*IMessage) EXPECT 

func (_m *IMessage) EXPECT() *IMessage_Expecter

func (*IMessage) GeMessageId 

func (_m *IMessage) GeMessageId() string

GeMessageId provides a mock function with given fields:

func (*IMessage) GetCreated 

func (_m *IMessage) GetCreated() time.Time

GetCreated provides a mock function with given fields:

func (*IMessage) GetEventTypeName 

func (_m *IMessage) GetEventTypeName() string

GetEventTypeName provides a mock function with given fields:

func (*IMessage) IsMessage 

func (_m *IMessage) IsMessage() bool

IsMessage provides a mock function with given fields:

func (*IMessage) SetEventTypeName 

func (_m *IMessage) SetEventTypeName(_a0 string)

SetEventTypeName provides a mock function with given fields: _a0

type IMessage_Expecter 

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

func (*IMessage_Expecter) GeMessageId 

func (_e *IMessage_Expecter) GeMessageId() *IMessage_GeMessageId_Call

GeMessageId is a helper method to define mock.On call

func (*IMessage_Expecter) GetCreated 

func (_e *IMessage_Expecter) GetCreated() *IMessage_GetCreated_Call

GetCreated is a helper method to define mock.On call

func (*IMessage_Expecter) GetEventTypeName 

func (_e *IMessage_Expecter) GetEventTypeName() *IMessage_GetEventTypeName_Call

GetEventTypeName is a helper method to define mock.On call

func (*IMessage_Expecter) IsMessage 

func (_e *IMessage_Expecter) IsMessage() *IMessage_IsMessage_Call

IsMessage is a helper method to define mock.On call

func (*IMessage_Expecter) SetEventTypeName 

func (_e *IMessage_Expecter) SetEventTypeName(_a0 interface{}) *IMessage_SetEventTypeName_Call

SetEventTypeName is a helper method to define mock.On call

  • _a0 string

type IMessage_GeMessageId_Call 

type IMessage_GeMessageId_Call struct {
	*mock.Call
}

IMessage_GeMessageId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GeMessageId'

func (*IMessage_GeMessageId_Call) Return 

func (_c *IMessage_GeMessageId_Call) Return(_a0 string) *IMessage_GeMessageId_Call

func (*IMessage_GeMessageId_Call) Run 

func (_c *IMessage_GeMessageId_Call) Run(run func()) *IMessage_GeMessageId_Call

func (*IMessage_GeMessageId_Call) RunAndReturn 

func (_c *IMessage_GeMessageId_Call) RunAndReturn(run func() string) *IMessage_GeMessageId_Call

type IMessage_GetCreated_Call 

type IMessage_GetCreated_Call struct {
	*mock.Call
}

IMessage_GetCreated_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCreated'

func (*IMessage_GetCreated_Call) Return 

func (_c *IMessage_GetCreated_Call) Return(_a0 time.Time) *IMessage_GetCreated_Call

func (*IMessage_GetCreated_Call) Run 

func (_c *IMessage_GetCreated_Call) Run(run func()) *IMessage_GetCreated_Call

func (*IMessage_GetCreated_Call) RunAndReturn 

func (_c *IMessage_GetCreated_Call) RunAndReturn(run func() time.Time) *IMessage_GetCreated_Call

type IMessage_GetEventTypeName_Call 

type IMessage_GetEventTypeName_Call struct {
	*mock.Call
}

IMessage_GetEventTypeName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetEventTypeName'

func (*IMessage_GetEventTypeName_Call) Return 

func (_c *IMessage_GetEventTypeName_Call) Return(_a0 string) *IMessage_GetEventTypeName_Call

func (*IMessage_GetEventTypeName_Call) Run 

func (_c *IMessage_GetEventTypeName_Call) Run(run func()) *IMessage_GetEventTypeName_Call

func (*IMessage_GetEventTypeName_Call) RunAndReturn 

func (_c *IMessage_GetEventTypeName_Call) RunAndReturn(run func() string) *IMessage_GetEventTypeName_Call

type IMessage_IsMessage_Call 

type IMessage_IsMessage_Call struct {
	*mock.Call
}

IMessage_IsMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsMessage'

func (*IMessage_IsMessage_Call) Return 

func (_c *IMessage_IsMessage_Call) Return(_a0 bool) *IMessage_IsMessage_Call

func (*IMessage_IsMessage_Call) Run 

func (_c *IMessage_IsMessage_Call) Run(run func()) *IMessage_IsMessage_Call

func (*IMessage_IsMessage_Call) RunAndReturn 

func (_c *IMessage_IsMessage_Call) RunAndReturn(run func() bool) *IMessage_IsMessage_Call

type IMessage_SetEventTypeName_Call 

type IMessage_SetEventTypeName_Call struct {
	*mock.Call
}

IMessage_SetEventTypeName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetEventTypeName'

func (*IMessage_SetEventTypeName_Call) Return 

func (_c *IMessage_SetEventTypeName_Call) Return() *IMessage_SetEventTypeName_Call

func (*IMessage_SetEventTypeName_Call) Run 

func (_c *IMessage_SetEventTypeName_Call) Run(run func(_a0 string)) *IMessage_SetEventTypeName_Call

func (*IMessage_SetEventTypeName_Call) RunAndReturn 

func (_c *IMessage_SetEventTypeName_Call) RunAndReturn(run func(string)) *IMessage_SetEventTypeName_Call

type MessageConsumeContext 

type MessageConsumeContext struct {
	mock.Mock
}

MessageConsumeContext is an autogenerated mock type for the MessageConsumeContext type

func NewMessageConsumeContext 

func NewMessageConsumeContext(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageConsumeContext

NewMessageConsumeContext creates a new instance of MessageConsumeContext. 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 (*MessageConsumeContext) ContentType 

func (_m *MessageConsumeContext) ContentType() string

ContentType provides a mock function with given fields:

func (*MessageConsumeContext) CorrelationId 

func (_m *MessageConsumeContext) CorrelationId() string

CorrelationId provides a mock function with given fields:

func (*MessageConsumeContext) Created 

func (_m *MessageConsumeContext) Created() time.Time

Created provides a mock function with given fields:

func (*MessageConsumeContext) DeliveryTag 

func (_m *MessageConsumeContext) DeliveryTag() uint64

DeliveryTag provides a mock function with given fields:

func (*MessageConsumeContext) EXPECT 

func (_m *MessageConsumeContext) EXPECT() *MessageConsumeContext_Expecter

func (*MessageConsumeContext) Message 

func (_m *MessageConsumeContext) Message() types.IMessage

Message provides a mock function with given fields:

func (*MessageConsumeContext) MessageId 

func (_m *MessageConsumeContext) MessageId() string

MessageId provides a mock function with given fields:

func (*MessageConsumeContext) MessageType 

func (_m *MessageConsumeContext) MessageType() string

MessageType provides a mock function with given fields:

func (*MessageConsumeContext) Metadata 

func (_m *MessageConsumeContext) Metadata() metadata.Metadata

Metadata provides a mock function with given fields:

type MessageConsumeContext_ContentType_Call 

type MessageConsumeContext_ContentType_Call struct {
	*mock.Call
}

MessageConsumeContext_ContentType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ContentType'

func (*MessageConsumeContext_ContentType_Call) Return 

func (_c *MessageConsumeContext_ContentType_Call) Return(_a0 string) *MessageConsumeContext_ContentType_Call

func (*MessageConsumeContext_ContentType_Call) Run 

func (_c *MessageConsumeContext_ContentType_Call) Run(run func()) *MessageConsumeContext_ContentType_Call

func (*MessageConsumeContext_ContentType_Call) RunAndReturn 

func (_c *MessageConsumeContext_ContentType_Call) RunAndReturn(run func() string) *MessageConsumeContext_ContentType_Call

type MessageConsumeContext_CorrelationId_Call 

type MessageConsumeContext_CorrelationId_Call struct {
	*mock.Call
}

MessageConsumeContext_CorrelationId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CorrelationId'

func (*MessageConsumeContext_CorrelationId_Call) Return 

func (_c *MessageConsumeContext_CorrelationId_Call) Return(_a0 string) *MessageConsumeContext_CorrelationId_Call

func (*MessageConsumeContext_CorrelationId_Call) Run 

func (_c *MessageConsumeContext_CorrelationId_Call) Run(run func()) *MessageConsumeContext_CorrelationId_Call

func (*MessageConsumeContext_CorrelationId_Call) RunAndReturn 

func (_c *MessageConsumeContext_CorrelationId_Call) RunAndReturn(run func() string) *MessageConsumeContext_CorrelationId_Call

type MessageConsumeContext_Created_Call 

type MessageConsumeContext_Created_Call struct {
	*mock.Call
}

MessageConsumeContext_Created_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Created'

func (*MessageConsumeContext_Created_Call) Return 

func (_c *MessageConsumeContext_Created_Call) Return(_a0 time.Time) *MessageConsumeContext_Created_Call

func (*MessageConsumeContext_Created_Call) Run 

func (_c *MessageConsumeContext_Created_Call) Run(run func()) *MessageConsumeContext_Created_Call

func (*MessageConsumeContext_Created_Call) RunAndReturn 

func (_c *MessageConsumeContext_Created_Call) RunAndReturn(run func() time.Time) *MessageConsumeContext_Created_Call

type MessageConsumeContext_DeliveryTag_Call 

type MessageConsumeContext_DeliveryTag_Call struct {
	*mock.Call
}

MessageConsumeContext_DeliveryTag_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeliveryTag'

func (*MessageConsumeContext_DeliveryTag_Call) Return 

func (_c *MessageConsumeContext_DeliveryTag_Call) Return(_a0 uint64) *MessageConsumeContext_DeliveryTag_Call

func (*MessageConsumeContext_DeliveryTag_Call) Run 

func (_c *MessageConsumeContext_DeliveryTag_Call) Run(run func()) *MessageConsumeContext_DeliveryTag_Call

func (*MessageConsumeContext_DeliveryTag_Call) RunAndReturn 

func (_c *MessageConsumeContext_DeliveryTag_Call) RunAndReturn(run func() uint64) *MessageConsumeContext_DeliveryTag_Call

type MessageConsumeContext_Expecter 

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

func (*MessageConsumeContext_Expecter) ContentType 

func (_e *MessageConsumeContext_Expecter) ContentType() *MessageConsumeContext_ContentType_Call

ContentType is a helper method to define mock.On call

func (*MessageConsumeContext_Expecter) CorrelationId 

func (_e *MessageConsumeContext_Expecter) CorrelationId() *MessageConsumeContext_CorrelationId_Call

CorrelationId is a helper method to define mock.On call

func (*MessageConsumeContext_Expecter) Created 

func (_e *MessageConsumeContext_Expecter) Created() *MessageConsumeContext_Created_Call

Created is a helper method to define mock.On call

func (*MessageConsumeContext_Expecter) DeliveryTag 

func (_e *MessageConsumeContext_Expecter) DeliveryTag() *MessageConsumeContext_DeliveryTag_Call

DeliveryTag is a helper method to define mock.On call

func (*MessageConsumeContext_Expecter) Message 

func (_e *MessageConsumeContext_Expecter) Message() *MessageConsumeContext_Message_Call

Message is a helper method to define mock.On call

func (*MessageConsumeContext_Expecter) MessageId 

func (_e *MessageConsumeContext_Expecter) MessageId() *MessageConsumeContext_MessageId_Call

MessageId is a helper method to define mock.On call

func (*MessageConsumeContext_Expecter) MessageType 

func (_e *MessageConsumeContext_Expecter) MessageType() *MessageConsumeContext_MessageType_Call

MessageType is a helper method to define mock.On call

func (*MessageConsumeContext_Expecter) Metadata 

func (_e *MessageConsumeContext_Expecter) Metadata() *MessageConsumeContext_Metadata_Call

Metadata is a helper method to define mock.On call

type MessageConsumeContext_MessageId_Call 

type MessageConsumeContext_MessageId_Call struct {
	*mock.Call
}

MessageConsumeContext_MessageId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MessageId'

func (*MessageConsumeContext_MessageId_Call) Return 

func (_c *MessageConsumeContext_MessageId_Call) Return(_a0 string) *MessageConsumeContext_MessageId_Call

func (*MessageConsumeContext_MessageId_Call) Run 

func (_c *MessageConsumeContext_MessageId_Call) Run(run func()) *MessageConsumeContext_MessageId_Call

func (*MessageConsumeContext_MessageId_Call) RunAndReturn 

func (_c *MessageConsumeContext_MessageId_Call) RunAndReturn(run func() string) *MessageConsumeContext_MessageId_Call

type MessageConsumeContext_MessageType_Call 

type MessageConsumeContext_MessageType_Call struct {
	*mock.Call
}

MessageConsumeContext_MessageType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MessageType'

func (*MessageConsumeContext_MessageType_Call) Return 

func (_c *MessageConsumeContext_MessageType_Call) Return(_a0 string) *MessageConsumeContext_MessageType_Call

func (*MessageConsumeContext_MessageType_Call) Run 

func (_c *MessageConsumeContext_MessageType_Call) Run(run func()) *MessageConsumeContext_MessageType_Call

func (*MessageConsumeContext_MessageType_Call) RunAndReturn 

func (_c *MessageConsumeContext_MessageType_Call) RunAndReturn(run func() string) *MessageConsumeContext_MessageType_Call

type MessageConsumeContext_Message_Call 

type MessageConsumeContext_Message_Call struct {
	*mock.Call
}

MessageConsumeContext_Message_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Message'

func (*MessageConsumeContext_Message_Call) Return 

func (_c *MessageConsumeContext_Message_Call) Return(_a0 types.IMessage) *MessageConsumeContext_Message_Call

func (*MessageConsumeContext_Message_Call) Run 

func (_c *MessageConsumeContext_Message_Call) Run(run func()) *MessageConsumeContext_Message_Call

func (*MessageConsumeContext_Message_Call) RunAndReturn 

func (_c *MessageConsumeContext_Message_Call) RunAndReturn(run func() types.IMessage) *MessageConsumeContext_Message_Call

type MessageConsumeContext_Metadata_Call 

type MessageConsumeContext_Metadata_Call struct {
	*mock.Call
}

MessageConsumeContext_Metadata_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Metadata'

func (*MessageConsumeContext_Metadata_Call) Return 

func (_c *MessageConsumeContext_Metadata_Call) Return(_a0 metadata.Metadata) *MessageConsumeContext_Metadata_Call

func (*MessageConsumeContext_Metadata_Call) Run 

func (_c *MessageConsumeContext_Metadata_Call) Run(run func()) *MessageConsumeContext_Metadata_Call

func (*MessageConsumeContext_Metadata_Call) RunAndReturn 

func (_c *MessageConsumeContext_Metadata_Call) RunAndReturn(run func() metadata.Metadata) *MessageConsumeContext_Metadata_Call

type Producer 

type Producer struct {
	mock.Mock
}

Producer is an autogenerated mock type for the Producer type

func NewProducer 

func NewProducer(t interface {
	mock.TestingT
	Cleanup(func())
}) *Producer

NewProducer creates a new instance of Producer. 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 (*Producer) EXPECT 

func (_m *Producer) EXPECT() *Producer_Expecter

func (*Producer) IsProduced 

func (_m *Producer) IsProduced(_a0 func(types.IMessage))

AddMessageProducedHandler provides a mock function with given fields: _a0

func (*Producer) PublishMessage 

func (_m *Producer) PublishMessage(ctx context.Context, message types.IMessage, meta metadata.Metadata) error

PublishMessage provides a mock function with given fields: ctx, message, meta

func (*Producer) PublishMessageWithTopicName 

func (_m *Producer) PublishMessageWithTopicName(ctx context.Context, message types.IMessage, meta metadata.Metadata, topicOrExchangeName string) error

PublishMessageWithTopicName provides a mock function with given fields: ctx, message, meta, topicOrExchangeName

type ProducerBuilderFuc 

type ProducerBuilderFuc[T interface{}] struct {
	mock.Mock
}

ProducerBuilderFuc is an autogenerated mock type for the ProducerBuilderFuc type

func NewProducerBuilderFuc 

func NewProducerBuilderFuc[T interface{}](t interface {
	mock.TestingT
	Cleanup(func())
}) *ProducerBuilderFuc[T]

NewProducerBuilderFuc creates a new instance of ProducerBuilderFuc. 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 (*ProducerBuilderFuc[T]) EXPECT 

func (_m *ProducerBuilderFuc[T]) EXPECT() *ProducerBuilderFuc_Expecter[T]

func (*ProducerBuilderFuc[T]) Execute 

func (_m *ProducerBuilderFuc[T]) Execute(builder T)

Execute provides a mock function with given fields: builder

type ProducerBuilderFuc_Execute_Call 

type ProducerBuilderFuc_Execute_Call[T interface{}] struct {
	*mock.Call
}

ProducerBuilderFuc_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'

func (*ProducerBuilderFuc_Execute_Call[T]) Return 

func (_c *ProducerBuilderFuc_Execute_Call[T]) Return() *ProducerBuilderFuc_Execute_Call[T]

func (*ProducerBuilderFuc_Execute_Call[T]) Run 

func (_c *ProducerBuilderFuc_Execute_Call[T]) Run(run func(builder T)) *ProducerBuilderFuc_Execute_Call[T]

func (*ProducerBuilderFuc_Execute_Call[T]) RunAndReturn 

func (_c *ProducerBuilderFuc_Execute_Call[T]) RunAndReturn(run func(T)) *ProducerBuilderFuc_Execute_Call[T]

type ProducerBuilderFuc_Expecter 

type ProducerBuilderFuc_Expecter[T interface{}] struct {
	// contains filtered or unexported fields
}

func (*ProducerBuilderFuc_Expecter[T]) Execute 

func (_e *ProducerBuilderFuc_Expecter[T]) Execute(builder interface{}) *ProducerBuilderFuc_Execute_Call[T]

Execute is a helper method to define mock.On call

  • builder T

type Producer_AddMessageProducedHandler_Call 

type Producer_AddMessageProducedHandler_Call struct {
	*mock.Call
}

Producer_AddMessageProducedHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsProduced'

func (*Producer_AddMessageProducedHandler_Call) Return 

func (_c *Producer_AddMessageProducedHandler_Call) Return() *Producer_AddMessageProducedHandler_Call

func (*Producer_AddMessageProducedHandler_Call) Run 

func (_c *Producer_AddMessageProducedHandler_Call) Run(run func(_a0 func(types.IMessage))) *Producer_AddMessageProducedHandler_Call

func (*Producer_AddMessageProducedHandler_Call) RunAndReturn 

func (_c *Producer_AddMessageProducedHandler_Call) RunAndReturn(run func(func(types.IMessage))) *Producer_AddMessageProducedHandler_Call

type Producer_Expecter 

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

func (*Producer_Expecter) AddMessageProducedHandler 

func (_e *Producer_Expecter) AddMessageProducedHandler(_a0 interface{}) *Producer_AddMessageProducedHandler_Call

AddMessageProducedHandler is a helper method to define mock.On call

  • _a0 func(types.IMessage)

func (*Producer_Expecter) PublishMessage 

func (_e *Producer_Expecter) PublishMessage(ctx interface{}, message interface{}, meta interface{}) *Producer_PublishMessage_Call

PublishMessage is a helper method to define mock.On call

  • ctx context.Context
  • message types.IMessage
  • meta metadata.Metadata

func (*Producer_Expecter) PublishMessageWithTopicName 

func (_e *Producer_Expecter) PublishMessageWithTopicName(ctx interface{}, message interface{}, meta interface{}, topicOrExchangeName interface{}) *Producer_PublishMessageWithTopicName_Call

PublishMessageWithTopicName is a helper method to define mock.On call

  • ctx context.Context
  • message types.IMessage
  • meta metadata.Metadata
  • topicOrExchangeName string

type Producer_PublishMessageWithTopicName_Call 

type Producer_PublishMessageWithTopicName_Call struct {
	*mock.Call
}

Producer_PublishMessageWithTopicName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishMessageWithTopicName'

func (*Producer_PublishMessageWithTopicName_Call) Return 

func (_c *Producer_PublishMessageWithTopicName_Call) Return(_a0 error) *Producer_PublishMessageWithTopicName_Call

func (*Producer_PublishMessageWithTopicName_Call) Run 

func (_c *Producer_PublishMessageWithTopicName_Call) Run(run func(ctx context.Context, message types.IMessage, meta metadata.Metadata, topicOrExchangeName string)) *Producer_PublishMessageWithTopicName_Call

func (*Producer_PublishMessageWithTopicName_Call) RunAndReturn 

func (_c *Producer_PublishMessageWithTopicName_Call) RunAndReturn(run func(context.Context, types.IMessage, metadata.Metadata, string) error) *Producer_PublishMessageWithTopicName_Call

type Producer_PublishMessage_Call 

type Producer_PublishMessage_Call struct {
	*mock.Call
}

Producer_PublishMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishMessage'

func (*Producer_PublishMessage_Call) Return 

func (_c *Producer_PublishMessage_Call) Return(_a0 error) *Producer_PublishMessage_Call

func (*Producer_PublishMessage_Call) Run 

func (_c *Producer_PublishMessage_Call) Run(run func(ctx context.Context, message types.IMessage, meta metadata.Metadata)) *Producer_PublishMessage_Call

func (*Producer_PublishMessage_Call) RunAndReturn 

func (_c *Producer_PublishMessage_Call) RunAndReturn(run func(context.Context, types.IMessage, metadata.Metadata) error) *Producer_PublishMessage_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.