Versions in this module Expand all Collapse all v1 v1.12.1 Mar 30, 2020 Changes in this version + var Capability_Protocol_name = map[int32]string + var Capability_Protocol_value = map[string]int32 + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AdsDummy) Descriptor() ([]byte, []int) + func (*AdsDummy) ProtoMessage() + func (m *AdsDummy) Reset() + func (m *AdsDummy) String() string + func (m *AdsDummy) XXX_DiscardUnknown() + func (m *AdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AdsDummy) XXX_Merge(src proto.Message) + func (m *AdsDummy) XXX_Size() int + func (m *AdsDummy) XXX_Unmarshal(b []byte) error + 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.ClientConn) 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Capability) Descriptor() ([]byte, []int) + func (*Capability) ProtoMessage() + func (m *Capability) GetHealthCheckProtocols() []Capability_Protocol + func (m *Capability) Reset() + func (m *Capability) String() string + func (m *Capability) XXX_DiscardUnknown() + func (m *Capability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Capability) XXX_Merge(src proto.Message) + func (m *Capability) XXX_Size() int + func (m *Capability) XXX_Unmarshal(b []byte) error + type Capability_Protocol int32 + const Capability_HTTP + const Capability_REDIS + const Capability_TCP + func (Capability_Protocol) EnumDescriptor() ([]byte, []int) + func (x Capability_Protocol) String() string + type ClusterHealthCheck struct + ClusterName string + HealthChecks []*core.HealthCheck + LocalityEndpoints []*LocalityEndpoints + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClusterHealthCheck) Descriptor() ([]byte, []int) + func (*ClusterHealthCheck) ProtoMessage() + func (m *ClusterHealthCheck) GetClusterName() string + func (m *ClusterHealthCheck) GetHealthChecks() []*core.HealthCheck + func (m *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints + func (m *ClusterHealthCheck) Reset() + func (m *ClusterHealthCheck) String() string + func (m *ClusterHealthCheck) XXX_DiscardUnknown() + func (m *ClusterHealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClusterHealthCheck) XXX_Merge(src proto.Message) + func (m *ClusterHealthCheck) XXX_Size() int + func (m *ClusterHealthCheck) XXX_Unmarshal(b []byte) error + type EndpointHealth struct + Endpoint *endpoint.Endpoint + HealthStatus core.HealthStatus + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EndpointHealth) Descriptor() ([]byte, []int) + func (*EndpointHealth) ProtoMessage() + func (m *EndpointHealth) GetEndpoint() *endpoint.Endpoint + func (m *EndpointHealth) GetHealthStatus() core.HealthStatus + func (m *EndpointHealth) Reset() + func (m *EndpointHealth) String() string + func (m *EndpointHealth) XXX_DiscardUnknown() + func (m *EndpointHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EndpointHealth) XXX_Merge(src proto.Message) + func (m *EndpointHealth) XXX_Size() int + func (m *EndpointHealth) XXX_Unmarshal(b []byte) error + type EndpointHealthResponse struct + EndpointsHealth []*EndpointHealth + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EndpointHealthResponse) Descriptor() ([]byte, []int) + func (*EndpointHealthResponse) ProtoMessage() + func (m *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth + func (m *EndpointHealthResponse) Reset() + func (m *EndpointHealthResponse) String() string + func (m *EndpointHealthResponse) XXX_DiscardUnknown() + func (m *EndpointHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EndpointHealthResponse) XXX_Merge(src proto.Message) + func (m *EndpointHealthResponse) XXX_Size() int + func (m *EndpointHealthResponse) XXX_Unmarshal(b []byte) error + type HealthCheckRequest struct + Capability *Capability + Node *core.Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HealthCheckRequest) Descriptor() ([]byte, []int) + func (*HealthCheckRequest) ProtoMessage() + func (m *HealthCheckRequest) GetCapability() *Capability + func (m *HealthCheckRequest) GetNode() *core.Node + func (m *HealthCheckRequest) Reset() + func (m *HealthCheckRequest) String() string + func (m *HealthCheckRequest) XXX_DiscardUnknown() + func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HealthCheckRequest) XXX_Merge(src proto.Message) + func (m *HealthCheckRequest) XXX_Size() int + func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error + type HealthCheckRequestOrEndpointHealthResponse struct + RequestType isHealthCheckRequestOrEndpointHealthResponse_RequestType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor() ([]byte, []int) + func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage() + func (*HealthCheckRequestOrEndpointHealthResponse) XXX_OneofWrappers() []interface{} + func (m *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse + func (m *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest + func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType + func (m *HealthCheckRequestOrEndpointHealthResponse) Reset() + func (m *HealthCheckRequestOrEndpointHealthResponse) String() string + func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_DiscardUnknown() + func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Merge(src proto.Message) + func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Size() int + func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal(b []byte) error + type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse struct + EndpointHealthResponse *EndpointHealthResponse + type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest struct + HealthCheckRequest *HealthCheckRequest + type HealthCheckSpecifier struct + ClusterHealthChecks []*ClusterHealthCheck + Interval *types.Duration + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HealthCheckSpecifier) Descriptor() ([]byte, []int) + func (*HealthCheckSpecifier) ProtoMessage() + func (m *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck + func (m *HealthCheckSpecifier) GetInterval() *types.Duration + func (m *HealthCheckSpecifier) Reset() + func (m *HealthCheckSpecifier) String() string + func (m *HealthCheckSpecifier) XXX_DiscardUnknown() + func (m *HealthCheckSpecifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HealthCheckSpecifier) XXX_Merge(src proto.Message) + func (m *HealthCheckSpecifier) XXX_Size() int + func (m *HealthCheckSpecifier) XXX_Unmarshal(b []byte) error + 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.ClientConn) 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LocalityEndpoints) Descriptor() ([]byte, []int) + func (*LocalityEndpoints) ProtoMessage() + func (m *LocalityEndpoints) GetEndpoints() []*endpoint.Endpoint + func (m *LocalityEndpoints) GetLocality() *core.Locality + func (m *LocalityEndpoints) Reset() + func (m *LocalityEndpoints) String() string + func (m *LocalityEndpoints) XXX_DiscardUnknown() + func (m *LocalityEndpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LocalityEndpoints) XXX_Merge(src proto.Message) + func (m *LocalityEndpoints) XXX_Size() int + func (m *LocalityEndpoints) XXX_Unmarshal(b []byte) error + type RtdsDummy struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RtdsDummy) Descriptor() ([]byte, []int) + func (*RtdsDummy) ProtoMessage() + func (m *RtdsDummy) Reset() + func (m *RtdsDummy) String() string + func (m *RtdsDummy) XXX_DiscardUnknown() + func (m *RtdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RtdsDummy) XXX_Merge(src proto.Message) + func (m *RtdsDummy) XXX_Size() int + func (m *RtdsDummy) XXX_Unmarshal(b []byte) error + type Runtime struct + Layer *types.Struct + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Runtime) Descriptor() ([]byte, []int) + func (*Runtime) ProtoMessage() + func (m *Runtime) GetLayer() *types.Struct + func (m *Runtime) GetName() string + func (m *Runtime) Reset() + func (m *Runtime) String() string + func (m *Runtime) XXX_DiscardUnknown() + func (m *Runtime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Runtime) XXX_Merge(src proto.Message) + func (m *Runtime) XXX_Size() int + func (m *Runtime) XXX_Unmarshal(b []byte) error + 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.ClientConn) 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 SdsDummy struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SdsDummy) Descriptor() ([]byte, []int) + func (*SdsDummy) ProtoMessage() + func (m *SdsDummy) Reset() + func (m *SdsDummy) String() string + func (m *SdsDummy) XXX_DiscardUnknown() + func (m *SdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SdsDummy) XXX_Merge(src proto.Message) + func (m *SdsDummy) XXX_Size() int + func (m *SdsDummy) XXX_Unmarshal(b []byte) error + 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.ClientConn) 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
Go to main page