Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for WithLabels (0.05 sec)

  1. 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 Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  2. 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 Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  3. 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 Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  4. 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 Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 23.3K bytes
    - Viewed (0)
Back to top