mocktest

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Jul 14, 2026 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ForTextSessionManager 

type ForTextSessionManager struct {
	mock.Mock
}

ForTextSessionManager is an autogenerated mock type for the ForTextSessionManager type

func NewForTextSessionManager 

func NewForTextSessionManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *ForTextSessionManager

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

func (_m *ForTextSessionManager) EXPECT() *ForTextSessionManager_Expecter

func (*ForTextSessionManager) IPCProcessErrorNotify 

func (_mock *ForTextSessionManager) IPCProcessErrorNotify(err error)

IPCProcessErrorNotify provides a mock function for the type ForTextSessionManager

func (*ForTextSessionManager) SessionIdleNotify 

func (_mock *ForTextSessionManager) SessionIdleNotify()

SessionIdleNotify provides a mock function for the type ForTextSessionManager

type ForTextSessionManager_Expecter 

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

func (*ForTextSessionManager_Expecter) IPCProcessErrorNotify 

func (_e *ForTextSessionManager_Expecter) IPCProcessErrorNotify(err interface{}) *ForTextSessionManager_IPCProcessErrorNotify_Call

IPCProcessErrorNotify is a helper method to define mock.On call

  • err error

func (*ForTextSessionManager_Expecter) SessionIdleNotify 

func (_e *ForTextSessionManager_Expecter) SessionIdleNotify() *ForTextSessionManager_SessionIdleNotify_Call

SessionIdleNotify is a helper method to define mock.On call

type ForTextSessionManager_IPCProcessErrorNotify_Call 

type ForTextSessionManager_IPCProcessErrorNotify_Call struct {
	*mock.Call
}

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

func (*ForTextSessionManager_IPCProcessErrorNotify_Call) Return 

func (_c *ForTextSessionManager_IPCProcessErrorNotify_Call) Return() *ForTextSessionManager_IPCProcessErrorNotify_Call

func (*ForTextSessionManager_IPCProcessErrorNotify_Call) Run 

func (_c *ForTextSessionManager_IPCProcessErrorNotify_Call) Run(run func(err error)) *ForTextSessionManager_IPCProcessErrorNotify_Call

func (*ForTextSessionManager_IPCProcessErrorNotify_Call) RunAndReturn 

func (_c *ForTextSessionManager_IPCProcessErrorNotify_Call) RunAndReturn(run func(err error)) *ForTextSessionManager_IPCProcessErrorNotify_Call

type ForTextSessionManager_SessionIdleNotify_Call 

type ForTextSessionManager_SessionIdleNotify_Call struct {
	*mock.Call
}

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

func (*ForTextSessionManager_SessionIdleNotify_Call) Return 

func (_c *ForTextSessionManager_SessionIdleNotify_Call) Return() *ForTextSessionManager_SessionIdleNotify_Call

func (*ForTextSessionManager_SessionIdleNotify_Call) Run 

func (_c *ForTextSessionManager_SessionIdleNotify_Call) Run(run func()) *ForTextSessionManager_SessionIdleNotify_Call

func (*ForTextSessionManager_SessionIdleNotify_Call) RunAndReturn 

func (_c *ForTextSessionManager_SessionIdleNotify_Call) RunAndReturn(run func()) *ForTextSessionManager_SessionIdleNotify_Call

type RedisBufferForTest 

type RedisBufferForTest struct {
	mock.Mock
}

RedisBufferForTest is an autogenerated mock type for the RedisBufferForTest type

func NewRedisBufferForTest 

func NewRedisBufferForTest(t interface {
	mock.TestingT
	Cleanup(func())
}) *RedisBufferForTest

NewRedisBufferForTest creates a new instance of RedisBufferForTest. 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 (*RedisBufferForTest) AsReadWriteCloser 

func (_mock *RedisBufferForTest) AsReadWriteCloser(parentCtx context.Context, initReadOffset int64, dataCheckInt time.Duration) io.ReadWriteCloser

AsReadWriteCloser provides a mock function for the type RedisBufferForTest

func (*RedisBufferForTest) EXPECT 

func (_m *RedisBufferForTest) EXPECT() *RedisBufferForTest_Expecter

func (*RedisBufferForTest) ReadAt 

func (_mock *RedisBufferForTest) ReadAt(ctx context.Context, buf []byte, offset int64) (int64, int, int64, error)

ReadAt provides a mock function for the type RedisBufferForTest

func (*RedisBufferForTest) ReadNewest 

func (_mock *RedisBufferForTest) ReadNewest(ctx context.Context, buf []byte) (int64, int, int64, error)

ReadNewest provides a mock function for the type RedisBufferForTest

func (*RedisBufferForTest) Total 

