- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for WithLabels (0.11 sec)
-
cni/pkg/nodeagent/net.go
} // RemovePodFromMesh is called when a pod needs to be removed from the mesh func (s *NetServer) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod, isDelete bool) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) log.WithLabels("delete", isDelete).Debugf("removing pod from the mesh") // Aggregate errors together, so that if part of the cleanup fails we still proceed with other steps. var errs []error
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Mon Oct 21 16:48:55 UTC 2024 - 9.1K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
log.Error("Failed to configure istio-cni logging") } 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{}
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Aug 14 19:36:19 UTC 2024 - 10.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
return "" } return m[label.IoIstioDataplaneMode.Name] } func (s *InformerHandlers) reconcilePod(input any) error { event := input.(controllers.Event) pod := event.Latest().(*corev1.Pod) log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) defer EventTotals.With(eventTypeTag.Value(event.Event.String())).Increment() switch event.Event { case controllers.EventAdd: // pod was added to our cache
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 11.7K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
} return retErr } func (s *meshDataplane) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod, isDelete bool) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) // Aggregate errors together, so that if part of the removal fails we still proceed with other steps. var errs []error
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Sep 25 20:54:34 UTC 2024 - 13.4K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// Append our rules here builder := cfg.appendHostRules(hostSNATIP, hostSNATIPV6) log.Info("Adding host netnamespace iptables rules") if err := cfg.executeCommands(log.WithLabels("component", "host"), builder); err != nil { log.Errorf("failed to add host netnamespace iptables rules: %v", err) return err } return nil } func (cfg *IptablesConfigurator) DeleteHostRules() {
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Tue Oct 15 15:39:28 UTC 2024 - 23.3K bytes - Viewed (0)