How to use GetExecutionPlan method of local Package

Best K6 code snippet using local.GetExecutionPlan

migration.go

Source:migration.go

1package migration2import (3	"context"4	"errors"5	"fmt"6	"sort"7	"sync"8	"time"9	"github.com/hashicorp/go-version"10	"github.com/safing/portbase/database"11	"github.com/safing/portbase/database/record"12	"github.com/safing/portbase/formats/dsd"13	"github.com/safing/portbase/log"14)15// MigrateFunc is called when a migration should be applied to the16// database. It receives the current version (from) and the target17// version (to) of the database and a dedicated interface for18// interacting with data stored in the DB.19// A dedicated log.ContextTracer is added to ctx for each migration20// run.21type MigrateFunc func(ctx context.Context, from, to *version.Version, dbInterface *database.Interface) error22// Migration represents a registered data-migration that should be applied to23// some database. Migrations are stacked on top and executed in order of increasing24// version number (see Version field).25type Migration struct {26	// Description provides a short human-readable description of the27	// migration.28	Description string29	// Version should hold the version of the database/subsystem after30	// the migration has been applied.31	Version string32	// MigrateFuc is executed when the migration should be performed.33	MigrateFunc MigrateFunc34}35// Registry holds a migration stack.36type Registry struct {37	key string38	lock       sync.Mutex39	migrations []Migration40}41// New creates a new migration registry.42// The key should be the name of the database key that is used to store43// the version of the last successfully applied migration.44func New(key string) *Registry {45	return &Registry{46		key: key,47	}48}49// Add adds one or more migrations to reg.50func (reg *Registry) Add(migrations ...Migration) error {51	reg.lock.Lock()52	defer reg.lock.Unlock()53	for _, m := range migrations {54		if _, err := version.NewSemver(m.Version); err != nil {55			return fmt.Errorf("migration %q: invalid version %s: %w", m.Description, m.Version, err)56		}57		reg.migrations = append(reg.migrations, m)58	}59	return nil60}61// Migrate migrates the database by executing all registered62// migration in order of increasing version numbers. The error63// returned, if not nil, is always of type *Diagnostics.64func (reg *Registry) Migrate(ctx context.Context) (err error) {65	reg.lock.Lock()66	defer reg.lock.Unlock()67	start := time.Now()68	log.Infof("migration: migration of %s started", reg.key)69	defer func() {70		if err != nil {71			log.Errorf("migration: migration of %s failed after %s: %s", reg.key, time.Since(start), err)72		} else {73			log.Infof("migration: migration of %s finished after %s", reg.key, time.Since(start))74		}75	}()76	db := database.NewInterface(&database.Options{77		Local:    true,78		Internal: true,79	})80	startOfMigration, err := reg.getLatestSuccessfulMigration(db)81	if err != nil {82		return err83	}84	execPlan, diag, err := reg.getExecutionPlan(startOfMigration)85	if err != nil {86		return err87	}88	if len(execPlan) == 0 {89		return nil90	}91	diag.TargetVersion = execPlan[len(execPlan)-1].Version92	// finally, apply our migrations93	lastAppliedMigration := startOfMigration94	for _, m := range execPlan {95		target, _ := version.NewSemver(m.Version) // we can safely ignore the error here96		migrationCtx, tracer := log.AddTracer(ctx)97		if err := m.MigrateFunc(migrationCtx, lastAppliedMigration, target, db); err != nil {98			diag.Wrapped = err99			diag.FailedMigration = m.Description100			tracer.Infof("migration: applied migration for %s: %s - %s", reg.key, target.String(), m.Description)101			tracer.Submit()102			return diag103		}104		lastAppliedMigration = target105		diag.LastSuccessfulMigration = lastAppliedMigration.String()106		if err := reg.saveLastSuccessfulMigration(db, target); err != nil {107			diag.Message = "failed to persist migration status"108			diag.Wrapped = err109			diag.FailedMigration = m.Description110		}111		tracer.Infof("migration: applied migration for %s: %s - %s", reg.key, target.String(), m.Description)112		tracer.Submit()113	}114	// all migrations have been applied successfully, we're done here115	return nil116}117func (reg *Registry) getLatestSuccessfulMigration(db *database.Interface) (*version.Version, error) {118	// find the latest version stored in the database119	rec, err := db.Get(reg.key)120	if errors.Is(err, database.ErrNotFound) {121		return nil, nil122	}123	if err != nil {124		return nil, &Diagnostics{125			Message: "failed to query database for migration status",126			Wrapped: err,127		}128	}129	// Unwrap the record to get the actual database130	r, ok := rec.(*record.Wrapper)131	if !ok {132		return nil, &Diagnostics{133			Wrapped: errors.New("expected wrapped database record"),134		}135	}136	sv, err := version.NewSemver(string(r.Data))137	if err != nil {138		return nil, &Diagnostics{139			Message: "failed to parse version stored in migration status record",140			Wrapped: err,141		}142	}143	return sv, nil144}145func (reg *Registry) saveLastSuccessfulMigration(db *database.Interface, ver *version.Version) error {146	r := &record.Wrapper{147		Data:   []byte(ver.String()),148		Format: dsd.RAW,149	}150	r.SetKey(reg.key)151	return db.Put(r)152}153func (reg *Registry) getExecutionPlan(startOfMigration *version.Version) ([]Migration, *Diagnostics, error) {154	// create a look-up map for migrations indexed by their semver created a155	// list of version (sorted by increasing number) that we use as our execution156	// plan.157	lm := make(map[string]Migration)158	versions := make(version.Collection, 0, len(reg.migrations))159	for _, m := range reg.migrations {160		ver, err := version.NewSemver(m.Version)161		if err != nil {162			return nil, nil, &Diagnostics{163				Message:         "failed to parse version of migration",164				Wrapped:         err,165				FailedMigration: m.Description,166			}167		}168		lm[ver.String()] = m // use .String() for a normalized string representation169		versions = append(versions, ver)170	}171	sort.Sort(versions)172	diag := new(Diagnostics)173	if startOfMigration != nil {174		diag.StartOfMigration = startOfMigration.String()175	}176	// prepare our diagnostics and the execution plan177	execPlan := make([]Migration, 0, len(versions))178	for _, ver := range versions {179		// skip an migration that has already been applied.180		if startOfMigration != nil && startOfMigration.GreaterThanOrEqual(ver) {181			continue182		}183		m := lm[ver.String()]184		diag.ExecutionPlan = append(diag.ExecutionPlan, DiagnosticStep{185			Description: m.Description,186			Version:     ver.String(),187		})188		execPlan = append(execPlan, m)189	}190	return execPlan, diag, nil191}...

