healthv3

package
v1.36.2-20240308200653... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 10 Imported by: 4

Documentation

Index

Constants

View Source 
const HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse_case case_HealthCheckRequestOrEndpointHealthResponse_RequestType = 2
View Source 
const HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest_case case_HealthCheckRequestOrEndpointHealthResponse_RequestType = 1
View Source 
const HealthCheckRequestOrEndpointHealthResponse_RequestType_not_set_case case_HealthCheckRequestOrEndpointHealthResponse_RequestType = 0

Variables

View Source 
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.

View Source 
var File_envoy_service_health_v3_hds_proto protoreflect.FileDescriptor

Functions

This section is empty.

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

func (x *Capability) SetHealthCheckProtocols(v []Capability_Protocol)

func (*Capability) String 

func (x *Capability) String() string

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

type Capability_builder struct {
	HealthCheckProtocols []Capability_Protocol
	// contains filtered or unexported fields
}

func (Capability_builder) Build 

func (b0 Capability_builder) Build() *Capability

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

func (x *ClusterEndpointsHealth) SetClusterName(v string)

func (*ClusterEndpointsHealth) SetLocalityEndpointsHealth 

func (x *ClusterEndpointsHealth) SetLocalityEndpointsHealth(v []*LocalityEndpointsHealth)

func (*ClusterEndpointsHealth) String 

func (x *ClusterEndpointsHealth) String() string

type ClusterEndpointsHealth_builder 

type ClusterEndpointsHealth_builder struct {
	ClusterName             string
	LocalityEndpointsHealth []*LocalityEndpointsHealth
	// contains filtered or unexported fields
}

func (ClusterEndpointsHealth_builder) Build 

func (b0 ClusterEndpointsHealth_builder) Build() *ClusterEndpointsHealth

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

func (x *ClusterHealthCheck) ClearUpstreamBindConfig()

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

func (x *ClusterHealthCheck) HasUpstreamBindConfig() bool

func (*ClusterHealthCheck) ProtoMessage 

func (*ClusterHealthCheck) ProtoMessage()

func (*ClusterHealthCheck) ProtoReflect 

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

func (*ClusterHealthCheck) Reset 

func (x *ClusterHealthCheck) Reset()

func (*ClusterHealthCheck) SetClusterName 

func (x *ClusterHealthCheck) SetClusterName(v string)

func (*ClusterHealthCheck) SetHealthChecks 

func (x *ClusterHealthCheck) SetHealthChecks(v []*v3.HealthCheck)

func (*ClusterHealthCheck) SetLocalityEndpoints 

func (x *ClusterHealthCheck) SetLocalityEndpoints(v []*LocalityEndpoints)

func (*ClusterHealthCheck) SetTransportSocketMatches 

func (x *ClusterHealthCheck) SetTransportSocketMatches(v []*v32.Cluster_TransportSocketMatch)

func (*ClusterHealthCheck) SetUpstreamBindConfig 

func (x *ClusterHealthCheck) SetUpstreamBindConfig(v *v3.BindConfig)

func (*ClusterHealthCheck) String 

func (x *ClusterHealthCheck) String() string

type ClusterHealthCheck_builder 

type ClusterHealthCheck_builder struct {
	ClusterName       string
	HealthChecks      []*v3.HealthCheck
	LocalityEndpoints []*LocalityEndpoints
	// 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
	// Optional configuration used to bind newly established upstream connections.
	// If the address and port are empty, no bind will be performed.
	UpstreamBindConfig *v3.BindConfig
	// contains filtered or unexported fields
}

func (ClusterHealthCheck_builder) Build 

func (b0 ClusterHealthCheck_builder) Build() *ClusterHealthCheck

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

func (x *EndpointHealth) ClearEndpoint()

func (*EndpointHealth) GetEndpoint 

func (x *EndpointHealth) GetEndpoint() *v31.Endpoint

func (*EndpointHealth) GetHealthStatus 

func (x *EndpointHealth) GetHealthStatus() v3.HealthStatus

func (*EndpointHealth) HasEndpoint 

func (x *EndpointHealth) HasEndpoint() bool

