clusterv2alpha

package
v1.36.3-20231010202158... Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const OutlierDetectionEvent_EjectConsecutiveEvent_case case_OutlierDetectionEvent_Event = 10
View Source 
const OutlierDetectionEvent_EjectFailurePercentageEvent_case case_OutlierDetectionEvent_Event = 11
View Source 
const OutlierDetectionEvent_EjectSuccessRateEvent_case case_OutlierDetectionEvent_Event = 9
View Source 
const OutlierDetectionEvent_Event_not_set_case case_OutlierDetectionEvent_Event = 0

Variables

View Source 
var (
	OutlierEjectionType_name = map[int32]string{
		0: "CONSECUTIVE_5XX",
		1: "CONSECUTIVE_GATEWAY_FAILURE",
		2: "SUCCESS_RATE",
		3: "CONSECUTIVE_LOCAL_ORIGIN_FAILURE",
		4: "SUCCESS_RATE_LOCAL_ORIGIN",
		5: "FAILURE_PERCENTAGE",
		6: "FAILURE_PERCENTAGE_LOCAL_ORIGIN",
	}
	OutlierEjectionType_value = map[string]int32{
		"CONSECUTIVE_5XX":                  0,
		"CONSECUTIVE_GATEWAY_FAILURE":      1,
		"SUCCESS_RATE":                     2,
		"CONSECUTIVE_LOCAL_ORIGIN_FAILURE": 3,
		"SUCCESS_RATE_LOCAL_ORIGIN":        4,
		"FAILURE_PERCENTAGE":               5,
		"FAILURE_PERCENTAGE_LOCAL_ORIGIN":  6,
	}
)

Enum value maps for OutlierEjectionType.

View Source 
var (
	Action_name = map[int32]string{
		0: "EJECT",
		1: "UNEJECT",
	}
	Action_value = map[string]int32{
		"EJECT":   0,
		"UNEJECT": 1,
	}
)

Enum value maps for Action.

View Source 
var File_envoy_data_cluster_v2alpha_outlier_detection_event_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Action 

type Action int32

Represents possible action applied to upstream host 

const (
	// In case host was excluded from service
	Action_EJECT Action = 0
	// In case host was brought back into service
	Action_UNEJECT Action = 1
)

func (Action) Descriptor 

func (Action) Descriptor() protoreflect.EnumDescriptor

func (Action) Enum 

func (x Action) Enum() *Action

func (Action) Number 

func (x Action) Number() protoreflect.EnumNumber

func (Action) String 

func (x Action) String() string

func (Action) Type 

func (Action) Type() protoreflect.EnumType

type OutlierDetectionEvent 

