- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for IncLookupClusterFailures (0.58 sec)
-
pilot/pkg/model/monitoring.go
package model import "istio.io/istio/pkg/monitoring" var providerLookupClusterFailures = monitoring.NewSum( "provider_lookup_cluster_failures", "Number of times a cluster lookup failed", ) func IncLookupClusterFailures(provider string) { providerLookupClusterFailures.With(typeTag.Value(provider)).Increment()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 904 bytes - Viewed (0) -
pilot/pkg/networking/core/tracing.go
providerConfig = func() (*anypb.Any, error) { hostname, cluster, err := clusterLookupFn(pushCtx, provider.Zipkin.GetService(), int(provider.Zipkin.GetPort())) if err != nil { model.IncLookupClusterFailures("zipkin") return nil, fmt.Errorf("could not find cluster for tracing provider %q: %v", provider, err) } return zipkinConfig(hostname, cluster, !provider.Zipkin.GetEnable_64BitTraceId()) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 24.2K bytes - Viewed (0) -
pilot/pkg/model/telemetry_logging.go
if len(prov.FilterStateObjectsToLog) != 0 { filterObjects = prov.FilterStateObjectsToLog } hostname, cluster, err := clusterLookupFn(push, prov.Service, int(prov.Port)) if err != nil { IncLookupClusterFailures("envoyTCPAls") log.Errorf("could not find cluster for tcp grpc provider %q: %v", prov, err) return nil } fl := &grpcaccesslog.TcpGrpcAccessLogConfig{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 23K bytes - Viewed (0) -
pilot/pkg/security/authz/builder/extauthz.go
port, err := parsePort(config.Port) if err != nil { errs = multierror.Append(errs, err) } hostname, cluster, err := model.LookupCluster(push, config.Service, port) if err != nil { model.IncLookupClusterFailures("authz") errs = multierror.Append(errs, err) } status, err := parseStatusOnError(config.StatusOnError) if err != nil { errs = multierror.Append(errs, err) } if config.PathPrefix != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/security/authn/policy_applier.go
} } else if features.JwksFetchMode == jwt.Hybrid { provider.JwksSourceSpecifier = push.JwtKeyResolver.BuildLocalJwks(jwtRule.JwksUri, jwtRule.Issuer, "", timeout.AsDuration()) } 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 "+
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 19.2K bytes - Viewed (0)