Versions in this module Expand all Collapse all v0 v0.6.1 Oct 15, 2018 v0.6.0 Sep 25, 2018 v0.5.0 Aug 14, 2018 Changes in this version + var Capability_Protocol_name = map[int32]string + var Capability_Protocol_value = map[string]int32 + var ErrIntOverflowAds = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowHds = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowSds = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthAds = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthHds = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthSds = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer) + func RegisterHealthDiscoveryServiceServer(s *grpc.Server, srv HealthDiscoveryServiceServer) + 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 (dst *AdsDummy) XXX_Merge(src proto.Message) + func (m *AdsDummy) Marshal() (dAtA []byte, err error) + func (m *AdsDummy) MarshalTo(dAtA []byte) (int, error) + func (m *AdsDummy) Reset() + func (m *AdsDummy) Size() (n int) + func (m *AdsDummy) String() string + func (m *AdsDummy) Unmarshal(dAtA []byte) error + func (m *AdsDummy) Validate() error + func (m *AdsDummy) XXX_DiscardUnknown() + func (m *AdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AdsDummy) XXX_Size() int + func (m *AdsDummy) XXX_Unmarshal(b []byte) error + type AdsDummyValidationError struct + Cause error + Field string + Key bool + Reason string + func (e AdsDummyValidationError) Error() string + type AggregatedDiscoveryServiceClient interface + IncrementalAggregatedResources func(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_IncrementalAggregatedResourcesClient, error) + StreamAggregatedResources func(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error) + func NewAggregatedDiscoveryServiceClient(cc *grpc.ClientConn) AggregatedDiscoveryServiceClient + type AggregatedDiscoveryServiceServer interface + IncrementalAggregatedResources func(AggregatedDiscoveryService_IncrementalAggregatedResourcesServer) error + StreamAggregatedResources func(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error + type AggregatedDiscoveryService_IncrementalAggregatedResourcesClient interface + Recv func() (*v2.IncrementalDiscoveryResponse, error) + Send func(*v2.IncrementalDiscoveryRequest) error + type AggregatedDiscoveryService_IncrementalAggregatedResourcesServer interface + Recv func() (*v2.IncrementalDiscoveryRequest, error) + Send func(*v2.IncrementalDiscoveryResponse) 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 (dst *Capability) XXX_Merge(src proto.Message) + func (m *Capability) GetHealthCheckProtocols() []Capability_Protocol + func (m *Capability) Marshal() (dAtA []byte, err error) + func (m *Capability) MarshalTo(dAtA []byte) (int, error) + func (m *Capability) Reset() + func (m *Capability) Size() (n int) + func (m *Capability) String() string + func (m *Capability) Unmarshal(dAtA []byte) error + func (m *Capability) Validate() error + func (m *Capability) XXX_DiscardUnknown() + func (m *Capability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Capability) XXX_Size() int + func (m *Capability) XXX_Unmarshal(b []byte) error + type CapabilityValidationError struct + Cause error + Field string + Key bool + Reason string + func (e CapabilityValidationError) Error() string + 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 (dst *ClusterHealthCheck) XXX_Merge(src proto.Message) + func (m *ClusterHealthCheck) GetClusterName() string + func (m *ClusterHealthCheck) GetHealthChecks() []*core.HealthCheck + func (m *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints + func (m *ClusterHealthCheck) Marshal() (dAtA []byte, err error) + func (m *ClusterHealthCheck) MarshalTo(dAtA []byte) (int, error) + func (m *ClusterHealthCheck) Reset() + func (m *ClusterHealthCheck) Size() (n int) + func (m *ClusterHealthCheck) String() string + func (m *ClusterHealthCheck) Unmarshal(dAtA []byte) error + func (m *ClusterHealthCheck) Validate() error + func (m *ClusterHealthCheck) XXX_DiscardUnknown() + func (m *ClusterHealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClusterHealthCheck) XXX_Size() int + func (m *ClusterHealthCheck) XXX_Unmarshal(b []byte) error + type ClusterHealthCheckValidationError struct + Cause error + Field string + Key bool + Reason string + func (e ClusterHealthCheckValidationError) Error() string + 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 (dst *EndpointHealth) XXX_Merge(src proto.Message) + func (m *EndpointHealth) GetEndpoint() *endpoint.Endpoint + func (m *EndpointHealth) GetHealthStatus() core.HealthStatus + func (m *EndpointHealth) Marshal() (dAtA []byte, err error) + func (m *EndpointHealth) MarshalTo(dAtA []byte) (int, error) + func (m *EndpointHealth) Reset() + func (m *EndpointHealth) Size() (n int) + func (m *EndpointHealth) String() string + func (m *EndpointHealth) Unmarshal(dAtA []byte) error + func (m *EndpointHealth) Validate() error + func (m *EndpointHealth) XXX_DiscardUnknown() + func (m *EndpointHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *EndpointHealthResponse) XXX_Merge(src proto.Message) + func (m *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth + func (m *EndpointHealthResponse) Marshal() (dAtA []byte, err error) + func (m *EndpointHealthResponse) MarshalTo(dAtA []byte) (int, error) + func (m *EndpointHealthResponse) Reset() + func (m *EndpointHealthResponse) Size() (n int) + func (m *EndpointHealthResponse) String() string + func (m *EndpointHealthResponse) Unmarshal(dAtA []byte) error + func (m *EndpointHealthResponse) Validate() error + func (m *EndpointHealthResponse) XXX_DiscardUnknown() + func (m *EndpointHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EndpointHealthResponse) XXX_Size() int + func (m *EndpointHealthResponse) XXX_Unmarshal(b []byte) error + type EndpointHealthResponseValidationError struct + Cause error + Field string + Key bool + Reason string + func (e EndpointHealthResponseValidationError) Error() string + type EndpointHealthValidationError struct + Cause error + Field string + Key bool + Reason string + func (e EndpointHealthValidationError) Error() string + 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 (dst *HealthCheckRequest) XXX_Merge(src proto.Message) + func (m *HealthCheckRequest) GetCapability() *Capability + func (m *HealthCheckRequest) GetNode() *core.Node + func (m *HealthCheckRequest) Marshal() (dAtA []byte, err error) + func (m *HealthCheckRequest) MarshalTo(dAtA []byte) (int, error) + func (m *HealthCheckRequest) Reset() + func (m *HealthCheckRequest) Size() (n int) + func (m *HealthCheckRequest) String() string + func (m *HealthCheckRequest) Unmarshal(dAtA []byte) error + func (m *HealthCheckRequest) Validate() error + func (m *HealthCheckRequest) XXX_DiscardUnknown() + func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (dst *HealthCheckRequestOrEndpointHealthResponse) XXX_Merge(src proto.Message) + func (m *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse + func (m *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest + func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType + func (m *HealthCheckRequestOrEndpointHealthResponse) Marshal() (dAtA []byte, err error) + func (m *HealthCheckRequestOrEndpointHealthResponse) MarshalTo(dAtA []byte) (int, error) + func (m *HealthCheckRequestOrEndpointHealthResponse) Reset() + func (m *HealthCheckRequestOrEndpointHealthResponse) Size() (n int) + func (m *HealthCheckRequestOrEndpointHealthResponse) String() string + func (m *HealthCheckRequestOrEndpointHealthResponse) Unmarshal(dAtA []byte) error + func (m *HealthCheckRequestOrEndpointHealthResponse) Validate() error + func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_DiscardUnknown() + func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Size() int + func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal(b []byte) error + type HealthCheckRequestOrEndpointHealthResponseValidationError struct + Cause error + Field string + Key bool + Reason string + func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Error() string + type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse struct + EndpointHealthResponse *EndpointHealthResponse + func (m *HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse) MarshalTo(dAtA []byte) (int, error) + func (m *HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse) Size() (n int) + type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest struct + HealthCheckRequest *HealthCheckRequest + func (m *HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest) MarshalTo(dAtA []byte) (int, error) + func (m *HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest) Size() (n int) + type HealthCheckRequestValidationError struct + Cause error + Field string + Key bool + Reason string + func (e HealthCheckRequestValidationError) Error() string + 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 (dst *HealthCheckSpecifier) XXX_Merge(src proto.Message) + func (m *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck + func (m *HealthCheckSpecifier) GetInterval() *types.Duration + func (m *HealthCheckSpecifier) Marshal() (dAtA []byte, err error) + func (m *HealthCheckSpecifier) MarshalTo(dAtA []byte) (int, error) + func (m *HealthCheckSpecifier) Reset() + func (m *HealthCheckSpecifier) Size() (n int) + func (m *HealthCheckSpecifier) String() string + func (m *HealthCheckSpecifier) Unmarshal(dAtA []byte) error + func (m *HealthCheckSpecifier) Validate() error + func (m *HealthCheckSpecifier) XXX_DiscardUnknown() + func (m *HealthCheckSpecifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HealthCheckSpecifier) XXX_Size() int + func (m *HealthCheckSpecifier) XXX_Unmarshal(b []byte) error + type HealthCheckSpecifierValidationError struct + Cause error + Field string + Key bool + Reason string + func (e HealthCheckSpecifierValidationError) Error() 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.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 (dst *LocalityEndpoints) XXX_Merge(src proto.Message) + func (m *LocalityEndpoints) GetEndpoints() []*endpoint.Endpoint + func (m *LocalityEndpoints) GetLocality() *core.Locality + func (m *LocalityEndpoints) Marshal() (dAtA []byte, err error) + func (m *LocalityEndpoints) MarshalTo(dAtA []byte) (int, error) + func (m *LocalityEndpoints) Reset() + func (m *LocalityEndpoints) Size() (n int) + func (m *LocalityEndpoints) String() string + func (m *LocalityEndpoints) Unmarshal(dAtA []byte) error + func (m *LocalityEndpoints) Validate() error + func (m *LocalityEndpoints) XXX_DiscardUnknown() + func (m *LocalityEndpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LocalityEndpoints) XXX_Size() int + func (m *LocalityEndpoints) XXX_Unmarshal(b []byte) error + type LocalityEndpointsValidationError struct + Cause error + Field string + Key bool + Reason string + func (e LocalityEndpointsValidationError) Error() string + type SdsDummy struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SdsDummy) Descriptor() ([]byte, []int) + func (*SdsDummy) ProtoMessage() + func (dst *SdsDummy) XXX_Merge(src proto.Message) + func (m *SdsDummy) Marshal() (dAtA []byte, err error) + func (m *SdsDummy) MarshalTo(dAtA []byte) (int, error) + func (m *SdsDummy) Reset() + func (m *SdsDummy) Size() (n int) + func (m *SdsDummy) String() string + func (m *SdsDummy) Unmarshal(dAtA []byte) error + func (m *SdsDummy) Validate() error + func (m *SdsDummy) XXX_DiscardUnknown() + func (m *SdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SdsDummy) XXX_Size() int + func (m *SdsDummy) XXX_Unmarshal(b []byte) error + type SdsDummyValidationError struct + Cause error + Field string + Key bool + Reason string + func (e SdsDummyValidationError) Error() string + type SecretDiscoveryServiceClient interface + 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 + FetchSecrets func(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error) + StreamSecrets func(SecretDiscoveryService_StreamSecretsServer) 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