type OutlierDetectionEvent struct {

	// In case of eject represents type of ejection that took place.
	Type OutlierEjectionType `protobuf:"varint,1,opt,name=type,proto3,enum=envoy.data.cluster.v2alpha.OutlierEjectionType" json:"type,omitempty"`
	// Timestamp for event.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The time in seconds since the last action (either an ejection or unejection) took place.
	SecsSinceLastAction *wrapperspb.UInt64Value `protobuf:"bytes,3,opt,name=secs_since_last_action,json=secsSinceLastAction,proto3" json:"secs_since_last_action,omitempty"`
	// The :ref:`cluster <envoy_api_msg_Cluster>` that owns the ejected host.
	ClusterName string `protobuf:"bytes,4,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// The URL of the ejected host. E.g., “tcp://1.2.3.4:80“.
	UpstreamUrl string `protobuf:"bytes,5,opt,name=upstream_url,json=upstreamUrl,proto3" json:"upstream_url,omitempty"`
	// The action that took place.
	Action Action `protobuf:"varint,6,opt,name=action,proto3,enum=envoy.data.cluster.v2alpha.Action" json:"action,omitempty"`
	// If “action“ is “eject“, specifies the number of times the host has been ejected (local to
	// that Envoy and gets reset if the host gets removed from the upstream cluster for any reason and
	// then re-added).
	NumEjections uint32 `protobuf:"varint,7,opt,name=num_ejections,json=numEjections,proto3" json:"num_ejections,omitempty"`
	// If “action“ is “eject“, specifies if the ejection was enforced. “true“ means the host was
	// ejected. “false“ means the event was logged but the host was not actually ejected.
	Enforced bool `protobuf:"varint,8,opt,name=enforced,proto3" json:"enforced,omitempty"`
	// Types that are valid to be assigned to Event:
	//
	//	*OutlierDetectionEvent_EjectSuccessRateEvent
	//	*OutlierDetectionEvent_EjectConsecutiveEvent
	//	*OutlierDetectionEvent_EjectFailurePercentageEvent
	Event isOutlierDetectionEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

[#next-free-field: 12]

func (*OutlierDetectionEvent) ClearEjectConsecutiveEvent 

func (x *OutlierDetectionEvent) ClearEjectConsecutiveEvent()

func (*OutlierDetectionEvent) ClearEjectFailurePercentageEvent 

func (x *OutlierDetectionEvent) ClearEjectFailurePercentageEvent()

func (*OutlierDetectionEvent) ClearEjectSuccessRateEvent 

func (x *OutlierDetectionEvent) ClearEjectSuccessRateEvent()

func (*OutlierDetectionEvent) ClearEvent 

func (x *OutlierDetectionEvent) ClearEvent()

func (*OutlierDetectionEvent) ClearSecsSinceLastAction 

func (x *OutlierDetectionEvent) ClearSecsSinceLastAction()

func (*OutlierDetectionEvent) ClearTimestamp 

func (x *OutlierDetectionEvent) ClearTimestamp()

func (*OutlierDetectionEvent) GetAction 

func (x *OutlierDetectionEvent) GetAction() Action

func (*OutlierDetectionEvent) GetClusterName 

func (x *OutlierDetectionEvent) GetClusterName() string

func (*OutlierDetectionEvent) GetEjectConsecutiveEvent 

func (x *OutlierDetectionEvent) GetEjectConsecutiveEvent() *OutlierEjectConsecutive

func (*OutlierDetectionEvent) GetEjectFailurePercentageEvent 

func (x *OutlierDetectionEvent) GetEjectFailurePercentageEvent() *OutlierEjectFailurePercentage

func (*OutlierDetectionEvent) GetEjectSuccessRateEvent 

func (x *OutlierDetectionEvent) GetEjectSuccessRateEvent() *OutlierEjectSuccessRate

func (*OutlierDetectionEvent) GetEnforced 

func (x *OutlierDetectionEvent) GetEnforced() bool

func (*OutlierDetectionEvent) GetEvent 

func (x *OutlierDetectionEvent) GetEvent() isOutlierDetectionEvent_Event

func (*OutlierDetectionEvent) GetNumEjections 

func (x *OutlierDetectionEvent) GetNumEjections() uint32

func (*OutlierDetectionEvent) GetSecsSinceLastAction 

func (x *OutlierDetectionEvent) GetSecsSinceLastAction() *wrapperspb.UInt64Value

func (*OutlierDetectionEvent) GetTimestamp 

func (x *OutlierDetectionEvent) GetTimestamp() *timestamppb.Timestamp

func (*OutlierDetectionEvent) GetType 

func (x *OutlierDetectionEvent) GetType() OutlierEjectionType

func (*OutlierDetectionEvent) GetUpstreamUrl 

func (x *OutlierDetectionEvent) GetUpstreamUrl() string

func (*OutlierDetectionEvent) HasEjectConsecutiveEvent 

func (x *OutlierDetectionEvent) HasEjectConsecutiveEvent() bool

func (*OutlierDetectionEvent) HasEjectFailurePercentageEvent 

func (x *OutlierDetectionEvent) HasEjectFailurePercentageEvent() bool

func (*OutlierDetectionEvent) HasEjectSuccessRateEvent 

func (x *OutlierDetectionEvent) HasEjectSuccessRateEvent() bool

func (*OutlierDetectionEvent) HasEvent 

func (x *OutlierDetectionEvent) HasEvent() bool

func (*OutlierDetectionEvent) HasSecsSinceLastAction 

func (x *OutlierDetectionEvent) HasSecsSinceLastAction() bool

func (*OutlierDetectionEvent) HasTimestamp 

func (x *OutlierDetectionEvent) HasTimestamp() bool

func (*OutlierDetectionEvent) ProtoMessage 

func (*OutlierDetectionEvent) ProtoMessage()

func (*OutlierDetectionEvent) ProtoReflect 

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

func (*OutlierDetectionEvent) Reset 

func (x *OutlierDetectionEvent) Reset()

func (*OutlierDetectionEvent) SetAction 

func (x *OutlierDetectionEvent) SetAction(v Action)

func (*OutlierDetectionEvent) SetClusterName 

func (x *OutlierDetectionEvent) SetClusterName(v string)

func (*OutlierDetectionEvent) SetEjectConsecutiveEvent 

func (x *OutlierDetectionEvent) SetEjectConsecutiveEvent(v *OutlierEjectConsecutive)

func (*OutlierDetectionEvent) SetEjectFailurePercentageEvent 

func (x *OutlierDetectionEvent) SetEjectFailurePercentageEvent(v *OutlierEjectFailurePercentage)

func (*OutlierDetectionEvent) SetEjectSuccessRateEvent 

func (x *OutlierDetectionEvent) SetEjectSuccessRateEvent(v *OutlierEjectSuccessRate)

func (*OutlierDetectionEvent) SetEnforced 

func (x *OutlierDetectionEvent) SetEnforced(v bool)

func (*OutlierDetectionEvent) SetNumEjections 

func (x *OutlierDetectionEvent) SetNumEjections(v uint32)

func (*OutlierDetectionEvent) SetSecsSinceLastAction 

func (x *OutlierDetectionEvent) SetSecsSinceLastAction(v *wrapperspb.UInt64Value)

func (*OutlierDetectionEvent) SetTimestamp 

func (x *OutlierDetectionEvent) SetTimestamp(v *timestamppb.Timestamp)

func (*OutlierDetectionEvent) SetType 

func (x *OutlierDetectionEvent) SetType(v OutlierEjectionType)

func (*OutlierDetectionEvent) SetUpstreamUrl 

func (x *OutlierDetectionEvent) SetUpstreamUrl(v string)

func (*OutlierDetectionEvent) String 

func (x *OutlierDetectionEvent) String() string

func (*OutlierDetectionEvent) WhichEvent 

func (x *OutlierDetectionEvent) WhichEvent() case_OutlierDetectionEvent_Event

type OutlierDetectionEvent_EjectConsecutiveEvent 

type OutlierDetectionEvent_EjectConsecutiveEvent struct {
	EjectConsecutiveEvent *OutlierEjectConsecutive `protobuf:"bytes,10,opt,name=eject_consecutive_event,json=ejectConsecutiveEvent,proto3,oneof"`
}

type OutlierDetectionEvent_EjectFailurePercentageEvent 

type OutlierDetectionEvent_EjectFailurePercentageEvent struct {
	EjectFailurePercentageEvent *OutlierEjectFailurePercentage `protobuf:"bytes,11,opt,name=eject_failure_percentage_event,json=ejectFailurePercentageEvent,proto3,oneof"`
}

type OutlierDetectionEvent_EjectSuccessRateEvent 

type OutlierDetectionEvent_EjectSuccessRateEvent struct {
	EjectSuccessRateEvent *OutlierEjectSuccessRate `protobuf:"bytes,9,opt,name=eject_success_rate_event,json=ejectSuccessRateEvent,proto3,oneof"`
}

type OutlierDetectionEvent_builder 

type OutlierDetectionEvent_builder struct {

	// In case of eject represents type of ejection that took place.
	Type OutlierEjectionType
	// Timestamp for event.
	Timestamp *timestamppb.Timestamp
	// The time in seconds since the last action (either an ejection or unejection) took place.
	SecsSinceLastAction *wrapperspb.UInt64Value
	// The :ref:`cluster <envoy_api_msg_Cluster>` that owns the ejected host.
	ClusterName string
	// The URL of the ejected host. E.g., “tcp://1.2.3.4:80“.
	UpstreamUrl string
	// The action that took place.
	Action Action
	// If “action“ is “eject“, specifies the number of times the host has been ejected (local to
	// that Envoy and gets reset if the host gets removed from the upstream cluster for any reason and
	// then re-added).
	NumEjections uint32
	// If “action“ is “eject“, specifies if the ejection was enforced. “true“ means the host was
	// ejected. “false“ means the event was logged but the host was not actually ejected.
	Enforced bool
	// Fields of oneof Event:
	EjectSuccessRateEvent       *OutlierEjectSuccessRate
	EjectConsecutiveEvent       *OutlierEjectConsecutive
	EjectFailurePercentageEvent *OutlierEjectFailurePercentage
	// contains filtered or unexported fields
}

func (OutlierDetectionEvent_builder) Build 

func (b0 OutlierDetectionEvent_builder) Build() *OutlierDetectionEvent

type OutlierEjectConsecutive 

type OutlierEjectConsecutive struct {
	// contains filtered or unexported fields
}

func (*OutlierEjectConsecutive) ProtoMessage 

func (*OutlierEjectConsecutive) ProtoMessage()

func (*OutlierEjectConsecutive) ProtoReflect 

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

func (*OutlierEjectConsecutive) Reset 

func (x *OutlierEjectConsecutive) Reset()

func (*OutlierEjectConsecutive) String 

func (x *OutlierEjectConsecutive) String() string

type OutlierEjectConsecutive_builder 

type OutlierEjectConsecutive_builder struct {
	// contains filtered or unexported fields
}

func (OutlierEjectConsecutive_builder) Build 

func (b0 OutlierEjectConsecutive_builder) Build() *OutlierEjectConsecutive

type OutlierEjectFailurePercentage 

type OutlierEjectFailurePercentage struct {

	// Host's success rate at the time of the ejection event on a 0-100 range.
	HostSuccessRate uint32 `protobuf:"varint,1,opt,name=host_success_rate,json=hostSuccessRate,proto3" json:"host_success_rate,omitempty"`
	// contains filtered or unexported fields
}

func (*OutlierEjectFailurePercentage) GetHostSuccessRate 

func (x *OutlierEjectFailurePercentage) GetHostSuccessRate() uint32

func (*OutlierEjectFailurePercentage) ProtoMessage 

func (*OutlierEjectFailurePercentage) ProtoMessage()

func (*OutlierEjectFailurePercentage) ProtoReflect 

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

func (*OutlierEjectFailurePercentage) Reset 

func (x *OutlierEjectFailurePercentage) Reset()

func (*OutlierEjectFailurePercentage) SetHostSuccessRate 

func (x *OutlierEjectFailurePercentage) SetHostSuccessRate(v uint32)

func (*OutlierEjectFailurePercentage) String 

func (x *OutlierEjectFailurePercentage) String() string

type OutlierEjectFailurePercentage_builder 

type OutlierEjectFailurePercentage_builder struct {

	// Host's success rate at the time of the ejection event on a 0-100 range.
	HostSuccessRate uint32
	// contains filtered or unexported fields
}

func (OutlierEjectFailurePercentage_builder) Build 

func (b0 OutlierEjectFailurePercentage_builder) Build() *OutlierEjectFailurePercentage

type OutlierEjectSuccessRate 

type OutlierEjectSuccessRate struct {

	// Host’s success rate at the time of the ejection event on a 0-100 range.
	HostSuccessRate uint32 `protobuf:"varint,1,opt,name=host_success_rate,json=hostSuccessRate,proto3" json:"host_success_rate,omitempty"`
	// Average success rate of the hosts in the cluster at the time of the ejection event on a 0-100
	// range.
	ClusterAverageSuccessRate uint32 `` /* 141-byte string literal not displayed */
	// Success rate ejection threshold at the time of the ejection event.
	ClusterSuccessRateEjectionThreshold uint32 `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OutlierEjectSuccessRate) GetClusterAverageSuccessRate 

