inspector

type Config struct {
	// StuckedInWorkAgo task will be considered stucked if
	// it was taken to work more than an StuckedInWorkAgo ago.
	StuckedInWorkAgo time.Duration

	// CheckTasksPeriod inspector of the problem tasks
	// will run every specified time period.
	CheckTasksPeriod time.Duration
}

type Inspector struct {
	Config *Config
	Logger *log.Logger

	OnInspectedTasks OnInspectedTasks
	// contains filtered or unexported fields
}

type LoggerInspector struct {
	Logger *log.Logger
}

type OnInspectedTasks func(ctx context.Context, stuckedTasks, failedTasks []Task)

type Storage interface {
	// GetStuckedTasks returns stucked tasks.
	// Stuck task it is task without error and taked in work before inWorkBefore.
	// Returns empty slcie when storage can't found stucked tasks.
	GetStuckedTasks(ctx context.Context, inWorkBefore time.Time) ([]Task, error)

	// GetFailedTasks returns failed tasks.
	// Failed task it is undone task with error.
	// Returns empty slcie when storage can't found failed tasks.
	GetFailedTasks(ctx context.Context) ([]Task, error)
}

type Task interface {
	tmanager.Task

	// GetError returns text of the task stored in the Storage.
	GetError() string
}