mocks

package
v0.0.0-...-4a59535 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2024 License: MIT Imports: 9 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))

IsConsumed provides a mock function with given fields: _a0

func (*Bus) IsProduced 

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

IsProduced 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))

IsConsumed 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_Expecter 

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

func (*BusControl_Expecter) IsConsumed 

func (_e *BusControl_Expecter) IsConsumed(_a0 interface{}) *BusControl_IsConsumed_Call

IsConsumed 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_IsConsumed_Call 

type BusControl_IsConsumed_Call struct {
	*mock.Call
}

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

func (*BusControl_IsConsumed_Call) Return 

func (_c *BusControl_IsConsumed_Call) Return() *BusControl_IsConsumed_Call

func (*BusControl_IsConsumed_Call) Run 

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

func (*BusControl_IsConsumed_Call) RunAndReturn 

func (_c *BusControl_IsConsumed_Call) RunAndReturn(run func(func(types.IMessage))) *BusControl_IsConsumed_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_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) 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) IsConsumed 

func (_e *Bus_Expecter) IsConsumed(_a0 interface{}) *Bus_IsConsumed_Call

IsConsumed is a helper method to define mock.On call

  • _a0 func(types.IMessage)

func (*Bus_Expecter) IsProduced 

func (_e *Bus_Expecter) IsProduced(_a0 interface{}) *Bus_IsProduced_Call

IsProduced is a helper method to define mock.On call

  • _a0 func(types.IMessage)

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_IsConsumed_Call 

type Bus_IsConsumed_Call struct {
	*mock.Call
}

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

func (*Bus_IsConsumed_Call) Return 

func (_c *Bus_IsConsumed_Call) Return() *Bus_IsConsumed_Call

func (*Bus_IsConsumed_Call) Run 

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

func (*Bus_IsConsumed_Call) RunAndReturn 

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

type Bus_IsProduced_Call 

type Bus_IsProduced_Call struct {
	*mock.Call
}

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

func (*Bus_IsProduced_Call) Return 

func (_c *Bus_IsProduced_Call) Return() *Bus_IsProduced_Call

func (*Bus_IsProduced_Call) Run 

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

func (*Bus_IsProduced_Call) RunAndReturn 

func (_c *Bus_IsProduced_Call) RunAndReturn(run func(func(types.IMessage))) *Bus_IsProduced_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) GetName 

func (_m *Consumer) GetName() string

GetName provides a mock function with given fields:

func (*Consumer) IsConsumed 

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

IsConsumed 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(ctx context.Context) error

Execute provides a mock function with given fields: ctx

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(ctx context.Context)) *ConsumerHandlerFunc_Execute_Call

func (*ConsumerHandlerFunc_Execute_Call) RunAndReturn 

func (_c *ConsumerHandlerFunc_Execute_Call) RunAndReturn(run func(context.Context) 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(ctx interface{}) *ConsumerHandlerFunc_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context

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_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) 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) GetName 

func (_e *Consumer_Expecter) GetName() *Consumer_GetName_Call

GetName is a helper method to define mock.On call

func (*Consumer_Expecter) IsConsumed 

func (_e *Consumer_Expecter) IsConsumed(_a0 interface{}) *Consumer_IsConsumed_Call

IsConsumed is a helper method to define mock.On call

  • _a0 func(types.IMessage)

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_GetName_Call 

type Consumer_GetName_Call struct {
	*mock.Call
}

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

func (*Consumer_GetName_Call) Return 

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

func (*Consumer_GetName_Call) Run 

func (_c *Consumer_GetName_Call) Run(run func()) *Consumer_GetName_Call

func (*Consumer_GetName_Call) RunAndReturn 

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

type Consumer_IsConsumed_Call 

type Consumer_IsConsumed_Call struct {
	*mock.Call
}

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

func (*Consumer_IsConsumed_Call) Return 

func (_c *Consumer_IsConsumed_Call) Return() *Consumer_IsConsumed_Call

func (*Consumer_IsConsumed_Call) Run 

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

func (*Consumer_IsConsumed_Call) RunAndReturn 

func (_c *Consumer_IsConsumed_Call) RunAndReturn(run func(func(types.IMessage))) *Consumer_IsConsumed_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) GetMessageFullTypeName 

func (_m *IMessage) GetMessageFullTypeName() string