func (x *OutlierEjectSuccessRate) GetClusterAverageSuccessRate() uint32

func (*OutlierEjectSuccessRate) GetClusterSuccessRateEjectionThreshold 

func (x *OutlierEjectSuccessRate) GetClusterSuccessRateEjectionThreshold() uint32

func (*OutlierEjectSuccessRate) GetHostSuccessRate 

func (x *OutlierEjectSuccessRate) GetHostSuccessRate() uint32

func (*OutlierEjectSuccessRate) ProtoMessage 

func (*OutlierEjectSuccessRate) ProtoMessage()

func (*OutlierEjectSuccessRate) ProtoReflect 

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

func (*OutlierEjectSuccessRate) Reset 

func (x *OutlierEjectSuccessRate) Reset()

func (*OutlierEjectSuccessRate) SetClusterAverageSuccessRate 

func (x *OutlierEjectSuccessRate) SetClusterAverageSuccessRate(v uint32)

func (*OutlierEjectSuccessRate) SetClusterSuccessRateEjectionThreshold 

func (x *OutlierEjectSuccessRate) SetClusterSuccessRateEjectionThreshold(v uint32)

func (*OutlierEjectSuccessRate) SetHostSuccessRate 

func (x *OutlierEjectSuccessRate) SetHostSuccessRate(v uint32)

