Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 51 for xdstype (0.12 sec)

  1. pilot/pkg/networking/core/route/route_internal_test.go

    					Percentage: &xdstype.FractionalPercent{
    						Numerator:   uint32(50 * 10000),
    						Denominator: xdstype.FractionalPercent_MILLION,
    					},
    					FaultDelaySecifier: &xdsfault.FaultDelay_FixedDelay{
    						FixedDelay: &durationpb.Duration{
    							Seconds: int64(3),
    						},
    					},
    				},
    				Abort: &xdshttpfault.FaultAbort{
    					Percentage: &xdstype.FractionalPercent{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat May 11 02:47:57 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  2. pilot/pkg/xds/monitoring.go

    		case v3.RouteType:
    			rdsSendErrPushes.Increment()
    		}
    		return true
    	}
    	return false
    }
    
    func recordPushTime(xdsType string, duration time.Duration) {
    	pushTime.With(typeTag.Value(v3.GetMetricType(xdsType))).Record(duration.Seconds())
    	pushes.With(typeTag.Value(v3.GetMetricType(xdsType))).Increment()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  3. pkg/xds/monitoring.go

    		"Total time in seconds Pilot takes to send generated configuration.",
    		[]float64{.01, .1, 1, 3, 5, 10, 20, 30},
    	)
    )
    
    func IncrementXDSRejects(xdsType string, node, errCode string) {
    	totalXDSRejects.With(typeTag.Value(model.GetMetricType(xdsType))).Increment()
    	switch xdsType {
    	case model.ListenerType:
    		ldsReject.With(nodeTag.Value(node), errTag.Value(errCode)).Increment()
    	case model.ClusterType:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/listener_test.go

    				Sampling:         0,
    			},
    			out: &hcm.HttpConnectionManager_Tracing{
    				MaxPathTagLength: nil,
    				ClientSampling: &xdstype.Percent{
    					Value: 100.0,
    				},
    				RandomSampling: &xdstype.Percent{
    					Value: 80.0,
    				},
    				OverallSampling: &xdstype.Percent{
    					Value: 100.0,
    				},
    				CustomTags: customTracingTags(),
    			},
    		},
    		{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 93.6K bytes
    - Viewed (0)
  5. pkg/bootstrap/config.go

    	discHost := strings.Split(cfg.Metadata.ProxyConfig.DiscoveryAddress, ":")[0]
    
    	xdsType := "GRPC"
    	if features.DeltaXds {
    		xdsType = "DELTA_GRPC"
    	}
    
    	// Waypoint overrides
    	metadataDiscovery := cfg.Metadata.MetadataDiscovery
    	if strings.HasPrefix(cfg.ID, "waypoint~") {
    		xdsType = "DELTA_GRPC"
    		metadataDiscovery = true
    	}
    
    	opts = append(opts,
    		option.NodeID(cfg.ID),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:02:38 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/route/route.go

    	return &xdstype.FractionalPercent{
    		Numerator:   uint32(p.Value * 10000),
    		Denominator: xdstype.FractionalPercent_MILLION,
    	}
    }
    
    // translateIntegerToFractionalPercent translates an int32 instance to an
    // envoy.type.FractionalPercent instance.
    func translateIntegerToFractionalPercent(p int32) *xdstype.FractionalPercent {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/tracing.go

    	}
    }
    
    func configureSampling(hcmTracing *hcm.HttpConnectionManager_Tracing, providerPercentage float64) {
    	hcmTracing.ClientSampling = &xdstype.Percent{
    		Value: 100.0,
    	}
    	hcmTracing.OverallSampling = &xdstype.Percent{
    		Value: 100.0,
    	}
    	hcmTracing.RandomSampling = &xdstype.Percent{
    		Value: providerPercentage,
    	}
    }
    
    func proxyConfigSamplingValue(config *meshconfig.ProxyConfig) float64 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 17:05:28 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  8. pilot/pkg/networking/core/cluster_traffic_policy.go

    	proxyprotocol "github.com/envoyproxy/go-control-plane/envoy/extensions/transport_sockets/proxy_protocol/v3"
    	http "github.com/envoyproxy/go-control-plane/envoy/extensions/upstreams/http/v3"
    	xdstype "github.com/envoyproxy/go-control-plane/envoy/type/v3"
    	"google.golang.org/protobuf/proto"
    	"google.golang.org/protobuf/types/known/durationpb"
    	"google.golang.org/protobuf/types/known/wrapperspb"
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 23 05:38:57 UTC 2024
    - 20K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/tracing_test.go

    	t := &hcm.HttpConnectionManager_Tracing{
    		ClientSampling: &xdstype.Percent{
    			Value: 100.0,
    		},
    		OverallSampling: &xdstype.Percent{
    			Value: 100.0,
    		},
    		RandomSampling: &xdstype.Percent{
    			Value: randomSampling,
    		},
    		CustomTags: tags,
    	}
    	if maxLen != 0 {
    		t.MaxPathTagLength = wrapperspb.UInt32(maxLen)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 20:47:52 UTC 2024
    - 38.6K bytes
    - Viewed (0)
  10. pkg/bootstrap/option/instances.go

    	return newOption("nodeID", value)
    }
    
    func NodeType(value string) Instance {
    	ntype := strings.Split(value, "~")[0]
    	return newOption("nodeType", ntype)
    }
    
    func XdsType(value string) Instance {
    	return newOption("xds_type", value)
    }
    
    func Region(value string) Instance {
    	return newOptionOrSkipIfZero("region", value)
    }
    
    func Zone(value string) Instance {
    	return newOptionOrSkipIfZero("zone", value)
    }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:02:38 UTC 2024
    - 9K bytes
    - Viewed (0)
Back to top