GetMessageFullTypeName provides a mock function with given fields:

func (*IMessage) GetMessageTypeName 

func (_m *IMessage) GetMessageTypeName() string

GetMessageTypeName provides a mock function with given fields:

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) GetMessageFullTypeName 

func (_e *IMessage_Expecter) GetMessageFullTypeName() *IMessage_GetMessageFullTypeName_Call

GetMessageFullTypeName is a helper method to define mock.On call

func (*IMessage_Expecter) GetMessageTypeName 

func (_e *IMessage_Expecter) GetMessageTypeName() *IMessage_GetMessageTypeName_Call

GetMessageTypeName is a helper method to define mock.On call

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_GetMessageFullTypeName_Call 

type IMessage_GetMessageFullTypeName_Call struct {
	*mock.Call
}

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

func (*IMessage_GetMessageFullTypeName_Call) Return 

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

func (*IMessage_GetMessageFullTypeName_Call) Run 

func (_c *IMessage_GetMessageFullTypeName_Call) Run(run func()) *IMessage_GetMessageFullTypeName_Call

func (*IMessage_GetMessageFullTypeName_Call) RunAndReturn 

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

type IMessage_GetMessageTypeName_Call 

type IMessage_GetMessageTypeName_Call struct {
	*mock.Call
}

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

func (*IMessage_GetMessageTypeName_Call) Return 

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

func (*IMessage_GetMessageTypeName_Call) Run 

func (_c *IMessage_GetMessageTypeName_Call) Run(run func()) *IMessage_GetMessageTypeName_Call

func (*IMessage_GetMessageTypeName_Call) RunAndReturn 

func (_c *IMessage_GetMessageTypeName_Call) RunAndReturn(run func() string) *IMessage_GetMessageTypeName_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 MessagePersistenceService 

type MessagePersistenceService struct {
	mock.Mock
}

MessagePersistenceService is an autogenerated mock type for the MessagePersistenceService type

func NewMessagePersistenceService 

func NewMessagePersistenceService(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessagePersistenceService

NewMessagePersistenceService creates a new instance of MessagePersistenceService. 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 (*MessagePersistenceService) Add 

func (_m *MessagePersistenceService) Add(ctx context.Context, storeMessage *persistmessage.StoreMessage) error

Add provides a mock function with given fields: ctx, storeMessage

func (*MessagePersistenceService) AddPublishMessage 

func (_m *MessagePersistenceService) AddPublishMessage(messageEnvelope types.MessageEnvelope, ctx context.Context) error

AddPublishMessage provides a mock function with given fields: messageEnvelope, ctx

func (*MessagePersistenceService) AddReceivedMessage 

func (_m *MessagePersistenceService) AddReceivedMessage(messageEnvelope types.MessageEnvelope, ctx context.Context) error

AddReceivedMessage provides a mock function with given fields: messageEnvelope, ctx

func (*MessagePersistenceService) ChangeState 

func (_m *MessagePersistenceService) ChangeState(ctx context.Context, messageID uuid.UUID, status persistmessage.MessageStatus) error

ChangeState provides a mock function with given fields: ctx, messageID, status

func (*MessagePersistenceService) CleanupMessages 

func (_m *MessagePersistenceService) CleanupMessages(ctx context.Context) error

CleanupMessages provides a mock function with given fields: ctx

func (*MessagePersistenceService) EXPECT 

func (_m *MessagePersistenceService) EXPECT() *MessagePersistenceService_Expecter

func (*MessagePersistenceService) GetAllActive 

func (_m *MessagePersistenceService) GetAllActive(ctx context.Context) ([]*persistmessage.StoreMessage, error)

GetAllActive provides a mock function with given fields: ctx

func (*MessagePersistenceService) GetByFilter 

func (_m *MessagePersistenceService) GetByFilter(ctx context.Context, predicate func(*persistmessage.StoreMessage) bool) ([]*persistmessage.StoreMessage, error)

GetByFilter provides a mock function with given fields: ctx, predicate

func (*MessagePersistenceService) GetById 

func (_m *MessagePersistenceService) GetById(ctx context.Context, id uuid.UUID) (*persistmessage.StoreMessage, error)

GetById provides a mock function with given fields: ctx, id

func (*MessagePersistenceService) Process 

func (_m *MessagePersistenceService) Process(messageID string, ctx context.Context) error

Process provides a mock function with given fields: messageID, ctx

func (*MessagePersistenceService) ProcessAll 

func (_m *MessagePersistenceService) ProcessAll(ctx context.Context) error

ProcessAll provides a mock function with given fields: ctx

func (*MessagePersistenceService) Remove 

func (_m *MessagePersistenceService) Remove(ctx context.Context, storeMessage *persistmessage.StoreMessage) (bool, error)

Remove provides a mock function with given fields: ctx, storeMessage

func (*MessagePersistenceService) Update 

func (_m *MessagePersistenceService) Update(ctx context.Context, storeMessage *persistmessage.StoreMessage) error

Update provides a mock function with given fields: ctx, storeMessage

type MessagePersistenceService_AddPublishMessage_Call 

type MessagePersistenceService_AddPublishMessage_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_AddPublishMessage_Call) Return 

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

