Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for deleteDevices (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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