Documentation
¶
Index ¶
- Variables
- func RegisterEndpointServiceServer(s grpc.ServiceRegistrar, srv EndpointServiceServer)
- type Endpoint
- func (*Endpoint) Descriptor() ([]byte, []int)deprecated
- func (x *Endpoint) GetHostname() string
- func (x *Endpoint) GetPort() uint32
- func (x *Endpoint) GetWeight() uint32
- func (*Endpoint) ProtoMessage()
- func (x *Endpoint) ProtoReflect() protoreflect.Message
- func (x *Endpoint) Reset()
- func (x *Endpoint) String() string
- func (m *Endpoint) Validate() error
- type EndpointServiceClient
- type EndpointServiceServer
- type EndpointService_WatchClient
- type EndpointService_WatchServer
- type EndpointValidationError
- type UnimplementedEndpointServiceServer
- type UnsafeEndpointServiceServer
- type WatchRequest
- func (*WatchRequest) Descriptor() ([]byte, []int)deprecated
- func (m *WatchRequest) GetRequestTypeOneof() isWatchRequest_RequestTypeOneof
- func (x *WatchRequest) GetSrv() *WatchRequest_SRVRequest
- func (*WatchRequest) ProtoMessage()
- func (x *WatchRequest) ProtoReflect() protoreflect.Message
- func (x *WatchRequest) Reset()
- func (x *WatchRequest) String() string
- func (m *WatchRequest) Validate() error
- type WatchRequestValidationError
- func (e WatchRequestValidationError) Cause() error
- func (e WatchRequestValidationError) Error() string
- func (e WatchRequestValidationError) ErrorName() string
- func (e WatchRequestValidationError) Field() string
- func (e WatchRequestValidationError) Key() bool
- func (e WatchRequestValidationError) Reason() string
- type WatchRequest_SRVRequest
- func (*WatchRequest_SRVRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchRequest_SRVRequest) GetDnsName() string
- func (x *WatchRequest_SRVRequest) GetProtocol() string
- func (x *WatchRequest_SRVRequest) GetService() string
- func (*WatchRequest_SRVRequest) ProtoMessage()
- func (x *WatchRequest_SRVRequest) ProtoReflect() protoreflect.Message
- func (x *WatchRequest_SRVRequest) Reset()
- func (x *WatchRequest_SRVRequest) String() string
- func (m *WatchRequest_SRVRequest) Validate() error
- type WatchRequest_SRVRequestValidationError
- func (e WatchRequest_SRVRequestValidationError) Cause() error
- func (e WatchRequest_SRVRequestValidationError) Error() string
- func (e WatchRequest_SRVRequestValidationError) ErrorName() string
- func (e WatchRequest_SRVRequestValidationError) Field() string
- func (e WatchRequest_SRVRequestValidationError) Key() bool
- func (e WatchRequest_SRVRequestValidationError) Reason() string
- type WatchRequest_Srv
- type WatchResponse
- func (*WatchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WatchResponse) GetEndpoints() []*Endpoint
- func (*WatchResponse) ProtoMessage()
- func (x *WatchResponse) ProtoReflect() protoreflect.Message
- func (x *WatchResponse) Reset()
- func (x *WatchResponse) String() string
- func (m *WatchResponse) Validate() error
- type WatchResponseValidationError
- func (e WatchResponseValidationError) Cause() error
- func (e WatchResponseValidationError) Error() string
- func (e WatchResponseValidationError) ErrorName() string
- func (e WatchResponseValidationError) Field() string
- func (e WatchResponseValidationError) Key() bool
- func (e WatchResponseValidationError) Reason() string
Constants ¶
This section is empty.
Variables ¶
var EndpointService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "servok.api.v1.EndpointService", HandlerType: (*EndpointServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Watch", Handler: _EndpointService_Watch_Handler, ServerStreams: true, }, }, Metadata: "servok/api/v1/v1.proto", }
EndpointService_ServiceDesc is the grpc.ServiceDesc for EndpointService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_servok_api_v1_v1_proto protoreflect.FileDescriptor
Functions ¶
func RegisterEndpointServiceServer ¶
func RegisterEndpointServiceServer(s grpc.ServiceRegistrar, srv EndpointServiceServer)
Types ¶
type Endpoint ¶
type Endpoint struct { Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` Weight uint32 `protobuf:"varint,3,opt,name=weight,proto3" json:"weight,omitempty"` // contains filtered or unexported fields }
func (*Endpoint) Descriptor
deprecated
func (*Endpoint) GetHostname ¶
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
func (*Endpoint) ProtoReflect ¶
func (x *Endpoint) ProtoReflect() protoreflect.Message
type EndpointServiceClient ¶
type EndpointServiceClient interface {
Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (EndpointService_WatchClient, error)
}
EndpointServiceClient is the client API for EndpointService 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.
func NewEndpointServiceClient ¶
func NewEndpointServiceClient(cc grpc.ClientConnInterface) EndpointServiceClient
type EndpointServiceServer ¶
type EndpointServiceServer interface { Watch(*WatchRequest, EndpointService_WatchServer) error // contains filtered or unexported methods }
EndpointServiceServer is the server API for EndpointService service. All implementations must embed UnimplementedEndpointServiceServer for forward compatibility
type EndpointService_WatchClient ¶
type EndpointService_WatchClient interface { Recv() (*WatchResponse, error) grpc.ClientStream }
type EndpointService_WatchServer ¶
type EndpointService_WatchServer interface { Send(*WatchResponse) error grpc.ServerStream }
type EndpointValidationError ¶
type EndpointValidationError struct {
// contains filtered or unexported fields
}
EndpointValidationError is the validation error returned by Endpoint.Validate if the designated constraints aren't met.
func (EndpointValidationError) Cause ¶
func (e EndpointValidationError) Cause() error
Cause function returns cause value.
func (EndpointValidationError) Error ¶
func (e EndpointValidationError) Error() string
Error satisfies the builtin error interface
func (EndpointValidationError) ErrorName ¶
func (e EndpointValidationError) ErrorName() string
ErrorName returns error name.
func (EndpointValidationError) Field ¶
func (e EndpointValidationError) Field() string
Field function returns field value.
func (EndpointValidationError) Key ¶
func (e EndpointValidationError) Key() bool
Key function returns key value.
func (EndpointValidationError) Reason ¶
func (e EndpointValidationError) Reason() string
Reason function returns reason value.
type UnimplementedEndpointServiceServer ¶
type UnimplementedEndpointServiceServer struct { }
UnimplementedEndpointServiceServer must be embedded to have forward compatible implementations.
type UnsafeEndpointServiceServer ¶
type UnsafeEndpointServiceServer interface {
// contains filtered or unexported methods
}
UnsafeEndpointServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EndpointServiceServer will result in compilation errors.
type WatchRequest ¶
type WatchRequest struct { // Types that are assignable to RequestTypeOneof: // *WatchRequest_Srv RequestTypeOneof isWatchRequest_RequestTypeOneof `protobuf_oneof:"request_type_oneof"` // contains filtered or unexported fields }
func (*WatchRequest) Descriptor
deprecated
func (*WatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.
func (*WatchRequest) GetRequestTypeOneof ¶
func (m *WatchRequest) GetRequestTypeOneof() isWatchRequest_RequestTypeOneof
func (*WatchRequest) GetSrv ¶
func (x *WatchRequest) GetSrv() *WatchRequest_SRVRequest
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) ProtoReflect ¶
func (x *WatchRequest) ProtoReflect() protoreflect.Message
func (*WatchRequest) Reset ¶
func (x *WatchRequest) Reset()
func (*WatchRequest) String ¶
func (x *WatchRequest) String() string
func (*WatchRequest) Validate ¶
func (m *WatchRequest) Validate() error
Validate checks the field values on WatchRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type WatchRequestValidationError ¶
type WatchRequestValidationError struct {
// contains filtered or unexported fields
}
WatchRequestValidationError is the validation error returned by WatchRequest.Validate if the designated constraints aren't met.
func (WatchRequestValidationError) Cause ¶
func (e WatchRequestValidationError) Cause() error
Cause function returns cause value.
func (WatchRequestValidationError) Error ¶
func (e WatchRequestValidationError) Error() string
Error satisfies the builtin error interface
func (WatchRequestValidationError) ErrorName ¶
func (e WatchRequestValidationError) ErrorName() string
ErrorName returns error name.
func (WatchRequestValidationError) Field ¶
func (e WatchRequestValidationError) Field() string
Field function returns field value.
func (WatchRequestValidationError) Key ¶
func (e WatchRequestValidationError) Key() bool
Key function returns key value.
func (WatchRequestValidationError) Reason ¶
func (e WatchRequestValidationError) Reason() string
Reason function returns reason value.
type WatchRequest_SRVRequest ¶
type WatchRequest_SRVRequest struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"` DnsName string `protobuf:"bytes,3,opt,name=dns_name,json=dnsName,proto3" json:"dns_name,omitempty"` // contains filtered or unexported fields }
func (*WatchRequest_SRVRequest) Descriptor
deprecated
func (*WatchRequest_SRVRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchRequest_SRVRequest.ProtoReflect.Descriptor instead.
func (*WatchRequest_SRVRequest) GetDnsName ¶
func (x *WatchRequest_SRVRequest) GetDnsName() string
func (*WatchRequest_SRVRequest) GetProtocol ¶
func (x *WatchRequest_SRVRequest) GetProtocol() string
func (*WatchRequest_SRVRequest) GetService ¶
func (x *WatchRequest_SRVRequest) GetService() string
func (*WatchRequest_SRVRequest) ProtoMessage ¶
func (*WatchRequest_SRVRequest) ProtoMessage()
func (*WatchRequest_SRVRequest) ProtoReflect ¶
func (x *WatchRequest_SRVRequest) ProtoReflect() protoreflect.Message
func (*WatchRequest_SRVRequest) Reset ¶
func (x *WatchRequest_SRVRequest) Reset()
func (*WatchRequest_SRVRequest) String ¶
func (x *WatchRequest_SRVRequest) String() string
func (*WatchRequest_SRVRequest) Validate ¶
func (m *WatchRequest_SRVRequest) Validate() error
Validate checks the field values on WatchRequest_SRVRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type WatchRequest_SRVRequestValidationError ¶
type WatchRequest_SRVRequestValidationError struct {
// contains filtered or unexported fields
}
WatchRequest_SRVRequestValidationError is the validation error returned by WatchRequest_SRVRequest.Validate if the designated constraints aren't met.
func (WatchRequest_SRVRequestValidationError) Cause ¶
func (e WatchRequest_SRVRequestValidationError) Cause() error
Cause function returns cause value.
func (WatchRequest_SRVRequestValidationError) Error ¶
func (e WatchRequest_SRVRequestValidationError) Error() string
Error satisfies the builtin error interface
func (WatchRequest_SRVRequestValidationError) ErrorName ¶
func (e WatchRequest_SRVRequestValidationError) ErrorName() string
ErrorName returns error name.
func (WatchRequest_SRVRequestValidationError) Field ¶
func (e WatchRequest_SRVRequestValidationError) Field() string
Field function returns field value.
func (WatchRequest_SRVRequestValidationError) Key ¶
func (e WatchRequest_SRVRequestValidationError) Key() bool
Key function returns key value.
func (WatchRequest_SRVRequestValidationError) Reason ¶
func (e WatchRequest_SRVRequestValidationError) Reason() string
Reason function returns reason value.
type WatchRequest_Srv ¶
type WatchRequest_Srv struct {
Srv *WatchRequest_SRVRequest `protobuf:"bytes,1,opt,name=srv,proto3,oneof"`
}
type WatchResponse ¶
type WatchResponse struct { Endpoints []*Endpoint `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"` // contains filtered or unexported fields }
func (*WatchResponse) Descriptor
deprecated
func (*WatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.
func (*WatchResponse) GetEndpoints ¶
func (x *WatchResponse) GetEndpoints() []*Endpoint
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) ProtoReflect ¶
func (x *WatchResponse) ProtoReflect() protoreflect.Message
func (*WatchResponse) Reset ¶
func (x *WatchResponse) Reset()
func (*WatchResponse) String ¶
func (x *WatchResponse) String() string
func (*WatchResponse) Validate ¶
func (m *WatchResponse) Validate() error
Validate checks the field values on WatchResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type WatchResponseValidationError ¶
type WatchResponseValidationError struct {
// contains filtered or unexported fields
}
WatchResponseValidationError is the validation error returned by WatchResponse.Validate if the designated constraints aren't met.
func (WatchResponseValidationError) Cause ¶
func (e WatchResponseValidationError) Cause() error
Cause function returns cause value.
func (WatchResponseValidationError) Error ¶
func (e WatchResponseValidationError) Error() string
Error satisfies the builtin error interface
func (WatchResponseValidationError) ErrorName ¶
func (e WatchResponseValidationError) ErrorName() string
ErrorName returns error name.
func (WatchResponseValidationError) Field ¶
func (e WatchResponseValidationError) Field() string
Field function returns field value.
func (WatchResponseValidationError) Key ¶
func (e WatchResponseValidationError) Key() bool
Key function returns key value.
func (WatchResponseValidationError) Reason ¶
func (e WatchResponseValidationError) Reason() string
Reason function returns reason value.