Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for releaseAllocatedResources (0.23 sec)

  1. pkg/registry/core/service/storage/storage.go

    		if err != nil && !errors.IsNotFound(err) {
    			klog.Errorf("delete service endpoints %s/%s failed: %v", svc.Name, svc.Namespace, err)
    		}
    
    		r.alloc.releaseAllocatedResources(svc)
    	}
    }
    
    func (r *REST) beginCreate(ctx context.Context, obj runtime.Object, options *metav1.CreateOptions) (genericregistry.FinishFunc, error) {
    	svc := obj.(*api.Service)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:33 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  2. pkg/registry/core/service/storage/alloc.go

    	case neededHealthCheckNodePort && !needsHealthCheckNodePort:
    		nodePortOp.ReleaseDeferred(int(oldHealthCheckNodePort))
    	}
    	return true, nil
    }
    
    func (al *Allocators) releaseAllocatedResources(svc *api.Service) {
    	al.releaseClusterIPs(svc)
    
    	for _, nodePort := range collectServiceNodePorts(svc) {
    		err := al.serviceNodePorts.Release(nodePort)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 37.3K bytes
    - Viewed (0)
Back to top