overloadv3

package
v1.36.3-20230428204821... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const ResourceMonitor_ConfigType_not_set_case case_ResourceMonitor_ConfigType = 0
View Source 
const ResourceMonitor_TypedConfig_case case_ResourceMonitor_ConfigType = 3
View Source 
const ScaleTimersOverloadActionConfig_ScaleTimer_MinScale_case case_ScaleTimersOverloadActionConfig_ScaleTimer_OverloadAdjust = 3
View Source 
const ScaleTimersOverloadActionConfig_ScaleTimer_MinTimeout_case case_ScaleTimersOverloadActionConfig_ScaleTimer_OverloadAdjust = 2
View Source 
const ScaleTimersOverloadActionConfig_ScaleTimer_OverloadAdjust_not_set_case case_ScaleTimersOverloadActionConfig_ScaleTimer_OverloadAdjust = 0
View Source 
const Trigger_Scaled_case case_Trigger_TriggerOneof = 3
View Source 
const Trigger_Threshold_case case_Trigger_TriggerOneof = 2
View Source 
const Trigger_TriggerOneof_not_set_case case_Trigger_TriggerOneof = 0

Variables

View Source 
var (
	ScaleTimersOverloadActionConfig_TimerType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "HTTP_DOWNSTREAM_CONNECTION_IDLE",
		2: "HTTP_DOWNSTREAM_STREAM_IDLE",
		3: "TRANSPORT_SOCKET_CONNECT",
	}
	ScaleTimersOverloadActionConfig_TimerType_value = map[string]int32{
		"UNSPECIFIED":                     0,
		"HTTP_DOWNSTREAM_CONNECTION_IDLE": 1,
		"HTTP_DOWNSTREAM_STREAM_IDLE":     2,
		"TRANSPORT_SOCKET_CONNECT":        3,
	}
)

Enum value maps for ScaleTimersOverloadActionConfig_TimerType.

View Source 
var File_envoy_config_overload_v3_overload_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BufferFactoryConfig 

type BufferFactoryConfig struct {

	// The minimum power of two at which Envoy starts tracking an account.
	//
	// Envoy has 8 power of two buckets starting with the provided exponent below.
	// Concretely the 1st bucket contains accounts for streams that use
	// [2^minimum_account_to_track_power_of_two,
	// 2^(minimum_account_to_track_power_of_two + 1)) bytes.
	// With the 8th bucket tracking accounts
	// >= 128 * 2^minimum_account_to_track_power_of_two.
	//
	// The maximum value is 56, since we're using uint64_t for bytes counting,
	// and that's the last value that would use the 8 buckets. In practice,
	// we don't expect the proxy to be holding 2^56 bytes.
	//
	// If omitted, Envoy should not do any tracking.
	MinimumAccountToTrackPowerOfTwo uint32 `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

Configuration for which accounts the WatermarkBuffer Factories should track.

func (*BufferFactoryConfig) GetMinimumAccountToTrackPowerOfTwo 

func (x *BufferFactoryConfig) GetMinimumAccountToTrackPowerOfTwo() uint32

func (*BufferFactoryConfig) ProtoMessage 

func (*BufferFactoryConfig) ProtoMessage()

func (*BufferFactoryConfig) ProtoReflect 

func (x *BufferFactoryConfig) ProtoReflect() protoreflect.Message

func (*BufferFactoryConfig) Reset 

func (x *BufferFactoryConfig) Reset()

func (*BufferFactoryConfig) SetMinimumAccountToTrackPowerOfTwo 

func (x *BufferFactoryConfig) SetMinimumAccountToTrackPowerOfTwo(v uint32)

func (*BufferFactoryConfig) String 

func (x *BufferFactoryConfig) String() string

type BufferFactoryConfig_builder 

type BufferFactoryConfig_builder struct {

	// The minimum power of two at which Envoy starts tracking an account.
	//
	// Envoy has 8 power of two buckets starting with the provided exponent below.
	// Concretely the 1st bucket contains accounts for streams that use
	// [2^minimum_account_to_track_power_of_two,
	// 2^(minimum_account_to_track_power_of_two + 1)) bytes.
	// With the 8th bucket tracking accounts
	// >= 128 * 2^minimum_account_to_track_power_of_two.
	//
	// The maximum value is 56, since we're using uint64_t for bytes counting,
	// and that's the last value that would use the 8 buckets. In practice,
	// we don't expect the proxy to be holding 2^56 bytes.
	//
	// If omitted, Envoy should not do any tracking.
	MinimumAccountToTrackPowerOfTwo uint32
	// contains filtered or unexported fields
}

func (BufferFactoryConfig_builder) Build 

func (b0 BufferFactoryConfig_builder) Build() *BufferFactoryConfig

type LoadShedPoint 

type LoadShedPoint struct {

	// This is just a well-known string for the LoadShedPoint.
	// Deployment specific LoadShedPoints e.g. within a custom extension should
	// be prefixed by the company / deployment name to avoid colliding with any
	// open source LoadShedPoints.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// A set of triggers for this LoadShedPoint. The LoadShedPoint will use the
	// the maximum state of all triggers, which can be scalar values between 0 and
	// 1 or saturated. A LoadShedPoint can only have one trigger for a given
	// resource e.g. :ref:`Trigger.name
	// <envoy_v3_api_field_config.overload.v3.Trigger.name>` must be unique in
	// this list.
	Triggers []*Trigger `protobuf:"bytes,2,rep,name=triggers,proto3" json:"triggers,omitempty"`
	// contains filtered or unexported fields
}

