- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for TrackResource (0.32 sec)
-
pkg/test/framework/components/namespace/kube.go
name := cfg.Prefix n := &kubeNamespace{ ctx: ctx, prefix: name, name: name, skipDump: cfg.SkipDump, } id := ctx.TrackResource(n) n.id = id if err := n.forEachCluster(func(_ int, c cluster.Cluster) error { if !kube2.NamespaceExists(c.Kube(), name) { return n.createInCluster(c, cfg) } return nil }); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 9K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/kube.go
`) } }() scopes.Framework.Infof("Test Framework Kubernetes environment Settings:\n%s", s) e := &Environment{ ctx: ctx, s: s, } e.id = ctx.TrackResource(e) configs, err := s.clusterConfigs() if err != nil { return nil, err } clusters, err := buildClusters(configs) if err != nil { return nil, err } e.clusters = clusters
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/kube.go
_ = ctx.ConfigKube().YAML(ns, yaml).Delete() }) return nil } func newKube(ctx resource.Context, cfgIn Config) (Instance, error) { c := &kubeComponent{ clusters: ctx.Clusters(), } c.id = ctx.TrackResource(c) c.api = make(map[string]prometheusApiV1.API) c.forwarder = make(map[string]istioKube.PortForwarder) cfg, err := istio.DefaultConfig(ctx) if err != nil { return nil, err } if !cfgIn.SkipDeploy {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/test/framework/components/ambient/waypoint.go
} // NewWaypointProxy creates a new WaypointProxy. func NewWaypointProxy(ctx resource.Context, ns namespace.Instance, name string) (WaypointProxy, error) { server := &kubeComponent{ ns: ns, } server.id = ctx.TrackResource(server) if err := crd.DeployGatewayAPI(ctx); err != nil { return nil, err } // TODO support multicluster ik, err := istioctl.New(ctx, istioctl.Config{}) if err != nil { return nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/test/framework/suite_test.go
runFn := func(ctx *suiteContext) int { err = ctx.GetResource(refPtr) return 0 } s := newTestSuite("tid", runFn, defaultExitFn, defaultSettingsFn) s.Setup(func(c resource.Context) error { c.TrackResource(trackedResource) return nil }) s.Run() return err } t.Run("struct reference", func(t *testing.T) { g := NewWithT(t) var ref *resource.FakeResource
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.5K bytes - Viewed (0) -
pkg/test/framework/components/istio/kube.go
externalControlPlane: ctx.AllClusters().IsExternalControlPlane(), } t0 := time.Now() defer func() { ctx.RecordTraceEvent("istio-deploy", time.Since(t0).Seconds()) }() i.id = ctx.TrackResource(i) if !cfg.DeployIstio { scopes.Framework.Info("skipping deployment as specified in the config") return i, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 31.1K bytes - Viewed (0)