How to use NewThresholds method of metrics Package

Best K6 code snippet using metrics.NewThresholds

engine_test.go

Source:engine_test.go

...206		)207		assert.IsType(t, &stats.GaugeSink{}, e.Metrics["my_metric"].Sink)208	})209	t.Run("submetric", func(t *testing.T) {210		ths, err := stats.NewThresholds([]string{`1+1==2`})211		assert.NoError(t, err)212		e, _, wait := newTestEngine(t, nil, nil, nil, lib.Options{213			Thresholds: map[string]stats.Thresholds{214				"my_metric{a:1}": ths,215			},216		})217		defer wait()218		sms := e.submetrics["my_metric"]219		assert.Len(t, sms, 1)220		assert.Equal(t, "my_metric{a:1}", sms[0].Name)221		assert.EqualValues(t, map[string]string{"a": "1"}, sms[0].Tags.CloneTags())222		e.processSamples(223			[]stats.SampleContainer{stats.Sample{Metric: metric, Value: 1.25, Tags: stats.IntoSampleTags(&map[string]string{"a": "1", "b": "2"})}},224		)225		assert.IsType(t, &stats.GaugeSink{}, e.Metrics["my_metric"].Sink)226		assert.IsType(t, &stats.GaugeSink{}, e.Metrics["my_metric{a:1}"].Sink)227	})228}229func TestEngineThresholdsWillAbort(t *testing.T) {230	metric := stats.New("my_metric", stats.Gauge)231	ths, err := stats.NewThresholds([]string{"1+1==3"})232	assert.NoError(t, err)233	ths.Thresholds[0].AbortOnFail = true234	thresholds := map[string]stats.Thresholds{metric.Name: ths}235	e, _, wait := newTestEngine(t, nil, nil, nil, lib.Options{Thresholds: thresholds})236	defer wait()237	e.processSamples(238		[]stats.SampleContainer{stats.Sample{Metric: metric, Value: 1.25, Tags: stats.IntoSampleTags(&map[string]string{"a": "1"})}},239	)240	assert.True(t, e.processThresholds())241}242func TestEngineAbortedByThresholds(t *testing.T) {243	metric := stats.New("my_metric", stats.Gauge)244	ths, err := stats.NewThresholds([]string{"1+1==3"})245	assert.NoError(t, err)246	ths.Thresholds[0].AbortOnFail = true247	thresholds := map[string]stats.Thresholds{metric.Name: ths}248	done := make(chan struct{})249	runner := &minirunner.MiniRunner{Fn: func(ctx context.Context, out chan<- stats.SampleContainer) error {250		out <- stats.Sample{Metric: metric, Value: 1.25, Tags: stats.IntoSampleTags(&map[string]string{"a": "1"})}251		<-ctx.Done()252		close(done)253		return nil254	}}255	_, run, wait := newTestEngine(t, nil, runner, nil, lib.Options{Thresholds: thresholds})256	defer wait()257	go func() {258		assert.NoError(t, run())259	}()260	select {261	case <-done:262		return263	case <-time.After(10 * time.Second):264		assert.Fail(t, "Test should have completed within 10 seconds")265	}266}267func TestEngine_processThresholds(t *testing.T) {268	metric := stats.New("my_metric", stats.Gauge)269	testdata := map[string]struct {270		pass  bool271		ths   map[string][]string272		abort bool273	}{274		"passing":  {true, map[string][]string{"my_metric": {"1+1==2"}}, false},275		"failing":  {false, map[string][]string{"my_metric": {"1+1==3"}}, false},276		"aborting": {false, map[string][]string{"my_metric": {"1+1==3"}}, true},277		"submetric,match,passing":   {true, map[string][]string{"my_metric{a:1}": {"1+1==2"}}, false},278		"submetric,match,failing":   {false, map[string][]string{"my_metric{a:1}": {"1+1==3"}}, false},279		"submetric,nomatch,passing": {true, map[string][]string{"my_metric{a:2}": {"1+1==2"}}, false},280		"submetric,nomatch,failing": {true, map[string][]string{"my_metric{a:2}": {"1+1==3"}}, false},281	}282	for name, data := range testdata {283		name, data := name, data284		t.Run(name, func(t *testing.T) {285			thresholds := make(map[string]stats.Thresholds, len(data.ths))286			for m, srcs := range data.ths {287				ths, err := stats.NewThresholds(srcs)288				assert.NoError(t, err)289				ths.Thresholds[0].AbortOnFail = data.abort290				thresholds[m] = ths291			}292			e, _, wait := newTestEngine(t, nil, nil, nil, lib.Options{Thresholds: thresholds})293			defer wait()294			e.processSamples(295				[]stats.SampleContainer{stats.Sample{Metric: metric, Value: 1.25, Tags: stats.IntoSampleTags(&map[string]string{"a": "1"})}},296			)297			assert.Equal(t, data.abort, e.processThresholds())298			assert.Equal(t, data.pass, !e.IsTainted())299		})300	}301}...

