Documentation ¶
Index ¶
- Variables
- func RegisterProcessorServer(s *grpc.Server, srv ProcessorServer)
- type DatasetRequest
- func (*DatasetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetRequest) GetData() []byte
- func (x *DatasetRequest) GetMetricId() string
- func (x *DatasetRequest) GetRitVersion() string
- func (x *DatasetRequest) GetSo() string
- func (x *DatasetRequest) GetTimestamp() *timestamp.Timestamp
- func (x *DatasetRequest) GetUserId() string
- func (*DatasetRequest) ProtoMessage()
- func (x *DatasetRequest) ProtoReflect() protoreflect.Message
- func (x *DatasetRequest) Reset()
- func (x *DatasetRequest) String() string
- type ProcessorClient
- type ProcessorServer
- type UnimplementedProcessorServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_internal_proto_metric_proto protoreflect.FileDescriptor
Functions ¶
func RegisterProcessorServer ¶
func RegisterProcessorServer(s *grpc.Server, srv ProcessorServer)
Types ¶
type DatasetRequest ¶
type DatasetRequest struct { MetricId string `protobuf:"bytes,1,opt,name=MetricId,proto3" json:"MetricId,omitempty"` UserId string `protobuf:"bytes,2,opt,name=UserId,proto3" json:"UserId,omitempty"` Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"` So string `protobuf:"bytes,4,opt,name=So,proto3" json:"So,omitempty"` RitVersion string `protobuf:"bytes,5,opt,name=RitVersion,proto3" json:"RitVersion,omitempty"` Data []byte `protobuf:"bytes,6,opt,name=Data,proto3" json:"Data,omitempty"` // contains filtered or unexported fields }
func (*DatasetRequest) Descriptor
deprecated
func (*DatasetRequest) Descriptor() ([]byte, []int)
Deprecated: Use DatasetRequest.ProtoReflect.Descriptor instead.
func (*DatasetRequest) GetData ¶
func (x *DatasetRequest) GetData() []byte
func (*DatasetRequest) GetMetricId ¶
func (x *DatasetRequest) GetMetricId() string
func (*DatasetRequest) GetRitVersion ¶
func (x *DatasetRequest) GetRitVersion() string
func (*DatasetRequest) GetSo ¶
func (x *DatasetRequest) GetSo() string
func (*DatasetRequest) GetTimestamp ¶
func (x *DatasetRequest) GetTimestamp() *timestamp.Timestamp
func (*DatasetRequest) GetUserId ¶
func (x *DatasetRequest) GetUserId() string
func (*DatasetRequest) ProtoMessage ¶
func (*DatasetRequest) ProtoMessage()
func (*DatasetRequest) ProtoReflect ¶
func (x *DatasetRequest) ProtoReflect() protoreflect.Message
func (*DatasetRequest) Reset ¶
func (x *DatasetRequest) Reset()
func (*DatasetRequest) String ¶
func (x *DatasetRequest) String() string
type ProcessorClient ¶
type ProcessorClient interface {
Process(ctx context.Context, in *DatasetRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}
ProcessorClient is the client API for Processor 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 NewProcessorClient ¶
func NewProcessorClient(cc grpc.ClientConnInterface) ProcessorClient
type ProcessorServer ¶
type ProcessorServer interface { Process(context.Context, *DatasetRequest) (*empty.Empty, error) // contains filtered or unexported methods }
ProcessorServer is the server API for Processor service. All implementations must embed UnimplementedProcessorServer for forward compatibility
type UnimplementedProcessorServer ¶
type UnimplementedProcessorServer struct { }
UnimplementedProcessorServer must be embedded to have forward compatible implementations.
func (*UnimplementedProcessorServer) Process ¶
func (*UnimplementedProcessorServer) Process(context.Context, *DatasetRequest) (*empty.Empty, error)
Click to show internal directories.
Click to hide internal directories.