v2

Aug 9, 2024

Changes in this version

+ const AggregatedDiscoveryService_DeltaAggregatedResources_FullMethodName

+ const AggregatedDiscoveryService_StreamAggregatedResources_FullMethodName

+ const HealthDiscoveryService_FetchHealthCheck_FullMethodName

+ const HealthDiscoveryService_StreamHealthCheck_FullMethodName

+ const RuntimeDiscoveryService_DeltaRuntime_FullMethodName

+ const RuntimeDiscoveryService_FetchRuntime_FullMethodName

+ const RuntimeDiscoveryService_StreamRuntime_FullMethodName

+ const SecretDiscoveryService_DeltaSecrets_FullMethodName

+ const SecretDiscoveryService_FetchSecrets_FullMethodName

+ const SecretDiscoveryService_StreamSecrets_FullMethodName

+ var AggregatedDiscoveryService_ServiceDesc = grpc.ServiceDesc

+ var HealthDiscoveryService_ServiceDesc = grpc.ServiceDesc

+ var RuntimeDiscoveryService_ServiceDesc = grpc.ServiceDesc

+ var SecretDiscoveryService_ServiceDesc = grpc.ServiceDesc

+ type UnsafeAggregatedDiscoveryServiceServer interface

+ type UnsafeHealthDiscoveryServiceServer interface

+ type UnsafeRuntimeDiscoveryServiceServer interface

+ type UnsafeSecretDiscoveryServiceServer interface

Oct 28, 2021

Changes in this version

type AdsDummy

+ func (m *AdsDummy) ValidateAll() error

+ type AdsDummyMultiError []error

+ func (m AdsDummyMultiError) AllErrors() []error

+ func (m AdsDummyMultiError) Error() string

type Capability

+ func (m *Capability) ValidateAll() error

+ type CapabilityMultiError []error

+ func (m CapabilityMultiError) AllErrors() []error

+ func (m CapabilityMultiError) Error() string

type ClusterHealthCheck

+ func (m *ClusterHealthCheck) ValidateAll() error

+ type ClusterHealthCheckMultiError []error

+ func (m ClusterHealthCheckMultiError) AllErrors() []error

+ func (m ClusterHealthCheckMultiError) Error() string

type EndpointHealth

+ func (m *EndpointHealth) ValidateAll() error

+ type EndpointHealthMultiError []error

+ func (m EndpointHealthMultiError) AllErrors() []error

+ func (m EndpointHealthMultiError) Error() string

type EndpointHealthResponse

+ func (m *EndpointHealthResponse) ValidateAll() error

+ type EndpointHealthResponseMultiError []error

+ func (m EndpointHealthResponseMultiError) AllErrors() []error

+ func (m EndpointHealthResponseMultiError) Error() string

type HealthCheckRequest

+ func (m *HealthCheckRequest) ValidateAll() error

+ type HealthCheckRequestMultiError []error

+ func (m HealthCheckRequestMultiError) AllErrors() []error

+ func (m HealthCheckRequestMultiError) Error() string

type HealthCheckRequestOrEndpointHealthResponse

+ func (m *HealthCheckRequestOrEndpointHealthResponse) ValidateAll() error

+ type HealthCheckRequestOrEndpointHealthResponseMultiError []error

+ func (m HealthCheckRequestOrEndpointHealthResponseMultiError) AllErrors() []error

+ func (m HealthCheckRequestOrEndpointHealthResponseMultiError) Error() string

type HealthCheckSpecifier

+ func (m *HealthCheckSpecifier) ValidateAll() error

+ type HealthCheckSpecifierMultiError []error

+ func (m HealthCheckSpecifierMultiError) AllErrors() []error

+ func (m HealthCheckSpecifierMultiError) Error() string

type LocalityEndpoints

+ func (m *LocalityEndpoints) ValidateAll() error

+ type LocalityEndpointsMultiError []error

+ func (m LocalityEndpointsMultiError) AllErrors() []error

+ func (m LocalityEndpointsMultiError) Error() string

type RtdsDummy

+ func (m *RtdsDummy) ValidateAll() error

+ type RtdsDummyMultiError []error