func (*EndpointHealth) ProtoMessage 

func (*EndpointHealth) ProtoMessage()

func (*EndpointHealth) ProtoReflect 

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

func (*EndpointHealth) Reset 

func (x *EndpointHealth) Reset()

func (*EndpointHealth) SetEndpoint 

func (x *EndpointHealth) SetEndpoint(v *v31.Endpoint)

func (*EndpointHealth) SetHealthStatus 

func (x *EndpointHealth) SetHealthStatus(v v3.HealthStatus)

func (*EndpointHealth) String 

func (x *EndpointHealth) String() string

type EndpointHealthResponse 

type EndpointHealthResponse struct {

	// Deprecated - Flat list of endpoint health information.
	//
	// Deprecated: Marked as deprecated in envoy/service/health/v3/hds.proto.
	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) GetClusterEndpointsHealth 

func (x *EndpointHealthResponse) GetClusterEndpointsHealth() []*ClusterEndpointsHealth

func (*EndpointHealthResponse) GetEndpointsHealth deprecated 

func (x *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth

Deprecated: Marked as deprecated in envoy/service/health/v3/hds.proto.

func (*EndpointHealthResponse) ProtoMessage 

func (*EndpointHealthResponse) ProtoMessage()

func (*EndpointHealthResponse) ProtoReflect 

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

func (*EndpointHealthResponse) Reset 

func (x *EndpointHealthResponse) Reset()

func (*EndpointHealthResponse) SetClusterEndpointsHealth 

func (x *EndpointHealthResponse) SetClusterEndpointsHealth(v []*ClusterEndpointsHealth)

func (*EndpointHealthResponse) SetEndpointsHealth deprecated 

func (x *EndpointHealthResponse) SetEndpointsHealth(v []*EndpointHealth)

Deprecated: Marked as deprecated in envoy/service/health/v3/hds.proto.

func (*EndpointHealthResponse) String 

func (x *EndpointHealthResponse) String() string

type EndpointHealthResponse_builder 

type EndpointHealthResponse_builder struct {

	// Deprecated - Flat list of endpoint health information.
	//
	// Deprecated: Marked as deprecated in envoy/service/health/v3/hds.proto.
	EndpointsHealth []*EndpointHealth
	// Organize Endpoint health information by cluster.
	ClusterEndpointsHealth []*ClusterEndpointsHealth
	// contains filtered or unexported fields
}

func (EndpointHealthResponse_builder) Build 

func (b0 EndpointHealthResponse_builder) Build() *EndpointHealthResponse

type EndpointHealth_builder 

type EndpointHealth_builder struct {
	Endpoint     *v31.Endpoint
	HealthStatus v3.HealthStatus
	// contains filtered or unexported fields
}

func (EndpointHealth_builder) Build 

func (b0 EndpointHealth_builder) Build() *EndpointHealth

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

func (*HdsDummy) ProtoMessage()

func (*HdsDummy) ProtoReflect 

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

func (*HdsDummy) Reset 

func (x *HdsDummy) Reset()

func (*HdsDummy) String 

func (x *HdsDummy) String() string

type HdsDummy_builder 

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

func (HdsDummy_builder) Build 

func (b0 HdsDummy_builder) Build() *HdsDummy

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

func (x *HealthCheckRequest) ClearCapability()

func (*HealthCheckRequest) ClearNode 

func (x *HealthCheckRequest) ClearNode()

func (*HealthCheckRequest) GetCapability 

func (x *HealthCheckRequest) GetCapability() *Capability

func (*HealthCheckRequest) GetNode 

func (x *HealthCheckRequest) GetNode() *v3.Node

func (*HealthCheckRequest) HasCapability 

func (x *HealthCheckRequest) HasCapability() bool

func (*HealthCheckRequest) HasNode 

func (x *HealthCheckRequest) HasNode() bool

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect 

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

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) SetCapability 

func (x *HealthCheckRequest) SetCapability(v *Capability)

func (*HealthCheckRequest) SetNode 

func (x *HealthCheckRequest) SetNode(v *v3.Node)

func (*HealthCheckRequest) String 

