envoy_data_cluster_v2alpha

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: May 10, 2019 License: Apache-2.0 Imports: 16 Imported by: 11

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthOutlierDetectionEvent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOutlierDetectionEvent   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Action_name = map[int32]string{
	0: "EJECT",
	1: "UNEJECT",
}
View Source 
var Action_value = map[string]int32{
	"EJECT":   0,
	"UNEJECT": 1,
}
View Source 
var OutlierEjectionType_name = map[int32]string{
	0: "CONSECUTIVE_5XX",
	1: "CONSECUTIVE_GATEWAY_FAILURE",
	2: "SUCCESS_RATE",
}
View Source 
var OutlierEjectionType_value = map[string]int32{
	"CONSECUTIVE_5XX":             0,
	"CONSECUTIVE_GATEWAY_FAILURE": 1,
	"SUCCESS_RATE":                2,
}

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) EnumDescriptor 

func (Action) EnumDescriptor() ([]byte, []int)

func (Action) String 

func (x Action) String() string

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 *time.Time `protobuf:"bytes,2,opt,name=timestamp,proto3,stdtime" json:"timestamp,omitempty"`
	// The time in seconds since the last action (either an ejection or unejection) took place.
	SecsSinceLastAction *types.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
	Event                isOutlierDetectionEvent_Event `protobuf_oneof:"event"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*OutlierDetectionEvent) Descriptor 

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

func (*OutlierDetectionEvent) Equal 

func (this *OutlierDetectionEvent) Equal(that interface{}) bool

func (*OutlierDetectionEvent) GetAction 

func (m *OutlierDetectionEvent) GetAction() Action

func (*OutlierDetectionEvent) GetClusterName 

func (m *OutlierDetectionEvent) GetClusterName() string

func (*OutlierDetectionEvent) GetEjectConsecutiveEvent 

func (m *OutlierDetectionEvent) GetEjectConsecutiveEvent() *OutlierEjectConsecutive

func (*OutlierDetectionEvent) GetEjectSuccessRateEvent 

func (m *OutlierDetectionEvent) GetEjectSuccessRateEvent() *OutlierEjectSuccessRate

func (*OutlierDetectionEvent) GetEnforced 

func (m *OutlierDetectionEvent) GetEnforced() bool

func (*OutlierDetectionEvent) GetEvent 

func (m *OutlierDetectionEvent) GetEvent() isOutlierDetectionEvent_Event

func (*OutlierDetectionEvent) GetNumEjections 

func (m *OutlierDetectionEvent) GetNumEjections() uint32

func (*OutlierDetectionEvent) GetSecsSinceLastAction 

func (m *OutlierDetectionEvent) GetSecsSinceLastAction() *types.UInt64Value

func (*OutlierDetectionEvent) GetTimestamp 

func (m *OutlierDetectionEvent) GetTimestamp() *time.Time

func (*OutlierDetectionEvent) GetType 

func (m *OutlierDetectionEvent) GetType() OutlierEjectionType

func (*OutlierDetectionEvent) GetUpstreamUrl 

func (m *OutlierDetectionEvent) GetUpstreamUrl() string

func (*OutlierDetectionEvent) Marshal 

func (m *OutlierDetectionEvent) Marshal() (dAtA []byte, err error)

func (*OutlierDetectionEvent) MarshalTo 

func (m *OutlierDetectionEvent) MarshalTo(dAtA []byte) (int, error)

func (*OutlierDetectionEvent) ProtoMessage 

func (*OutlierDetectionEvent) ProtoMessage()

func (*OutlierDetectionEvent) Reset 

func (m *OutlierDetectionEvent) Reset()

func (*OutlierDetectionEvent) Size 

func (m *OutlierDetectionEvent) Size() (n int)

func (*OutlierDetectionEvent) String 

func (m *OutlierDetectionEvent) String() string

func (*OutlierDetectionEvent) Unmarshal 

func (m *OutlierDetectionEvent) Unmarshal(dAtA []byte) error

func (*OutlierDetectionEvent) Validate 

func (m *OutlierDetectionEvent) Validate() error

Validate checks the field values on OutlierDetectionEvent with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*OutlierDetectionEvent) XXX_DiscardUnknown 

func (m *OutlierDetectionEvent) XXX_DiscardUnknown()

func (*OutlierDetectionEvent) XXX_Marshal 

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

func (*OutlierDetectionEvent) XXX_Merge 

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

func (*OutlierDetectionEvent) XXX_OneofFuncs 

func (*OutlierDetectionEvent) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*OutlierDetectionEvent) XXX_Size 

func (m *OutlierDetectionEvent) XXX_Size() int

func (*OutlierDetectionEvent) XXX_Unmarshal 

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

type OutlierDetectionEventValidationError 

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

OutlierDetectionEventValidationError is the validation error returned by OutlierDetectionEvent.Validate if the designated constraints aren't met.

func (OutlierDetectionEventValidationError) Cause 

func (e OutlierDetectionEventValidationError) Cause() error

Cause function returns cause value.

func (OutlierDetectionEventValidationError) Error 

func (e OutlierDetectionEventValidationError) Error() string

Error satisfies the builtin error interface

func (OutlierDetectionEventValidationError) ErrorName added in v0.7.0 

func (e OutlierDetectionEventValidationError) ErrorName() string

ErrorName returns error name.

func (OutlierDetectionEventValidationError) Field 

func (e OutlierDetectionEventValidationError) Field() string

Field function returns field value.

func (OutlierDetectionEventValidationError) Key 

func (e OutlierDetectionEventValidationError) Key() bool

Key function returns key value.

func (OutlierDetectionEventValidationError) Reason 

func (e OutlierDetectionEventValidationError) Reason() string

Reason function returns reason value.

type OutlierDetectionEvent_EjectConsecutiveEvent 

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

func (*OutlierDetectionEvent_EjectConsecutiveEvent) Equal 

func (this *OutlierDetectionEvent_EjectConsecutiveEvent) Equal(that interface{}) bool

func (*OutlierDetectionEvent_EjectConsecutiveEvent) MarshalTo 

func (m *OutlierDetectionEvent_EjectConsecutiveEvent) MarshalTo(dAtA []byte) (int, error)

func (*OutlierDetectionEvent_EjectConsecutiveEvent) Size 

func (m *OutlierDetectionEvent_EjectConsecutiveEvent) Size() (n int)

type OutlierDetectionEvent_EjectSuccessRateEvent 

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

func (*OutlierDetectionEvent_EjectSuccessRateEvent) Equal 

func (this *OutlierDetectionEvent_EjectSuccessRateEvent) Equal(that interface{}) bool

func (*OutlierDetectionEvent_EjectSuccessRateEvent) MarshalTo 

func (m *OutlierDetectionEvent_EjectSuccessRateEvent) MarshalTo(dAtA []byte) (int, error)

func (*OutlierDetectionEvent_EjectSuccessRateEvent) Size 

func (m *OutlierDetectionEvent_EjectSuccessRateEvent) Size() (n int)

type OutlierEjectConsecutive 

type OutlierEjectConsecutive struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OutlierEjectConsecutive) Descriptor 

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

func (*OutlierEjectConsecutive) Equal 

func (this *OutlierEjectConsecutive) Equal(that interface{}) bool

func (*OutlierEjectConsecutive) Marshal 

func (m *OutlierEjectConsecutive) Marshal() (dAtA []byte, err error)

func (*OutlierEjectConsecutive) MarshalTo 

func (m *OutlierEjectConsecutive) MarshalTo(dAtA []byte) (int, error)

func (*OutlierEjectConsecutive) ProtoMessage 

func (*OutlierEjectConsecutive) ProtoMessage()

func (*OutlierEjectConsecutive) Reset 

func (m *OutlierEjectConsecutive) Reset()

func (*OutlierEjectConsecutive) Size 

func (m *OutlierEjectConsecutive) Size() (n int)

func (*OutlierEjectConsecutive) String 

func (m *OutlierEjectConsecutive) String() string

func (*OutlierEjectConsecutive) Unmarshal 

func (m *OutlierEjectConsecutive) Unmarshal(dAtA []byte) error

func (*OutlierEjectConsecutive) Validate 

func (m *OutlierEjectConsecutive) Validate() error

Validate checks the field values on OutlierEjectConsecutive with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*OutlierEjectConsecutive) XXX_DiscardUnknown 

func (m *OutlierEjectConsecutive) XXX_DiscardUnknown()

func (*OutlierEjectConsecutive) XXX_Marshal 

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

func (*OutlierEjectConsecutive) XXX_Merge 

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

func (*OutlierEjectConsecutive) XXX_Size 

func (m *OutlierEjectConsecutive) XXX_Size() int

func (*OutlierEjectConsecutive) XXX_Unmarshal 

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

type OutlierEjectConsecutiveValidationError 

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

OutlierEjectConsecutiveValidationError is the validation error returned by OutlierEjectConsecutive.Validate if the designated constraints aren't met.

func (OutlierEjectConsecutiveValidationError) Cause 

func (e OutlierEjectConsecutiveValidationError) Cause() error

Cause function returns cause value.

func (OutlierEjectConsecutiveValidationError) Error 

func (e OutlierEjectConsecutiveValidationError) Error() string

Error satisfies the builtin error interface

func (OutlierEjectConsecutiveValidationError) ErrorName added in v0.7.0 

func (e OutlierEjectConsecutiveValidationError) ErrorName() string

ErrorName returns error name.

func (OutlierEjectConsecutiveValidationError) Field 

func (e OutlierEjectConsecutiveValidationError) Field() string

Field function returns field value.

func (OutlierEjectConsecutiveValidationError) Key 

func (e OutlierEjectConsecutiveValidationError) Key() bool

Key function returns key value.

func (OutlierEjectConsecutiveValidationError) Reason 

func (e OutlierEjectConsecutiveValidationError) Reason() string

Reason function returns reason value.

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 */
	XXX_NoUnkeyedLiteral                struct{} `json:"-"`
	XXX_unrecognized                    []byte   `json:"-"`
	XXX_sizecache                       int32    `json:"-"`
}

func (*OutlierEjectSuccessRate) Descriptor 

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

func (*OutlierEjectSuccessRate) Equal 

func (this *OutlierEjectSuccessRate) Equal(that interface{}) bool

func (*OutlierEjectSuccessRate) GetClusterAverageSuccessRate 

func (m *OutlierEjectSuccessRate) GetClusterAverageSuccessRate() uint32

func (*OutlierEjectSuccessRate) GetClusterSuccessRateEjectionThreshold 

func (m *OutlierEjectSuccessRate) GetClusterSuccessRateEjectionThreshold() uint32

func (*OutlierEjectSuccessRate) GetHostSuccessRate 

func (m *OutlierEjectSuccessRate) GetHostSuccessRate() uint32

func (*OutlierEjectSuccessRate) Marshal 

func (m *OutlierEjectSuccessRate) Marshal() (dAtA []byte, err error)

func (*OutlierEjectSuccessRate) MarshalTo 

func (m *OutlierEjectSuccessRate) MarshalTo(dAtA []byte) (int, error)

func (*OutlierEjectSuccessRate) ProtoMessage 

func (*OutlierEjectSuccessRate) ProtoMessage()

func (*OutlierEjectSuccessRate) Reset 

func (m *OutlierEjectSuccessRate) Reset()

func (*OutlierEjectSuccessRate) Size 

func (m *OutlierEjectSuccessRate) Size() (n int)

func (*OutlierEjectSuccessRate) String 

func (m *OutlierEjectSuccessRate) String() string

func (*OutlierEjectSuccessRate) Unmarshal 

func (m *OutlierEjectSuccessRate) Unmarshal(dAtA []byte) error

func (*OutlierEjectSuccessRate) Validate 

func (m *OutlierEjectSuccessRate) Validate() error

Validate checks the field values on OutlierEjectSuccessRate with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*OutlierEjectSuccessRate) XXX_DiscardUnknown 

func (m *OutlierEjectSuccessRate) XXX_DiscardUnknown()

func (*OutlierEjectSuccessRate) XXX_Marshal 

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

func (*OutlierEjectSuccessRate) XXX_Merge 

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

func (*OutlierEjectSuccessRate) XXX_Size 

func (m *OutlierEjectSuccessRate) XXX_Size() int

func (*OutlierEjectSuccessRate) XXX_Unmarshal 

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

type OutlierEjectSuccessRateValidationError 

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

OutlierEjectSuccessRateValidationError is the validation error returned by OutlierEjectSuccessRate.Validate if the designated constraints aren't met.

func (OutlierEjectSuccessRateValidationError) Cause 

func (e OutlierEjectSuccessRateValidationError) Cause() error

Cause function returns cause value.

func (OutlierEjectSuccessRateValidationError) Error 

func (e OutlierEjectSuccessRateValidationError) Error() string

Error satisfies the builtin error interface

func (OutlierEjectSuccessRateValidationError) ErrorName added in v0.7.0 

func (e OutlierEjectSuccessRateValidationError) ErrorName() string

ErrorName returns error name.

func (OutlierEjectSuccessRateValidationError) Field 

func (e OutlierEjectSuccessRateValidationError) Field() string

Field function returns field value.

func (OutlierEjectSuccessRateValidationError) Key 

func (e OutlierEjectSuccessRateValidationError) Key() bool

Key function returns key value.

func (OutlierEjectSuccessRateValidationError) Reason 

func (e OutlierEjectSuccessRateValidationError) Reason() string

Reason function returns reason value.

type OutlierEjectionType 

type OutlierEjectionType int32

Type of ejection that took place 

const (
	// In case upstream host returns certain number of consecutive 5xx
	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
	OutlierEjectionType_SUCCESS_RATE OutlierEjectionType = 2
)

func (OutlierEjectionType) EnumDescriptor 

func (OutlierEjectionType) EnumDescriptor() ([]byte, []int)

func (OutlierEjectionType) String 

func (x OutlierEjectionType) String() string

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.