A point within the connection or request lifecycle that provides context on whether to shed load at that given stage for the current entity at the point.

func (*LoadShedPoint) GetName 

func (x *LoadShedPoint) GetName() string

func (*LoadShedPoint) GetTriggers 

func (x *LoadShedPoint) GetTriggers() []*Trigger

func (*LoadShedPoint) ProtoMessage 

func (*LoadShedPoint) ProtoMessage()

func (*LoadShedPoint) ProtoReflect 

func (x *LoadShedPoint) ProtoReflect() protoreflect.Message

func (*LoadShedPoint) Reset 

func (x *LoadShedPoint) Reset()

func (*LoadShedPoint) SetName 

func (x *LoadShedPoint) SetName(v string)

func (*LoadShedPoint) SetTriggers 

func (x *LoadShedPoint) SetTriggers(v []*Trigger)

func (*LoadShedPoint) String 

func (x *LoadShedPoint) String() string

type LoadShedPoint_builder 

type LoadShedPoint_builder struct {

	// This is just a well-known string for the LoadShedPoint.
	// Deployment specific LoadShedPoints e.g. within a custom extension should
	// be prefixed by the company / deployment name to avoid colliding with any
	// open source LoadShedPoints.
	Name string
	// A set of triggers for this LoadShedPoint. The LoadShedPoint will use the
	// the maximum state of all triggers, which can be scalar values between 0 and
	// 1 or saturated. A LoadShedPoint can only have one trigger for a given
	// resource e.g. :ref:`Trigger.name
	// <envoy_v3_api_field_config.overload.v3.Trigger.name>` must be unique in
	// this list.
	Triggers []*Trigger
	// contains filtered or unexported fields
}

func (LoadShedPoint_builder) Build 

func (b0 LoadShedPoint_builder) Build() *LoadShedPoint

type OverloadAction 

type OverloadAction struct {

	// The name of the overload action. This is just a well-known string that listeners can
	// use for registering callbacks. Custom overload actions should be named using reverse
	// DNS to ensure uniqueness.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// A set of triggers for this action. The state of the action is the maximum
	// state of all triggers, which can be scalar values between 0 and 1 or
	// saturated. Listeners are notified when the overload action changes state.
	// An overload manager action can only have one trigger for a given resource
	// e.g. :ref:`Trigger.name
	// <envoy_v3_api_field_config.overload.v3.Trigger.name>` must be unique
	// in this list.
	Triggers []*Trigger `protobuf:"bytes,2,rep,name=triggers,proto3" json:"triggers,omitempty"`
	// Configuration for the action being instantiated.
	TypedConfig *anypb.Any `protobuf:"bytes,3,opt,name=typed_config,json=typedConfig,proto3" json:"typed_config,omitempty"`
	// contains filtered or unexported fields
}

