Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for XdsType (0.6 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. 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)
  3. 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)
  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. pilot/pkg/status/distribution/reporter.go

    func (r *Reporter) RegisterDisconnect(conID string, types sets.Set[xds.EventType]) {
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	for xdsType := range types {
    		key := GenStatusReporterMapKey(conID, xdsType)
    		r.deleteKeyFromReverseMap(key)
    		delete(r.status, key)
    	}
    }
    
    func (r *Reporter) SetController(controller *Controller) {
    	r.controller = controller
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 30 17:25:17 UTC 2024
    - 11.5K bytes
    - Viewed (0)
Back to top