Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 1,680 for cluster1 (0.1 sec)

  1. 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)
  2. pilot/pkg/networking/core/cluster_waypoint.go

    	clusters = append(clusters, MainInternalCluster, EncapCluster)
    	// Creates per-VIP load balancing upstreams.
    	clusters = append(clusters, cb.buildWaypointInboundVIP(proxy, svcs)...)
    	// Upstream of the "encap" listener.
    	clusters = append(clusters, cb.buildWaypointConnectOriginate(proxy, push))
    
    	for _, c := range clusters {
    		if c.TransportSocket != nil && c.TransportSocketMatches != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 9K bytes
    - Viewed (0)
  3. pkg/test/framework/components/echo/deployment/builder.go

    	}
    	b.templates = templates
    
    	return b.WithClusters(clusters...)
    }
    
    type builder struct {
    	ctx resource.Context
    
    	// clusters contains the current set of clusters that subsequent With calls will be applied to,
    	// if the Config passed to With does not explicitly choose a cluster.
    	clusters cluster.Clusters
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 12K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/ambient/workloads_test.go

    					Status:            workloadapi.WorkloadStatus_HEALTHY,
    					ClusterId:         testC,
    					Services: map[string]*workloadapi.PortList{
    						"ns/a.example.com": {
    							Ports: []*workloadapi.Port{{
    								ServicePort: 80,
    								TargetPort:  80,
    							}},
    						},
    					},
    				},
    				{
    					Uid:               "cluster0/networking.istio.io/ServiceEntry/ns/name/b.example.com",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  5. pkg/controller/nodeipam/config/types.go

    	// NodeCIDRMaskSizeIPv4 is the mask size for IPv4 node cidr in dual-stack cluster.
    	// This can be used only with dual stack clusters and is incompatible with single stack clusters.
    	NodeCIDRMaskSizeIPv4 int32
    	// NodeCIDRMaskSizeIPv6 is the mask size for IPv6 node cidr in dual-stack cluster.
    	// This can be used only with dual stack clusters and is incompatible with single stack clusters.
    	NodeCIDRMaskSizeIPv6 int32
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 15 23:38:06 UTC 2019
    - 1.6K bytes
    - Viewed (0)
  6. pkg/kube/multicluster/secretcontroller.go

    	log.Infof("Deleting cluster_id=%v configured by secret=%v", cluster.ID, secretKey)
    	cluster.Stop()
    	c.handleDelete(cluster.ID)
    	c.cs.Delete(secretKey, cluster.ID)
    
    	log.Infof("Number of remote clusters: %d", c.cs.Len())
    }
    
    func (c *Controller) handleAdd(cluster *Cluster) []ComponentConstraint {
    	syncers := make([]ComponentConstraint, 0, len(c.handlers))
    	for _, handler := range c.handlers {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 06 02:13:10 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. pkg/test/framework/components/istio/kube.go

    	}
    	return nil
    }
    
    func getTargetClusterListForCluster(targetClusters []cluster.Cluster, c cluster.Cluster) []cluster.Cluster {
    	var outClusters []cluster.Cluster
    	scopes.Framework.Infof("Secret from cluster: %s will be placed in following clusters", c.Name())
    	for _, cc := range targetClusters {
    		// if cc is an external cluster, config cluster's secret should have already been
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  8. pkg/test/framework/components/environment/kube/settings.go

    	// controlPlaneTopology maps each cluster to the cluster that runs its control plane. For replicated control
    	// plane cases (where each cluster has its own control plane), the cluster will map to itself (e.g. 0->0).
    	controlPlaneTopology clusterTopology
    
    	// networkTopology is used for the initial assignment of networks to each cluster.
    	// The source of truth clusters' networks is the Cluster instances themselves, rather than this field.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  9. pilot/pkg/networking/grpcgen/cds.go

    	subsetClusters := b.applyDestinationRule(defaultCluster)
    	out := make([]*cluster.Cluster, 0, 1+len(subsetClusters))
    	if defaultCluster != nil {
    		out = append(out, defaultCluster)
    	}
    	return append(out, subsetClusters...)
    }
    
    // edsCluster creates a simple cluster to read endpoints from ads/eds.
    func edsCluster(name string) *cluster.Cluster {
    	return &cluster.Cluster{
    		Name:                 name,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. tests/integration/pilot/workloadentry_test.go

    			}
    			gatewayAddresses := map[string]gwAddr{}
    			for _, cluster := range t.Clusters() {
    				if _, ok := gatewayAddresses[cluster.NetworkName()]; ok {
    					continue
    				}
    				ips, ports := i.EastWestGatewayFor(cluster).AddressesForPort(15443)
    				if ips != nil {
    					gatewayAddresses[cluster.NetworkName()] = gwAddr{ips[0], ports[0]}
    				}
    			}
    			if len(t.Clusters().Networks()) != len(gatewayAddresses) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top