- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for filterClusters (0.26 sec)
-
pkg/test/framework/components/cluster/clusters.go
func (c Clusters) Primaries(excluded ...Cluster) Clusters { return c.filterClusters(func(cc Cluster) bool { return cc.IsPrimary() }, exclude(excluded...)) } // Exclude returns all clusters not given as input. func (c Clusters) Exclude(excluded ...Cluster) Clusters { return c.filterClusters(func(cc Cluster) bool { return true }, exclude(excluded...)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 4.7K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
Instances: instances, Configs: cfgs, }) clusters := cg.Clusters(cg.SetupProxy(nil)) xdstest.ValidateClusters(t, clusters) if c.filter != nil { clusters = xdstest.FilterClusters(clusters, c.filter) } g.Expect(len(clusters)).ShouldNot(Equal(0)) for _, cluster := range clusters { g.Expect(cluster.CircuitBreakers).NotTo(BeNil())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
} return m }(), }) sim := simulation.NewSimulationFromConfigGen(t, s, s.SetupProxy(tt.proxy)) clusters := xdstest.FilterClusters(sim.Clusters, func(c *cluster.Cluster) bool { return strings.HasPrefix(c.Name, "inbound") }) if len(s.PushContext().ProxyStatus) != 0 { // TODO make this fatal, once inbound conflict is silenced
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0)