- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for StatPrefix (0.21 sec)
-
pilot/pkg/networking/core/networkfilter.go
// configuring the Redis proxy. func buildRedisFilter(statPrefix, clusterName string) *listener.Filter { redisProxy := &redis.RedisProxy{ LatencyInMicros: true, // redis latency stats are captured in micro seconds which is typically the case. StatPrefix: statPrefix, // redis stats are prefixed with redis.<statPrefix> by Envoy Settings: &redis.RedisProxy_ConnPoolSettings{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
statPrefix := fcc.clusterName // If stat name is configured, build the stat prefix from configured pattern. if len(lb.push.Mesh.InboundClusterStatName) != 0 { statPrefix = telemetry.BuildInboundStatPrefix(lb.push.Mesh.InboundClusterStatName, fcc.telemetryMetadata, "", uint32(fcc.port.Port), fcc.port.Name) } tcpProxy := &tcp.TcpProxy{ StatPrefix: statPrefix,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter_test.go
redisProxy := redis.RedisProxy{} if err := config.TypedConfig.UnmarshalTo(&redisProxy); err != nil { t.Errorf("unmarshal failed: %v", err) } if redisProxy.StatPrefix != "redis" { t.Errorf("redis proxy statPrefix is %s", redisProxy.StatPrefix) } if !redisProxy.LatencyInMicros { t.Errorf("redis proxy latency stat is not configured for microseconds") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 25.8K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder.go
} else { connectionManager.CodecType = hcm.HttpConnectionManager_AUTO } connectionManager.AccessLog = []*accesslog.AccessLog{} connectionManager.StatPrefix = httpOpts.statPrefix // Setup normalization connectionManager.PathWithEscapedSlashesAction = hcm.HttpConnectionManager_KEEP_UNCHANGED switch lb.push.Mesh.GetPathNormalization().GetNormalization() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
}, suppressEnvoyDebugHeaders: ph.SuppressDebugHeaders, protocol: cc.port.Protocol, class: istionetworking.ListenerClassSidecarInbound, statPrefix: cc.StatPrefix(), isWaypoint: true, policySvc: svc, } // See https://github.com/grpc/grpc-web/tree/master/net/grpc/gateway/examples/helloworld#configure-the-proxy
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway.go
if len(opt.networkFilters) > 0 { filterChain.Filters = append(filterChain.Filters, opt.networkFilters...) } // If statPrefix has been set before calling this method, respect that. if len(opt.httpOpts.statPrefix) == 0 { opt.httpOpts.statPrefix = strings.ToLower(ml.Listener.TrafficDirection.String()) + "_" + ml.Listener.Name } opt.httpOpts.port = opts.port
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 46.4K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/listener_patch_test.go
{ Filters: []*listener.Filter{ { Name: "envoy.redis_proxy", ConfigType: &listener.Filter_TypedConfig{ TypedConfig: protoconv.MessageToAny(&redis.RedisProxy{ StatPrefix: "redis_stats", PrefixRoutes: &redis.RedisProxy_PrefixRoutes{ CatchAllRoute: &redis.RedisProxy_PrefixRoutes_Route{ Cluster: "custom-redis-cluster", }, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 70.1K bytes - Viewed (0) -
pilot/pkg/security/authz/builder/extauthz.go
TransportApiVersion: core.ApiVersion_V3, WithRequestBody: withBodyRequest(config.IncludeRequestBodyInCheck), } tcp := &extauthztcp.ExtAuthz{ StatPrefix: "tcp.", FailureModeAllow: config.FailOpen, TransportApiVersion: core.ApiVersion_V3, GrpcService: grpc, FilterEnabledMetadata: generateFilterMatcher(wellknown.RoleBasedAccessControl),
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/networking/core/listener_test.go
f := fc.Filters[0] expectedStatPrefix := util.PassthroughCluster cfg, _ := conversion.MessageToStruct(f.GetTypedConfig()) statPrefix := cfg.Fields["stat_prefix"].GetStringValue() if statPrefix != expectedStatPrefix { t.Fatalf("expected listener to contain stat_prefix %s, found %s", expectedStatPrefix, statPrefix) } } func verifyOutboundTCPListenerHostname(t *testing.T, l *listener.Listener, hostname host.Name) { t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route.go
Match: TranslateRouteMatch(virtualService, match, node.SupportsEnvoyExtendedJwt()), Metadata: util.BuildConfigInfoMetadata(virtualService.Meta), } if match != nil && match.StatPrefix != "" { out.StatPrefix = match.StatPrefix } authority := "" if in.Headers != nil { operations := TranslateHeadersOperations(in.Headers) out.RequestHeadersToAdd = operations.RequestHeadersToAdd
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 56.1K bytes - Viewed (0)