func (x *HealthCheckRequest) String() string

type HealthCheckRequestOrEndpointHealthResponse 

type HealthCheckRequestOrEndpointHealthResponse struct {

	// Types that are valid to be assigned to RequestType:
	//
	//	*HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest
	//	*HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse
	RequestType isHealthCheckRequestOrEndpointHealthResponse_RequestType `protobuf_oneof:"request_type"`
	// contains filtered or unexported fields
}

func (*HealthCheckRequestOrEndpointHealthResponse) ClearEndpointHealthResponse 

func (x *HealthCheckRequestOrEndpointHealthResponse) ClearEndpointHealthResponse()

func (*HealthCheckRequestOrEndpointHealthResponse) ClearHealthCheckRequest 

func (x *HealthCheckRequestOrEndpointHealthResponse) ClearHealthCheckRequest()

func (*HealthCheckRequestOrEndpointHealthResponse) ClearRequestType 

func (x *HealthCheckRequestOrEndpointHealthResponse) ClearRequestType()

func (*HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse 

func (x *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse

func (*HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest 

func (x *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest

func (*HealthCheckRequestOrEndpointHealthResponse) GetRequestType 

func (x *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType

func (*HealthCheckRequestOrEndpointHealthResponse) HasEndpointHealthResponse 

func (x *HealthCheckRequestOrEndpointHealthResponse) HasEndpointHealthResponse() bool

func (*HealthCheckRequestOrEndpointHealthResponse) HasHealthCheckRequest 

func (x *HealthCheckRequestOrEndpointHealthResponse) HasHealthCheckRequest() bool

func (*HealthCheckRequestOrEndpointHealthResponse) HasRequestType 

func (x *HealthCheckRequestOrEndpointHealthResponse) HasRequestType() bool

func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage 

func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()

func (*HealthCheckRequestOrEndpointHealthResponse) ProtoReflect 

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

func (*HealthCheckRequestOrEndpointHealthResponse) Reset 

func (x *HealthCheckRequestOrEndpointHealthResponse) Reset()

func (*HealthCheckRequestOrEndpointHealthResponse) SetEndpointHealthResponse 

func (x *HealthCheckRequestOrEndpointHealthResponse) SetEndpointHealthResponse(v *EndpointHealthResponse)

func (*HealthCheckRequestOrEndpointHealthResponse) SetHealthCheckRequest 

func (x *HealthCheckRequestOrEndpointHealthResponse) SetHealthCheckRequest(v *HealthCheckRequest)

func (*HealthCheckRequestOrEndpointHealthResponse) String 

func (x *HealthCheckRequestOrEndpointHealthResponse) String() string

func (*HealthCheckRequestOrEndpointHealthResponse) WhichRequestType 

func (x *HealthCheckRequestOrEndpointHealthResponse) WhichRequestType() case_HealthCheckRequestOrEndpointHealthResponse_RequestType

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 HealthCheckRequestOrEndpointHealthResponse_builder 

type HealthCheckRequestOrEndpointHealthResponse_builder struct {

	// Fields of oneof RequestType:
	HealthCheckRequest     *HealthCheckRequest
	EndpointHealthResponse *EndpointHealthResponse
	// contains filtered or unexported fields
}

func (HealthCheckRequestOrEndpointHealthResponse_builder) Build 

func (b0 HealthCheckRequestOrEndpointHealthResponse_builder) Build() *HealthCheckRequestOrEndpointHealthResponse

type HealthCheckRequest_builder 

type HealthCheckRequest_builder struct {
	Node       *v3.Node
	Capability *Capability
	// contains filtered or unexported fields
}

func (HealthCheckRequest_builder) Build 

func (b0 HealthCheckRequest_builder) Build() *HealthCheckRequest

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

func (x *HealthCheckSpecifier) ClearInterval()

func (*HealthCheckSpecifier) GetClusterHealthChecks 

func (x *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck

func (*HealthCheckSpecifier) GetInterval 

func (x *HealthCheckSpecifier) GetInterval() *durationpb.Duration

func (*HealthCheckSpecifier) HasInterval 

func (x *HealthCheckSpecifier) HasInterval() bool

func (*HealthCheckSpecifier) ProtoMessage 

func (*HealthCheckSpecifier) ProtoMessage()

func (*HealthCheckSpecifier) ProtoReflect 

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

func (*HealthCheckSpecifier) Reset 

func (x *HealthCheckSpecifier) Reset()

func (*HealthCheckSpecifier) SetClusterHealthChecks 

func (x *HealthCheckSpecifier) SetClusterHealthChecks(v []*ClusterHealthCheck)

func (*HealthCheckSpecifier) SetInterval 

func (x *HealthCheckSpecifier) SetInterval(v *durationpb.Duration)

func (*HealthCheckSpecifier) String 

func (x *HealthCheckSpecifier) String() string

type HealthCheckSpecifier_builder 

type HealthCheckSpecifier_builder struct {
	ClusterHealthChecks []*ClusterHealthCheck
	// The default is 1 second.
	Interval *durationpb.Duration
	// contains filtered or unexported fields
}

func (HealthCheckSpecifier_builder) Build 

func (b0 HealthCheckSpecifier_builder) Build() *HealthCheckSpecifier

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

func (x *LocalityEndpoints) ClearLocality()

func (*LocalityEndpoints) GetEndpoints 

func (x *LocalityEndpoints) GetEndpoints() []*v31.Endpoint

func (*LocalityEndpoints) GetLocality 

func (x *LocalityEndpoints) GetLocality() *v3.Locality

func (*LocalityEndpoints) HasLocality 

func (x *LocalityEndpoints) HasLocality() bool

func (*LocalityEndpoints) ProtoMessage 

func (*LocalityEndpoints) ProtoMessage()

func (*LocalityEndpoints) ProtoReflect 

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

func (*LocalityEndpoints) Reset 

func (x *LocalityEndpoints) Reset()

func (*LocalityEndpoints) SetEndpoints 

func (x *LocalityEndpoints) SetEndpoints(v []*v31.Endpoint)

func (*LocalityEndpoints) SetLocality 

func (x *LocalityEndpoints) SetLocality(v *v3.Locality)

func (*LocalityEndpoints) String 

func (x *LocalityEndpoints) String() string

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

func (x *LocalityEndpointsHealth) ClearLocality()

func (*LocalityEndpointsHealth) GetEndpointsHealth 

func (x *LocalityEndpointsHealth) GetEndpointsHealth() []*EndpointHealth

func (*LocalityEndpointsHealth) GetLocality 

func (x *LocalityEndpointsHealth) GetLocality() *v3.Locality

func (*LocalityEndpointsHealth) HasLocality 

func (x *LocalityEndpointsHealth) HasLocality() bool

func (*LocalityEndpointsHealth) ProtoMessage 

func (*LocalityEndpointsHealth) ProtoMessage()

func (*LocalityEndpointsHealth) ProtoReflect 

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

func (*LocalityEndpointsHealth) Reset 

func (x *LocalityEndpointsHealth) Reset()

func (*LocalityEndpointsHealth) SetEndpointsHealth 

func (x *LocalityEndpointsHealth) SetEndpointsHealth(v []*EndpointHealth)

func (*LocalityEndpointsHealth) SetLocality 

func (x *LocalityEndpointsHealth) SetLocality(v *v3.Locality)

func (*LocalityEndpointsHealth) String 

func (x *LocalityEndpointsHealth) String() string

type LocalityEndpointsHealth_builder 

type LocalityEndpointsHealth_builder struct {
	Locality        *v3.Locality
	EndpointsHealth []*EndpointHealth
	// contains filtered or unexported fields
}

func (LocalityEndpointsHealth_builder) Build 

func (b0 LocalityEndpointsHealth_builder) Build() *LocalityEndpointsHealth

type LocalityEndpoints_builder 

type LocalityEndpoints_builder struct {
	Locality  *v3.Locality
	Endpoints []*v31.Endpoint
	// contains filtered or unexported fields
}

func (LocalityEndpoints_builder) Build 

func (b0 LocalityEndpoints_builder) Build() *LocalityEndpoints

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.