Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for StatPrefix (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top