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

Copied to Clipboard!

How to use State method of modulestest Package

Best K6 code snippet using modulestest.State

k6_test.go

Source:k6_test.go

...38		&modulestest.VU{39			RuntimeField: rt,40			InitEnvField: &common.InitEnvironment{},41			CtxField:     context.Background(),42			StateField:   nil,43		},44	).(*K6)45	require.True(t, ok)46	require.NoError(t, rt.Set("k6", m.Exports().Named))47	_, err := rt.RunString(`k6.fail("blah")`)48	assert.Contains(t, err.Error(), "blah")49}50func TestSleep(t *testing.T) {51	t.Parallel()52	testdata := map[string]time.Duration{53		"1":   1 * time.Second,54		"1.0": 1 * time.Second,55		"0.5": 500 * time.Millisecond,56	}57	for name, d := range testdata {58		d := d59		t.Run(name, func(t *testing.T) {60			t.Parallel()61			rt := goja.New()62			m, ok := New().NewModuleInstance(63				&modulestest.VU{64					RuntimeField: rt,65					InitEnvField: &common.InitEnvironment{},66					CtxField:     context.Background(),67					StateField:   nil,68				},69			).(*K6)70			require.True(t, ok)71			require.NoError(t, rt.Set("k6", m.Exports().Named))72			startTime := time.Now()73			_, err := rt.RunString(`k6.sleep(1)`)74			endTime := time.Now()75			assert.NoError(t, err)76			assert.True(t, endTime.Sub(startTime) > d, "did not sleep long enough")77		})78	}79	t.Run("Cancel", func(t *testing.T) {80		t.Parallel()81		rt := goja.New()82		ctx, cancel := context.WithCancel(context.Background())83		m, ok := New().NewModuleInstance(84			&modulestest.VU{85				RuntimeField: rt,86				InitEnvField: &common.InitEnvironment{},87				CtxField:     ctx,88				StateField:   nil,89			},90		).(*K6)91		require.True(t, ok)92		require.NoError(t, rt.Set("k6", m.Exports().Named))93		dch := make(chan time.Duration)94		go func() {95			startTime := time.Now()96			_, err := rt.RunString(`k6.sleep(10)`)97			endTime := time.Now()98			assert.NoError(t, err)99			dch <- endTime.Sub(startTime)100		}()101		time.Sleep(1 * time.Second)102		cancel()103		d := <-dch104		assert.True(t, d > 500*time.Millisecond, "did not sleep long enough")105		assert.True(t, d < 2*time.Second, "slept for too long!!")106	})107}108func TestRandSeed(t *testing.T) {109	t.Parallel()110	rt := goja.New()111	m, ok := New().NewModuleInstance(112		&modulestest.VU{113			RuntimeField: rt,114			InitEnvField: &common.InitEnvironment{},115			CtxField:     context.Background(),116			StateField:   nil,117		},118	).(*K6)119	require.True(t, ok)120	require.NoError(t, rt.Set("k6", m.Exports().Named))121	rand := 0.8487305991992138122	_, err := rt.RunString(fmt.Sprintf(`123		var rnd = Math.random();124		if (rnd == %.16f) { throw new Error("wrong random: " + rnd); }125	`, rand))126	assert.NoError(t, err)127	_, err = rt.RunString(fmt.Sprintf(`128		k6.randomSeed(12345)129		var rnd = Math.random();130		if (rnd != %.16f) { throw new Error("wrong random: " + rnd); }131	`, rand))132	assert.NoError(t, err)133}134func TestGroup(t *testing.T) {135	t.Parallel()136	setupGroupTest := func() (*goja.Runtime, *lib.State, *lib.Group) {137		root, err := lib.NewGroup("", nil)138		assert.NoError(t, err)139		rt := goja.New()140		state := &lib.State{141			Group:   root,142			Samples: make(chan metrics.SampleContainer, 1000),143			Tags:    lib.NewTagMap(nil),144			Options: lib.Options{145				SystemTags: metrics.NewSystemTagSet(metrics.TagGroup),146			},147		}148		state.BuiltinMetrics = metrics.RegisterBuiltinMetrics(metrics.NewRegistry())149		m, ok := New().NewModuleInstance(150			&modulestest.VU{151				RuntimeField: rt,152				InitEnvField: &common.InitEnvironment{},153				CtxField:     context.Background(),154				StateField:   state,155			},156		).(*K6)157		require.True(t, ok)158		require.NoError(t, rt.Set("k6", m.Exports().Named))159		return rt, state, root160	}161	t.Run("Valid", func(t *testing.T) {162		t.Parallel()163		rt, state, root := setupGroupTest()164		assert.Equal(t, state.Group, root)165		require.NoError(t, rt.Set("fn", func() {166			groupTag, ok := state.Tags.Get("group")167			require.True(t, ok)168			assert.Equal(t, groupTag, "::my group")169			assert.Equal(t, state.Group.Name, "my group")170			assert.Equal(t, state.Group.Parent, root)171		}))172		_, err := rt.RunString(`k6.group("my group", fn)`)173		assert.NoError(t, err)174		assert.Equal(t, state.Group, root)175		groupTag, ok := state.Tags.Get("group")176		require.True(t, ok)177		assert.Equal(t, groupTag, root.Name)178	})179	t.Run("Invalid", func(t *testing.T) {180		t.Parallel()181		rt, _, _ := setupGroupTest()182		_, err := rt.RunString(`k6.group("::", function() { throw new Error("nooo") })`)183		assert.Contains(t, err.Error(), "group and check names may not contain '::'")184	})185}186func checkTestRuntime(t testing.TB) (*goja.Runtime, chan metrics.SampleContainer, *metrics.BuiltinMetrics) {187	rt := goja.New()188	root, err := lib.NewGroup("", nil)189	assert.NoError(t, err)190	samples := make(chan metrics.SampleContainer, 1000)191	state := &lib.State{192		Group: root,193		Options: lib.Options{194			SystemTags: &metrics.DefaultSystemTagSet,195		},196		Samples: samples,197		Tags: lib.NewTagMap(map[string]string{198			"group": root.Path,199		}),200	}201	state.BuiltinMetrics = metrics.RegisterBuiltinMetrics(metrics.NewRegistry())202	m, ok := New().NewModuleInstance(203		&modulestest.VU{204			RuntimeField: rt,205			InitEnvField: &common.InitEnvironment{},206			CtxField:     context.Background(),207			StateField:   state,208		},209	).(*K6)210	require.True(t, ok)211	require.NoError(t, rt.Set("k6", m.Exports().Named))212	return rt, samples, state.BuiltinMetrics213}214func TestCheckObject(t *testing.T) {215	t.Parallel()216	rt, samples, builtinMetrics := checkTestRuntime(t)217	_, err := rt.RunString(`k6.check(null, { "check": true })`)218	assert.NoError(t, err)219	bufSamples := metrics.GetBufferedSamples(samples)220	if assert.Len(t, bufSamples, 1) {221		sample, ok := bufSamples[0].(metrics.Sample)222		require.True(t, ok)223		assert.NotZero(t, sample.Time)224		assert.Equal(t, builtinMetrics.Checks, sample.Metric)225		assert.Equal(t, float64(1), sample.Value)226		assert.Equal(t, map[string]string{227			"group": "",228			"check": "check",229		}, sample.Tags.CloneTags())230	}231	t.Run("Multiple", func(t *testing.T) {232		t.Parallel()233		rt, samples, _ := checkTestRuntime(t)234		_, err := rt.RunString(`k6.check(null, { "a": true, "b": false })`)235		assert.NoError(t, err)236		bufSamples := metrics.GetBufferedSamples(samples)237		assert.Len(t, bufSamples, 2)238		var foundA, foundB bool239		for _, sampleC := range bufSamples {240			for _, sample := range sampleC.GetSamples() {241				name, ok := sample.Tags.Get("check")242				assert.True(t, ok)243				switch name {244				case "a":245					assert.False(t, foundA, "duplicate 'a'")246					foundA = true247				case "b":248					assert.False(t, foundB, "duplicate 'b'")249					foundB = true250				default:251					assert.Fail(t, name)252				}253			}254		}255		assert.True(t, foundA, "missing 'a'")256		assert.True(t, foundB, "missing 'b'")257	})258	t.Run("Invalid", func(t *testing.T) {259		t.Parallel()260		rt, _, _ := checkTestRuntime(t)261		_, err := rt.RunString(`k6.check(null, { "::": true })`)262		assert.Contains(t, err.Error(), "group and check names may not contain '::'")263	})264}265func TestCheckArray(t *testing.T) {266	t.Parallel()267	rt, samples, builtinMetrics := checkTestRuntime(t)268	_, err := rt.RunString(`k6.check(null, [ true ])`)269	assert.NoError(t, err)270	bufSamples := metrics.GetBufferedSamples(samples)271	if assert.Len(t, bufSamples, 1) {272		sample, ok := bufSamples[0].(metrics.Sample)273		require.True(t, ok)274		assert.NotZero(t, sample.Time)275		assert.Equal(t, builtinMetrics.Checks, sample.Metric)276		assert.Equal(t, float64(1), sample.Value)277		assert.Equal(t, map[string]string{278			"group": "",279			"check": "0",280		}, sample.Tags.CloneTags())281	}282}283func TestCheckLiteral(t *testing.T) {284	t.Parallel()285	rt, samples, _ := checkTestRuntime(t)286	_, err := rt.RunString(`k6.check(null, 12345)`)287	assert.NoError(t, err)288	assert.Len(t, metrics.GetBufferedSamples(samples), 0)289}290func TestCheckNull(t *testing.T) {291	t.Parallel()292	rt, samples, _ := checkTestRuntime(t)293	_, err := rt.RunString(`k6.check(5)`)294	require.Error(t, err)295	assert.Contains(t, err.Error(), "no checks provided")296	assert.Len(t, metrics.GetBufferedSamples(samples), 0)297}298func TestCheckThrows(t *testing.T) {299	t.Parallel()300	rt, samples, builtinMetrics := checkTestRuntime(t)301	_, err := rt.RunString(`302		k6.check(null, {303			"a": function() { throw new Error("error A") },304			"b": function() { throw new Error("error B") },305		})306		`)307	assert.EqualError(t, err, "Error: error A at a (<eval>:3:28(3))")308	bufSamples := metrics.GetBufferedSamples(samples)309	if assert.Len(t, bufSamples, 1) {310		sample, ok := bufSamples[0].(metrics.Sample)311		require.True(t, ok)312		assert.NotZero(t, sample.Time)313		assert.Equal(t, builtinMetrics.Checks, sample.Metric)314		assert.Equal(t, float64(0), sample.Value)315		assert.Equal(t, map[string]string{316			"group": "",317			"check": "a",318		}, sample.Tags.CloneTags())319	}320}321func TestCheckTypes(t *testing.T) {322	t.Parallel()323	templates := map[string]string{324		"Literal":      `k6.check(null,{"check": %s})`,325		"Callable":     `k6.check(null,{"check": function() { return %s; }})`,326		"Callable/Arg": `k6.check(%s,{"check": function(v) {return v; }})`,327	}328	testdata := map[string]bool{329		`0`:         false,330		`1`:         true,331		`-1`:        true,332		`""`:        false,333		`"true"`:    true,334		`"false"`:   true,335		`true`:      true,336		`false`:     false,337		`null`:      false,338		`undefined`: false,339	}340	for name, tpl := range templates {341		name, tpl := name, tpl342		t.Run(name, func(t *testing.T) {343			t.Parallel()344			for value, succ := range testdata {345				value, succ := value, succ346				t.Run(value, func(t *testing.T) {347					t.Parallel()348					rt, samples, builtinMetrics := checkTestRuntime(t)349					v, err := rt.RunString(fmt.Sprintf(tpl, value))350					if assert.NoError(t, err) {351						assert.Equal(t, succ, v.Export())352					}353					bufSamples := metrics.GetBufferedSamples(samples)354					if assert.Len(t, bufSamples, 1) {355						sample, ok := bufSamples[0].(metrics.Sample)356						require.True(t, ok)357						assert.NotZero(t, sample.Time)358						assert.Equal(t, builtinMetrics.Checks, sample.Metric)359						if succ {360							assert.Equal(t, float64(1), sample.Value)361						} else {362							assert.Equal(t, float64(0), sample.Value)363						}364						assert.Equal(t, map[string]string{365							"group": "",366							"check": "check",367						}, sample.Tags.CloneTags())368					}369				})370			}371		})372	}373}374func TestCheckContextExpiry(t *testing.T) {375	t.Parallel()376	rt := goja.New()377	ctx, cancel := context.WithCancel(context.Background())378	root, err := lib.NewGroup("", nil)379	require.NoError(t, err)380	samples := make(chan metrics.SampleContainer, 1000)381	state := &lib.State{382		Group: root,383		Options: lib.Options{384			SystemTags: &metrics.DefaultSystemTagSet,385		},386		Samples: samples,387		Tags: lib.NewTagMap(map[string]string{388			"group": root.Path,389		}),390	}391	state.BuiltinMetrics = metrics.RegisterBuiltinMetrics(metrics.NewRegistry())392	m, ok := New().NewModuleInstance(393		&modulestest.VU{394			RuntimeField: rt,395			InitEnvField: &common.InitEnvironment{},396			CtxField:     ctx,397			StateField:   state,398		},399	).(*K6)400	require.True(t, ok)401	require.NoError(t, rt.Set("k6", m.Exports().Named))402	v, err := rt.RunString(`k6.check(null, { "check": true })`)403	if assert.NoError(t, err) {404		assert.Equal(t, true, v.Export())405	}406	check, _ := root.Check("check")407	assert.Equal(t, int64(1), check.Passes)408	assert.Equal(t, int64(0), check.Fails)409	cancel()410	v, err = rt.RunString(`k6.check(null, { "check": true })`)411	require.NoError(t, err)...

bench_test.go

Source:bench_test.go

...76		ts.server.Close()77		close(ch) // this might need to be elsewhere78	})79	ts.vu = new(modulestest.VU)80	ts.vu.StateField = new(lib.State)81	ts.vu.CtxField = context.Background()82	ts.vu.StateField.Tags = lib.NewTagMap(nil)83	ts.vu.StateField.Transport = ts.server.Client().Transport84	ts.vu.StateField.BPool = bpool.NewBufferPool(123)85	ts.vu.StateField.Samples = ch86	ts.vu.StateField.BuiltinMetrics = metrics.RegisterBuiltinMetrics(metrics.NewRegistry())87	go func() {88		for range ch {89		}90	}()91	return ts92}93func BenchmarkStoreFromPrecompiledTemplates(b *testing.B) {94	s := newTestServer(b)95	c := &Client{96		client: &http.Client{},97		cfg: &Config{98			Url:     s.server.URL,99			Timeout: "100s",100		},...

batch_test.go

Source:batch_test.go

...8	"go.k6.io/k6/metrics"9)10func BenchmarkNewBatch(b *testing.B) {11	samples := make(chan metrics.SampleContainer)12	state := &lib.State{13		Samples: samples,14		VUID:    15,15	}16	ctx, cancel := context.WithCancel(context.Background())17	vu := &modulestest.VU{18		CtxField:   ctx,19		StateField: state,20	}21	defer cancel()22	defer close(samples)23	go func() { // this is so that we read the send samples24		for range samples {25		}26	}()27	faker := gofakeit.New(12345)28	cardinalities := map[string]int{29		"app":       5,30		"namespace": 10,31		"pod":       100,32	}33	streams, minBatchSize, maxBatchSize := 5, 500, 100034	labels := newLabelPool(faker, cardinalities)35	c := Client{36		vu: vu,37	}38	b.ResetTimer()39	b.ReportAllocs()40	for i := 0; i < b.N; i++ {41		_ = c.newBatch(labels, streams, minBatchSize, maxBatchSize)42	}43}44func BenchmarkEncode(b *testing.B) {45	samples := make(chan metrics.SampleContainer)46	state := &lib.State{47		Samples: samples,48		VUID:    15,49	}50	ctx, cancel := context.WithCancel(context.Background())51	vu := &modulestest.VU{52		CtxField:   ctx,53		StateField: state,54	}55	defer cancel()56	defer close(samples)57	go func() { // this is so that we read the send samples58		for range samples {59		}60	}()61	faker := gofakeit.New(12345)62	cardinalities := map[string]int{63		"app":       5,64		"namespace": 10,65		"pod":       100,66	}67	streams, minBatchSize, maxBatchSize := 5, 500, 1000...

State

Using AI Code Generation

1import (2func main() {3	modulestest.State()4	fmt.Println("main")5}6import (7func main() {8	modulestest.State()9	fmt.Println("main")10}11import (12func main() {13	modulestest.State()14	fmt.Println("main")15}16import (17func main() {18	modulestest.State()19	fmt.Println("main")20}21import (22func main() {23	modulestest.State()24	fmt.Println("main")25}26import (27func main() {28	modulestest.State()29	fmt.Println("main")30}31import (32func main() {33	modulestest.State()34	fmt.Println("main")35}36import (37func main() {38	modulestest.State()39	fmt.Println("main")40}41import (42func main() {43	modulestest.State()44	fmt.Println("main")45}46import (47func main() {48	modulestest.State()49	fmt.Println("main")50}51import (

State

Using AI Code Generation

1import (2func main() {3	fmt.Println("Hello, playground")4	modulestest.State()5}6import (7func State() {8	fmt.Println("This is a test")9}

State

Using AI Code Generation

1import (2func main() {3    fmt.Println("modulestest.State():", modulestest.State())4}5import (6func State() string {7    return fmt.Sprintf("modulestest.State(): %s", modules.State())8}9import (10func State() string {11    return fmt.Sprintf("modules.State(): %s", "ok")12}13import (14func main() {15    fmt.Println("modulestest.State():", modulestest.State())16    fmt.Println("modules.State():", modules.State())17}18import (19func State() string {20    return fmt.Sprintf("modulestest.State(): %s", modules.State())21}22import (23func main() {24    fmt.Println("modulestest.State():", modulestest.State())25}

State

Using AI Code Generation

1import (2func main() {3    m := modulestest{}4    m.State()5}6import (7func main() {8    m := modulestest{}9    m.State()10}11import (

State

Using AI Code Generation

1import (2func main() {3    fmt.Println("Hello, playground")4    modulestest := testing.Modulestest{}5    modulestest.State()6}

State

Using AI Code Generation

1import (2func main() {3    fmt.Println("Hello World!")4    modulestest.State()5}6import (7func main() {8    fmt.Println("Hello World!")9    modulestest.State()10}11import (12func main() {13    fmt.Println("Hello World!")14    modulestest.State()15}16import (17func main() {18    fmt.Println("Hello World!")19    modulestest.State()20}21import (22func main() {23    fmt.Println("Hello World!")24    modulestest.State()25}26import (27func main() {28    fmt.Println("Hello World!")29    modulestest.State()30}31import (32func main() {33    fmt.Println("Hello World!")34    modulestest.State()35}36import (37func main() {38    fmt.Println("Hello World!")39    modulestest.State()40}41import (

State

Using AI Code Generation

1import "fmt"2import "github.com/udhos/gobus/modules"3func main() {4  mod := modules.New()5  fmt.Println(mod.State())6}7import "fmt"8import "github.com/udhos/gobus/modules"9func main() {10  mod := modules.New()11  fmt.Println(mod.State())12}13import "fmt"14import "github.com/udhos/gobus/modules"15func main() {16  mod := modules.New()17  fmt.Println(mod.State())18}19import "fmt"20import "github.com/udhos/gobus/modules"21func main() {22  mod := modules.New()23  fmt.Println(mod.State())24}25import "fmt"26import "github.com/udhos/gobus/modules"27func main() {28  mod := modules.New()29  fmt.Println(mod.State())30}31import "fmt"32import "github.com/udhos/gobus/modules"33func main() {34  mod := modules.New()35  fmt.Println(mod.State())36}37import "fmt"38import "github.com/udhos/gobus/modules"39func main() {40  mod := modules.New()41  fmt.Println(mod.State())42}43import "fmt"44import "github.com/udhos/gobus/modules"45func main() {46  mod := modules.New()47  fmt.Println(mod.State())48}49import "fmt"50import "github.com/udhos/gobus/modules"51func main() {52  mod := modules.New()53  fmt.Println(mod.State())54}

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.