v2

package
v0.0.0-...-113c6ea Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2019 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package v2 is a generated protocol buffer package.

It is generated from these files: 

envoy/service/discovery/v2/ads.proto
envoy/service/discovery/v2/hds.proto
envoy/service/discovery/v2/sds.proto

It has these top-level messages: 

AdsDummy
Capability
HealthCheckRequest
EndpointHealth
EndpointHealthResponse
HealthCheckRequestOrEndpointHealthResponse
LocalityEndpoints
ClusterHealthCheck
HealthCheckSpecifier
SdsDummy

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAds = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAds   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthHds = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHds   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSds = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSds   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Capability_Protocol_name = map[int32]string{
	0: "HTTP",
	1: "TCP",
	2: "REDIS",
}
View Source 
var Capability_Protocol_value = map[string]int32{
	"HTTP":  0,
	"TCP":   1,
	"REDIS": 2,
}

Functions

func RegisterAggregatedDiscoveryServiceServer 

func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer)

func RegisterHealthDiscoveryServiceServer 

func RegisterHealthDiscoveryServiceServer(s *grpc.Server, srv HealthDiscoveryServiceServer)

func RegisterSecretDiscoveryServiceServer 

func RegisterSecretDiscoveryServiceServer(s *grpc.Server, srv SecretDiscoveryServiceServer)

Types

type AdsDummy 

type AdsDummy struct {
}

[#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing services: https://github.com/google/protobuf/issues/4221

func (*AdsDummy) Descriptor 

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

func (*AdsDummy) Marshal 

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

func (*AdsDummy) MarshalTo 

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

func (*AdsDummy) ProtoMessage 

func (*AdsDummy) ProtoMessage()

func (*AdsDummy) Reset 

func (m *AdsDummy) Reset()

func (*AdsDummy) Size 

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

func (*AdsDummy) String 

func (m *AdsDummy) String() string

func (*AdsDummy) Unmarshal 

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

func (*AdsDummy) Validate 

func (m *AdsDummy) Validate() error

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

type AdsDummyValidationError 

type AdsDummyValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

AdsDummyValidationError is the validation error returned by AdsDummy.Validate if the designated constraints aren't met.

func (AdsDummyValidationError) Error 

func (e AdsDummyValidationError) Error() string

Error satisfies the builtin error interface

type AggregatedDiscoveryServiceClient 

type AggregatedDiscoveryServiceClient interface {
	// This is a gRPC-only API.
	StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error)
	IncrementalAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_IncrementalAggregatedResourcesClient, error)
}

func NewAggregatedDiscoveryServiceClient 

func NewAggregatedDiscoveryServiceClient(cc *grpc.ClientConn) AggregatedDiscoveryServiceClient

type AggregatedDiscoveryServiceServer 

type AggregatedDiscoveryServiceServer interface {
	// This is a gRPC-only API.
	StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
	IncrementalAggregatedResources(AggregatedDiscoveryService_IncrementalAggregatedResourcesServer) error
}

type AggregatedDiscoveryService_IncrementalAggregatedResourcesClient 

type AggregatedDiscoveryService_IncrementalAggregatedResourcesClient interface {
	Send(*envoy_api_v2.IncrementalDiscoveryRequest) error
	Recv() (*envoy_api_v2.IncrementalDiscoveryResponse, error)
	grpc.ClientStream
}

type AggregatedDiscoveryService_IncrementalAggregatedResourcesServer 

type AggregatedDiscoveryService_IncrementalAggregatedResourcesServer interface {
	Send(*envoy_api_v2.IncrementalDiscoveryResponse) error
	Recv() (*envoy_api_v2.IncrementalDiscoveryRequest, error)
	grpc.ServerStream
}

type AggregatedDiscoveryService_StreamAggregatedResourcesClient 

type AggregatedDiscoveryService_StreamAggregatedResourcesClient interface {
	Send(*envoy_api_v2.DiscoveryRequest) error
	Recv() (*envoy_api_v2.DiscoveryResponse, error)
	grpc.ClientStream
}

type AggregatedDiscoveryService_StreamAggregatedResourcesServer 

type AggregatedDiscoveryService_StreamAggregatedResourcesServer interface {
	Send(*envoy_api_v2.DiscoveryResponse) error
	Recv() (*envoy_api_v2.DiscoveryRequest, error)
	grpc.ServerStream
}

type Capability 

type Capability struct {
	HealthCheckProtocol []Capability_Protocol `` /* 173-byte string literal not displayed */
}

Defines supported protocols etc, so the management server can assign proper endpoints to healthcheck.

func (*Capability) Descriptor 

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

func (*Capability) GetHealthCheckProtocol 

