Versions in this module Expand all Collapse all v0 v0.9.8 Jun 18, 2021 Changes in this version + var Capability_Protocol_name = map[int32]string + var Capability_Protocol_value = map[string]int32 + var File_envoy_service_discovery_v2_ads_proto protoreflect.FileDescriptor + var File_envoy_service_discovery_v2_hds_proto protoreflect.FileDescriptor + var File_envoy_service_discovery_v2_rtds_proto protoreflect.FileDescriptor + var File_envoy_service_discovery_v2_sds_proto protoreflect.FileDescriptor + func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer) + func RegisterHealthDiscoveryServiceServer(s *grpc.Server, srv HealthDiscoveryServiceServer) + func RegisterRuntimeDiscoveryServiceServer(s *grpc.Server, srv RuntimeDiscoveryServiceServer) + func RegisterSecretDiscoveryServiceServer(s *grpc.Server, srv SecretDiscoveryServiceServer) + type AdsDummy struct + func (*AdsDummy) Descriptor() ([]byte, []int) + func (*AdsDummy) ProtoMessage() + func (m *AdsDummy) Validate() error + func (x *AdsDummy) ProtoReflect() protoreflect.Message + func (x *AdsDummy) Reset() + func (x *AdsDummy) String() string + type AdsDummyValidationError struct + func (e AdsDummyValidationError) Cause() error + func (e AdsDummyValidationError) Error() string + func (e AdsDummyValidationError) ErrorName() string + func (e AdsDummyValidationError) Field() string + func (e AdsDummyValidationError) Key() bool + func (e AdsDummyValidationError) Reason() string + type AggregatedDiscoveryServiceClient interface + DeltaAggregatedResources func(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error) + StreamAggregatedResources func(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error) + func NewAggregatedDiscoveryServiceClient(cc grpc.ClientConnInterface) AggregatedDiscoveryServiceClient + type AggregatedDiscoveryServiceServer interface + DeltaAggregatedResources func(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error + StreamAggregatedResources func(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error + type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface + Recv func() (*v2.DeltaDiscoveryResponse, error) + Send func(*v2.DeltaDiscoveryRequest) error + type AggregatedDiscoveryService_DeltaAggregatedResourcesServer interface + Recv func() (*v2.DeltaDiscoveryRequest, error) + Send func(*v2.DeltaDiscoveryResponse) error + type AggregatedDiscoveryService_StreamAggregatedResourcesClient interface + Recv func() (*v2.DiscoveryResponse, error) + Send func(*v2.DiscoveryRequest) error + type AggregatedDiscoveryService_StreamAggregatedResourcesServer interface + Recv func() (*v2.DiscoveryRequest, error) + Send func(*v2.DiscoveryResponse) error + type Capability struct + HealthCheckProtocols []Capability_Protocol + func (*Capability) Descriptor() ([]byte, []int) + func (*Capability) ProtoMessage() + func (m *Capability) Validate() error + func (x *Capability) GetHealthCheckProtocols() []Capability_Protocol + func (x *Capability) ProtoReflect() protoreflect.Message + func (x *Capability) Reset() + func (x *Capability) String() string + type CapabilityValidationError struct + func (e CapabilityValidationError) Cause() error + func (e CapabilityValidationError) Error() string + func (e CapabilityValidationError) ErrorName() string + func (e CapabilityValidationError) Field() string + func (e CapabilityValidationError) Key() bool + func (e CapabilityValidationError) Reason() string + type Capability_Protocol int32 + const Capability_HTTP + const Capability_REDIS + const Capability_TCP + func (Capability_Protocol) Descriptor() protoreflect.EnumDescriptor + func (Capability_Protocol) EnumDescriptor() ([]byte, []int) + func (Capability_Protocol) Type() protoreflect.EnumType + func (x Capability_Protocol) Enum() *Capability_Protocol + func (x Capability_Protocol) Number() protoreflect.EnumNumber + func (x Capability_Protocol) String() string + type ClusterHealthCheck struct + ClusterName string + HealthChecks []*core.HealthCheck + LocalityEndpoints []*LocalityEndpoints + func (*ClusterHealthCheck) Descriptor() ([]byte, []int) + func (*ClusterHealthCheck) ProtoMessage() + func (m *ClusterHealthCheck) Validate() error + func (x *ClusterHealthCheck) GetClusterName() string + func (x *ClusterHealthCheck) GetHealthChecks() []*core.HealthCheck + func (x *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints + func (x *ClusterHealthCheck) ProtoReflect() protoreflect.Message + func (x *ClusterHealthCheck) Reset() + func (x *ClusterHealthCheck) String() string + type ClusterHealthCheckValidationError struct + func (e ClusterHealthCheckValidationError) Cause() error + func (e ClusterHealthCheckValidationError) Error() string + func (e ClusterHealthCheckValidationError) ErrorName() string + func (e ClusterHealthCheckValidationError) Field() string + func (e ClusterHealthCheckValidationError) Key() bool + func (e ClusterHealthCheckValidationError) Reason() string + type EndpointHealth struct + Endpoint *endpoint.Endpoint + HealthStatus core.HealthStatus + func (*EndpointHealth) Descriptor() ([]byte, []int) + func (*EndpointHealth) ProtoMessage() + func (m *EndpointHealth) Validate() error + func (x *EndpointHealth) GetEndpoint() *endpoint.Endpoint + func (x *EndpointHealth) GetHealthStatus() core.HealthStatus + func (x *EndpointHealth) ProtoReflect() protoreflect.Message + func (x *EndpointHealth) Reset() + func (x *EndpointHealth) String() string + type EndpointHealthResponse struct + EndpointsHealth []*EndpointHealth + func (*EndpointHealthResponse) Descriptor() ([]byte, []int) + func (*EndpointHealthResponse) ProtoMessage() + func (m *EndpointHealthResponse) Validate() error + func (x *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth + func (x *EndpointHealthResponse) ProtoReflect() protoreflect.Message + func (x *EndpointHealthResponse) Reset() + func (x *EndpointHealthResponse) String() string + type EndpointHealthResponseValidationError struct + func (e EndpointHealthResponseValidationError) Cause() error + func (e EndpointHealthResponseValidationError) Error() string + func (e EndpointHealthResponseValidationError) ErrorName() string + func (e EndpointHealthResponseValidationError) Field() string + func (e EndpointHealthResponseValidationError) Key() bool + func (e EndpointHealthResponseValidationError) Reason() string + type EndpointHealthValidationError struct + func (e EndpointHealthValidationError) Cause() error + func (e EndpointHealthValidationError) Error() string + func (e EndpointHealthValidationError) ErrorName() string + func (e EndpointHealthValidationError) Field() string + func (e EndpointHealthValidationError) Key() bool + func (e EndpointHealthValidationError) Reason() string + type HealthCheckRequest struct + Capability *Capability + Node *core.Node + func (*HealthCheckRequest) Descriptor() ([]byte, []int) + func (*HealthCheckRequest) ProtoMessage() + func (m *HealthCheckRequest) Validate() error + func (x *HealthCheckRequest) GetCapability() *Capability + func (x *HealthCheckRequest) GetNode() *core.Node + func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message + func (x *HealthCheckRequest) Reset() + func (x *HealthCheckRequest) String() string + type HealthCheckRequestOrEndpointHealthResponse struct + RequestType isHealthCheckRequestOrEndpointHealthResponse_RequestType + func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor() ([]byte, []int) + func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage() + func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType + func (m *HealthCheckRequestOrEndpointHealthResponse) Validate() error + func (x *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse + func (x *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest + func (x *HealthCheckRequestOrEndpointHealthResponse) ProtoReflect() protoreflect.Message + func (x *HealthCheckRequestOrEndpointHealthResponse) Reset() + func (x *HealthCheckRequestOrEndpointHealthResponse) String() string + type HealthCheckRequestOrEndpointHealthResponseValidationError struct + func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Cause() error + func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Error() string + func (e HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName() string + func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Field() string + func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Key() bool + func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Reason() string + type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse struct + EndpointHealthResponse *EndpointHealthResponse + type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest struct + HealthCheckRequest *HealthCheckRequest + type HealthCheckRequestValidationError struct + func (e HealthCheckRequestValidationError) Cause() error + func (e HealthCheckRequestValidationError) Error() string + func (e HealthCheckRequestValidationError) ErrorName() string + func (e HealthCheckRequestValidationError) Field() string + func (e HealthCheckRequestValidationError) Key() bool + func (e HealthCheckRequestValidationError) Reason() string + type HealthCheckSpecifier struct + ClusterHealthChecks []*ClusterHealthCheck + Interval *duration.Duration + func (*HealthCheckSpecifier) Descriptor() ([]byte, []int) + func (*HealthCheckSpecifier) ProtoMessage() + func (m *HealthCheckSpecifier) Validate() error + func (x *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck + func (x *HealthCheckSpecifier) GetInterval() *duration.Duration + func (x *HealthCheckSpecifier) ProtoReflect() protoreflect.Message + func (x *HealthCheckSpecifier) Reset() + func (x *HealthCheckSpecifier) String() string + type HealthCheckSpecifierValidationError struct + func (e HealthCheckSpecifierValidationError) Cause() error + func (e HealthCheckSpecifierValidationError) Error() string + func (e HealthCheckSpecifierValidationError) ErrorName() string + func (e HealthCheckSpecifierValidationError) Field() string + func (e HealthCheckSpecifierValidationError) Key() bool + func (e HealthCheckSpecifierValidationError) Reason() string + type HealthDiscoveryServiceClient interface + FetchHealthCheck func(ctx context.Context, in *HealthCheckRequestOrEndpointHealthResponse, ...) (*HealthCheckSpecifier, error) + StreamHealthCheck func(ctx context.Context, opts ...grpc.CallOption) (HealthDiscoveryService_StreamHealthCheckClient, error) + func NewHealthDiscoveryServiceClient(cc grpc.ClientConnInterface) HealthDiscoveryServiceClient + type HealthDiscoveryServiceServer interface + FetchHealthCheck func(context.Context, *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error) + StreamHealthCheck func(HealthDiscoveryService_StreamHealthCheckServer) error + type HealthDiscoveryService_StreamHealthCheckClient interface + Recv func() (*HealthCheckSpecifier, error) + Send func(*HealthCheckRequestOrEndpointHealthResponse) error + type HealthDiscoveryService_StreamHealthCheckServer interface + Recv func() (*HealthCheckRequestOrEndpointHealthResponse, error) + Send func(*HealthCheckSpecifier) error + type LocalityEndpoints struct + Endpoints []*endpoint.Endpoint + Locality *core.Locality + func (*LocalityEndpoints) Descriptor() ([]byte, []int) + func (*LocalityEndpoints) ProtoMessage() + func (m *LocalityEndpoints) Validate() error + func (x *LocalityEndpoints) GetEndpoints() []*endpoint.Endpoint + func (x *LocalityEndpoints) GetLocality() *core.Locality + func (x *LocalityEndpoints) ProtoReflect() protoreflect.Message + func (x *LocalityEndpoints) Reset() + func (x *LocalityEndpoints) String() string + type LocalityEndpointsValidationError struct + func (e LocalityEndpointsValidationError) Cause() error + func (e LocalityEndpointsValidationError) Error() string + func (e LocalityEndpointsValidationError) ErrorName() string + func (e LocalityEndpointsValidationError) Field() string + func (e LocalityEndpointsValidationError) Key() bool + func (e LocalityEndpointsValidationError) Reason() string + type RtdsDummy struct + func (*RtdsDummy) Descriptor() ([]byte, []int) + func (*RtdsDummy) ProtoMessage() + func (m *RtdsDummy) Validate() error + func (x *RtdsDummy) ProtoReflect() protoreflect.Message + func (x *RtdsDummy) Reset() + func (x *RtdsDummy) String() string + type RtdsDummyValidationError struct + func (e RtdsDummyValidationError) Cause() error + func (e RtdsDummyValidationError) Error() string + func (e RtdsDummyValidationError) ErrorName() string + func (e RtdsDummyValidationError) Field() string + func (e RtdsDummyValidationError) Key() bool + func (e RtdsDummyValidationError) Reason() string + type Runtime struct + Layer *_struct.Struct + Name string + func (*Runtime) Descriptor() ([]byte, []int) + func (*Runtime) ProtoMessage() + func (m *Runtime) Validate() error + func (x *Runtime) GetLayer() *_struct.Struct + func (x *Runtime) GetName() string + func (x *Runtime) ProtoReflect() protoreflect.Message + func (x *Runtime) Reset() + func (x *Runtime) String() string + type RuntimeDiscoveryServiceClient interface + DeltaRuntime func(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_DeltaRuntimeClient, error) + FetchRuntime func(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error) + StreamRuntime func(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_StreamRuntimeClient, error) + func NewRuntimeDiscoveryServiceClient(cc grpc.ClientConnInterface) RuntimeDiscoveryServiceClient + type RuntimeDiscoveryServiceServer interface + DeltaRuntime func(RuntimeDiscoveryService_DeltaRuntimeServer) error + FetchRuntime func(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error) + StreamRuntime func(RuntimeDiscoveryService_StreamRuntimeServer) error + type RuntimeDiscoveryService_DeltaRuntimeClient interface + Recv func() (*v2.DeltaDiscoveryResponse, error) + Send func(*v2.DeltaDiscoveryRequest) error + type RuntimeDiscoveryService_DeltaRuntimeServer interface + Recv func() (*v2.DeltaDiscoveryRequest, error) + Send func(*v2.DeltaDiscoveryResponse) error + type RuntimeDiscoveryService_StreamRuntimeClient interface + Recv func() (*v2.DiscoveryResponse, error) + Send func(*v2.DiscoveryRequest) error + type RuntimeDiscoveryService_StreamRuntimeServer interface + Recv func() (*v2.DiscoveryRequest, error) + Send func(*v2.DiscoveryResponse) error + type RuntimeValidationError struct + func (e RuntimeValidationError) Cause() error + func (e RuntimeValidationError) Error() string + func (e RuntimeValidationError) ErrorName() string + func (e RuntimeValidationError) Field() string + func (e RuntimeValidationError) Key() bool + func (e RuntimeValidationError) Reason() string + type SdsDummy struct + func (*SdsDummy) Descriptor() ([]byte, []int) + func (*SdsDummy) ProtoMessage() + func (m *SdsDummy) Validate() error + func (x *SdsDummy) ProtoReflect() protoreflect.Message + func (x *SdsDummy) Reset() + func (x *SdsDummy) String() string + type SdsDummyValidationError struct + func (e SdsDummyValidationError) Cause() error + func (e SdsDummyValidationError) Error() string + func (e SdsDummyValidationError) ErrorName() string + func (e SdsDummyValidationError) Field() string + func (e SdsDummyValidationError) Key() bool + func (e SdsDummyValidationError) Reason() string + type SecretDiscoveryServiceClient interface + DeltaSecrets func(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_DeltaSecretsClient, error) + FetchSecrets func(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error) + StreamSecrets func(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_StreamSecretsClient, error) + func NewSecretDiscoveryServiceClient(cc grpc.ClientConnInterface) SecretDiscoveryServiceClient + type SecretDiscoveryServiceServer interface + DeltaSecrets func(SecretDiscoveryService_DeltaSecretsServer) error + FetchSecrets func(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error) + StreamSecrets func(SecretDiscoveryService_StreamSecretsServer) error + type SecretDiscoveryService_DeltaSecretsClient interface + Recv func() (*v2.DeltaDiscoveryResponse, error) + Send func(*v2.DeltaDiscoveryRequest) error + type SecretDiscoveryService_DeltaSecretsServer interface + Recv func() (*v2.DeltaDiscoveryRequest, error) + Send func(*v2.DeltaDiscoveryResponse) error + type SecretDiscoveryService_StreamSecretsClient interface + Recv func() (*v2.DiscoveryResponse, error) + Send func(*v2.DiscoveryRequest) error + type SecretDiscoveryService_StreamSecretsServer interface + Recv func() (*v2.DiscoveryRequest, error) + Send func(*v2.DiscoveryResponse) error + type UnimplementedAggregatedDiscoveryServiceServer struct + func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error + func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error + type UnimplementedHealthDiscoveryServiceServer struct + func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck(context.Context, *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error) + func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck(HealthDiscoveryService_StreamHealthCheckServer) error + type UnimplementedRuntimeDiscoveryServiceServer struct + func (*UnimplementedRuntimeDiscoveryServiceServer) DeltaRuntime(RuntimeDiscoveryService_DeltaRuntimeServer) error + func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error) + func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime(RuntimeDiscoveryService_StreamRuntimeServer) error + type UnimplementedSecretDiscoveryServiceServer struct + func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets(SecretDiscoveryService_DeltaSecretsServer) error + func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error) + func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets(SecretDiscoveryService_StreamSecretsServer) error
Go to main page