discoveryv2

package
v3.9.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

This section is empty.

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 ¶

func RegisterAggregatedDiscoveryServiceServer ¶ 

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

func RegisterHealthDiscoveryServiceServer ¶ 

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

func RegisterRuntimeDiscoveryServiceServer ¶ 

func RegisterRuntimeDiscoveryServiceServer(s *grpc.Server, srv RuntimeDiscoveryServiceServer)

func RegisterSecretDiscoveryServiceServer ¶ 

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

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

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

Deprecated: Use AdsDummy.ProtoReflect.Descriptor instead.

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

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, the first error encountered is returned, or nil if there are no violations.

func (*AdsDummy) ValidateAll ¶ 

func (m *AdsDummy) ValidateAll() error

ValidateAll checks the field values on AdsDummy with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AdsDummyMultiError, or nil if none found.

type AdsDummyMultiError ¶ 

type AdsDummyMultiError []error

AdsDummyMultiError is an error wrapping multiple validation errors returned by AdsDummy.ValidateAll() if the designated constraints aren't met.

func (AdsDummyMultiError) AllErrors ¶ 

func (m AdsDummyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AdsDummyMultiError) Error ¶ 

func (m AdsDummyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AdsDummyValidationError ¶ 

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

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

func (AdsDummyValidationError) Cause ¶ 

func (e AdsDummyValidationError) Cause() error

Cause function returns cause value.

func (AdsDummyValidationError) Error ¶ 

func (e AdsDummyValidationError) Error() string

Error satisfies the builtin error interface

func (AdsDummyValidationError) ErrorName ¶ 

func (e AdsDummyValidationError) ErrorName() string

ErrorName returns error name.

func (AdsDummyValidationError) Field ¶ 

func (e AdsDummyValidationError) Field() string

Field function returns field value.

func (AdsDummyValidationError) Key ¶ 

func (e AdsDummyValidationError) Key() bool

Key function returns key value.

func (AdsDummyValidationError) Reason ¶ 

func (e AdsDummyValidationError) Reason() string

Reason function returns reason value.

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.ClientConnInterface) 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 ¶ 

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

type AggregatedDiscoveryService_DeltaAggregatedResourcesServer ¶ 

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 */
	// contains filtered or unexported fields
}

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

func (*Capability) Descriptor deprecated 

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

Deprecated: Use Capability.ProtoReflect.Descriptor instead.

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

func (x *Capability) String() string

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, the first error encountered is returned, or nil if there are no violations.

func (*Capability) ValidateAll ¶ 

func (m *Capability) ValidateAll() error

ValidateAll checks the field values on Capability with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CapabilityMultiError, or nil if none found.

type CapabilityMultiError ¶ 

type CapabilityMultiError []error

CapabilityMultiError is an error wrapping multiple validation errors returned by Capability.ValidateAll() if the designated constraints aren't met.

func (CapabilityMultiError) AllErrors ¶ 

func (m CapabilityMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CapabilityMultiError) Error ¶ 

