discoveryv2

package
v1.36.4-20230823200325... Latest Latest
Warning

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

Go to latest
Published: unknown License: Apache-2.0 Imports: 13 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_discovery_v2_ads_proto protoreflect.FileDescriptor
View Source
var File_envoy_service_discovery_v2_hds_proto protoreflect.FileDescriptor
View Source
var File_envoy_service_discovery_v2_rtds_proto protoreflect.FileDescriptor
View Source
var File_envoy_service_discovery_v2_sds_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AdsDummy

type AdsDummy 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

func (*AdsDummy) ProtoMessage

func (*AdsDummy) ProtoMessage()

func (*AdsDummy) ProtoReflect

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

func (*AdsDummy) Reset

func (x *AdsDummy) Reset()

func (*AdsDummy) String

func (x *AdsDummy) String() string

type AdsDummy_builder

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

func (AdsDummy_builder) Build

func (b0 AdsDummy_builder) Build() *AdsDummy

type Capability

type Capability struct {
	HealthCheckProtocols []Capability_Protocol `` /* 183-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) Enum

func (Capability_Protocol) Number

func (Capability_Protocol) String

func (x Capability_Protocol) String() string

func (Capability_Protocol) Type

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 ClusterHealthCheck

type ClusterHealthCheck struct {
	ClusterName       string               `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	HealthChecks      []*core.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"`
	// 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.

func (*ClusterHealthCheck) GetClusterName

func (x *ClusterHealthCheck) GetClusterName() string

func (*ClusterHealthCheck) GetHealthChecks

func (x *ClusterHealthCheck) GetHealthChecks() []*core.HealthCheck

func (*ClusterHealthCheck) GetLocalityEndpoints

func (x *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints

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 []*core.HealthCheck)

func (*ClusterHealthCheck) SetLocalityEndpoints

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

func (*ClusterHealthCheck) String

func (x *ClusterHealthCheck) String() string

type ClusterHealthCheck_builder

type ClusterHealthCheck_builder struct {
	ClusterName       string
	HealthChecks      []*core.HealthCheck
	LocalityEndpoints []*LocalityEndpoints
	// contains filtered or unexported fields
}

func (ClusterHealthCheck_builder) Build

type EndpointHealth

type EndpointHealth struct {
	Endpoint     *endpoint.Endpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	HealthStatus core.HealthStatus  `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EndpointHealth) ClearEndpoint

func (x *EndpointHealth) ClearEndpoint()

func (*EndpointHealth) GetEndpoint

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

func (*EndpointHealth) GetHealthStatus

func (x *EndpointHealth) GetHealthStatus() core.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 *endpoint.Endpoint)

func (*EndpointHealth) SetHealthStatus

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

func (*EndpointHealth) String

func (x *EndpointHealth) String() string

type EndpointHealthResponse

type EndpointHealthResponse struct {
	EndpointsHealth []*EndpointHealth `protobuf:"bytes,1,rep,name=endpoints_health,json=endpointsHealth,proto3" json:"endpoints_health,omitempty"`
	// contains filtered or unexported fields
}

func (*EndpointHealthResponse) GetEndpointsHealth

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

func (*EndpointHealthResponse) ProtoMessage

func (*EndpointHealthResponse) ProtoMessage()

func (*EndpointHealthResponse) ProtoReflect

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

func (*EndpointHealthResponse) Reset

func (x *EndpointHealthResponse) Reset()

func (*EndpointHealthResponse) SetEndpointsHealth

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

func (*EndpointHealthResponse) String

func (x *EndpointHealthResponse) String() string

type EndpointHealthResponse_builder

type EndpointHealthResponse_builder struct {
	EndpointsHealth []*EndpointHealth
	// contains filtered or unexported fields
}

func (EndpointHealthResponse_builder) Build

type EndpointHealth_builder

type EndpointHealth_builder struct {
	Endpoint     *endpoint.Endpoint
	HealthStatus core.HealthStatus
	// contains filtered or unexported fields
}

func (EndpointHealth_builder) Build

type HealthCheckRequest

type HealthCheckRequest struct {
	Node       *core.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() *core.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 *core.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 (*HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest

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 (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage

func (*HealthCheckRequestOrEndpointHealthResponse) ProtoReflect

func (*HealthCheckRequestOrEndpointHealthResponse) Reset

func (*HealthCheckRequestOrEndpointHealthResponse) SetEndpointHealthResponse

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

func (*HealthCheckRequestOrEndpointHealthResponse) SetHealthCheckRequest

func (*HealthCheckRequestOrEndpointHealthResponse) 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

type HealthCheckRequest_builder

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

func (HealthCheckRequest_builder) Build

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

type LocalityEndpoints

type LocalityEndpoints struct {
	Locality  *core.Locality       `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"`
	Endpoints []*endpoint.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() []*endpoint.Endpoint

func (*LocalityEndpoints) GetLocality

func (x *LocalityEndpoints) GetLocality() *core.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 []*endpoint.Endpoint)

func (*LocalityEndpoints) SetLocality

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

func (*LocalityEndpoints) String

func (x *LocalityEndpoints) String() string

type LocalityEndpoints_builder

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

func (LocalityEndpoints_builder) Build

type RtdsDummy

type RtdsDummy 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

func (*RtdsDummy) ProtoMessage

func (*RtdsDummy) ProtoMessage()

func (*RtdsDummy) ProtoReflect

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

func (*RtdsDummy) Reset

func (x *RtdsDummy) Reset()

func (*RtdsDummy) String

func (x *RtdsDummy) String() string

type RtdsDummy_builder

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

func (RtdsDummy_builder) Build

func (b0 RtdsDummy_builder) Build() *RtdsDummy

type Runtime

type Runtime struct {

	// Runtime resource name. This makes the Runtime a self-describing xDS
	// resource.
	Name  string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Layer *structpb.Struct `protobuf:"bytes,2,opt,name=layer,proto3" json:"layer,omitempty"`
	// contains filtered or unexported fields
}

RTDS resource type. This describes a layer in the runtime virtual filesystem.

func (*Runtime) ClearLayer

func (x *Runtime) ClearLayer()

func (*Runtime) GetLayer

func (x *Runtime) GetLayer() *structpb.Struct

func (*Runtime) GetName

func (x *Runtime) GetName() string

func (*Runtime) HasLayer

func (x *Runtime) HasLayer() bool

func (*Runtime) ProtoMessage

func (*Runtime) ProtoMessage()

func (*Runtime) ProtoReflect

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

func (*Runtime) Reset

func (x *Runtime) Reset()

func (*Runtime) SetLayer

func (x *Runtime) SetLayer(v *structpb.Struct)

func (*Runtime) SetName

func (x *Runtime) SetName(v string)

func (*Runtime) String

func (x *Runtime) String() string

type Runtime_builder

type Runtime_builder struct {

	// Runtime resource name. This makes the Runtime a self-describing xDS
	// resource.
	Name  string
	Layer *structpb.Struct
	// contains filtered or unexported fields
}

func (Runtime_builder) Build

func (b0 Runtime_builder) Build() *Runtime

type SdsDummy

type SdsDummy 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

func (*SdsDummy) ProtoMessage

func (*SdsDummy) ProtoMessage()

func (*SdsDummy) ProtoReflect

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

func (*SdsDummy) Reset

func (x *SdsDummy) Reset()

func (*SdsDummy) String

func (x *SdsDummy) String() string

type SdsDummy_builder

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

func (SdsDummy_builder) Build

func (b0 SdsDummy_builder) Build() *SdsDummy

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL