Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for newKube (0.43 sec)

  1. pkg/test/framework/components/prometheus/kube.go

    	}
    	if err := ctx.ConfigKube().YAML(ns, yaml).Apply(apply.NoCleanup); err != nil {
    		return err
    	}
    	ctx.CleanupConditionally(func() {
    		_ = 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)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  2. pkg/test/framework/components/namespace/kube.go

    		_, err := c.Kube().CoreV1().Namespaces().Patch(context.TODO(), name, types.JSONPatchType, []byte(nsLabelPatch), metav1.PatchOptions{})
    		return err
    	})
    }
    
    // NewNamespace allocates a new testing namespace.
    func newKube(ctx resource.Context, cfg Config) (Instance, error) {
    	mu.Lock()
    	idctr++
    	nsid := idctr
    	r := rnd.Intn(99999)
    	mu.Unlock()
    
    	name := fmt.Sprintf("%s-%d-%d", cfg.Prefix, nsid, r)
    	n := &kubeNamespace{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 9K bytes
    - Viewed (0)
  3. tests/integration/README.md

        ctx.Environment().Case(environment.Native, func() {
            i, err = newNative(ctx)
        })
        ctx.Environment().Case(environment.Kube, func() {
            i, err = newKube(ctx)
        })
        return
    }
    
    func NewOrFail(t test.Failer, ctx resource.Context) Instance {
        i, err := New(ctx)
        if err != nil {
            t.Fatal(err)
        }
        return i
    }
    ```
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 19:04:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. pkg/test/framework/components/istio/kube.go

    	return addr, nil
    }
    
    func (i *istioImpl) Values() (OperatorValues, error) {
    	return i.values, nil
    }
    
    func (i *istioImpl) ValuesOrFail(test.Failer) OperatorValues {
    	return i.values
    }
    
    func newKube(ctx resource.Context, cfg Config) (Instance, error) {
    	cfg.fillDefaults(ctx)
    
    	scopes.Framework.Infof("=== Istio Component Config ===")
    	scopes.Framework.Infof("\n%s", cfg.String())
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  5. cni/pkg/iptables/iptables_linux.go

    		// A very similar mechanism is used for sidecar TPROXY.
    		//
    		// TODO largely identical/copied from tools/istio-iptables/pkg/capture/run_linux.go
    		inpodMarkRule := netlink.NewRule()
    		inpodMarkRule.Family = family
    		inpodMarkRule.Table = RouteTableInbound
    		inpodMarkRule.Mark = InpodTProxyMark
    		inpodMarkRule.Mask = InpodTProxyMask
    		inpodMarkRule.Priority = 32764
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  6. tools/istio-iptables/pkg/capture/run_linux.go

    			families := []int{unix.AF_INET}
    			if cfg.EnableIPv6 {
    				families = append(families, unix.AF_INET6)
    			}
    			for _, family := range families {
    				r := netlink.NewRule()
    				r.Family = family
    				r.Table = tproxyTable
    				r.Mark = tproxyMark
    				if err := netlink.RuleAdd(r); err != nil {
    					return fmt.Errorf("failed to configure netlink rule: %v", err)
    				}
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 3.1K bytes
    - Viewed (0)
Back to top