Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for StatPrefix (0.22 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/tls.go

    			port = service.Ports[0].Port
    		}
    
    		clusterName := model.BuildSubsetKey(model.TrafficDirectionOutbound, "", service.Hostname, port)
    		statPrefix := clusterName
    		// If stat name is configured, use it to build the stat prefix.
    		if len(push.Mesh.OutboundClusterStatName) != 0 {
    			statPrefix = telemetry.BuildStatPrefix(push.Mesh.OutboundClusterStatName, string(service.Hostname), "", &model.Port{Port: port}, 0, &service.Attributes)
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. pilot/pkg/model/virtualservice.go

    	if out.SourceNamespace == "" {
    		out.SourceNamespace = root.SourceNamespace
    	}
    
    	if len(out.Gateways) == 0 {
    		out.Gateways = root.Gateways
    	}
    
    	if len(out.StatPrefix) == 0 {
    		out.StatPrefix = root.StatPrefix
    	}
    	return &out
    }
    
    func hasConflict(root, leaf *networking.HTTPMatchRequest) bool {
    	roots := []*networking.StringMatch{root.Uri, root.Scheme, root.Method, root.Authority}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 11:17:03 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  8. 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)
  9. pilot/pkg/xds/xds_test.go

    			Equals(wellknown.TCPProxy, "{.filterChains[1].filters[0].name}").
    			Equals("PassthroughCluster", "{.filterChains[1].filters[0].typedConfig.cluster}").
    			Equals("PassthroughCluster", "{.filterChains[1].filters[0].typedConfig.statPrefix}").
    			Equals(true, "{.useOriginalDst}").
    			CheckOrFail(t)
    	})
    
    	t.Run("mongo", func(t *testing.T) {
    		s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  10. 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)
Back to top