- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetRegistries (0.15 sec)
-
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) -
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) -
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)