Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for filterClusters (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top