func (m *Capability) GetHealthCheckProtocol() []Capability_Protocol

func (*Capability) Marshal 

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

func (*Capability) MarshalTo 

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

func (*Capability) ProtoMessage 

func (*Capability) ProtoMessage()

func (*Capability) Reset 

func (m *Capability) Reset()

func (*Capability) Size 

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

func (*Capability) String 

func (m *Capability) String() string

func (*Capability) Unmarshal 

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

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, an error is returned.

type CapabilityValidationError 

type CapabilityValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

CapabilityValidationError is the validation error returned by Capability.Validate if the designated constraints aren't met.

func (CapabilityValidationError) Error 

func (e CapabilityValidationError) Error() string

Error satisfies the builtin error interface

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

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

func (Capability_Protocol) String 

func (x Capability_Protocol) String() string

type ClusterHealthCheck 

type ClusterHealthCheck struct {
	ClusterName  string                            `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	HealthChecks []*envoy_api_v2_core1.HealthCheck `protobuf:"bytes,2,rep,name=health_checks,json=healthChecks" json:"health_checks,omitempty"`
	Endpoints    []*LocalityEndpoints              `protobuf:"bytes,3,rep,name=endpoints" json:"endpoints,omitempty"`
}

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

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

func (*ClusterHealthCheck) GetClusterName 

func (m *ClusterHealthCheck) GetClusterName() string

func (*ClusterHealthCheck) GetEndpoints 

func (m *ClusterHealthCheck) GetEndpoints() []*LocalityEndpoints

func (*ClusterHealthCheck) GetHealthChecks 

func (m *ClusterHealthCheck) GetHealthChecks() []*envoy_api_v2_core1.HealthCheck

func (*ClusterHealthCheck) Marshal 

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

func (*ClusterHealthCheck) MarshalTo 

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

func (*ClusterHealthCheck) ProtoMessage 

func (*ClusterHealthCheck) ProtoMessage()

func (*ClusterHealthCheck) Reset 

func (m *ClusterHealthCheck) Reset()

func (*ClusterHealthCheck) Size 

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

func (*ClusterHealthCheck) String 

func (m *ClusterHealthCheck) String() string

func (*ClusterHealthCheck) Unmarshal 

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

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, an error is returned.

type ClusterHealthCheckValidationError 

type ClusterHealthCheckValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

ClusterHealthCheckValidationError is the validation error returned by ClusterHealthCheck.Validate if the designated constraints aren't met.

func (ClusterHealthCheckValidationError) Error 

func (e ClusterHealthCheckValidationError) Error() string

Error satisfies the builtin error interface

type EndpointHealth 

type EndpointHealth struct {
	Endpoint     *envoy_api_v2_endpoint.Endpoint `protobuf:"bytes,1,opt,name=endpoint" json:"endpoint,omitempty"`
	HealthStatus envoy_api_v2_core1.HealthStatus `` /* 134-byte string literal not displayed */
}

func (*EndpointHealth) Descriptor 

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

func (*EndpointHealth) GetEndpoint 

func (m *EndpointHealth) GetEndpoint() *envoy_api_v2_endpoint.Endpoint

func (*EndpointHealth) GetHealthStatus 

func (m *EndpointHealth) GetHealthStatus() envoy_api_v2_core1.HealthStatus

func (*EndpointHealth) Marshal 

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

func (*EndpointHealth) MarshalTo 

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

func (*EndpointHealth) ProtoMessage 

func (*EndpointHealth) ProtoMessage()

func (*EndpointHealth) Reset 

func (m *EndpointHealth) Reset()

func (*EndpointHealth) Size 

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

func (*EndpointHealth) String 

func (m *EndpointHealth) String() string

func (*EndpointHealth) Unmarshal 

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

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, an error is returned.

type EndpointHealthResponse 

type EndpointHealthResponse struct {
	EndpointsHealth []*EndpointHealth `protobuf:"bytes,1,rep,name=endpoints_health,json=endpointsHealth" json:"endpoints_health,omitempty"`
}

func (*EndpointHealthResponse) Descriptor 

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

func (*EndpointHealthResponse) GetEndpointsHealth 

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

func (*EndpointHealthResponse) Marshal 

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

func (*EndpointHealthResponse) MarshalTo 

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

func (*EndpointHealthResponse) ProtoMessage 

func (*EndpointHealthResponse) ProtoMessage()

func (*EndpointHealthResponse) Reset 

func (m *EndpointHealthResponse) Reset()

func (*EndpointHealthResponse) Size 

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

func (*EndpointHealthResponse) String 

func (m *EndpointHealthResponse) String() string

func (*EndpointHealthResponse) Unmarshal 

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

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, an error is returned.

type EndpointHealthResponseValidationError 

type EndpointHealthResponseValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

EndpointHealthResponseValidationError is the validation error returned by EndpointHealthResponse.Validate if the designated constraints aren't met.

func (EndpointHealthResponseValidationError) Error 

func (e EndpointHealthResponseValidationError) Error() string

Error satisfies the builtin error interface

type EndpointHealthValidationError 

type EndpointHealthValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

EndpointHealthValidationError is the validation error returned by EndpointHealth.Validate if the designated constraints aren't met.

func (EndpointHealthValidationError) Error 

func (e EndpointHealthValidationError) Error() string

Error satisfies the builtin error interface

type HealthCheckRequest 

type HealthCheckRequest struct {
	Node       *envoy_api_v2_core.Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
	Capability *Capability             `protobuf:"bytes,2,opt,name=capability" json:"capability,omitempty"`
}

func (*HealthCheckRequest) Descriptor 

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

func (*HealthCheckRequest) GetCapability 

func (m *HealthCheckRequest) GetCapability() *Capability

func (*HealthCheckRequest) GetNode 

func (m *HealthCheckRequest) GetNode() *envoy_api_v2_core.Node

func (*HealthCheckRequest) Marshal 

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

func (*HealthCheckRequest) MarshalTo 

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

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset 

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) Size 

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

func (*HealthCheckRequest) String 

func (m *HealthCheckRequest) String() string

func (*HealthCheckRequest) Unmarshal 

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

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, an error is returned.

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"`
}

