- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for WithLabels (0.31 sec)
-
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) -
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) -
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) -
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) -
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) -
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)