Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

Automation Advisor
K6
metrics
newThresholdsWithConfig

How to use newThresholdsWithConfig method of metrics Package

Best K6 code snippet using metrics.newThresholdsWithConfig

thresholds.go

Source:thresholds.go

...129	tcs := make([]thresholdConfig, len(sources))130	for i, source := range sources {131		tcs[i].Threshold = source132	}133	return newThresholdsWithConfig(tcs)134}135func newThresholdsWithConfig(configs []thresholdConfig) Thresholds {136	thresholds := make([]*Threshold, len(configs))137	sinked := make(map[string]float64)138	for i, config := range configs {139		t := newThreshold(config.Threshold, config.AbortOnFail, config.AbortGracePeriod)140		thresholds[i] = t141	}142	return Thresholds{thresholds, false, sinked}143}144func (ts *Thresholds) runAll(timeSpentInTest time.Duration) (bool, error) {145	succeeded := true146	for i, threshold := range ts.Thresholds {147		b, err := threshold.run(ts.sinked)148		if err != nil {149			return false, fmt.Errorf("threshold %d run error: %w", i, err)150		}151		if !b {152			succeeded = false153			if ts.Abort || !threshold.AbortOnFail {154				continue155			}156			ts.Abort = !threshold.AbortGracePeriod.Valid ||157				threshold.AbortGracePeriod.Duration < types.Duration(timeSpentInTest)158		}159	}160	return succeeded, nil161}162// Run processes all the thresholds with the provided Sink at the provided time and returns if any163// of them fails164func (ts *Thresholds) Run(sink Sink, duration time.Duration) (bool, error) {165	// Initialize the sinks store166	ts.sinked = make(map[string]float64)167	// FIXME: Remove this comment as soon as the metrics.Sink does not expose Format anymore.168	//169	// As of December 2021, this block reproduces the behavior of the170	// metrics.Sink.Format behavior. As we intend to try to get away from it,171	// we instead implement the behavior directly here.172	//173	// For more details, see https://github.com/grafana/k6/issues/2320174	switch sinkImpl := sink.(type) {175	case *CounterSink:176		ts.sinked["count"] = sinkImpl.Value177		ts.sinked["rate"] = sinkImpl.Value / (float64(duration) / float64(time.Second))178	case *GaugeSink:179		ts.sinked["value"] = sinkImpl.Value180	case *TrendSink:181		ts.sinked["min"] = sinkImpl.Min182		ts.sinked["max"] = sinkImpl.Max183		ts.sinked["avg"] = sinkImpl.Avg184		ts.sinked["med"] = sinkImpl.Med185		// Parse the percentile thresholds and insert them in186		// the sinks mapping.187		for _, threshold := range ts.Thresholds {188			if threshold.parsed.AggregationMethod != tokenPercentile {189				continue190			}191			key := fmt.Sprintf("p(%g)", threshold.parsed.AggregationValue.Float64)192			ts.sinked[key] = sinkImpl.P(threshold.parsed.AggregationValue.Float64 / 100)193		}194	case *RateSink:195		ts.sinked["rate"] = float64(sinkImpl.Trues) / float64(sinkImpl.Total)196	case DummySink:197		for k, v := range sinkImpl {198			ts.sinked[k] = v199		}200	default:201		return false, fmt.Errorf("unable to run Thresholds; reason: unknown sink type")202	}203	return ts.runAll(duration)204}205// Parse parses the Thresholds and fills each Threshold.parsed field with the result.206// It effectively asserts they are syntaxically correct.207func (ts *Thresholds) Parse() error {208	for _, t := range ts.Thresholds {209		parsed, err := parseThresholdExpression(t.Source)210		if err != nil {211			return err212		}213		t.parsed = parsed214	}215	return nil216}217// ErrInvalidThreshold indicates a threshold is not valid218var ErrInvalidThreshold = errors.New("invalid threshold")219// Validate ensures a threshold definition is consistent with the metric it applies to.220// Given a metric registry and a metric name to apply the expressions too, Validate will221// assert that each threshold expression uses an aggregation method that's supported by the222// provided metric. It returns an error otherwise.223// Note that this function expects the passed in thresholds to have been parsed already, and224// have their Parsed (ThresholdExpression) field already filled.225func (ts *Thresholds) Validate(metricName string, r *Registry) error {226	parsedMetricName, _, err := ParseMetricName(metricName)227	if err != nil {228		err := fmt.Errorf("unable to validate threshold expressions: %w", ErrMetricNameParsing)229		return errext.WithExitCodeIfNone(err, exitcodes.InvalidConfig)230	}231	// Obtain the metric the thresholds apply to from the registry.232	// if the metric doesn't exist, then we return an error indicating233	// the InvalidConfig exitcode should be used.234	metric := r.Get(parsedMetricName)235	if metric == nil {236		err := fmt.Errorf("%w defined on %s; reason: no metric name %q found", ErrInvalidThreshold, metricName, metricName)237		return errext.WithExitCodeIfNone(err, exitcodes.InvalidConfig)238	}239	for _, threshold := range ts.Thresholds {240		// Return a digestable error if we attempt to validate a threshold241		// that hasn't been parsed yet.242		if threshold.parsed == nil {243			thresholdExpression, err := parseThresholdExpression(threshold.Source)244			if err != nil {245				return fmt.Errorf("unable to validate threshold %q on metric %s; reason: "+246					"parsing threshold failed %w", threshold.Source, metricName, err)247			}248			threshold.parsed = thresholdExpression249		}250		// If the threshold's expression aggregation method is not251		// supported for the metric we validate against, then we return252		// an error indicating the InvalidConfig exitcode should be used.253		if !metric.Type.supportsAggregationMethod(threshold.parsed.AggregationMethod) {254			err := fmt.Errorf(255				"%w %q applied on metric %s; reason: "+256					"unsupported aggregation method %s on metric of type %s. "+257					"supported aggregation methods for this metric are: %s",258				ErrInvalidThreshold, threshold.Source, metricName,259				threshold.parsed.AggregationMethod, metric.Type,260				strings.Join(metric.Type.supportedAggregationMethods(), ", "),261			)262			return errext.WithExitCodeIfNone(err, exitcodes.InvalidConfig)263		}264	}265	return nil266}267// UnmarshalJSON is implementation of json.Unmarshaler268func (ts *Thresholds) UnmarshalJSON(data []byte) error {269	var configs []thresholdConfig270	if err := json.Unmarshal(data, &configs); err != nil {271		return err272	}273	*ts = newThresholdsWithConfig(configs)274	return nil275}276// MarshalJSON is implementation of json.Marshaler277func (ts Thresholds) MarshalJSON() ([]byte, error) {278	configs := make([]thresholdConfig, len(ts.Thresholds))279	for i, t := range ts.Thresholds {280		configs[i].Threshold = t.Source281		configs[i].AbortOnFail = t.AbortOnFail282		configs[i].AbortGracePeriod = t.AbortGracePeriod283	}284	return MarshalJSONWithoutHTMLEscape(configs)285}286// MarshalJSONWithoutHTMLEscape marshals t to JSON without escaping characters287// for safe use in HTML....