func (_mock *RedisBufferForTest) Total(ctx context.Context) (int64, error)

Total provides a mock function for the type RedisBufferForTest

func (*RedisBufferForTest) Write 

func (_mock *RedisBufferForTest) Write(ctx context.Context, data []byte) (int64, error)

Write provides a mock function for the type RedisBufferForTest

type RedisBufferForTest_AsReadWriteCloser_Call 

type RedisBufferForTest_AsReadWriteCloser_Call struct {
	*mock.Call
}

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

func (*RedisBufferForTest_AsReadWriteCloser_Call) Return 

func (_c *RedisBufferForTest_AsReadWriteCloser_Call) Return(readWriteCloser io.ReadWriteCloser) *RedisBufferForTest_AsReadWriteCloser_Call

func (*RedisBufferForTest_AsReadWriteCloser_Call) Run 

func (_c *RedisBufferForTest_AsReadWriteCloser_Call) Run(run func(parentCtx context.Context, initReadOffset int64, dataCheckInt time.Duration)) *RedisBufferForTest_AsReadWriteCloser_Call

func (*RedisBufferForTest_AsReadWriteCloser_Call) RunAndReturn 

func (_c *RedisBufferForTest_AsReadWriteCloser_Call) RunAndReturn(run func(parentCtx context.Context, initReadOffset int64, dataCheckInt time.Duration) io.ReadWriteCloser) *RedisBufferForTest_AsReadWriteCloser_Call

type RedisBufferForTest_Expecter 

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

func (*RedisBufferForTest_Expecter) AsReadWriteCloser 

func (_e *RedisBufferForTest_Expecter) AsReadWriteCloser(parentCtx interface{}, initReadOffset interface{}, dataCheckInt interface{}) *RedisBufferForTest_AsReadWriteCloser_Call

AsReadWriteCloser is a helper method to define mock.On call

  • parentCtx context.Context
  • initReadOffset int64
  • dataCheckInt time.Duration

func (*RedisBufferForTest_Expecter) ReadAt 

func (_e *RedisBufferForTest_Expecter) ReadAt(ctx interface{}, buf interface{}, offset interface{}) *RedisBufferForTest_ReadAt_Call

ReadAt is a helper method to define mock.On call

  • ctx context.Context
  • buf []byte
  • offset int64

func (*RedisBufferForTest_Expecter) ReadNewest 

func (_e *RedisBufferForTest_Expecter) ReadNewest(ctx interface{}, buf interface{}) *RedisBufferForTest_ReadNewest_Call

ReadNewest is a helper method to define mock.On call

  • ctx context.Context
  • buf []byte

func (*RedisBufferForTest_Expecter) Total 

func (_e *RedisBufferForTest_Expecter) Total(ctx interface{}) *RedisBufferForTest_Total_Call

Total is a helper method to define mock.On call

  • ctx context.Context

func (*RedisBufferForTest_Expecter) Write 

func (_e *RedisBufferForTest_Expecter) Write(ctx interface{}, data interface{}) *RedisBufferForTest_Write_Call

Write is a helper method to define mock.On call

  • ctx context.Context
  • data []byte

type RedisBufferForTest_ReadAt_Call 

type RedisBufferForTest_ReadAt_Call struct {
	*mock.Call
}

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

func (*RedisBufferForTest_ReadAt_Call) Return 

func (_c *RedisBufferForTest_ReadAt_Call) Return(n int64, n1 int, n2 int64, err error) *RedisBufferForTest_ReadAt_Call

func (*RedisBufferForTest_ReadAt_Call) Run 

func (_c *RedisBufferForTest_ReadAt_Call) Run(run func(ctx context.Context, buf []byte, offset int64)) *RedisBufferForTest_ReadAt_Call

func (*RedisBufferForTest_ReadAt_Call) RunAndReturn 

func (_c *RedisBufferForTest_ReadAt_Call) RunAndReturn(run func(ctx context.Context, buf []byte, offset int64) (int64, int, int64, error)) *RedisBufferForTest_ReadAt_Call

type RedisBufferForTest_ReadNewest_Call 

type RedisBufferForTest_ReadNewest_Call struct {
	*mock.Call
}

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

func (*RedisBufferForTest_ReadNewest_Call) Return 

func (_c *RedisBufferForTest_ReadNewest_Call) Return(n int64, n1 int, n2 int64, err error) *RedisBufferForTest_ReadNewest_Call

func (*RedisBufferForTest_ReadNewest_Call) Run 

func (_c *RedisBufferForTest_ReadNewest_Call) Run(run func(ctx context.Context, buf []byte)) *RedisBufferForTest_ReadNewest_Call

