Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for deleteService (0.26 sec)

  1. src/cmd/vendor/golang.org/x/sys/windows/zsyscall_windows.go

    	procCryptReleaseContext                                  = modadvapi32.NewProc("CryptReleaseContext")
    	procDeleteService                                        = modadvapi32.NewProc("DeleteService")
    	procDeregisterEventSource                                = modadvapi32.NewProc("DeregisterEventSource")
    	procDuplicateTokenEx                                     = modadvapi32.NewProc("DuplicateTokenEx")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 195.8K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/store.go

    	}
    	return model.SortServicesByCreationTime(out)
    }
    
    func (s *serviceStore) getServices(key types.NamespacedName) []*model.Service {
    	return s.servicesBySE[key]
    }
    
    func (s *serviceStore) deleteServices(key types.NamespacedName) {
    	delete(s.servicesBySE, key)
    }
    
    func (s *serviceStore) updateServices(key types.NamespacedName, services []*model.Service) {
    	s.servicesBySE[key] = services
    	s.allocateNeeded = true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/store_test.go

    	if !reflect.DeepEqual(got, expectedServices) {
    		t.Errorf("got unexpected services %v", got)
    	}
    	if !store.allocateNeeded {
    		t.Errorf("expected allocate needed")
    	}
    	store.allocateNeeded = false
    	store.deleteServices(httpDNSRR.NamespacedName())
    	got = store.getAllServices()
    	if len(got) != 0 {
    		t.Errorf("got unexpected services %v", got)
    	}
    	if store.allocateNeeded {
    		t.Errorf("expected no allocate needed")
    	}
    }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. pkg/proxy/winkernel/proxier_test.go

    		t.Errorf("Global refCount: %v does not match endpoint refCount: %v", *proxier.endPointsRefCount[endpointGuid1], *epInfo.refCount)
    	}
    
    	proxier.setInitialized(false)
    	deleteServices(proxier,
    		makeTestService(svcPortName2.Namespace, svcPortName2.Name, func(svc *v1.Service) {
    			svc.Spec.Type = "NodePort"
    			svc.Spec.ClusterIP = svcIP2
    			svc.Spec.Ports = []v1.ServicePort{{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    	// Now delete few services and validate that IPs are retained for original services.
    	deleteServices := []*model.Service{}
    	for i, svc := range inServices {
    		if _, exists := originalServices[svc.Hostname.String()]; !exists {
    			if i%2 == 0 {
    				continue
    			}
    		}
    		deleteServices = append(deleteServices, svc)
    	}
    	inServices = deleteServices
    	allocateAndValidate()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  6. pkg/volume/iscsi/iscsi_util.go

    			return nil
    		}
    	}
    
    	// Persist iscsi disk config to json file for DetachDisk path
    	return util.persistISCSIFile(*(b.iscsiDisk), globalPDPath)
    }
    
    // Delete 1 block device of the form "sd*"
    func deleteDevice(deviceName string) error {
    	filename := fmt.Sprintf("/sys/block/%s/device/delete", deviceName)
    	fd, err := os.OpenFile(filename, os.O_WRONLY, 0)
    	if err != nil {
    		// The file was not present, so just return without error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 22 12:53:01 UTC 2022
    - 34.1K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/serviceentry/controller.go

    			updatedSvcs = append(updatedSvcs, unchangedSvcs...)
    			unchangedSvcs = nil
    		}
    		s.services.updateServices(key, cs)
    	case model.EventDelete:
    		deletedSvcs = cs
    		s.services.deleteServices(key)
    	case model.EventAdd:
    		addedSvcs = cs
    		s.services.updateServices(key, cs)
    	default:
    		// this should not happen
    		unchangedSvcs = cs
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
Back to top