- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 145 for ClusterID (0.79 sec)
-
pkg/kube/kclient/client_test.go
Namespace: "foo", }, want: kubetypes.InformerOptions{ Namespace: "foo", Cluster: c.ClusterID(), }, }, { name: "watch pods in the InformerWatchNamespace", gvr: gvr.Pod, want: kubetypes.InformerOptions{ Namespace: features.InformerWatchNamespace, Cluster: c.ClusterID(), }, }, { name: "watch namespaces", gvr: gvr.Namespace,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
pkg/test/framework/components/istio/ca.go
Csr: string(csrPEM), ValidityDuration: int64((time.Hour * 24 * 7).Seconds()), } rctx := metadata.NewOutgoingContext(context.Background(), metadata.Pairs("Authorization", "Bearer "+token, "ClusterID", constants.DefaultClusterName)) resp, err := client.CreateCertificate(rctx, req) if err != nil { return Cert{}, fmt.Errorf("send CSR: %v", err) } certChain := []byte{} for _, c := range resp.CertChain {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
return err } defer upstreamConn.Close() xds := discovery.NewAggregatedDiscoveryServiceClient(upstreamConn) ctx = metadata.AppendToOutgoingContext(context.Background(), "ClusterID", p.clusterID) for k, v := range p.xdsHeaders { ctx = metadata.AppendToOutgoingContext(ctx, k, v) } // We must propagate upstream termination to Envoy. This ensures that we resume the full XDS sequence on new connection
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
pilot/pkg/xds/nds_test.go
nameTable: nil, }, } for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { if tt.proxy.Metadata == nil { tt.proxy.Metadata = &model.NodeMetadata{} } tt.proxy.Metadata.ClusterID = constants.DefaultClusterName s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) gen := s.Discovery.Generators[v3.NameTableType] tt.request.Start = time.Now()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 4.6K bytes - Viewed (0) -
pilot/pkg/model/service_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 20:38:02 UTC 2024 - 13.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
gvr.ServiceEntry, } { clienttest.MakeCRD(t, cl, crd) } idx := New(Options{ Client: cl, SystemNamespace: systemNS, DomainSuffix: "company.com", ClusterID: clusterID, XDSUpdater: up, LookupNetwork: func(endpointIP string, labels labels.Instance) network.ID { return networkID }, }) cl.RunAndWait(test.NewStop(t)) t.Cleanup(func() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
ip2instance map[string][]*model.ServiceInstance WantGetProxyServiceTargets []model.ServiceTarget InstancesError error Controller model.Controller ClusterID cluster.ID // Used by GetProxyWorkloadLabels ip2workloadLabels map[string]labels.Instance addresses map[string]model.AddressInfo // XDSUpdater will push EDS changes to the ADS model.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
meshWatcher mesh.Watcher model.NoopAmbientIndexes model.NetworkGatewaysHandler } type Option func(*Controller) func WithClusterID(clusterID cluster.ID) Option { return func(o *Controller) { o.clusterID = clusterID } } func WithNetworkIDCb(cb func(endpointIP string, labels labels.Instance) network.ID) Option { return func(o *Controller) { o.networkIDCallback = cb } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pkg/security/security.go
ProvCert string // ClusterID is the cluster where the agent resides. // Normally initialized from ISTIO_META_CLUSTER_ID - after a tortuous journey it // makes its way into the ClusterID metadata of Citadel gRPC request to create the cert. // Didn't find much doc - but I suspect used for 'central cluster' use cases - so should // match the cluster name set in the MC setup. ClusterID string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 19.1K bytes - Viewed (0) -
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)