func (*RedisBufferForTest_ReadNewest_Call) RunAndReturn 

func (_c *RedisBufferForTest_ReadNewest_Call) RunAndReturn(run func(ctx context.Context, buf []byte) (int64, int, int64, error)) *RedisBufferForTest_ReadNewest_Call

type RedisBufferForTest_Total_Call 

type RedisBufferForTest_Total_Call struct {
	*mock.Call
}

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

func (*RedisBufferForTest_Total_Call) Return 

func (_c *RedisBufferForTest_Total_Call) Return(n int64, err error) *RedisBufferForTest_Total_Call

func (*RedisBufferForTest_Total_Call) Run 

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

func (*RedisBufferForTest_Total_Call) RunAndReturn 

func (_c *RedisBufferForTest_Total_Call) RunAndReturn(run func(ctx context.Context) (int64, error)) *RedisBufferForTest_Total_Call

type RedisBufferForTest_Write_Call 

type RedisBufferForTest_Write_Call struct {
	*mock.Call
}

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

func (*RedisBufferForTest_Write_Call) Return 

func (_c *RedisBufferForTest_Write_Call) Return(n int64, err error) *RedisBufferForTest_Write_Call

func (*RedisBufferForTest_Write_Call) Run 

func (_c *RedisBufferForTest_Write_Call) Run(run func(ctx context.Context, data []byte)) *RedisBufferForTest_Write_Call

func (*RedisBufferForTest_Write_Call) RunAndReturn 

func (_c *RedisBufferForTest_Write_Call) RunAndReturn(run func(ctx context.Context, data []byte) (int64, error)) *RedisBufferForTest_Write_Call

type RedisClientForTest 

type RedisClientForTest struct {
	mock.Mock
}

RedisClientForTest is an autogenerated mock type for the RedisClientForTest type

func NewRedisClientForTest 

func NewRedisClientForTest(t interface {
	mock.TestingT
	Cleanup(func())
}) *RedisClientForTest

NewRedisClientForTest creates a new instance of RedisClientForTest. 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 (*RedisClientForTest) DeleteQueue 

func (_mock *RedisClientForTest) DeleteQueue(ctx context.Context, queueName string) error

DeleteQueue provides a mock function for the type RedisClientForTest

func (*RedisClientForTest) DeleteRingBuffer 

func (_mock *RedisClientForTest) DeleteRingBuffer(ctx context.Context, bufferName string) error

DeleteRingBuffer provides a mock function for the type RedisClientForTest

func (*RedisClientForTest) EXPECT 

func (_m *RedisClientForTest) EXPECT() *RedisClientForTest_Expecter

func (*RedisClientForTest) GetQueueHandle 

func (_mock *RedisClientForTest) GetQueueHandle(ctx context.Context, queueName string) (redis.Queue, error)

GetQueueHandle provides a mock function for the type RedisClientForTest

func (*RedisClientForTest) GetRingBuffer 

func (_mock *RedisClientForTest) GetRingBuffer(ctx context.Context, bufferName string, capacity int64) (redis.RingBuffer, error)

GetRingBuffer provides a mock function for the type RedisClientForTest

type RedisClientForTest_DeleteQueue_Call 

type RedisClientForTest_DeleteQueue_Call struct {
	*mock.Call
}

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

func (*RedisClientForTest_DeleteQueue_Call) Return 

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

func (*RedisClientForTest_DeleteQueue_Call) Run 

func (_c *RedisClientForTest_DeleteQueue_Call) Run(run func(ctx context.Context, queueName string)) *RedisClientForTest_DeleteQueue_Call

func (*RedisClientForTest_DeleteQueue_Call) RunAndReturn 

func (_c *RedisClientForTest_DeleteQueue_Call) RunAndReturn(run func(ctx context.Context, queueName string) error) *RedisClientForTest_DeleteQueue_Call

type RedisClientForTest_DeleteRingBuffer_Call 

type RedisClientForTest_DeleteRingBuffer_Call struct {
	*mock.Call
}

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

func (*RedisClientForTest_DeleteRingBuffer_Call) Return 

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

func (*RedisClientForTest_DeleteRingBuffer_Call) Run 

func (_c *RedisClientForTest_DeleteRingBuffer_Call) Run(run func(ctx context.Context, bufferName string)) *RedisClientForTest_DeleteRingBuffer_Call

func (*RedisClientForTest_DeleteRingBuffer_Call) RunAndReturn 

func (_c *RedisClientForTest_DeleteRingBuffer_Call) RunAndReturn(run func(ctx context.Context, bufferName string) error) *RedisClientForTest_DeleteRingBuffer_Call