garbage.go

Source:garbage.go

...49					continue50				}51				localCache[rp.CollectionID] = collection52			}53			ep, err := model.GetExecutionPlan(collection.ID, rp.PlanID)54			if err != nil {55				continue56			}57			item := &RunningPlan{58				ep:         ep,59				collection: collection,60			}61			jobs <- item62		}63		time.Sleep(2 * time.Second)64	}65}66func (c *Controller) cleanLocalStore() {67	for {...

inspect.go

Source:inspect.go

...120	execScheduler, err := local.NewExecutionScheduler(runner, logger)121	if err != nil {122		return nil, err123	}124	executionPlan := execScheduler.GetExecutionPlan()125	duration, _ := lib.GetEndOffset(executionPlan)126	return struct {127		lib.Options128		TotalDuration types.NullDuration `json:"totalDuration"`129		MaxVUs        uint64             `json:"maxVUs"`130	}{131		conf.Options,132		types.NewNullDuration(duration, true),133		lib.GetMaxPossibleVUs(executionPlan),134	}, nil135}...

GetExecutionPlan

Using AI Code Generation

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

GetExecutionPlan

Using AI Code Generation

1import (2func main() {3  c, _, err := zk.Connect([]string{"localhost"}, time.Second)4  if err != nil {5    panic(err)6  }7  defer c.Close()8  b, _, err := c.Get("/zookeeper/config")9  if err != nil {10    panic(err)11  }12  fmt.Printf("%s13}14import (15func main() {16  c, _, err := zk.Connect([]string{"localhost"}, time.Second)17  if err != nil {18    panic(err)19  }20  defer c.Close()21  b, _, err := c.Get("/zookeeper/config")22  if err != nil {23    panic(err)24  }25  fmt.Printf("%s26}27import (28func main() {29  c, _, err := zk.Connect([]string{"localhost"}, time.Second)30  if err != nil {31    panic(err)32  }33  defer c.Close()34  b, _, err := c.Get("/zookeeper/config")35  if err != nil {36    panic(err)37  }38  fmt.Printf("%s39}40import (41func main() {42  c, _, err := zk.Connect([]string{"localhost"}, time.Second)43  if err != nil {44    panic(err)45  }46  defer c.Close()47  b, _, err := c.Get("/zookeeper/config")48  if err != nil {49    panic(err)50  }51  fmt.Printf("%s52}53import (54func main() {55  c, _, err := zk.Connect([]string{"localhost"}, time.Second

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.