func AssertMetricMissing()

in integration_test/gce-testing-internal/gce/gce_testing.go [549:587]
31 lines of code
10 McCabe index (conditional complexity)

func AssertMetricMissing(ctx context.Context, logger *log.Logger, vm *VM, metric string, isPrometheus bool, window time.Duration) error {
	descriptorNotFoundErrCount := 0
	for attempt := 1; attempt <= queryMaxAttemptsMetricMissing; attempt++ {
		it := lookupMetric(ctx, logger, vm, metric, window, nil, isPrometheus)
		series, err := nonEmptySeriesList(logger, it, 1)
		found := len(series) > 0
		logger.Printf("nonEmptySeriesList check(metric=%q): err=%v, found=%v, attempt (%d/%d)",
			metric, err, found, attempt, queryMaxAttemptsMetricMissing)

		if err == nil {
			if found {
				return fmt.Errorf("AssertMetricMissing(metric=%q): %v failed: unexpectedly found data for metric", metric, err)
			}
			// Success
			return nil
		}
		if !isRetriableLookupError(err) {
			return fmt.Errorf("AssertMetricMissing(metric=%q): %v", metric, err)
		}

		// prometheus.googleapis.com/* domain metrics are created on first write, and may not be immediately queryable.
		// The error doesn't always look the same, hopefully looking for Code() == NotFound will catch all variations.
		myStatus, ok := status.FromError(err)
		if ok && isPrometheus && myStatus.Code() == codes.NotFound {
			descriptorNotFoundErrCount += 1
		}
		time.Sleep(queryBackoffDuration)
	}
	if !isPrometheus {
		return fmt.Errorf("AssertMetricMissing(metric=%q): failed: no successful queries to the backend", metric)
	}

	if descriptorNotFoundErrCount != queryMaxAttemptsMetricMissing {
		return fmt.Errorf("AssertMetricMissing(metric=%q): failed: atleast one query failed with something other than a NOT_FOUND error", metric)
	}

	// Success
	return nil
}