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
- 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)deprecated
- func (x *Capability) GetHealthCheckProtocols() []Capability_Protocol
- func (*Capability) ProtoMessage()
- func (x *Capability) ProtoReflect() protoreflect.Message
- func (x *Capability) Reset()
- func (x *Capability) String() string
- func (m *Capability) Validate() error
- type CapabilityValidationError
- type Capability_Protocol
- func (Capability_Protocol) Descriptor() protoreflect.EnumDescriptor
- func (x Capability_Protocol) Enum() *Capability_Protocol
- func (Capability_Protocol) EnumDescriptor() ([]byte, []int)deprecated
- func (x Capability_Protocol) Number() protoreflect.EnumNumber
- func (x Capability_Protocol) String() string
- func (Capability_Protocol) Type() protoreflect.EnumType
- type ClusterHealthCheck
- func (*ClusterHealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterHealthCheck) GetClusterName() string
- func (x *ClusterHealthCheck) GetHealthChecks() []*core.HealthCheck
- func (x *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints
- func (*ClusterHealthCheck) ProtoMessage()
- func (x *ClusterHealthCheck) ProtoReflect() protoreflect.Message
- func (x *ClusterHealthCheck) Reset()
- func (x *ClusterHealthCheck) String() string
- func (m *ClusterHealthCheck) Validate() 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)deprecated
- func (x *EndpointHealth) GetEndpoint() *endpoint.Endpoint
- func (x *EndpointHealth) GetHealthStatus() core.HealthStatus
- func (*EndpointHealth) ProtoMessage()
- func (x *EndpointHealth) ProtoReflect() protoreflect.Message
- func (x *EndpointHealth) Reset()
- func (x *EndpointHealth) String() string
- func (m *EndpointHealth) Validate() error
- type EndpointHealthResponse
- func (*EndpointHealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth
- func (*EndpointHealthResponse) ProtoMessage()
- func (x *EndpointHealthResponse) ProtoReflect() protoreflect.Message
- func (x *EndpointHealthResponse) Reset()
- func (x *EndpointHealthResponse) String() string
- func (m *EndpointHealthResponse) Validate() 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)deprecated
- func (x *HealthCheckRequest) GetCapability() *Capability
- func (x *HealthCheckRequest) GetNode() *core.Node
- func (*HealthCheckRequest) ProtoMessage()
- func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
- func (x *HealthCheckRequest) Reset()
- func (x *HealthCheckRequest) String() string
- func (m *HealthCheckRequest) Validate() error
- type HealthCheckRequestOrEndpointHealthResponse
- func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse
- func (x *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest
- func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType
- func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()
- func (x *HealthCheckRequestOrEndpointHealthResponse) ProtoReflect() protoreflect.Message
- func (x *HealthCheckRequestOrEndpointHealthResponse) Reset()
- func (x *HealthCheckRequestOrEndpointHealthResponse) String() string
- func (m *HealthCheckRequestOrEndpointHealthResponse) Validate() 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)deprecated
- func (x *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck
- func (x *HealthCheckSpecifier) GetInterval() *duration.Duration
- func (*HealthCheckSpecifier) ProtoMessage()
- func (x *HealthCheckSpecifier) ProtoReflect() protoreflect.Message
- func (x *HealthCheckSpecifier) Reset()
- func (x *HealthCheckSpecifier) String() string
- func (m *HealthCheckSpecifier) Validate() 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)deprecated
- func (x *LocalityEndpoints) GetEndpoints() []*endpoint.Endpoint
- func (x *LocalityEndpoints) GetLocality() *core.Locality
- func (*LocalityEndpoints) ProtoMessage()
- func (x *LocalityEndpoints) ProtoReflect() protoreflect.Message
- func (x *LocalityEndpoints) Reset()
- func (x *LocalityEndpoints) String() string
- func (m *LocalityEndpoints) Validate() 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
- type RtdsDummyValidationError
- type Runtime
- func (*Runtime) Descriptor() ([]byte, []int)deprecated
- func (x *Runtime) GetLayer() *_struct.Struct
- func (x *Runtime) GetName() string
- func (*Runtime) ProtoMessage()
- func (x *Runtime) ProtoReflect() protoreflect.Message
- func (x *Runtime) Reset()
- func (x *Runtime) String() string
- func (m *Runtime) Validate() error
- type RuntimeDiscoveryServiceClient
- type RuntimeDiscoveryServiceServer
- type RuntimeDiscoveryService_DeltaRuntimeClient
- type RuntimeDiscoveryService_DeltaRuntimeServer
- type RuntimeDiscoveryService_StreamRuntimeClient
- type RuntimeDiscoveryService_StreamRuntimeServer
- type RuntimeValidationError
- type SdsDummy
- 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(RuntimeDiscoveryService_DeltaRuntimeServer) error
- func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
- func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime(RuntimeDiscoveryService_StreamRuntimeServer) error
- type UnimplementedSecretDiscoveryServiceServer
- func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets(SecretDiscoveryService_DeltaSecretsServer) error
- func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
- func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets(SecretDiscoveryService_StreamSecretsServer) error
Constants ¶
This section is empty.
Variables ¶
var ( Capability_Protocol_name = map[int32]string{ 0: "HTTP", 1: "TCP", 2: "REDIS", } Capability_Protocol_value = map[string]int32{ "HTTP": 0, "TCP": 1, "REDIS": 2, } )
Enum value maps for Capability_Protocol.
var File_envoy_service_discovery_v2_ads_proto protoreflect.FileDescriptor
var File_envoy_service_discovery_v2_hds_proto protoreflect.FileDescriptor
var File_envoy_service_discovery_v2_rtds_proto protoreflect.FileDescriptor
var File_envoy_service_discovery_v2_sds_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAggregatedDiscoveryServiceServer ¶
func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer)
func RegisterHealthDiscoveryServiceServer ¶
func RegisterHealthDiscoveryServiceServer(s *grpc.Server, srv HealthDiscoveryServiceServer)
func RegisterRuntimeDiscoveryServiceServer ¶ added in v0.9.6
func RegisterRuntimeDiscoveryServiceServer(s *grpc.Server, srv RuntimeDiscoveryServiceServer)
func RegisterSecretDiscoveryServiceServer ¶
func RegisterSecretDiscoveryServiceServer(s *grpc.Server, srv SecretDiscoveryServiceServer)
Types ¶
type AdsDummy ¶
type AdsDummy struct {
// contains filtered or unexported fields
}
func (*AdsDummy) Descriptor
deprecated
func (*AdsDummy) ProtoMessage ¶
func (*AdsDummy) ProtoMessage()
func (*AdsDummy) ProtoReflect ¶ added in v0.9.7
func (x *AdsDummy) ProtoReflect() protoreflect.Message
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.ClientConnInterface) 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 */ // contains filtered or unexported fields }
func (*Capability) Descriptor
deprecated
func (*Capability) Descriptor() ([]byte, []int)
Deprecated: Use Capability.ProtoReflect.Descriptor instead.
func (*Capability) GetHealthCheckProtocols ¶
func (x *Capability) GetHealthCheckProtocols() []Capability_Protocol
func (*Capability) ProtoMessage ¶
func (*Capability) ProtoMessage()
func (*Capability) ProtoReflect ¶ added in v0.9.7
func (x *Capability) ProtoReflect() protoreflect.Message
func (*Capability) Reset ¶
func (x *Capability) Reset()
func (*Capability) String ¶
func (x *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.
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) Descriptor ¶ added in v0.9.7
func (Capability_Protocol) Descriptor() protoreflect.EnumDescriptor
func (Capability_Protocol) Enum ¶ added in v0.9.7
func (x Capability_Protocol) Enum() *Capability_Protocol
func (Capability_Protocol) EnumDescriptor
deprecated
func (Capability_Protocol) EnumDescriptor() ([]byte, []int)
Deprecated: Use Capability_Protocol.Descriptor instead.
func (Capability_Protocol) Number ¶ added in v0.9.7
func (x Capability_Protocol) Number() protoreflect.EnumNumber
func (Capability_Protocol) String ¶
func (x Capability_Protocol) String() string
func (Capability_Protocol) Type ¶ added in v0.9.7
func (Capability_Protocol) Type() protoreflect.EnumType
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"` // contains filtered or unexported fields }
func (*ClusterHealthCheck) Descriptor
deprecated
func (*ClusterHealthCheck) Descriptor() ([]byte, []int)
Deprecated: Use ClusterHealthCheck.ProtoReflect.Descriptor instead.
func (*ClusterHealthCheck) GetClusterName ¶
func (x *ClusterHealthCheck) GetClusterName() string
func (*ClusterHealthCheck) GetHealthChecks ¶
func (x *ClusterHealthCheck) GetHealthChecks() []*core.HealthCheck
func (*ClusterHealthCheck) GetLocalityEndpoints ¶
func (x *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints
func (*ClusterHealthCheck) ProtoMessage ¶
func (*ClusterHealthCheck) ProtoMessage()
func (*ClusterHealthCheck) ProtoReflect ¶ added in v0.9.7
func (x *ClusterHealthCheck) ProtoReflect() protoreflect.Message
func (*ClusterHealthCheck) Reset ¶
func (x *ClusterHealthCheck) Reset()
func (*ClusterHealthCheck) String ¶
func (x *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.
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 */ // contains filtered or unexported fields }
func (*EndpointHealth) Descriptor
deprecated
func (*EndpointHealth) Descriptor() ([]byte, []int)
Deprecated: Use EndpointHealth.ProtoReflect.Descriptor instead.
func (*EndpointHealth) GetEndpoint ¶
func (x *EndpointHealth) GetEndpoint() *endpoint.Endpoint
func (*EndpointHealth) GetHealthStatus ¶
func (x *EndpointHealth) GetHealthStatus() core.HealthStatus
func (*EndpointHealth) ProtoMessage ¶
func (*EndpointHealth) ProtoMessage()
func (*EndpointHealth) ProtoReflect ¶ added in v0.9.7
func (x *EndpointHealth) ProtoReflect() protoreflect.Message
func (*EndpointHealth) Reset ¶
func (x *EndpointHealth) Reset()
func (*EndpointHealth) String ¶
func (x *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.
type EndpointHealthResponse ¶
type EndpointHealthResponse struct { EndpointsHealth []*EndpointHealth `protobuf:"bytes,1,rep,name=endpoints_health,json=endpointsHealth,proto3" json:"endpoints_health,omitempty"` // contains filtered or unexported fields }
func (*EndpointHealthResponse) Descriptor
deprecated
func (*EndpointHealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use EndpointHealthResponse.ProtoReflect.Descriptor instead.
func (*EndpointHealthResponse) GetEndpointsHealth ¶
func (x *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth
func (*EndpointHealthResponse) ProtoMessage ¶
func (*EndpointHealthResponse) ProtoMessage()
func (*EndpointHealthResponse) ProtoReflect ¶ added in v0.9.7
func (x *EndpointHealthResponse) ProtoReflect() protoreflect.Message
func (*EndpointHealthResponse) Reset ¶
func (x *EndpointHealthResponse) Reset()
func (*EndpointHealthResponse) String ¶
func (x *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.
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"` // contains filtered or unexported fields }
func (*HealthCheckRequest) Descriptor
deprecated
func (*HealthCheckRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.
func (*HealthCheckRequest) GetCapability ¶
func (x *HealthCheckRequest) GetCapability() *Capability
func (*HealthCheckRequest) GetNode ¶
func (x *HealthCheckRequest) GetNode() *core.Node
func (*HealthCheckRequest) ProtoMessage ¶
func (*HealthCheckRequest) ProtoMessage()
func (*HealthCheckRequest) ProtoReflect ¶ added in v0.9.7
func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
func (*HealthCheckRequest) Reset ¶
func (x *HealthCheckRequest) Reset()
func (*HealthCheckRequest) String ¶
func (x *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.
type HealthCheckRequestOrEndpointHealthResponse ¶
type HealthCheckRequestOrEndpointHealthResponse struct { // Types that are assignable to RequestType: // *HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest // *HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse RequestType isHealthCheckRequestOrEndpointHealthResponse_RequestType `protobuf_oneof:"request_type"` // contains filtered or unexported fields }
func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor
deprecated
func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckRequestOrEndpointHealthResponse.ProtoReflect.Descriptor instead.
func (*HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse ¶
func (x *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse
func (*HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest ¶
func (x *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest
func (*HealthCheckRequestOrEndpointHealthResponse) GetRequestType ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType
func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage ¶
func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()
func (*HealthCheckRequestOrEndpointHealthResponse) ProtoReflect ¶ added in v0.9.7
func (x *HealthCheckRequestOrEndpointHealthResponse) ProtoReflect() protoreflect.Message
func (*HealthCheckRequestOrEndpointHealthResponse) Reset ¶
func (x *HealthCheckRequestOrEndpointHealthResponse) Reset()
func (*HealthCheckRequestOrEndpointHealthResponse) String ¶
func (x *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.
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"` // contains filtered or unexported fields }
func (*HealthCheckSpecifier) Descriptor
deprecated
func (*HealthCheckSpecifier) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckSpecifier.ProtoReflect.Descriptor instead.
func (*HealthCheckSpecifier) GetClusterHealthChecks ¶
func (x *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck
func (*HealthCheckSpecifier) GetInterval ¶
func (x *HealthCheckSpecifier) GetInterval() *duration.Duration
func (*HealthCheckSpecifier) ProtoMessage ¶
func (*HealthCheckSpecifier) ProtoMessage()
func (*HealthCheckSpecifier) ProtoReflect ¶ added in v0.9.7
func (x *HealthCheckSpecifier) ProtoReflect() protoreflect.Message
func (*HealthCheckSpecifier) Reset ¶
func (x *HealthCheckSpecifier) Reset()
func (*HealthCheckSpecifier) String ¶
func (x *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.
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.ClientConnInterface) 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"` // contains filtered or unexported fields }
func (*LocalityEndpoints) Descriptor
deprecated
func (*LocalityEndpoints) Descriptor() ([]byte, []int)
Deprecated: Use LocalityEndpoints.ProtoReflect.Descriptor instead.
func (*LocalityEndpoints) GetEndpoints ¶
func (x *LocalityEndpoints) GetEndpoints() []*endpoint.Endpoint
func (*LocalityEndpoints) GetLocality ¶
func (x *LocalityEndpoints) GetLocality() *core.Locality
func (*LocalityEndpoints) ProtoMessage ¶
func (*LocalityEndpoints) ProtoMessage()
func (*LocalityEndpoints) ProtoReflect ¶ added in v0.9.7
func (x *LocalityEndpoints) ProtoReflect() protoreflect.Message
func (*LocalityEndpoints) Reset ¶
func (x *LocalityEndpoints) Reset()
func (*LocalityEndpoints) String ¶
func (x *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.
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.9.6
type RtdsDummy struct {
// contains filtered or unexported fields
}
func (*RtdsDummy) Descriptor
deprecated
added in
v0.9.6
func (*RtdsDummy) ProtoMessage ¶ added in v0.9.6
func (*RtdsDummy) ProtoMessage()
func (*RtdsDummy) ProtoReflect ¶ added in v0.9.7
func (x *RtdsDummy) ProtoReflect() protoreflect.Message
type RtdsDummyValidationError ¶ added in v0.9.6
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.9.6
func (e RtdsDummyValidationError) Cause() error
Cause function returns cause value.
func (RtdsDummyValidationError) Error ¶ added in v0.9.6
func (e RtdsDummyValidationError) Error() string
Error satisfies the builtin error interface
func (RtdsDummyValidationError) ErrorName ¶ added in v0.9.6
func (e RtdsDummyValidationError) ErrorName() string
ErrorName returns error name.
func (RtdsDummyValidationError) Field ¶ added in v0.9.6
func (e RtdsDummyValidationError) Field() string
Field function returns field value.
func (RtdsDummyValidationError) Key ¶ added in v0.9.6
func (e RtdsDummyValidationError) Key() bool
Key function returns key value.
func (RtdsDummyValidationError) Reason ¶ added in v0.9.6
func (e RtdsDummyValidationError) Reason() string
Reason function returns reason value.
type Runtime ¶ added in v0.9.6
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"` // contains filtered or unexported fields }
func (*Runtime) Descriptor
deprecated
added in
v0.9.6
func (*Runtime) ProtoMessage ¶ added in v0.9.6
func (*Runtime) ProtoMessage()
func (*Runtime) ProtoReflect ¶ added in v0.9.7
func (x *Runtime) ProtoReflect() protoreflect.Message
type RuntimeDiscoveryServiceClient ¶ added in v0.9.6
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.9.6
func NewRuntimeDiscoveryServiceClient(cc grpc.ClientConnInterface) RuntimeDiscoveryServiceClient
type RuntimeDiscoveryServiceServer ¶ added in v0.9.6
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.9.6
type RuntimeDiscoveryService_DeltaRuntimeClient interface { Send(*v2.DeltaDiscoveryRequest) error Recv() (*v2.DeltaDiscoveryResponse, error) grpc.ClientStream }
type RuntimeDiscoveryService_DeltaRuntimeServer ¶ added in v0.9.6
type RuntimeDiscoveryService_DeltaRuntimeServer interface { Send(*v2.DeltaDiscoveryResponse) error Recv() (*v2.DeltaDiscoveryRequest, error) grpc.ServerStream }
type RuntimeDiscoveryService_StreamRuntimeClient ¶ added in v0.9.6
type RuntimeDiscoveryService_StreamRuntimeClient interface { Send(*v2.DiscoveryRequest) error Recv() (*v2.DiscoveryResponse, error) grpc.ClientStream }
type RuntimeDiscoveryService_StreamRuntimeServer ¶ added in v0.9.6
type RuntimeDiscoveryService_StreamRuntimeServer interface { Send(*v2.DiscoveryResponse) error Recv() (*v2.DiscoveryRequest, error) grpc.ServerStream }
type RuntimeValidationError ¶ added in v0.9.6
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.9.6
func (e RuntimeValidationError) Cause() error
Cause function returns cause value.
func (RuntimeValidationError) Error ¶ added in v0.9.6
func (e RuntimeValidationError) Error() string
Error satisfies the builtin error interface
func (RuntimeValidationError) ErrorName ¶ added in v0.9.6
func (e RuntimeValidationError) ErrorName() string
ErrorName returns error name.
func (RuntimeValidationError) Field ¶ added in v0.9.6
func (e RuntimeValidationError) Field() string
Field function returns field value.
func (RuntimeValidationError) Key ¶ added in v0.9.6
func (e RuntimeValidationError) Key() bool
Key function returns key value.
func (RuntimeValidationError) Reason ¶ added in v0.9.6
func (e RuntimeValidationError) Reason() string
Reason function returns reason value.
type SdsDummy ¶
type SdsDummy struct {
// contains filtered or unexported fields
}
func (*SdsDummy) Descriptor
deprecated
func (*SdsDummy) ProtoMessage ¶
func (*SdsDummy) ProtoMessage()
func (*SdsDummy) ProtoReflect ¶ added in v0.9.7
func (x *SdsDummy) ProtoReflect() protoreflect.Message
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.ClientConnInterface) 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.9.6
type SecretDiscoveryService_DeltaSecretsClient interface { Send(*v2.DeltaDiscoveryRequest) error Recv() (*v2.DeltaDiscoveryResponse, error) grpc.ClientStream }
type SecretDiscoveryService_DeltaSecretsServer ¶ added in v0.9.6
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.6
type UnimplementedAggregatedDiscoveryServiceServer struct { }
UnimplementedAggregatedDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources ¶ added in v0.9.6
func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources ¶ added in v0.9.6
func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
type UnimplementedHealthDiscoveryServiceServer ¶ added in v0.9.6
type UnimplementedHealthDiscoveryServiceServer struct { }
UnimplementedHealthDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck ¶ added in v0.9.6
func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck(context.Context, *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error)
func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck ¶ added in v0.9.6
func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck(HealthDiscoveryService_StreamHealthCheckServer) error
type UnimplementedRuntimeDiscoveryServiceServer ¶ added in v0.9.6
type UnimplementedRuntimeDiscoveryServiceServer struct { }
UnimplementedRuntimeDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedRuntimeDiscoveryServiceServer) DeltaRuntime ¶ added in v0.9.6
func (*UnimplementedRuntimeDiscoveryServiceServer) DeltaRuntime(RuntimeDiscoveryService_DeltaRuntimeServer) error
func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime ¶ added in v0.9.6
func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime ¶ added in v0.9.6
func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime(RuntimeDiscoveryService_StreamRuntimeServer) error
type UnimplementedSecretDiscoveryServiceServer ¶ added in v0.9.6
type UnimplementedSecretDiscoveryServiceServer struct { }
UnimplementedSecretDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets ¶ added in v0.9.6
func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets(SecretDiscoveryService_DeltaSecretsServer) error
func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets ¶ added in v0.9.6
func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets ¶ added in v0.9.6
func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets(SecretDiscoveryService_StreamSecretsServer) error