v2

package

Go to main page

Versions in this module

v0

v0.7.1

Apr 19, 2019

v0.7.0

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

v0.6.9

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

v0.6.8

Mar 1, 2019

v0.6.7

Jan 25, 2019

v0.6.6

Jan 4, 2019

v0.6.5

Dec 21, 2018

v0.6.4

Dec 21, 2018

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL