envoy_config_filter_http_adaptive_concurrency_v2alpha

package
v1.12.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 30, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdaptiveConcurrency 

type AdaptiveConcurrency struct {
	// Types that are valid to be assigned to ConcurrencyControllerConfig:
	//	*AdaptiveConcurrency_GradientControllerConfig
	ConcurrencyControllerConfig isAdaptiveConcurrency_ConcurrencyControllerConfig `protobuf_oneof:"concurrency_controller_config"`
	// If set to false, the adaptive concurrency filter will operate as a pass-through filter. If the
	// message is unspecified, the filter will be enabled.
	Enabled              *core.RuntimeFeatureFlag `protobuf:"bytes,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*AdaptiveConcurrency) Descriptor 

func (*AdaptiveConcurrency) Descriptor() ([]byte, []int)

func (*AdaptiveConcurrency) GetConcurrencyControllerConfig 

func (m *AdaptiveConcurrency) GetConcurrencyControllerConfig() isAdaptiveConcurrency_ConcurrencyControllerConfig

func (*AdaptiveConcurrency) GetEnabled 

func (m *AdaptiveConcurrency) GetEnabled() *core.RuntimeFeatureFlag

func (*AdaptiveConcurrency) GetGradientControllerConfig 

func (m *AdaptiveConcurrency) GetGradientControllerConfig() *GradientControllerConfig

func (*AdaptiveConcurrency) ProtoMessage 

func (*AdaptiveConcurrency) ProtoMessage()

func (*AdaptiveConcurrency) Reset 

func (m *AdaptiveConcurrency) Reset()

func (*AdaptiveConcurrency) String 

func (m *AdaptiveConcurrency) String() string

func (*AdaptiveConcurrency) XXX_DiscardUnknown 

func (m *AdaptiveConcurrency) XXX_DiscardUnknown()

func (*AdaptiveConcurrency) XXX_Marshal 

func (m *AdaptiveConcurrency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AdaptiveConcurrency) XXX_Merge 

func (m *AdaptiveConcurrency) XXX_Merge(src proto.Message)

func (*AdaptiveConcurrency) XXX_OneofWrappers 

func (*AdaptiveConcurrency) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AdaptiveConcurrency) XXX_Size 

func (m *AdaptiveConcurrency) XXX_Size() int

func (*AdaptiveConcurrency) XXX_Unmarshal 

func (m *AdaptiveConcurrency) XXX_Unmarshal(b []byte) error

type AdaptiveConcurrency_GradientControllerConfig 

type AdaptiveConcurrency_GradientControllerConfig struct {
	GradientControllerConfig *GradientControllerConfig `protobuf:"bytes,1,opt,name=gradient_controller_config,json=gradientControllerConfig,proto3,oneof"`
}

type GradientControllerConfig 

type GradientControllerConfig struct {
	// The percentile to use when summarizing aggregated samples. Defaults to p50.
	SampleAggregatePercentile *_type.Percent                                              `` /* 138-byte string literal not displayed */
	ConcurrencyLimitParams    *GradientControllerConfig_ConcurrencyLimitCalculationParams `` /* 129-byte string literal not displayed */
	MinRttCalcParams          *GradientControllerConfig_MinimumRTTCalculationParams       `protobuf:"bytes,3,opt,name=min_rtt_calc_params,json=minRttCalcParams,proto3" json:"min_rtt_calc_params,omitempty"`
	XXX_NoUnkeyedLiteral      struct{}                                                    `json:"-"`
	XXX_unrecognized          []byte                                                      `json:"-"`
	XXX_sizecache             int32                                                       `json:"-"`
}

Configuration parameters for the gradient controller.

func (*GradientControllerConfig) Descriptor 

func (*GradientControllerConfig) Descriptor() ([]byte, []int)

func (*GradientControllerConfig) GetConcurrencyLimitParams 

func (m *GradientControllerConfig) GetConcurrencyLimitParams() *GradientControllerConfig_ConcurrencyLimitCalculationParams

func (*GradientControllerConfig) GetMinRttCalcParams 

func (m *GradientControllerConfig) GetMinRttCalcParams() *GradientControllerConfig_MinimumRTTCalculationParams

func (*GradientControllerConfig) GetSampleAggregatePercentile 

func (m *GradientControllerConfig) GetSampleAggregatePercentile() *_type.Percent

func (*GradientControllerConfig) ProtoMessage 

func (*GradientControllerConfig) ProtoMessage()

func (*GradientControllerConfig) Reset 

func (m *GradientControllerConfig) Reset()

func (*GradientControllerConfig) String 

func (m *GradientControllerConfig) String() string

func (*GradientControllerConfig) XXX_DiscardUnknown 

func (m *GradientControllerConfig) XXX_DiscardUnknown()

func (*GradientControllerConfig) XXX_Marshal 

func (m *GradientControllerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GradientControllerConfig) XXX_Merge 

func (m *GradientControllerConfig) XXX_Merge(src proto.Message)

func (*GradientControllerConfig) XXX_Size 

func (m *GradientControllerConfig) XXX_Size() int

func (*GradientControllerConfig) XXX_Unmarshal 

func (m *GradientControllerConfig) XXX_Unmarshal(b []byte) error

type GradientControllerConfig_ConcurrencyLimitCalculationParams 

type GradientControllerConfig_ConcurrencyLimitCalculationParams struct {
	// The maximum value the gradient is allowed to take. This influences how aggressively the
	// concurrency limit can increase. Defaults to 2.0.
	MaxGradient *types.DoubleValue `protobuf:"bytes,1,opt,name=max_gradient,json=maxGradient,proto3" json:"max_gradient,omitempty"`
	// The allowed upper-bound on the calculated concurrency limit. Defaults to 1000.
	MaxConcurrencyLimit *types.UInt32Value `protobuf:"bytes,2,opt,name=max_concurrency_limit,json=maxConcurrencyLimit,proto3" json:"max_concurrency_limit,omitempty"`
	// The period of time samples are taken to recalculate the concurrency limit.
	ConcurrencyUpdateInterval *types.Duration `` /* 138-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{}        `json:"-"`
	XXX_unrecognized          []byte          `json:"-"`
	XXX_sizecache             int32           `json:"-"`
}

Parameters controlling the periodic recalculation of the concurrency limit from sampled request latencies.

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) Descriptor 

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) Descriptor() ([]byte, []int)

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) GetConcurrencyUpdateInterval 

func (m *GradientControllerConfig_ConcurrencyLimitCalculationParams) GetConcurrencyUpdateInterval() *types.Duration

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) GetMaxConcurrencyLimit 

func (m *GradientControllerConfig_ConcurrencyLimitCalculationParams) GetMaxConcurrencyLimit() *types.UInt32Value

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) GetMaxGradient 

func (m *GradientControllerConfig_ConcurrencyLimitCalculationParams) GetMaxGradient() *types.DoubleValue

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) ProtoMessage 

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) ProtoMessage()

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) Reset 

func (m *GradientControllerConfig_ConcurrencyLimitCalculationParams) Reset()

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) String 

func (m *GradientControllerConfig_ConcurrencyLimitCalculationParams) String() string

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) XXX_DiscardUnknown 

func (m *GradientControllerConfig_ConcurrencyLimitCalculationParams) XXX_DiscardUnknown()

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) XXX_Marshal 

func (m *GradientControllerConfig_ConcurrencyLimitCalculationParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) XXX_Merge 

func (m *GradientControllerConfig_ConcurrencyLimitCalculationParams) XXX_Merge(src proto.Message)

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) XXX_Size 

func (m *GradientControllerConfig_ConcurrencyLimitCalculationParams) XXX_Size() int

func (*GradientControllerConfig_ConcurrencyLimitCalculationParams) XXX_Unmarshal 

func (m *GradientControllerConfig_ConcurrencyLimitCalculationParams) XXX_Unmarshal(b []byte) error

type GradientControllerConfig_MinimumRTTCalculationParams 

type GradientControllerConfig_MinimumRTTCalculationParams struct {
	// The time interval between recalculating the minimum request round-trip time.
	Interval *types.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// The number of requests to aggregate/sample during the minRTT recalculation window before
	// updating. Defaults to 50.
	RequestCount *types.UInt32Value `protobuf:"bytes,2,opt,name=request_count,json=requestCount,proto3" json:"request_count,omitempty"`
	// Randomized time delta that will be introduced to the start of the minRTT calculation window.
	// This is represented as a percentage of the interval duration. Defaults to 15%.
	//
	// Example: If the interval is 10s and the jitter is 15%, the next window will begin
	// somewhere in the range (10s - 11.5s).
	Jitter               *_type.Percent `protobuf:"bytes,3,opt,name=jitter,proto3" json:"jitter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Parameters controlling the periodic minRTT recalculation.

func (*GradientControllerConfig_MinimumRTTCalculationParams) Descriptor 

func (*GradientControllerConfig_MinimumRTTCalculationParams) Descriptor() ([]byte, []int)

func (*GradientControllerConfig_MinimumRTTCalculationParams) GetInterval 

func (m *GradientControllerConfig_MinimumRTTCalculationParams) GetInterval() *types.Duration

func (*GradientControllerConfig_MinimumRTTCalculationParams) GetJitter 

func (m *GradientControllerConfig_MinimumRTTCalculationParams) GetJitter() *_type.Percent

func (*GradientControllerConfig_MinimumRTTCalculationParams) GetRequestCount 

func (m *GradientControllerConfig_MinimumRTTCalculationParams) GetRequestCount() *types.UInt32Value

func (*GradientControllerConfig_MinimumRTTCalculationParams) ProtoMessage 

func (*GradientControllerConfig_MinimumRTTCalculationParams) ProtoMessage()

func (*GradientControllerConfig_MinimumRTTCalculationParams) Reset 

func (m *GradientControllerConfig_MinimumRTTCalculationParams) Reset()

func (*GradientControllerConfig_MinimumRTTCalculationParams) String 

func (m *GradientControllerConfig_MinimumRTTCalculationParams) String() string

func (*GradientControllerConfig_MinimumRTTCalculationParams) XXX_DiscardUnknown 

func (m *GradientControllerConfig_MinimumRTTCalculationParams) XXX_DiscardUnknown()

func (*GradientControllerConfig_MinimumRTTCalculationParams) XXX_Marshal 

func (m *GradientControllerConfig_MinimumRTTCalculationParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GradientControllerConfig_MinimumRTTCalculationParams) XXX_Merge 

func (m *GradientControllerConfig_MinimumRTTCalculationParams) XXX_Merge(src proto.Message)

func (*GradientControllerConfig_MinimumRTTCalculationParams) XXX_Size 

func (m *GradientControllerConfig_MinimumRTTCalculationParams) XXX_Size() int

func (*GradientControllerConfig_MinimumRTTCalculationParams) XXX_Unmarshal 

func (m *GradientControllerConfig_MinimumRTTCalculationParams) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.