func (*MessagePersistenceService_AddPublishMessage_Call) Run 

func (_c *MessagePersistenceService_AddPublishMessage_Call) Run(run func(messageEnvelope types.MessageEnvelope, ctx context.Context)) *MessagePersistenceService_AddPublishMessage_Call

func (*MessagePersistenceService_AddPublishMessage_Call) RunAndReturn 

func (_c *MessagePersistenceService_AddPublishMessage_Call) RunAndReturn(run func(types.MessageEnvelope, context.Context) error) *MessagePersistenceService_AddPublishMessage_Call

type MessagePersistenceService_AddReceivedMessage_Call 

type MessagePersistenceService_AddReceivedMessage_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_AddReceivedMessage_Call) Return 

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

func (*MessagePersistenceService_AddReceivedMessage_Call) Run 

func (_c *MessagePersistenceService_AddReceivedMessage_Call) Run(run func(messageEnvelope types.MessageEnvelope, ctx context.Context)) *MessagePersistenceService_AddReceivedMessage_Call

func (*MessagePersistenceService_AddReceivedMessage_Call) RunAndReturn 

func (_c *MessagePersistenceService_AddReceivedMessage_Call) RunAndReturn(run func(types.MessageEnvelope, context.Context) error) *MessagePersistenceService_AddReceivedMessage_Call

type MessagePersistenceService_Add_Call 

type MessagePersistenceService_Add_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_Add_Call) Return 

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

func (*MessagePersistenceService_Add_Call) Run 

func (_c *MessagePersistenceService_Add_Call) Run(run func(ctx context.Context, storeMessage *persistmessage.StoreMessage)) *MessagePersistenceService_Add_Call

func (*MessagePersistenceService_Add_Call) RunAndReturn 

func (_c *MessagePersistenceService_Add_Call) RunAndReturn(run func(context.Context, *persistmessage.StoreMessage) error) *MessagePersistenceService_Add_Call

type MessagePersistenceService_ChangeState_Call 

type MessagePersistenceService_ChangeState_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_ChangeState_Call) Return 

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

func (*MessagePersistenceService_ChangeState_Call) Run 

func (_c *MessagePersistenceService_ChangeState_Call) Run(run func(ctx context.Context, messageID uuid.UUID, status persistmessage.MessageStatus)) *MessagePersistenceService_ChangeState_Call

func (*MessagePersistenceService_ChangeState_Call) RunAndReturn 

func (_c *MessagePersistenceService_ChangeState_Call) RunAndReturn(run func(context.Context, uuid.UUID, persistmessage.MessageStatus) error) *MessagePersistenceService_ChangeState_Call

type MessagePersistenceService_CleanupMessages_Call 

type MessagePersistenceService_CleanupMessages_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_CleanupMessages_Call) Return 

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

func (*MessagePersistenceService_CleanupMessages_Call) Run 

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

func (*MessagePersistenceService_CleanupMessages_Call) RunAndReturn 

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

type MessagePersistenceService_Expecter 

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

func (*MessagePersistenceService_Expecter) Add 

func (_e *MessagePersistenceService_Expecter) Add(ctx interface{}, storeMessage interface{}) *MessagePersistenceService_Add_Call

Add is a helper method to define mock.On call

  • ctx context.Context
  • storeMessage *persistmessage.StoreMessage

func (*MessagePersistenceService_Expecter) AddPublishMessage 

func (_e *MessagePersistenceService_Expecter) AddPublishMessage(messageEnvelope interface{}, ctx interface{}) *MessagePersistenceService_AddPublishMessage_Call

