internal

package
v0.0.0-...-873fb03 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 8, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL