Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for ends (0.24 sec)

  1. cni/pkg/plugin/kubernetes.go

    	b.WriteString(fmt.Sprintf("  Labels: %+v\n", pi.Labels))
    	b.WriteString(fmt.Sprintf("  Annotations: %+v\n", pi.Annotations))
    	b.WriteString(fmt.Sprintf("  Envs: %+v\n", pi.ProxyEnvironments))
    	b.WriteString(fmt.Sprintf("  ProxyConfig: %+v\n", pi.ProxyEnvironments))
    	return b.String()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  2. istioctl/pkg/util/configdump/ecds.go

    	ecdsDumpAny, err := w.getSections(ecds)
    	if err != nil {
    		return nil, err
    	}
    
    	ecdsDump := &admin.EcdsConfigDump{}
    	for _, dump := range ecdsDumpAny {
    		ecds := &admin.EcdsConfigDump{}
    		err = dump.UnmarshalTo(ecds)
    		if err != nil {
    			return nil, err
    		}
    
    		ecdsDump.EcdsFilters = append(ecdsDump.EcdsFilters, ecds.EcdsFilters...)
    	}
    
    	if err != nil {
    		return nil, err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Dec 24 08:16:26 GMT 2023
    - 1.2K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/envoy/configdump/endpoint.go

    	}
    	dump, err := c.retrieveSortedEndpointsSlice(filter)
    	if err != nil {
    		return err
    	}
    	marshaller := make(proto.MessageSlice, 0, len(dump))
    	for _, eds := range dump {
    		marshaller = append(marshaller, eds)
    	}
    	out, err := json.MarshalIndent(marshaller, "", "    ")
    	if err != nil {
    		return err
    	}
    	if outputFormat == "yaml" {
    		if out, err = yaml.JSONToYAML(out); err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  4. cni/pkg/plugin/plugin.go

    		}
    		conf.RawPrevResult = nil
    		conf.PrevResult, err = cniv1.NewResultFromResult(res)
    		if err != nil {
    			return nil, fmt.Errorf("could not convert result to current version: %v", err)
    		}
    	}
    	// End previous result parsing
    
    	return &conf, nil
    }
    
    func getLogLevel(logLevel string) log.Level {
    	switch logLevel {
    	case "debug":
    		return log.DebugLevel
    	case "warn":
    		return log.WarnLevel
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 15:58:51 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/podcgroupns.go

    		// zero or more punctuation separated "segments" (e.g. "docker-")
    		`(?:[[:^punct:]]+[[:punct:]])*` +
    		// non-punctuation end of string, i.e., the container ID
    		`(?P<containerid>[[:^punct:]]+)$`),
    
    	// This regex applies for container runtimes, that won't put the PodUID into
    	// the cgroup name.
    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/nodeagent/cni-watcher.go

    	retries := 0
    	var ambientPod *corev1.Pod
    	var err error
    
    	log.Debugf("Checking pod: %s in ns: %s is enabled for ambient", addCmd.PodName, addCmd.PodNamespace)
    	// The plugin already consulted the k8s API - but on this end handler caches may be stale, so retry a few times if we get no pod.
    	for ambientPod, err = s.handlers.GetPodIfAmbient(addCmd.PodName, addCmd.PodNamespace); (ambientPod == nil) && (retries < maxStaleRetries); retries++ {
    		if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 6.1K bytes
    - Viewed (0)
Back to top