func (*OverloadAction) ClearTypedConfig 

func (x *OverloadAction) ClearTypedConfig()

func (*OverloadAction) GetName 

func (x *OverloadAction) GetName() string

func (*OverloadAction) GetTriggers 

func (x *OverloadAction) GetTriggers() []*Trigger

func (*OverloadAction) GetTypedConfig 

func (x *OverloadAction) GetTypedConfig() *anypb.Any

func (*OverloadAction) HasTypedConfig 

func (x *OverloadAction) HasTypedConfig() bool

func (*OverloadAction) ProtoMessage 

func (*OverloadAction) ProtoMessage()

func (*OverloadAction) ProtoReflect 

func (x *OverloadAction) ProtoReflect() protoreflect.Message

func (*OverloadAction) Reset 

func (x *OverloadAction) Reset()

func (*OverloadAction) SetName 

func (x *OverloadAction) SetName(v string)

func (*OverloadAction) SetTriggers 

func (x *OverloadAction) SetTriggers(v []*Trigger)

func (*OverloadAction) SetTypedConfig 

func (x *OverloadAction) SetTypedConfig(v *anypb.Any)

func (*OverloadAction) String 

func (x *OverloadAction) String() string

type OverloadAction_builder 

type OverloadAction_builder struct {

	// The name of the overload action. This is just a well-known string that listeners can
	// use for registering callbacks. Custom overload actions should be named using reverse
	// DNS to ensure uniqueness.
	Name string
	// A set of triggers for this action. The state of the action is the maximum
	// state of all triggers, which can be scalar values between 0 and 1 or
	// saturated. Listeners are notified when the overload action changes state.
	// An overload manager action can only have one trigger for a given resource
	// e.g. :ref:`Trigger.name
	// <envoy_v3_api_field_config.overload.v3.Trigger.name>` must be unique
	// in this list.
	Triggers []*Trigger
	// Configuration for the action being instantiated.
	TypedConfig *anypb.Any
	// contains filtered or unexported fields
}

func (OverloadAction_builder) Build 

func (b0 OverloadAction_builder) Build() *OverloadAction

type OverloadManager 

type OverloadManager struct {

	// The interval for refreshing resource usage.
	RefreshInterval *durationpb.Duration `protobuf:"bytes,1,opt,name=refresh_interval,json=refreshInterval,proto3" json:"refresh_interval,omitempty"`
	// The set of resources to monitor.
	ResourceMonitors []*ResourceMonitor `protobuf:"bytes,2,rep,name=resource_monitors,json=resourceMonitors,proto3" json:"resource_monitors,omitempty"`
	// The set of overload actions.
	Actions []*OverloadAction `protobuf:"bytes,3,rep,name=actions,proto3" json:"actions,omitempty"`
	// The set of load shed points.
	LoadshedPoints []*LoadShedPoint `protobuf:"bytes,5,rep,name=loadshed_points,json=loadshedPoints,proto3" json:"loadshed_points,omitempty"`
	// Configuration for buffer factory.
	BufferFactoryConfig *BufferFactoryConfig `protobuf:"bytes,4,opt,name=buffer_factory_config,json=bufferFactoryConfig,proto3" json:"buffer_factory_config,omitempty"`
	// contains filtered or unexported fields
}

