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

Copied to Clipboard!

Automation Advisor
K6
executor
maxAllowedVUsHandlerStrategy

How to use maxAllowedVUsHandlerStrategy method of executor Package

Best K6 code snippet using executor.maxAllowedVUsHandlerStrategy

ramping_vus.go

Source:ramping_vus.go

...501	// this will populate stopped VUs and run runLoopsIfPossible on each VU502	// handle in a new goroutine503	runState.runLoopsIfPossible(maxDurationCtx, cancel)504	var (505		handleNewMaxAllowedVUs = runState.maxAllowedVUsHandlerStrategy()506		handleNewScheduledVUs  = runState.scheduledVUsHandlerStrategy()507	)508	handledGracefulSteps := runState.iterateSteps(509		ctx,510		handleNewMaxAllowedVUs,511		handleNewScheduledVUs,512	)513	go runState.runRemainingGracefulSteps(514		ctx,515		handleNewMaxAllowedVUs,516		handledGracefulSteps,517	)518	return nil519}520// rampingVUsRunState is created and initialized by the Run() method521// of the ramping VUs executor. It is used to track and modify various522// details of the execution.523type rampingVUsRunState struct {524	executor       *RampingVUs525	vuHandles      []*vuHandle // handles for manipulating and tracking all of the VUs526	maxVUs         uint64      // the scaled number of initially configured MaxVUs527	activeVUsCount *int64      // the current number of active VUs, used only for the progress display528	started        time.Time529	wg             sync.WaitGroup530	runIteration func(context.Context, lib.ActiveVU) bool // a helper closure function that runs a single iteration531}532func (rs *rampingVUsRunState) makeProgressFn(regular time.Duration) (progressFn func() (float64, []string)) {533	vusFmt := pb.GetFixedLengthIntFormat(int64(rs.maxVUs))534	regularDuration := pb.GetFixedLengthDuration(regular, regular)535	return func() (float64, []string) {536		spent := time.Since(rs.started)537		cur := atomic.LoadInt64(rs.activeVUsCount)538		progVUs := fmt.Sprintf(vusFmt+"/"+vusFmt+" VUs", cur, rs.maxVUs)539		if spent > regular {540			return 1, []string{progVUs, regular.String()}541		}542		status := pb.GetFixedLengthDuration(spent, regular) + "/" + regularDuration543		return float64(spent) / float64(regular), []string{progVUs, status}544	}545}546func (rs *rampingVUsRunState) runLoopsIfPossible(ctx context.Context, cancel func()) {547	getVU := func() (lib.InitializedVU, error) {548		pvu, err := rs.executor.executionState.GetPlannedVU(rs.executor.logger, false)549		if err != nil {550			rs.executor.logger.WithError(err).Error("Cannot get a VU from the buffer")551			cancel()552			return pvu, err553		}554		rs.wg.Add(1)555		atomic.AddInt64(rs.activeVUsCount, 1)556		rs.executor.executionState.ModCurrentlyActiveVUsCount(+1)557		return pvu, err558	}559	returnVU := func(initVU lib.InitializedVU) {560		rs.executor.executionState.ReturnVU(initVU, false)561		atomic.AddInt64(rs.activeVUsCount, -1)562		rs.wg.Done()563		rs.executor.executionState.ModCurrentlyActiveVUsCount(-1)564	}565	for i := uint64(0); i < rs.maxVUs; i++ {566		rs.vuHandles[i] = newStoppedVUHandle(567			ctx, getVU, returnVU, rs.executor.nextIterationCounters,568			&rs.executor.config.BaseConfig, rs.executor.logger.WithField("vuNum", i))569		go rs.vuHandles[i].runLoopsIfPossible(rs.runIteration)570	}571}572// iterateSteps iterates over rawSteps and gracefulSteps in order according to573// their TimeOffsets, prioritizing rawSteps. It stops iterating once rawSteps574// are over. And it returns the number of handled gracefulSteps.575func (rs *rampingVUsRunState) iterateSteps(576	ctx context.Context,577	handleNewMaxAllowedVUs, handleNewScheduledVUs func(lib.ExecutionStep),578) (handledGracefulSteps int) {579	wait := waiter(ctx, rs.started)580	i, j := 0, 0581	for i != len(rs.executor.rawSteps) {582		r, g := rs.executor.rawSteps[i], rs.executor.gracefulSteps[j]583		if g.TimeOffset < r.TimeOffset {584			if wait(g.TimeOffset) {585				break586			}587			handleNewMaxAllowedVUs(g)588			j++589		} else {590			if wait(r.TimeOffset) {591				break592			}593			handleNewScheduledVUs(r)594			i++595		}596	}597	return j598}599// runRemainingGracefulSteps runs the remaining gracefulSteps concurrently600// before the gracefulStop timeout period stops VUs.601//602// This way we will have run the gracefulSteps at the same time while603// waiting for the VUs to finish.604//605// (gracefulStop = maxDuration-regularDuration)606func (rs *rampingVUsRunState) runRemainingGracefulSteps(607	ctx context.Context,608	handleNewMaxAllowedVUs func(lib.ExecutionStep),609	handledGracefulSteps int,610) {611	wait := waiter(ctx, rs.started)612	for _, s := range rs.executor.gracefulSteps[handledGracefulSteps:] {613		if wait(s.TimeOffset) {614			return615		}616		handleNewMaxAllowedVUs(s)617	}618}619func (rs *rampingVUsRunState) maxAllowedVUsHandlerStrategy() func(lib.ExecutionStep) {620	var cur uint64 // current number of planned graceful VUs621	return func(graceful lib.ExecutionStep) {622		pv := graceful.PlannedVUs623		for ; pv < cur; cur-- {624			rs.vuHandles[cur-1].hardStop()625		}626		cur = pv627	}628}629func (rs *rampingVUsRunState) scheduledVUsHandlerStrategy() func(lib.ExecutionStep) {630	var cur uint64 // current number of planned raw VUs631	return func(raw lib.ExecutionStep) {632		pv := raw.PlannedVUs633		for ; cur < pv; cur++ {...

