- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for deleteDevices (0.34 sec)
-
pkg/volume/iscsi/iscsi_util.go
return fmt.Errorf("no data written to file: %s", filename) } klog.V(4).Infof("Deleted block device: %s", deviceName) return nil } // deleteDevices tries to remove all the block devices and multipath map devices // associated with a given iscsi device func deleteDevices(c iscsiDiskUnmounter) error { lunNumber, err := strconv.Atoi(c.iscsiDisk.Lun) if err != nil {
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/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) -
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)