Documentation ¶
Index ¶
- Variables
- func RegisterHealthDiscoveryServiceServer(s *grpc.Server, srv HealthDiscoveryServiceServer)
- type Capability
- func (*Capability) Descriptor() ([]byte, []int)deprecated
- func (x *Capability) GetHealthCheckProtocols() []Capability_Protocol
- func (*Capability) ProtoMessage()
- func (x *Capability) ProtoReflect() protoreflect.Message
- func (x *Capability) Reset()
- func (x *Capability) String() string
- func (m *Capability) Validate() error
- func (m *Capability) ValidateAll() error
- type CapabilityMultiError
- type CapabilityValidationError
- type Capability_Protocol
- func (Capability_Protocol) Descriptor() protoreflect.EnumDescriptor
- func (x Capability_Protocol) Enum() *Capability_Protocol
- func (Capability_Protocol) EnumDescriptor() ([]byte, []int)deprecated
- func (x Capability_Protocol) Number() protoreflect.EnumNumber
- func (x Capability_Protocol) String() string
- func (Capability_Protocol) Type() protoreflect.EnumType
- type ClusterEndpointsHealth
- func (*ClusterEndpointsHealth) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterEndpointsHealth) GetClusterName() string
- func (x *ClusterEndpointsHealth) GetLocalityEndpointsHealth() []*LocalityEndpointsHealth
- func (*ClusterEndpointsHealth) ProtoMessage()
- func (x *ClusterEndpointsHealth) ProtoReflect() protoreflect.Message
- func (x *ClusterEndpointsHealth) Reset()
- func (x *ClusterEndpointsHealth) String() string
- func (m *ClusterEndpointsHealth) Validate() error
- func (m *ClusterEndpointsHealth) ValidateAll() error
- type ClusterEndpointsHealthMultiError
- type ClusterEndpointsHealthValidationError
- func (e ClusterEndpointsHealthValidationError) Cause() error
- func (e ClusterEndpointsHealthValidationError) Error() string
- func (e ClusterEndpointsHealthValidationError) ErrorName() string
- func (e ClusterEndpointsHealthValidationError) Field() string
- func (e ClusterEndpointsHealthValidationError) Key() bool
- func (e ClusterEndpointsHealthValidationError) Reason() string
- type ClusterHealthCheck
- func (*ClusterHealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterHealthCheck) GetClusterName() string
- func (x *ClusterHealthCheck) GetHealthChecks() []*v3.HealthCheck
- func (x *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints
- func (x *ClusterHealthCheck) GetTransportSocketMatches() []*v32.Cluster_TransportSocketMatch
- func (x *ClusterHealthCheck) GetUpstreamBindConfig() *v3.BindConfig
- func (*ClusterHealthCheck) ProtoMessage()
- func (x *ClusterHealthCheck) ProtoReflect() protoreflect.Message
- func (x *ClusterHealthCheck) Reset()
- func (x *ClusterHealthCheck) String() string
- func (m *ClusterHealthCheck) Validate() error
- func (m *ClusterHealthCheck) ValidateAll() error
- type ClusterHealthCheckMultiError
- type ClusterHealthCheckValidationError
- func (e ClusterHealthCheckValidationError) Cause() error
- func (e ClusterHealthCheckValidationError) Error() string
- func (e ClusterHealthCheckValidationError) ErrorName() string
- func (e ClusterHealthCheckValidationError) Field() string
- func (e ClusterHealthCheckValidationError) Key() bool
- func (e ClusterHealthCheckValidationError) Reason() string
- type EndpointHealth
- func (*EndpointHealth) Descriptor() ([]byte, []int)deprecated
- func (x *EndpointHealth) GetEndpoint() *v31.Endpoint
- func (x *EndpointHealth) GetHealthStatus() v3.HealthStatus
- func (*EndpointHealth) ProtoMessage()
- func (x *EndpointHealth) ProtoReflect() protoreflect.Message
- func (x *EndpointHealth) Reset()
- func (x *EndpointHealth) String() string
- func (m *EndpointHealth) Validate() error
- func (m *EndpointHealth) ValidateAll() error
- type EndpointHealthMultiError
- type EndpointHealthResponse
- func (*EndpointHealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EndpointHealthResponse) GetClusterEndpointsHealth() []*ClusterEndpointsHealth
- func (x *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealthdeprecated
- func (*EndpointHealthResponse) ProtoMessage()
- func (x *EndpointHealthResponse) ProtoReflect() protoreflect.Message
- func (x *EndpointHealthResponse) Reset()
- func (x *EndpointHealthResponse) String() string
- func (m *EndpointHealthResponse) Validate() error
- func (m *EndpointHealthResponse) ValidateAll() error
- type EndpointHealthResponseMultiError
- type EndpointHealthResponseValidationError
- func (e EndpointHealthResponseValidationError) Cause() error
- func (e EndpointHealthResponseValidationError) Error() string
- func (e EndpointHealthResponseValidationError) ErrorName() string
- func (e EndpointHealthResponseValidationError) Field() string
- func (e EndpointHealthResponseValidationError) Key() bool
- func (e EndpointHealthResponseValidationError) Reason() string
- type EndpointHealthValidationError
- func (e EndpointHealthValidationError) Cause() error
- func (e EndpointHealthValidationError) Error() string
- func (e EndpointHealthValidationError) ErrorName() string
- func (e EndpointHealthValidationError) Field() string
- func (e EndpointHealthValidationError) Key() bool
- func (e EndpointHealthValidationError) Reason() string
- type HdsDummy
- type HdsDummyMultiError
- type HdsDummyValidationError
- type HealthCheckRequest
- func (*HealthCheckRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckRequest) GetCapability() *Capability
- func (x *HealthCheckRequest) GetNode() *v3.Node
- func (*HealthCheckRequest) ProtoMessage()
- func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
- func (x *HealthCheckRequest) Reset()
- func (x *HealthCheckRequest) String() string
- func (m *HealthCheckRequest) Validate() error
- func (m *HealthCheckRequest) ValidateAll() error
- type HealthCheckRequestMultiError
- type HealthCheckRequestOrEndpointHealthResponse
- func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse
- func (x *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest
- func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType
- func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()
- func (x *HealthCheckRequestOrEndpointHealthResponse) ProtoReflect() protoreflect.Message
- func (x *HealthCheckRequestOrEndpointHealthResponse) Reset()
- func (x *HealthCheckRequestOrEndpointHealthResponse) String() string
- func (m *HealthCheckRequestOrEndpointHealthResponse) Validate() error
- func (m *HealthCheckRequestOrEndpointHealthResponse) ValidateAll() error
- type HealthCheckRequestOrEndpointHealthResponseMultiError
- type HealthCheckRequestOrEndpointHealthResponseValidationError
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Cause() error
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Error() string
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName() string
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Field() string
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Key() bool
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Reason() string
- type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse
- type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest
- type HealthCheckRequestValidationError
- func (e HealthCheckRequestValidationError) Cause() error
- func (e HealthCheckRequestValidationError) Error() string
- func (e HealthCheckRequestValidationError) ErrorName() string
- func (e HealthCheckRequestValidationError) Field() string
- func (e HealthCheckRequestValidationError) Key() bool
- func (e HealthCheckRequestValidationError) Reason() string
- type HealthCheckSpecifier
- func (*HealthCheckSpecifier) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck
- func (x *HealthCheckSpecifier) GetInterval() *durationpb.Duration
- func (*HealthCheckSpecifier) ProtoMessage()
- func (x *HealthCheckSpecifier) ProtoReflect() protoreflect.Message
- func (x *HealthCheckSpecifier) Reset()
- func (x *HealthCheckSpecifier) String() string
- func (m *HealthCheckSpecifier) Validate() error
- func (m *HealthCheckSpecifier) ValidateAll() error
- type HealthCheckSpecifierMultiError
- type HealthCheckSpecifierValidationError
- func (e HealthCheckSpecifierValidationError) Cause() error
- func (e HealthCheckSpecifierValidationError) Error() string
- func (e HealthCheckSpecifierValidationError) ErrorName() string
- func (e HealthCheckSpecifierValidationError) Field() string
- func (e HealthCheckSpecifierValidationError) Key() bool
- func (e HealthCheckSpecifierValidationError) Reason() string
- type HealthDiscoveryServiceClient
- type HealthDiscoveryServiceServer
- type HealthDiscoveryService_StreamHealthCheckClient
- type HealthDiscoveryService_StreamHealthCheckServer
- type LocalityEndpoints
- func (*LocalityEndpoints) Descriptor() ([]byte, []int)deprecated
- func (x *LocalityEndpoints) GetEndpoints() []*v31.Endpoint
- func (x *LocalityEndpoints) GetLocality() *v3.Locality
- func (*LocalityEndpoints) ProtoMessage()
- func (x *LocalityEndpoints) ProtoReflect() protoreflect.Message
- func (x *LocalityEndpoints) Reset()
- func (x *LocalityEndpoints) String() string
- func (m *LocalityEndpoints) Validate() error
- func (m *LocalityEndpoints) ValidateAll() error
- type LocalityEndpointsHealth
- func (*LocalityEndpointsHealth) Descriptor() ([]byte, []int)deprecated
- func (x *LocalityEndpointsHealth) GetEndpointsHealth() []*EndpointHealth
- func (x *LocalityEndpointsHealth) GetLocality() *v3.Locality
- func (*LocalityEndpointsHealth) ProtoMessage()
- func (x *LocalityEndpointsHealth) ProtoReflect() protoreflect.Message
- func (x *LocalityEndpointsHealth) Reset()
- func (x *LocalityEndpointsHealth) String() string
- func (m *LocalityEndpointsHealth) Validate() error
- func (m *LocalityEndpointsHealth) ValidateAll() error
- type LocalityEndpointsHealthMultiError
- type LocalityEndpointsHealthValidationError
- func (e LocalityEndpointsHealthValidationError) Cause() error
- func (e LocalityEndpointsHealthValidationError) Error() string
- func (e LocalityEndpointsHealthValidationError) ErrorName() string
- func (e LocalityEndpointsHealthValidationError) Field() string
- func (e LocalityEndpointsHealthValidationError) Key() bool
- func (e LocalityEndpointsHealthValidationError) Reason() string
- type LocalityEndpointsMultiError
- type LocalityEndpointsValidationError
- func (e LocalityEndpointsValidationError) Cause() error
- func (e LocalityEndpointsValidationError) Error() string
- func (e LocalityEndpointsValidationError) ErrorName() string
- func (e LocalityEndpointsValidationError) Field() string
- func (e LocalityEndpointsValidationError) Key() bool
- func (e LocalityEndpointsValidationError) Reason() string
- type UnimplementedHealthDiscoveryServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( Capability_Protocol_name = map[int32]string{ 0: "HTTP", 1: "TCP", 2: "REDIS", } Capability_Protocol_value = map[string]int32{ "HTTP": 0, "TCP": 1, "REDIS": 2, } )
Enum value maps for Capability_Protocol.
var File_envoy_service_health_v3_hds_proto protoreflect.FileDescriptor
Functions ¶
func RegisterHealthDiscoveryServiceServer ¶
func RegisterHealthDiscoveryServiceServer(s *grpc.Server, srv HealthDiscoveryServiceServer)
Types ¶
type Capability ¶
type Capability struct { HealthCheckProtocols []Capability_Protocol `` /* 180-byte string literal not displayed */ // contains filtered or unexported fields }
Defines supported protocols etc, so the management server can assign proper endpoints to healthcheck.
func (*Capability) Descriptor
deprecated
func (*Capability) Descriptor() ([]byte, []int)
Deprecated: Use Capability.ProtoReflect.Descriptor instead.
func (*Capability) GetHealthCheckProtocols ¶
func (x *Capability) GetHealthCheckProtocols() []Capability_Protocol
func (*Capability) ProtoMessage ¶
func (*Capability) ProtoMessage()
func (*Capability) ProtoReflect ¶
func (x *Capability) ProtoReflect() protoreflect.Message
func (*Capability) Reset ¶
func (x *Capability) Reset()
func (*Capability) String ¶
func (x *Capability) String() string
func (*Capability) Validate ¶
func (m *Capability) Validate() error
Validate checks the field values on Capability with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Capability) ValidateAll ¶
func (m *Capability) ValidateAll() error
ValidateAll checks the field values on Capability with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CapabilityMultiError, or nil if none found.
type CapabilityMultiError ¶
type CapabilityMultiError []error
CapabilityMultiError is an error wrapping multiple validation errors returned by Capability.ValidateAll() if the designated constraints aren't met.
func (CapabilityMultiError) AllErrors ¶
func (m CapabilityMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (CapabilityMultiError) Error ¶
func (m CapabilityMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type CapabilityValidationError ¶
type CapabilityValidationError struct {
// contains filtered or unexported fields
}
CapabilityValidationError is the validation error returned by Capability.Validate if the designated constraints aren't met.
func (CapabilityValidationError) Cause ¶
func (e CapabilityValidationError) Cause() error
Cause function returns cause value.
func (CapabilityValidationError) Error ¶
func (e CapabilityValidationError) Error() string
Error satisfies the builtin error interface
func (CapabilityValidationError) ErrorName ¶
func (e CapabilityValidationError) ErrorName() string
ErrorName returns error name.
func (CapabilityValidationError) Field ¶
func (e CapabilityValidationError) Field() string
Field function returns field value.
func (CapabilityValidationError) Key ¶
func (e CapabilityValidationError) Key() bool
Key function returns key value.
func (CapabilityValidationError) Reason ¶
func (e CapabilityValidationError) Reason() string
Reason function returns reason value.
type Capability_Protocol ¶
type Capability_Protocol int32
Different Envoy instances may have different capabilities (e.g. Redis) and/or have ports enabled for different protocols.
const ( Capability_HTTP Capability_Protocol = 0 Capability_TCP Capability_Protocol = 1 Capability_REDIS Capability_Protocol = 2 )
func (Capability_Protocol) Descriptor ¶
func (Capability_Protocol) Descriptor() protoreflect.EnumDescriptor
func (Capability_Protocol) Enum ¶
func (x Capability_Protocol) Enum() *Capability_Protocol
func (Capability_Protocol) EnumDescriptor
deprecated
func (Capability_Protocol) EnumDescriptor() ([]byte, []int)
Deprecated: Use Capability_Protocol.Descriptor instead.
func (Capability_Protocol) Number ¶
func (x Capability_Protocol) Number() protoreflect.EnumNumber
func (Capability_Protocol) String ¶
func (x Capability_Protocol) String() string
func (Capability_Protocol) Type ¶
func (Capability_Protocol) Type() protoreflect.EnumType
type ClusterEndpointsHealth ¶
type ClusterEndpointsHealth struct { ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` LocalityEndpointsHealth []*LocalityEndpointsHealth `` /* 132-byte string literal not displayed */ // contains filtered or unexported fields }
The health status of endpoints in a cluster. The cluster name and locality should match the corresponding fields in ClusterHealthCheck message.
func (*ClusterEndpointsHealth) Descriptor
deprecated
func (*ClusterEndpointsHealth) Descriptor() ([]byte, []int)
Deprecated: Use ClusterEndpointsHealth.ProtoReflect.Descriptor instead.
func (*ClusterEndpointsHealth) GetClusterName ¶
func (x *ClusterEndpointsHealth) GetClusterName() string
func (*ClusterEndpointsHealth) GetLocalityEndpointsHealth ¶
func (x *ClusterEndpointsHealth) GetLocalityEndpointsHealth() []*LocalityEndpointsHealth
func (*ClusterEndpointsHealth) ProtoMessage ¶
func (*ClusterEndpointsHealth) ProtoMessage()
func (*ClusterEndpointsHealth) ProtoReflect ¶
func (x *ClusterEndpointsHealth) ProtoReflect() protoreflect.Message
func (*ClusterEndpointsHealth) Reset ¶
func (x *ClusterEndpointsHealth) Reset()
func (*ClusterEndpointsHealth) String ¶
func (x *ClusterEndpointsHealth) String() string
func (*ClusterEndpointsHealth) Validate ¶
func (m *ClusterEndpointsHealth) Validate() error
Validate checks the field values on ClusterEndpointsHealth with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ClusterEndpointsHealth) ValidateAll ¶
func (m *ClusterEndpointsHealth) ValidateAll() error
ValidateAll checks the field values on ClusterEndpointsHealth with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClusterEndpointsHealthMultiError, or nil if none found.
type ClusterEndpointsHealthMultiError ¶
type ClusterEndpointsHealthMultiError []error
ClusterEndpointsHealthMultiError is an error wrapping multiple validation errors returned by ClusterEndpointsHealth.ValidateAll() if the designated constraints aren't met.
func (ClusterEndpointsHealthMultiError) AllErrors ¶
func (m ClusterEndpointsHealthMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ClusterEndpointsHealthMultiError) Error ¶
func (m ClusterEndpointsHealthMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ClusterEndpointsHealthValidationError ¶
type ClusterEndpointsHealthValidationError struct {
// contains filtered or unexported fields
}
ClusterEndpointsHealthValidationError is the validation error returned by ClusterEndpointsHealth.Validate if the designated constraints aren't met.
func (ClusterEndpointsHealthValidationError) Cause ¶
func (e ClusterEndpointsHealthValidationError) Cause() error
Cause function returns cause value.
func (ClusterEndpointsHealthValidationError) Error ¶
func (e ClusterEndpointsHealthValidationError) Error() string
Error satisfies the builtin error interface
func (ClusterEndpointsHealthValidationError) ErrorName ¶
func (e ClusterEndpointsHealthValidationError) ErrorName() string
ErrorName returns error name.
func (ClusterEndpointsHealthValidationError) Field ¶
func (e ClusterEndpointsHealthValidationError) Field() string
Field function returns field value.
func (ClusterEndpointsHealthValidationError) Key ¶
func (e ClusterEndpointsHealthValidationError) Key() bool
Key function returns key value.
func (ClusterEndpointsHealthValidationError) Reason ¶
func (e ClusterEndpointsHealthValidationError) Reason() string
Reason function returns reason value.
type ClusterHealthCheck ¶
type ClusterHealthCheck struct { ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` HealthChecks []*v3.HealthCheck `protobuf:"bytes,2,rep,name=health_checks,json=healthChecks,proto3" json:"health_checks,omitempty"` LocalityEndpoints []*LocalityEndpoints `protobuf:"bytes,3,rep,name=locality_endpoints,json=localityEndpoints,proto3" json:"locality_endpoints,omitempty"` // Optional map that gets filtered by :ref:`health_checks.transport_socket_match_criteria <envoy_v3_api_field_config.core.v3.HealthCheck.transport_socket_match_criteria>` // on connection when health checking. For more details, see // :ref:`config.cluster.v3.Cluster.transport_socket_matches <envoy_v3_api_field_config.cluster.v3.Cluster.transport_socket_matches>`. TransportSocketMatches []*v32.Cluster_TransportSocketMatch `` /* 129-byte string literal not displayed */ // Optional configuration used to bind newly established upstream connections. // If the address and port are empty, no bind will be performed. UpstreamBindConfig *v3.BindConfig `protobuf:"bytes,5,opt,name=upstream_bind_config,json=upstreamBindConfig,proto3" json:"upstream_bind_config,omitempty"` // contains filtered or unexported fields }
The cluster name and locality is provided to Envoy for the endpoints that it health checks to support statistics reporting, logging and debugging by the Envoy instance (outside of HDS). For maximum usefulness, it should match the same cluster structure as that provided by EDS. [#next-free-field: 6]
func (*ClusterHealthCheck) Descriptor
deprecated
func (*ClusterHealthCheck) Descriptor() ([]byte, []int)
Deprecated: Use ClusterHealthCheck.ProtoReflect.Descriptor instead.
func (*ClusterHealthCheck) GetClusterName ¶
func (x *ClusterHealthCheck) GetClusterName() string
func (*ClusterHealthCheck) GetHealthChecks ¶
func (x *ClusterHealthCheck) GetHealthChecks() []*v3.HealthCheck
func (*ClusterHealthCheck) GetLocalityEndpoints ¶
func (x *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints
func (*ClusterHealthCheck) GetTransportSocketMatches ¶
func (x *ClusterHealthCheck) GetTransportSocketMatches() []*v32.Cluster_TransportSocketMatch
func (*ClusterHealthCheck) GetUpstreamBindConfig ¶
func (x *ClusterHealthCheck) GetUpstreamBindConfig() *v3.BindConfig
func (*ClusterHealthCheck) ProtoMessage ¶
func (*ClusterHealthCheck) ProtoMessage()
func (*ClusterHealthCheck) ProtoReflect ¶
func (x *ClusterHealthCheck) ProtoReflect() protoreflect.Message
func (*ClusterHealthCheck) Reset ¶
func (x *ClusterHealthCheck) Reset()
func (*ClusterHealthCheck) String ¶
func (x *ClusterHealthCheck) String() string
func (*ClusterHealthCheck) Validate ¶
func (m *ClusterHealthCheck) Validate() error
Validate checks the field values on ClusterHealthCheck with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ClusterHealthCheck) ValidateAll ¶
func (m *ClusterHealthCheck) ValidateAll() error
ValidateAll checks the field values on ClusterHealthCheck with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClusterHealthCheckMultiError, or nil if none found.
type ClusterHealthCheckMultiError ¶
type ClusterHealthCheckMultiError []error
ClusterHealthCheckMultiError is an error wrapping multiple validation errors returned by ClusterHealthCheck.ValidateAll() if the designated constraints aren't met.
func (ClusterHealthCheckMultiError) AllErrors ¶
func (m ClusterHealthCheckMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ClusterHealthCheckMultiError) Error ¶
func (m ClusterHealthCheckMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ClusterHealthCheckValidationError ¶
type ClusterHealthCheckValidationError struct {
// contains filtered or unexported fields
}
ClusterHealthCheckValidationError is the validation error returned by ClusterHealthCheck.Validate if the designated constraints aren't met.
func (ClusterHealthCheckValidationError) Cause ¶
func (e ClusterHealthCheckValidationError) Cause() error
Cause function returns cause value.
func (ClusterHealthCheckValidationError) Error ¶
func (e ClusterHealthCheckValidationError) Error() string
Error satisfies the builtin error interface
func (ClusterHealthCheckValidationError) ErrorName ¶
func (e ClusterHealthCheckValidationError) ErrorName() string
ErrorName returns error name.
func (ClusterHealthCheckValidationError) Field ¶
func (e ClusterHealthCheckValidationError) Field() string
Field function returns field value.
func (ClusterHealthCheckValidationError) Key ¶
func (e ClusterHealthCheckValidationError) Key() bool
Key function returns key value.
func (ClusterHealthCheckValidationError) Reason ¶
func (e ClusterHealthCheckValidationError) Reason() string
Reason function returns reason value.
type EndpointHealth ¶
type EndpointHealth struct { Endpoint *v31.Endpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` HealthStatus v3.HealthStatus `` /* 137-byte string literal not displayed */ // contains filtered or unexported fields }
func (*EndpointHealth) Descriptor
deprecated
func (*EndpointHealth) Descriptor() ([]byte, []int)
Deprecated: Use EndpointHealth.ProtoReflect.Descriptor instead.
func (*EndpointHealth) GetEndpoint ¶
func (x *EndpointHealth) GetEndpoint() *v31.Endpoint
func (*EndpointHealth) GetHealthStatus ¶
func (x *EndpointHealth) GetHealthStatus() v3.HealthStatus
func (*EndpointHealth) ProtoMessage ¶
func (*EndpointHealth) ProtoMessage()
func (*EndpointHealth) ProtoReflect ¶
func (x *EndpointHealth) ProtoReflect() protoreflect.Message
func (*EndpointHealth) Reset ¶
func (x *EndpointHealth) Reset()
func (*EndpointHealth) String ¶
func (x *EndpointHealth) String() string
func (*EndpointHealth) Validate ¶
func (m *EndpointHealth) Validate() error
Validate checks the field values on EndpointHealth with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*EndpointHealth) ValidateAll ¶
func (m *EndpointHealth) ValidateAll() error
ValidateAll checks the field values on EndpointHealth with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EndpointHealthMultiError, or nil if none found.
type EndpointHealthMultiError ¶
type EndpointHealthMultiError []error
EndpointHealthMultiError is an error wrapping multiple validation errors returned by EndpointHealth.ValidateAll() if the designated constraints aren't met.
func (EndpointHealthMultiError) AllErrors ¶
func (m EndpointHealthMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (EndpointHealthMultiError) Error ¶
func (m EndpointHealthMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type EndpointHealthResponse ¶
type EndpointHealthResponse struct { // Deprecated - Flat list of endpoint health information. // // Deprecated: Do not use. EndpointsHealth []*EndpointHealth `protobuf:"bytes,1,rep,name=endpoints_health,json=endpointsHealth,proto3" json:"endpoints_health,omitempty"` // Organize Endpoint health information by cluster. ClusterEndpointsHealth []*ClusterEndpointsHealth `` /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
func (*EndpointHealthResponse) Descriptor
deprecated
func (*EndpointHealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use EndpointHealthResponse.ProtoReflect.Descriptor instead.
func (*EndpointHealthResponse) GetClusterEndpointsHealth ¶
func (x *EndpointHealthResponse) GetClusterEndpointsHealth() []*ClusterEndpointsHealth
func (*EndpointHealthResponse) GetEndpointsHealth
deprecated
func (x *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth
Deprecated: Do not use.
func (*EndpointHealthResponse) ProtoMessage ¶
func (*EndpointHealthResponse) ProtoMessage()
func (*EndpointHealthResponse) ProtoReflect ¶
func (x *EndpointHealthResponse) ProtoReflect() protoreflect.Message
func (*EndpointHealthResponse) Reset ¶
func (x *EndpointHealthResponse) Reset()
func (*EndpointHealthResponse) String ¶
func (x *EndpointHealthResponse) String() string
func (*EndpointHealthResponse) Validate ¶
func (m *EndpointHealthResponse) Validate() error
Validate checks the field values on EndpointHealthResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*EndpointHealthResponse) ValidateAll ¶
func (m *EndpointHealthResponse) ValidateAll() error
ValidateAll checks the field values on EndpointHealthResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EndpointHealthResponseMultiError, or nil if none found.
type EndpointHealthResponseMultiError ¶
type EndpointHealthResponseMultiError []error
EndpointHealthResponseMultiError is an error wrapping multiple validation errors returned by EndpointHealthResponse.ValidateAll() if the designated constraints aren't met.
func (EndpointHealthResponseMultiError) AllErrors ¶
func (m EndpointHealthResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (EndpointHealthResponseMultiError) Error ¶
func (m EndpointHealthResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type EndpointHealthResponseValidationError ¶
type EndpointHealthResponseValidationError struct {
// contains filtered or unexported fields
}
EndpointHealthResponseValidationError is the validation error returned by EndpointHealthResponse.Validate if the designated constraints aren't met.
func (EndpointHealthResponseValidationError) Cause ¶
func (e EndpointHealthResponseValidationError) Cause() error
Cause function returns cause value.
func (EndpointHealthResponseValidationError) Error ¶
func (e EndpointHealthResponseValidationError) Error() string
Error satisfies the builtin error interface
func (EndpointHealthResponseValidationError) ErrorName ¶
func (e EndpointHealthResponseValidationError) ErrorName() string
ErrorName returns error name.
func (EndpointHealthResponseValidationError) Field ¶
func (e EndpointHealthResponseValidationError) Field() string
Field function returns field value.
func (EndpointHealthResponseValidationError) Key ¶
func (e EndpointHealthResponseValidationError) Key() bool
Key function returns key value.
func (EndpointHealthResponseValidationError) Reason ¶
func (e EndpointHealthResponseValidationError) Reason() string
Reason function returns reason value.
type EndpointHealthValidationError ¶
type EndpointHealthValidationError struct {
// contains filtered or unexported fields
}
EndpointHealthValidationError is the validation error returned by EndpointHealth.Validate if the designated constraints aren't met.
func (EndpointHealthValidationError) Cause ¶
func (e EndpointHealthValidationError) Cause() error
Cause function returns cause value.
func (EndpointHealthValidationError) Error ¶
func (e EndpointHealthValidationError) Error() string
Error satisfies the builtin error interface
func (EndpointHealthValidationError) ErrorName ¶
func (e EndpointHealthValidationError) ErrorName() string
ErrorName returns error name.
func (EndpointHealthValidationError) Field ¶
func (e EndpointHealthValidationError) Field() string
Field function returns field value.
func (EndpointHealthValidationError) Key ¶
func (e EndpointHealthValidationError) Key() bool
Key function returns key value.
func (EndpointHealthValidationError) Reason ¶
func (e EndpointHealthValidationError) Reason() string
Reason function returns reason value.
type HdsDummy ¶
type HdsDummy struct {
// contains filtered or unexported fields
}
[#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing services: https://github.com/google/protobuf/issues/4221 and protoxform to upgrade the file.
func (*HdsDummy) Descriptor
deprecated
func (*HdsDummy) ProtoMessage ¶
func (*HdsDummy) ProtoMessage()
func (*HdsDummy) ProtoReflect ¶
func (x *HdsDummy) ProtoReflect() protoreflect.Message
func (*HdsDummy) Validate ¶
Validate checks the field values on HdsDummy with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*HdsDummy) ValidateAll ¶
ValidateAll checks the field values on HdsDummy with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in HdsDummyMultiError, or nil if none found.
type HdsDummyMultiError ¶
type HdsDummyMultiError []error
HdsDummyMultiError is an error wrapping multiple validation errors returned by HdsDummy.ValidateAll() if the designated constraints aren't met.
func (HdsDummyMultiError) AllErrors ¶
func (m HdsDummyMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (HdsDummyMultiError) Error ¶
func (m HdsDummyMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type HdsDummyValidationError ¶
type HdsDummyValidationError struct {
// contains filtered or unexported fields
}
HdsDummyValidationError is the validation error returned by HdsDummy.Validate if the designated constraints aren't met.
func (HdsDummyValidationError) Cause ¶
func (e HdsDummyValidationError) Cause() error
Cause function returns cause value.
func (HdsDummyValidationError) Error ¶
func (e HdsDummyValidationError) Error() string
Error satisfies the builtin error interface
func (HdsDummyValidationError) ErrorName ¶
func (e HdsDummyValidationError) ErrorName() string
ErrorName returns error name.
func (HdsDummyValidationError) Field ¶
func (e HdsDummyValidationError) Field() string
Field function returns field value.
func (HdsDummyValidationError) Key ¶
func (e HdsDummyValidationError) Key() bool
Key function returns key value.
func (HdsDummyValidationError) Reason ¶
func (e HdsDummyValidationError) Reason() string
Reason function returns reason value.
type HealthCheckRequest ¶
type HealthCheckRequest struct { Node *v3.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` Capability *Capability `protobuf:"bytes,2,opt,name=capability,proto3" json:"capability,omitempty"` // contains filtered or unexported fields }
func (*HealthCheckRequest) Descriptor
deprecated
func (*HealthCheckRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.
func (*HealthCheckRequest) GetCapability ¶
func (x *HealthCheckRequest) GetCapability() *Capability
func (*HealthCheckRequest) GetNode ¶
func (x *HealthCheckRequest) GetNode() *v3.Node
func (*HealthCheckRequest) ProtoMessage ¶
func (*HealthCheckRequest) ProtoMessage()
func (*HealthCheckRequest) ProtoReflect ¶
func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
func (*HealthCheckRequest) Reset ¶
func (x *HealthCheckRequest) Reset()
func (*HealthCheckRequest) String ¶
func (x *HealthCheckRequest) String() string
func (*HealthCheckRequest) Validate ¶
func (m *HealthCheckRequest) Validate() error
Validate checks the field values on HealthCheckRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*HealthCheckRequest) ValidateAll ¶
func (m *HealthCheckRequest) ValidateAll() error
ValidateAll checks the field values on HealthCheckRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in HealthCheckRequestMultiError, or nil if none found.
type HealthCheckRequestMultiError ¶
type HealthCheckRequestMultiError []error
HealthCheckRequestMultiError is an error wrapping multiple validation errors returned by HealthCheckRequest.ValidateAll() if the designated constraints aren't met.
func (HealthCheckRequestMultiError) AllErrors ¶
func (m HealthCheckRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (HealthCheckRequestMultiError) Error ¶
func (m HealthCheckRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type HealthCheckRequestOrEndpointHealthResponse ¶
type HealthCheckRequestOrEndpointHealthResponse struct { // Types that are assignable to RequestType: // // *HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest // *HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse RequestType isHealthCheckRequestOrEndpointHealthResponse_RequestType `protobuf_oneof:"request_type"` // contains filtered or unexported fields }
func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor
deprecated
func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckRequestOrEndpointHealthResponse.ProtoReflect.Descriptor instead.
func (*HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse ¶
func (x *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse
func (*HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest ¶
func (x *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest
func (*HealthCheckRequestOrEndpointHealthResponse) GetRequestType ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType
func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage ¶
func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()
func (*HealthCheckRequestOrEndpointHealthResponse) ProtoReflect ¶
func (x *HealthCheckRequestOrEndpointHealthResponse) ProtoReflect() protoreflect.Message
func (*HealthCheckRequestOrEndpointHealthResponse) Reset ¶
func (x *HealthCheckRequestOrEndpointHealthResponse) Reset()
func (*HealthCheckRequestOrEndpointHealthResponse) String ¶
func (x *HealthCheckRequestOrEndpointHealthResponse) String() string
func (*HealthCheckRequestOrEndpointHealthResponse) Validate ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) Validate() error
Validate checks the field values on HealthCheckRequestOrEndpointHealthResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*HealthCheckRequestOrEndpointHealthResponse) ValidateAll ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) ValidateAll() error
ValidateAll checks the field values on HealthCheckRequestOrEndpointHealthResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in HealthCheckRequestOrEndpointHealthResponseMultiError, or nil if none found.
type HealthCheckRequestOrEndpointHealthResponseMultiError ¶
type HealthCheckRequestOrEndpointHealthResponseMultiError []error
HealthCheckRequestOrEndpointHealthResponseMultiError is an error wrapping multiple validation errors returned by HealthCheckRequestOrEndpointHealthResponse.ValidateAll() if the designated constraints aren't met.
func (HealthCheckRequestOrEndpointHealthResponseMultiError) AllErrors ¶
func (m HealthCheckRequestOrEndpointHealthResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (HealthCheckRequestOrEndpointHealthResponseMultiError) Error ¶
func (m HealthCheckRequestOrEndpointHealthResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type HealthCheckRequestOrEndpointHealthResponseValidationError ¶
type HealthCheckRequestOrEndpointHealthResponseValidationError struct {
// contains filtered or unexported fields
}
HealthCheckRequestOrEndpointHealthResponseValidationError is the validation error returned by HealthCheckRequestOrEndpointHealthResponse.Validate if the designated constraints aren't met.
func (HealthCheckRequestOrEndpointHealthResponseValidationError) Cause ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Cause() error
Cause function returns cause value.
func (HealthCheckRequestOrEndpointHealthResponseValidationError) Error ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Error() string
Error satisfies the builtin error interface
func (HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName() string
ErrorName returns error name.
func (HealthCheckRequestOrEndpointHealthResponseValidationError) Field ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Field() string
Field function returns field value.
func (HealthCheckRequestOrEndpointHealthResponseValidationError) Key ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Key() bool
Key function returns key value.
func (HealthCheckRequestOrEndpointHealthResponseValidationError) Reason ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Reason() string
Reason function returns reason value.
type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse ¶
type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse struct {
EndpointHealthResponse *EndpointHealthResponse `protobuf:"bytes,2,opt,name=endpoint_health_response,json=endpointHealthResponse,proto3,oneof"`
}
type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest ¶
type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest struct {
HealthCheckRequest *HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof"`
}
type HealthCheckRequestValidationError ¶
type HealthCheckRequestValidationError struct {
// contains filtered or unexported fields
}
HealthCheckRequestValidationError is the validation error returned by HealthCheckRequest.Validate if the designated constraints aren't met.
func (HealthCheckRequestValidationError) Cause ¶
func (e HealthCheckRequestValidationError) Cause() error
Cause function returns cause value.
func (HealthCheckRequestValidationError) Error ¶
func (e HealthCheckRequestValidationError) Error() string
Error satisfies the builtin error interface
func (HealthCheckRequestValidationError) ErrorName ¶
func (e HealthCheckRequestValidationError) ErrorName() string
ErrorName returns error name.
func (HealthCheckRequestValidationError) Field ¶
func (e HealthCheckRequestValidationError) Field() string
Field function returns field value.
func (HealthCheckRequestValidationError) Key ¶
func (e HealthCheckRequestValidationError) Key() bool
Key function returns key value.
func (HealthCheckRequestValidationError) Reason ¶
func (e HealthCheckRequestValidationError) Reason() string
Reason function returns reason value.
type HealthCheckSpecifier ¶
type HealthCheckSpecifier struct { ClusterHealthChecks []*ClusterHealthCheck `protobuf:"bytes,1,rep,name=cluster_health_checks,json=clusterHealthChecks,proto3" json:"cluster_health_checks,omitempty"` // The default is 1 second. Interval *durationpb.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"` // contains filtered or unexported fields }
func (*HealthCheckSpecifier) Descriptor
deprecated
func (*HealthCheckSpecifier) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckSpecifier.ProtoReflect.Descriptor instead.
func (*HealthCheckSpecifier) GetClusterHealthChecks ¶
func (x *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck
func (*HealthCheckSpecifier) GetInterval ¶
func (x *HealthCheckSpecifier) GetInterval() *durationpb.Duration
func (*HealthCheckSpecifier) ProtoMessage ¶
func (*HealthCheckSpecifier) ProtoMessage()
func (*HealthCheckSpecifier) ProtoReflect ¶
func (x *HealthCheckSpecifier) ProtoReflect() protoreflect.Message
func (*HealthCheckSpecifier) Reset ¶
func (x *HealthCheckSpecifier) Reset()
func (*HealthCheckSpecifier) String ¶
func (x *HealthCheckSpecifier) String() string
func (*HealthCheckSpecifier) Validate ¶
func (m *HealthCheckSpecifier) Validate() error
Validate checks the field values on HealthCheckSpecifier with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*HealthCheckSpecifier) ValidateAll ¶
func (m *HealthCheckSpecifier) ValidateAll() error
ValidateAll checks the field values on HealthCheckSpecifier with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in HealthCheckSpecifierMultiError, or nil if none found.
type HealthCheckSpecifierMultiError ¶
type HealthCheckSpecifierMultiError []error
HealthCheckSpecifierMultiError is an error wrapping multiple validation errors returned by HealthCheckSpecifier.ValidateAll() if the designated constraints aren't met.
func (HealthCheckSpecifierMultiError) AllErrors ¶
func (m HealthCheckSpecifierMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (HealthCheckSpecifierMultiError) Error ¶
func (m HealthCheckSpecifierMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type HealthCheckSpecifierValidationError ¶
type HealthCheckSpecifierValidationError struct {
// contains filtered or unexported fields
}
HealthCheckSpecifierValidationError is the validation error returned by HealthCheckSpecifier.Validate if the designated constraints aren't met.
func (HealthCheckSpecifierValidationError) Cause ¶
func (e HealthCheckSpecifierValidationError) Cause() error
Cause function returns cause value.
func (HealthCheckSpecifierValidationError) Error ¶
func (e HealthCheckSpecifierValidationError) Error() string
Error satisfies the builtin error interface
func (HealthCheckSpecifierValidationError) ErrorName ¶
func (e HealthCheckSpecifierValidationError) ErrorName() string
ErrorName returns error name.
func (HealthCheckSpecifierValidationError) Field ¶
func (e HealthCheckSpecifierValidationError) Field() string
Field function returns field value.
func (HealthCheckSpecifierValidationError) Key ¶
func (e HealthCheckSpecifierValidationError) Key() bool
Key function returns key value.
func (HealthCheckSpecifierValidationError) Reason ¶
func (e HealthCheckSpecifierValidationError) Reason() string
Reason function returns reason value.
type HealthDiscoveryServiceClient ¶
type HealthDiscoveryServiceClient interface { // 1. Envoy starts up and if its can_healthcheck option in the static // bootstrap config is enabled, sends HealthCheckRequest to the management // server. It supplies its capabilities (which protocol it can health check // with, what zone it resides in, etc.). // 2. In response to (1), the management server designates this Envoy as a // healthchecker to health check a subset of all upstream hosts for a given // cluster (for example upstream Host 1 and Host 2). It streams // HealthCheckSpecifier messages with cluster related configuration for all // clusters this Envoy is designated to health check. Subsequent // HealthCheckSpecifier message will be sent on changes to: // a. Endpoints to health checks // b. Per cluster configuration change // 3. Envoy creates a health probe based on the HealthCheck config and sends // it to endpoint(ip:port) of Host 1 and 2. Based on the HealthCheck // configuration Envoy waits upon the arrival of the probe response and // looks at the content of the response to decide whether the endpoint is // healthy or not. If a response hasn't been received within the timeout // interval, the endpoint health status is considered TIMEOUT. // 4. Envoy reports results back in an EndpointHealthResponse message. // Envoy streams responses as often as the interval configured by the // management server in HealthCheckSpecifier. // 5. The management Server collects health statuses for all endpoints in the // cluster (for all clusters) and uses this information to construct // EndpointDiscoveryResponse messages. // 6. Once Envoy has a list of upstream endpoints to send traffic to, it load // balances traffic to them without additional health checking. It may // use inline healthcheck (i.e. consider endpoint UNHEALTHY if connection // failed to a particular endpoint to account for health status propagation // delay between HDS and EDS). // // By default, can_healthcheck is true. If can_healthcheck is false, Cluster // configuration may not contain HealthCheck message. // TODO(htuch): How is can_healthcheck communicated to CDS to ensure the above // invariant? // TODO(htuch): Add @amb67's diagram. StreamHealthCheck(ctx context.Context, opts ...grpc.CallOption) (HealthDiscoveryService_StreamHealthCheckClient, error) // TODO(htuch): Unlike the gRPC version, there is no stream-based binding of // request/response. Should we add an identifier to the HealthCheckSpecifier // to bind with the response? FetchHealthCheck(ctx context.Context, in *HealthCheckRequestOrEndpointHealthResponse, opts ...grpc.CallOption) (*HealthCheckSpecifier, error) }
HealthDiscoveryServiceClient is the client API for HealthDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewHealthDiscoveryServiceClient ¶
func NewHealthDiscoveryServiceClient(cc grpc.ClientConnInterface) HealthDiscoveryServiceClient
type HealthDiscoveryServiceServer ¶
type HealthDiscoveryServiceServer interface { // 1. Envoy starts up and if its can_healthcheck option in the static // bootstrap config is enabled, sends HealthCheckRequest to the management // server. It supplies its capabilities (which protocol it can health check // with, what zone it resides in, etc.). // 2. In response to (1), the management server designates this Envoy as a // healthchecker to health check a subset of all upstream hosts for a given // cluster (for example upstream Host 1 and Host 2). It streams // HealthCheckSpecifier messages with cluster related configuration for all // clusters this Envoy is designated to health check. Subsequent // HealthCheckSpecifier message will be sent on changes to: // a. Endpoints to health checks // b. Per cluster configuration change // 3. Envoy creates a health probe based on the HealthCheck config and sends // it to endpoint(ip:port) of Host 1 and 2. Based on the HealthCheck // configuration Envoy waits upon the arrival of the probe response and // looks at the content of the response to decide whether the endpoint is // healthy or not. If a response hasn't been received within the timeout // interval, the endpoint health status is considered TIMEOUT. // 4. Envoy reports results back in an EndpointHealthResponse message. // Envoy streams responses as often as the interval configured by the // management server in HealthCheckSpecifier. // 5. The management Server collects health statuses for all endpoints in the // cluster (for all clusters) and uses this information to construct // EndpointDiscoveryResponse messages. // 6. Once Envoy has a list of upstream endpoints to send traffic to, it load // balances traffic to them without additional health checking. It may // use inline healthcheck (i.e. consider endpoint UNHEALTHY if connection // failed to a particular endpoint to account for health status propagation // delay between HDS and EDS). // // By default, can_healthcheck is true. If can_healthcheck is false, Cluster // configuration may not contain HealthCheck message. // TODO(htuch): How is can_healthcheck communicated to CDS to ensure the above // invariant? // TODO(htuch): Add @amb67's diagram. StreamHealthCheck(HealthDiscoveryService_StreamHealthCheckServer) error // TODO(htuch): Unlike the gRPC version, there is no stream-based binding of // request/response. Should we add an identifier to the HealthCheckSpecifier // to bind with the response? FetchHealthCheck(context.Context, *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error) }
HealthDiscoveryServiceServer is the server API for HealthDiscoveryService service.
type HealthDiscoveryService_StreamHealthCheckClient ¶
type HealthDiscoveryService_StreamHealthCheckClient interface { Send(*HealthCheckRequestOrEndpointHealthResponse) error Recv() (*HealthCheckSpecifier, error) grpc.ClientStream }
type HealthDiscoveryService_StreamHealthCheckServer ¶
type HealthDiscoveryService_StreamHealthCheckServer interface { Send(*HealthCheckSpecifier) error Recv() (*HealthCheckRequestOrEndpointHealthResponse, error) grpc.ServerStream }
type LocalityEndpoints ¶
type LocalityEndpoints struct { Locality *v3.Locality `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"` Endpoints []*v31.Endpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"` // contains filtered or unexported fields }
func (*LocalityEndpoints) Descriptor
deprecated
func (*LocalityEndpoints) Descriptor() ([]byte, []int)
Deprecated: Use LocalityEndpoints.ProtoReflect.Descriptor instead.
func (*LocalityEndpoints) GetEndpoints ¶
func (x *LocalityEndpoints) GetEndpoints() []*v31.Endpoint
func (*LocalityEndpoints) GetLocality ¶
func (x *LocalityEndpoints) GetLocality() *v3.Locality
func (*LocalityEndpoints) ProtoMessage ¶
func (*LocalityEndpoints) ProtoMessage()
func (*LocalityEndpoints) ProtoReflect ¶
func (x *LocalityEndpoints) ProtoReflect() protoreflect.Message
func (*LocalityEndpoints) Reset ¶
func (x *LocalityEndpoints) Reset()
func (*LocalityEndpoints) String ¶
func (x *LocalityEndpoints) String() string
func (*LocalityEndpoints) Validate ¶
func (m *LocalityEndpoints) Validate() error
Validate checks the field values on LocalityEndpoints with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*LocalityEndpoints) ValidateAll ¶
func (m *LocalityEndpoints) ValidateAll() error
ValidateAll checks the field values on LocalityEndpoints with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LocalityEndpointsMultiError, or nil if none found.
type LocalityEndpointsHealth ¶
type LocalityEndpointsHealth struct { Locality *v3.Locality `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"` EndpointsHealth []*EndpointHealth `protobuf:"bytes,2,rep,name=endpoints_health,json=endpointsHealth,proto3" json:"endpoints_health,omitempty"` // contains filtered or unexported fields }
Group endpoint health by locality under each cluster.
func (*LocalityEndpointsHealth) Descriptor
deprecated
func (*LocalityEndpointsHealth) Descriptor() ([]byte, []int)
Deprecated: Use LocalityEndpointsHealth.ProtoReflect.Descriptor instead.
func (*LocalityEndpointsHealth) GetEndpointsHealth ¶
func (x *LocalityEndpointsHealth) GetEndpointsHealth() []*EndpointHealth
func (*LocalityEndpointsHealth) GetLocality ¶
func (x *LocalityEndpointsHealth) GetLocality() *v3.Locality
func (*LocalityEndpointsHealth) ProtoMessage ¶
func (*LocalityEndpointsHealth) ProtoMessage()
func (*LocalityEndpointsHealth) ProtoReflect ¶
func (x *LocalityEndpointsHealth) ProtoReflect() protoreflect.Message
func (*LocalityEndpointsHealth) Reset ¶
func (x *LocalityEndpointsHealth) Reset()
func (*LocalityEndpointsHealth) String ¶
func (x *LocalityEndpointsHealth) String() string
func (*LocalityEndpointsHealth) Validate ¶
func (m *LocalityEndpointsHealth) Validate() error
Validate checks the field values on LocalityEndpointsHealth with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*LocalityEndpointsHealth) ValidateAll ¶
func (m *LocalityEndpointsHealth) ValidateAll() error
ValidateAll checks the field values on LocalityEndpointsHealth with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LocalityEndpointsHealthMultiError, or nil if none found.
type LocalityEndpointsHealthMultiError ¶
type LocalityEndpointsHealthMultiError []error
LocalityEndpointsHealthMultiError is an error wrapping multiple validation errors returned by LocalityEndpointsHealth.ValidateAll() if the designated constraints aren't met.
func (LocalityEndpointsHealthMultiError) AllErrors ¶
func (m LocalityEndpointsHealthMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (LocalityEndpointsHealthMultiError) Error ¶
func (m LocalityEndpointsHealthMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type LocalityEndpointsHealthValidationError ¶
type LocalityEndpointsHealthValidationError struct {
// contains filtered or unexported fields
}
LocalityEndpointsHealthValidationError is the validation error returned by LocalityEndpointsHealth.Validate if the designated constraints aren't met.
func (LocalityEndpointsHealthValidationError) Cause ¶
func (e LocalityEndpointsHealthValidationError) Cause() error
Cause function returns cause value.
func (LocalityEndpointsHealthValidationError) Error ¶
func (e LocalityEndpointsHealthValidationError) Error() string
Error satisfies the builtin error interface
func (LocalityEndpointsHealthValidationError) ErrorName ¶
func (e LocalityEndpointsHealthValidationError) ErrorName() string
ErrorName returns error name.
func (LocalityEndpointsHealthValidationError) Field ¶
func (e LocalityEndpointsHealthValidationError) Field() string
Field function returns field value.
func (LocalityEndpointsHealthValidationError) Key ¶
func (e LocalityEndpointsHealthValidationError) Key() bool
Key function returns key value.
func (LocalityEndpointsHealthValidationError) Reason ¶
func (e LocalityEndpointsHealthValidationError) Reason() string
Reason function returns reason value.
type LocalityEndpointsMultiError ¶
type LocalityEndpointsMultiError []error
LocalityEndpointsMultiError is an error wrapping multiple validation errors returned by LocalityEndpoints.ValidateAll() if the designated constraints aren't met.
func (LocalityEndpointsMultiError) AllErrors ¶
func (m LocalityEndpointsMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (LocalityEndpointsMultiError) Error ¶
func (m LocalityEndpointsMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type LocalityEndpointsValidationError ¶
type LocalityEndpointsValidationError struct {
// contains filtered or unexported fields
}
LocalityEndpointsValidationError is the validation error returned by LocalityEndpoints.Validate if the designated constraints aren't met.
func (LocalityEndpointsValidationError) Cause ¶
func (e LocalityEndpointsValidationError) Cause() error
Cause function returns cause value.
func (LocalityEndpointsValidationError) Error ¶
func (e LocalityEndpointsValidationError) Error() string
Error satisfies the builtin error interface
func (LocalityEndpointsValidationError) ErrorName ¶
func (e LocalityEndpointsValidationError) ErrorName() string
ErrorName returns error name.
func (LocalityEndpointsValidationError) Field ¶
func (e LocalityEndpointsValidationError) Field() string
Field function returns field value.
func (LocalityEndpointsValidationError) Key ¶
func (e LocalityEndpointsValidationError) Key() bool
Key function returns key value.
func (LocalityEndpointsValidationError) Reason ¶
func (e LocalityEndpointsValidationError) Reason() string
Reason function returns reason value.
type UnimplementedHealthDiscoveryServiceServer ¶
type UnimplementedHealthDiscoveryServiceServer struct { }
UnimplementedHealthDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck ¶
func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck(context.Context, *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error)
func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck ¶
func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck(HealthDiscoveryService_StreamHealthCheckServer) error