mocktest

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: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type UnitTestCallbackCollector 

type UnitTestCallbackCollector struct {
	mock.Mock
}

UnitTestCallbackCollector is an autogenerated mock type for the UnitTestCallbackCollector type

func NewUnitTestCallbackCollector 

func NewUnitTestCallbackCollector(t interface {
	mock.TestingT
	Cleanup(func())
}) *UnitTestCallbackCollector

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

func (_m *UnitTestCallbackCollector) EXPECT() *UnitTestCallbackCollector_Expecter

func (*UnitTestCallbackCollector) NewRedisIPCMsgReceiver 

func (_mock *UnitTestCallbackCollector) NewRedisIPCMsgReceiver(ctx context.Context, queueName string, redis1 redis.Client, reader string) (common.IPCMessageReceive, error)

NewRedisIPCMsgReceiver provides a mock function for the type UnitTestCallbackCollector

func (*UnitTestCallbackCollector) NewRedisIPCMsgSender 

func (_mock *UnitTestCallbackCollector) NewRedisIPCMsgSender(ctx context.Context, queueName string, redis1 redis.Client, sender string) (common.IPCMessageSend, error)

NewRedisIPCMsgSender provides a mock function for the type UnitTestCallbackCollector

func (*UnitTestCallbackCollector) NewTaskExecutor 

func (_mock *UnitTestCallbackCollector) NewTaskExecutor(parentCtx context.Context, taskQueue string, workerCount int, requestBufferLen int, support task.ExecutorSupport, processors map[string]models.TaskExecutionProcessor) (task.Executor, error)

NewTaskExecutor provides a mock function for the type UnitTestCallbackCollector

func (*UnitTestCallbackCollector) OnComplete 

func (_mock *UnitTestCallbackCollector) OnComplete(ctx context.Context, instanceID string, err error, timestamp time.Time)

OnComplete provides a mock function for the type UnitTestCallbackCollector

func (*UnitTestCallbackCollector) OnFatal 

func (_mock *UnitTestCallbackCollector) OnFatal(reporter string, err error, timestamp time.Time)

OnFatal provides a mock function for the type UnitTestCallbackCollector

type UnitTestCallbackCollector_Expecter 

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

func (*UnitTestCallbackCollector_Expecter) NewRedisIPCMsgReceiver 

func (_e *UnitTestCallbackCollector_Expecter) NewRedisIPCMsgReceiver(ctx interface{}, queueName interface{}, redis1 interface{}, reader interface{}) *UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call

NewRedisIPCMsgReceiver is a helper method to define mock.On call

  • ctx context.Context
  • queueName string
  • redis1 redis.Client
  • reader string

func (*UnitTestCallbackCollector_Expecter) NewRedisIPCMsgSender 

func (_e *UnitTestCallbackCollector_Expecter) NewRedisIPCMsgSender(ctx interface{}, queueName interface{}, redis1 interface{}, sender interface{}) *UnitTestCallbackCollector_NewRedisIPCMsgSender_Call

NewRedisIPCMsgSender is a helper method to define mock.On call

  • ctx context.Context
  • queueName string
  • redis1 redis.Client
  • sender string

func (*UnitTestCallbackCollector_Expecter) NewTaskExecutor 

func (_e *UnitTestCallbackCollector_Expecter) NewTaskExecutor(parentCtx interface{}, taskQueue interface{}, workerCount interface{}, requestBufferLen interface{}, support interface{}, processors interface{}) *UnitTestCallbackCollector_NewTaskExecutor_Call

NewTaskExecutor is a helper method to define mock.On call

  • parentCtx context.Context
  • taskQueue string
  • workerCount int
  • requestBufferLen int
  • support task.ExecutorSupport
  • processors map[string]models.TaskExecutionProcessor

func (*UnitTestCallbackCollector_Expecter) OnComplete 

func (_e *UnitTestCallbackCollector_Expecter) OnComplete(ctx interface{}, instanceID interface{}, err interface{}, timestamp interface{}) *UnitTestCallbackCollector_OnComplete_Call

OnComplete is a helper method to define mock.On call

  • ctx context.Context
  • instanceID string
  • err error
  • timestamp time.Time

func (*UnitTestCallbackCollector_Expecter) OnFatal 

func (_e *UnitTestCallbackCollector_Expecter) OnFatal(reporter interface{}, err interface{}, timestamp interface{}) *UnitTestCallbackCollector_OnFatal_Call

OnFatal is a helper method to define mock.On call

  • reporter string
  • err error
  • timestamp time.Time

type UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call 

type UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call struct {
	*mock.Call
}

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

func (*UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call) Return 

func (_c *UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call) Return(iPCMessageReceive common.IPCMessageReceive, err error) *UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call

func (*UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call) Run 

