Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetRegistries (0.14 sec)

  1. pilot/pkg/serviceregistry/aggregate/controller.go

    		return nil
    	}
    	var res []model.ServiceInfo
    	for _, p := range c.GetRegistries() {
    		res = append(res, p.ServicesForWaypoint(key)...)
    	}
    	return res
    }
    
    func (c *Controller) WorkloadsForWaypoint(key model.WaypointKey) []model.WorkloadInfo {
    	if !features.EnableAmbientWaypoints {
    		return nil
    	}
    	var res []model.WorkloadInfo
    	for _, p := range c.GetRegistries() {
    		res = append(res, p.WorkloadsForWaypoint(key)...)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. tests/fuzz/aggregate_controller_fuzzer.go

    	}
    	c.AddRegistry(registry)
    	return nil
    }
    
    // Helper function to delete a registry.
    func runDeleteRegistry(f *fuzz.ConsumeFuzzer, c *aggregate.Controller) error {
    	registries := c.GetRegistries()
    	if len(registries) == 0 {
    		return fmt.Errorf("no registries")
    	}
    	index, err := f.GetInt()
    	if err != nil {
    		return err
    	}
    	selectedRegistry := registries[index%len(registries)]
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 07 18:40:05 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/aggregate/controller_test.go

    		ctrl.AddRegistry(r)
    	}
    
    	// Test Get
    	result := ctrl.GetRegistries()
    	if l := len(result); l != 3 {
    		t.Fatalf("Expected length of the registries slice should be 3, got %d", l)
    	}
    
    	// Test Delete cluster2
    	ctrl.DeleteRegistry(registries[1].ClusterID, registries[1].ProviderID)
    	result = ctrl.GetRegistries()
    	if l := len(result); l != 2 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 14.5K bytes
    - Viewed (0)
Back to top