Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for WithLabels (0.31 sec)

  1. cni/pkg/repair/repaircontroller.go

    // Additionally, we need to jump through hoops to find the network namespace.
    func (c *Controller) repairPod(pod *corev1.Pod) error {
    	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
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    		// don't return error here, as this is purely informational.
    	}
    	return retErr
    }
    
    func (s *meshDataplane) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error {
    	log := log.WithLabels("ns", pod.Namespace, "name", pod.Name)
    	err := s.netServer.RemovePodFromMesh(ctx, pod)
    	if err != nil {
    		log.Errorf("failed to remove pod from mesh: %v", err)
    		return err
    	}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 01:42:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  3. cni/pkg/plugin/plugin.go

    	setupLogging(conf)
    
    	var loggedPrevResult any
    	if conf.PrevResult == nil {
    		loggedPrevResult = "none"
    	} else {
    		loggedPrevResult = conf.PrevResult
    	}
    	log.WithLabels("if", args.IfName).Debugf("istio-cni CmdAdd config: %+v", conf)
    	log.Debugf("istio-cni CmdAdd previous result: %+v", loggedPrevResult)
    
    	// Determine if running under k8s by checking the CNI args
    	k8sArgs := K8sArgs{}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net.go

    		NetworkNamespace: "",
    	}
    }
    
    // Remove pod from mesh: pod is not deleted, we just want to remove it from the mesh.
    func (s *NetServer) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error {
    	log := log.WithLabels("ns", pod.Namespace, "name", pod.Name)
    	log.Debugf("Pod is now opt out... cleaning up.")
    
    	openNetns := s.currentPodSnapshot.Take(string(pod.UID))
    	if openNetns == nil {
    		log.Warn("failed to find pod netns")
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.1K bytes
    - Viewed (1)
  5. cni/pkg/nodeagent/cni-watcher.go

    	}
    
    	log.Debugf("Deserialized CNI plugin event: %+v", msg)
    	return msg, nil
    }
    
    func (s *CniPluginServer) ReconcileCNIAddEvent(ctx context.Context, addCmd CNIPluginAddEvent) error {
    	log := log.WithLabels("cni-event", addCmd)
    
    	log.Debugf("netns: %s", addCmd.Netns)
    
    	// The CNI node plugin should have already checked the pod against the k8s API before forwarding us the event,
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  6. api/go1.9.txt

    pkg runtime/pprof, func Label(context.Context, string) (string, bool)
    pkg runtime/pprof, func Labels(...string) LabelSet
    pkg runtime/pprof, func SetGoroutineLabels(context.Context)
    pkg runtime/pprof, func WithLabels(context.Context, LabelSet) context.Context
    pkg runtime/pprof, type LabelSet struct
    pkg sync, method (*Map) Delete(interface{})
    pkg sync, method (*Map) Load(interface{}) (interface{}, bool)
    Plain Text
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Mon Oct 04 20:20:20 GMT 2021
    - 10.7K bytes
    - Viewed (0)
Back to top