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

Copied to Clipboard!

How to use GetStartTime method of executor Package

Best K6 code snippet using executor.GetStartTime

executors.go

Source:executors.go

...69type ExecutorConfig interface {70	Validate() []error71	GetName() string72	GetType() string73	GetStartTime() time.Duration74	GetGracefulStop() time.Duration75	// This is used to validate whether a particular script can run in the cloud76	// or, in the future, in the native k6 distributed execution. Currently only77	// the externally-controlled executor should return false.78	IsDistributable() bool79	GetEnv() map[string]string80	// Allows us to get the non-default function the executor should run, if it81	// has been specified.82	//83	// TODO: use interface{} so plain http requests can be specified?84	GetExec() string85	GetTags() map[string]string86	// Calculates the VU requirements in different stages of the executor's87	// execution, including any extensions caused by waiting for iterations to88	// finish with graceful stops or ramp-downs.89	GetExecutionRequirements(*ExecutionTuple) []ExecutionStep90	// Return a human-readable description of the executor91	GetDescription(*ExecutionTuple) string92	NewExecutor(*ExecutionState, *logrus.Entry) (Executor, error)93	// HasWork reports whether there is any work for the executor to do with a given segment.94	HasWork(*ExecutionTuple) bool95}96// InitVUFunc is just a shorthand so we don't have to type the function97// signature every time.98type InitVUFunc func(context.Context, *logrus.Entry) (InitializedVU, error)99// Executor is the interface all executors should implement100type Executor interface {101	GetConfig() ExecutorConfig102	GetProgress() *pb.ProgressBar103	GetLogger() *logrus.Entry104	Init(ctx context.Context) error105	Run(ctx context.Context, engineOut chan<- stats.SampleContainer) error106}107// PausableExecutor should be implemented by the executors that can be paused108// and resumed in the middle of the test execution. Currently, only the109// externally controlled executor implements it.110type PausableExecutor interface {111	SetPaused(bool) error112}113// LiveUpdatableExecutor should be implemented for the executors whose114// configuration can be modified in the middle of the test execution. Currently,115// only the manual execution executor implements it.116type LiveUpdatableExecutor interface {117	UpdateConfig(ctx context.Context, newConfig interface{}) error118}119// ExecutorConfigConstructor is a simple function that returns a concrete120// Config instance with the specified name and all default values correctly121// initialized122type ExecutorConfigConstructor func(name string, rawJSON []byte) (ExecutorConfig, error)123// RegisterExecutorConfigType adds the supplied ExecutorConfigConstructor as124// the constructor for its type in the configConstructors map, in a thread-safe125// manner126func RegisterExecutorConfigType(configType string, constructor ExecutorConfigConstructor) {127	executorConfigTypesMutex.Lock()128	defer executorConfigTypesMutex.Unlock()129	if constructor == nil {130		panic("executor configs: constructor is nil")131	}132	if _, configTypeExists := executorConfigConstructors[configType]; configTypeExists {133		panic("executor configs: lib.RegisterExecutorConfigType called twice for  " + configType)134	}135	executorConfigConstructors[configType] = constructor136}137// ScenarioConfigs can contain mixed executor config types138type ScenarioConfigs map[string]ExecutorConfig139// UnmarshalJSON implements the json.Unmarshaler interface in a two-step manner,140// creating the correct type of configs based on the `type` property.141func (scs *ScenarioConfigs) UnmarshalJSON(data []byte) error {142	if len(data) == 0 {143		return nil144	}145	if len(data) == 4 && string(data) == "null" {146		return nil147	}148	// TODO: use a more sophisticated combination of dec.Token() and dec.More(),149	// which would allow us to support both arrays and maps for this config?150	var protoConfigs map[string]protoExecutorConfig151	if err := StrictJSONUnmarshal(data, &protoConfigs); err != nil {152		return err153	}154	result := make(ScenarioConfigs, len(protoConfigs))155	for k, v := range protoConfigs {156		if v.executorType == "" {157			return fmt.Errorf("scenario '%s' doesn't have a specified executor type", k)158		}159		config, err := GetParsedExecutorConfig(k, v.executorType, v.rawJSON)160		if err != nil {161			return err162		}163		result[k] = config164	}165	*scs = result166	return nil167}168// Validate checks if all of the specified executor options make sense169func (scs ScenarioConfigs) Validate() (errors []error) {170	for name, exec := range scs {171		if execErr := exec.Validate(); len(execErr) != 0 {172			errors = append(errors,173				fmt.Errorf("scenario %s has configuration errors: %s", name, ConcatErrors(execErr, ", ")))174		}175	}176	return errors177}178// GetSortedConfigs returns a slice with the executor configurations,179// sorted in a consistent and predictable manner. It is useful when we want or180// have to avoid using maps with string keys (and tons of string lookups in181// them) and avoid the unpredictable iterations over Go maps. Slices allow us182// constant-time lookups and ordered iterations.183//184// The configs in the returned slice will be sorted by their start times in an185// ascending order, and alphabetically by their names (which are unique) if186// there are ties.187func (scs ScenarioConfigs) GetSortedConfigs() []ExecutorConfig {188	configs := make([]ExecutorConfig, len(scs))189	// Populate the configs slice with sorted executor configs190	i := 0191	for _, config := range scs {192		configs[i] = config // populate the slice in an unordered manner193		i++194	}195	sort.Slice(configs, func(a, b int) bool { // sort by (start time, name)196		switch {197		case configs[a].GetStartTime() < configs[b].GetStartTime():198			return true199		case configs[a].GetStartTime() == configs[b].GetStartTime():200			return strings.Compare(configs[a].GetName(), configs[b].GetName()) < 0201		default:202			return false203		}204	})205	return configs206}207// GetFullExecutionRequirements combines the execution requirements from all of208// the configured executors. It takes into account their start times and their209// individual VU requirements and calculates the total VU requirements for each210// moment in the test execution.211func (scs ScenarioConfigs) GetFullExecutionRequirements(et *ExecutionTuple) []ExecutionStep {212	sortedConfigs := scs.GetSortedConfigs()213	// Combine the steps and requirements from all different executors, and214	// sort them by their time offset, counting the executors' startTimes as215	// well.216	type trackedStep struct {217		ExecutionStep218		configID int219	}220	trackedSteps := []trackedStep{}221	for configID, config := range sortedConfigs { // orderly iteration over a slice222		configStartTime := config.GetStartTime()223		configSteps := config.GetExecutionRequirements(et)224		for _, cs := range configSteps {225			cs.TimeOffset += configStartTime // add the executor start time to the step time offset226			trackedSteps = append(trackedSteps, trackedStep{cs, configID})227		}228	}229	// Sort by (time offset, config id). It's important that we use stable230	// sorting algorithm, since there could be steps with the same time from231	// the same executor and their order is important.232	sort.SliceStable(trackedSteps, func(a, b int) bool {233		if trackedSteps[a].TimeOffset == trackedSteps[b].TimeOffset {234			return trackedSteps[a].configID < trackedSteps[b].configID235		}236		return trackedSteps[a].TimeOffset < trackedSteps[b].TimeOffset...

task_builder.go

Source:task_builder.go

...16	case Type_TASK_STATE:17		to := ev.GetState()18		t.State = to19	case Type_TASK_START_TIME:20		t.GetTaskLog(attempt).StartTime = ev.GetStartTime()21	case Type_TASK_END_TIME:22		t.GetTaskLog(attempt).EndTime = ev.GetEndTime()23	case Type_TASK_OUTPUTS:24		t.GetTaskLog(attempt).Outputs = ev.GetOutputs().Value25	case Type_TASK_METADATA:26		t.GetTaskLog(attempt).Metadata = ev.GetMetadata().Value27	case Type_EXECUTOR_START_TIME:28		t.GetExecLog(attempt, index).StartTime = ev.GetStartTime()29	case Type_EXECUTOR_END_TIME:30		t.GetExecLog(attempt, index).EndTime = ev.GetEndTime()31	case Type_EXECUTOR_EXIT_CODE:32		t.GetExecLog(attempt, index).ExitCode = ev.GetExitCode()33	case Type_EXECUTOR_STDOUT:34		t.GetExecLog(attempt, index).Stdout += ev.GetStdout()35	case Type_EXECUTOR_STDERR:36		t.GetExecLog(attempt, index).Stderr += ev.GetStderr()37		// TODO include system logs?38	}39}...

GetStartTime

Using AI Code Generation

1import (2func main() {3	c := cron.New()4	c.AddFunc("*/1 * * * *", func() { fmt.Println("Every hour on the half hour") })5	c.Start()6	time.Sleep(2 * time.Second)7	c.Stop()8}

GetStartTime

Using AI Code Generation

1import (2func main() {3	executor := executor.New()4	fmt.Println(executor.GetStartTime())5}6import (7func main() {8	executor := executor.New()9	fmt.Println(executor.GetStartTime())10}

GetStartTime

Using AI Code Generation

1import (2func main() {3	executor := NewExecutor()4	executor.AddTask("task", func() {5	})6	executor.Start()7	startTime := executor.GetStartTime()8	fmt.Println("Start time of the executor:", startTime)9	time.Sleep(2 * time.Second)10}11import (12func main() {13	executor := NewExecutor()14	executor.AddTask("task", func() {15	})16	executor.Start()17	tasks := executor.GetTasks()18	fmt.Println("Tasks of the executor:", tasks)19}20import (21func main() {22	executor := NewExecutor()23	executor.AddTask("task", func() {24	})25	executor.Start()

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.