+ func (m RtdsDummyMultiError) AllErrors() []error

+ func (m RtdsDummyMultiError) Error() string

type Runtime

+ func (m *Runtime) ValidateAll() error

+ type RuntimeMultiError []error

+ func (m RuntimeMultiError) AllErrors() []error

+ func (m RuntimeMultiError) Error() string

type SdsDummy

+ func (m *SdsDummy) ValidateAll() error

+ type SdsDummyMultiError []error

+ func (m SdsDummyMultiError) AllErrors() []error

+ func (m SdsDummyMultiError) Error() string

Jul 5, 2020

Changes in this version

+ 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

type AdsDummy

+ func (x *AdsDummy) ProtoReflect() protoreflect.Message

type Capability

+ func (x *Capability) ProtoReflect() protoreflect.Message

type Capability_Protocol

+ func (Capability_Protocol) Descriptor() protoreflect.EnumDescriptor

+ func (Capability_Protocol) Type() protoreflect.EnumType

+ func (x Capability_Protocol) Enum() *Capability_Protocol

+ func (x Capability_Protocol) Number() protoreflect.EnumNumber

type ClusterHealthCheck

+ func (x *ClusterHealthCheck) ProtoReflect() protoreflect.Message

type EndpointHealth

+ func (x *EndpointHealth) ProtoReflect() protoreflect.Message

type EndpointHealthResponse

+ func (x *EndpointHealthResponse) ProtoReflect() protoreflect.Message

type HealthCheckRequest

+ func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message

type HealthCheckRequestOrEndpointHealthResponse

+ func (x *HealthCheckRequestOrEndpointHealthResponse) ProtoReflect() protoreflect.Message

type HealthCheckSpecifier

+ func (x *HealthCheckSpecifier) ProtoReflect() protoreflect.Message

type LocalityEndpoints

+ func (x *LocalityEndpoints) ProtoReflect() protoreflect.Message

type RtdsDummy

+ func (x *RtdsDummy) ProtoReflect() protoreflect.Message

type Runtime

+ func (x *Runtime) ProtoReflect() protoreflect.Message

type SdsDummy

+ func (x *SdsDummy) ProtoReflect() protoreflect.Message

Nov 9, 2019

Changes in this version

+ type UnimplementedAggregatedDiscoveryServiceServer struct

