v2

package
v0.6.9 Latest Latest
Warning

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

 Go to latest Published: Mar 11, 2019 License: Apache-2.0 Imports: 20 Imported by: 218

Documentation ¶

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

[#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.

func (*AdsDummy) XXX_DiscardUnknown ¶ 

func (m *AdsDummy) XXX_DiscardUnknown()

func (*AdsDummy) XXX_Marshal ¶ 

func (m *AdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AdsDummy) XXX_Merge ¶ 

func (m *AdsDummy) XXX_Merge(src proto.Message)

func (*AdsDummy) XXX_Size ¶ 

func (m *AdsDummy) XXX_Size() int

func (*AdsDummy) XXX_Unmarshal ¶ 

func (m *AdsDummy) XXX_Unmarshal(b []byte) error

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)
	DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error)
}

AggregatedDiscoveryServiceClient is the client API for AggregatedDiscoveryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAggregatedDiscoveryServiceClient ¶ 

func NewAggregatedDiscoveryServiceClient(cc *grpc.ClientConn) AggregatedDiscoveryServiceClient

type AggregatedDiscoveryServiceServer ¶ 

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

AggregatedDiscoveryServiceServer is the server API for AggregatedDiscoveryService service.

type AggregatedDiscoveryService_DeltaAggregatedResourcesClient ¶ added in v0.6.9 

type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface {
	Send(*v2.DeltaDiscoveryRequest) error
	Recv() (*v2.DeltaDiscoveryResponse, error)
	grpc.ClientStream
}

type AggregatedDiscoveryService_DeltaAggregatedResourcesServer ¶ added in v0.6.9 

type AggregatedDiscoveryService_DeltaAggregatedResourcesServer interface {
	Send(*v2.DeltaDiscoveryResponse) error
	Recv() (*v2.DeltaDiscoveryRequest, error)
	grpc.ServerStream
}

type AggregatedDiscoveryService_StreamAggregatedResourcesClient ¶ 

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

type AggregatedDiscoveryService_StreamAggregatedResourcesServer ¶ 

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

type Capability ¶ 