type RedisClientForTest_Expecter 

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

func (*RedisClientForTest_Expecter) DeleteQueue 

func (_e *RedisClientForTest_Expecter) DeleteQueue(ctx interface{}, queueName interface{}) *RedisClientForTest_DeleteQueue_Call

DeleteQueue is a helper method to define mock.On call

  • ctx context.Context
  • queueName string

func (*RedisClientForTest_Expecter) DeleteRingBuffer 

func (_e *RedisClientForTest_Expecter) DeleteRingBuffer(ctx interface{}, bufferName interface{}) *RedisClientForTest_DeleteRingBuffer_Call

DeleteRingBuffer is a helper method to define mock.On call

  • ctx context.Context
  • bufferName string

func (*RedisClientForTest_Expecter) GetQueueHandle 

func (_e *RedisClientForTest_Expecter) GetQueueHandle(ctx interface{}, queueName interface{}) *RedisClientForTest_GetQueueHandle_Call

GetQueueHandle is a helper method to define mock.On call

  • ctx context.Context
  • queueName string

func (*RedisClientForTest_Expecter) GetRingBuffer 

func (_e *RedisClientForTest_Expecter) GetRingBuffer(ctx interface{}, bufferName interface{}, capacity interface{}) *RedisClientForTest_GetRingBuffer_Call

GetRingBuffer is a helper method to define mock.On call

  • ctx context.Context
  • bufferName string
  • capacity int64

type RedisClientForTest_GetQueueHandle_Call 

type RedisClientForTest_GetQueueHandle_Call struct {
	*mock.Call
}

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

func (*RedisClientForTest_GetQueueHandle_Call) Return 

func (_c *RedisClientForTest_GetQueueHandle_Call) Return(queue redis.Queue, err error) *RedisClientForTest_GetQueueHandle_Call

func (*RedisClientForTest_GetQueueHandle_Call) Run 

func (_c *RedisClientForTest_GetQueueHandle_Call) Run(run func(ctx context.Context, queueName string)) *RedisClientForTest_GetQueueHandle_Call

func (*RedisClientForTest_GetQueueHandle_Call) RunAndReturn 

func (_c *RedisClientForTest_GetQueueHandle_Call) RunAndReturn(run func(ctx context.Context, queueName string) (redis.Queue, error)) *RedisClientForTest_GetQueueHandle_Call

type RedisClientForTest_GetRingBuffer_Call 

type RedisClientForTest_GetRingBuffer_Call struct {
	*mock.Call
}

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

func (*RedisClientForTest_GetRingBuffer_Call) Return 

func (_c *RedisClientForTest_GetRingBuffer_Call) Return(ringBuffer redis.RingBuffer, err error) *RedisClientForTest_GetRingBuffer_Call

func (*RedisClientForTest_GetRingBuffer_Call) Run 

func (_c *RedisClientForTest_GetRingBuffer_Call) Run(run func(ctx context.Context, bufferName string, capacity int64)) *RedisClientForTest_GetRingBuffer_Call

func (*RedisClientForTest_GetRingBuffer_Call) RunAndReturn 

func (_c *RedisClientForTest_GetRingBuffer_Call) RunAndReturn(run func(ctx context.Context, bufferName string, capacity int64) (redis.RingBuffer, error)) *RedisClientForTest_GetRingBuffer_Call

type RedisQueueForTest 

type RedisQueueForTest struct {
	mock.Mock
}

RedisQueueForTest is an autogenerated mock type for the RedisQueueForTest type

func NewRedisQueueForTest 

func NewRedisQueueForTest(t interface {
	mock.TestingT
	Cleanup(func())
}) *RedisQueueForTest

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

func (_m *RedisQueueForTest) EXPECT() *RedisQueueForTest_Expecter

func (*RedisQueueForTest) Length 

func (_mock *RedisQueueForTest) Length(ctx context.Context) (uint64, error)

Length provides a mock function for the type RedisQueueForTest

func (*RedisQueueForTest) PeakLeft 

func (_mock *RedisQueueForTest) PeakLeft(ctx context.Context) (redis.QueueMessageEnvelope, error)

PeakLeft provides a mock function for the type RedisQueueForTest

func (*RedisQueueForTest) PeakRight 

func (_mock *RedisQueueForTest) PeakRight(ctx context.Context) (redis.QueueMessageEnvelope, error)

PeakRight provides a mock function for the type RedisQueueForTest

func (*RedisQueueForTest) PopLeft 

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

PopLeft provides a mock function for the type RedisQueueForTest

func (*RedisQueueForTest) PopLeftAndMove 

