How to use runNoTaint method of metrics Package

Best K6 code snippet using metrics.runNoTaint

thresholds_test.go

Source:thresholds_test.go

...40	assert.Equal(t, abortOnFail, gotThreshold.AbortOnFail)41	assert.Equal(t, gracePeriod, gotThreshold.AbortGracePeriod)42	assert.Nil(t, gotThreshold.parsed)43}44func TestThreshold_runNoTaint(t *testing.T) {45	t.Parallel()46	tests := []struct {47		name             string48		parsed           *thresholdExpression49		abortGracePeriod types.NullDuration50		sinks            map[string]float6451		wantOk           bool52		wantErr          bool53	}{54		{55			name:             "valid expression using the > operator over passing threshold",56			parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenGreater, 0.01},57			abortGracePeriod: types.NullDurationFrom(0 * time.Second),58			sinks:            map[string]float64{"rate": 1},59			wantOk:           true,60			wantErr:          false,61		},62		{63			name:             "valid expression using the > operator over passing threshold and defined abort grace period",64			parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenGreater, 0.01},65			abortGracePeriod: types.NullDurationFrom(2 * time.Second),66			sinks:            map[string]float64{"rate": 1},67			wantOk:           true,68			wantErr:          false,69		},70		{71			name:             "valid expression using the >= operator over passing threshold",72			parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenGreaterEqual, 0.01},73			abortGracePeriod: types.NullDurationFrom(0 * time.Second),74			sinks:            map[string]float64{"rate": 0.01},75			wantOk:           true,76			wantErr:          false,77		},78		{79			name:             "valid expression using the <= operator over passing threshold",80			parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenLessEqual, 0.01},81			abortGracePeriod: types.NullDurationFrom(0 * time.Second),82			sinks:            map[string]float64{"rate": 0.01},83			wantOk:           true,84			wantErr:          false,85		},86		{87			name:             "valid expression using the < operator over passing threshold",88			parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenLess, 0.01},89			abortGracePeriod: types.NullDurationFrom(0 * time.Second),90			sinks:            map[string]float64{"rate": 0.00001},91			wantOk:           true,92			wantErr:          false,93		},94		{95			name:             "valid expression using the == operator over passing threshold",96			parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenLooselyEqual, 0.01},97			abortGracePeriod: types.NullDurationFrom(0 * time.Second),98			sinks:            map[string]float64{"rate": 0.01},99			wantOk:           true,100			wantErr:          false,101		},102		{103			name:             "valid expression using the === operator over passing threshold",104			parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenStrictlyEqual, 0.01},105			abortGracePeriod: types.NullDurationFrom(0 * time.Second),106			sinks:            map[string]float64{"rate": 0.01},107			wantOk:           true,108			wantErr:          false,109		},110		{111			name:             "valid expression using != operator over passing threshold",112			parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenBangEqual, 0.01},113			abortGracePeriod: types.NullDurationFrom(0 * time.Second),114			sinks:            map[string]float64{"rate": 0.02},115			wantOk:           true,116			wantErr:          false,117		},118		{119			name:             "valid expression over failing threshold",120			parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenGreater, 0.01},121			abortGracePeriod: types.NullDurationFrom(0 * time.Second),122			sinks:            map[string]float64{"rate": 0.00001},123			wantOk:           false,124			wantErr:          false,125		},126		{127			name:             "valid expression over non-existing sink",128			parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenGreater, 0.01},129			abortGracePeriod: types.NullDurationFrom(0 * time.Second),130			sinks:            map[string]float64{"med": 27.2},131			wantOk:           false,132			wantErr:          true,133		},134		{135			// The ParseThresholdCondition constructor should ensure that no invalid136			// operator gets through, but let's protect our future selves anyhow.137			name:             "invalid expression operator",138			parsed:           &thresholdExpression{tokenRate, null.Float{}, "&", 0.01},139			abortGracePeriod: types.NullDurationFrom(0 * time.Second),140			sinks:            map[string]float64{"rate": 0.00001},141			wantOk:           false,142			wantErr:          true,143		},144	}145	for _, testCase := range tests {146		testCase := testCase147		t.Run(testCase.name, func(t *testing.T) {148			t.Parallel()149			threshold := &Threshold{150				LastFailed:       false,151				AbortOnFail:      false,152				AbortGracePeriod: testCase.abortGracePeriod,153				parsed:           testCase.parsed,154			}155			gotOk, gotErr := threshold.runNoTaint(testCase.sinks)156			assert.Equal(t,157				testCase.wantErr,158				gotErr != nil,159				"Threshold.runNoTaint() error = %v, wantErr %v", gotErr, testCase.wantErr,160			)161			assert.Equal(t,162				testCase.wantOk,163				gotOk,164				"Threshold.runNoTaint() gotOk = %v, want %v", gotOk, testCase.wantOk,165			)166		})167	}168}169func BenchmarkRunNoTaint(b *testing.B) {170	threshold := &Threshold{171		Source:           "rate>0.01",172		LastFailed:       false,173		AbortOnFail:      false,174		AbortGracePeriod: types.NullDurationFrom(2 * time.Second),175		parsed:           &thresholdExpression{tokenRate, null.Float{}, tokenGreater, 0.01},176	}177	sinks := map[string]float64{"rate": 1}178	b.ResetTimer()179	for i := 0; i < b.N; i++ {180		threshold.runNoTaint(sinks) // nolint181	}182}183func TestThresholdRun(t *testing.T) {184	t.Parallel()185	t.Run("true", func(t *testing.T) {186		t.Parallel()187		sinks := map[string]float64{"rate": 0.0001}188		parsed, parseErr := parseThresholdExpression("rate<0.01")189		require.NoError(t, parseErr)190		threshold := newThreshold(`rate<0.01`, false, types.NullDuration{})191		threshold.parsed = parsed192		t.Run("no taint", func(t *testing.T) {193			b, err := threshold.runNoTaint(sinks)194			assert.NoError(t, err)195			assert.True(t, b)196			assert.False(t, threshold.LastFailed)197		})198		t.Run("taint", func(t *testing.T) {199			t.Parallel()200			b, err := threshold.run(sinks)201			assert.NoError(t, err)202			assert.True(t, b)203			assert.False(t, threshold.LastFailed)204		})205	})206	t.Run("false", func(t *testing.T) {207		t.Parallel()208		sinks := map[string]float64{"rate": 1}209		parsed, parseErr := parseThresholdExpression("rate<0.01")210		require.NoError(t, parseErr)211		threshold := newThreshold(`rate<0.01`, false, types.NullDuration{})212		threshold.parsed = parsed213		t.Run("no taint", func(t *testing.T) {214			b, err := threshold.runNoTaint(sinks)215			assert.NoError(t, err)216			assert.False(t, b)217			assert.False(t, threshold.LastFailed)218		})219		t.Run("taint", func(t *testing.T) {220			b, err := threshold.run(sinks)221			assert.NoError(t, err)222			assert.False(t, b)223			assert.True(t, threshold.LastFailed)224		})225	})226}227func TestThresholdsParse(t *testing.T) {228	t.Parallel()...

thresholds.go

Source:thresholds.go

...50		AbortGracePeriod: gracePeriod,51		parsed:           nil,52	}53}54func (t *Threshold) runNoTaint(sinks map[string]float64) (bool, error) {55	// Extract the sink value for the aggregation method used in the threshold56	// expression57	lhs, ok := sinks[t.parsed.SinkKey()]58	if !ok {59		return false, fmt.Errorf("unable to apply threshold %s over metrics; reason: "+60			"no metric supporting the %s aggregation method found",61			t.Source,62			t.parsed.AggregationMethod)63	}64	// Apply the threshold expression operator to the left and65	// right hand side values66	var passes bool67	switch t.parsed.Operator {68	case ">":69		passes = lhs > t.parsed.Value70	case ">=":71		passes = lhs >= t.parsed.Value72	case "<=":73		passes = lhs <= t.parsed.Value74	case "<":75		passes = lhs < t.parsed.Value76	case "==", "===":77		// Considering a sink always maps to float64 values,78		// strictly equal is equivalent to loosely equal79		passes = lhs == t.parsed.Value80	case "!=":81		passes = lhs != t.parsed.Value82	default:83		// The parseThresholdExpression function should ensure that no invalid84		// operator gets through, but let's protect our future selves anyhow.85		return false, fmt.Errorf("unable to apply threshold %s over metrics; "+86			"reason: %s is an invalid operator",87			t.Source,88			t.parsed.Operator,89		)90	}91	// Perform the actual threshold verification92	return passes, nil93}94func (t *Threshold) run(sinks map[string]float64) (bool, error) {95	passes, err := t.runNoTaint(sinks)96	t.LastFailed = !passes97	return passes, err98}99type thresholdConfig struct {100	Threshold        string             `json:"threshold"`101	AbortOnFail      bool               `json:"abortOnFail"`102	AbortGracePeriod types.NullDuration `json:"delayAbortEval"`103}104// used internally for JSON marshalling105type rawThresholdConfig thresholdConfig106func (tc *thresholdConfig) UnmarshalJSON(data []byte) error {107	// shortcircuit unmarshalling for simple string format108	if err := json.Unmarshal(data, &tc.Threshold); err == nil {109		return nil...

runNoTaint

Using AI Code Generation

1import (2func main() {3	mc := memcache.New("localhost:11211")4	err := mc.Set(&memcache.Item{Key: "foo", Value: []byte("bar")})5	if err != nil {6		log.Fatal(err)7	}8	item, err := mc.Get("foo")9	if err != nil {10		log.Fatal(err)11	}12	fmt.Printf("The value of 'foo' is: %s13	metrics := newMetrics(mc)14	prometheus.MustRegister(metrics)15	http.Handle("/metrics", promhttp.Handler())16	log.Fatal(http.ListenAndServe(":8080", nil))17}18type metrics struct {

runNoTaint

Using AI Code Generation

1import (2func main() {3    fmt.Println(stringutil.Reverse("Hello, world"))4}5import (6func main() {7    fmt.Println(stringutil.Reverse("Hello, world"))8}9import (10func main() {11    fmt.Println(stringutil.Reverse("Hello, world"))12}13./1.go:8: cannot use metrics (type *Metrics) as type Metrics in argument to stringutil.Reverse14./1.go:8: cannot use metrics (type *Metrics) as type *Metrics in argument to stringutil.Reverse15func (m *Metrics) runNoTaint() {16    fmt.Println("runNoTaint")17}18func (m *Metrics) runTaint() {19    fmt.Println("runTaint")20}21import (22type Foo struct {23}24func NewFoo(c *Client) *Foo {25    return &Foo{26    }27}28func (f *Foo) Bar() {29    resp, err := f.client.DoSomething()30    if err != nil {31        log.Fatal(err)32    }33    fmt.Println(resp)34}35type Client struct {36}37func (c *Client) DoSomething() (string

runNoTaint

Using AI Code Generation

1import (2func main() {3 fd := flowdynamics.New()4 m := metrics.New()5 flow := fd.NewFlow()6 fd.AddFlow(flow)

runNoTaint

Using AI Code Generation

1import (2func main() {3	m := metrics.New()4	c := m.NewCounter("counter1")5	c.Incr(1)6	fmt.Println(c.Count())7	g := m.NewGauge("gauge1")8	g.Update(10)9	fmt.Println(g.Value())10	h := m.NewHistogram("histogram1")11	h.Update(5)12	fmt.Println(h.Mean())13	mt := m.NewMeter("meter1")14	mt.Mark(1)15	fmt.Println(mt.Rate1())16	t := m.NewTimer("timer1")17	t.Update(1)18	fmt.Println(t.Mean())19	m.PrintAll()20	m.PrintAllJSON()21	m.PrintAllCSV()22	m.PrintAllGraphite()23	m.PrintAllInfluxDB()24	m.PrintAllOpenTSDB()25	m.PrintAllPrometheus()26	m.PrintAllStatsD()27	m.PrintAllYAML()28	m.PrintAllXML()29	m.PrintAllCustom()30	m.PrintAllCustom2()31	m.PrintAllCustom3()

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.