maxAllowedVUsHandlerStrategy

Using AI Code Generation

1import (2func main() {3	r, err := lib.NewTestRunner(lib.Options{})4	if err != nil {5		fmt.Println(err)6	}7	ctx, cancel := context.WithCancel(context.Background())8	defer cancel()9	maxDuration, _ := types.NewNullDuration(10*time.Second, types.NullDurationSource{Value: 10 * time.Second, Valid: true})10	executorConfig := executor.NewConstantArrivalRateConfig("executor", 1, 1, maxDuration)11	maxAllowedVUsHandler := executor.NewConstantArrivalRate(executorConfig)12	run := &lib.Runner{13		Options: lib.Options{14			MaxVUs: null.IntFrom(10),15		},16	}17	if err := maxAllowedVUsHandler.Init(ctx, r, run); err != nil {18		fmt.Println(err)19	}20	if err := maxAllowedVUsHandler.Run(ctx, r, run); err != nil {21		fmt.Println(err)22	}23	fmt.Println("DONE")24}25import (26func main() {27	r, err := lib.NewTestRunner(lib.Options{})

maxAllowedVUsHandlerStrategy

Using AI Code Generation

1import (2func main() {3	fmt.Println("Hello, playground")4	es := executor.NewExecutionScheduler([]lib.ExecutionStep{5		{executor: executor.NewConstantVUsPerDurationConfig("1", 1, 1, 1*time.Second)},6		{executor: executor.NewConstantVUsPerDurationConfig("2", 1, 1, 1*time.Second)},7	})8	ctx, cancel := context.WithCancel(context.Background())9	defer cancel()10	testRun := testutils.NewTestRun(t)11	defer testRun.CleanUp()12	engine, err := NewEngine(es, testRun.Logger, testRun.Samples)13	if err != nil {14		t.Fatal(err)15	}16	err = engine.Run(ctx, lib.RuntimeOptions{})17	if err != nil {18		t.Fatal(err)19	}20	data := engine.GetFullExecutionData()21	if len(data) != 1 {22		t.Fatalf("Expected 1 test run, got %d", len(data))23	}24	data := engine.GetFullExecutionData()25	if len(data) != 1 {26		t.Fatalf("Expected 1 test run, got %d", len(data))27	}28	checkMetrics(t, data[0].Metrics, []stats.Metric{29		{Name: "http_reqs", Type: stats.Counter},30		{Name: "http_req_duration", Type: stats.Trend},31		{Name: "http_req_blocked", Type: stats.Trend},32		{Name: "http_req_connecting", Type: stats.Trend},33		{Name: "http_req_sending", Type: stats.Trend},34		{Name: "http_req_waiting", Type: stats.Trend},35		{Name: "http_req_receiving", Type: stats.Trend},36		{Name: "iterations", Type: stats.Counter},37		{Name: "vus", Type: stats.Gauge},38		{Name: "vus_max", Type: stats.Gauge},39	})40}

maxAllowedVUsHandlerStrategy

Using AI Code Generation

1import (2func main() {3	maxVUs := null.NewInt(100, true)4	executorConfig := lib.ExecutorConfig{5		MaxDuration:  types.NullDurationFrom(10 * time.Second),6		StartTime:    types.NullDurationFrom(5 * time.Second),7		GracefulStop: types.NullDurationFrom(1 * time.Second),8	}9	executorConfigRaw, _ := executorConfig.MarshalJSON()10	executor, err := executor.New(executorConfigRaw, nil)11	if err != nil {12		fmt.Println(err)13	}14	engineOut := make(chan stats.SampleContainer, 1000)15	engine := &lib.Engine{16		MaxVUs: null.NewInt(100, true),17	}18	runner, err := loader.Load(19		&loader.SourceData{20			URL: &url.URL{Path: "/script.js"},21			Data: []byte(`22			import http from "k6/http";23			export let options = {24				scenarios: {25					example_scenario: {26					},27				},28			};29			export default function () {30			}31		},32		lib.RuntimeOptions{},33	if err != nil {34		fmt.Println(err)35	}36	ctx, cancel := context.WithCancel(context.Background())37	defer cancel()38	err = executor.Run(ctx, engine, runner.GetDefaultGroup())39	if err != nil {40		fmt.Println(err)41	}42}43import (

maxAllowedVUsHandlerStrategy

Using AI Code Generation

1func main() {2    executor := maxAllowedVUsHandlerStrategy{}3    executor.initializeExecutor()4    executor.maxAllowedVUsHandler(10)5}6func main() {7    executor := maxAllowedVUsHandlerStrategy{}8    executor.initializeExecutor()9    executor.maxAllowedVUsHandler(20)10}11func main() {12    executor := maxAllowedVUsHandlerStrategy{}13    executor.initializeExecutor()14    executor.maxAllowedVUsHandler(30)15}16func main() {17    executor := maxAllowedVUsHandlerStrategy{}18    executor.initializeExecutor()19    executor.maxAllowedVUsHandler(40)20}21func main() {22    executor := maxAllowedVUsHandlerStrategy{}23    executor.initializeExecutor()24    executor.maxAllowedVUsHandler(50)25}26func main() {27    executor := maxAllowedVUsHandlerStrategy{}28    executor.initializeExecutor()29    executor.maxAllowedVUsHandler(60)30}31func main() {32    executor := maxAllowedVUsHandlerStrategy{}33    executor.initializeExecutor()34    executor.maxAllowedVUsHandler(70)35}36func main() {37    executor := maxAllowedVUsHandlerStrategy{}38    executor.initializeExecutor()39    executor.maxAllowedVUsHandler(80)40}41func main() {42    executor := maxAllowedVUsHandlerStrategy{}43    executor.initializeExecutor()44    executor.maxAllowedVUsHandler(90)45}46func main() {47    executor := maxAllowedVUsHandlerStrategy{}48    executor.initializeExecutor()49    executor.maxAllowedVUsHandler(100)50}

maxAllowedVUsHandlerStrategy

Using AI Code Generation

1func main() {2    executor := newExecutor()3    ctx := context.Background()4    engine := newEngine(ctx, executor)5    engine.Run(ctx)6}7func newExecutor() *lib.Executor {8    executor := &lib.Executor{9        Config: lib.ExecutorConfig{10            Duration: types.NullDurationFrom(11        },12        Strategy: lib.NewPerVUIterationsStrategy(13        Runner: &lib.MixedRunner{14            Config: lib.MixedRunnerConfig{15                Runners: []lib.RunnerConfig{16                    {17                        Source: lib.SourceData{18                            Data:      `export let options = { vus: 2, duration: "5s" }; export default function() { console.log("hello") }`,19                        },20                    },21                },22            },23        },24    }25}26func newEngine(ctx context.Context, executor *lib.Executor) *lib.Engine {

maxAllowedVUsHandlerStrategy

Using AI Code Generation

1func init() {2    rootCmd.AddCommand(maxAllowedVUsCmd)3    maxAllowedVUsCmd.Flags().IntVarP(&maxAllowedVUs, "maxAllowedVUs", "m", 0, "Set maxAllowedVUs for the executor")4    maxAllowedVUsCmd.Flags().StringVarP(&exec, "exec", "e", "", "Set the executor")5}6func init() {7    rootCmd.AddCommand(maxAllowedVUsCmd)8    maxAllowedVUsCmd.Flags().IntVarP(&maxAllowedVUs, "maxAllowedVUs", "m", 0, "Set maxAllowedVUs for the executor")9    maxAllowedVUsCmd.Flags().StringVarP(&exec, "exec", "e", "", "Set the executor")10}11func init() {12    rootCmd.AddCommand(maxAllowedVUsCmd)13    maxAllowedVUsCmd.Flags().IntVarP(&maxAllowedVUs, "maxAllowedVUs", "m", 0, "Set maxAllowedVUs for the executor")14    maxAllowedVUsCmd.Flags().StringVarP(&exec, "exec", "e", "", "Set the executor")15}16func init() {17    rootCmd.AddCommand(maxAllowedVUsCmd)18    maxAllowedVUsCmd.Flags().IntVarP(&maxAllowedVUs, "maxAllowedVUs", "m", 0, "Set maxAllowedVUs for the executor")19    maxAllowedVUsCmd.Flags().StringVarP(&exec, "exec", "e", "", "Set the executor")20}

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.