Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 570 for cluster2b (0.96 sec)

  1. tensorflow/compiler/mlir/tensorflow/transforms/cluster_ops_by_policy.cc

          cluster.constraints = std::move(member.constraints);
    
        // Add operation to the cluster.
        if (auto op = member.source.dyn_cast<Operation *>())
          cluster.operations.emplace_back(op);
      }
    
      llvm::SmallVector<Cluster> clusters;
      for (auto &kv : root_clusters) {
        Cluster &cluster = kv.getSecond();
        // Skip degenerate clusters formed by a single basic block argument.
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  2. pilot/pkg/xds/xds_test.go

    		serviceCluster      string
    		wantClusterLocal    map[cluster.ID][]string
    		wantNonClusterLocal map[cluster.ID][]string
    	}{
    		// set up a k8s service in each cluster, with a pod in each cluster and a workloadentry in cluster-1
    		"k8s service with pod and workloadentry": {
    			fakeOpts: func() xds.FakeOptions {
    				k8sObjects := map[cluster.ID]string{
    					"cluster-1": "",
    					"cluster-2": "",
    				}
    				i := 1
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/conversion.go

    	}
    	labels := labelutil.AugmentLabels(we.Labels, clusterID, locality, "", networkID)
    	return &model.WorkloadInstance{
    		Endpoint: &model.IstioEndpoint{
    			Address: addr,
    			// Not setting ports here as its done by k8s controller
    			Network: network.ID(we.Network),
    			Locality: model.Locality{
    				Label:     locality,
    				ClusterID: clusterID,
    			},
    			LbWeight:  we.Weight,
    			Namespace: cfg.Namespace,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/util/config/cluster.go

    func FetchInitConfigurationFromCluster(client clientset.Interface, printer output.Printer, logPrefix string, newControlPlane, skipComponentConfigs bool) (*kubeadmapi.InitConfiguration, error) {
    	if printer == nil {
    		printer = &output.TextPrinter{}
    	}
    	printer.Printf("[%s] Reading configuration from the cluster...\n", logPrefix)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 11:04:08 UTC 2024
    - 11K bytes
    - Viewed (0)
  5. pkg/test/framework/components/cluster/cluster.go

    	PrimaryName() string
    
    	// Config returns the config cluster for this cluster. Will return itself if
    	// IsConfig.
    	Config() Cluster
    
    	// ConfigName returns the name of the config cluster for this cluster.
    	ConfigName() string
    
    	// HTTPProxy returns the HTTP proxy config to connect to the cluster
    	HTTPProxy() string
    
    	// Metadata returns the value for a given metadata key for the cluster.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/cluster.go

    func (p clusterPatcher) conditionallyAppend(l []*cluster.Cluster, hosts []host.Name, clusters ...*cluster.Cluster) []*cluster.Cluster {
    	if !p.hasPatches() {
    		return append(l, clusters...)
    	}
    	for _, c := range clusters {
    		if patched := p.doPatch(hosts, c); patched != nil {
    			l = append(l, patched)
    		}
    	}
    	return l
    }
    
    func (p clusterPatcher) insertedClusters() []*cluster.Cluster {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/envoy/configdump/cluster.go

    		if c.Cluster != nil {
    			clusterTyped := &cluster.Cluster{}
    			// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    			c.Cluster.TypeUrl = v3.ClusterType
    			err = c.Cluster.UnmarshalTo(clusterTyped)
    			if err != nil {
    				return nil, err
    			}
    			clusters = append(clusters, clusterTyped)
    		}
    	}
    	for _, c := range clusterDump.StaticClusters {
    		if c.Cluster != nil {
    			clusterTyped := &cluster.Cluster{}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 11 05:38:17 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/multicluster.go

    		s:                      s,
    	}
    	mc.component = multicluster.BuildMultiClusterComponent(controller, func(cluster *multicluster.Cluster) *kubeController {
    		stop := make(chan struct{})
    		client := cluster.Client
    		configCluster := opts.ClusterID == cluster.ID
    
    		options := opts
    		options.ClusterID = cluster.ID
    		if !configCluster {
    			options.SyncTimeout = features.RemoteClusterTimeout
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. tensorflow/compiler/mlir/tensorflow/tests/tpu_cluster_formation.mlir

    // CHECK-SAME: device = "device_1"
    // CHECK-SAME: topology = "topology_1"
    // CHECK:      return %[[CLUSTER_0]], %[[CLUSTER_1]]
    
    
    // Test operands and results of ops of a cluster that are interleaved between
    // other ops of the same cluster are moved before and after the cluster
    // properly.
    // CHECK-LABEL: func @interleaved_cluster_operands_results
    func.func @interleaved_cluster_operands_results() {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu May 02 22:03:30 UTC 2024
    - 53.9K bytes
    - Viewed (0)
  10. pilot/pkg/networking/core/envoyfilter/cluster_patch_test.go

    		{Name: "inbound|7443||", DnsLookupFamily: cluster.Cluster_V4_ONLY, LbPolicy: cluster.Cluster_ROUND_ROBIN},
    	}
    	sidecarInboundServiceOut := []*cluster.Cluster{
    		{
    			Name: "inbound|7443||", ClusterDiscoveryType: &cluster.Cluster_Type{Type: cluster.Cluster_EDS},
    			DnsLookupFamily: cluster.Cluster_V6_ONLY, LbPolicy: cluster.Cluster_RING_HASH,
    		},
    	}
    
    	gatewayInput := []*cluster.Cluster{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 20.7K bytes
    - Viewed (0)
Back to top