thresholds_test.go

Source:thresholds_test.go

...474			})475		}476	})477}478func TestNewThresholds(t *testing.T) {479	t.Parallel()480	t.Run("empty", func(t *testing.T) {481		t.Parallel()482		ts := NewThresholds([]string{})483		assert.Len(t, ts.Thresholds, 0)484	})485	t.Run("two", func(t *testing.T) {486		t.Parallel()487		sources := []string{`rate<0.01`, `p(95)<200`}488		ts := NewThresholds(sources)489		assert.Len(t, ts.Thresholds, 2)490		for i, th := range ts.Thresholds {491			assert.Equal(t, sources[i], th.Source)492			assert.False(t, th.LastFailed)493			assert.False(t, th.AbortOnFail)494		}495	})496}497func TestNewThresholdsWithConfig(t *testing.T) {498	t.Parallel()499	t.Run("empty", func(t *testing.T) {500		t.Parallel()501		ts := NewThresholds([]string{})502		assert.Len(t, ts.Thresholds, 0)503	})504	t.Run("two", func(t *testing.T) {505		t.Parallel()506		configs := []thresholdConfig{507			{`rate<0.01`, false, types.NullDuration{}},508			{`p(95)<200`, true, types.NullDuration{}},509		}510		ts := newThresholdsWithConfig(configs)511		assert.Len(t, ts.Thresholds, 2)512		for i, th := range ts.Thresholds {513			assert.Equal(t, configs[i].Threshold, th.Source)514			assert.False(t, th.LastFailed)515			assert.Equal(t, configs[i].AbortOnFail, th.AbortOnFail)516		}517	})518}519func TestThresholdsRunAll(t *testing.T) {520	t.Parallel()521	zero := types.NullDuration{}522	oneSec := types.NullDurationFrom(time.Second)523	twoSec := types.NullDurationFrom(2 * time.Second)524	testdata := map[string]struct {525		succeeded bool526		err       bool527		abort     bool528		grace     types.NullDuration529		sources   []string530	}{531		"one passing":                {true, false, false, zero, []string{`rate<0.01`}},532		"one failing":                {false, false, false, zero, []string{`p(95)<200`}},533		"two passing":                {true, false, false, zero, []string{`rate<0.1`, `rate<0.01`}},534		"two failing":                {false, false, false, zero, []string{`p(95)<200`, `rate<0.1`}},535		"two mixed":                  {false, false, false, zero, []string{`rate<0.01`, `p(95)<200`}},536		"one aborting":               {false, false, true, zero, []string{`p(95)<200`}},537		"abort with grace period":    {false, false, true, oneSec, []string{`p(95)<200`}},538		"no abort with grace period": {false, false, true, twoSec, []string{`p(95)<200`}},539	}540	for name, data := range testdata {541		t.Run(name, func(t *testing.T) {542			t.Parallel()543			thresholds := NewThresholds(data.sources)544			gotParseErr := thresholds.Parse()545			require.NoError(t, gotParseErr)546			thresholds.sinked = map[string]float64{"rate": 0.0001, "p(95)": 500}547			thresholds.Thresholds[0].AbortOnFail = data.abort548			thresholds.Thresholds[0].AbortGracePeriod = data.grace549			runDuration := 1500 * time.Millisecond550			succeeded, err := thresholds.runAll(runDuration)551			if data.err {552				assert.Error(t, err)553			} else {554				assert.NoError(t, err)555			}556			if data.succeeded {557				assert.True(t, succeeded)558			} else {559				assert.False(t, succeeded)560			}561			if data.abort && data.grace.Duration < types.Duration(runDuration) {562				assert.True(t, thresholds.Abort)563			} else {564				assert.False(t, thresholds.Abort)565			}566		})567	}568}569func TestThresholds_Run(t *testing.T) {570	t.Parallel()571	type args struct {572		sink     Sink573		duration time.Duration574	}575	tests := []struct {576		name    string577		args    args578		want    bool579		wantErr bool580	}{581		{582			"Running thresholds of existing sink",583			args{DummySink{"p(95)": 1234.5}, 0},584			true,585			false,586		},587		{588			"Running thresholds of existing sink but failing threshold",589			args{DummySink{"p(95)": 3000}, 0},590			false,591			false,592		},593		{594			"Running threshold on non existing sink fails",595			args{DummySink{"dummy": 0}, 0},596			false,597			true,598		},599	}600	for _, testCase := range tests {601		testCase := testCase602		t.Run(testCase.name, func(t *testing.T) {603			t.Parallel()604			thresholds := NewThresholds([]string{"p(95)<2000"})605			gotParseErr := thresholds.Parse()606			require.NoError(t, gotParseErr)607			gotOk, gotErr := thresholds.Run(testCase.args.sink, testCase.args.duration)608			assert.Equal(t, gotErr != nil, testCase.wantErr, "Thresholds.Run() error = %v, wantErr %v", gotErr, testCase.wantErr)609			assert.Equal(t, gotOk, testCase.want, "Thresholds.Run() = %v, want %v", gotOk, testCase.want)610		})611	}612}613func TestThresholdsJSON(t *testing.T) {614	t.Parallel()615	testdata := []struct {616		JSON        string617		sources     []string618		abortOnFail bool...

thresholds.go

Source:thresholds.go

...123	Thresholds []*Threshold124	Abort      bool125	sinked     map[string]float64126}127// NewThresholds returns Thresholds objects representing the provided source strings128func NewThresholds(sources []string) Thresholds {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}...

NewThresholds

Using AI Code Generation

1import (2func init() {3	mb.Registry.MustAddMetricSet("windows", "perfmon", New,4		mb.WithHostParser(parse.EmptyHostParser),5		mb.DefaultMetricSet(),6}7type MetricSet struct {8}9func New(base mb.BaseMetricSet) (mb.MetricSet, error) {10	config := struct{}{}11	if err := base.Module().UnpackConfig(&config); err != nil {12	}13	perfmon.AddCounter("Processor", `\Processor Information(_Total)\% Processor Time`)14	perfmon.AddCounter("Memory", `\Memory\% Committed Bytes In Use`)15	perfmon.AddCounter("Processor", `\Processor Information(0,1)\% Processor Time`)16	perfmon.AddCounterWithLabels("Processor", `\Processor Information(0,1)\% Processor Time`, "core", "0,1")17	perfmon.AddCounterWithLabels("Processor", `\Processor Information(0,1)\% Processor Time`, "custom_name", "0,1")18	perfmon.AddCounterWithLabels("Processor", `\Processor Information(0,1)\% Processor Time`, "custom_name", "0,1")19	perfmon.AddCounterWithLabels("Processor", `\Processor Information(0,1)\% Processor Time`, "custom_name", "0,1")20	perfmon.AddCounterWithLabels("Processor", `\Processor Information(0,1)\% Processor Time`, "custom_name", "0,1")21	perfmon.AddCounterWithLabels("Processor",

NewThresholds

Using AI Code Generation

1import (2func main() {3	metrics := promauto.NewCounter(prometheus.CounterOpts{4	})5	metrics.Add(10)6	fmt.Println(metrics)7	http.Handle("/metrics", promhttp.Handler())8	log.Fatal(http.ListenAndServe(":2112", nil))9}10import (11func main() {12	metrics := promauto.NewCounterVec(prometheus.CounterOpts{13	}, []string{"code"})14	metrics.WithLabelValues("404").Add(10)15	metrics.WithLabelValues("500").Add(20)16	fmt.Println(metrics)17	http.Handle("/metrics", promhttp.Handler())18	log.Fatal(http.ListenAndServe(":2112", nil))19}20import (21func main() {22	metrics := promauto.NewGauge(prometheus.GaugeOpts{23	})24	metrics.Set(10)25	fmt.Println(metrics)26	go func() {27		for {28			metrics.Inc()29			time.Sleep(1 * time.Second)30		}31	}()32	http.Handle("/metrics", promhttp.Handler())33	log.Fatal(http.ListenAndServe(":2112", nil))34}

NewThresholds

Using AI Code Generation

1import (2func main() {3	fmt.Println("Hello World!")4	config := sarama.NewConfig()5	producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, config)6	if err != nil {7		panic(err)8	}9	defer producer.Close()10	metrics := metrics.NewRegistry()11	t := metrics.NewTimer()12	metrics.Register("timer", t)13	thresholds := metrics.NewThresholds(t)14	metrics.Register("thresholds", thresholds)15	wg.Add(1)16	go func() {17		defer wg.Done()18		for {19			select {20				fmt.Println("Thresholds triggered")21			}22		}23	}()24	for i := 0; i < 100; i++ {25		msg := &sarama.ProducerMessage{26			Value: sarama.StringEncoder(strings.Repeat("a", 100000)),27		}28		_, _, err := producer.SendMessage(msg)29		if err != nil {30			panic(err)31		}32		t.Update(time.Millisecond * 100)33	}34	wg.Wait()35	fmt.Println("Done")36}

NewThresholds

Using AI Code Generation

1import (2func main() {3    fmt.Println("Hello, playground")4    thresholds := metrics.NewThresholds(3, 5, 7, 9)5    fmt.Println(thresholds)6    fmt.Println(thresholds.Get(2))7    fmt.Println(thresholds.Get(4))8    fmt.Println(thresholds.Get(6))9    fmt.Println(thresholds.Get(8))10    fmt.Println(thresholds.Get(10))11}12{3 5 7 9}13import (14func main() {15    fmt.Println("Hello, playground")16    thresholds := metrics.NewThresholds(3, 5, 7, 9)17    fmt.Println(thresholds)18    fmt.Println(thresholds.Get(2))19    fmt.Println(thresholds.Get(4))20    fmt.Println(thresholds.Get(6))21    fmt.Println(thresholds.Get(8))22    fmt.Println(thresholds.Get(10))23}24{3 5 7 9}25import (26func main() {27    fmt.Println("Hello, playground")28    thresholds := metrics.NewThresholds(3, 5, 7, 9)29    fmt.Println(thresholds)30    fmt.Println(thresholds.Get(2))31    fmt.Println(thresholds.Get(4))32    fmt.Println(thresholds.Get(6))33    fmt.Println(thresholds.Get(8))34    fmt.Println(thresholds.Get(10))35}36{3 5 7 9}37import (38func main() {39    fmt.Println("Hello, playground")

NewThresholds

Using AI Code Generation

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

NewThresholds

Using AI Code Generation

1import (2func main() {3    t := mdata.NewThresholds(1, 2, 3)4    log.Println(t)5}62016/12/03 18:00:00 &{1 2 3}7import (8func main() {9    t := mdata.NewThresholds(1, 2, 3)10    t1 := t.Copy()11    log.Println(t1)12}132016/12/03 18:00:00 &{1 2 3}

NewThresholds

Using AI Code Generation

1import (2func main() {3	metrics := metrics_helper.NewMetricsHelper()4	threshold := metrics_helper.NewThresholds("threshold1", 1, 2, 3, 4, 5)5	metrics.AddThreshold(threshold)6	metric := metrics_helper.NewMetric("metric1", "metric1", "metric1", "metric1", "metric1")7	metrics.AddMetric(metric)8	dimension := metrics_helper.NewDimension("dimension1", "dimension1")9	metrics.AddDimension(dimension)10	dimension2 := metrics_helper.NewDimension("dimension2", "dimension2")11	metrics.AddDimension(dimension2)12	metrics.SetMetricValue("metric1", 1.0)13	metrics.SetMetricValue("metric1", 2.0)14	metrics.SetMetricValue("metric1", 3.0)15	metrics.SetMetricValue("metric1", 4.0)16	metrics.SetMetricValue("metric1", 5.0)17	metrics.SetMetricValue("metric1", 6.0)18	metrics.SetMetricValue("metric1", 7.0)19	metrics.SetMetricValue("metric1", 8.0)20	metrics.SetMetricValue("metric1", 9.0)21	metrics.SetMetricValue("metric1", 10.0)22	metrics.SetMetricValue("metric1", 11.0)

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.