Method batchSize

internal/maintenance/queue_cleaner.go:144–149

()

}

func (s *QueueCleaner) batchSize() int {
	if s.reducedBatchSizeBreaker.Open() {
		return s.Config.Reduced
	}
	return s.Config.Default
}

type queueCleanerRunOnceResult struct {
	QueuesDeleted []string