Как протестировать регистрацию динамических метрик в пользовательском экспортере Prometheus?

ОБНОВЛЕНИЕ: текущий источник доступен здесь.

В настоящее время я работаю над пользовательским экспортером Prometheus для changetection.io , чтобы отображать как парсинг, так и ценовые показатели для всех зарегистрированных часов.

Получив рабочее доказательство концепции, я пытаюсь сделать проект пригодным для сопровождения и готовым к выпуску для сообщества с открытым исходным кодом (например, добавляя тесты и документацию и делая его максимально полным).

При написании этих тестов я наткнулся на проблему при попытке протестировать динамическую регистрацию новых часов по мере их создания в отслеживаемом экземпляре Changetection.io. Чтобы экспортер мог их забрать без перезапуска, я проверяю API на предмет вновь добавленных часов при каждом запуске сбора.

Вот функция CollectpriceCollector:

func (c *priceCollector) Collect(ch chan<- prometheus.Metric) {
    // check for new watches before collecting metrics
    watches, err := c.ApiClient.getWatches()
    if err != nil {
        log.Errorf("error while fetching watches: %v", err)
    } else {
        for id, watch := range watches {
            if _, ok := c.priceMetrics[id]; !ok {
                // create new metric and register it on the DefaultRegisterer
                c.priceMetrics[id] = newPriceMetric(prometheus.Labels{"title": watch.Title}, c.ApiClient, id)
                prometheus.MustRegister(c.priceMetrics[id])

                log.Infof("Picked up new watch %s, registered as metric %s", watch.Title, id)
            }
        }
    }

    // collect all registered metrics
    for _, metric := range c.priceMetrics {
        metric.Collect(ch)
    }
}

Функция newPriceMetric просто создает новый объект priceMetric, состоящий из prometheus.Desc, ApiClient (класса, обеспечивающего доступ к API Changetection.io) и UUID:

func newPriceMetric(labels prometheus.Labels, apiClient *ApiClient, uuid string) priceMetric {
    return priceMetric{
        desc: prometheus.NewDesc(
            prometheus.BuildFQName(namespace, "watch", "price"),
            "Current price of an offer type watch",
            nil, labels,
        ),
        apiClient: apiClient,
        UUID:      uuid,
    }
}

Тестирование поведения по умолчанию работает отлично и проходит все тесты, но когда я пытаюсь протестировать поведение при добавлении новых часов (когда экспортер работает без его перезапуска), тест завершается неудачно.

Примечания: И expectMetrics, и expectMetricCount являются функциями-обертками вокруг собственных testutil.CollectAndCompare и testutil.CollectAndCount Prometheus. Помощник CreateTestApiServer создает завернутый httptest сервер, который возвращает полезные данные JSON на основе переданной map[string]*data.WatchItem структуры.

func TestAutoregisterPriceCollector(t *testing.T) {
    watchDb := createCollectorTestDb()
    server := testutil.CreateTestApiServer(t, watchDb)
    defer server.Close()

    c, err := NewPriceCollector(server.URL(), "foo-bar-key")
    if err != nil {
        t.Fatal(err)
    }
    expectMetricCount(t, c, 2, "changedetectionio_watch_price")

    // now add a new watch and expect the collector to pick it up
    uuid, newItem := testutil.NewTestItem("Item 3", 300, "USD")
    watchDb[uuid] = newItem

    expectMetrics(t, c, "price_metrics_autoregister.prom", "changedetectionio_watch_price")
    expectMetricCount(t, c, 3, "changedetectionio_watch_price")
}

При запуске этого теста запуск завершается неудачно со следующей ошибкой:

Collector_test.go:23: Возвращены неожиданные метрики: не удалось собрать метрики: собранная метрика изменена. help: «Текущая цена для просмотра типа предложения», constLabels: {title="Item 3"},variableLabels: {}}

В настоящее время я предполагаю, что эта ошибка связана с внутренней работой testutil.CollectAnd*. Согласно комментариям к функциям, они регистрируют сборщик в недавно созданном педантичном реестре, что может привести к тому, что он не подберет лениво зарегистрированный дескриптор.

Есть мысли по этому поводу?