func (_c *UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call) Run(run func(ctx context.Context, queueName string, redis1 redis.Client, reader string)) *UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call

func (*UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call) RunAndReturn 

func (_c *UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call) RunAndReturn(run func(ctx context.Context, queueName string, redis1 redis.Client, reader string) (common.IPCMessageReceive, error)) *UnitTestCallbackCollector_NewRedisIPCMsgReceiver_Call

type UnitTestCallbackCollector_NewRedisIPCMsgSender_Call 

type UnitTestCallbackCollector_NewRedisIPCMsgSender_Call struct {
	*mock.Call
}

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

func (*UnitTestCallbackCollector_NewRedisIPCMsgSender_Call) Return 

func (_c *UnitTestCallbackCollector_NewRedisIPCMsgSender_Call) Return(iPCMessageSend common.IPCMessageSend, err error) *UnitTestCallbackCollector_NewRedisIPCMsgSender_Call

func (*UnitTestCallbackCollector_NewRedisIPCMsgSender_Call) Run 

func (_c *UnitTestCallbackCollector_NewRedisIPCMsgSender_Call) Run(run func(ctx context.Context, queueName string, redis1 redis.Client, sender string)) *UnitTestCallbackCollector_NewRedisIPCMsgSender_Call

func (*UnitTestCallbackCollector_NewRedisIPCMsgSender_Call) RunAndReturn 

func (_c *UnitTestCallbackCollector_NewRedisIPCMsgSender_Call) RunAndReturn(run func(ctx context.Context, queueName string, redis1 redis.Client, sender string) (common.IPCMessageSend, error)) *UnitTestCallbackCollector_NewRedisIPCMsgSender_Call

type UnitTestCallbackCollector_NewTaskExecutor_Call 

type UnitTestCallbackCollector_NewTaskExecutor_Call struct {
	*mock.Call
}

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

func (*UnitTestCallbackCollector_NewTaskExecutor_Call) Return 

func (_c *UnitTestCallbackCollector_NewTaskExecutor_Call) Return(executor task.Executor, err error) *UnitTestCallbackCollector_NewTaskExecutor_Call

func (*UnitTestCallbackCollector_NewTaskExecutor_Call) Run 

func (_c *UnitTestCallbackCollector_NewTaskExecutor_Call) Run(run func(parentCtx context.Context, taskQueue string, workerCount int, requestBufferLen int, support task.ExecutorSupport, processors map[string]models.TaskExecutionProcessor)) *UnitTestCallbackCollector_NewTaskExecutor_Call

func (*UnitTestCallbackCollector_NewTaskExecutor_Call) RunAndReturn 

func (_c *UnitTestCallbackCollector_NewTaskExecutor_Call) RunAndReturn(run func(parentCtx context.Context, taskQueue string, workerCount int, requestBufferLen int, support task.ExecutorSupport, processors map[string]models.TaskExecutionProcessor) (task.Executor, error)) *UnitTestCallbackCollector_NewTaskExecutor_Call

type UnitTestCallbackCollector_OnComplete_Call 

type UnitTestCallbackCollector_OnComplete_Call struct {
	*mock.Call
}

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

func (*UnitTestCallbackCollector_OnComplete_Call) Return 

func (_c *UnitTestCallbackCollector_OnComplete_Call) Return() *UnitTestCallbackCollector_OnComplete_Call

func (*UnitTestCallbackCollector_OnComplete_Call) Run 

func (_c *UnitTestCallbackCollector_OnComplete_Call) Run(run func(ctx context.Context, instanceID string, err error, timestamp time.Time)) *UnitTestCallbackCollector_OnComplete_Call

func (*UnitTestCallbackCollector_OnComplete_Call) RunAndReturn 

func (_c *UnitTestCallbackCollector_OnComplete_Call) RunAndReturn(run func(ctx context.Context, instanceID string, err error, timestamp time.Time)) *UnitTestCallbackCollector_OnComplete_Call

type UnitTestCallbackCollector_OnFatal_Call 

type UnitTestCallbackCollector_OnFatal_Call struct {
	*mock.Call
}

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

func (*UnitTestCallbackCollector_OnFatal_Call) Return 

func (_c *UnitTestCallbackCollector_OnFatal_Call) Return() *UnitTestCallbackCollector_OnFatal_Call

func (*UnitTestCallbackCollector_OnFatal_Call) Run 

func (_c *UnitTestCallbackCollector_OnFatal_Call) Run(run func(reporter string, err error, timestamp time.Time)) *UnitTestCallbackCollector_OnFatal_Call

func (*UnitTestCallbackCollector_OnFatal_Call) RunAndReturn 

func (_c *UnitTestCallbackCollector_OnFatal_Call) RunAndReturn(run func(reporter string, err error, timestamp time.Time)) *UnitTestCallbackCollector_OnFatal_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.