[#next-free-field: 6]

func (*OverloadManager) ClearBufferFactoryConfig 

func (x *OverloadManager) ClearBufferFactoryConfig()

func (*OverloadManager) ClearRefreshInterval 

func (x *OverloadManager) ClearRefreshInterval()

func (*OverloadManager) GetActions 

func (x *OverloadManager) GetActions() []*OverloadAction

func (*OverloadManager) GetBufferFactoryConfig 

func (x *OverloadManager) GetBufferFactoryConfig() *BufferFactoryConfig

func (*OverloadManager) GetLoadshedPoints 

func (x *OverloadManager) GetLoadshedPoints() []*LoadShedPoint

func (*OverloadManager) GetRefreshInterval 

func (x *OverloadManager) GetRefreshInterval() *durationpb.Duration

func (*OverloadManager) GetResourceMonitors 

func (x *OverloadManager) GetResourceMonitors() []*ResourceMonitor

func (*OverloadManager) HasBufferFactoryConfig 

func (x *OverloadManager) HasBufferFactoryConfig() bool

func (*OverloadManager) HasRefreshInterval 

func (x *OverloadManager) HasRefreshInterval() bool

func (*OverloadManager) ProtoMessage 

func (*OverloadManager) ProtoMessage()

func (*OverloadManager) ProtoReflect 

func (x *OverloadManager) ProtoReflect() protoreflect.Message

func (*OverloadManager) Reset 

func (x *OverloadManager) Reset()

func (*OverloadManager) SetActions 

func (x *OverloadManager) SetActions(v []*OverloadAction)

func (*OverloadManager) SetBufferFactoryConfig 

func (x *OverloadManager) SetBufferFactoryConfig(v *BufferFactoryConfig)

func (*OverloadManager) SetLoadshedPoints 

func (x *OverloadManager) SetLoadshedPoints(v []*LoadShedPoint)

func (*OverloadManager) SetRefreshInterval 

func (x *OverloadManager) SetRefreshInterval(v *durationpb.Duration)

func (*OverloadManager) SetResourceMonitors 

func (x *OverloadManager) SetResourceMonitors(v []*ResourceMonitor)

func (*OverloadManager) String 

func (x *OverloadManager) String() string

type OverloadManager_builder 

type OverloadManager_builder struct {

	// The interval for refreshing resource usage.
	RefreshInterval *durationpb.Duration
	// The set of resources to monitor.
	ResourceMonitors []*ResourceMonitor
	// The set of overload actions.
	Actions []*OverloadAction
	// The set of load shed points.
	LoadshedPoints []*LoadShedPoint
	// Configuration for buffer factory.
	BufferFactoryConfig *BufferFactoryConfig
	// contains filtered or unexported fields
}

func (OverloadManager_builder) Build 

func (b0 OverloadManager_builder) Build() *OverloadManager

type ResourceMonitor 

type ResourceMonitor struct {

	// The name of the resource monitor to instantiate. Must match a registered
	// resource monitor type.
	// See the :ref:`extensions listed in typed_config below <extension_category_envoy.resource_monitors>` for the default list of available resource monitor.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Configuration for the resource monitor being instantiated.
	// [#extension-category: envoy.resource_monitors]
	//
	// Types that are valid to be assigned to ConfigType:
	//
	//	*ResourceMonitor_TypedConfig
	ConfigType isResourceMonitor_ConfigType `protobuf_oneof:"config_type"`
	// contains filtered or unexported fields
}

func (*ResourceMonitor) ClearConfigType 

func (x *ResourceMonitor) ClearConfigType()

func (*ResourceMonitor) ClearTypedConfig 

func (x *ResourceMonitor) ClearTypedConfig()

func (*ResourceMonitor) GetConfigType 

func (x *ResourceMonitor) GetConfigType() isResourceMonitor_ConfigType

func (*ResourceMonitor) GetName 

func (x *ResourceMonitor) GetName() string

func (*ResourceMonitor) GetTypedConfig 

func (x *ResourceMonitor) GetTypedConfig() *anypb.Any

func (*ResourceMonitor) HasConfigType 

func (x *ResourceMonitor) HasConfigType() bool

func (*ResourceMonitor) HasTypedConfig 

func (x *ResourceMonitor) HasTypedConfig() bool

func (*ResourceMonitor) ProtoMessage 

func (*ResourceMonitor) ProtoMessage()

func (*ResourceMonitor) ProtoReflect 

func (x *ResourceMonitor) ProtoReflect() protoreflect.Message

func (*ResourceMonitor) Reset 

func (x *ResourceMonitor) Reset()

func (*ResourceMonitor) SetName 

func (x *ResourceMonitor) SetName(v string)

func (*ResourceMonitor) SetTypedConfig 

func (x *ResourceMonitor) SetTypedConfig(v *anypb.Any)

func (*ResourceMonitor) String 

func (x *ResourceMonitor) String() string

func (*ResourceMonitor) WhichConfigType 

func (x *ResourceMonitor) WhichConfigType() case_ResourceMonitor_ConfigType

type ResourceMonitor_TypedConfig 

type ResourceMonitor_TypedConfig struct {
	TypedConfig *anypb.Any `protobuf:"bytes,3,opt,name=typed_config,json=typedConfig,proto3,oneof"`
}

type ResourceMonitor_builder 

type ResourceMonitor_builder struct {

	// The name of the resource monitor to instantiate. Must match a registered
	// resource monitor type.
	// See the :ref:`extensions listed in typed_config below <extension_category_envoy.resource_monitors>` for the default list of available resource monitor.
	Name string

	// Fields of oneof ConfigType:
	TypedConfig *anypb.Any
	// contains filtered or unexported fields
}

func (ResourceMonitor_builder) Build 

func (b0 ResourceMonitor_builder) Build() *ResourceMonitor

type ScaleTimersOverloadActionConfig 

type ScaleTimersOverloadActionConfig struct {

	// A set of timer scaling rules to be applied.
	TimerScaleFactors []*ScaleTimersOverloadActionConfig_ScaleTimer `protobuf:"bytes,1,rep,name=timer_scale_factors,json=timerScaleFactors,proto3" json:"timer_scale_factors,omitempty"`
	// contains filtered or unexported fields
}

Typed configuration for the "envoy.overload_actions.reduce_timeouts" action. See :ref:`the docs <config_overload_manager_reducing_timeouts>` for an example of how to configure the action with different timeouts and minimum values.

func (*ScaleTimersOverloadActionConfig) GetTimerScaleFactors 

func (x *ScaleTimersOverloadActionConfig) GetTimerScaleFactors() []*ScaleTimersOverloadActionConfig_ScaleTimer

func (*ScaleTimersOverloadActionConfig) ProtoMessage 

func (*ScaleTimersOverloadActionConfig) ProtoMessage()

func (*ScaleTimersOverloadActionConfig) ProtoReflect 

func (x *ScaleTimersOverloadActionConfig) ProtoReflect() protoreflect.Message

func (*ScaleTimersOverloadActionConfig) Reset 

func (x *ScaleTimersOverloadActionConfig) Reset()

func (*ScaleTimersOverloadActionConfig) SetTimerScaleFactors 

func (x *ScaleTimersOverloadActionConfig) SetTimerScaleFactors(v []*ScaleTimersOverloadActionConfig_ScaleTimer)

func (*ScaleTimersOverloadActionConfig) String 

func (x *ScaleTimersOverloadActionConfig) String() string

type ScaleTimersOverloadActionConfig_ScaleTimer 

type ScaleTimersOverloadActionConfig_ScaleTimer struct {

	// The type of timer this minimum applies to.
	Timer ScaleTimersOverloadActionConfig_TimerType `` /* 136-byte string literal not displayed */
	// Types that are valid to be assigned to OverloadAdjust:
	//
	//	*ScaleTimersOverloadActionConfig_ScaleTimer_MinTimeout
	//	*ScaleTimersOverloadActionConfig_ScaleTimer_MinScale
	OverloadAdjust isScaleTimersOverloadActionConfig_ScaleTimer_OverloadAdjust `protobuf_oneof:"overload_adjust"`
	// contains filtered or unexported fields
}

func (*ScaleTimersOverloadActionConfig_ScaleTimer) ClearMinScale 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) ClearMinScale()

