Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for TrackResource (0.32 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top