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

Copied to Clipboard!

Automation Advisor
K6
local
newTestExecutionScheduler

How to use newTestExecutionScheduler method of local Package

Best K6 code snippet using local.newTestExecutionScheduler

k6execution_test.go

Source:k6execution_test.go

...89		builtinMetrics,90		registry,91	)92	require.NoError(t, err)93	ctx, cancel, execScheduler, samples := newTestExecutionScheduler(t, runner, logger, lib.Options{})94	defer cancel()95	type vuStat struct {96		iteration uint6497		scIter    map[string]uint6498	}99	vuStats := map[uint64]*vuStat{}100	type logEntry struct {101		IDInInstance        uint64102		Scenario            string103		IterationInInstance uint64104		IterationInScenario uint64105	}106	errCh := make(chan error, 1)107	go func() { errCh <- execScheduler.Run(ctx, ctx, samples, builtinMetrics) }()108	select {109	case err := <-errCh:110		require.NoError(t, err)111		entries := logHook.Drain()112		assert.InDelta(t, 20, len(entries), 2)113		le := &logEntry{}114		for _, entry := range entries {115			err = json.Unmarshal([]byte(entry.Message), le)116			require.NoError(t, err)117			assert.Contains(t, []uint64{1, 2}, le.IDInInstance)118			if _, ok := vuStats[le.IDInInstance]; !ok {119				vuStats[le.IDInInstance] = &vuStat{0, make(map[string]uint64)}120			}121			if le.IterationInInstance > vuStats[le.IDInInstance].iteration {122				vuStats[le.IDInInstance].iteration = le.IterationInInstance123			}124			if le.IterationInScenario > vuStats[le.IDInInstance].scIter[le.Scenario] {125				vuStats[le.IDInInstance].scIter[le.Scenario] = le.IterationInScenario126			}127		}128		require.Len(t, vuStats, 2)129		// Both VUs should complete 10 iterations each globally, but 5130		// iterations each per scenario (iterations are 0-based)131		for _, v := range vuStats {132			assert.Equal(t, uint64(9), v.iteration)133			assert.Equal(t, uint64(4), v.scIter["cvus"])134			assert.Equal(t, uint64(4), v.scIter["carr"])135		}136	case <-time.After(10 * time.Second):137		t.Fatal("timed out")138	}139}140func TestExecutionInfoScenarioIter(t *testing.T) {141	t.Parallel()142	script := []byte(`143		import exec from 'k6/execution';144		// The pvu scenario should reuse the two VUs created for the carr scenario.145		export let options = {146			scenarios: {147				carr: {148					executor: 'constant-arrival-rate',149					exec: 'carr',150					rate: 9,151					timeUnit: '0.95s',152					duration: '1s',153					preAllocatedVUs: 2,154					maxVUs: 10,155					gracefulStop: '100ms',156				},157				pvu: {158					executor: 'per-vu-iterations',159					exec: 'pvu',160					vus: 2,161					iterations: 5,162					startTime: '2s',163					gracefulStop: '100ms',164				},165			},166		};167		export function pvu() {168			const info = Object.assign({VUID: __VU}, exec.scenario);169			console.log(JSON.stringify(info));170		}171		export function carr() {172			const info = Object.assign({VUID: __VU}, exec.scenario);173			console.log(JSON.stringify(info));174		};175`)176	logger := logrus.New()177	logger.SetOutput(ioutil.Discard)178	logHook := testutils.SimpleLogrusHook{HookedLevels: []logrus.Level{logrus.InfoLevel}}179	logger.AddHook(&logHook)180	registry := metrics.NewRegistry()181	builtinMetrics := metrics.RegisterBuiltinMetrics(registry)182	runner, err := js.New(183		logger,184		&loader.SourceData{185			URL:  &url.URL{Path: "/script.js"},186			Data: script,187		},188		nil,189		lib.RuntimeOptions{},190		builtinMetrics,191		registry,192	)193	require.NoError(t, err)194	ctx, cancel, execScheduler, samples := newTestExecutionScheduler(t, runner, logger, lib.Options{})195	defer cancel()196	errCh := make(chan error, 1)197	go func() { errCh <- execScheduler.Run(ctx, ctx, samples, builtinMetrics) }()198	scStats := map[string]uint64{}199	type logEntry struct {200		Name                      string201		IterationInInstance, VUID uint64202	}203	select {204	case err := <-errCh:205		require.NoError(t, err)206		entries := logHook.Drain()207		require.Len(t, entries, 20)208		le := &logEntry{}209		for _, entry := range entries {210			err = json.Unmarshal([]byte(entry.Message), le)211			require.NoError(t, err)212			assert.Contains(t, []uint64{1, 2}, le.VUID)213			if le.IterationInInstance > scStats[le.Name] {214				scStats[le.Name] = le.IterationInInstance215			}216		}217		require.Len(t, scStats, 2)218		// The global per scenario iteration count should be 9 (iterations219		// start at 0), despite VUs being shared or more than 1 being used.220		for _, v := range scStats {221			assert.Equal(t, uint64(9), v)222		}223	case <-time.After(10 * time.Second):224		t.Fatal("timed out")225	}226}227// Ensure that scenario iterations returned from k6/execution are228// stable during the execution of an iteration.229func TestSharedIterationsStable(t *testing.T) {230	t.Parallel()231	script := []byte(`232		import { sleep } from 'k6';233		import exec from 'k6/execution';234		export let options = {235			scenarios: {236				test: {237					executor: 'shared-iterations',238					vus: 50,239					iterations: 50,240				},241			},242		};243		export default function () {244			sleep(1);245			console.log(JSON.stringify(Object.assign({VUID: __VU}, exec.scenario)));246		}247`)248	logger := logrus.New()249	logger.SetOutput(ioutil.Discard)250	logHook := testutils.SimpleLogrusHook{HookedLevels: []logrus.Level{logrus.InfoLevel}}251	logger.AddHook(&logHook)252	registry := metrics.NewRegistry()253	builtinMetrics := metrics.RegisterBuiltinMetrics(registry)254	runner, err := js.New(255		logger,256		&loader.SourceData{257			URL:  &url.URL{Path: "/script.js"},258			Data: script,259		},260		nil,261		lib.RuntimeOptions{},262		builtinMetrics,263		registry,264	)265	require.NoError(t, err)266	ctx, cancel, execScheduler, samples := newTestExecutionScheduler(t, runner, logger, lib.Options{})267	defer cancel()268	errCh := make(chan error, 1)269	go func() { errCh <- execScheduler.Run(ctx, ctx, samples, builtinMetrics) }()270	expIters := [50]int64{}271	for i := 0; i < 50; i++ {272		expIters[i] = int64(i)273	}274	gotLocalIters, gotGlobalIters := []int64{}, []int64{}275	type logEntry struct{ IterationInInstance, IterationInTest int64 }276	select {277	case err := <-errCh:278		require.NoError(t, err)279		entries := logHook.Drain()280		require.Len(t, entries, 50)281		le := &logEntry{}282		for _, entry := range entries {283			err = json.Unmarshal([]byte(entry.Message), le)284			require.NoError(t, err)285			require.Equal(t, le.IterationInInstance, le.IterationInTest)286			gotLocalIters = append(gotLocalIters, le.IterationInInstance)287			gotGlobalIters = append(gotGlobalIters, le.IterationInTest)288		}289		assert.ElementsMatch(t, expIters, gotLocalIters)290		assert.ElementsMatch(t, expIters, gotGlobalIters)291	case <-time.After(5 * time.Second):292		t.Fatal("timed out")293	}294}295func TestExecutionInfoAll(t *testing.T) {296	t.Parallel()297	scriptTemplate := `298	import { sleep } from 'k6';299	import exec from "k6/execution";300	export let options = {301		scenarios: {302			executor: {303				executor: "%[1]s",304				%[2]s305			}306		}307	}308	export default function () {309		sleep(0.2);310		console.log(JSON.stringify(exec));311	}`312	executorConfigs := map[string]string{313		"constant-arrival-rate": `314			rate: 1,315			timeUnit: "1s",316			duration: "1s",317			preAllocatedVUs: 1,318			maxVUs: 2,319			gracefulStop: "0s",`,320		"constant-vus": `321			vus: 1,322			duration: "1s",323			gracefulStop: "0s",`,324		"externally-controlled": `325			vus: 1,326			duration: "1s",`,327		"per-vu-iterations": `328			vus: 1,329			iterations: 1,330			gracefulStop: "0s",`,331		"shared-iterations": `332			vus: 1,333			iterations: 1,334			gracefulStop: "0s",`,335		"ramping-arrival-rate": `336			startRate: 1,337			timeUnit: "0.5s",338			preAllocatedVUs: 1,339			maxVUs: 2,340			stages: [ { target: 1, duration: "1s" } ],341			gracefulStop: "0s",`,342		"ramping-vus": `343			startVUs: 1,344			stages: [ { target: 1, duration: "1s" } ],345			gracefulStop: "0s",`,346	}347	testCases := []struct{ name, script string }{}348	for ename, econf := range executorConfigs {349		testCases = append(testCases, struct{ name, script string }{350			ename, fmt.Sprintf(scriptTemplate, ename, econf),351		})352	}353	// We're only checking a small subset of all properties, to ensure354	// there were no errors with accessing any of the top-level ones.355	// Most of the others are time-based, and would be difficult/flaky to check.356	type logEntry struct {357		Scenario struct{ Executor string }358		Instance struct{ VUsActive int }359		VU       struct{ IDInTest int }360	}361	for _, tc := range testCases {362		tc := tc363		t.Run(tc.name, func(t *testing.T) {364			t.Parallel()365			logger := logrus.New()366			logger.SetOutput(ioutil.Discard)367			logHook := testutils.SimpleLogrusHook{HookedLevels: []logrus.Level{logrus.InfoLevel}}368			logger.AddHook(&logHook)369			registry := metrics.NewRegistry()370			builtinMetrics := metrics.RegisterBuiltinMetrics(registry)371			runner, err := js.New(logger, &loader.SourceData{372				URL:  &url.URL{Path: "/script.js"},373				Data: []byte(tc.script),374			}, nil, lib.RuntimeOptions{}, builtinMetrics, registry)375			require.NoError(t, err)376			ctx, cancel, execScheduler, samples := newTestExecutionScheduler(t, runner, logger, lib.Options{})377			defer cancel()378			errCh := make(chan error, 1)379			go func() { errCh <- execScheduler.Run(ctx, ctx, samples, builtinMetrics) }()380			select {381			case err := <-errCh:382				require.NoError(t, err)383				entries := logHook.Drain()384				require.GreaterOrEqual(t, len(entries), 1)385				le := &logEntry{}386				err = json.Unmarshal([]byte(entries[0].Message), le)387				require.NoError(t, err)388				assert.Equal(t, tc.name, le.Scenario.Executor)389				assert.Equal(t, 1, le.Instance.VUsActive)390				assert.Equal(t, 1, le.VU.IDInTest)...

newTestExecutionScheduler

Using AI Code Generation

1import "fmt"2type A struct {3}4func (a *A) GetName() string {5}6type B struct {7}8func main() {9    a := &A{name: "A"}10    b := &B{a}11    fmt.Println(b.GetName())12}13How can I access GetName() method of A from B ?14type MyStruct struct {15}16func main() {17    m := make(map[MyStruct]int)18}19type MyStruct struct {20}21func (ms MyStruct) Hash() int {22}23func main() {24    m := make(map[MyStruct]int)25}26type MyStruct struct {27}28func (ms *MyStruct) Hash() int {29}30func main() {31    m := make(map[*MyStruct]int)32}33type MyStruct struct {34}35func (ms MyStruct) Hash() int {36}37func (ms MyStruct) Equal(other MyStruct) bool {

newTestExecutionScheduler

Using AI Code Generation

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

newTestExecutionScheduler

Using AI Code Generation

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

newTestExecutionScheduler

Using AI Code Generation

1import "fmt"2func main() {3    fmt.Println("Hello, playground")4    local := new(local)5    local.newTestExecutionScheduler()6}7import "fmt"8func main() {9    fmt.Println("Hello, playground")10    local := local{}11    local.newTestExecutionScheduler()12}13./2.go:7: cannot use local (type local) as type *local in assignment:14local does not implement *local (missing newTestExecutionScheduler method)

newTestExecutionScheduler

Using AI Code Generation

1public class Test {2    public static void main(String[] args) {3        TestExecutionScheduler scheduler = new TestExecutionScheduler();4        scheduler.newTestExecutionScheduler();5    }6}

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.