Versions in this module Expand all Collapse all v0 v0.9.82 Jan 31, 2021 Changes in this version + var Capability_Protocol_name = map[int32]string + var Capability_Protocol_value = map[string]int32 + var File_envoy_service_health_v3_hds_proto protoreflect.FileDescriptor + func RegisterHealthDiscoveryServiceServer(s *grpc.Server, srv HealthDiscoveryServiceServer) + type Capability struct + HealthCheckProtocols []Capability_Protocol + func (*Capability) Descriptor() ([]byte, []int) + func (*Capability) ProtoMessage() + func (m *Capability) Validate() error + func (x *Capability) GetHealthCheckProtocols() []Capability_Protocol + func (x *Capability) ProtoReflect() protoreflect.Message + func (x *Capability) Reset() + func (x *Capability) String() string + type CapabilityValidationError struct + func (e CapabilityValidationError) Cause() error + func (e CapabilityValidationError) Error() string + func (e CapabilityValidationError) ErrorName() string + func (e CapabilityValidationError) Field() string + func (e CapabilityValidationError) Key() bool + func (e CapabilityValidationError) Reason() string + type Capability_Protocol int32 + const Capability_HTTP + const Capability_REDIS + const Capability_TCP + func (Capability_Protocol) Descriptor() protoreflect.EnumDescriptor + func (Capability_Protocol) EnumDescriptor() ([]byte, []int) + func (Capability_Protocol) Type() protoreflect.EnumType + func (x Capability_Protocol) Enum() *Capability_Protocol + func (x Capability_Protocol) Number() protoreflect.EnumNumber + func (x Capability_Protocol) String() string + type ClusterEndpointsHealth struct + ClusterName string + LocalityEndpointsHealth []*LocalityEndpointsHealth + func (*ClusterEndpointsHealth) Descriptor() ([]byte, []int) + func (*ClusterEndpointsHealth) ProtoMessage() + func (m *ClusterEndpointsHealth) Validate() error + func (x *ClusterEndpointsHealth) GetClusterName() string + func (x *ClusterEndpointsHealth) GetLocalityEndpointsHealth() []*LocalityEndpointsHealth + func (x *ClusterEndpointsHealth) ProtoReflect() protoreflect.Message + func (x *ClusterEndpointsHealth) Reset() + func (x *ClusterEndpointsHealth) String() string + type ClusterEndpointsHealthValidationError struct + 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 struct + ClusterName string + HealthChecks []*v3.HealthCheck + LocalityEndpoints []*LocalityEndpoints + TransportSocketMatches []*v32.Cluster_TransportSocketMatch + func (*ClusterHealthCheck) Descriptor() ([]byte, []int) + func (*ClusterHealthCheck) ProtoMessage() + func (m *ClusterHealthCheck) Validate() error + 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) ProtoReflect() protoreflect.Message + func (x *ClusterHealthCheck) Reset() + func (x *ClusterHealthCheck) String() string + type ClusterHealthCheckValidationError struct + 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 struct + Endpoint *v31.Endpoint + HealthStatus v3.HealthStatus + func (*EndpointHealth) Descriptor() ([]byte, []int) + func (*EndpointHealth) ProtoMessage() + func (m *EndpointHealth) Validate() error + func (x *EndpointHealth) GetEndpoint() *v31.Endpoint + func (x *EndpointHealth) GetHealthStatus() v3.HealthStatus + func (x *EndpointHealth) ProtoReflect() protoreflect.Message + func (x *EndpointHealth) Reset() + func (x *EndpointHealth) String() string + type EndpointHealthResponse struct + ClusterEndpointsHealth []*ClusterEndpointsHealth + EndpointsHealth []*EndpointHealth + func (*EndpointHealthResponse) Descriptor() ([]byte, []int) + func (*EndpointHealthResponse) ProtoMessage() + func (m *EndpointHealthResponse) Validate() error + func (x *EndpointHealthResponse) GetClusterEndpointsHealth() []*ClusterEndpointsHealth + func (x *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth + func (x *EndpointHealthResponse) ProtoReflect() protoreflect.Message + func (x *EndpointHealthResponse) Reset() + func (x *EndpointHealthResponse) String() string + type EndpointHealthResponseValidationError struct + 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 struct + 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 HealthCheckRequest struct + Capability *Capability + Node *v3.Node + func (*HealthCheckRequest) Descriptor() ([]byte, []int) + func (*HealthCheckRequest) ProtoMessage() + func (m *HealthCheckRequest) Validate() error + func (x *HealthCheckRequest) GetCapability() *Capability + func (x *HealthCheckRequest) GetNode() *v3.Node + func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message + func (x *HealthCheckRequest) Reset() + func (x *HealthCheckRequest) String() string + type HealthCheckRequestOrEndpointHealthResponse struct + RequestType isHealthCheckRequestOrEndpointHealthResponse_RequestType + func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor() ([]byte, []int) + func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage() + func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType + func (m *HealthCheckRequestOrEndpointHealthResponse) Validate() error + func (x *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse + func (x *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest + func (x *HealthCheckRequestOrEndpointHealthResponse) ProtoReflect() protoreflect.Message + func (x *HealthCheckRequestOrEndpointHealthResponse) Reset() + func (x *HealthCheckRequestOrEndpointHealthResponse) String() string + type HealthCheckRequestOrEndpointHealthResponseValidationError struct + 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 struct + EndpointHealthResponse *EndpointHealthResponse + type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest struct + HealthCheckRequest *HealthCheckRequest + type HealthCheckRequestValidationError struct + 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 struct + ClusterHealthChecks []*ClusterHealthCheck + Interval *duration.Duration + func (*HealthCheckSpecifier) Descriptor() ([]byte, []int) + func (*HealthCheckSpecifier) ProtoMessage() + func (m *HealthCheckSpecifier) Validate() error + func (x *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck + func (x *HealthCheckSpecifier) GetInterval() *duration.Duration + func (x *HealthCheckSpecifier) ProtoReflect() protoreflect.Message + func (x *HealthCheckSpecifier) Reset() + func (x *HealthCheckSpecifier) String() string + type HealthCheckSpecifierValidationError struct + 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 interface + FetchHealthCheck func(ctx context.Context, in *HealthCheckRequestOrEndpointHealthResponse, ...) (*HealthCheckSpecifier, error) + StreamHealthCheck func(ctx context.Context, opts ...grpc.CallOption) (HealthDiscoveryService_StreamHealthCheckClient, error) + func NewHealthDiscoveryServiceClient(cc grpc.ClientConnInterface) HealthDiscoveryServiceClient + type HealthDiscoveryServiceServer interface + FetchHealthCheck func(context.Context, *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error) + StreamHealthCheck func(HealthDiscoveryService_StreamHealthCheckServer) error + type HealthDiscoveryService_StreamHealthCheckClient interface + Recv func() (*HealthCheckSpecifier, error) + Send func(*HealthCheckRequestOrEndpointHealthResponse) error + type HealthDiscoveryService_StreamHealthCheckServer interface + Recv func() (*HealthCheckRequestOrEndpointHealthResponse, error) + Send func(*HealthCheckSpecifier) error + type LocalityEndpoints struct + Endpoints []*v31.Endpoint + Locality *v3.Locality + func (*LocalityEndpoints) Descriptor() ([]byte, []int) + func (*LocalityEndpoints) ProtoMessage() + func (m *LocalityEndpoints) Validate() error + func (x *LocalityEndpoints) GetEndpoints() []*v31.Endpoint + func (x *LocalityEndpoints) GetLocality() *v3.Locality + func (x *LocalityEndpoints) ProtoReflect() protoreflect.Message + func (x *LocalityEndpoints) Reset() + func (x *LocalityEndpoints) String() string + type LocalityEndpointsHealth struct + EndpointsHealth []*EndpointHealth + Locality *v3.Locality + func (*LocalityEndpointsHealth) Descriptor() ([]byte, []int) + func (*LocalityEndpointsHealth) ProtoMessage() + func (m *LocalityEndpointsHealth) Validate() error + func (x *LocalityEndpointsHealth) GetEndpointsHealth() []*EndpointHealth + func (x *LocalityEndpointsHealth) GetLocality() *v3.Locality + func (x *LocalityEndpointsHealth) ProtoReflect() protoreflect.Message + func (x *LocalityEndpointsHealth) Reset() + func (x *LocalityEndpointsHealth) String() string + type LocalityEndpointsHealthValidationError struct + 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 LocalityEndpointsValidationError struct + 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 struct + func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck(context.Context, *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error) + func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck(HealthDiscoveryService_StreamHealthCheckServer) error