Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 46 of 46 for ClusterID (0.2 sec)

  1. pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller_test.go

    			},
    		},
    	}
    	env := model.Environment{Watcher: mesh.NewFixedWatcher(&m)}
    	env.Init()
    
    	sc := newAutoServiceExportController(autoServiceExportOptions{
    		Client:       client,
    		ClusterID:    "",
    		DomainSuffix: env.DomainSuffix,
    		ClusterLocal: env.ClusterLocal(),
    	})
    
    	stop := test.NewStop(t)
    	client.RunAndWait(stop)
    	go sc.Run(stop)
    
    	t.Run("exportable", func(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 06 16:02:24 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/cluster_cache.go

    			service, dr,
    		)
    	}
    	return clusterCache{
    		clusterName:     clusterName,
    		proxyVersion:    cb.proxyVersion,
    		locality:        cb.locality,
    		proxyClusterID:  cb.clusterID,
    		proxySidecar:    cb.sidecarProxy(),
    		proxyView:       cb.proxyView,
    		hbone:           cb.sendHbone,
    		http2:           port.Protocol.IsHTTP2(),
    		downstreamAuto:  cb.sidecarProxy() && port.Protocol.IsUnsupported(),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 18 19:09:43 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. pilot/pkg/config/kube/gateway/context.go

    			if len(instances) > 0 {
    				foundInternal.Insert(fmt.Sprintf("%s:%d", g, port))
    				foundInternalIP.InsertAll(svc.GetAddresses(&model.Proxy{Metadata: &model.NodeMetadata{ClusterID: gc.cluster}})...)
    				if svc.Attributes.ClusterExternalAddresses.Len() > 0 {
    					// Fetch external IPs from all clusters
    					svc.Attributes.ClusterExternalAddresses.ForEach(func(c cluster.ID, externalIPs []string) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 18:33:02 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  4. pkg/dns/server/name_table.go

    					}
    					// TODO(stevenctl): headless across-networks https://github.com/istio/istio/issues/38327
    					sameNetwork := cfg.Node.InNetwork(instance.Network)
    					sameCluster := cfg.Node.InCluster(instance.Locality.ClusterID)
    					// For all k8s headless services, populate the dns table with the endpoint IPs as k8s does.
    					// And for each individual pod, populate the dns table with the endpoint IP with a manufactured host name.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Feb 27 07:19:38 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  5. pkg/istio-agent/xds_proxy_delta_test.go

    		t.Fatalf("Expected to get listener response but got %v", res)
    	}
    }
    
    func TestDeltaECDSWasmConversion(t *testing.T) {
    	node := model.NodeMetadata{
    		Namespace:   "default",
    		InstanceIPs: []string{"1.1.1.1"},
    		ClusterID:   constants.DefaultClusterName,
    	}
    	proxy := setupXdsProxy(t)
    	// Reset wasm cache to a fake ACK cache.
    	proxy.wasmCache.Cleanup()
    	proxy.wasmCache = &fakeAckCache{}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 04:48:02 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  6. pkg/config/analysis/README.md

                c.Report(gvk.VirtualService, msg)
            }
        }
    }
    ```
    
    If you are writing a multi-cluster analyzer, you can obtain the cluster name from the resource metadata:
    
    ```go
    clusterID := r.Origin.ClusterName()
    ```
    
    ### 2. Add the Analyzer to All()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 08:32:06 UTC 2024
    - 9.4K bytes
    - Viewed (0)
Back to top