- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 178 for clusterIPs (0.2 sec)
-
pkg/test/framework/components/echo/workload.go
} return out } func (ws Workloads) Clusters() cluster.Clusters { clusters := make(map[string]cluster.Cluster) for _, w := range ws { if c := w.Cluster(); c != nil { clusters[c.Name()] = c } } out := make(cluster.Clusters, 0, len(clusters)) for _, c := range clusters { out = append(out, c) } // Sort the clusters by name. sort.SliceStable(out, func(i, j int) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 25 19:46:28 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/kube.go
} func (e *Environment) AllClusters() cluster.Clusters { out := make([]cluster.Cluster, 0, len(e.clusters)) out = append(out, e.clusters...) return out } func (e *Environment) Clusters() cluster.Clusters { return e.AllClusters().MeshClusters() } // ClustersByNetwork returns an inverse mapping of the network topolgoy to a slice of clusters in a given network.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/test/framework/config.go
type configFactory struct { ctx resource.Context clusters []cluster.Cluster prefix string } func newConfigFactory(ctx resource.Context, clusters cluster.Clusters) config.Factory { if len(clusters) == 0 { clusters = ctx.Clusters() } return &configFactory{ ctx: ctx, clusters: clusters, } } // GlobalYAMLWrites records how many YAMLs we have applied from all sources.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/kube/multicluster/component.go
constructor func(cluster *Cluster) T clusters map[cluster.ID]T } func (m *Component[T]) ForCluster(clusterID cluster.ID) *T { m.mu.RLock() defer m.mu.RUnlock() t, f := m.clusters[clusterID] if !f { return nil } return &t } func (m *Component[T]) All() []T { m.mu.RLock() defer m.mu.RUnlock() return maps.Values(m.clusters) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.4K bytes - Viewed (0) -
releasenotes/notes/set-tcp-idle-timeout-in-http-clusters.yaml
Jacek Ewertowski <******@****.***> 1704944248 +0100
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 11 03:37:28 UTC 2024 - 168 bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_waypoint.go
svcs map[host.Name]*model.Service, ) []*cluster.Cluster { clusters := make([]*cluster.Cluster, 0) // Creates "main_internal" cluster to route to the main internal listener. // Creates "encap" cluster to route to the encap listener. clusters = append(clusters, MainInternalCluster, EncapCluster) // Creates per-VIP load balancing upstreams. clusters = append(clusters, cb.buildWaypointInboundVIP(proxy, svcs)...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9K bytes - Viewed (0) -
pkg/test/framework/components/echo/instances.go
} return out } // Clusters returns a list of cluster names that the instances are deployed in func (i Instances) Clusters() cluster.Clusters { clusters := map[string]cluster.Cluster{} for _, instance := range i { clusters[instance.Config().Cluster.Name()] = instance.Config().Cluster } out := make(cluster.Clusters, 0, len(clusters)) for _, c := range clusters { out = append(out, c) } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 25 18:26:17 UTC 2024 - 4.7K bytes - Viewed (0) -
tests/integration/pilot/piggyback_test.go
output, _, err := istioCtl.Invoke(args) if err != nil { return err } return expectSubstrings(output, "Clusters Match", "Listeners Match", "Routes Match") }) // Test gRPC-based tapped XDS using istioctl. retry.UntilSuccessOrFail(t, func() error { pf, err := t.Clusters()[0].NewPortForwarder(podName, namespace, "localhost", 0, 15004) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/fake.go
return false } func (f FakeEnvironment) EnvironmentName() string { if len(f.Name) == 0 { return "fake" } return f.Name } func (f FakeEnvironment) AllClusters() cluster.Clusters { res := cluster.Clusters{} allClusters := make(cluster.Map) for i := 0; i < f.NumClusters; i++ { topo := cluster.NewTopology(cluster.Config{ Name: fmt.Sprintf("cluster-%d", i),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 1.8K bytes - Viewed (0) -
tests/integration/pilot/workloadentry_test.go
cfg := t.ConfigIstio().YAML(i.Settings().SystemNamespace, exposeServices) for _, network := range t.Clusters().Networks() { cfg. YAML(i.Settings().SystemNamespace, fmt.Sprintf(gwTmpl, network, network, gatewayAddresses[network].ip)) } cfg.ApplyOrFail(t) // create a unique SE per cluster for _, c := range t.Clusters().Configs() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.1K bytes - Viewed (0)