Documentation ¶
Index ¶
- Variables
- 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
- func (*AdsDummy) Descriptor() ([]byte, []int)
- func (*AdsDummy) ProtoMessage()
- func (m *AdsDummy) Reset()
- func (m *AdsDummy) String() string
- 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_Merge(src proto.Message)
- func (m *AdsDummy) XXX_Size() int
- func (m *AdsDummy) XXX_Unmarshal(b []byte) error
- type AdsDummyValidationError
- type AggregatedDiscoveryServiceClient
- type AggregatedDiscoveryServiceServer
- type AggregatedDiscoveryService_DeltaAggregatedResourcesClient
- type AggregatedDiscoveryService_DeltaAggregatedResourcesServer
- type AggregatedDiscoveryService_StreamAggregatedResourcesClient
- type AggregatedDiscoveryService_StreamAggregatedResourcesServer
- type Capability
- func (*Capability) Descriptor() ([]byte, []int)
- func (m *Capability) GetHealthCheckProtocols() []Capability_Protocol
- func (*Capability) ProtoMessage()
- func (m *Capability) Reset()
- func (m *Capability) String() string
- 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_Merge(src proto.Message)
- func (m *Capability) XXX_Size() int
- func (m *Capability) XXX_Unmarshal(b []byte) error
- type CapabilityValidationError
- type Capability_Protocol
- type ClusterHealthCheck
- func (*ClusterHealthCheck) Descriptor() ([]byte, []int)
- func (m *ClusterHealthCheck) GetClusterName() string
- func (m *ClusterHealthCheck) GetHealthChecks() []*core.HealthCheck
- func (m *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints
- func (*ClusterHealthCheck) ProtoMessage()
- func (m *ClusterHealthCheck) Reset()
- func (m *ClusterHealthCheck) String() string
- 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_Merge(src proto.Message)
- func (m *ClusterHealthCheck) XXX_Size() int
- func (m *ClusterHealthCheck) XXX_Unmarshal(b []byte) error
- type ClusterHealthCheckValidationError
- func (e ClusterHealthCheckValidationError) Cause() error
- func (e ClusterHealthCheckValidationError) Error() string
- func (e ClusterHealthCheckValidationError) ErrorName() string
- func (e ClusterHealthCheckValidationError) Field() string
- func (e ClusterHealthCheckValidationError) Key() bool
- func (e ClusterHealthCheckValidationError) Reason() string
- type EndpointHealth
- func (*EndpointHealth) Descriptor() ([]byte, []int)
- func (m *EndpointHealth) GetEndpoint() *endpoint.Endpoint
- func (m *EndpointHealth) GetHealthStatus() core.HealthStatus
- func (*EndpointHealth) ProtoMessage()
- func (m *EndpointHealth) Reset()
- func (m *EndpointHealth) String() string
- 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_Merge(src proto.Message)
- func (m *EndpointHealth) XXX_Size() int
- func (m *EndpointHealth) XXX_Unmarshal(b []byte) error
- type EndpointHealthResponse
- func (*EndpointHealthResponse) Descriptor() ([]byte, []int)
- func (m *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth
- func (*EndpointHealthResponse) ProtoMessage()
- func (m *EndpointHealthResponse) Reset()
- func (m *EndpointHealthResponse) String() string
- 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_Merge(src proto.Message)
- func (m *EndpointHealthResponse) XXX_Size() int
- func (m *EndpointHealthResponse) XXX_Unmarshal(b []byte) error
- type EndpointHealthResponseValidationError
- func (e EndpointHealthResponseValidationError) Cause() error
- func (e EndpointHealthResponseValidationError) Error() string
- func (e EndpointHealthResponseValidationError) ErrorName() string
- func (e EndpointHealthResponseValidationError) Field() string
- func (e EndpointHealthResponseValidationError) Key() bool
- func (e EndpointHealthResponseValidationError) Reason() string
- type EndpointHealthValidationError
- func (e EndpointHealthValidationError) Cause() error
- func (e EndpointHealthValidationError) Error() string
- func (e EndpointHealthValidationError) ErrorName() string
- func (e EndpointHealthValidationError) Field() string
- func (e EndpointHealthValidationError) Key() bool
- func (e EndpointHealthValidationError) Reason() string
- type HealthCheckRequest
- func (*HealthCheckRequest) Descriptor() ([]byte, []int)
- func (m *HealthCheckRequest) GetCapability() *Capability
- func (m *HealthCheckRequest) GetNode() *core.Node
- func (*HealthCheckRequest) ProtoMessage()
- func (m *HealthCheckRequest) Reset()
- func (m *HealthCheckRequest) String() string
- 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_Merge(src proto.Message)
- func (m *HealthCheckRequest) XXX_Size() int
- func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error
- type HealthCheckRequestOrEndpointHealthResponse
- func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor() ([]byte, []int)
- func (m *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse
- func (m *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest
- func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType
- func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()
- func (m *HealthCheckRequestOrEndpointHealthResponse) Reset()
- func (m *HealthCheckRequestOrEndpointHealthResponse) String() string
- 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_Merge(src proto.Message)
- func (*HealthCheckRequestOrEndpointHealthResponse) XXX_OneofWrappers() []interface{}
- func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Size() int
- func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal(b []byte) error
- type HealthCheckRequestOrEndpointHealthResponseValidationError
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Cause() error
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Error() string
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName() string
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Field() string
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Key() bool
- func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Reason() string
- type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse
- type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest
- type HealthCheckRequestValidationError
- func (e HealthCheckRequestValidationError) Cause() error
- func (e HealthCheckRequestValidationError) Error() string
- func (e HealthCheckRequestValidationError) ErrorName() string
- func (e HealthCheckRequestValidationError) Field() string
- func (e HealthCheckRequestValidationError) Key() bool
- func (e HealthCheckRequestValidationError) Reason() string
- type HealthCheckSpecifier
- func (*HealthCheckSpecifier) Descriptor() ([]byte, []int)
- func (m *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck
- func (m *HealthCheckSpecifier) GetInterval() *duration.Duration
- func (*HealthCheckSpecifier) ProtoMessage()
- func (m *HealthCheckSpecifier) Reset()
- func (m *HealthCheckSpecifier) String() string
- 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_Merge(src proto.Message)
- func (m *HealthCheckSpecifier) XXX_Size() int
- func (m *HealthCheckSpecifier) XXX_Unmarshal(b []byte) error
- type HealthCheckSpecifierValidationError
- func (e HealthCheckSpecifierValidationError) Cause() error
- func (e HealthCheckSpecifierValidationError) Error() string
- func (e HealthCheckSpecifierValidationError) ErrorName() string
- func (e HealthCheckSpecifierValidationError) Field() string
- func (e HealthCheckSpecifierValidationError) Key() bool
- func (e HealthCheckSpecifierValidationError) Reason() string
- type HealthDiscoveryServiceClient
- type HealthDiscoveryServiceServer
- type HealthDiscoveryService_StreamHealthCheckClient
- type HealthDiscoveryService_StreamHealthCheckServer
- type LocalityEndpoints
- func (*LocalityEndpoints) Descriptor() ([]byte, []int)
- func (m *LocalityEndpoints) GetEndpoints() []*endpoint.Endpoint
- func (m *LocalityEndpoints) GetLocality() *core.Locality
- func (*LocalityEndpoints) ProtoMessage()
- func (m *LocalityEndpoints) Reset()
- func (m *LocalityEndpoints) String() string
- 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_Merge(src proto.Message)
- func (m *LocalityEndpoints) XXX_Size() int
- func (m *LocalityEndpoints) XXX_Unmarshal(b []byte) error
- type LocalityEndpointsValidationError
- func (e LocalityEndpointsValidationError) Cause() error
- func (e LocalityEndpointsValidationError) Error() string
- func (e LocalityEndpointsValidationError) ErrorName() string
- func (e LocalityEndpointsValidationError) Field() string
- func (e LocalityEndpointsValidationError) Key() bool
- func (e LocalityEndpointsValidationError) Reason() string
- type RtdsDummy
- func (*RtdsDummy) Descriptor() ([]byte, []int)
- func (*RtdsDummy) ProtoMessage()
- func (m *RtdsDummy) Reset()
- func (m *RtdsDummy) String() string
- 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
- type Runtime
- func (*Runtime) Descriptor() ([]byte, []int)
- func (m *Runtime) GetLayer() *_struct.Struct
- func (m *Runtime) GetName() string
- func (*Runtime) ProtoMessage()
- func (m *Runtime) Reset()
- func (m *Runtime) String() string
- 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
- type RuntimeDiscoveryServiceServer
- type RuntimeDiscoveryService_DeltaRuntimeClient
- type RuntimeDiscoveryService_DeltaRuntimeServer
- type RuntimeDiscoveryService_StreamRuntimeClient
- type RuntimeDiscoveryService_StreamRuntimeServer
- type RuntimeValidationError
- type SdsDummy
- func (*SdsDummy) Descriptor() ([]byte, []int)
- func (*SdsDummy) ProtoMessage()
- func (m *SdsDummy) Reset()
- func (m *SdsDummy) String() string
- 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_Merge(src proto.Message)
- func (m *SdsDummy) XXX_Size() int
- func (m *SdsDummy) XXX_Unmarshal(b []byte) error
- type SdsDummyValidationError
- type SecretDiscoveryServiceClient
- type SecretDiscoveryServiceServer
- type SecretDiscoveryService_DeltaSecretsClient
- type SecretDiscoveryService_DeltaSecretsServer
- type SecretDiscoveryService_StreamSecretsClient
- type SecretDiscoveryService_StreamSecretsServer
- type UnimplementedAggregatedDiscoveryServiceServer
- type UnimplementedHealthDiscoveryServiceServer
- type UnimplementedRuntimeDiscoveryServiceServer
- 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
- 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
Constants ¶
This section is empty.
Variables ¶
var Capability_Protocol_name = map[int32]string{
0: "HTTP",
1: "TCP",
2: "REDIS",
}
var Capability_Protocol_value = map[string]int32{
"HTTP": 0,
"TCP": 1,
"REDIS": 2,
}
Functions ¶
func RegisterAggregatedDiscoveryServiceServer ¶
func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer)
func RegisterHealthDiscoveryServiceServer ¶
func RegisterHealthDiscoveryServiceServer(s *grpc.Server, srv HealthDiscoveryServiceServer)
func RegisterRuntimeDiscoveryServiceServer ¶ added in v0.8.1
func RegisterRuntimeDiscoveryServiceServer(s *grpc.Server, srv RuntimeDiscoveryServiceServer)
func RegisterSecretDiscoveryServiceServer ¶
func RegisterSecretDiscoveryServiceServer(s *grpc.Server, srv SecretDiscoveryServiceServer)
Types ¶
type AdsDummy ¶
type AdsDummy struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AdsDummy) Descriptor ¶
func (*AdsDummy) ProtoMessage ¶
func (*AdsDummy) ProtoMessage()
func (*AdsDummy) Validate ¶
Validate checks the field values on AdsDummy with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*AdsDummy) XXX_DiscardUnknown ¶
func (m *AdsDummy) XXX_DiscardUnknown()
func (*AdsDummy) XXX_Marshal ¶
func (*AdsDummy) XXX_Unmarshal ¶
type AdsDummyValidationError ¶
type AdsDummyValidationError struct {
// contains filtered or unexported fields
}
AdsDummyValidationError is the validation error returned by AdsDummy.Validate if the designated constraints aren't met.
func (AdsDummyValidationError) Cause ¶
func (e AdsDummyValidationError) Cause() error
Cause function returns cause value.
func (AdsDummyValidationError) Error ¶
func (e AdsDummyValidationError) Error() string
Error satisfies the builtin error interface
func (AdsDummyValidationError) ErrorName ¶ added in v0.7.0
func (e AdsDummyValidationError) ErrorName() string
ErrorName returns error name.
func (AdsDummyValidationError) Field ¶
func (e AdsDummyValidationError) Field() string
Field function returns field value.
func (AdsDummyValidationError) Key ¶
func (e AdsDummyValidationError) Key() bool
Key function returns key value.
func (AdsDummyValidationError) Reason ¶
func (e AdsDummyValidationError) Reason() string
Reason function returns reason value.
type AggregatedDiscoveryServiceClient ¶
type AggregatedDiscoveryServiceClient interface { StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error) DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error) }
AggregatedDiscoveryServiceClient is the client API for AggregatedDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAggregatedDiscoveryServiceClient ¶
func NewAggregatedDiscoveryServiceClient(cc *grpc.ClientConn) AggregatedDiscoveryServiceClient
type AggregatedDiscoveryServiceServer ¶
type AggregatedDiscoveryServiceServer interface { StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error }
AggregatedDiscoveryServiceServer is the server API for AggregatedDiscoveryService service.
type AggregatedDiscoveryService_DeltaAggregatedResourcesClient ¶ added in v0.6.9
type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface { Send(*v2.DeltaDiscoveryRequest) error Recv() (*v2.DeltaDiscoveryResponse, error) grpc.ClientStream }
type AggregatedDiscoveryService_DeltaAggregatedResourcesServer ¶ added in v0.6.9
type AggregatedDiscoveryService_DeltaAggregatedResourcesServer interface { Send(*v2.DeltaDiscoveryResponse) error Recv() (*v2.DeltaDiscoveryRequest, error) grpc.ServerStream }
type AggregatedDiscoveryService_StreamAggregatedResourcesClient ¶
type AggregatedDiscoveryService_StreamAggregatedResourcesClient interface { Send(*v2.DiscoveryRequest) error Recv() (*v2.DiscoveryResponse, error) grpc.ClientStream }
type AggregatedDiscoveryService_StreamAggregatedResourcesServer ¶
type AggregatedDiscoveryService_StreamAggregatedResourcesServer interface { Send(*v2.DiscoveryResponse) error Recv() (*v2.DiscoveryRequest, error) grpc.ServerStream }
type Capability ¶
type Capability struct { HealthCheckProtocols []Capability_Protocol `` /* 183-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Capability) Descriptor ¶
func (*Capability) Descriptor() ([]byte, []int)
func (*Capability) GetHealthCheckProtocols ¶
func (m *Capability) GetHealthCheckProtocols() []Capability_Protocol
func (*Capability) ProtoMessage ¶
func (*Capability) ProtoMessage()
func (*Capability) Reset ¶
func (m *Capability) Reset()
func (*Capability) String ¶
func (m *Capability) String() string
func (*Capability) Validate ¶
func (m *Capability) Validate() error
Validate checks the field values on Capability with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Capability) XXX_DiscardUnknown ¶
func (m *Capability) XXX_DiscardUnknown()
func (*Capability) XXX_Marshal ¶
func (m *Capability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Capability) XXX_Merge ¶
func (m *Capability) XXX_Merge(src proto.Message)
func (*Capability) XXX_Size ¶
func (m *Capability) XXX_Size() int
func (*Capability) XXX_Unmarshal ¶
func (m *Capability) XXX_Unmarshal(b []byte) error
type CapabilityValidationError ¶
type CapabilityValidationError struct {
// contains filtered or unexported fields
}
CapabilityValidationError is the validation error returned by Capability.Validate if the designated constraints aren't met.
func (CapabilityValidationError) Cause ¶
func (e CapabilityValidationError) Cause() error
Cause function returns cause value.
func (CapabilityValidationError) Error ¶
func (e CapabilityValidationError) Error() string
Error satisfies the builtin error interface
func (CapabilityValidationError) ErrorName ¶ added in v0.7.0
func (e CapabilityValidationError) ErrorName() string
ErrorName returns error name.
func (CapabilityValidationError) Field ¶
func (e CapabilityValidationError) Field() string
Field function returns field value.
func (CapabilityValidationError) Key ¶
func (e CapabilityValidationError) Key() bool
Key function returns key value.
func (CapabilityValidationError) Reason ¶
func (e CapabilityValidationError) Reason() string
Reason function returns reason value.
type Capability_Protocol ¶
type Capability_Protocol int32
const ( Capability_HTTP Capability_Protocol = 0 Capability_TCP Capability_Protocol = 1 Capability_REDIS Capability_Protocol = 2 )
func (Capability_Protocol) EnumDescriptor ¶
func (Capability_Protocol) EnumDescriptor() ([]byte, []int)
func (Capability_Protocol) String ¶
func (x Capability_Protocol) String() string
type ClusterHealthCheck ¶
type ClusterHealthCheck struct { ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` HealthChecks []*core.HealthCheck `protobuf:"bytes,2,rep,name=health_checks,json=healthChecks,proto3" json:"health_checks,omitempty"` LocalityEndpoints []*LocalityEndpoints `protobuf:"bytes,3,rep,name=locality_endpoints,json=localityEndpoints,proto3" json:"locality_endpoints,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClusterHealthCheck) Descriptor ¶
func (*ClusterHealthCheck) Descriptor() ([]byte, []int)
func (*ClusterHealthCheck) GetClusterName ¶
func (m *ClusterHealthCheck) GetClusterName() string
func (*ClusterHealthCheck) GetHealthChecks ¶
func (m *ClusterHealthCheck) GetHealthChecks() []*core.HealthCheck
func (*ClusterHealthCheck) GetLocalityEndpoints ¶
func (m *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints
func (*ClusterHealthCheck) ProtoMessage ¶
func (*ClusterHealthCheck) ProtoMessage()
func (*ClusterHealthCheck) Reset ¶
func (m *ClusterHealthCheck) Reset()
func (*ClusterHealthCheck) String ¶
func (m *ClusterHealthCheck) String() string
func (*ClusterHealthCheck) Validate ¶
func (m *ClusterHealthCheck) Validate() error
Validate checks the field values on ClusterHealthCheck with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*ClusterHealthCheck) XXX_DiscardUnknown ¶
func (m *ClusterHealthCheck) XXX_DiscardUnknown()
func (*ClusterHealthCheck) XXX_Marshal ¶
func (m *ClusterHealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterHealthCheck) XXX_Merge ¶
func (m *ClusterHealthCheck) XXX_Merge(src proto.Message)
func (*ClusterHealthCheck) XXX_Size ¶
func (m *ClusterHealthCheck) XXX_Size() int
func (*ClusterHealthCheck) XXX_Unmarshal ¶
func (m *ClusterHealthCheck) XXX_Unmarshal(b []byte) error
type ClusterHealthCheckValidationError ¶
type ClusterHealthCheckValidationError struct {
// contains filtered or unexported fields
}
ClusterHealthCheckValidationError is the validation error returned by ClusterHealthCheck.Validate if the designated constraints aren't met.
func (ClusterHealthCheckValidationError) Cause ¶
func (e ClusterHealthCheckValidationError) Cause() error
Cause function returns cause value.
func (ClusterHealthCheckValidationError) Error ¶
func (e ClusterHealthCheckValidationError) Error() string
Error satisfies the builtin error interface
func (ClusterHealthCheckValidationError) ErrorName ¶ added in v0.7.0
func (e ClusterHealthCheckValidationError) ErrorName() string
ErrorName returns error name.
func (ClusterHealthCheckValidationError) Field ¶
func (e ClusterHealthCheckValidationError) Field() string
Field function returns field value.
func (ClusterHealthCheckValidationError) Key ¶
func (e ClusterHealthCheckValidationError) Key() bool
Key function returns key value.
func (ClusterHealthCheckValidationError) Reason ¶
func (e ClusterHealthCheckValidationError) Reason() string
Reason function returns reason value.
type EndpointHealth ¶
type EndpointHealth struct { Endpoint *endpoint.Endpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` HealthStatus core.HealthStatus `` /* 134-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EndpointHealth) Descriptor ¶
func (*EndpointHealth) Descriptor() ([]byte, []int)
func (*EndpointHealth) GetEndpoint ¶
func (m *EndpointHealth) GetEndpoint() *endpoint.Endpoint
func (*EndpointHealth) GetHealthStatus ¶
func (m *EndpointHealth) GetHealthStatus() core.HealthStatus
func (*EndpointHealth) ProtoMessage ¶
func (*EndpointHealth) ProtoMessage()
func (*EndpointHealth) Reset ¶
func (m *EndpointHealth) Reset()
func (*EndpointHealth) String ¶
func (m *EndpointHealth) String() string
func (*EndpointHealth) Validate ¶
func (m *EndpointHealth) Validate() error
Validate checks the field values on EndpointHealth with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*EndpointHealth) XXX_DiscardUnknown ¶
func (m *EndpointHealth) XXX_DiscardUnknown()
func (*EndpointHealth) XXX_Marshal ¶
func (m *EndpointHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EndpointHealth) XXX_Merge ¶
func (m *EndpointHealth) XXX_Merge(src proto.Message)
func (*EndpointHealth) XXX_Size ¶
func (m *EndpointHealth) XXX_Size() int
func (*EndpointHealth) XXX_Unmarshal ¶
func (m *EndpointHealth) XXX_Unmarshal(b []byte) error
type EndpointHealthResponse ¶
type EndpointHealthResponse struct { EndpointsHealth []*EndpointHealth `protobuf:"bytes,1,rep,name=endpoints_health,json=endpointsHealth,proto3" json:"endpoints_health,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EndpointHealthResponse) Descriptor ¶
func (*EndpointHealthResponse) Descriptor() ([]byte, []int)
func (*EndpointHealthResponse) GetEndpointsHealth ¶
func (m *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth
func (*EndpointHealthResponse) ProtoMessage ¶
func (*EndpointHealthResponse) ProtoMessage()
func (*EndpointHealthResponse) Reset ¶
func (m *EndpointHealthResponse) Reset()
func (*EndpointHealthResponse) String ¶
func (m *EndpointHealthResponse) String() string
func (*EndpointHealthResponse) Validate ¶
func (m *EndpointHealthResponse) Validate() error
Validate checks the field values on EndpointHealthResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*EndpointHealthResponse) XXX_DiscardUnknown ¶
func (m *EndpointHealthResponse) XXX_DiscardUnknown()
func (*EndpointHealthResponse) XXX_Marshal ¶
func (m *EndpointHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EndpointHealthResponse) XXX_Merge ¶
func (m *EndpointHealthResponse) XXX_Merge(src proto.Message)
func (*EndpointHealthResponse) XXX_Size ¶
func (m *EndpointHealthResponse) XXX_Size() int
func (*EndpointHealthResponse) XXX_Unmarshal ¶
func (m *EndpointHealthResponse) XXX_Unmarshal(b []byte) error
type EndpointHealthResponseValidationError ¶
type EndpointHealthResponseValidationError struct {
// contains filtered or unexported fields
}
EndpointHealthResponseValidationError is the validation error returned by EndpointHealthResponse.Validate if the designated constraints aren't met.
func (EndpointHealthResponseValidationError) Cause ¶
func (e EndpointHealthResponseValidationError) Cause() error
Cause function returns cause value.
func (EndpointHealthResponseValidationError) Error ¶
func (e EndpointHealthResponseValidationError) Error() string
Error satisfies the builtin error interface
func (EndpointHealthResponseValidationError) ErrorName ¶ added in v0.7.0
func (e EndpointHealthResponseValidationError) ErrorName() string
ErrorName returns error name.
func (EndpointHealthResponseValidationError) Field ¶
func (e EndpointHealthResponseValidationError) Field() string
Field function returns field value.
func (EndpointHealthResponseValidationError) Key ¶
func (e EndpointHealthResponseValidationError) Key() bool
Key function returns key value.
func (EndpointHealthResponseValidationError) Reason ¶
func (e EndpointHealthResponseValidationError) Reason() string
Reason function returns reason value.
type EndpointHealthValidationError ¶
type EndpointHealthValidationError struct {
// contains filtered or unexported fields
}
EndpointHealthValidationError is the validation error returned by EndpointHealth.Validate if the designated constraints aren't met.
func (EndpointHealthValidationError) Cause ¶
func (e EndpointHealthValidationError) Cause() error
Cause function returns cause value.
func (EndpointHealthValidationError) Error ¶
func (e EndpointHealthValidationError) Error() string
Error satisfies the builtin error interface
func (EndpointHealthValidationError) ErrorName ¶ added in v0.7.0
func (e EndpointHealthValidationError) ErrorName() string
ErrorName returns error name.
func (EndpointHealthValidationError) Field ¶
func (e EndpointHealthValidationError) Field() string
Field function returns field value.
func (EndpointHealthValidationError) Key ¶
func (e EndpointHealthValidationError) Key() bool
Key function returns key value.
func (EndpointHealthValidationError) Reason ¶
func (e EndpointHealthValidationError) Reason() string
Reason function returns reason value.
type HealthCheckRequest ¶
type HealthCheckRequest struct { Node *core.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` Capability *Capability `protobuf:"bytes,2,opt,name=capability,proto3" json:"capability,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthCheckRequest) Descriptor ¶
func (*HealthCheckRequest) Descriptor() ([]byte, []int)
func (*HealthCheckRequest) GetCapability ¶
func (m *HealthCheckRequest) GetCapability() *Capability
func (*HealthCheckRequest) GetNode ¶
func (m *HealthCheckRequest) GetNode() *core.Node
func (*HealthCheckRequest) ProtoMessage ¶
func (*HealthCheckRequest) ProtoMessage()
func (*HealthCheckRequest) Reset ¶
func (m *HealthCheckRequest) Reset()
func (*HealthCheckRequest) String ¶
func (m *HealthCheckRequest) String() string
func (*HealthCheckRequest) Validate ¶
func (m *HealthCheckRequest) Validate() error
Validate checks the field values on HealthCheckRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*HealthCheckRequest) XXX_DiscardUnknown ¶
func (m *HealthCheckRequest) XXX_DiscardUnknown()
func (*HealthCheckRequest) XXX_Marshal ¶
func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthCheckRequest) XXX_Merge ¶
func (m *HealthCheckRequest) XXX_Merge(src proto.Message)
func (*HealthCheckRequest) XXX_Size ¶
func (m *HealthCheckRequest) XXX_Size() int
func (*HealthCheckRequest) XXX_Unmarshal ¶
func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error
type HealthCheckRequestOrEndpointHealthResponse ¶
type HealthCheckRequestOrEndpointHealthResponse struct { // Types that are valid to be assigned to RequestType: // *HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest // *HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse RequestType isHealthCheckRequestOrEndpointHealthResponse_RequestType `protobuf_oneof:"request_type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor ¶
func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor() ([]byte, []int)
func (*HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse
func (*HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest
func (*HealthCheckRequestOrEndpointHealthResponse) GetRequestType ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType
func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage ¶
func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()
func (*HealthCheckRequestOrEndpointHealthResponse) Reset ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) Reset()
func (*HealthCheckRequestOrEndpointHealthResponse) String ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) String() string
func (*HealthCheckRequestOrEndpointHealthResponse) Validate ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) Validate() error
Validate checks the field values on HealthCheckRequestOrEndpointHealthResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_DiscardUnknown ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_DiscardUnknown()
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Marshal ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Merge ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Merge(src proto.Message)
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_OneofWrappers ¶ added in v0.9.0
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Size ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Size() int
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal(b []byte) error
type HealthCheckRequestOrEndpointHealthResponseValidationError ¶
type HealthCheckRequestOrEndpointHealthResponseValidationError struct {
// contains filtered or unexported fields
}
HealthCheckRequestOrEndpointHealthResponseValidationError is the validation error returned by HealthCheckRequestOrEndpointHealthResponse.Validate if the designated constraints aren't met.
func (HealthCheckRequestOrEndpointHealthResponseValidationError) Cause ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Cause() error
Cause function returns cause value.
func (HealthCheckRequestOrEndpointHealthResponseValidationError) Error ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Error() string
Error satisfies the builtin error interface
func (HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName ¶ added in v0.7.0
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName() string
ErrorName returns error name.
func (HealthCheckRequestOrEndpointHealthResponseValidationError) Field ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Field() string
Field function returns field value.
func (HealthCheckRequestOrEndpointHealthResponseValidationError) Key ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Key() bool
Key function returns key value.
func (HealthCheckRequestOrEndpointHealthResponseValidationError) Reason ¶
func (e HealthCheckRequestOrEndpointHealthResponseValidationError) Reason() string
Reason function returns reason value.
type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse ¶
type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse struct {
EndpointHealthResponse *EndpointHealthResponse `protobuf:"bytes,2,opt,name=endpoint_health_response,json=endpointHealthResponse,proto3,oneof"`
}
type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest ¶
type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest struct {
HealthCheckRequest *HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof"`
}
type HealthCheckRequestValidationError ¶
type HealthCheckRequestValidationError struct {
// contains filtered or unexported fields
}
HealthCheckRequestValidationError is the validation error returned by HealthCheckRequest.Validate if the designated constraints aren't met.
func (HealthCheckRequestValidationError) Cause ¶
func (e HealthCheckRequestValidationError) Cause() error
Cause function returns cause value.
func (HealthCheckRequestValidationError) Error ¶
func (e HealthCheckRequestValidationError) Error() string
Error satisfies the builtin error interface
func (HealthCheckRequestValidationError) ErrorName ¶ added in v0.7.0
func (e HealthCheckRequestValidationError) ErrorName() string
ErrorName returns error name.
func (HealthCheckRequestValidationError) Field ¶
func (e HealthCheckRequestValidationError) Field() string
Field function returns field value.
func (HealthCheckRequestValidationError) Key ¶
func (e HealthCheckRequestValidationError) Key() bool
Key function returns key value.
func (HealthCheckRequestValidationError) Reason ¶
func (e HealthCheckRequestValidationError) Reason() string
Reason function returns reason value.
type HealthCheckSpecifier ¶
type HealthCheckSpecifier struct { ClusterHealthChecks []*ClusterHealthCheck `protobuf:"bytes,1,rep,name=cluster_health_checks,json=clusterHealthChecks,proto3" json:"cluster_health_checks,omitempty"` Interval *duration.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthCheckSpecifier) Descriptor ¶
func (*HealthCheckSpecifier) Descriptor() ([]byte, []int)
func (*HealthCheckSpecifier) GetClusterHealthChecks ¶
func (m *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck
func (*HealthCheckSpecifier) GetInterval ¶
func (m *HealthCheckSpecifier) GetInterval() *duration.Duration
func (*HealthCheckSpecifier) ProtoMessage ¶
func (*HealthCheckSpecifier) ProtoMessage()
func (*HealthCheckSpecifier) Reset ¶
func (m *HealthCheckSpecifier) Reset()
func (*HealthCheckSpecifier) String ¶
func (m *HealthCheckSpecifier) String() string
func (*HealthCheckSpecifier) Validate ¶
func (m *HealthCheckSpecifier) Validate() error
Validate checks the field values on HealthCheckSpecifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*HealthCheckSpecifier) XXX_DiscardUnknown ¶
func (m *HealthCheckSpecifier) XXX_DiscardUnknown()
func (*HealthCheckSpecifier) XXX_Marshal ¶
func (m *HealthCheckSpecifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthCheckSpecifier) XXX_Merge ¶
func (m *HealthCheckSpecifier) XXX_Merge(src proto.Message)
func (*HealthCheckSpecifier) XXX_Size ¶
func (m *HealthCheckSpecifier) XXX_Size() int
func (*HealthCheckSpecifier) XXX_Unmarshal ¶
func (m *HealthCheckSpecifier) XXX_Unmarshal(b []byte) error
type HealthCheckSpecifierValidationError ¶
type HealthCheckSpecifierValidationError struct {
// contains filtered or unexported fields
}
HealthCheckSpecifierValidationError is the validation error returned by HealthCheckSpecifier.Validate if the designated constraints aren't met.
func (HealthCheckSpecifierValidationError) Cause ¶
func (e HealthCheckSpecifierValidationError) Cause() error
Cause function returns cause value.
func (HealthCheckSpecifierValidationError) Error ¶
func (e HealthCheckSpecifierValidationError) Error() string
Error satisfies the builtin error interface
func (HealthCheckSpecifierValidationError) ErrorName ¶ added in v0.7.0
func (e HealthCheckSpecifierValidationError) ErrorName() string
ErrorName returns error name.
func (HealthCheckSpecifierValidationError) Field ¶
func (e HealthCheckSpecifierValidationError) Field() string
Field function returns field value.
func (HealthCheckSpecifierValidationError) Key ¶
func (e HealthCheckSpecifierValidationError) Key() bool
Key function returns key value.
func (HealthCheckSpecifierValidationError) Reason ¶
func (e HealthCheckSpecifierValidationError) Reason() string
Reason function returns reason value.
type HealthDiscoveryServiceClient ¶
type HealthDiscoveryServiceClient interface { StreamHealthCheck(ctx context.Context, opts ...grpc.CallOption) (HealthDiscoveryService_StreamHealthCheckClient, error) FetchHealthCheck(ctx context.Context, in *HealthCheckRequestOrEndpointHealthResponse, opts ...grpc.CallOption) (*HealthCheckSpecifier, error) }
HealthDiscoveryServiceClient is the client API for HealthDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewHealthDiscoveryServiceClient ¶
func NewHealthDiscoveryServiceClient(cc *grpc.ClientConn) HealthDiscoveryServiceClient
type HealthDiscoveryServiceServer ¶
type HealthDiscoveryServiceServer interface { StreamHealthCheck(HealthDiscoveryService_StreamHealthCheckServer) error FetchHealthCheck(context.Context, *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error) }
HealthDiscoveryServiceServer is the server API for HealthDiscoveryService service.
type HealthDiscoveryService_StreamHealthCheckClient ¶
type HealthDiscoveryService_StreamHealthCheckClient interface { Send(*HealthCheckRequestOrEndpointHealthResponse) error Recv() (*HealthCheckSpecifier, error) grpc.ClientStream }
type HealthDiscoveryService_StreamHealthCheckServer ¶
type HealthDiscoveryService_StreamHealthCheckServer interface { Send(*HealthCheckSpecifier) error Recv() (*HealthCheckRequestOrEndpointHealthResponse, error) grpc.ServerStream }
type LocalityEndpoints ¶
type LocalityEndpoints struct { Locality *core.Locality `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"` Endpoints []*endpoint.Endpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LocalityEndpoints) Descriptor ¶
func (*LocalityEndpoints) Descriptor() ([]byte, []int)
func (*LocalityEndpoints) GetEndpoints ¶
func (m *LocalityEndpoints) GetEndpoints() []*endpoint.Endpoint
func (*LocalityEndpoints) GetLocality ¶
func (m *LocalityEndpoints) GetLocality() *core.Locality
func (*LocalityEndpoints) ProtoMessage ¶
func (*LocalityEndpoints) ProtoMessage()
func (*LocalityEndpoints) Reset ¶
func (m *LocalityEndpoints) Reset()
func (*LocalityEndpoints) String ¶
func (m *LocalityEndpoints) String() string
func (*LocalityEndpoints) Validate ¶
func (m *LocalityEndpoints) Validate() error
Validate checks the field values on LocalityEndpoints with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*LocalityEndpoints) XXX_DiscardUnknown ¶
func (m *LocalityEndpoints) XXX_DiscardUnknown()
func (*LocalityEndpoints) XXX_Marshal ¶
func (m *LocalityEndpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LocalityEndpoints) XXX_Merge ¶
func (m *LocalityEndpoints) XXX_Merge(src proto.Message)
func (*LocalityEndpoints) XXX_Size ¶
func (m *LocalityEndpoints) XXX_Size() int
func (*LocalityEndpoints) XXX_Unmarshal ¶
func (m *LocalityEndpoints) XXX_Unmarshal(b []byte) error
type LocalityEndpointsValidationError ¶
type LocalityEndpointsValidationError struct {
// contains filtered or unexported fields
}
LocalityEndpointsValidationError is the validation error returned by LocalityEndpoints.Validate if the designated constraints aren't met.
func (LocalityEndpointsValidationError) Cause ¶
func (e LocalityEndpointsValidationError) Cause() error
Cause function returns cause value.
func (LocalityEndpointsValidationError) Error ¶
func (e LocalityEndpointsValidationError) Error() string
Error satisfies the builtin error interface
func (LocalityEndpointsValidationError) ErrorName ¶ added in v0.7.0
func (e LocalityEndpointsValidationError) ErrorName() string
ErrorName returns error name.
func (LocalityEndpointsValidationError) Field ¶
func (e LocalityEndpointsValidationError) Field() string
Field function returns field value.
func (LocalityEndpointsValidationError) Key ¶
func (e LocalityEndpointsValidationError) Key() bool
Key function returns key value.
func (LocalityEndpointsValidationError) Reason ¶
func (e LocalityEndpointsValidationError) Reason() string
Reason function returns reason value.
type RtdsDummy ¶ added in v0.8.2
type RtdsDummy struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RtdsDummy) Descriptor ¶ added in v0.8.2
func (*RtdsDummy) ProtoMessage ¶ added in v0.8.2
func (*RtdsDummy) ProtoMessage()
func (*RtdsDummy) Validate ¶ added in v0.8.2
Validate checks the field values on RtdsDummy with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*RtdsDummy) XXX_DiscardUnknown ¶ added in v0.8.2
func (m *RtdsDummy) XXX_DiscardUnknown()
func (*RtdsDummy) XXX_Marshal ¶ added in v0.8.2
func (*RtdsDummy) XXX_Unmarshal ¶ added in v0.8.2
type RtdsDummyValidationError ¶ added in v0.8.2
type RtdsDummyValidationError struct {
// contains filtered or unexported fields
}
RtdsDummyValidationError is the validation error returned by RtdsDummy.Validate if the designated constraints aren't met.
func (RtdsDummyValidationError) Cause ¶ added in v0.8.2
func (e RtdsDummyValidationError) Cause() error
Cause function returns cause value.
func (RtdsDummyValidationError) Error ¶ added in v0.8.2
func (e RtdsDummyValidationError) Error() string
Error satisfies the builtin error interface
func (RtdsDummyValidationError) ErrorName ¶ added in v0.8.2
func (e RtdsDummyValidationError) ErrorName() string
ErrorName returns error name.
func (RtdsDummyValidationError) Field ¶ added in v0.8.2
func (e RtdsDummyValidationError) Field() string
Field function returns field value.
func (RtdsDummyValidationError) Key ¶ added in v0.8.2
func (e RtdsDummyValidationError) Key() bool
Key function returns key value.
func (RtdsDummyValidationError) Reason ¶ added in v0.8.2
func (e RtdsDummyValidationError) Reason() string
Reason function returns reason value.
type Runtime ¶ added in v0.8.1
type Runtime struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Layer *_struct.Struct `protobuf:"bytes,2,opt,name=layer,proto3" json:"layer,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Runtime) Descriptor ¶ added in v0.8.1
func (*Runtime) ProtoMessage ¶ added in v0.8.1
func (*Runtime) ProtoMessage()
func (*Runtime) Validate ¶ added in v0.8.1
Validate checks the field values on Runtime with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Runtime) XXX_DiscardUnknown ¶ added in v0.8.1
func (m *Runtime) XXX_DiscardUnknown()
func (*Runtime) XXX_Marshal ¶ added in v0.8.1
func (*Runtime) XXX_Unmarshal ¶ added in v0.8.1
type RuntimeDiscoveryServiceClient ¶ added in v0.8.1
type RuntimeDiscoveryServiceClient interface { StreamRuntime(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_StreamRuntimeClient, error) DeltaRuntime(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_DeltaRuntimeClient, error) FetchRuntime(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error) }
RuntimeDiscoveryServiceClient is the client API for RuntimeDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRuntimeDiscoveryServiceClient ¶ added in v0.8.1
func NewRuntimeDiscoveryServiceClient(cc *grpc.ClientConn) RuntimeDiscoveryServiceClient
type RuntimeDiscoveryServiceServer ¶ added in v0.8.1
type RuntimeDiscoveryServiceServer interface { StreamRuntime(RuntimeDiscoveryService_StreamRuntimeServer) error DeltaRuntime(RuntimeDiscoveryService_DeltaRuntimeServer) error FetchRuntime(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error) }
RuntimeDiscoveryServiceServer is the server API for RuntimeDiscoveryService service.
type RuntimeDiscoveryService_DeltaRuntimeClient ¶ added in v0.8.2
type RuntimeDiscoveryService_DeltaRuntimeClient interface { Send(*v2.DeltaDiscoveryRequest) error Recv() (*v2.DeltaDiscoveryResponse, error) grpc.ClientStream }
type RuntimeDiscoveryService_DeltaRuntimeServer ¶ added in v0.8.2
type RuntimeDiscoveryService_DeltaRuntimeServer interface { Send(*v2.DeltaDiscoveryResponse) error Recv() (*v2.DeltaDiscoveryRequest, error) grpc.ServerStream }
type RuntimeDiscoveryService_StreamRuntimeClient ¶ added in v0.8.1
type RuntimeDiscoveryService_StreamRuntimeClient interface { Send(*v2.DiscoveryRequest) error Recv() (*v2.DiscoveryResponse, error) grpc.ClientStream }
type RuntimeDiscoveryService_StreamRuntimeServer ¶ added in v0.8.1
type RuntimeDiscoveryService_StreamRuntimeServer interface { Send(*v2.DiscoveryResponse) error Recv() (*v2.DiscoveryRequest, error) grpc.ServerStream }
type RuntimeValidationError ¶ added in v0.8.1
type RuntimeValidationError struct {
// contains filtered or unexported fields
}
RuntimeValidationError is the validation error returned by Runtime.Validate if the designated constraints aren't met.
func (RuntimeValidationError) Cause ¶ added in v0.8.1
func (e RuntimeValidationError) Cause() error
Cause function returns cause value.
func (RuntimeValidationError) Error ¶ added in v0.8.1
func (e RuntimeValidationError) Error() string
Error satisfies the builtin error interface
func (RuntimeValidationError) ErrorName ¶ added in v0.8.1
func (e RuntimeValidationError) ErrorName() string
ErrorName returns error name.
func (RuntimeValidationError) Field ¶ added in v0.8.1
func (e RuntimeValidationError) Field() string
Field function returns field value.
func (RuntimeValidationError) Key ¶ added in v0.8.1
func (e RuntimeValidationError) Key() bool
Key function returns key value.
func (RuntimeValidationError) Reason ¶ added in v0.8.1
func (e RuntimeValidationError) Reason() string
Reason function returns reason value.
type SdsDummy ¶
type SdsDummy struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SdsDummy) Descriptor ¶
func (*SdsDummy) ProtoMessage ¶
func (*SdsDummy) ProtoMessage()
func (*SdsDummy) Validate ¶
Validate checks the field values on SdsDummy with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*SdsDummy) XXX_DiscardUnknown ¶
func (m *SdsDummy) XXX_DiscardUnknown()
func (*SdsDummy) XXX_Marshal ¶
func (*SdsDummy) XXX_Unmarshal ¶
type SdsDummyValidationError ¶
type SdsDummyValidationError struct {
// contains filtered or unexported fields
}
SdsDummyValidationError is the validation error returned by SdsDummy.Validate if the designated constraints aren't met.
func (SdsDummyValidationError) Cause ¶
func (e SdsDummyValidationError) Cause() error
Cause function returns cause value.
func (SdsDummyValidationError) Error ¶
func (e SdsDummyValidationError) Error() string
Error satisfies the builtin error interface
func (SdsDummyValidationError) ErrorName ¶ added in v0.7.0
func (e SdsDummyValidationError) ErrorName() string
ErrorName returns error name.
func (SdsDummyValidationError) Field ¶
func (e SdsDummyValidationError) Field() string
Field function returns field value.
func (SdsDummyValidationError) Key ¶
func (e SdsDummyValidationError) Key() bool
Key function returns key value.
func (SdsDummyValidationError) Reason ¶
func (e SdsDummyValidationError) Reason() string
Reason function returns reason value.
type SecretDiscoveryServiceClient ¶
type SecretDiscoveryServiceClient interface { DeltaSecrets(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_DeltaSecretsClient, error) StreamSecrets(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_StreamSecretsClient, error) FetchSecrets(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error) }
SecretDiscoveryServiceClient is the client API for SecretDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewSecretDiscoveryServiceClient ¶
func NewSecretDiscoveryServiceClient(cc *grpc.ClientConn) SecretDiscoveryServiceClient
type SecretDiscoveryServiceServer ¶
type SecretDiscoveryServiceServer interface { DeltaSecrets(SecretDiscoveryService_DeltaSecretsServer) error StreamSecrets(SecretDiscoveryService_StreamSecretsServer) error FetchSecrets(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error) }
SecretDiscoveryServiceServer is the server API for SecretDiscoveryService service.
type SecretDiscoveryService_DeltaSecretsClient ¶ added in v0.8.1
type SecretDiscoveryService_DeltaSecretsClient interface { Send(*v2.DeltaDiscoveryRequest) error Recv() (*v2.DeltaDiscoveryResponse, error) grpc.ClientStream }
type SecretDiscoveryService_DeltaSecretsServer ¶ added in v0.8.1
type SecretDiscoveryService_DeltaSecretsServer interface { Send(*v2.DeltaDiscoveryResponse) error Recv() (*v2.DeltaDiscoveryRequest, error) grpc.ServerStream }
type SecretDiscoveryService_StreamSecretsClient ¶
type SecretDiscoveryService_StreamSecretsClient interface { Send(*v2.DiscoveryRequest) error Recv() (*v2.DiscoveryResponse, error) grpc.ClientStream }
type SecretDiscoveryService_StreamSecretsServer ¶
type SecretDiscoveryService_StreamSecretsServer interface { Send(*v2.DiscoveryResponse) error Recv() (*v2.DiscoveryRequest, error) grpc.ServerStream }
type UnimplementedAggregatedDiscoveryServiceServer ¶ added in v0.9.1
type UnimplementedAggregatedDiscoveryServiceServer struct { }
UnimplementedAggregatedDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources ¶ added in v0.9.1
func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources(srv AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources ¶ added in v0.9.1
func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources(srv AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
type UnimplementedHealthDiscoveryServiceServer ¶ added in v0.9.1
type UnimplementedHealthDiscoveryServiceServer struct { }
UnimplementedHealthDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck ¶ added in v0.9.1
func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck(ctx context.Context, req *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error)
func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck ¶ added in v0.9.1
func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck(srv HealthDiscoveryService_StreamHealthCheckServer) error
type UnimplementedRuntimeDiscoveryServiceServer ¶ added in v0.9.1
type UnimplementedRuntimeDiscoveryServiceServer struct { }
UnimplementedRuntimeDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedRuntimeDiscoveryServiceServer) DeltaRuntime ¶ added in v0.9.1
func (*UnimplementedRuntimeDiscoveryServiceServer) DeltaRuntime(srv RuntimeDiscoveryService_DeltaRuntimeServer) error
func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime ¶ added in v0.9.1
func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime(ctx context.Context, req *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime ¶ added in v0.9.1
func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime(srv RuntimeDiscoveryService_StreamRuntimeServer) error
type UnimplementedSecretDiscoveryServiceServer ¶ added in v0.9.1
type UnimplementedSecretDiscoveryServiceServer struct { }
UnimplementedSecretDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets ¶ added in v0.9.1
func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets(srv SecretDiscoveryService_DeltaSecretsServer) error
func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets ¶ added in v0.9.1
func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets(ctx context.Context, req *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets ¶ added in v0.9.1
func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets(srv SecretDiscoveryService_StreamSecretsServer) error