func (*OutlierEjectSuccessRate) String 

func (x *OutlierEjectSuccessRate) String() string

type OutlierEjectSuccessRate_builder 

type OutlierEjectSuccessRate_builder struct {

	// Host’s success rate at the time of the ejection event on a 0-100 range.
	HostSuccessRate uint32
	// Average success rate of the hosts in the cluster at the time of the ejection event on a 0-100
	// range.
	ClusterAverageSuccessRate uint32
	// Success rate ejection threshold at the time of the ejection event.
	ClusterSuccessRateEjectionThreshold uint32
	// contains filtered or unexported fields
}

func (OutlierEjectSuccessRate_builder) Build 

func (b0 OutlierEjectSuccessRate_builder) Build() *OutlierEjectSuccessRate

type OutlierEjectionType 

type OutlierEjectionType int32

Type of ejection that took place 

const (
	// In case upstream host returns certain number of consecutive 5xx.
	// If
	// :ref:`outlier_detection.split_external_local_origin_errors<envoy_api_field_cluster.OutlierDetection.split_external_local_origin_errors>`
	// is *false*, all type of errors are treated as HTTP 5xx errors.
	// See :ref:`Cluster outlier detection <arch_overview_outlier_detection>` documentation for
	// details.
	OutlierEjectionType_CONSECUTIVE_5XX OutlierEjectionType = 0
	// In case upstream host returns certain number of consecutive gateway errors
	OutlierEjectionType_CONSECUTIVE_GATEWAY_FAILURE OutlierEjectionType = 1
	// Runs over aggregated success rate statistics from every host in cluster
	// and selects hosts for which ratio of successful replies deviates from other hosts
	// in the cluster.
	// If
	// :ref:`outlier_detection.split_external_local_origin_errors<envoy_api_field_cluster.OutlierDetection.split_external_local_origin_errors>`
	// is *false*, all errors (externally and locally generated) are used to calculate success rate
	// statistics. See :ref:`Cluster outlier detection <arch_overview_outlier_detection>`
	// documentation for details.
	OutlierEjectionType_SUCCESS_RATE OutlierEjectionType = 2
	// Consecutive local origin failures: Connection failures, resets, timeouts, etc
	// This type of ejection happens only when
	// :ref:`outlier_detection.split_external_local_origin_errors<envoy_api_field_cluster.OutlierDetection.split_external_local_origin_errors>`
	// is set to *true*.
	// See :ref:`Cluster outlier detection <arch_overview_outlier_detection>` documentation for
	OutlierEjectionType_CONSECUTIVE_LOCAL_ORIGIN_FAILURE OutlierEjectionType = 3
	// Runs over aggregated success rate statistics for local origin failures
	// for all hosts in the cluster and selects hosts for which success rate deviates from other
	// hosts in the cluster. This type of ejection happens only when
	// :ref:`outlier_detection.split_external_local_origin_errors<envoy_api_field_cluster.OutlierDetection.split_external_local_origin_errors>`
	// is set to *true*.
	// See :ref:`Cluster outlier detection <arch_overview_outlier_detection>` documentation for
	OutlierEjectionType_SUCCESS_RATE_LOCAL_ORIGIN OutlierEjectionType = 4
	// Runs over aggregated success rate statistics from every host in cluster and selects hosts for
	// which ratio of failed replies is above configured value.
	OutlierEjectionType_FAILURE_PERCENTAGE OutlierEjectionType = 5
	// Runs over aggregated success rate statistics for local origin failures from every host in
	// cluster and selects hosts for which ratio of failed replies is above configured value.
	OutlierEjectionType_FAILURE_PERCENTAGE_LOCAL_ORIGIN OutlierEjectionType = 6
)

func (OutlierEjectionType) Descriptor 

func (OutlierEjectionType) Descriptor() protoreflect.EnumDescriptor

func (OutlierEjectionType) Enum 

func (x OutlierEjectionType) Enum() *OutlierEjectionType

func (OutlierEjectionType) Number 

func (x OutlierEjectionType) Number() protoreflect.EnumNumber

func (OutlierEjectionType) String 

func (x OutlierEjectionType) String() string

func (OutlierEjectionType) Type 

func (OutlierEjectionType) Type() protoreflect.EnumType

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.