Versions in this module Expand all Collapse all v0 v0.6.3 Nov 12, 2018 v0.6.2 Nov 6, 2018 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