envoy_service_discovery_v2

package
v0.0.0-...-d64db01 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2020 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
}

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

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

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

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

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

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

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

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

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

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

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 {
	StreamHealthCheck(ctx context.Context, opts ...grpc.CallOption) (HealthDiscoveryService_StreamHealthCheckClient, error)
	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 {
	StreamHealthCheck(HealthDiscoveryService_StreamHealthCheckServer) error
	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, an error is returned.

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
}

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

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

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

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

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

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.