Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. istioctl/cmd/options.go

    		// (Currently the only global options we show are help options)
    		rootCmd.PersistentFlags().VisitAll(func(flag *pflag.Flag) {
    			if _, ok := helpFlags[flag.Name]; ok {
    				// Currently every flag.Shorthand is "", so there is no point in showing shorthands
    				shorthand := "   "
    				if flag.Shorthand != "" {
    					shorthand = "-" + flag.Shorthand + ","
    				}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 1.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/ztunnelserver.go

    		go func() {
    			log.Debug("handling conn")
    			if err := z.handleConn(ctx, conn); err != nil {
    				log.Errorf("failed to handle conn: %v", err)
    			}
    		}()
    	}
    }
    
    // ZDS protocol is very simple, for every message sent, and ack is sent.
    // the ack only has temporal correlation (i.e. it is the first and only ack msg after the message was sent)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/informers.go

    				return nil
    			}
    
    			err := s.dataplane.AddPodToMesh(s.ctx, pod, podIPs, "")
    			log.Debugf("AddPodToMesh(%s) returned %v", newPod.Name, err)
    		}
    	case controllers.EventDelete:
    		// TODO: as every pod on our node will come through here, check if pod is annotated?
    		err := s.dataplane.DelPodFromMesh(s.ctx, pod)
    		log.Debugf("DelPodFromMesh(%s) returned %v", pod.Name, err)
    	}
    	return nil
    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/repair/repaircontroller.go

    	m := podsRepaired.With(typeLabel.Value(repairType))
    	log := repairLog.WithLabels("pod", pod.Namespace+"/"+pod.Name)
    	key := types.NamespacedName{Name: pod.Name, Namespace: pod.Namespace}
    	// We will get an event every time the pod changes. The repair is not instantaneous, though -- it will only recover
    	// once the pod restarts (in CrashLoopBackoff), which can take some time.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/podcgroupns.go

    }
    
    // GetCGroups returns a slice of cgroups for pid using fs for filesystem calls.
    //
    // The expected cgroup format is "hierarchy-ID:controller-list:cgroup-path", and
    // this function will return an error if every cgroup does not meet that format.
    //
    // For more information, see:
    //   - http://man7.org/linux/man-pages/man7/cgroups.7.html
    //   - https://www.kernel.org/doc/Documentation/cgroup-v2.txt
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  6. cni/pkg/iptables/iptables_linux.go

    	}
    	for _, family := range families {
    		// Equiv:
    		// ip rule add fwmark 0x111/0xfff pref 32764 lookup 100
    		//
    		// Adds in-pod rules for marking packets with the istio-specific TPROXY mark.
    		// 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
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  7. cni/pkg/util/podutil.go

    }
    
    // Get any IPs currently assigned to the Pod.
    //
    // If 'PodIPs' exists, it is preferred (and should be guaranteed to contain the address in 'PodIP'),
    // otherwise fallback to 'PodIP'.
    //
    // Note that very early in the pod's lifecycle (before all the node CNI plugin invocations finish)
    // K8S may not have received the pod IPs yet, and may not report the pod as having any.
    func GetPodIPsIfPresent(pod *corev1.Pod) []netip.Addr {
    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)
Back to top