mockcommon

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Aug 11, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type IPCMessageReceive 

type IPCMessageReceive struct {
	mock.Mock
}

IPCMessageReceive is an autogenerated mock type for the IPCMessageReceive type

func NewIPCMessageReceive 

func NewIPCMessageReceive(t interface {
	mock.TestingT
	Cleanup(func())
}) *IPCMessageReceive

NewIPCMessageReceive creates a new instance of IPCMessageReceive. 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 (*IPCMessageReceive) DeleteBufferedMessage 

func (_mock *IPCMessageReceive) DeleteBufferedMessage(ctx context.Context, msg redis.QueueMessageEnvelope) error

DeleteBufferedMessage provides a mock function for the type IPCMessageReceive

func (*IPCMessageReceive) DequeueBufferedMessage 

func (_mock *IPCMessageReceive) DequeueBufferedMessage(ctx context.Context, blocking bool, maxWait *time.Duration) (redis.QueueMessageEnvelope, error)

DequeueBufferedMessage provides a mock function for the type IPCMessageReceive

func (*IPCMessageReceive) DequeueMessage 

func (_mock *IPCMessageReceive) DequeueMessage(ctx context.Context, blocking bool, maxWait *time.Duration) (redis.QueueMessageEnvelope, error)

DequeueMessage provides a mock function for the type IPCMessageReceive

func (*IPCMessageReceive) EXPECT 

func (_m *IPCMessageReceive) EXPECT() *IPCMessageReceive_Expecter

func (*IPCMessageReceive) ReEnqueueOnMainQueue 

func (_mock *IPCMessageReceive) ReEnqueueOnMainQueue(ctx context.Context, msg redis.QueueMessageEnvelope) error

ReEnqueueOnMainQueue provides a mock function for the type IPCMessageReceive

type IPCMessageReceive_DeleteBufferedMessage_Call 

type IPCMessageReceive_DeleteBufferedMessage_Call struct {
	*mock.Call
}

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

func (*IPCMessageReceive_DeleteBufferedMessage_Call) Return 

func (_c *IPCMessageReceive_DeleteBufferedMessage_Call) Return(err error) *IPCMessageReceive_DeleteBufferedMessage_Call

func (*IPCMessageReceive_DeleteBufferedMessage_Call) Run 

func (_c *IPCMessageReceive_DeleteBufferedMessage_Call) Run(run func(ctx context.Context, msg redis.QueueMessageEnvelope)) *IPCMessageReceive_DeleteBufferedMessage_Call

func (*IPCMessageReceive_DeleteBufferedMessage_Call) RunAndReturn 

func (_c *IPCMessageReceive_DeleteBufferedMessage_Call) RunAndReturn(run func(ctx context.Context, msg redis.QueueMessageEnvelope) error) *IPCMessageReceive_DeleteBufferedMessage_Call

type IPCMessageReceive_DequeueBufferedMessage_Call 

type IPCMessageReceive_DequeueBufferedMessage_Call struct {
	*mock.Call
}

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

func (*IPCMessageReceive_DequeueBufferedMessage_Call) Return 

func (_c *IPCMessageReceive_DequeueBufferedMessage_Call) Return(queueMessageEnvelope redis.QueueMessageEnvelope, err error) *IPCMessageReceive_DequeueBufferedMessage_Call

func (*IPCMessageReceive_DequeueBufferedMessage_Call) Run 

func (_c *IPCMessageReceive_DequeueBufferedMessage_Call) Run(run func(ctx context.Context, blocking bool, maxWait *time.Duration)) *IPCMessageReceive_DequeueBufferedMessage_Call

func (*IPCMessageReceive_DequeueBufferedMessage_Call) RunAndReturn 

func (_c *IPCMessageReceive_DequeueBufferedMessage_Call) RunAndReturn(run func(ctx context.Context, blocking bool, maxWait *time.Duration) (redis.QueueMessageEnvelope, error)) *IPCMessageReceive_DequeueBufferedMessage_Call

type IPCMessageReceive_DequeueMessage_Call 

type IPCMessageReceive_DequeueMessage_Call struct {
	*mock.Call
}

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

func (*IPCMessageReceive_DequeueMessage_Call) Return 

func (_c *IPCMessageReceive_DequeueMessage_Call) Return(queueMessageEnvelope redis.QueueMessageEnvelope, err error) *IPCMessageReceive_DequeueMessage_Call

func (*IPCMessageReceive_DequeueMessage_Call) Run 

func (_c *IPCMessageReceive_DequeueMessage_Call) Run(run func(ctx context.Context, blocking bool, maxWait *time.Duration)) *IPCMessageReceive_DequeueMessage_Call

func (*IPCMessageReceive_DequeueMessage_Call) RunAndReturn 

func (_c *IPCMessageReceive_DequeueMessage_Call) RunAndReturn(run func(ctx context.Context, blocking bool, maxWait *time.Duration) (redis.QueueMessageEnvelope, error)) *IPCMessageReceive_DequeueMessage_Call