func (*ScaleTimersOverloadActionConfig_ScaleTimer) ClearMinTimeout 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) ClearMinTimeout()

func (*ScaleTimersOverloadActionConfig_ScaleTimer) ClearOverloadAdjust 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) ClearOverloadAdjust()

func (*ScaleTimersOverloadActionConfig_ScaleTimer) GetMinScale 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) GetMinScale() *v3.Percent

func (*ScaleTimersOverloadActionConfig_ScaleTimer) GetMinTimeout 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) GetMinTimeout() *durationpb.Duration

func (*ScaleTimersOverloadActionConfig_ScaleTimer) GetOverloadAdjust 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) GetOverloadAdjust() isScaleTimersOverloadActionConfig_ScaleTimer_OverloadAdjust

func (*ScaleTimersOverloadActionConfig_ScaleTimer) GetTimer 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) GetTimer() ScaleTimersOverloadActionConfig_TimerType

func (*ScaleTimersOverloadActionConfig_ScaleTimer) HasMinScale 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) HasMinScale() bool

func (*ScaleTimersOverloadActionConfig_ScaleTimer) HasMinTimeout 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) HasMinTimeout() bool

func (*ScaleTimersOverloadActionConfig_ScaleTimer) HasOverloadAdjust 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) HasOverloadAdjust() bool