func (_mock *RedisQueueForTest) PopLeftAndMove(ctx context.Context, destination string, insertOnLeft bool, blocking bool, maxWait *time.Duration) (redis.QueueMessageEnvelope, error)

PopLeftAndMove provides a mock function for the type RedisQueueForTest

func (*RedisQueueForTest) PopRight 

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

PopRight provides a mock function for the type RedisQueueForTest

func (*RedisQueueForTest) PopRightAndMove 

func (_mock *RedisQueueForTest) PopRightAndMove(ctx context.Context, destination string, insertOnLeft bool, blocking bool, maxWait *time.Duration) (redis.QueueMessageEnvelope, error)

PopRightAndMove provides a mock function for the type RedisQueueForTest

func (*RedisQueueForTest) PushLeft 

func (_mock *RedisQueueForTest) PushLeft(ctx context.Context, message redis.QueueMessageEnvelope, ttl *time.Duration) (uint64, error)

PushLeft provides a mock function for the type RedisQueueForTest

func (*RedisQueueForTest) PushRight 

func (_mock *RedisQueueForTest) PushRight(ctx context.Context, message redis.QueueMessageEnvelope, ttl *time.Duration) (uint64, error)

PushRight provides a mock function for the type RedisQueueForTest

func (*RedisQueueForTest) QueueName 

func (_mock *RedisQueueForTest) QueueName() string

QueueName provides a mock function for the type RedisQueueForTest

func (*RedisQueueForTest) Remove 

func (_mock *RedisQueueForTest) Remove(ctx context.Context, message redis.QueueMessageEnvelope) error

Remove provides a mock function for the type RedisQueueForTest

type RedisQueueForTest_Expecter 

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

func (*RedisQueueForTest_Expecter) Length 

func (_e *RedisQueueForTest_Expecter) Length(ctx interface{}) *RedisQueueForTest_Length_Call

Length is a helper method to define mock.On call

  • ctx context.Context

func (*RedisQueueForTest_Expecter) PeakLeft 

func (_e *RedisQueueForTest_Expecter) PeakLeft(ctx interface{}) *RedisQueueForTest_PeakLeft_Call

PeakLeft is a helper method to define mock.On call

  • ctx context.Context

func (*RedisQueueForTest_Expecter) PeakRight 

func (_e *RedisQueueForTest_Expecter) PeakRight(ctx interface{}) *RedisQueueForTest_PeakRight_Call

PeakRight is a helper method to define mock.On call

  • ctx context.Context

func (*RedisQueueForTest_Expecter) PopLeft 

func (_e *RedisQueueForTest_Expecter) PopLeft(ctx interface{}, blocking interface{}, maxWait interface{}) *RedisQueueForTest_PopLeft_Call

PopLeft is a helper method to define mock.On call

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

func (*RedisQueueForTest_Expecter) PopLeftAndMove 

func (_e *RedisQueueForTest_Expecter) PopLeftAndMove(ctx interface{}, destination interface{}, insertOnLeft interface{}, blocking interface{}, maxWait interface{}) *RedisQueueForTest_PopLeftAndMove_Call

PopLeftAndMove is a helper method to define mock.On call

  • ctx context.Context
  • destination string
  • insertOnLeft bool
  • blocking bool
  • maxWait *time.Duration

func (*RedisQueueForTest_Expecter) PopRight 

func (_e *RedisQueueForTest_Expecter) PopRight(ctx interface{}, blocking interface{}, maxWait interface{}) *RedisQueueForTest_PopRight_Call

PopRight is a helper method to define mock.On call

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

func (*RedisQueueForTest_Expecter) PopRightAndMove 

func (_e *RedisQueueForTest_Expecter) PopRightAndMove(ctx interface{}, destination interface{}, insertOnLeft interface{}, blocking interface{}, maxWait interface{}) *RedisQueueForTest_PopRightAndMove_Call

PopRightAndMove is a helper method to define mock.On call

  • ctx context.Context
  • destination string
  • insertOnLeft bool
  • blocking bool
  • maxWait *time.Duration

func (*RedisQueueForTest_Expecter) PushLeft 

func (_e *RedisQueueForTest_Expecter) PushLeft(ctx interface{}, message interface{}, ttl interface{}) *RedisQueueForTest_PushLeft_Call

PushLeft is a helper method to define mock.On call

  • ctx context.Context
  • message redis.QueueMessageEnvelope
  • ttl *time.Duration

func (*RedisQueueForTest_Expecter) PushRight 

func (_e *RedisQueueForTest_Expecter) PushRight(ctx interface{}, message interface{}, ttl interface{}) *RedisQueueForTest_PushRight_Call