type IPCMessageReceive_Expecter 

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

func (*IPCMessageReceive_Expecter) DeleteBufferedMessage 

func (_e *IPCMessageReceive_Expecter) DeleteBufferedMessage(ctx interface{}, msg interface{}) *IPCMessageReceive_DeleteBufferedMessage_Call

DeleteBufferedMessage is a helper method to define mock.On call

  • ctx context.Context
  • msg redis.QueueMessageEnvelope

func (*IPCMessageReceive_Expecter) DequeueBufferedMessage 

func (_e *IPCMessageReceive_Expecter) DequeueBufferedMessage(ctx interface{}, blocking interface{}, maxWait interface{}) *IPCMessageReceive_DequeueBufferedMessage_Call

DequeueBufferedMessage is a helper method to define mock.On call

  • ctx context.Context
  • blocking bool
  • maxWait *time.Duration

func (*IPCMessageReceive_Expecter) DequeueMessage 

func (_e *IPCMessageReceive_Expecter) DequeueMessage(ctx interface{}, blocking interface{}, maxWait interface{}) *IPCMessageReceive_DequeueMessage_Call

DequeueMessage is a helper method to define mock.On call

  • ctx context.Context
  • blocking bool
  • maxWait *time.Duration

func (*IPCMessageReceive_Expecter) ReEnqueueOnMainQueue 

func (_e *IPCMessageReceive_Expecter) ReEnqueueOnMainQueue(ctx interface{}, msg interface{}) *IPCMessageReceive_ReEnqueueOnMainQueue_Call

ReEnqueueOnMainQueue is a helper method to define mock.On call

  • ctx context.Context
  • msg redis.QueueMessageEnvelope

type IPCMessageReceive_ReEnqueueOnMainQueue_Call 

type IPCMessageReceive_ReEnqueueOnMainQueue_Call struct {
	*mock.Call
}

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

func (*IPCMessageReceive_ReEnqueueOnMainQueue_Call) Return 

func (_c *IPCMessageReceive_ReEnqueueOnMainQueue_Call) Return(err error) *IPCMessageReceive_ReEnqueueOnMainQueue_Call

func (*IPCMessageReceive_ReEnqueueOnMainQueue_Call) Run 

func (_c *IPCMessageReceive_ReEnqueueOnMainQueue_Call) Run(run func(ctx context.Context, msg redis.QueueMessageEnvelope)) *IPCMessageReceive_ReEnqueueOnMainQueue_Call

func (*IPCMessageReceive_ReEnqueueOnMainQueue_Call) RunAndReturn 

func (_c *IPCMessageReceive_ReEnqueueOnMainQueue_Call) RunAndReturn(run func(ctx context.Context, msg redis.QueueMessageEnvelope) error) *IPCMessageReceive_ReEnqueueOnMainQueue_Call

type IPCMessageSend 

type IPCMessageSend struct {
	mock.Mock
}

IPCMessageSend is an autogenerated mock type for the IPCMessageSend type

func NewIPCMessageSend 

func NewIPCMessageSend(t interface {
	mock.TestingT
	Cleanup(func())
}) *IPCMessageSend

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

func (_m *IPCMessageSend) EXPECT() *IPCMessageSend_Expecter

func (*IPCMessageSend) EnqueueMessage 

func (_mock *IPCMessageSend) EnqueueMessage(ctx context.Context, msg redis.QueueMessageEnvelope) error

EnqueueMessage provides a mock function for the type IPCMessageSend

type IPCMessageSend_EnqueueMessage_Call 

type IPCMessageSend_EnqueueMessage_Call struct {
	*mock.Call
}

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

func (*IPCMessageSend_EnqueueMessage_Call) Return 

func (_c *IPCMessageSend_EnqueueMessage_Call) Return(err error) *IPCMessageSend_EnqueueMessage_Call

func (*IPCMessageSend_EnqueueMessage_Call) Run 

func (_c *IPCMessageSend_EnqueueMessage_Call) Run(run func(ctx context.Context, msg redis.QueueMessageEnvelope)) *IPCMessageSend_EnqueueMessage_Call

func (*IPCMessageSend_EnqueueMessage_Call) RunAndReturn 

func (_c *IPCMessageSend_EnqueueMessage_Call) RunAndReturn(run func(ctx context.Context, msg redis.QueueMessageEnvelope) error) *IPCMessageSend_EnqueueMessage_Call

type IPCMessageSend_Expecter 

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

func (*IPCMessageSend_Expecter) EnqueueMessage 

func (_e *IPCMessageSend_Expecter) EnqueueMessage(ctx interface{}, msg interface{}) *IPCMessageSend_EnqueueMessage_Call

EnqueueMessage is a helper method to define mock.On call

  • ctx context.Context
  • msg redis.QueueMessageEnvelope

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.