func (*ScaleTimersOverloadActionConfig_ScaleTimer) ProtoMessage 

func (*ScaleTimersOverloadActionConfig_ScaleTimer) ProtoMessage()

func (*ScaleTimersOverloadActionConfig_ScaleTimer) ProtoReflect 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) ProtoReflect() protoreflect.Message

func (*ScaleTimersOverloadActionConfig_ScaleTimer) Reset 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) Reset()

func (*ScaleTimersOverloadActionConfig_ScaleTimer) SetMinScale 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) SetMinScale(v *v3.Percent)

func (*ScaleTimersOverloadActionConfig_ScaleTimer) SetMinTimeout 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) SetMinTimeout(v *durationpb.Duration)

func (*ScaleTimersOverloadActionConfig_ScaleTimer) SetTimer 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) SetTimer(v ScaleTimersOverloadActionConfig_TimerType)

func (*ScaleTimersOverloadActionConfig_ScaleTimer) String 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) String() string

func (*ScaleTimersOverloadActionConfig_ScaleTimer) WhichOverloadAdjust 

func (x *ScaleTimersOverloadActionConfig_ScaleTimer) WhichOverloadAdjust() case_ScaleTimersOverloadActionConfig_ScaleTimer_OverloadAdjust

type ScaleTimersOverloadActionConfig_ScaleTimer_MinScale 

type ScaleTimersOverloadActionConfig_ScaleTimer_MinScale struct {
	// Sets the minimum duration as a percentage of the maximum value.
	MinScale *v3.Percent `protobuf:"bytes,3,opt,name=min_scale,json=minScale,proto3,oneof"`
}

type ScaleTimersOverloadActionConfig_ScaleTimer_MinTimeout 

type ScaleTimersOverloadActionConfig_ScaleTimer_MinTimeout struct {
	// Sets the minimum duration as an absolute value.
	MinTimeout *durationpb.Duration `protobuf:"bytes,2,opt,name=min_timeout,json=minTimeout,proto3,oneof"`
}

type ScaleTimersOverloadActionConfig_ScaleTimer_builder 

type ScaleTimersOverloadActionConfig_ScaleTimer_builder struct {

	// The type of timer this minimum applies to.
	Timer ScaleTimersOverloadActionConfig_TimerType
	// Fields of oneof OverloadAdjust:
	// Sets the minimum duration as an absolute value.
	MinTimeout *durationpb.Duration
	// Sets the minimum duration as a percentage of the maximum value.
	MinScale *v3.Percent
	// contains filtered or unexported fields
}

func (ScaleTimersOverloadActionConfig_ScaleTimer_builder) Build 

func (b0 ScaleTimersOverloadActionConfig_ScaleTimer_builder) Build() *ScaleTimersOverloadActionConfig_ScaleTimer

type ScaleTimersOverloadActionConfig_TimerType 

type ScaleTimersOverloadActionConfig_TimerType int32
const (
	// Unsupported value; users must explicitly specify the timer they want scaled.
	ScaleTimersOverloadActionConfig_UNSPECIFIED ScaleTimersOverloadActionConfig_TimerType = 0
	// Adjusts the idle timer for downstream HTTP connections that takes effect when there are no active streams.
	// This affects the value of :ref:`HttpConnectionManager.common_http_protocol_options.idle_timeout
	// <envoy_v3_api_field_config.core.v3.HttpProtocolOptions.idle_timeout>`
	ScaleTimersOverloadActionConfig_HTTP_DOWNSTREAM_CONNECTION_IDLE ScaleTimersOverloadActionConfig_TimerType = 1
	// Adjusts the idle timer for HTTP streams initiated by downstream clients.
	// This affects the value of :ref:`RouteAction.idle_timeout <envoy_v3_api_field_config.route.v3.RouteAction.idle_timeout>` and
	// :ref:`HttpConnectionManager.stream_idle_timeout
	// <envoy_v3_api_field_extensions.filters.network.http_connection_manager.v3.HttpConnectionManager.stream_idle_timeout>`
	ScaleTimersOverloadActionConfig_HTTP_DOWNSTREAM_STREAM_IDLE ScaleTimersOverloadActionConfig_TimerType = 2
	// Adjusts the timer for how long downstream clients have to finish transport-level negotiations
	// before the connection is closed.
	// This affects the value of
	// :ref:`FilterChain.transport_socket_connect_timeout <envoy_v3_api_field_config.listener.v3.FilterChain.transport_socket_connect_timeout>`.
	ScaleTimersOverloadActionConfig_TRANSPORT_SOCKET_CONNECT ScaleTimersOverloadActionConfig_TimerType = 3
)

