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

Copied to Clipboard!

Automation Advisor
K6
executor
retrieveStartMaxVUs

How to use retrieveStartMaxVUs method of executor Package

Best K6 code snippet using executor.retrieveStartMaxVUs

externally_controlled.go

Source:externally_controlled.go

...344	vuHandles       []*manualVUHandle // handles for manipulating and tracking all of the VUs345	currentlyPaused bool              // whether the executor is currently paused346	runIteration func(context.Context, lib.ActiveVU) bool // a helper closure function that runs a single iteration347}348// retrieveStartMaxVUs gets and initializes the (scaled) number of MaxVUs349// from the global VU buffer. These are the VUs that the user originally350// specified in the JS config, and that the ExecutionScheduler pre-initialized351// for us.352func (rs *externallyControlledRunState) retrieveStartMaxVUs() error {353	for i := int64(0); i < rs.startMaxVUs; i++ { // get the initial planned VUs from the common buffer354		initVU, vuGetErr := rs.executor.executionState.GetPlannedVU(rs.executor.logger, false)355		if vuGetErr != nil {356			return vuGetErr357		}358		vuHandle := rs.newManualVUHandle(initVU, rs.executor.logger.WithField("vuNum", i))359		go vuHandle.runLoopsIfPossible(rs.runIteration)360		rs.vuHandles[i] = vuHandle361	}362	return nil363}364func (rs *externallyControlledRunState) progressFn() (float64, []string) {365	// TODO: simulate spinner for the other case or cycle 0-100?366	currentActiveVUs := atomic.LoadInt64(rs.activeVUsCount)367	currentMaxVUs := atomic.LoadInt64(rs.maxVUs)368	vusFmt := pb.GetFixedLengthIntFormat(currentMaxVUs)369	progVUs := fmt.Sprintf(vusFmt+"/"+vusFmt+" VUs", currentActiveVUs, currentMaxVUs)370	right := []string{progVUs, rs.duration.String(), ""}371	// TODO: use a saner way to calculate the elapsed time, without relying on372	// the global execution state...373	elapsed := rs.executor.executionState.GetCurrentTestRunDuration() - rs.executor.config.StartTime.TimeDuration()374	if elapsed > rs.duration {375		return 1, right376	}377	progress := 0.0378	if rs.duration > 0 {379		progress = math.Min(1, float64(elapsed)/float64(rs.duration))380	}381	spentDuration := pb.GetFixedLengthDuration(elapsed, rs.duration)382	progDur := fmt.Sprintf("%s/%s", spentDuration, rs.duration)383	right[1] = progDur384	return progress, right385}386func (rs *externallyControlledRunState) handleConfigChange(oldCfg, newCfg ExternallyControlledConfigParams) error {387	executionState := rs.executor.executionState388	et := executionState.ExecutionTuple389	oldActiveVUs := et.ScaleInt64(oldCfg.VUs.Int64)390	oldMaxVUs := et.ScaleInt64(oldCfg.MaxVUs.Int64)391	newActiveVUs := et.ScaleInt64(newCfg.VUs.Int64)392	newMaxVUs := et.ScaleInt64(newCfg.MaxVUs.Int64)393	rs.executor.logger.WithFields(logrus.Fields{394		"oldActiveVUs": oldActiveVUs, "oldMaxVUs": oldMaxVUs,395		"newActiveVUs": newActiveVUs, "newMaxVUs": newMaxVUs,396	}).Debug("Updating execution configuration...")397	for i := oldMaxVUs; i < newMaxVUs; i++ {398		select { // check if the user didn't try to abort k6 while we're scaling up the VUs399		case <-rs.ctx.Done():400			return rs.ctx.Err()401		default: // do nothing402		}403		initVU, vuInitErr := executionState.InitializeNewVU(rs.ctx, rs.executor.logger)404		if vuInitErr != nil {405			return vuInitErr406		}407		vuHandle := rs.newManualVUHandle(initVU, rs.executor.logger.WithField("vuNum", i))408		go vuHandle.runLoopsIfPossible(rs.runIteration)409		rs.vuHandles = append(rs.vuHandles, vuHandle)410	}411	if oldActiveVUs < newActiveVUs {412		for i := oldActiveVUs; i < newActiveVUs; i++ {413			if !rs.currentlyPaused {414				if err := rs.vuHandles[i].start(); err != nil {415					// TODO: maybe just log it ?416					return err417				}418			}419		}420	} else {421		for i := newActiveVUs; i < oldActiveVUs; i++ {422			rs.vuHandles[i].hardStop()423		}424		for i := newActiveVUs; i < oldActiveVUs; i++ {425			rs.vuHandles[i].wg.Wait()426		}427	}428	if oldMaxVUs > newMaxVUs {429		for i := newMaxVUs; i < oldMaxVUs; i++ {430			rs.vuHandles[i].cancelVU()431			if i < rs.startMaxVUs {432				// return the initial planned VUs to the common buffer433				executionState.ReturnVU(rs.vuHandles[i].initVU, false)434			} else {435				executionState.ModInitializedVUsCount(-1)436			}437			rs.vuHandles[i] = nil438		}439		rs.vuHandles = rs.vuHandles[:newMaxVUs]440	}441	atomic.StoreInt64(rs.maxVUs, newMaxVUs)442	return nil443}444// Run constantly loops through as many iterations as possible on a variable445// dynamically controlled number of VUs either for the specified duration, or446// until the test is manually stopped.447// nolint:funlen,gocognit,cyclop448func (mex *ExternallyControlled) Run(parentCtx context.Context, out chan<- metrics.SampleContainer) (err error) {449	mex.configLock.RLock()450	// Safely get the current config - it's important that the close of the451	// hasStarted channel is inside of the lock, so that there are no data races452	// between it and the UpdateConfig() method.453	currentControlConfig := mex.currentControlConfig454	close(mex.hasStarted)455	mex.configLock.RUnlock()456	ctx, cancel := context.WithCancel(parentCtx)457	defer cancel()458	duration := currentControlConfig.Duration.TimeDuration()459	if duration > 0 { // Only keep track of duration if it's not infinite460		go mex.stopWhenDurationIsReached(ctx, duration, cancel)461	}462	mex.logger.WithFields(463		logrus.Fields{"type": externallyControlledType, "duration": duration},464	).Debug("Starting executor run...")465	startMaxVUs := mex.executionState.ExecutionTuple.ScaleInt64(mex.config.MaxVUs.Int64)466	ss := &lib.ScenarioState{467		Name:      mex.config.Name,468		Executor:  mex.config.Type,469		StartTime: time.Now(),470	}471	ctx = lib.WithScenarioState(ctx, ss)472	runState := &externallyControlledRunState{473		ctx:             ctx,474		executor:        mex,475		startMaxVUs:     startMaxVUs,476		duration:        duration,477		vuHandles:       make([]*manualVUHandle, startMaxVUs),478		currentlyPaused: false,479		activeVUsCount:  new(int64),480		maxVUs:          new(int64),481		runIteration:    getIterationRunner(mex.executionState, mex.logger),482	}483	ss.ProgressFn = runState.progressFn484	*runState.maxVUs = startMaxVUs485	if err = runState.retrieveStartMaxVUs(); err != nil {486		return err487	}488	mex.progress.Modify(pb.WithProgress(runState.progressFn)) // Keep track of the progress489	go trackProgress(parentCtx, ctx, ctx, mex, runState.progressFn)490	err = runState.handleConfigChange( // Start by setting MaxVUs to the starting MaxVUs491		ExternallyControlledConfigParams{MaxVUs: mex.config.MaxVUs}, currentControlConfig,492	)493	if err != nil {494		return err495	}496	defer func() { // Make sure we release the VUs at the end497		err = runState.handleConfigChange(currentControlConfig, ExternallyControlledConfigParams{})498	}()499	for {...

