Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for have (0.15 sec)

  1. istioctl/pkg/waypoint/waypoint_test.go

    				makeGateway(constants.DefaultNamespaceWaypoint, "default", true, true),
    				makeGateway(constants.DefaultNamespaceWaypoint, "fake", true, true),
    			},
    			expectedOutFile: "all-gateway",
    		},
    		{
    			name: "have both managed and unmanaged gateways",
    			args: strings.Split("list -A", " "),
    			gateways: []*gateway.Gateway{
    				makeGateway("bookinfo", "default", false, true),
    				makeGateway("bookinfo-invalid", "fake", true, false),
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 04 15:53:09 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/pod_cache.go

    	// lock current snapshot pod map
    	p.mu.RLock()
    	defer p.mu.RUnlock()
    	if info, f := p.currentPodCache[uid]; f {
    		return info.Netns
    	}
    	return nil
    }
    
    // make sure uid is in the cache, even if we don't have a netns
    func (p *podNetnsCache) Ensure(uid string) {
    	p.mu.Lock()
    	defer p.mu.Unlock()
    	if _, ok := p.currentPodCache[uid]; !ok {
    		p.currentPodCache[uid] = WorkloadInfo{}
    	}
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/informers.go

    			// for the pod. If this is a pod added via informer, the pod should have already gone thru
    			// the CNI plugin chain, and have a PodIP.
    			//
    			// If PodIPs exists, it is preferred, otherwise fallback to PodIP.
    			//
    			// If we get to this point and have a pod that really and truly has no IP in either of those,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 9.6K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/ztunnelserver_test.go

    	uid := fixture.uid
    
    	m, fds := readRequest(t, ztunClient)
    	// we got am essage from ztun, so it should have observed us being connected
    	mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(1))
    
    	// we should get the fd to dev null. note that we can't assert the fd number
    	// as the kernel may have given us a different number that refers to the same file.
    	assert.Equal(t, len(fds), 1)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 8.6K bytes
    - Viewed (0)
  5. cni/pkg/ipset/nldeps_linux.go

    // the kernel can be out of sync with the CLI utility, leading to errors like:
    //
    // ipset v7.10: Argument `comment' is supported in the kernel module of the set type hash:ip
    // starting from the revision 3 and you have installed revision 1 only.
    // Your kernel is behind your ipset utility.
    //
    // This happens with kernels as recent as Fedora38, e.g: 6.4.11-200.fc38.aarch64
    func (m *realDeps) clearEntriesWithComment(name, comment string) error {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  6. cni/pkg/util/podutil.go

    ))
    
    var annotationRemovePatch = []byte(fmt.Sprintf(
    	`{"metadata":{"annotations":{"%s":null}}}`,
    	constants.AmbientRedirection,
    ))
    
    // PodRedirectionEnabled determines if a pod should or should not be configured
    // to have traffic redirected thru the node proxy.
    func PodRedirectionEnabled(namespace *corev1.Namespace, pod *corev1.Pod) bool {
    	if !(namespace.GetLabels()[constants.DataplaneModeLabel] == constants.DataplaneModeAmbient ||
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  7. cni/pkg/ipset/ipset.go

    	ipToInsert := ip.Unmap()
    
    	// We have already Unmap'd, so we can do a simple IsV6 y/n check now
    	if ipToInsert.Is6() {
    		return m.Deps.addIP(m.V6Name, ipToInsert, ipProto, comment, replace)
    	}
    	return m.Deps.addIP(m.V4Name, ipToInsert, ipProto, comment, replace)
    }
    
    func (m *IPSet) DeleteIP(ip netip.Addr, ipProto uint8) error {
    	ipToDel := ip.Unmap()
    
    	// We have already Unmap'd, so we can do a simple IsV6 y/n check now
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
Back to top