func (ScaleTimersOverloadActionConfig_TimerType) Descriptor 

func (ScaleTimersOverloadActionConfig_TimerType) Descriptor() protoreflect.EnumDescriptor

func (ScaleTimersOverloadActionConfig_TimerType) Enum 

func (x ScaleTimersOverloadActionConfig_TimerType) Enum() *ScaleTimersOverloadActionConfig_TimerType

func (ScaleTimersOverloadActionConfig_TimerType) Number 

func (x ScaleTimersOverloadActionConfig_TimerType) Number() protoreflect.EnumNumber

func (ScaleTimersOverloadActionConfig_TimerType) String 

func (x ScaleTimersOverloadActionConfig_TimerType) String() string

func (ScaleTimersOverloadActionConfig_TimerType) Type 

func (ScaleTimersOverloadActionConfig_TimerType) Type() protoreflect.EnumType

type ScaleTimersOverloadActionConfig_builder 

type ScaleTimersOverloadActionConfig_builder struct {

	// A set of timer scaling rules to be applied.
	TimerScaleFactors []*ScaleTimersOverloadActionConfig_ScaleTimer
	// contains filtered or unexported fields
}

func (ScaleTimersOverloadActionConfig_builder) Build 

func (b0 ScaleTimersOverloadActionConfig_builder) Build() *ScaleTimersOverloadActionConfig

type ScaledTrigger 

type ScaledTrigger struct {

	// If the resource pressure is greater than this value, the trigger will be in the
	// :ref:`scaling <arch_overview_overload_manager-triggers-state>` state with value
	// “(pressure - scaling_threshold) / (saturation_threshold - scaling_threshold)“.
	ScalingThreshold float64 `protobuf:"fixed64,1,opt,name=scaling_threshold,json=scalingThreshold,proto3" json:"scaling_threshold,omitempty"`
	// If the resource pressure is greater than this value, the trigger will enter saturation.
	SaturationThreshold float64 `protobuf:"fixed64,2,opt,name=saturation_threshold,json=saturationThreshold,proto3" json:"saturation_threshold,omitempty"`
	// contains filtered or unexported fields
}

func (*ScaledTrigger) GetSaturationThreshold 

func (x *ScaledTrigger) GetSaturationThreshold() float64

func (*ScaledTrigger) GetScalingThreshold 

func (x *ScaledTrigger) GetScalingThreshold() float64

func (*ScaledTrigger) ProtoMessage 

func (*ScaledTrigger) ProtoMessage()

func (*ScaledTrigger) ProtoReflect 

func (x *ScaledTrigger) ProtoReflect() protoreflect.Message

func (*ScaledTrigger) Reset 

func (x *ScaledTrigger) Reset()

func (*ScaledTrigger) SetSaturationThreshold 

func (x *ScaledTrigger) SetSaturationThreshold(v float64)

func (*ScaledTrigger) SetScalingThreshold 

func (x *ScaledTrigger) SetScalingThreshold(v float64)

func (*ScaledTrigger) String 

func (x *ScaledTrigger) String() string

type ScaledTrigger_builder 