AddPublishMessage is a helper method to define mock.On call

  • messageEnvelope types.MessageEnvelope
  • ctx context.Context

func (*MessagePersistenceService_Expecter) AddReceivedMessage 

func (_e *MessagePersistenceService_Expecter) AddReceivedMessage(messageEnvelope interface{}, ctx interface{}) *MessagePersistenceService_AddReceivedMessage_Call

AddReceivedMessage is a helper method to define mock.On call

  • messageEnvelope types.MessageEnvelope
  • ctx context.Context

func (*MessagePersistenceService_Expecter) ChangeState 

func (_e *MessagePersistenceService_Expecter) ChangeState(ctx interface{}, messageID interface{}, status interface{}) *MessagePersistenceService_ChangeState_Call

ChangeState is a helper method to define mock.On call

  • ctx context.Context
  • messageID uuid.UUID
  • status persistmessage.MessageStatus

func (*MessagePersistenceService_Expecter) CleanupMessages 

func (_e *MessagePersistenceService_Expecter) CleanupMessages(ctx interface{}) *MessagePersistenceService_CleanupMessages_Call

CleanupMessages is a helper method to define mock.On call

  • ctx context.Context

func (*MessagePersistenceService_Expecter) GetAllActive 

func (_e *MessagePersistenceService_Expecter) GetAllActive(ctx interface{}) *MessagePersistenceService_GetAllActive_Call

GetAllActive is a helper method to define mock.On call

  • ctx context.Context

func (*MessagePersistenceService_Expecter) GetByFilter 

func (_e *MessagePersistenceService_Expecter) GetByFilter(ctx interface{}, predicate interface{}) *MessagePersistenceService_GetByFilter_Call

GetByFilter is a helper method to define mock.On call

  • ctx context.Context
  • predicate func(*persistmessage.StoreMessage) bool

func (*MessagePersistenceService_Expecter) GetById 

func (_e *MessagePersistenceService_Expecter) GetById(ctx interface{}, id interface{}) *MessagePersistenceService_GetById_Call

GetById is a helper method to define mock.On call

  • ctx context.Context
  • id uuid.UUID

func (*MessagePersistenceService_Expecter) Process 

func (_e *MessagePersistenceService_Expecter) Process(messageID interface{}, ctx interface{}) *MessagePersistenceService_Process_Call

Process is a helper method to define mock.On call

  • messageID string
  • ctx context.Context

func (*MessagePersistenceService_Expecter) ProcessAll 

func (_e *MessagePersistenceService_Expecter) ProcessAll(ctx interface{}) *MessagePersistenceService_ProcessAll_Call

ProcessAll is a helper method to define mock.On call

  • ctx context.Context

func (*MessagePersistenceService_Expecter) Remove 

func (_e *MessagePersistenceService_Expecter) Remove(ctx interface{}, storeMessage interface{}) *MessagePersistenceService_Remove_Call

Remove is a helper method to define mock.On call

  • ctx context.Context
  • storeMessage *persistmessage.StoreMessage

func (*MessagePersistenceService_Expecter) Update 

func (_e *MessagePersistenceService_Expecter) Update(ctx interface{}, storeMessage interface{}) *MessagePersistenceService_Update_Call

Update is a helper method to define mock.On call

  • ctx context.Context
  • storeMessage *persistmessage.StoreMessage

type MessagePersistenceService_GetAllActive_Call 

type MessagePersistenceService_GetAllActive_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_GetAllActive_Call) Return 

func (_c *MessagePersistenceService_GetAllActive_Call) Return(_a0 []*persistmessage.StoreMessage, _a1 error) *MessagePersistenceService_GetAllActive_Call

func (*MessagePersistenceService_GetAllActive_Call) Run 

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

func (*MessagePersistenceService_GetAllActive_Call) RunAndReturn 

func (_c *MessagePersistenceService_GetAllActive_Call) RunAndReturn(run func(context.Context) ([]*persistmessage.StoreMessage, error)) *MessagePersistenceService_GetAllActive_Call

type MessagePersistenceService_GetByFilter_Call 

type MessagePersistenceService_GetByFilter_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_GetByFilter_Call) Return 

func (_c *MessagePersistenceService_GetByFilter_Call) Return(_a0 []*persistmessage.StoreMessage, _a1 error) *MessagePersistenceService_GetByFilter_Call