+ func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources(srv AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error

+ func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources(srv AggregatedDiscoveryService_StreamAggregatedResourcesServer) error

+ type UnimplementedHealthDiscoveryServiceServer struct

+ func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck(ctx context.Context, req *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error)

+ func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck(srv HealthDiscoveryService_StreamHealthCheckServer) error

+ type UnimplementedRuntimeDiscoveryServiceServer struct

+ func (*UnimplementedRuntimeDiscoveryServiceServer) DeltaRuntime(srv RuntimeDiscoveryService_DeltaRuntimeServer) error

+ func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime(ctx context.Context, req *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

+ func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime(srv RuntimeDiscoveryService_StreamRuntimeServer) error

+ type UnimplementedSecretDiscoveryServiceServer struct

+ func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets(srv SecretDiscoveryService_DeltaSecretsServer) error

+ func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets(ctx context.Context, req *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

+ func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets(srv SecretDiscoveryService_StreamSecretsServer) error

Sep 10, 2019

Changes in this version

type HealthCheckRequestOrEndpointHealthResponse

+ func (*HealthCheckRequestOrEndpointHealthResponse) XXX_OneofWrappers() []interface{}

Jul 8, 2019

Changes in this version

+ var ErrIntOverflowRtds = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthRtds = fmt.Errorf("proto: negative length found during unmarshaling")

+ type RtdsDummy struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RtdsDummy) Descriptor() ([]byte, []int)

+ func (*RtdsDummy) ProtoMessage()

+ func (m *RtdsDummy) Marshal() (dAtA []byte, err error)

+ func (m *RtdsDummy) MarshalTo(dAtA []byte) (int, error)

+ func (m *RtdsDummy) Reset()

+ func (m *RtdsDummy) Size() (n int)

+ func (m *RtdsDummy) String() string

+ func (m *RtdsDummy) Unmarshal(dAtA []byte) error

+ func (m *RtdsDummy) Validate() error

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

+ Name string

+ func (m *Runtime) GetName() string

type RuntimeDiscoveryServiceClient

+ DeltaRuntime func(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_DeltaRuntimeClient, error)

type RuntimeDiscoveryServiceServer

+ DeltaRuntime func(RuntimeDiscoveryService_DeltaRuntimeServer) 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

Jun 15, 2019

Changes in this version

+ var ErrIntOverflowTds = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthTds = fmt.Errorf("proto: negative length found during unmarshaling")

+ func RegisterRuntimeDiscoveryServiceServer(s *grpc.Server, srv RuntimeDiscoveryServiceServer)

+ type Runtime struct

+ Layer *types.Struct

+ 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) Marshal() (dAtA []byte, err error)

+ func (m *Runtime) MarshalTo(dAtA []byte) (int, error)

+ func (m *Runtime) Reset()

+ func (m *Runtime) Size() (n int)

+ func (m *Runtime) String() string

+ func (m *Runtime) Unmarshal(dAtA []byte) error

+ func (m *Runtime) Validate() error

+ 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

+ 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

+ FetchRuntime func(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

+ StreamRuntime func(RuntimeDiscoveryService_StreamRuntimeServer) 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 SecretDiscoveryServiceClient

+ DeltaSecrets func(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_DeltaSecretsClient, error)

type SecretDiscoveryServiceServer

+ DeltaSecrets func(SecretDiscoveryService_DeltaSecretsServer) 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 TdsDummy struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TdsDummy) Descriptor() ([]byte, []int)

+ func (*TdsDummy) ProtoMessage()

+ func (m *TdsDummy) Marshal() (dAtA []byte, err error)

+ func (m *TdsDummy) MarshalTo(dAtA []byte) (int, error)

+ func (m *TdsDummy) Reset()

+ func (m *TdsDummy) Size() (n int)

+ func (m *TdsDummy) String() string

+ func (m *TdsDummy) Unmarshal(dAtA []byte) error

+ func (m *TdsDummy) Validate() error

+ func (m *TdsDummy) XXX_DiscardUnknown()

+ func (m *TdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TdsDummy) XXX_Merge(src proto.Message)

+ func (m *TdsDummy) XXX_Size() int

+ func (m *TdsDummy) XXX_Unmarshal(b []byte) error

+ type TdsDummyValidationError struct

+ func (e TdsDummyValidationError) Cause() error

+ func (e TdsDummyValidationError) Error() string

+ func (e TdsDummyValidationError) ErrorName() string

+ func (e TdsDummyValidationError) Field() string

+ func (e TdsDummyValidationError) Key() bool

+ func (e TdsDummyValidationError) Reason() string

Apr 8, 2019

Changes in this version

type AdsDummyValidationError

+ func (e AdsDummyValidationError) ErrorName() string

type CapabilityValidationError

+ func (e CapabilityValidationError) ErrorName() string

type ClusterHealthCheckValidationError

+ func (e ClusterHealthCheckValidationError) ErrorName() string

type EndpointHealthResponseValidationError

+ func (e EndpointHealthResponseValidationError) ErrorName() string

type EndpointHealthValidationError

+ func (e EndpointHealthValidationError) ErrorName() string

type HealthCheckRequestOrEndpointHealthResponseValidationError

+ func (e HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName() string

type HealthCheckRequestValidationError

+ func (e HealthCheckRequestValidationError) ErrorName() string

type HealthCheckSpecifierValidationError

+ func (e HealthCheckSpecifierValidationError) ErrorName() string

type LocalityEndpointsValidationError

+ func (e LocalityEndpointsValidationError) ErrorName() string

type SdsDummyValidationError

+ func (e SdsDummyValidationError) ErrorName() string

Mar 11, 2019

Changes in this version

type AggregatedDiscoveryServiceClient

+ DeltaAggregatedResources func(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error)

type AggregatedDiscoveryServiceServer

+ DeltaAggregatedResources func(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) 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

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