type Capability struct {
	HealthCheckProtocols []Capability_Protocol `` /* 183-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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

func (*Capability) Descriptor ¶ 

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

func (*Capability) GetHealthCheckProtocols ¶ 

func (m *Capability) GetHealthCheckProtocols() []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.

func (*Capability) XXX_DiscardUnknown ¶ 

func (m *Capability) XXX_DiscardUnknown()

func (*Capability) XXX_Marshal ¶ 

func (m *Capability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Capability) XXX_Merge ¶ 

func (m *Capability) XXX_Merge(src proto.Message)

func (*Capability) XXX_Size ¶ 

func (m *Capability) XXX_Size() int

func (*Capability) XXX_Unmarshal ¶ 

func (m *Capability) XXX_Unmarshal(b []byte) error

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         []*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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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) GetHealthChecks ¶ 

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

func (*ClusterHealthCheck) GetLocalityEndpoints ¶ 

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

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.

func (*ClusterHealthCheck) XXX_DiscardUnknown ¶ 

func (m *ClusterHealthCheck) XXX_DiscardUnknown()

func (*ClusterHealthCheck) XXX_Marshal ¶ 

func (m *ClusterHealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterHealthCheck) XXX_Merge ¶ 

func (m *ClusterHealthCheck) XXX_Merge(src proto.Message)

func (*ClusterHealthCheck) XXX_Size ¶ 

func (m *ClusterHealthCheck) XXX_Size() int

func (*ClusterHealthCheck) XXX_Unmarshal ¶ 

func (m *ClusterHealthCheck) XXX_Unmarshal(b []byte) error

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             *endpoint.Endpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	HealthStatus         core.HealthStatus  `` /* 134-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*EndpointHealth) Descriptor ¶ 

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

func (*EndpointHealth) GetEndpoint ¶ 

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

func (*EndpointHealth) GetHealthStatus ¶ 

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

func (*EndpointHealth) XXX_DiscardUnknown ¶ 

func (m *EndpointHealth) XXX_DiscardUnknown()

func (*EndpointHealth) XXX_Marshal ¶ 

func (m *EndpointHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointHealth) XXX_Merge ¶ 

func (m *EndpointHealth) XXX_Merge(src proto.Message)

func (*EndpointHealth) XXX_Size ¶ 

func (m *EndpointHealth) XXX_Size() int

func (*EndpointHealth) XXX_Unmarshal ¶ 

func (m *EndpointHealth) XXX_Unmarshal(b []byte) error

type EndpointHealthResponse ¶ 

type EndpointHealthResponse struct {
	EndpointsHealth      []*EndpointHealth `protobuf:"bytes,1,rep,name=endpoints_health,json=endpointsHealth,proto3" json:"endpoints_health,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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.

func (*EndpointHealthResponse) XXX_DiscardUnknown ¶ 

func (m *EndpointHealthResponse) XXX_DiscardUnknown()

func (*EndpointHealthResponse) XXX_Marshal ¶ 

func (m *EndpointHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointHealthResponse) XXX_Merge ¶ 

func (m *EndpointHealthResponse) XXX_Merge(src proto.Message)

func (*EndpointHealthResponse) XXX_Size ¶ 

func (m *EndpointHealthResponse) XXX_Size() int

func (*EndpointHealthResponse) XXX_Unmarshal ¶ 

func (m *EndpointHealthResponse) XXX_Unmarshal(b []byte) error

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                 *core.Node  `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Capability           *Capability `protobuf:"bytes,2,opt,name=capability,proto3" json:"capability,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*HealthCheckRequest) Descriptor ¶ 

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

func (*HealthCheckRequest) GetCapability ¶ 

func (m *HealthCheckRequest) GetCapability() *Capability

func (*HealthCheckRequest) GetNode ¶ 

func (m *HealthCheckRequest) GetNode() *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.

func (*HealthCheckRequest) XXX_DiscardUnknown ¶ 

func (m *HealthCheckRequest) XXX_DiscardUnknown()

func (*HealthCheckRequest) XXX_Marshal ¶ 

func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckRequest) XXX_Merge ¶ 

func (m *HealthCheckRequest) XXX_Merge(src proto.Message)

func (*HealthCheckRequest) XXX_Size ¶ 

func (m *HealthCheckRequest) XXX_Size() int

func (*HealthCheckRequest) XXX_Unmarshal ¶ 

func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                                                 `json:"-"`
	XXX_unrecognized     []byte                                                   `json:"-"`
	XXX_sizecache        int32                                                    `json:"-"`
}

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_DiscardUnknown ¶ 

func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_DiscardUnknown()

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Marshal ¶ 

func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Merge ¶ 

func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Merge(src proto.Message)

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.

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Size ¶ 

func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Size() int

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal ¶ 

func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal(b []byte) error

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,proto3,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,proto3,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 {
	ClusterHealthChecks []*ClusterHealthCheck `protobuf:"bytes,1,rep,name=cluster_health_checks,json=clusterHealthChecks,proto3" json:"cluster_health_checks,omitempty"`
	// The default is 1 second.
	Interval             *types.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*HealthCheckSpecifier) Descriptor ¶ 

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

func (*HealthCheckSpecifier) GetClusterHealthChecks ¶ 

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

func (*HealthCheckSpecifier) GetInterval ¶ 

func (m *HealthCheckSpecifier) GetInterval() *types.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.

func (*HealthCheckSpecifier) XXX_DiscardUnknown ¶ 

func (m *HealthCheckSpecifier) XXX_DiscardUnknown()

func (*HealthCheckSpecifier) XXX_Marshal ¶ 

func (m *HealthCheckSpecifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckSpecifier) XXX_Merge ¶ 

func (m *HealthCheckSpecifier) XXX_Merge(src proto.Message)

func (*HealthCheckSpecifier) XXX_Size ¶ 

func (m *HealthCheckSpecifier) XXX_Size() int

func (*HealthCheckSpecifier) XXX_Unmarshal ¶ 

func (m *HealthCheckSpecifier) XXX_Unmarshal(b []byte) error

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

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

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             *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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*LocalityEndpoints) Descriptor ¶ 

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

func (*LocalityEndpoints) GetEndpoints ¶ 

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

func (*LocalityEndpoints) GetLocality ¶ 

func (m *LocalityEndpoints) GetLocality() *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.

func (*LocalityEndpoints) XXX_DiscardUnknown ¶ 

func (m *LocalityEndpoints) XXX_DiscardUnknown()

func (*LocalityEndpoints) XXX_Marshal ¶ 

func (m *LocalityEndpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LocalityEndpoints) XXX_Merge ¶ 

func (m *LocalityEndpoints) XXX_Merge(src proto.Message)

func (*LocalityEndpoints) XXX_Size ¶ 

func (m *LocalityEndpoints) XXX_Size() int

func (*LocalityEndpoints) XXX_Unmarshal ¶ 

func (m *LocalityEndpoints) XXX_Unmarshal(b []byte) error

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

[#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.

func (*SdsDummy) XXX_DiscardUnknown ¶ 

func (m *SdsDummy) XXX_DiscardUnknown()

func (*SdsDummy) XXX_Marshal ¶ 

func (m *SdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SdsDummy) XXX_Merge ¶ 

func (m *SdsDummy) XXX_Merge(src proto.Message)

func (*SdsDummy) XXX_Size ¶ 

func (m *SdsDummy) XXX_Size() int

func (*SdsDummy) XXX_Unmarshal ¶ 

func (m *SdsDummy) XXX_Unmarshal(b []byte) error

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 *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error)
}

SecretDiscoveryServiceClient is the client API for SecretDiscoveryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSecretDiscoveryServiceClient ¶ 

func NewSecretDiscoveryServiceClient(cc *grpc.ClientConn) SecretDiscoveryServiceClient

type SecretDiscoveryServiceServer ¶ 

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

SecretDiscoveryServiceServer is the server API for SecretDiscoveryService service.

type SecretDiscoveryService_StreamSecretsClient ¶ 

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

type SecretDiscoveryService_StreamSecretsServer ¶ 

type SecretDiscoveryService_StreamSecretsServer interface {
	Send(*v2.DiscoveryResponse) error
	Recv() (*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.