retrieveStartMaxVUs

Using AI Code Generation

1import (2func main() {3    myExecutor := executor.PerVUIterations.New(lib.Options{4        MaxVUs:     types.NullIntFrom(5),5        VUs:        types.NullIntFrom(5),6        Duration:   types.NullDurationFrom(10 * time.Second),7        Iterations: types.NullIntFrom(10),8    })9    myScenario := &lib.Scenario{10        Exec: func(ctx context.Context) {11        },12    }13    myEngine := Engine{14        Options: lib.Options{15            MaxVUs:     types.NullIntFrom(5),16            VUs:        types.NullIntFrom(5),17            Duration:   types.NullDurationFrom(10 * time.Second),18            Iterations: types.NullIntFrom(10),19        },20        Scenarios: []*lib.Scenario{myScenario},21    }22    myEngine.Run(ctx, logger, out)23    maxVUs := myExecutor.GetMaxVUs()24    log.Print(maxVUs)25}26import (27func main() {28    myExecutor := executor.PerVUIterations.New(lib.Options{29        MaxVUs:     types.NullIntFrom(5),30        VUs:        types.NullIntFrom(5),31        Duration:   types.NullDurationFrom(10 * time.Second),32        Iterations: types.NullIntFrom(10),33    })34    myScenario := &lib.Scenario{35        Exec: func(ctx context.Context) {36        },37    }

retrieveStartMaxVUs

Using AI Code Generation

1import (2func main() {3	executor = &executor.PerVUIterations{4		Iterations: types.NullIntFrom(100),5		VUs:        types.NullIntFrom(10),6		MaxVUs:     types.NullIntFrom(100),7	}8	fmt.Println("MaxVUs", executor.GetMaxVUs())9}10How to use the retrieveStartMaxVUs() method of executor class to retrieve the maxVUs value11executor.GetMaxVUs()12import (13func main() {14	executor = &executor.PerVUIterations{15		Iterations: types.NullIntFrom(100),16		VUs:        types.NullIntFrom(10),17		MaxVUs:     types.NullIntFrom(100),18	}19	fmt.Println("MaxVUs", executor.GetMaxVUs())20}21Recommended Posts: Go | GetMaxVUs() method in executor class22Go | GetVUs() method in executor class23Go | GetIterations() method in executor class24Go | GetStartVUs() method in executor class25Go | GetStartMaxVUs() method in executor class26Go | GetScenario() method in executor class27Go | GetExecutionSegment() method in executor class28Go | GetExecutionSegmentSequence() method in executor class29Go | GetExecutionSegment() method in executor.PerVUIterations class30Go | GetExecutionSegmentSequence() method in executor.PerVUIterations class31Go | GetExecutionSegment() method

retrieveStartMaxVUs

Using AI Code Generation

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

retrieveStartMaxVUs

Using AI Code Generation

1import (2func main() {3	executor := lib.NewExecutor("externally-controlled", types.ExternallyControlledConfig{}, nil, stats.NoopSink{})4	state := lib.ExecutorState{5	}6	startMaxVUs, err := executor.RetrieveStartMaxVUs(state)7	fmt.Println("startMaxVUs", startMaxVUs)8	fmt.Println("err", err)9}10func (e *ExternallyControlled) RetrieveMaxPossibleVUs(_ lib.ExecutorState) (uint64, error) {11}12import (13func main() {14	executor := lib.NewExecutor("externally-controlled", types.ExternallyControlledConfig{}, nil, stats.NoopSink{})15	state := lib.ExecutorState{16	}17	maxPossibleVUs, err := executor.RetrieveMaxPossibleVUs(state)18	fmt.Println("maxPossibleVUs", maxPossibleVUs)19	fmt.Println("err", err)20}21func (e *ExternallyControlled) SetRunState(state lib.Run

retrieveStartMaxVUs

Using AI Code Generation

1executor := NewExecutor()2executor.retrieveStartMaxVUs()3executor := NewExecutor()4executor.retrieveStartMaxVUs()5executor := NewExecutor()6executor.retrieveStartMaxVUs()7executor := NewExecutor()8executor.retrieveStartMaxVUs()9executor := NewExecutor()10executor.retrieveStartMaxVUs()11executor := NewExecutor()12executor.retrieveStartMaxVUs()13executor := NewExecutor()14executor.retrieveStartMaxVUs()15executor := NewExecutor()16executor.retrieveStartMaxVUs()17executor := NewExecutor()18executor.retrieveStartMaxVUs()19executor := NewExecutor()20executor.retrieveStartMaxVUs()21executor := NewExecutor()22executor.retrieveStartMaxVUs()23executor := NewExecutor()24executor.retrieveStartMaxVUs()25executor := NewExecutor()26executor.retrieveStartMaxVUs()27executor := NewExecutor()28executor.retrieveStartMaxVUs()29executor := NewExecutor()30executor.retrieveStartMaxVUs()31executor := NewExecutor()

retrieveStartMaxVUs

Using AI Code Generation

1func main() {2    if err != nil {3        log.Fatal(err)4    }5    startMaxVUs, err := executor.RetrieveStartMaxVUs()6    if err != nil {7        log.Fatal(err)8    }9    fmt.Println(startMaxVUs)10}11func main() {12    if err != nil {13        log.Fatal(err)14    }15    startMaxVUs, err := executor.RetrieveStartMaxVUs()16    if err != nil {17        log.Fatal(err)18    }19    fmt.Println(startMaxVUs)20}21func main() {22    if err != nil {23        log.Fatal(err)24    }25    startMaxVUs, err := executor.RetrieveStartMaxVUs()26    if err != nil {27        log.Fatal(err)28    }29    fmt.Println(startMaxVUs)30}31func main() {32    if err != nil {33        log.Fatal(err)34    }35    startMaxVUs, err := executor.RetrieveStartMaxVUs()36    if err != nil {37        log.Fatal(err)38    }39    fmt.Println(startMaxVUs)40}41func main() {42    if err != nil {43        log.Fatal(err)44    }45    startMaxVUs, err := executor.RetrieveStartMaxVUs()46    if err != nil {47        log.Fatal(err)48    }49    fmt.Println(startMaxVUs)50}51func main() {52    if err != nil {53        log.Fatal(err)54    }

retrieveStartMaxVUs

Using AI Code Generation

1func main() {2    executor := new(Executor)3    executor.retrieveStartMaxVUs()4    fmt.Println("Start Max VUs is ", executor.StartMaxVUs)5}6func main() {7    executor := new(Executor)8    executor.retrieveStartMaxVUs()9    fmt.Println("Start Max VUs is ", executor.StartMaxVUs)10}11func main() {12    executor := new(Executor)13    executor.retrieveStartMaxVUs()14    fmt.Println("Start Max VUs is ", executor.StartMaxVUs)15}16func main() {17    executor := new(Executor)18    executor.retrieveStartMaxVUs()19    fmt.Println("Start Max VUs is ", executor.StartMaxVUs)20}21func main() {22    executor := new(Executor)23    executor.retrieveStartMaxVUs()24    fmt.Println("Start Max VUs is ", executor.StartMaxVUs)25}26func main() {27    executor := new(Executor)28    executor.retrieveStartMaxVUs()29    fmt.Println("Start Max VUs is ", executor.StartMaxVUs)30}31func main() {32    executor := new(Executor)33    executor.retrieveStartMaxVUs()34    fmt.Println("Start Max VUs is ", executor.StartMaxVUs)35}36func main() {37    executor := new(Executor)38    executor.retrieveStartMaxVUs()39    fmt.Println("Start Max VUs is ", executor.StartMaxVUs)

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.