- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 111 for serviceentry (3.55 sec)
-
pilot/pkg/xds/endpoints/endpoint_builder.go
Kind: kind.DestinationRule, Name: dr.Name, Namespace: dr.Namespace, }.HashCode()) } } if b.service != nil { configs = append(configs, model.ConfigKey{ Kind: kind.ServiceEntry, Name: string(b.service.Hostname), Namespace: b.service.Attributes.Namespace, }.HashCode()) } // For now, this matches clusterCache's DependentConfigs. If adding anything here, we may need to add them there.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
tests/integration/security/pass_through_filter_chain_test.go
// ports differently for each test and rely on allow/deny for each to indicate whether // mtls was used. Source(config.YAML(`apiVersion: networking.istio.io/v1beta1 kind: ServiceEntry metadata: name: {{ .To.ServiceName }}-se spec: hosts: - fake.destination.{{ .To.ServiceName }} location: MESH_INTERNAL resolution: NONE addresses:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 11.9K bytes - Viewed (0) -
pilot/pkg/features/pilot.go
}() CanonicalServiceForMeshExternalServiceEntry = env.Register("LABEL_CANONICAL_SERVICES_FOR_MESH_EXTERNAL_SERVICE_ENTRIES", false, "If enabled, metadata representing canonical services for ServiceEntry resources with a location of mesh_external will be populated"+ "in the cluster metadata for those endpoints.").Get() LocalClusterSecretWatcher = env.Register("LOCAL_CLUSTER_SECRET_WATCHER", false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 13.3K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
) // deltaConfigTypes are used to detect changes and trigger delta calculations. When config updates has ONLY entries // in this map, then delta calculation is triggered. var deltaConfigTypes = sets.New(kind.ServiceEntry.String(), kind.DestinationRule.String()) // BuildClusters returns the list of clusters for the given proxy. This is the CDS output // For outbound: Cluster for each service/subset hostname or cidr with SNI set to service hostname
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/model/config.go
) // Statically link protobuf descriptors from UDPA var _ = udpa.TypedStruct{} type ConfigHash uint64 // ConfigKey describe a specific config item. // In most cases, the name is the config's name. However, for ServiceEntry it is service's FQDN. type ConfigKey struct { Kind kind.Kind Name string Namespace string } func (key ConfigKey) HashCode() ConfigHash { h := hash.New() h.Write([]byte{byte(key.Kind)})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 08:51:03 UTC 2024 - 13.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
// because the proxy is in a different cluster. func skipSearchingRegistryForProxy(nodeClusterID cluster.ID, r serviceregistry.Instance) bool { // Always search non-kube (usually serviceentry) registry. // Check every registry if cluster ID isn't specified. if r.Provider() != provider.Kubernetes || nodeClusterID == "" { return false } return !r.Cluster().Equals(nodeClusterID) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
s.MemRegistry.RemoveService("adsupdate.example.com") s.Discovery.ConfigUpdate(&model.PushRequest{ Full: true, ConfigsUpdated: sets.New(model.ConfigKey{Kind: kind.ServiceEntry, Name: "adsupdate.example.com", Namespace: "default"}), }) s.EnsureSynced(t) ads = s.ConnectDeltaADS() // Sometimes we get an EDS request first before CDS
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
tests/integration/telemetry/api/stats_test.go
t.ConfigIstio().Eval(ist.Settings().SystemNamespace, map[string]any{ "Namespace": apps.External.Namespace.Name(), "Hostname": cdeployment.ExternalHostname, }, `apiVersion: networking.istio.io/v1alpha3 kind: ServiceEntry metadata: name: external-service spec: exportTo: [.] hosts: - {{.Hostname}} location: MESH_EXTERNAL resolution: DNS endpoints:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.3K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
changed = true } } if changed { res := ObjectToInstance(se) messages.Add(msg.NewUpdateIncompatibility(res, "ENABLE_RESOLUTION_NONE_TARGET_PORT", "1.21", "ServiceEntry with resolution NONE and a targetPort set previously did nothing but now is respected", "1.21")) } } return nil } func checkExternalNameAlias(cli kube.CLIClient, messages *diag.Messages) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 02:57:30 UTC 2024 - 19.3K bytes - Viewed (0) -
pilot/pkg/security/authn/policy_applier.go
} else { model.IncLookupClusterFailures("jwks") // Log error and create remote JWKs with fake cluster authnLog.Errorf("Failed to look up Envoy cluster %v. "+ "Please create ServiceEntry to register external JWKs server or "+ "set PILOT_JWT_ENABLE_REMOTE_JWKS to hybrid/istiod mode.", err) provider.JwksSourceSpecifier = &envoy_jwt.JwtProvider_RemoteJwks{ RemoteJwks: &envoy_jwt.RemoteJwks{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 19.2K bytes - Viewed (0)