newThresholdsWithConfig

Using AI Code Generation

1import (2func main() {3	httpRequestLatency := promauto.NewSummaryVec(prometheus.SummaryOpts{4	}, []string{"path"})5	httpRequestsTotal := promauto.NewCounterVec(prometheus.CounterOpts{6	}, []string{"path", "status_code"})7	httpRequestLatency2 := promauto.NewHistogramVec(prometheus.HistogramOpts{8	}, []string{"path"})9	httpRequestsInFlight := promauto.NewGauge(prometheus.GaugeOpts{10	})11	httpRequestsInFlight2 := promauto.NewGaugeVec(prometheus.GaugeOpts{12	}, []string{"path"})13	httpRequestsInFlight3 := promauto.NewGaugeVec(prometheus.GaugeOpts{14	}, []string{"path"})15	httpRequestsInFlight4 := promauto.NewGaugeVec(prometheus.GaugeOpts{16	}, []string{"path"})

newThresholdsWithConfig

Using AI Code Generation

1import (2func main() {3	m := metrics.NewMetrics()4	m = metrics.NewMetricsWithConfig(metrics.Config{5		Thresholds: metrics.Thresholds{6		},7	})

newThresholdsWithConfig

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	client, err := monitoring.NewService(ctx, option.WithoutAuthentication())5	if err != nil {6		log.Fatalf("Failed to create client: %v", err)7	}

newThresholdsWithConfig

Using AI Code Generation

1import (2func main() {3	metrics := metrics.NewThresholdsWithConfig(1, 1, 1, 1, 1, 1, 1, 1, 1, 1)4	fmt.Println(metrics)5}6import (7func main() {8	metrics := metrics.NewThresholds()9	fmt.Println(metrics)10}11import (12func main() {13	metrics := metrics.NewThresholds()14	metrics.Set(2, 2, 2, 2, 2, 2, 2, 2, 2, 2)15	fmt.Println(metrics)16}17import (18func main() {19	metrics := metrics.NewThresholds()20	metrics.Set(2, 2, 2, 2, 2, 2, 2, 2, 2, 2)21	fmt.Println(metrics)22}23import (24func main() {25	metrics := metrics.NewThresholds()26	metrics.Set(2, 2, 2, 2, 2, 2, 2, 2, 2, 2)27	fmt.Println(metrics)28	fmt.Println(metrics.String())29}

newThresholdsWithConfig

Using AI Code Generation

1thresholds := metrics.NewThresholdsWithConfig(metrics.Config{2})3thresholds := metrics.NewThresholds(0.8, 0.9)4thresholds := metrics.NewThresholds(0.8, 0.9)5thresholds := metrics.NewThresholdsWithConfig(metrics.Config{6})7thresholds := metrics.NewThresholdsWithConfig(metrics.Config{8})9thresholds := metrics.NewThresholds(0.8, 0.9)10thresholds := metrics.NewThresholds(0.8, 0.9)11thresholds := metrics.NewThresholdsWithConfig(metrics.Config{12})13thresholds := metrics.NewThresholdsWithConfig(metrics.Config{14})15thresholds := metrics.NewThresholds(0.8, 0.9)

newThresholdsWithConfig

Using AI Code Generation

1func main() {2    metrics := NewMetrics()3    threshold := metrics.NewThresholdsWithConfig("test", 100, 10, 50, 5, 2)4    metrics.AddThreshold(threshold)5    metrics.GetThreshold("test")6}7func main() {8    metrics := NewMetrics()9    threshold := metrics.NewThresholds("test", 100, 10, 50, 5)10    metrics.AddThreshold(threshold)11    metrics.GetThreshold("test")12}13func main() {14    metrics := NewMetrics()15    threshold := metrics.NewThresholdsWithoutConfig("test", 100, 10, 50, 5)16    metrics.AddThreshold(threshold)17    metrics.GetThreshold("test")18}19func main() {20    metrics := NewMetrics()21    threshold := metrics.NewThresholdsWithoutConfig("test", 100, 10, 50, 5)22    metrics.AddThreshold(threshold)23    metrics.GetThreshold("test")24}25func main() {26    metrics := NewMetrics()27    threshold := metrics.NewThresholdsWithoutConfig("test", 100, 10, 50, 5)28    metrics.AddThreshold(threshold)29    metrics.GetThreshold("test")30}31func main() {

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.