Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 188 for It (0.03 sec)

  1. pilot/pkg/xds/deltatest.go

    	wantUnchanged := sets.New[string]()
    	for _, c := range current {
    		n := newByName[c.Name]
    		if n == nil {
    			// We had a resource, but SotW didn't generate it.
    			if watched.Contains(c.Name) {
    				// We only need to delete it if Envoy is watching. Otherwise, it may have simply unsubscribed
    				wantDeleted.Insert(c.Name)
    			}
    		} else if diff := cmp.Diff(c.Resource, n.Resource, protocmp.Transform()); diff != "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/pod_cache.go

    	return maps.Clone(p.currentPodCache)
    }
    
    // Remove and return the Netns for the given uid
    // No need to return NetnsCloser here it will be closed automatically on GC.
    // (it may be used in parallel by other parts of the code, so we want it to be used only when not used)
    func (p *podNetnsCache) Take(uid string) Netns {
    	// lock current pod map
    	p.mu.Lock()
    	defer p.mu.Unlock()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 17:18:11 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  3. pkg/kube/krt/join.go

    	res := []T{}
    	found := sets.New[Key[T]]()
    	for _, c := range j.collections {
    		for _, i := range c.List() {
    			key := GetKey(i)
    			if !found.InsertContains(key) {
    				// Only keep it if it is the first time we saw it, as our merging mechanism is to keep the first one
    				res = append(res, i)
    			}
    		}
    	}
    	return res
    }
    
    func (j *join[T]) Register(f func(o Event[T])) Syncer {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  4. cni/pkg/log/uds_test.go

    			// Each log is 2x: one direct, and one over UDS. Just test the UDS one
    			continue
    		}
    		// remove scope since it is constant and not needed to test
    		delete(parsedLog, "scope")
    		// check time is there
    		if _, f := parsedLog["time"]; !f {
    			t.Fatalf("log %v did not have time", i)
    		}
    		// but remove time since it changes on each test
    		delete(parsedLog, "time")
    		want := map[string]any{
    			"level": cases[i].level,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 16:26:28 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  5. manifests/charts/install-OpenShift.md

    The installation process using the Helm charts is as follows:
    
    1) `base` chart creates cluster-wide CRDs, cluster bindings and cluster resources. It is possible to change the namespace from `istio-system` but it is not recommended.
    
    ```console
    helm install istio-base -n istio-system manifests/charts/base --set profile=openshift
    ```
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 16:01:31 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  6. releasenotes/notes/50791.yaml

    apiVersion: release-notes/v2
    kind: feature
    area: istioctl
    issue:
      - 50790
    releaseNotes:
    - |
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 01 16:16:40 UTC 2024
    - 219 bytes
    - Viewed (0)
  7. pkg/envoy/proxy.go

    		// At high QPS (>250 QPS) we will log the same amount as we will log due to exceeding buffer size, rather
    		// than the flush interval.
    		"--file-flush-interval-msec", "1000",
    		"--disable-hot-restart", // We don't use it, so disable it to simplify Envoy's logic
    		"--allow-unknown-static-fields",
    	}
    
    	startupArgs = append(startupArgs, e.extraArgs...)
    
    	if overrideFname != "" {
    		s, err := readBootstrapToJSON(overrideFname)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 10:02:56 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. pilot/pkg/xds/endpoints/ep_filters.go

    	// Go through all cluster endpoints and add those with the same network as the sidecar
    	// to the result. Also count the number of endpoints per each remote network while
    	// iterating so that it can be used as the weight for the gateway endpoint
    	for _, ep := range endpoints {
    		lbEndpoints := &LocalityEndpoints{
    			llbEndpoints: endpoint.LocalityLbEndpoints{
    				Locality: ep.llbEndpoints.Locality,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  9. releasenotes/notes/49700.yaml

    ambient mode no longer use the original service account or namespace attachment semantics. If you were using a namespace-scope waypoint previously migration should be fairly straight forward. Annotate your namespace with the appropriate waypoint and it should function in a similar way.
    
          If you were using service account attachment there will be more to understand. Under the old waypoint logic all types of traffic, both addressed to a service as well as addressed to a workload, were treated...
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. cni/cmd/istio-cni/main.go

    		// Log sync will send logs to install-cni container via UDS.
    		// We don't need a timeout here because underlying the log pkg already handles it.
    		// this may fail, but it should be safe to ignore according
    		// to https://github.com/uber-go/zap/issues/328
    		_ = log.Sync()
    	}()
    
    	// TODO: implement plugin version
    	funcs := skel.CNIFuncs{
    		Add:   plugin.CmdAdd,
    		Del:   plugin.CmdDelete,
    		Check: plugin.CmdCheck,
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 16:26:35 UTC 2024
    - 2K bytes
    - Viewed (0)
Back to top