Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PodDeleted (0.09 sec)

  1. cni/pkg/nodeagent/fakes_test.go

    type fakeZtunnel struct {
    	deletedPods atomic.Int32
    	addedPods   atomic.Int32
    	addError    error
    	delError    error
    }
    
    func (f *fakeZtunnel) Run(ctx context.Context) {
    }
    
    func (f *fakeZtunnel) PodDeleted(ctx context.Context, uid string) error {
    	f.deletedPods.Add(1)
    	return f.delError
    }
    
    func (f *fakeZtunnel) PodAdded(ctx context.Context, pod *corev1.Pod, netns Netns) error {
    	f.addedPods.Add(1)
    	return f.addError
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 23:33:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/ztunnelserver.go

    	readWriteDeadline             = 5 * time.Second
    )
    
    var ztunnelConnected = monitoring.NewGauge("ztunnel_connected",
    	"number of connections to ztunnel")
    
    type ZtunnelServer interface {
    	Run(ctx context.Context)
    	PodDeleted(ctx context.Context, uid string) error
    	PodAdded(ctx context.Context, pod *v1.Pod, netns Netns) error
    	Close() error
    }
    
    /*
    To clean up stale ztunnels
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/net.go

    			}
    		} else {
    			log.Warn("pod netns already gone, not deleting inpod rules")
    		}
    	}
    
    	log.Debug("removing pod from ztunnel")
    	if err := s.ztunnelServer.PodDeleted(ctx, string(pod.UID)); err != nil {
    		log.Errorf("failed to delete pod from ztunnel: %v", err)
    		errs = append(errs, err)
    	}
    	return errors.Join(errs...)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
Back to top