func (*MessagePersistenceService_GetByFilter_Call) Run 

func (_c *MessagePersistenceService_GetByFilter_Call) Run(run func(ctx context.Context, predicate func(*persistmessage.StoreMessage) bool)) *MessagePersistenceService_GetByFilter_Call

func (*MessagePersistenceService_GetByFilter_Call) RunAndReturn 

func (_c *MessagePersistenceService_GetByFilter_Call) RunAndReturn(run func(context.Context, func(*persistmessage.StoreMessage) bool) ([]*persistmessage.StoreMessage, error)) *MessagePersistenceService_GetByFilter_Call

type MessagePersistenceService_GetById_Call 

type MessagePersistenceService_GetById_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_GetById_Call) Return 

func (_c *MessagePersistenceService_GetById_Call) Return(_a0 *persistmessage.StoreMessage, _a1 error) *MessagePersistenceService_GetById_Call

func (*MessagePersistenceService_GetById_Call) Run 

func (_c *MessagePersistenceService_GetById_Call) Run(run func(ctx context.Context, id uuid.UUID)) *MessagePersistenceService_GetById_Call

func (*MessagePersistenceService_GetById_Call) RunAndReturn 

func (_c *MessagePersistenceService_GetById_Call) RunAndReturn(run func(context.Context, uuid.UUID) (*persistmessage.StoreMessage, error)) *MessagePersistenceService_GetById_Call

type MessagePersistenceService_ProcessAll_Call 

type MessagePersistenceService_ProcessAll_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_ProcessAll_Call) Return 

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

func (*MessagePersistenceService_ProcessAll_Call) Run 

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

func (*MessagePersistenceService_ProcessAll_Call) RunAndReturn 

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

type MessagePersistenceService_Process_Call 

type MessagePersistenceService_Process_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_Process_Call) Return 

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

func (*MessagePersistenceService_Process_Call) Run 

func (_c *MessagePersistenceService_Process_Call) Run(run func(messageID string, ctx context.Context)) *MessagePersistenceService_Process_Call

func (*MessagePersistenceService_Process_Call) RunAndReturn 

func (_c *MessagePersistenceService_Process_Call) RunAndReturn(run func(string, context.Context) error) *MessagePersistenceService_Process_Call

type MessagePersistenceService_Remove_Call 

type MessagePersistenceService_Remove_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_Remove_Call) Return 

func (_c *MessagePersistenceService_Remove_Call) Return(_a0 bool, _a1 error) *MessagePersistenceService_Remove_Call

func (*MessagePersistenceService_Remove_Call) Run 

func (_c *MessagePersistenceService_Remove_Call) Run(run func(ctx context.Context, storeMessage *persistmessage.StoreMessage)) *MessagePersistenceService_Remove_Call

func (*MessagePersistenceService_Remove_Call) RunAndReturn 

func (_c *MessagePersistenceService_Remove_Call) RunAndReturn(run func(context.Context, *persistmessage.StoreMessage) (bool, error)) *MessagePersistenceService_Remove_Call

type MessagePersistenceService_Update_Call 

type MessagePersistenceService_Update_Call struct {
	*mock.Call
}

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

func (*MessagePersistenceService_Update_Call) Return 

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

func (*MessagePersistenceService_Update_Call) Run 

func (_c *MessagePersistenceService_Update_Call) Run(run func(ctx context.Context, storeMessage *persistmessage.StoreMessage)) *MessagePersistenceService_Update_Call

func (*MessagePersistenceService_Update_Call) RunAndReturn 

func (_c *MessagePersistenceService_Update_Call) RunAndReturn(run func(context.Context, *persistmessage.StoreMessage) error) *MessagePersistenceService_Update_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))

IsProduced 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_Expecter 

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

func (*Producer_Expecter) IsProduced 

func (_e *Producer_Expecter) IsProduced(_a0 interface{}) *Producer_IsProduced_Call

IsProduced 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_IsProduced_Call 

type Producer_IsProduced_Call struct {
	*mock.Call
}

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

func (*Producer_IsProduced_Call) Return 

func (_c *Producer_IsProduced_Call) Return() *Producer_IsProduced_Call

func (*Producer_IsProduced_Call) Run 

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

func (*Producer_IsProduced_Call) RunAndReturn 

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

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.