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 ¶
var File_points_proto protoreflect.FileDescriptor
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.