Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for inpod (0.19 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go

    		if err != nil {
    			return nil, false, err
    		}
    		inPod := obj.(*example.Pod)
    		if inPod.ResourceVersion == "" || inPod.ResourceVersion == "0" {
    			inPod.ResourceVersion = p.updatePod.ResourceVersion
    		}
    		if inPod.ResourceVersion != p.updatePod.ResourceVersion {
    			// If the patch didn't have an opinion on the resource version, retry like GuaranteedUpdate does
    			if inPod.ResourceVersion == currentResourceVersion {
    				continue
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/net.go

    	}); err != nil {
    		log.Errorf("failed to update POD inpod: %s/%s %v", pod.Namespace, pod.Name, err)
    		return err
    	}
    
    	// For *any* failures after calling `CreateInpodRules`, we must return PartialAdd error.
    	// The pod was injected with iptables rules, so it must be annotated as "inpod" - even if
    	// the following fails.
    	// This is so that if it is removed from the mesh, the inpod rules will unconditionally
    	// be removed.
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. cni/pkg/iptables/iptables.go

    	iptableslog "istio.io/istio/tools/istio-iptables/pkg/log"
    )
    
    var log = scopes.CNIAgent
    
    const (
    	// INPOD marks/masks
    	InpodTProxyMark      = 0x111
    	InpodTProxyMask      = 0xfff
    	InpodMark            = 1337 // this needs to match the inpod config mark in ztunnel.
    	InpodMask            = 0xfff
    	InpodRestoreMask     = 0xffffffff
    	ChainInpodOutput     = "ISTIO_OUTPUT"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 21:45:18 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  4. cni/pkg/cmd/root.go

    			// Start ambient controller
    
    			// node agent will spawn a goroutine and watch the K8S API for events,
    			// as well as listen for messages from the CNI binary.
    			log.Info("Starting ambient node agent with inpod redirect mode")
    			ambientAgent, err := nodeagent.NewServer(ctx, watchServerReady, cfg.InstallConfig.CNIEventAddress,
    				nodeagent.AmbientArgs{
    					SystemNamespace: nodeagent.SystemNamespace,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 16:26:35 UTC 2024
    - 13K bytes
    - Viewed (0)
  5. pkg/controller/tainteviction/taint_eviction.go

    			prevPod := prev.(*v1.Pod)
    			newPod := obj.(*v1.Pod)
    			tm.PodUpdated(prevPod, newPod)
    		},
    		DeleteFunc: func(obj interface{}) {
    			pod, isPod := obj.(*v1.Pod)
    			// We can get DeletedFinalStateUnknown instead of *v1.Pod here and we need to handle that correctly.
    			if !isPod {
    				deletedState, ok := obj.(cache.DeletedFinalStateUnknown)
    				if !ok {
    					logger.Error(nil, "Received unexpected object", "object", obj)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 19.9K bytes
    - Viewed (0)
Back to top