PushRight is a helper method to define mock.On call

  • ctx context.Context
  • message redis.QueueMessageEnvelope
  • ttl *time.Duration

func (*RedisQueueForTest_Expecter) QueueName 

func (_e *RedisQueueForTest_Expecter) QueueName() *RedisQueueForTest_QueueName_Call

QueueName is a helper method to define mock.On call

func (*RedisQueueForTest_Expecter) Remove 

func (_e *RedisQueueForTest_Expecter) Remove(ctx interface{}, message interface{}) *RedisQueueForTest_Remove_Call

Remove is a helper method to define mock.On call

  • ctx context.Context
  • message redis.QueueMessageEnvelope

type RedisQueueForTest_Length_Call 

type RedisQueueForTest_Length_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_Length_Call) Return 

func (_c *RedisQueueForTest_Length_Call) Return(v uint64, err error) *RedisQueueForTest_Length_Call

func (*RedisQueueForTest_Length_Call) Run 

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

func (*RedisQueueForTest_Length_Call) RunAndReturn 

func (_c *RedisQueueForTest_Length_Call) RunAndReturn(run func(ctx context.Context) (uint64, error)) *RedisQueueForTest_Length_Call

type RedisQueueForTest_PeakLeft_Call 

type RedisQueueForTest_PeakLeft_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_PeakLeft_Call) Return 

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

func (*RedisQueueForTest_PeakLeft_Call) Run 

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

func (*RedisQueueForTest_PeakLeft_Call) RunAndReturn 

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

type RedisQueueForTest_PeakRight_Call 

type RedisQueueForTest_PeakRight_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_PeakRight_Call) Return 

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

func (*RedisQueueForTest_PeakRight_Call) Run 

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

func (*RedisQueueForTest_PeakRight_Call) RunAndReturn 

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

type RedisQueueForTest_PopLeftAndMove_Call 

type RedisQueueForTest_PopLeftAndMove_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_PopLeftAndMove_Call) Return 

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

func (*RedisQueueForTest_PopLeftAndMove_Call) Run 

func (_c *RedisQueueForTest_PopLeftAndMove_Call) Run(run func(ctx context.Context, destination string, insertOnLeft bool, blocking bool, maxWait *time.Duration)) *RedisQueueForTest_PopLeftAndMove_Call

func (*RedisQueueForTest_PopLeftAndMove_Call) RunAndReturn 

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

type RedisQueueForTest_PopLeft_Call 

type RedisQueueForTest_PopLeft_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_PopLeft_Call) Return 

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

func (*RedisQueueForTest_PopLeft_Call) Run 

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

func (*RedisQueueForTest_PopLeft_Call) RunAndReturn 

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

type RedisQueueForTest_PopRightAndMove_Call 

type RedisQueueForTest_PopRightAndMove_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_PopRightAndMove_Call) Return 

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

func (*RedisQueueForTest_PopRightAndMove_Call) Run 

func (_c *RedisQueueForTest_PopRightAndMove_Call) Run(run func(ctx context.Context, destination string, insertOnLeft bool, blocking bool, maxWait *time.Duration)) *RedisQueueForTest_PopRightAndMove_Call

func (*RedisQueueForTest_PopRightAndMove_Call) RunAndReturn 

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

type RedisQueueForTest_PopRight_Call 

type RedisQueueForTest_PopRight_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_PopRight_Call) Return 

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

func (*RedisQueueForTest_PopRight_Call) Run 

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

func (*RedisQueueForTest_PopRight_Call) RunAndReturn 

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

type RedisQueueForTest_PushLeft_Call 

type RedisQueueForTest_PushLeft_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_PushLeft_Call) Return 

func (_c *RedisQueueForTest_PushLeft_Call) Return(v uint64, err error) *RedisQueueForTest_PushLeft_Call

func (*RedisQueueForTest_PushLeft_Call) Run 

func (_c *RedisQueueForTest_PushLeft_Call) Run(run func(ctx context.Context, message redis.QueueMessageEnvelope, ttl *time.Duration)) *RedisQueueForTest_PushLeft_Call

func (*RedisQueueForTest_PushLeft_Call) RunAndReturn 

func (_c *RedisQueueForTest_PushLeft_Call) RunAndReturn(run func(ctx context.Context, message redis.QueueMessageEnvelope, ttl *time.Duration) (uint64, error)) *RedisQueueForTest_PushLeft_Call

type RedisQueueForTest_PushRight_Call 

type RedisQueueForTest_PushRight_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_PushRight_Call) Return 

func (_c *RedisQueueForTest_PushRight_Call) Return(v uint64, err error) *RedisQueueForTest_PushRight_Call