func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor 

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

func (*HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse 

func (m *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse

func (*HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest 

func (m *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest

func (*HealthCheckRequestOrEndpointHealthResponse) GetRequestType 

func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType

func (*HealthCheckRequestOrEndpointHealthResponse) Marshal 

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

func (*HealthCheckRequestOrEndpointHealthResponse) MarshalTo 

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

func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage 

func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()

func (*HealthCheckRequestOrEndpointHealthResponse) Reset 

func (m *HealthCheckRequestOrEndpointHealthResponse) Reset()

func (*HealthCheckRequestOrEndpointHealthResponse) Size 

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

func (*HealthCheckRequestOrEndpointHealthResponse) String 

func (m *HealthCheckRequestOrEndpointHealthResponse) String() string

func (*HealthCheckRequestOrEndpointHealthResponse) Unmarshal 

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

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, an error is returned.

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_OneofFuncs 

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

XXX_OneofFuncs is for the internal use of the proto package.

type HealthCheckRequestOrEndpointHealthResponseValidationError 

type HealthCheckRequestOrEndpointHealthResponseValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

HealthCheckRequestOrEndpointHealthResponseValidationError is the validation error returned by HealthCheckRequestOrEndpointHealthResponse.Validate if the designated constraints aren't met.

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Error 

func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Error() string

Error satisfies the builtin error interface

type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse 

type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse struct {
	EndpointHealthResponse *EndpointHealthResponse `protobuf:"bytes,2,opt,name=endpoint_health_response,json=endpointHealthResponse,oneof"`
}

func (*HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse) MarshalTo 

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

func (*HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse) Size 

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

type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest 

type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest struct {
	HealthCheckRequest *HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,oneof"`
}

func (*HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest) MarshalTo 

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

func (*HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest) Size 

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

type HealthCheckRequestValidationError 

type HealthCheckRequestValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

HealthCheckRequestValidationError is the validation error returned by HealthCheckRequest.Validate if the designated constraints aren't met.

func (HealthCheckRequestValidationError) Error 

func (e HealthCheckRequestValidationError) Error() string

Error satisfies the builtin error interface

type HealthCheckSpecifier 

type HealthCheckSpecifier struct {
	HealthCheck []*ClusterHealthCheck `protobuf:"bytes,1,rep,name=health_check,json=healthCheck" json:"health_check,omitempty"`
	// The default is 1 second.
	Interval *google_protobuf3.Duration `protobuf:"bytes,2,opt,name=interval" json:"interval,omitempty"`
}

func (*HealthCheckSpecifier) Descriptor 

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

func (*HealthCheckSpecifier) GetHealthCheck 

func (m *HealthCheckSpecifier) GetHealthCheck() []*ClusterHealthCheck

func (*HealthCheckSpecifier) GetInterval 

func (m *HealthCheckSpecifier) GetInterval() *google_protobuf3.Duration

func (*HealthCheckSpecifier) Marshal 

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

func (*HealthCheckSpecifier) MarshalTo 

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

func (*HealthCheckSpecifier) ProtoMessage 

func (*HealthCheckSpecifier) ProtoMessage()

func (*HealthCheckSpecifier) Reset 

func (m *HealthCheckSpecifier) Reset()

func (*HealthCheckSpecifier) Size 

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

func (*HealthCheckSpecifier) String 

func (m *HealthCheckSpecifier) String() string

func (*HealthCheckSpecifier) Unmarshal 

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

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, an error is returned.

type HealthCheckSpecifierValidationError 

type HealthCheckSpecifierValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

HealthCheckSpecifierValidationError is the validation error returned by HealthCheckSpecifier.Validate if the designated constraints aren't met.

func (HealthCheckSpecifierValidationError) Error 

func (e HealthCheckSpecifierValidationError) Error() string

Error satisfies the builtin error interface

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

func NewHealthDiscoveryServiceClient 

func NewHealthDiscoveryServiceClient(cc *grpc.ClientConn) 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)
}

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  *envoy_api_v2_core.Locality       `protobuf:"bytes,1,opt,name=locality" json:"locality,omitempty"`
	Endpoints []*envoy_api_v2_endpoint.Endpoint `protobuf:"bytes,2,rep,name=endpoints" json:"endpoints,omitempty"`
}

func (*LocalityEndpoints) Descriptor 

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

func (*LocalityEndpoints) GetEndpoints 

func (m *LocalityEndpoints) GetEndpoints() []*envoy_api_v2_endpoint.Endpoint

func (*LocalityEndpoints) GetLocality 

func (m *LocalityEndpoints) GetLocality() *envoy_api_v2_core.Locality

func (*LocalityEndpoints) Marshal 

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

func (*LocalityEndpoints) MarshalTo 

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

func (*LocalityEndpoints) ProtoMessage 

func (*LocalityEndpoints) ProtoMessage()

func (*LocalityEndpoints) Reset 

func (m *LocalityEndpoints) Reset()

func (*LocalityEndpoints) Size 

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

func (*LocalityEndpoints) String 

func (m *LocalityEndpoints) String() string

func (*LocalityEndpoints) Unmarshal 

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

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, an error is returned.

type LocalityEndpointsValidationError 

type LocalityEndpointsValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

LocalityEndpointsValidationError is the validation error returned by LocalityEndpoints.Validate if the designated constraints aren't met.

func (LocalityEndpointsValidationError) Error 

func (e LocalityEndpointsValidationError) Error() string

Error satisfies the builtin error interface

type SdsDummy 

type SdsDummy struct {
}

[#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing services: https://github.com/google/protobuf/issues/4221

func (*SdsDummy) Descriptor 

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

func (*SdsDummy) Marshal 

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

func (*SdsDummy) MarshalTo 

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

func (*SdsDummy) ProtoMessage 

func (*SdsDummy) ProtoMessage()

func (*SdsDummy) Reset 

func (m *SdsDummy) Reset()

func (*SdsDummy) Size 

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

func (*SdsDummy) String 

func (m *SdsDummy) String() string

func (*SdsDummy) Unmarshal 

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

func (*SdsDummy) Validate 

func (m *SdsDummy) Validate() error

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

type SdsDummyValidationError 

type SdsDummyValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

SdsDummyValidationError is the validation error returned by SdsDummy.Validate if the designated constraints aren't met.

func (SdsDummyValidationError) Error 

func (e SdsDummyValidationError) Error() string

Error satisfies the builtin error interface

type SecretDiscoveryServiceClient 

type SecretDiscoveryServiceClient interface {
	StreamSecrets(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_StreamSecretsClient, error)
	FetchSecrets(ctx context.Context, in *envoy_api_v2.DiscoveryRequest, opts ...grpc.CallOption) (*envoy_api_v2.DiscoveryResponse, error)
}

func NewSecretDiscoveryServiceClient 

func NewSecretDiscoveryServiceClient(cc *grpc.ClientConn) SecretDiscoveryServiceClient

type SecretDiscoveryServiceServer 

type SecretDiscoveryServiceServer interface {
	StreamSecrets(SecretDiscoveryService_StreamSecretsServer) error
	FetchSecrets(context.Context, *envoy_api_v2.DiscoveryRequest) (*envoy_api_v2.DiscoveryResponse, error)
}

type SecretDiscoveryService_StreamSecretsClient 

type SecretDiscoveryService_StreamSecretsClient interface {
	Send(*envoy_api_v2.DiscoveryRequest) error
	Recv() (*envoy_api_v2.DiscoveryResponse, error)
	grpc.ClientStream
}

type SecretDiscoveryService_StreamSecretsServer 

type SecretDiscoveryService_StreamSecretsServer interface {
	Send(*envoy_api_v2.DiscoveryResponse) error
	Recv() (*envoy_api_v2.DiscoveryRequest, error)
	grpc.ServerStream
}

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.