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 *v3alpha.DiscoveryRequest) (*v3alpha.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 *v3alpha.DiscoveryRequest) (*v3alpha.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 ¶
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 ¶
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 ¶
type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface { Send(*v3alpha.DeltaDiscoveryRequest) error Recv() (*v3alpha.DeltaDiscoveryResponse, error) grpc.ClientStream }
type AggregatedDiscoveryService_DeltaAggregatedResourcesServer ¶
type AggregatedDiscoveryService_DeltaAggregatedResourcesServer interface { Send(*v3alpha.DeltaDiscoveryResponse) error Recv() (*v3alpha.DeltaDiscoveryRequest, error) grpc.ServerStream }
type AggregatedDiscoveryService_StreamAggregatedResourcesClient ¶
type AggregatedDiscoveryService_StreamAggregatedResourcesClient interface { Send(*v3alpha.DiscoveryRequest) error Recv() (*v3alpha.DiscoveryResponse, error) grpc.ClientStream }
type AggregatedDiscoveryService_StreamAggregatedResourcesServer ¶
type AggregatedDiscoveryService_StreamAggregatedResourcesServer interface { Send(*v3alpha.DiscoveryResponse) error Recv() (*v3alpha.DiscoveryRequest, error) grpc.ServerStream }
type Capability ¶
type Capability struct { HealthCheckProtocols []Capability_Protocol `` /* 188-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 ¶
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 ¶
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 `` /* 139-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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
type RtdsDummy struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RtdsDummy) Descriptor ¶
func (*RtdsDummy) ProtoMessage ¶
func (*RtdsDummy) ProtoMessage()
func (*RtdsDummy) Validate ¶
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 ¶
func (m *RtdsDummy) XXX_DiscardUnknown()
func (*RtdsDummy) XXX_Marshal ¶
func (*RtdsDummy) XXX_Unmarshal ¶
type RtdsDummyValidationError ¶
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 ¶
func (e RtdsDummyValidationError) Cause() error
Cause function returns cause value.
func (RtdsDummyValidationError) Error ¶
func (e RtdsDummyValidationError) Error() string
Error satisfies the builtin error interface
func (RtdsDummyValidationError) ErrorName ¶
func (e RtdsDummyValidationError) ErrorName() string
ErrorName returns error name.
func (RtdsDummyValidationError) Field ¶
func (e RtdsDummyValidationError) Field() string
Field function returns field value.
func (RtdsDummyValidationError) Key ¶
func (e RtdsDummyValidationError) Key() bool
Key function returns key value.
func (RtdsDummyValidationError) Reason ¶
func (e RtdsDummyValidationError) Reason() string
Reason function returns reason value.
type Runtime ¶
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 ¶
func (*Runtime) ProtoMessage ¶
func (*Runtime) ProtoMessage()
func (*Runtime) Validate ¶
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 ¶
func (m *Runtime) XXX_DiscardUnknown()
func (*Runtime) XXX_Marshal ¶
func (*Runtime) XXX_Unmarshal ¶
type RuntimeDiscoveryServiceClient ¶
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 *v3alpha.DiscoveryRequest, opts ...grpc.CallOption) (*v3alpha.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 ¶
func NewRuntimeDiscoveryServiceClient(cc *grpc.ClientConn) RuntimeDiscoveryServiceClient
type RuntimeDiscoveryServiceServer ¶
type RuntimeDiscoveryServiceServer interface { StreamRuntime(RuntimeDiscoveryService_StreamRuntimeServer) error DeltaRuntime(RuntimeDiscoveryService_DeltaRuntimeServer) error FetchRuntime(context.Context, *v3alpha.DiscoveryRequest) (*v3alpha.DiscoveryResponse, error) }
RuntimeDiscoveryServiceServer is the server API for RuntimeDiscoveryService service.
type RuntimeDiscoveryService_DeltaRuntimeClient ¶
type RuntimeDiscoveryService_DeltaRuntimeClient interface { Send(*v3alpha.DeltaDiscoveryRequest) error Recv() (*v3alpha.DeltaDiscoveryResponse, error) grpc.ClientStream }
type RuntimeDiscoveryService_DeltaRuntimeServer ¶
type RuntimeDiscoveryService_DeltaRuntimeServer interface { Send(*v3alpha.DeltaDiscoveryResponse) error Recv() (*v3alpha.DeltaDiscoveryRequest, error) grpc.ServerStream }
type RuntimeDiscoveryService_StreamRuntimeClient ¶
type RuntimeDiscoveryService_StreamRuntimeClient interface { Send(*v3alpha.DiscoveryRequest) error Recv() (*v3alpha.DiscoveryResponse, error) grpc.ClientStream }
type RuntimeDiscoveryService_StreamRuntimeServer ¶
type RuntimeDiscoveryService_StreamRuntimeServer interface { Send(*v3alpha.DiscoveryResponse) error Recv() (*v3alpha.DiscoveryRequest, error) grpc.ServerStream }
type RuntimeValidationError ¶
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 ¶
func (e RuntimeValidationError) Cause() error
Cause function returns cause value.
func (RuntimeValidationError) Error ¶
func (e RuntimeValidationError) Error() string
Error satisfies the builtin error interface
func (RuntimeValidationError) ErrorName ¶
func (e RuntimeValidationError) ErrorName() string
ErrorName returns error name.
func (RuntimeValidationError) Field ¶
func (e RuntimeValidationError) Field() string
Field function returns field value.
func (RuntimeValidationError) Key ¶
func (e RuntimeValidationError) Key() bool
Key function returns key value.
func (RuntimeValidationError) Reason ¶
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 ¶
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 *v3alpha.DiscoveryRequest, opts ...grpc.CallOption) (*v3alpha.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, *v3alpha.DiscoveryRequest) (*v3alpha.DiscoveryResponse, error) }
SecretDiscoveryServiceServer is the server API for SecretDiscoveryService service.
type SecretDiscoveryService_DeltaSecretsClient ¶
type SecretDiscoveryService_DeltaSecretsClient interface { Send(*v3alpha.DeltaDiscoveryRequest) error Recv() (*v3alpha.DeltaDiscoveryResponse, error) grpc.ClientStream }
type SecretDiscoveryService_DeltaSecretsServer ¶
type SecretDiscoveryService_DeltaSecretsServer interface { Send(*v3alpha.DeltaDiscoveryResponse) error Recv() (*v3alpha.DeltaDiscoveryRequest, error) grpc.ServerStream }
type SecretDiscoveryService_StreamSecretsClient ¶
type SecretDiscoveryService_StreamSecretsClient interface { Send(*v3alpha.DiscoveryRequest) error Recv() (*v3alpha.DiscoveryResponse, error) grpc.ClientStream }
type SecretDiscoveryService_StreamSecretsServer ¶
type SecretDiscoveryService_StreamSecretsServer interface { Send(*v3alpha.DiscoveryResponse) error Recv() (*v3alpha.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 *v3alpha.DiscoveryRequest) (*v3alpha.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 *v3alpha.DiscoveryRequest) (*v3alpha.DiscoveryResponse, error)
func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets ¶ added in v0.9.1
func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets(srv SecretDiscoveryService_StreamSecretsServer) error