Documentation
¶
Index ¶
- Variables
- func RegisterHandlerServer(s grpc.ServiceRegistrar, srv HandlerServer)
- type HandlerClient
- type HandlerServer
- type Point
- func (*Point) Descriptor() ([]byte, []int)deprecated
- func (x *Point) GetMeasurement() string
- func (x *Point) GetName() string
- func (x *Point) GetTimestamp() int64
- func (x *Point) GetVal() float64
- func (*Point) ProtoMessage()
- func (x *Point) ProtoReflect() protoreflect.Message
- func (x *Point) Reset()
- func (x *Point) String() string
- type Points
- func (*Points) Descriptor() ([]byte, []int)deprecated
- func (x *Points) GetClass() string
- func (x *Points) GetPoints() []*Point
- func (x *Points) GetSource() string
- func (*Points) ProtoMessage()
- func (x *Points) ProtoReflect() protoreflect.Message
- func (x *Points) Reset()
- func (x *Points) String() string
- type PointsResponse
- func (*PointsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PointsResponse) GetError() string
- func (x *PointsResponse) GetProcessed() uint32
- func (x *PointsResponse) GetStatus() uint32
- func (*PointsResponse) ProtoMessage()
- func (x *PointsResponse) ProtoReflect() protoreflect.Message
- func (x *PointsResponse) Reset()
- func (x *PointsResponse) String() string
- type UnimplementedHandlerServer
- type UnsafeHandlerServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_points_proto protoreflect.FileDescriptor
View Source
var Handler_ServiceDesc = grpc.ServiceDesc{ ServiceName: "points.Handler", HandlerType: (*HandlerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Do", Handler: _Handler_Do_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "points.proto", }
Handler_ServiceDesc is the grpc.ServiceDesc for Handler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterHandlerServer ¶
func RegisterHandlerServer(s grpc.ServiceRegistrar, srv HandlerServer)
Types ¶
type HandlerClient ¶
type HandlerClient interface {
Do(ctx context.Context, in *Points, opts ...grpc.CallOption) (*PointsResponse, error)
}
HandlerClient is the client API for Handler 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 NewHandlerClient ¶
func NewHandlerClient(cc grpc.ClientConnInterface) HandlerClient
type HandlerServer ¶
type HandlerServer interface {
Do(context.Context, *Points) (*PointsResponse, error)
// contains filtered or unexported methods
}
HandlerServer is the server API for Handler service. All implementations must embed UnimplementedHandlerServer for forward compatibility
type Point ¶
type Point struct {
Measurement string `protobuf:"bytes,1,opt,name=measurement,proto3" json:"measurement,omitempty"`
Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
Val float64 `protobuf:"fixed64,4,opt,name=val,proto3" json:"val,omitempty"`
// contains filtered or unexported fields
}
func (*Point) Descriptor
deprecated
func (*Point) GetMeasurement ¶
func (*Point) GetTimestamp ¶
func (*Point) ProtoMessage ¶
func (*Point) ProtoMessage()
func (*Point) ProtoReflect ¶
func (x *Point) ProtoReflect() protoreflect.Message
type Points ¶
type Points struct {
Class string `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"`
Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
Points []*Point `protobuf:"bytes,3,rep,name=points,proto3" json:"points,omitempty"`
// contains filtered or unexported fields
}
func (*Points) Descriptor
deprecated
func (*Points) ProtoMessage ¶
func (*Points) ProtoMessage()
func (*Points) ProtoReflect ¶
func (x *Points) ProtoReflect() protoreflect.Message
type PointsResponse ¶
type PointsResponse struct {
Processed uint32 `protobuf:"varint,1,opt,name=processed,proto3" json:"processed,omitempty"`
Status uint32 `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*PointsResponse) Descriptor
deprecated
func (*PointsResponse) Descriptor() ([]byte, []int)
Deprecated: Use PointsResponse.ProtoReflect.Descriptor instead.
func (*PointsResponse) GetError ¶
func (x *PointsResponse) GetError() string
func (*PointsResponse) GetProcessed ¶
func (x *PointsResponse) GetProcessed() uint32
func (*PointsResponse) GetStatus ¶
func (x *PointsResponse) GetStatus() uint32
func (*PointsResponse) ProtoMessage ¶
func (*PointsResponse) ProtoMessage()
func (*PointsResponse) ProtoReflect ¶
func (x *PointsResponse) ProtoReflect() protoreflect.Message
func (*PointsResponse) Reset ¶
func (x *PointsResponse) Reset()
func (*PointsResponse) String ¶
func (x *PointsResponse) String() string
type UnimplementedHandlerServer ¶
type UnimplementedHandlerServer struct {
}
UnimplementedHandlerServer must be embedded to have forward compatible implementations.
func (UnimplementedHandlerServer) Do ¶
func (UnimplementedHandlerServer) Do(context.Context, *Points) (*PointsResponse, error)
type UnsafeHandlerServer ¶
type UnsafeHandlerServer interface {
// contains filtered or unexported methods
}
UnsafeHandlerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HandlerServer will result in compilation errors.
Source Files
Click to show internal directories.
Click to hide internal directories.