task_manager

Documentation

Index

• func New(repository contracts.RepositoryInterface, eh contracts.EventHandlerInterface, ...) contracts.TaskManagerInterface
• type Options
• type TaskManagerMock
  • func (tm *TaskManagerMock) ConfirmExecution(ctx context.Context, tasks []domain.Task) error
  • func (tm *TaskManagerMock) Create(ctx context.Context, task *domain.Task, isTaken bool) error
  • func (tm *TaskManagerMock) Delete(ctx context.Context, taskId string) error
  • func (tm *TaskManagerMock) GetTasksToComplete(ctx context.Context, preloadingTimeRange time.Duration) (contracts.CollectionsInterface, error)

Functions

func New

func New(
	repository contracts.RepositoryInterface,
	eh contracts.EventHandlerInterface,
	monitoring contracts.MonitoringInterface,
	options *Options,
) contracts.TaskManagerInterface

Types

type Options

type Options struct {
	MaxRetry            int
	TimeGapBetweenRetry time.Duration
}

type TaskManagerMock

type TaskManagerMock struct {
	contracts.TaskManagerInterface

	/*
		You need to substitute *Mock methods to do substitute original functions
	*/
	ConfirmExecutionMock   func(ctx context.Context, tasks []domain.Task) error
	CreateMock             func(ctx context.Context, task *domain.Task, isTaken bool) error
	DeleteMock             func(ctx context.Context, taskId string) error
	GetTasksToCompleteMock func(ctx context.Context, preloadingTimeRange time.Duration) (contracts.CollectionsInterface, error)
}

func (*TaskManagerMock) ConfirmExecution

func (tm *TaskManagerMock) ConfirmExecution(ctx context.Context, tasks []domain.Task) error

func (*TaskManagerMock) Create

func (tm *TaskManagerMock) Create(ctx context.Context, task *domain.Task, isTaken bool) error

func (*TaskManagerMock) Delete

func (tm *TaskManagerMock) Delete(ctx context.Context, taskId string) error

func (*TaskManagerMock) GetTasksToComplete

func (tm *TaskManagerMock) GetTasksToComplete(ctx context.Context, preloadingTimeRange time.Duration) (contracts.CollectionsInterface, error)