repository

type Collections struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type CollectionsMock struct {
	contracts.CollectionsInterface
	NextMock func(ctx context.Context) (tasks []domain.Task, err error)
}

type Options struct {
	/*
		It is approximately count of tasks in collection
	*/
	MaxCountTasksInCollection int

	/*
		0 - disable deleting empty collections
		1 - delete empty collection each times
		n - delete empty collections every n times
	*/
	CleaningFrequency int
}

type RepositoryMock struct {
	contracts.RepositoryInterface

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