func (*RedisQueueForTest_PushRight_Call) Run 

func (_c *RedisQueueForTest_PushRight_Call) Run(run func(ctx context.Context, message redis.QueueMessageEnvelope, ttl *time.Duration)) *RedisQueueForTest_PushRight_Call

func (*RedisQueueForTest_PushRight_Call) RunAndReturn 

func (_c *RedisQueueForTest_PushRight_Call) RunAndReturn(run func(ctx context.Context, message redis.QueueMessageEnvelope, ttl *time.Duration) (uint64, error)) *RedisQueueForTest_PushRight_Call

type RedisQueueForTest_QueueName_Call 

type RedisQueueForTest_QueueName_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_QueueName_Call) Return 

func (_c *RedisQueueForTest_QueueName_Call) Return(s string) *RedisQueueForTest_QueueName_Call

func (*RedisQueueForTest_QueueName_Call) Run 

func (_c *RedisQueueForTest_QueueName_Call) Run(run func()) *RedisQueueForTest_QueueName_Call

func (*RedisQueueForTest_QueueName_Call) RunAndReturn 

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

type RedisQueueForTest_Remove_Call 

type RedisQueueForTest_Remove_Call struct {
	*mock.Call
}

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

func (*RedisQueueForTest_Remove_Call) Return 

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

func (*RedisQueueForTest_Remove_Call) Run 

func (_c *RedisQueueForTest_Remove_Call) Run(run func(ctx context.Context, message redis.QueueMessageEnvelope)) *RedisQueueForTest_Remove_Call

func (*RedisQueueForTest_Remove_Call) RunAndReturn 

func (_c *RedisQueueForTest_Remove_Call) RunAndReturn(run func(ctx context.Context, message redis.QueueMessageEnvelope) error) *RedisQueueForTest_Remove_Call

type TaskProcessorForTest 

type TaskProcessorForTest struct {
	mock.Mock
}

TaskProcessorForTest is an autogenerated mock type for the TaskProcessorForTest type

func NewTaskProcessorForTest 

func NewTaskProcessorForTest(t interface {
	mock.TestingT
	Cleanup(func())
}) *TaskProcessorForTest

NewTaskProcessorForTest creates a new instance of TaskProcessorForTest. 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 (*TaskProcessorForTest) AddToTaskExecutionMap 

func (_mock *TaskProcessorForTest) AddToTaskExecutionMap(parameterType reflect.Type, handler goutils.TaskProcessorSupportHandler) error

AddToTaskExecutionMap provides a mock function for the type TaskProcessorForTest

func (*TaskProcessorForTest) EXPECT 

func (_m *TaskProcessorForTest) EXPECT() *TaskProcessorForTest_Expecter

func (*TaskProcessorForTest) SetTaskExecutionMap 

func (_mock *TaskProcessorForTest) SetTaskExecutionMap(newMap map[reflect.Type]goutils.TaskProcessorSupportHandler) error

SetTaskExecutionMap provides a mock function for the type TaskProcessorForTest

func (*TaskProcessorForTest) StartEventLoop 

func (_mock *TaskProcessorForTest) StartEventLoop(wg *sync.WaitGroup) error

StartEventLoop provides a mock function for the type TaskProcessorForTest

func (*TaskProcessorForTest) StopEventLoop 

func (_mock *TaskProcessorForTest) StopEventLoop() error

StopEventLoop provides a mock function for the type TaskProcessorForTest

func (*TaskProcessorForTest) Submit 

func (_mock *TaskProcessorForTest) Submit(ctx context.Context, newTaskParam interface{}) error

Submit provides a mock function for the type TaskProcessorForTest

type TaskProcessorForTest_AddToTaskExecutionMap_Call 

type TaskProcessorForTest_AddToTaskExecutionMap_Call struct {
	*mock.Call
}

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

func (*TaskProcessorForTest_AddToTaskExecutionMap_Call) Return 

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

func (*TaskProcessorForTest_AddToTaskExecutionMap_Call) Run 

func (_c *TaskProcessorForTest_AddToTaskExecutionMap_Call) Run(run func(parameterType reflect.Type, handler goutils.TaskProcessorSupportHandler)) *TaskProcessorForTest_AddToTaskExecutionMap_Call

func (*TaskProcessorForTest_AddToTaskExecutionMap_Call) RunAndReturn 

func (_c *TaskProcessorForTest_AddToTaskExecutionMap_Call) RunAndReturn(run func(parameterType reflect.Type, handler goutils.TaskProcessorSupportHandler) error) *TaskProcessorForTest_AddToTaskExecutionMap_Call

type TaskProcessorForTest_Expecter 

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