type ScaledTrigger_builder struct {

	// If the resource pressure is greater than this value, the trigger will be in the
	// :ref:`scaling <arch_overview_overload_manager-triggers-state>` state with value
	// “(pressure - scaling_threshold) / (saturation_threshold - scaling_threshold)“.
	ScalingThreshold float64
	// If the resource pressure is greater than this value, the trigger will enter saturation.
	SaturationThreshold float64
	// contains filtered or unexported fields
}

func (ScaledTrigger_builder) Build 

func (b0 ScaledTrigger_builder) Build() *ScaledTrigger

type ThresholdTrigger 

type ThresholdTrigger struct {

	// If the resource pressure is greater than or equal to this value, the trigger
	// will enter saturation.
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ThresholdTrigger) GetValue 

func (x *ThresholdTrigger) GetValue() float64

func (*ThresholdTrigger) ProtoMessage 

func (*ThresholdTrigger) ProtoMessage()

func (*ThresholdTrigger) ProtoReflect 

func (x *ThresholdTrigger) ProtoReflect() protoreflect.Message

func (*ThresholdTrigger) Reset 

func (x *ThresholdTrigger) Reset()

func (*ThresholdTrigger) SetValue 

func (x *ThresholdTrigger) SetValue(v float64)

func (*ThresholdTrigger) String 

func (x *ThresholdTrigger) String() string

type ThresholdTrigger_builder 

type ThresholdTrigger_builder struct {

	// If the resource pressure is greater than or equal to this value, the trigger
	// will enter saturation.
	Value float64
	// contains filtered or unexported fields
}

func (ThresholdTrigger_builder) Build 

func (b0 ThresholdTrigger_builder) Build() *ThresholdTrigger

type Trigger 

type Trigger struct {

	// The name of the resource this is a trigger for.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to TriggerOneof:
	//
	//	*Trigger_Threshold
	//	*Trigger_Scaled
	TriggerOneof isTrigger_TriggerOneof `protobuf_oneof:"trigger_oneof"`
	// contains filtered or unexported fields
}

func (*Trigger) ClearScaled 

func (x *Trigger) ClearScaled()

func (*Trigger) ClearThreshold 

func (x *Trigger) ClearThreshold()

func (*Trigger) ClearTriggerOneof 

func (x *Trigger) ClearTriggerOneof()

func (*Trigger) GetName 

func (x *Trigger) GetName() string

func (*Trigger) GetScaled 

func (x *Trigger) GetScaled() *ScaledTrigger

func (*Trigger) GetThreshold 

func (x *Trigger) GetThreshold() *ThresholdTrigger

func (*Trigger) GetTriggerOneof 

func (x *Trigger) GetTriggerOneof() isTrigger_TriggerOneof

func (*Trigger) HasScaled 

func (x *Trigger) HasScaled() bool

func (*Trigger) HasThreshold 

func (x *Trigger) HasThreshold() bool

func (*Trigger) HasTriggerOneof 

func (x *Trigger) HasTriggerOneof() bool

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect 

func (x *Trigger) ProtoReflect() protoreflect.Message

func (*Trigger) Reset 

func (x *Trigger) Reset()

func (*Trigger) SetName 

func (x *Trigger) SetName(v string)

func (*Trigger) SetScaled 

func (x *Trigger) SetScaled(v *ScaledTrigger)

func (*Trigger) SetThreshold 

func (x *Trigger) SetThreshold(v *ThresholdTrigger)

func (*Trigger) String 

func (x *Trigger) String() string

func (*Trigger) WhichTriggerOneof 

func (x *Trigger) WhichTriggerOneof() case_Trigger_TriggerOneof

type Trigger_Scaled 

type Trigger_Scaled struct {
	Scaled *ScaledTrigger `protobuf:"bytes,3,opt,name=scaled,proto3,oneof"`
}

type Trigger_Threshold 

type Trigger_Threshold struct {
	Threshold *ThresholdTrigger `protobuf:"bytes,2,opt,name=threshold,proto3,oneof"`
}

type Trigger_builder 

type Trigger_builder struct {

	// The name of the resource this is a trigger for.
	Name string
	// Fields of oneof TriggerOneof:
	Threshold *ThresholdTrigger
	Scaled    *ScaledTrigger
	// contains filtered or unexported fields
}

func (Trigger_builder) Build 

func (b0 Trigger_builder) Build() *Trigger

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.