func (m CapabilityMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CapabilityValidationError ¶ 

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

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

func (CapabilityValidationError) Cause ¶ 

func (e CapabilityValidationError) Cause() error

Cause function returns cause value.

func (CapabilityValidationError) Error ¶ 

func (e CapabilityValidationError) Error() string

Error satisfies the builtin error interface

func (CapabilityValidationError) ErrorName ¶ 

func (e CapabilityValidationError) ErrorName() string

ErrorName returns error name.

func (CapabilityValidationError) Field ¶ 

func (e CapabilityValidationError) Field() string

Field function returns field value.

func (CapabilityValidationError) Key ¶ 

func (e CapabilityValidationError) Key() bool

Key function returns key value.

func (CapabilityValidationError) Reason ¶ 

func (e CapabilityValidationError) Reason() string

Reason function returns reason value.

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

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

Deprecated: Use Capability_Protocol.Descriptor instead.

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

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

Deprecated: Use ClusterHealthCheck.ProtoReflect.Descriptor instead.

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

func (x *ClusterHealthCheck) String() string

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, the first error encountered is returned, or nil if there are no violations.

func (*ClusterHealthCheck) ValidateAll ¶ 

func (m *ClusterHealthCheck) ValidateAll() error

ValidateAll checks the field values on ClusterHealthCheck with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClusterHealthCheckMultiError, or nil if none found.

type ClusterHealthCheckMultiError ¶ 

type ClusterHealthCheckMultiError []error

ClusterHealthCheckMultiError is an error wrapping multiple validation errors returned by ClusterHealthCheck.ValidateAll() if the designated constraints aren't met.

func (ClusterHealthCheckMultiError) AllErrors ¶ 

func (m ClusterHealthCheckMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ClusterHealthCheckMultiError) Error ¶ 

func (m ClusterHealthCheckMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ClusterHealthCheckValidationError ¶ 

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

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

func (ClusterHealthCheckValidationError) Cause ¶ 

func (e ClusterHealthCheckValidationError) Cause() error

Cause function returns cause value.

func (ClusterHealthCheckValidationError) Error ¶ 

func (e ClusterHealthCheckValidationError) Error() string

Error satisfies the builtin error interface

func (ClusterHealthCheckValidationError) ErrorName ¶ 

func (e ClusterHealthCheckValidationError) ErrorName() string

ErrorName returns error name.

func (ClusterHealthCheckValidationError) Field ¶ 

func (e ClusterHealthCheckValidationError) Field() string

Field function returns field value.

func (ClusterHealthCheckValidationError) Key ¶ 

func (e ClusterHealthCheckValidationError) Key() bool

Key function returns key value.

func (ClusterHealthCheckValidationError) Reason ¶ 

func (e ClusterHealthCheckValidationError) Reason() string

Reason function returns reason value.

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

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

Deprecated: Use EndpointHealth.ProtoReflect.Descriptor instead.

func (*EndpointHealth) GetEndpoint ¶ 

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

func (*EndpointHealth) GetHealthStatus ¶ 

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

func (*EndpointHealth) ProtoMessage ¶ 

func (*EndpointHealth) ProtoMessage()

func (*EndpointHealth) ProtoReflect ¶ 

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

func (*EndpointHealth) Reset ¶ 

func (x *EndpointHealth) Reset()

func (*EndpointHealth) String ¶ 

func (x *EndpointHealth) String() string

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, the first error encountered is returned, or nil if there are no violations.

func (*EndpointHealth) ValidateAll ¶ 

func (m *EndpointHealth) ValidateAll() error

ValidateAll checks the field values on EndpointHealth with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EndpointHealthMultiError, or nil if none found.

type EndpointHealthMultiError ¶ 

type EndpointHealthMultiError []error

EndpointHealthMultiError is an error wrapping multiple validation errors returned by EndpointHealth.ValidateAll() if the designated constraints aren't met.

func (EndpointHealthMultiError) AllErrors ¶ 

func (m EndpointHealthMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EndpointHealthMultiError) Error ¶ 

func (m EndpointHealthMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

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

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

Deprecated: Use EndpointHealthResponse.ProtoReflect.Descriptor instead.

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

func (x *EndpointHealthResponse) String() string

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, the first error encountered is returned, or nil if there are no violations.

func (*EndpointHealthResponse) ValidateAll ¶ 

func (m *EndpointHealthResponse) ValidateAll() error

ValidateAll checks the field values on EndpointHealthResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EndpointHealthResponseMultiError, or nil if none found.

type EndpointHealthResponseMultiError ¶ 

type EndpointHealthResponseMultiError []error

EndpointHealthResponseMultiError is an error wrapping multiple validation errors returned by EndpointHealthResponse.ValidateAll() if the designated constraints aren't met.

func (EndpointHealthResponseMultiError) AllErrors ¶ 

func (m EndpointHealthResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EndpointHealthResponseMultiError) Error ¶ 

func (m EndpointHealthResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EndpointHealthResponseValidationError ¶ 

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

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

func (EndpointHealthResponseValidationError) Cause ¶ 

func (e EndpointHealthResponseValidationError) Cause() error

Cause function returns cause value.

func (EndpointHealthResponseValidationError) Error ¶ 

func (e EndpointHealthResponseValidationError) Error() string

Error satisfies the builtin error interface

func (EndpointHealthResponseValidationError) ErrorName ¶ 

func (e EndpointHealthResponseValidationError) ErrorName() string

ErrorName returns error name.

func (EndpointHealthResponseValidationError) Field ¶ 

func (e EndpointHealthResponseValidationError) Field() string

Field function returns field value.

func (EndpointHealthResponseValidationError) Key ¶ 

func (e EndpointHealthResponseValidationError) Key() bool

Key function returns key value.

func (EndpointHealthResponseValidationError) Reason ¶ 

func (e EndpointHealthResponseValidationError) Reason() string

Reason function returns reason value.

type EndpointHealthValidationError ¶ 

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

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

func (EndpointHealthValidationError) Cause ¶ 

func (e EndpointHealthValidationError) Cause() error

Cause function returns cause value.

func (EndpointHealthValidationError) Error ¶ 

func (e EndpointHealthValidationError) Error() string

Error satisfies the builtin error interface

func (EndpointHealthValidationError) ErrorName ¶ 

func (e EndpointHealthValidationError) ErrorName() string

ErrorName returns error name.

func (EndpointHealthValidationError) Field ¶ 

func (e EndpointHealthValidationError) Field() string

Field function returns field value.

func (EndpointHealthValidationError) Key ¶ 

func (e EndpointHealthValidationError) Key() bool

Key function returns key value.

func (EndpointHealthValidationError) Reason ¶ 

func (e EndpointHealthValidationError) Reason() string

Reason function returns reason value.

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

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) GetCapability ¶ 

func (x *HealthCheckRequest) GetCapability() *Capability

func (*HealthCheckRequest) GetNode ¶ 

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

func (*HealthCheckRequest) ProtoMessage ¶ 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect ¶ 

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

func (*HealthCheckRequest) Reset ¶ 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String ¶ 

func (x *HealthCheckRequest) String() string

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, the first error encountered is returned, or nil if there are no violations.

func (*HealthCheckRequest) ValidateAll ¶ 

func (m *HealthCheckRequest) ValidateAll() error

ValidateAll checks the field values on HealthCheckRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in HealthCheckRequestMultiError, or nil if none found.

type HealthCheckRequestMultiError ¶ 

type HealthCheckRequestMultiError []error

HealthCheckRequestMultiError is an error wrapping multiple validation errors returned by HealthCheckRequest.ValidateAll() if the designated constraints aren't met.

func (HealthCheckRequestMultiError) AllErrors ¶ 

func (m HealthCheckRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (HealthCheckRequestMultiError) Error ¶ 

func (m HealthCheckRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type HealthCheckRequestOrEndpointHealthResponse ¶ 

type HealthCheckRequestOrEndpointHealthResponse struct {

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

func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckRequestOrEndpointHealthResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse ¶ 

func (x *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse

func (*HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest ¶ 

func (x *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest

func (*HealthCheckRequestOrEndpointHealthResponse) GetRequestType ¶ 

func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType

func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage ¶ 

func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()

func (*HealthCheckRequestOrEndpointHealthResponse) ProtoReflect ¶ 

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

func (*HealthCheckRequestOrEndpointHealthResponse) Reset ¶ 

func (x *HealthCheckRequestOrEndpointHealthResponse) Reset()

func (*HealthCheckRequestOrEndpointHealthResponse) String ¶ 

func (x *HealthCheckRequestOrEndpointHealthResponse) String() string

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, the first error encountered is returned, or nil if there are no violations.

func (*HealthCheckRequestOrEndpointHealthResponse) ValidateAll ¶ 

func (m *HealthCheckRequestOrEndpointHealthResponse) ValidateAll() error

ValidateAll checks the field values on HealthCheckRequestOrEndpointHealthResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in HealthCheckRequestOrEndpointHealthResponseMultiError, or nil if none found.

type HealthCheckRequestOrEndpointHealthResponseMultiError ¶ 

type HealthCheckRequestOrEndpointHealthResponseMultiError []error

HealthCheckRequestOrEndpointHealthResponseMultiError is an error wrapping multiple validation errors returned by HealthCheckRequestOrEndpointHealthResponse.ValidateAll() if the designated constraints aren't met.

func (HealthCheckRequestOrEndpointHealthResponseMultiError) AllErrors ¶ 

func (m HealthCheckRequestOrEndpointHealthResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (HealthCheckRequestOrEndpointHealthResponseMultiError) Error ¶ 

func (m HealthCheckRequestOrEndpointHealthResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type HealthCheckRequestOrEndpointHealthResponseValidationError ¶ 

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

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

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Cause ¶ 

func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Cause() error

Cause function returns cause value.

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Error ¶ 

func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Error() string

Error satisfies the builtin error interface

func (HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName ¶ 

func (e HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName() string

ErrorName returns error name.

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Field ¶ 

func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Field() string

Field function returns field value.

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Key ¶ 

func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Key() bool

Key function returns key value.

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Reason ¶ 

func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Reason() string

Reason function returns reason value.

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

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

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

func (HealthCheckRequestValidationError) Cause ¶ 

func (e HealthCheckRequestValidationError) Cause() error

Cause function returns cause value.

func (HealthCheckRequestValidationError) Error ¶ 

func (e HealthCheckRequestValidationError) Error() string

Error satisfies the builtin error interface

func (HealthCheckRequestValidationError) ErrorName ¶ 

func (e HealthCheckRequestValidationError) ErrorName() string

ErrorName returns error name.

func (HealthCheckRequestValidationError) Field ¶ 

func (e HealthCheckRequestValidationError) Field() string

Field function returns field value.

func (HealthCheckRequestValidationError) Key ¶ 

func (e HealthCheckRequestValidationError) Key() bool

Key function returns key value.

func (HealthCheckRequestValidationError) Reason ¶ 

func (e HealthCheckRequestValidationError) Reason() string

Reason function returns reason value.

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 *duration.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckSpecifier) Descriptor deprecated 

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

Deprecated: Use HealthCheckSpecifier.ProtoReflect.Descriptor instead.

func (*HealthCheckSpecifier) GetClusterHealthChecks ¶ 

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

func (*HealthCheckSpecifier) GetInterval ¶ 

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

func (*HealthCheckSpecifier) ProtoMessage ¶ 

func (*HealthCheckSpecifier) ProtoMessage()

func (*HealthCheckSpecifier) ProtoReflect ¶ 

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

func (*HealthCheckSpecifier) Reset ¶ 

func (x *HealthCheckSpecifier) Reset()

func (*HealthCheckSpecifier) String ¶ 

func (x *HealthCheckSpecifier) String() string

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, the first error encountered is returned, or nil if there are no violations.

func (*HealthCheckSpecifier) ValidateAll ¶ 

func (m *HealthCheckSpecifier) ValidateAll() error

ValidateAll checks the field values on HealthCheckSpecifier with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in HealthCheckSpecifierMultiError, or nil if none found.

type HealthCheckSpecifierMultiError ¶ 

type HealthCheckSpecifierMultiError []error

HealthCheckSpecifierMultiError is an error wrapping multiple validation errors returned by HealthCheckSpecifier.ValidateAll() if the designated constraints aren't met.

func (HealthCheckSpecifierMultiError) AllErrors ¶ 

func (m HealthCheckSpecifierMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (HealthCheckSpecifierMultiError) Error ¶ 

func (m HealthCheckSpecifierMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type HealthCheckSpecifierValidationError ¶ 

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

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

func (HealthCheckSpecifierValidationError) Cause ¶ 

func (e HealthCheckSpecifierValidationError) Cause() error

Cause function returns cause value.

func (HealthCheckSpecifierValidationError) Error ¶ 

func (e HealthCheckSpecifierValidationError) Error() string

Error satisfies the builtin error interface

func (HealthCheckSpecifierValidationError) ErrorName ¶ 

func (e HealthCheckSpecifierValidationError) ErrorName() string

ErrorName returns error name.

func (HealthCheckSpecifierValidationError) Field ¶ 

func (e HealthCheckSpecifierValidationError) Field() string

Field function returns field value.

func (HealthCheckSpecifierValidationError) Key ¶ 

func (e HealthCheckSpecifierValidationError) Key() bool

Key function returns key value.

func (HealthCheckSpecifierValidationError) Reason ¶ 

func (e HealthCheckSpecifierValidationError) Reason() string

Reason function returns reason value.

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.ClientConnInterface) 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"`
	// contains filtered or unexported fields
}

func (*LocalityEndpoints) Descriptor deprecated 

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

Deprecated: Use LocalityEndpoints.ProtoReflect.Descriptor instead.

func (*LocalityEndpoints) GetEndpoints ¶ 

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

func (*LocalityEndpoints) GetLocality ¶ 

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

func (*LocalityEndpoints) ProtoMessage ¶ 

func (*LocalityEndpoints) ProtoMessage()

func (*LocalityEndpoints) ProtoReflect ¶ 

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

func (*LocalityEndpoints) Reset ¶ 

func (x *LocalityEndpoints) Reset()

func (*LocalityEndpoints) String ¶ 

func (x *LocalityEndpoints) String() string

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, the first error encountered is returned, or nil if there are no violations.

func (*LocalityEndpoints) ValidateAll ¶ 

func (m *LocalityEndpoints) ValidateAll() error

ValidateAll checks the field values on LocalityEndpoints with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LocalityEndpointsMultiError, or nil if none found.

type LocalityEndpointsMultiError ¶ 

type LocalityEndpointsMultiError []error

LocalityEndpointsMultiError is an error wrapping multiple validation errors returned by LocalityEndpoints.ValidateAll() if the designated constraints aren't met.

func (LocalityEndpointsMultiError) AllErrors ¶ 

func (m LocalityEndpointsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LocalityEndpointsMultiError) Error ¶ 

func (m LocalityEndpointsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LocalityEndpointsValidationError ¶ 

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

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

func (LocalityEndpointsValidationError) Cause ¶ 

func (e LocalityEndpointsValidationError) Cause() error

Cause function returns cause value.

func (LocalityEndpointsValidationError) Error ¶ 

func (e LocalityEndpointsValidationError) Error() string

Error satisfies the builtin error interface

func (LocalityEndpointsValidationError) ErrorName ¶ 

func (e LocalityEndpointsValidationError) ErrorName() string

ErrorName returns error name.

func (LocalityEndpointsValidationError) Field ¶ 

func (e LocalityEndpointsValidationError) Field() string

Field function returns field value.

func (LocalityEndpointsValidationError) Key ¶ 

func (e LocalityEndpointsValidationError) Key() bool

Key function returns key value.

func (LocalityEndpointsValidationError) Reason ¶ 

func (e LocalityEndpointsValidationError) Reason() string

Reason function returns reason value.

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

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

Deprecated: Use RtdsDummy.ProtoReflect.Descriptor instead.

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

func (*RtdsDummy) Validate ¶ 

func (m *RtdsDummy) Validate() error

Validate checks the field values on RtdsDummy with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RtdsDummy) ValidateAll ¶ 

func (m *RtdsDummy) ValidateAll() error

ValidateAll checks the field values on RtdsDummy with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RtdsDummyMultiError, or nil if none found.

type RtdsDummyMultiError ¶ 

type RtdsDummyMultiError []error

RtdsDummyMultiError is an error wrapping multiple validation errors returned by RtdsDummy.ValidateAll() if the designated constraints aren't met.

func (RtdsDummyMultiError) AllErrors ¶ 

func (m RtdsDummyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RtdsDummyMultiError) Error ¶ 

func (m RtdsDummyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RtdsDummyValidationError ¶ 

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

RtdsDummyValidationError is the validation error returned by RtdsDummy.Validate if the designated constraints aren't met.

func (RtdsDummyValidationError) Cause ¶ 

func (e RtdsDummyValidationError) Cause() error

Cause function returns cause value.

func (RtdsDummyValidationError) Error ¶ 

func (e RtdsDummyValidationError) Error() string

Error satisfies the builtin error interface

func (RtdsDummyValidationError) ErrorName ¶ 

func (e RtdsDummyValidationError) ErrorName() string

ErrorName returns error name.

func (RtdsDummyValidationError) Field ¶ 

func (e RtdsDummyValidationError) Field() string

Field function returns field value.

func (RtdsDummyValidationError) Key ¶ 

func (e RtdsDummyValidationError) Key() bool

Key function returns key value.

func (RtdsDummyValidationError) Reason ¶ 

func (e RtdsDummyValidationError) Reason() string

Reason function returns reason value.

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 *_struct.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) Descriptor deprecated 

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

Deprecated: Use Runtime.ProtoReflect.Descriptor instead.

func (*Runtime) GetLayer ¶ 

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

func (*Runtime) GetName ¶ 

func (x *Runtime) GetName() string

func (*Runtime) ProtoMessage ¶ 

func (*Runtime) ProtoMessage()

func (*Runtime) ProtoReflect ¶ 

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

func (*Runtime) Reset ¶ 

func (x *Runtime) Reset()

func (*Runtime) String ¶ 

func (x *Runtime) String() string

func (*Runtime) Validate ¶ 

func (m *Runtime) Validate() error

Validate checks the field values on Runtime with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Runtime) ValidateAll ¶ 

func (m *Runtime) ValidateAll() error

ValidateAll checks the field values on Runtime with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RuntimeMultiError, or nil if none found.

type RuntimeDiscoveryServiceClient ¶ 

type RuntimeDiscoveryServiceClient interface {
	StreamRuntime(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_StreamRuntimeClient, error)
	DeltaRuntime(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_DeltaRuntimeClient, error)
	FetchRuntime(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error)
}

RuntimeDiscoveryServiceClient is the client API for RuntimeDiscoveryService service.

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

func NewRuntimeDiscoveryServiceClient ¶ 

func NewRuntimeDiscoveryServiceClient(cc grpc.ClientConnInterface) RuntimeDiscoveryServiceClient

type RuntimeDiscoveryServiceServer ¶ 

type RuntimeDiscoveryServiceServer interface {
	StreamRuntime(RuntimeDiscoveryService_StreamRuntimeServer) error
	DeltaRuntime(RuntimeDiscoveryService_DeltaRuntimeServer) error
	FetchRuntime(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
}

RuntimeDiscoveryServiceServer is the server API for RuntimeDiscoveryService service.

type RuntimeDiscoveryService_DeltaRuntimeClient ¶ 

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

type RuntimeDiscoveryService_DeltaRuntimeServer ¶ 

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

type RuntimeDiscoveryService_StreamRuntimeClient ¶ 

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

type RuntimeDiscoveryService_StreamRuntimeServer ¶ 

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

type RuntimeMultiError ¶ 

type RuntimeMultiError []error

RuntimeMultiError is an error wrapping multiple validation errors returned by Runtime.ValidateAll() if the designated constraints aren't met.

func (RuntimeMultiError) AllErrors ¶ 

func (m RuntimeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RuntimeMultiError) Error ¶ 

func (m RuntimeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RuntimeValidationError ¶ 

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

RuntimeValidationError is the validation error returned by Runtime.Validate if the designated constraints aren't met.

func (RuntimeValidationError) Cause ¶ 

func (e RuntimeValidationError) Cause() error

Cause function returns cause value.

func (RuntimeValidationError) Error ¶ 

func (e RuntimeValidationError) Error() string

Error satisfies the builtin error interface

func (RuntimeValidationError) ErrorName ¶ 

func (e RuntimeValidationError) ErrorName() string

ErrorName returns error name.

func (RuntimeValidationError) Field ¶ 

func (e RuntimeValidationError) Field() string

Field function returns field value.

func (RuntimeValidationError) Key ¶ 

func (e RuntimeValidationError) Key() bool

Key function returns key value.

func (RuntimeValidationError) Reason ¶ 

func (e RuntimeValidationError) Reason() string

Reason function returns reason value.

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

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

Deprecated: Use SdsDummy.ProtoReflect.Descriptor instead.

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

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, the first error encountered is returned, or nil if there are no violations.

func (*SdsDummy) ValidateAll ¶ 

func (m *SdsDummy) ValidateAll() error

ValidateAll checks the field values on SdsDummy with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SdsDummyMultiError, or nil if none found.

type SdsDummyMultiError ¶ 

type SdsDummyMultiError []error

SdsDummyMultiError is an error wrapping multiple validation errors returned by SdsDummy.ValidateAll() if the designated constraints aren't met.

func (SdsDummyMultiError) AllErrors ¶ 

func (m SdsDummyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SdsDummyMultiError) Error ¶ 

func (m SdsDummyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SdsDummyValidationError ¶ 

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

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

func (SdsDummyValidationError) Cause ¶ 

func (e SdsDummyValidationError) Cause() error

Cause function returns cause value.

func (SdsDummyValidationError) Error ¶ 

func (e SdsDummyValidationError) Error() string

Error satisfies the builtin error interface

func (SdsDummyValidationError) ErrorName ¶ 

func (e SdsDummyValidationError) ErrorName() string

ErrorName returns error name.

func (SdsDummyValidationError) Field ¶ 

func (e SdsDummyValidationError) Field() string

Field function returns field value.

func (SdsDummyValidationError) Key ¶ 

func (e SdsDummyValidationError) Key() bool

Key function returns key value.

func (SdsDummyValidationError) Reason ¶ 

func (e SdsDummyValidationError) Reason() string

Reason function returns reason value.

type SecretDiscoveryServiceClient ¶ 

type SecretDiscoveryServiceClient interface {
	DeltaSecrets(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_DeltaSecretsClient, error)
	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.ClientConnInterface) SecretDiscoveryServiceClient

type SecretDiscoveryServiceServer ¶ 

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

SecretDiscoveryServiceServer is the server API for SecretDiscoveryService service.

type SecretDiscoveryService_DeltaSecretsClient ¶ 

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

type SecretDiscoveryService_DeltaSecretsServer ¶ 

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

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
}

type UnimplementedAggregatedDiscoveryServiceServer ¶ 

type UnimplementedAggregatedDiscoveryServiceServer struct {
}

UnimplementedAggregatedDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources ¶ 

func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error

func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources ¶ 

func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error

type UnimplementedHealthDiscoveryServiceServer ¶ 

type UnimplementedHealthDiscoveryServiceServer struct {
}

UnimplementedHealthDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck ¶ 

func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck(context.Context, *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error)

func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck ¶ 

func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck(HealthDiscoveryService_StreamHealthCheckServer) error

type UnimplementedRuntimeDiscoveryServiceServer ¶ 

type UnimplementedRuntimeDiscoveryServiceServer struct {
}

UnimplementedRuntimeDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRuntimeDiscoveryServiceServer) DeltaRuntime ¶ 

func (*UnimplementedRuntimeDiscoveryServiceServer) DeltaRuntime(RuntimeDiscoveryService_DeltaRuntimeServer) error

func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime ¶ 

func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime ¶ 

func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime(RuntimeDiscoveryService_StreamRuntimeServer) error

type UnimplementedSecretDiscoveryServiceServer ¶ 

type UnimplementedSecretDiscoveryServiceServer struct {
}

UnimplementedSecretDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets ¶ 

func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets(SecretDiscoveryService_DeltaSecretsServer) error

func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets ¶ 

func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets ¶ 

func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets(SecretDiscoveryService_StreamSecretsServer) error

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.