func (*TaskProcessorForTest_Expecter) AddToTaskExecutionMap 

func (_e *TaskProcessorForTest_Expecter) AddToTaskExecutionMap(parameterType interface{}, handler interface{}) *TaskProcessorForTest_AddToTaskExecutionMap_Call

AddToTaskExecutionMap is a helper method to define mock.On call

  • parameterType reflect.Type
  • handler goutils.TaskProcessorSupportHandler

func (*TaskProcessorForTest_Expecter) SetTaskExecutionMap 

func (_e *TaskProcessorForTest_Expecter) SetTaskExecutionMap(newMap interface{}) *TaskProcessorForTest_SetTaskExecutionMap_Call

SetTaskExecutionMap is a helper method to define mock.On call

  • newMap map[reflect.Type]goutils.TaskProcessorSupportHandler

func (*TaskProcessorForTest_Expecter) StartEventLoop 

func (_e *TaskProcessorForTest_Expecter) StartEventLoop(wg interface{}) *TaskProcessorForTest_StartEventLoop_Call

StartEventLoop is a helper method to define mock.On call

  • wg *sync.WaitGroup

func (*TaskProcessorForTest_Expecter) StopEventLoop 

func (_e *TaskProcessorForTest_Expecter) StopEventLoop() *TaskProcessorForTest_StopEventLoop_Call

StopEventLoop is a helper method to define mock.On call

func (*TaskProcessorForTest_Expecter) Submit 

func (_e *TaskProcessorForTest_Expecter) Submit(ctx interface{}, newTaskParam interface{}) *TaskProcessorForTest_Submit_Call

Submit is a helper method to define mock.On call

  • ctx context.Context
  • newTaskParam interface{}

type TaskProcessorForTest_SetTaskExecutionMap_Call 

type TaskProcessorForTest_SetTaskExecutionMap_Call struct {
	*mock.Call
}

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

func (*TaskProcessorForTest_SetTaskExecutionMap_Call) Return 

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

func (*TaskProcessorForTest_SetTaskExecutionMap_Call) Run 

func (_c *TaskProcessorForTest_SetTaskExecutionMap_Call) Run(run func(newMap map[reflect.Type]goutils.TaskProcessorSupportHandler)) *TaskProcessorForTest_SetTaskExecutionMap_Call

func (*TaskProcessorForTest_SetTaskExecutionMap_Call) RunAndReturn 

func (_c *TaskProcessorForTest_SetTaskExecutionMap_Call) RunAndReturn(run func(newMap map[reflect.Type]goutils.TaskProcessorSupportHandler) error) *TaskProcessorForTest_SetTaskExecutionMap_Call

type TaskProcessorForTest_StartEventLoop_Call 

type TaskProcessorForTest_StartEventLoop_Call struct {
	*mock.Call
}

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

func (*TaskProcessorForTest_StartEventLoop_Call) Return 

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

func (*TaskProcessorForTest_StartEventLoop_Call) Run 

func (_c *TaskProcessorForTest_StartEventLoop_Call) Run(run func(wg *sync.WaitGroup)) *TaskProcessorForTest_StartEventLoop_Call

func (*TaskProcessorForTest_StartEventLoop_Call) RunAndReturn 

func (_c *TaskProcessorForTest_StartEventLoop_Call) RunAndReturn(run func(wg *sync.WaitGroup) error) *TaskProcessorForTest_StartEventLoop_Call

type TaskProcessorForTest_StopEventLoop_Call 

type TaskProcessorForTest_StopEventLoop_Call struct {
	*mock.Call
}

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

func (*TaskProcessorForTest_StopEventLoop_Call) Return 

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

func (*TaskProcessorForTest_StopEventLoop_Call) Run 

func (_c *TaskProcessorForTest_StopEventLoop_Call) Run(run func()) *TaskProcessorForTest_StopEventLoop_Call

func (*TaskProcessorForTest_StopEventLoop_Call) RunAndReturn 

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

type TaskProcessorForTest_Submit_Call 

type TaskProcessorForTest_Submit_Call struct {
	*mock.Call
}

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

func (*TaskProcessorForTest_Submit_Call) Return 

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

func (*TaskProcessorForTest_Submit_Call) Run 

func (_c *TaskProcessorForTest_Submit_Call) Run(run func(ctx context.Context, newTaskParam interface{})) *TaskProcessorForTest_Submit_Call

func (*TaskProcessorForTest_Submit_Call) RunAndReturn 

func (_c *TaskProcessorForTest_Submit_Call) RunAndReturn(run func(ctx context.Context, newTaskParam interface{}) error) *TaskProcessorForTest_Submit_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.