- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for deleteService (0.26 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)