test

type UnitTestCallbackCollector interface {
	// OnFatal called when background task need to report fatal error
	OnFatal(reporter string, err error, timestamp time.Time)

	// OnComplete called when task execution completes
	OnComplete(ctx context.Context, instanceID string, err error, timestamp time.Time)

	// NewTaskExecutor factory function for defining new task executors
	NewTaskExecutor(
		parentCtx context.Context,
		taskQueue string,
		workerCount int,
		requestBufferLen int,
		support task.ExecutorSupport,
		processors map[string]models.TaskExecutionProcessor,
	) (task.Executor, error)

	// NewRedisIPCMsgReceiver factory function for defining new Redis based IPC message receivers
	NewRedisIPCMsgReceiver(
		ctx context.Context, queueName string, redis goutilsRedis.Client, reader string,
	) (common.IPCMessageReceive, error)

	// NewRedisIPCMsgSender factory function for defining new Redis based IPC message senders
	NewRedisIPCMsgSender(
		ctx context.Context, queueName string, redis goutilsRedis.Client, sender string,
	) (common.IPCMessageSend, error)
}