Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterRegistryServer(s grpc.ServiceRegistrar, srv RegistryServer)
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRequest) GetKinds() []ServiceKind
- func (*ListRequest) ProtoMessage()
- func (x *ListRequest) ProtoReflect() protoreflect.Message
- func (x *ListRequest) Reset()
- func (x *ListRequest) String() string
- func (m *ListRequest) Validate() error
- func (m *ListRequest) ValidateAll() error
- type ListRequestMultiError
- type ListRequestValidationError
- func (e ListRequestValidationError) Cause() error
- func (e ListRequestValidationError) Error() string
- func (e ListRequestValidationError) ErrorName() string
- func (e ListRequestValidationError) Field() string
- func (e ListRequestValidationError) Key() bool
- func (e ListRequestValidationError) Reason() string
- type RegisterRequest
- func (*RegisterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterRequest) GetMetadata() map[string]*anypb.Any
- func (x *RegisterRequest) GetServices() []*Service
- func (*RegisterRequest) ProtoMessage()
- func (x *RegisterRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterRequest) Reset()
- func (x *RegisterRequest) String() string
- func (m *RegisterRequest) Validate() error
- func (m *RegisterRequest) ValidateAll() error
- type RegisterRequestMultiError
- type RegisterRequestValidationError
- func (e RegisterRequestValidationError) Cause() error
- func (e RegisterRequestValidationError) Error() string
- func (e RegisterRequestValidationError) ErrorName() string
- func (e RegisterRequestValidationError) Field() string
- func (e RegisterRequestValidationError) Key() bool
- func (e RegisterRequestValidationError) Reason() string
- type RegisterResponse
- func (*RegisterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterResponse) GetCallBackAfter() *durationpb.Duration
- func (*RegisterResponse) ProtoMessage()
- func (x *RegisterResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterResponse) Reset()
- func (x *RegisterResponse) String() string
- func (m *RegisterResponse) Validate() error
- func (m *RegisterResponse) ValidateAll() error
- type RegisterResponseMultiError
- type RegisterResponseValidationError
- func (e RegisterResponseValidationError) Cause() error
- func (e RegisterResponseValidationError) Error() string
- func (e RegisterResponseValidationError) ErrorName() string
- func (e RegisterResponseValidationError) Field() string
- func (e RegisterResponseValidationError) Key() bool
- func (e RegisterResponseValidationError) Reason() string
- type RegistryClient
- type RegistryServer
- type Registry_WatchClient
- type Registry_WatchServer
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetEndpoint() string
- func (x *Service) GetKind() ServiceKind
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- func (m *Service) Validate() error
- func (m *Service) ValidateAll() error
- type ServiceKind
- func (ServiceKind) Descriptor() protoreflect.EnumDescriptor
- func (x ServiceKind) Enum() *ServiceKind
- func (ServiceKind) EnumDescriptor() ([]byte, []int)deprecated
- func (x ServiceKind) Number() protoreflect.EnumNumber
- func (x ServiceKind) String() string
- func (ServiceKind) Type() protoreflect.EnumType
- type ServiceList
- func (*ServiceList) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceList) GetServices() []*Service
- func (*ServiceList) ProtoMessage()
- func (x *ServiceList) ProtoReflect() protoreflect.Message
- func (x *ServiceList) Reset()
- func (x *ServiceList) String() string
- func (m *ServiceList) Validate() error
- func (m *ServiceList) ValidateAll() error
- type ServiceListMultiError
- type ServiceListValidationError
- func (e ServiceListValidationError) Cause() error
- func (e ServiceListValidationError) Error() string
- func (e ServiceListValidationError) ErrorName() string
- func (e ServiceListValidationError) Field() string
- func (e ServiceListValidationError) Key() bool
- func (e ServiceListValidationError) Reason() string
- type ServiceMultiError
- type ServiceRegistration
- func (*ServiceRegistration) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceRegistration) GetExpiresAt() *timestamppb.Timestamp
- func (x *ServiceRegistration) GetService() *Service
- func (*ServiceRegistration) ProtoMessage()
- func (x *ServiceRegistration) ProtoReflect() protoreflect.Message
- func (x *ServiceRegistration) Reset()
- func (x *ServiceRegistration) String() string
- func (m *ServiceRegistration) Validate() error
- func (m *ServiceRegistration) ValidateAll() error
- type ServiceRegistrationMultiError
- type ServiceRegistrationValidationError
- func (e ServiceRegistrationValidationError) Cause() error
- func (e ServiceRegistrationValidationError) Error() string
- func (e ServiceRegistrationValidationError) ErrorName() string
- func (e ServiceRegistrationValidationError) Field() string
- func (e ServiceRegistrationValidationError) Key() bool
- func (e ServiceRegistrationValidationError) Reason() string
- type ServiceValidationError
- type UnimplementedRegistryServer
- type UnsafeRegistryServer
Constants ¶
const ( Registry_Report_FullMethodName = "/registry.Registry/Report" Registry_List_FullMethodName = "/registry.Registry/List" Registry_Watch_FullMethodName = "/registry.Registry/Watch" )
Variables ¶
var ( ServiceKind_name = map[int32]string{ 0: "UNDEFINED_DO_NOT_USE", 1: "DATABROKER", 2: "AUTHORIZE", 3: "AUTHENTICATE", 4: "PROXY", 5: "REGISTRY", 6: "CONSOLE", 7: "PROMETHEUS_METRICS", } ServiceKind_value = map[string]int32{ "UNDEFINED_DO_NOT_USE": 0, "DATABROKER": 1, "AUTHORIZE": 2, "AUTHENTICATE": 3, "PROXY": 4, "REGISTRY": 5, "CONSOLE": 6, "PROMETHEUS_METRICS": 7, } )
Enum value maps for ServiceKind.
var File_registry_proto protoreflect.FileDescriptor
var Registry_ServiceDesc = grpc.ServiceDesc{ ServiceName: "registry.Registry", HandlerType: (*RegistryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Report", Handler: _Registry_Report_Handler, }, { MethodName: "List", Handler: _Registry_List_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Watch", Handler: _Registry_Watch_Handler, ServerStreams: true, }, }, Metadata: "registry.proto", }
Registry_ServiceDesc is the grpc.ServiceDesc for Registry service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRegistryServer ¶
func RegisterRegistryServer(s grpc.ServiceRegistrar, srv RegistryServer)
Types ¶
type ListRequest ¶
type ListRequest struct { Kinds []ServiceKind `protobuf:"varint,1,rep,packed,name=kinds,proto3,enum=registry.ServiceKind" json:"kinds,omitempty"` // contains filtered or unexported fields }
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetKinds ¶
func (x *ListRequest) GetKinds() []ServiceKind
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
func (*ListRequest) Validate ¶
func (m *ListRequest) Validate() error
Validate checks the field values on ListRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ListRequest) ValidateAll ¶ added in v0.16.0
func (m *ListRequest) ValidateAll() error
ValidateAll checks the field values on ListRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListRequestMultiError, or nil if none found.
type ListRequestMultiError ¶ added in v0.16.0
type ListRequestMultiError []error
ListRequestMultiError is an error wrapping multiple validation errors returned by ListRequest.ValidateAll() if the designated constraints aren't met.
func (ListRequestMultiError) AllErrors ¶ added in v0.16.0
func (m ListRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ListRequestMultiError) Error ¶ added in v0.16.0
func (m ListRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ListRequestValidationError ¶
type ListRequestValidationError struct {
// contains filtered or unexported fields
}
ListRequestValidationError is the validation error returned by ListRequest.Validate if the designated constraints aren't met.
func (ListRequestValidationError) Cause ¶
func (e ListRequestValidationError) Cause() error
Cause function returns cause value.
func (ListRequestValidationError) Error ¶
func (e ListRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ListRequestValidationError) ErrorName ¶
func (e ListRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ListRequestValidationError) Field ¶
func (e ListRequestValidationError) Field() string
Field function returns field value.
func (ListRequestValidationError) Key ¶
func (e ListRequestValidationError) Key() bool
Key function returns key value.
func (ListRequestValidationError) Reason ¶
func (e ListRequestValidationError) Reason() string
Reason function returns reason value.
type RegisterRequest ¶
type RegisterRequest struct { // services this deployment runs Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` // service may optionally provide certain metadata, such as // - build version // - startup time // - bootstrap configuration // - OS, OS version, OS hostname // - etc // this information is not distributed back to the inquiring nodes // and may also have a different storage and time to live Metadata map[string]*anypb.Any `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RegisterRequest) Descriptor
deprecated
func (*RegisterRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.
func (*RegisterRequest) GetMetadata ¶
func (x *RegisterRequest) GetMetadata() map[string]*anypb.Any
func (*RegisterRequest) GetServices ¶
func (x *RegisterRequest) GetServices() []*Service
func (*RegisterRequest) ProtoMessage ¶
func (*RegisterRequest) ProtoMessage()
func (*RegisterRequest) ProtoReflect ¶
func (x *RegisterRequest) ProtoReflect() protoreflect.Message
func (*RegisterRequest) Reset ¶
func (x *RegisterRequest) Reset()
func (*RegisterRequest) String ¶
func (x *RegisterRequest) String() string
func (*RegisterRequest) Validate ¶
func (m *RegisterRequest) Validate() error
Validate checks the field values on RegisterRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*RegisterRequest) ValidateAll ¶ added in v0.16.0
func (m *RegisterRequest) ValidateAll() error
ValidateAll checks the field values on RegisterRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RegisterRequestMultiError, or nil if none found.
type RegisterRequestMultiError ¶ added in v0.16.0
type RegisterRequestMultiError []error
RegisterRequestMultiError is an error wrapping multiple validation errors returned by RegisterRequest.ValidateAll() if the designated constraints aren't met.
func (RegisterRequestMultiError) AllErrors ¶ added in v0.16.0
func (m RegisterRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RegisterRequestMultiError) Error ¶ added in v0.16.0
func (m RegisterRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RegisterRequestValidationError ¶
type RegisterRequestValidationError struct {
// contains filtered or unexported fields
}
RegisterRequestValidationError is the validation error returned by RegisterRequest.Validate if the designated constraints aren't met.
func (RegisterRequestValidationError) Cause ¶
func (e RegisterRequestValidationError) Cause() error
Cause function returns cause value.
func (RegisterRequestValidationError) Error ¶
func (e RegisterRequestValidationError) Error() string
Error satisfies the builtin error interface
func (RegisterRequestValidationError) ErrorName ¶
func (e RegisterRequestValidationError) ErrorName() string
ErrorName returns error name.
func (RegisterRequestValidationError) Field ¶
func (e RegisterRequestValidationError) Field() string
Field function returns field value.
func (RegisterRequestValidationError) Key ¶
func (e RegisterRequestValidationError) Key() bool
Key function returns key value.
func (RegisterRequestValidationError) Reason ¶
func (e RegisterRequestValidationError) Reason() string
Reason function returns reason value.
type RegisterResponse ¶
type RegisterResponse struct { // indicates when to report back again CallBackAfter *durationpb.Duration `protobuf:"bytes,2,opt,name=call_back_after,json=callBackAfter,proto3" json:"call_back_after,omitempty"` // contains filtered or unexported fields }
func (*RegisterResponse) Descriptor
deprecated
func (*RegisterResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.
func (*RegisterResponse) GetCallBackAfter ¶
func (x *RegisterResponse) GetCallBackAfter() *durationpb.Duration
func (*RegisterResponse) ProtoMessage ¶
func (*RegisterResponse) ProtoMessage()
func (*RegisterResponse) ProtoReflect ¶
func (x *RegisterResponse) ProtoReflect() protoreflect.Message
func (*RegisterResponse) Reset ¶
func (x *RegisterResponse) Reset()
func (*RegisterResponse) String ¶
func (x *RegisterResponse) String() string
func (*RegisterResponse) Validate ¶
func (m *RegisterResponse) Validate() error
Validate checks the field values on RegisterResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*RegisterResponse) ValidateAll ¶ added in v0.16.0
func (m *RegisterResponse) ValidateAll() error
ValidateAll checks the field values on RegisterResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RegisterResponseMultiError, or nil if none found.
type RegisterResponseMultiError ¶ added in v0.16.0
type RegisterResponseMultiError []error
RegisterResponseMultiError is an error wrapping multiple validation errors returned by RegisterResponse.ValidateAll() if the designated constraints aren't met.
func (RegisterResponseMultiError) AllErrors ¶ added in v0.16.0
func (m RegisterResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RegisterResponseMultiError) Error ¶ added in v0.16.0
func (m RegisterResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RegisterResponseValidationError ¶
type RegisterResponseValidationError struct {
// contains filtered or unexported fields
}
RegisterResponseValidationError is the validation error returned by RegisterResponse.Validate if the designated constraints aren't met.
func (RegisterResponseValidationError) Cause ¶
func (e RegisterResponseValidationError) Cause() error
Cause function returns cause value.
func (RegisterResponseValidationError) Error ¶
func (e RegisterResponseValidationError) Error() string
Error satisfies the builtin error interface
func (RegisterResponseValidationError) ErrorName ¶
func (e RegisterResponseValidationError) ErrorName() string
ErrorName returns error name.
func (RegisterResponseValidationError) Field ¶
func (e RegisterResponseValidationError) Field() string
Field function returns field value.
func (RegisterResponseValidationError) Key ¶
func (e RegisterResponseValidationError) Key() bool
Key function returns key value.
func (RegisterResponseValidationError) Reason ¶
func (e RegisterResponseValidationError) Reason() string
Reason function returns reason value.
type RegistryClient ¶
type RegistryClient interface { // Report is periodically sent by each service to confirm it is still serving // with the registry data is persisted with a certain TTL Report(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error) // List returns current snapshot of the services known to the registry List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ServiceList, error) // Watch returns a stream of updates // for the simplicity of consumer its delivered as full snapshots // and is only sent when change is detected Watch(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ServiceList], error) }
RegistryClient is the client API for Registry service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Registry is invoked by services to inform
func NewRegistryClient ¶
func NewRegistryClient(cc grpc.ClientConnInterface) RegistryClient
type RegistryServer ¶
type RegistryServer interface { // Report is periodically sent by each service to confirm it is still serving // with the registry data is persisted with a certain TTL Report(context.Context, *RegisterRequest) (*RegisterResponse, error) // List returns current snapshot of the services known to the registry List(context.Context, *ListRequest) (*ServiceList, error) // Watch returns a stream of updates // for the simplicity of consumer its delivered as full snapshots // and is only sent when change is detected Watch(*ListRequest, grpc.ServerStreamingServer[ServiceList]) error }
RegistryServer is the server API for Registry service. All implementations should embed UnimplementedRegistryServer for forward compatibility.
Registry is invoked by services to inform
type Registry_WatchClient ¶
type Registry_WatchClient = grpc.ServerStreamingClient[ServiceList]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Registry_WatchServer ¶
type Registry_WatchServer = grpc.ServerStreamingServer[ServiceList]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Service ¶
type Service struct { // kind is service kind Kind ServiceKind `protobuf:"varint,1,opt,name=kind,proto3,enum=registry.ServiceKind" json:"kind,omitempty"` // network endpoints this service may be reachable at Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // contains filtered or unexported fields }
func (*Service) Descriptor
deprecated
func (*Service) GetEndpoint ¶
func (*Service) GetKind ¶
func (x *Service) GetKind() ServiceKind
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
func (*Service) Validate ¶
Validate checks the field values on Service with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Service) ValidateAll ¶ added in v0.16.0
ValidateAll checks the field values on Service with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ServiceMultiError, or nil if none found.
type ServiceKind ¶
type ServiceKind int32
const ( ServiceKind_UNDEFINED_DO_NOT_USE ServiceKind = 0 // databroker grpc service ServiceKind_DATABROKER ServiceKind = 1 // authorize grpc service ServiceKind_AUTHORIZE ServiceKind = 2 // authentication http(s) service ServiceKind_AUTHENTICATE ServiceKind = 3 // proxy service ServiceKind_PROXY ServiceKind = 4 // registry service ServiceKind_REGISTRY ServiceKind = 5 // console grpc service ServiceKind_CONSOLE ServiceKind = 6 // prometheus metrics compatible http endpoint ServiceKind_PROMETHEUS_METRICS ServiceKind = 7 )
func (ServiceKind) Descriptor ¶
func (ServiceKind) Descriptor() protoreflect.EnumDescriptor
func (ServiceKind) Enum ¶
func (x ServiceKind) Enum() *ServiceKind
func (ServiceKind) EnumDescriptor
deprecated
func (ServiceKind) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServiceKind.Descriptor instead.
func (ServiceKind) Number ¶
func (x ServiceKind) Number() protoreflect.EnumNumber
func (ServiceKind) String ¶
func (x ServiceKind) String() string
func (ServiceKind) Type ¶
func (ServiceKind) Type() protoreflect.EnumType
type ServiceList ¶
type ServiceList struct { Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
RegistrationSnapshot represents the current state of the services
func (*ServiceList) Descriptor
deprecated
func (*ServiceList) Descriptor() ([]byte, []int)
Deprecated: Use ServiceList.ProtoReflect.Descriptor instead.
func (*ServiceList) GetServices ¶
func (x *ServiceList) GetServices() []*Service
func (*ServiceList) ProtoMessage ¶
func (*ServiceList) ProtoMessage()
func (*ServiceList) ProtoReflect ¶
func (x *ServiceList) ProtoReflect() protoreflect.Message
func (*ServiceList) Reset ¶
func (x *ServiceList) Reset()
func (*ServiceList) String ¶
func (x *ServiceList) String() string
func (*ServiceList) Validate ¶
func (m *ServiceList) Validate() error
Validate checks the field values on ServiceList with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ServiceList) ValidateAll ¶ added in v0.16.0
func (m *ServiceList) ValidateAll() error
ValidateAll checks the field values on ServiceList with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ServiceListMultiError, or nil if none found.
type ServiceListMultiError ¶ added in v0.16.0
type ServiceListMultiError []error
ServiceListMultiError is an error wrapping multiple validation errors returned by ServiceList.ValidateAll() if the designated constraints aren't met.
func (ServiceListMultiError) AllErrors ¶ added in v0.16.0
func (m ServiceListMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ServiceListMultiError) Error ¶ added in v0.16.0
func (m ServiceListMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ServiceListValidationError ¶
type ServiceListValidationError struct {
// contains filtered or unexported fields
}
ServiceListValidationError is the validation error returned by ServiceList.Validate if the designated constraints aren't met.
func (ServiceListValidationError) Cause ¶
func (e ServiceListValidationError) Cause() error
Cause function returns cause value.
func (ServiceListValidationError) Error ¶
func (e ServiceListValidationError) Error() string
Error satisfies the builtin error interface
func (ServiceListValidationError) ErrorName ¶
func (e ServiceListValidationError) ErrorName() string
ErrorName returns error name.
func (ServiceListValidationError) Field ¶
func (e ServiceListValidationError) Field() string
Field function returns field value.
func (ServiceListValidationError) Key ¶
func (e ServiceListValidationError) Key() bool
Key function returns key value.
func (ServiceListValidationError) Reason ¶
func (e ServiceListValidationError) Reason() string
Reason function returns reason value.
type ServiceMultiError ¶ added in v0.16.0
type ServiceMultiError []error
ServiceMultiError is an error wrapping multiple validation errors returned by Service.ValidateAll() if the designated constraints aren't met.
func (ServiceMultiError) AllErrors ¶ added in v0.16.0
func (m ServiceMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ServiceMultiError) Error ¶ added in v0.16.0
func (m ServiceMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ServiceRegistration ¶
type ServiceRegistration struct { Service *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"` // contains filtered or unexported fields }
func (*ServiceRegistration) Descriptor
deprecated
func (*ServiceRegistration) Descriptor() ([]byte, []int)
Deprecated: Use ServiceRegistration.ProtoReflect.Descriptor instead.
func (*ServiceRegistration) GetExpiresAt ¶
func (x *ServiceRegistration) GetExpiresAt() *timestamppb.Timestamp
func (*ServiceRegistration) GetService ¶
func (x *ServiceRegistration) GetService() *Service
func (*ServiceRegistration) ProtoMessage ¶
func (*ServiceRegistration) ProtoMessage()
func (*ServiceRegistration) ProtoReflect ¶
func (x *ServiceRegistration) ProtoReflect() protoreflect.Message
func (*ServiceRegistration) Reset ¶
func (x *ServiceRegistration) Reset()
func (*ServiceRegistration) String ¶
func (x *ServiceRegistration) String() string
func (*ServiceRegistration) Validate ¶
func (m *ServiceRegistration) Validate() error
Validate checks the field values on ServiceRegistration with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ServiceRegistration) ValidateAll ¶ added in v0.16.0
func (m *ServiceRegistration) ValidateAll() error
ValidateAll checks the field values on ServiceRegistration with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ServiceRegistrationMultiError, or nil if none found.
type ServiceRegistrationMultiError ¶ added in v0.16.0
type ServiceRegistrationMultiError []error
ServiceRegistrationMultiError is an error wrapping multiple validation errors returned by ServiceRegistration.ValidateAll() if the designated constraints aren't met.
func (ServiceRegistrationMultiError) AllErrors ¶ added in v0.16.0
func (m ServiceRegistrationMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ServiceRegistrationMultiError) Error ¶ added in v0.16.0
func (m ServiceRegistrationMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ServiceRegistrationValidationError ¶
type ServiceRegistrationValidationError struct {
// contains filtered or unexported fields
}
ServiceRegistrationValidationError is the validation error returned by ServiceRegistration.Validate if the designated constraints aren't met.
func (ServiceRegistrationValidationError) Cause ¶
func (e ServiceRegistrationValidationError) Cause() error
Cause function returns cause value.
func (ServiceRegistrationValidationError) Error ¶
func (e ServiceRegistrationValidationError) Error() string
Error satisfies the builtin error interface
func (ServiceRegistrationValidationError) ErrorName ¶
func (e ServiceRegistrationValidationError) ErrorName() string
ErrorName returns error name.
func (ServiceRegistrationValidationError) Field ¶
func (e ServiceRegistrationValidationError) Field() string
Field function returns field value.
func (ServiceRegistrationValidationError) Key ¶
func (e ServiceRegistrationValidationError) Key() bool
Key function returns key value.
func (ServiceRegistrationValidationError) Reason ¶
func (e ServiceRegistrationValidationError) Reason() string
Reason function returns reason value.
type ServiceValidationError ¶
type ServiceValidationError struct {
// contains filtered or unexported fields
}
ServiceValidationError is the validation error returned by Service.Validate if the designated constraints aren't met.
func (ServiceValidationError) Cause ¶
func (e ServiceValidationError) Cause() error
Cause function returns cause value.
func (ServiceValidationError) Error ¶
func (e ServiceValidationError) Error() string
Error satisfies the builtin error interface
func (ServiceValidationError) ErrorName ¶
func (e ServiceValidationError) ErrorName() string
ErrorName returns error name.
func (ServiceValidationError) Field ¶
func (e ServiceValidationError) Field() string
Field function returns field value.
func (ServiceValidationError) Key ¶
func (e ServiceValidationError) Key() bool
Key function returns key value.
func (ServiceValidationError) Reason ¶
func (e ServiceValidationError) Reason() string
Reason function returns reason value.
type UnimplementedRegistryServer ¶
type UnimplementedRegistryServer struct{}
UnimplementedRegistryServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedRegistryServer) List ¶
func (UnimplementedRegistryServer) List(context.Context, *ListRequest) (*ServiceList, error)
func (UnimplementedRegistryServer) Report ¶
func (UnimplementedRegistryServer) Report(context.Context, *RegisterRequest) (*RegisterResponse, error)
func (UnimplementedRegistryServer) Watch ¶
func (UnimplementedRegistryServer) Watch(*ListRequest, grpc.ServerStreamingServer[ServiceList]) error
type UnsafeRegistryServer ¶ added in v0.27.0
type UnsafeRegistryServer interface {
// contains filtered or unexported methods
}
UnsafeRegistryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RegistryServer will result in compilation errors.
Source Files
¶
Directories
¶
Path | Synopsis |
---|---|
Package mock_registry is a generated GoMock package.
|
Package mock_registry is a generated GoMock package. |