collector

Aug 12, 2024

Changes in this version

+ const Collector_BoatControl_FullMethodName

+ const Collector_ReportNow_FullMethodName

+ const OperationCollectorBoatControl

+ const OperationCollectorReportNow

+ var BoatControlCommand_name = map[int32]string

+ var BoatControlCommand_value = map[string]int32

+ type BoatControlCommand int32

+ const BoatControlCommand_FORWARD

+ const BoatControlCommand_LEFT

+ const BoatControlCommand_RIGHT

+ func (BoatControlCommand) Descriptor() protoreflect.EnumDescriptor

+ func (BoatControlCommand) EnumDescriptor() ([]byte, []int)

+ func (BoatControlCommand) Type() protoreflect.EnumType

+ func (x BoatControlCommand) Enum() *BoatControlCommand

+ func (x BoatControlCommand) Number() protoreflect.EnumNumber

+ func (x BoatControlCommand) String() string

+ type BoatControlReq struct

+ Command BoatControlCommand

+ DeviceId uint64

+ func (*BoatControlReq) Descriptor() ([]byte, []int)

+ func (*BoatControlReq) ProtoMessage()

+ func (x *BoatControlReq) GetCommand() BoatControlCommand

+ func (x *BoatControlReq) GetDeviceId() uint64

+ func (x *BoatControlReq) ProtoReflect() protoreflect.Message

+ func (x *BoatControlReq) Reset()

+ func (x *BoatControlReq) String() string

type CollectorClient

+ BoatControl func(ctx context.Context, in *BoatControlReq, opts ...grpc.CallOption) (*Empty, error)

+ ReportNow func(ctx context.Context, in *ReportNowReq, opts ...grpc.CallOption) (*Empty, error)

type CollectorHTTPClient

+ BoatControl func(ctx context.Context, req *BoatControlReq, opts ...http.CallOption) (rsp *Empty, err error)

+ ReportNow func(ctx context.Context, req *ReportNowReq, opts ...http.CallOption) (rsp *Empty, err error)

type CollectorHTTPClientImpl

+ func (c *CollectorHTTPClientImpl) BoatControl(ctx context.Context, in *BoatControlReq, opts ...http.CallOption) (*Empty, error)

+ func (c *CollectorHTTPClientImpl) ReportNow(ctx context.Context, in *ReportNowReq, opts ...http.CallOption) (*Empty, error)

type CollectorHTTPServer

+ BoatControl func(context.Context, *BoatControlReq) (*Empty, error)

+ ReportNow func(context.Context, *ReportNowReq) (*Empty, error)

type CollectorServer

+ BoatControl func(context.Context, *BoatControlReq) (*Empty, error)

+ ReportNow func(context.Context, *ReportNowReq) (*Empty, error)

+ type ReportNowReq struct

+ DeviceId uint64

+ func (*ReportNowReq) Descriptor() ([]byte, []int)

+ func (*ReportNowReq) ProtoMessage()

+ func (x *ReportNowReq) GetDeviceId() uint64

+ func (x *ReportNowReq) ProtoReflect() protoreflect.Message

+ func (x *ReportNowReq) Reset()

+ func (x *ReportNowReq) String() string

type SetReportIntervalReq

+ DeviceId uint64

+ func (x *SetReportIntervalReq) GetDeviceId() uint64

type UnimplementedCollectorServer

+ func (UnimplementedCollectorServer) BoatControl(context.Context, *BoatControlReq) (*Empty, error)

+ func (UnimplementedCollectorServer) ReportNow(context.Context, *ReportNowReq) (*Empty, error)

Mar 6, 2024

Changes in this version

+ const Collector_GetDeviceStreamEvent_FullMethodName

+ const Collector_GetDeviceStreamReport_FullMethodName

type CollectorClient

+ GetDeviceStreamEvent func(ctx context.Context, in *GetDeviceStreamEventReq, opts ...grpc.CallOption) (Collector_GetDeviceStreamEventClient, error)

+ GetDeviceStreamReport func(ctx context.Context, in *GetDeviceStreamReportReq, opts ...grpc.CallOption) (Collector_GetDeviceStreamReportClient, error)

type CollectorServer

+ GetDeviceStreamEvent func(*GetDeviceStreamEventReq, Collector_GetDeviceStreamEventServer) error

+ GetDeviceStreamReport func(*GetDeviceStreamReportReq, Collector_GetDeviceStreamReportServer) error

+ type Collector_GetDeviceStreamEventClient interface

+ Recv func() (*GetDeviceStreamEventResp, error)

+ type Collector_GetDeviceStreamEventServer interface

+ Send func(*GetDeviceStreamEventResp) error

+ type Collector_GetDeviceStreamReportClient interface

+ Recv func() (*collection.CollectionData, error)

+ type Collector_GetDeviceStreamReportServer interface

+ Send func(*collection.CollectionData) error

+ type Empty struct

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (x *Empty) ProtoReflect() protoreflect.Message

+ func (x *Empty) Reset()

+ func (x *Empty) String() string

+ type GetDeviceStreamEventReq struct

+ EventFilter string

+ Id uint64

+ func (*GetDeviceStreamEventReq) Descriptor() ([]byte, []int)

+ func (*GetDeviceStreamEventReq) ProtoMessage()

+ func (x *GetDeviceStreamEventReq) GetEventFilter() string

+ func (x *GetDeviceStreamEventReq) GetId() uint64

+ func (x *GetDeviceStreamEventReq) ProtoReflect() protoreflect.Message

+ func (x *GetDeviceStreamEventReq) Reset()

+ func (x *GetDeviceStreamEventReq) String() string

+ type GetDeviceStreamEventResp struct

+ Message string

+ Topic string

+ func (*GetDeviceStreamEventResp) Descriptor() ([]byte, []int)

+ func (*GetDeviceStreamEventResp) ProtoMessage()

+ func (x *GetDeviceStreamEventResp) GetMessage() string

+ func (x *GetDeviceStreamEventResp) GetTopic() string

+ func (x *GetDeviceStreamEventResp) ProtoReflect() protoreflect.Message

+ func (x *GetDeviceStreamEventResp) Reset()

+ func (x *GetDeviceStreamEventResp) String() string

+ type GetDeviceStreamReportReq struct

+ Id uint64

+ func (*GetDeviceStreamReportReq) Descriptor() ([]byte, []int)

+ func (*GetDeviceStreamReportReq) ProtoMessage()

+ func (x *GetDeviceStreamReportReq) GetId() uint64

+ func (x *GetDeviceStreamReportReq) ProtoReflect() protoreflect.Message

+ func (x *GetDeviceStreamReportReq) Reset()

+ func (x *GetDeviceStreamReportReq) String() string

type UnimplementedCollectorServer

+ func (UnimplementedCollectorServer) GetDeviceStreamEvent(*GetDeviceStreamEventReq, Collector_GetDeviceStreamEventServer) error

+ func (UnimplementedCollectorServer) GetDeviceStreamReport(*GetDeviceStreamReportReq, Collector_GetDeviceStreamReportServer) error

Feb 22, 2024

Changes in this version

+ const Collector_GetDeviceStreamLog_FullMethodName

type CollectorClient

+ GetDeviceStreamLog func(ctx context.Context, in *GetDeviceStreamLogReq, opts ...grpc.CallOption) (Collector_GetDeviceStreamLogClient, error)

type CollectorServer

+ GetDeviceStreamLog func(*GetDeviceStreamLogReq, Collector_GetDeviceStreamLogServer) error

+ type Collector_GetDeviceStreamLogClient interface

+ Recv func() (*GetDeviceStreamLogResp, error)

+ type Collector_GetDeviceStreamLogServer interface

+ Send func(*GetDeviceStreamLogResp) error

+ type GetDeviceStreamLogReq struct

+ Id uint64

+ LevelFilter string

+ func (*GetDeviceStreamLogReq) Descriptor() ([]byte, []int)

+ func (*GetDeviceStreamLogReq) ProtoMessage()

+ func (x *GetDeviceStreamLogReq) GetId() uint64

+ func (x *GetDeviceStreamLogReq) GetLevelFilter() string

+ func (x *GetDeviceStreamLogReq) ProtoReflect() protoreflect.Message

+ func (x *GetDeviceStreamLogReq) Reset()

+ func (x *GetDeviceStreamLogReq) String() string

+ type GetDeviceStreamLogResp struct

+ Level uint32

+ Message string

+ Timestamp int64

+ func (*GetDeviceStreamLogResp) Descriptor() ([]byte, []int)

+ func (*GetDeviceStreamLogResp) ProtoMessage()

+ func (x *GetDeviceStreamLogResp) GetLevel() uint32

+ func (x *GetDeviceStreamLogResp) GetMessage() string

+ func (x *GetDeviceStreamLogResp) GetTimestamp() int64

+ func (x *GetDeviceStreamLogResp) ProtoReflect() protoreflect.Message

+ func (x *GetDeviceStreamLogResp) Reset()

+ func (x *GetDeviceStreamLogResp) String() string

type UnimplementedCollectorServer

+ func (UnimplementedCollectorServer) GetDeviceStreamLog(*GetDeviceStreamLogReq, Collector_GetDeviceStreamLogServer) error

Jan 3, 2024

Changes in this version

+ const Collector_ReportImmediately_FullMethodName

+ const Collector_SetReportInterval_FullMethodName

+ const OperationCollectorReportImmediately

+ const OperationCollectorSetReportInterval

+ var Collector_ServiceDesc = grpc.ServiceDesc

+ var File_collector_collector_proto protoreflect.FileDescriptor

+ func RegisterCollectorHTTPServer(s *http.Server, srv CollectorHTTPServer)

+ func RegisterCollectorServer(s grpc.ServiceRegistrar, srv CollectorServer)

+ type CollectorClient interface

+ ReportImmediately func(ctx context.Context, in *ReportImmediatelyReq, opts ...grpc.CallOption) (*ReportImmediatelyResp, error)

+ SetReportInterval func(ctx context.Context, in *SetReportIntervalReq, opts ...grpc.CallOption) (*SetReportIntervalResp, error)

+ func NewCollectorClient(cc grpc.ClientConnInterface) CollectorClient

+ type CollectorHTTPClient interface

+ ReportImmediately func(ctx context.Context, req *ReportImmediatelyReq, opts ...http.CallOption) (rsp *ReportImmediatelyResp, err error)

+ SetReportInterval func(ctx context.Context, req *SetReportIntervalReq, opts ...http.CallOption) (rsp *SetReportIntervalResp, err error)

+ func NewCollectorHTTPClient(client *http.Client) CollectorHTTPClient

+ type CollectorHTTPClientImpl struct

+ func (c *CollectorHTTPClientImpl) ReportImmediately(ctx context.Context, in *ReportImmediatelyReq, opts ...http.CallOption) (*ReportImmediatelyResp, error)

+ func (c *CollectorHTTPClientImpl) SetReportInterval(ctx context.Context, in *SetReportIntervalReq, opts ...http.CallOption) (*SetReportIntervalResp, error)

+ type CollectorHTTPServer interface

+ ReportImmediately func(context.Context, *ReportImmediatelyReq) (*ReportImmediatelyResp, error)

+ SetReportInterval func(context.Context, *SetReportIntervalReq) (*SetReportIntervalResp, error)

+ type CollectorServer interface

+ ReportImmediately func(context.Context, *ReportImmediatelyReq) (*ReportImmediatelyResp, error)

+ SetReportInterval func(context.Context, *SetReportIntervalReq) (*SetReportIntervalResp, error)

+ type ReportImmediatelyReq struct

+ Id uint64

+ func (*ReportImmediatelyReq) Descriptor() ([]byte, []int)

+ func (*ReportImmediatelyReq) ProtoMessage()

+ func (x *ReportImmediatelyReq) GetId() uint64

+ func (x *ReportImmediatelyReq) ProtoReflect() protoreflect.Message

+ func (x *ReportImmediatelyReq) Reset()

+ func (x *ReportImmediatelyReq) String() string

+ type ReportImmediatelyResp struct

+ func (*ReportImmediatelyResp) Descriptor() ([]byte, []int)

+ func (*ReportImmediatelyResp) ProtoMessage()

+ func (x *ReportImmediatelyResp) ProtoReflect() protoreflect.Message

+ func (x *ReportImmediatelyResp) Reset()

+ func (x *ReportImmediatelyResp) String() string

+ type SetReportIntervalReq struct

+ Id uint64

+ Interval uint64

+ func (*SetReportIntervalReq) Descriptor() ([]byte, []int)

+ func (*SetReportIntervalReq) ProtoMessage()

+ func (x *SetReportIntervalReq) GetId() uint64

+ func (x *SetReportIntervalReq) GetInterval() uint64

+ func (x *SetReportIntervalReq) ProtoReflect() protoreflect.Message

+ func (x *SetReportIntervalReq) Reset()

+ func (x *SetReportIntervalReq) String() string

+ type SetReportIntervalResp struct

+ func (*SetReportIntervalResp) Descriptor() ([]byte, []int)

+ func (*SetReportIntervalResp) ProtoMessage()

+ func (x *SetReportIntervalResp) ProtoReflect() protoreflect.Message

+ func (x *SetReportIntervalResp) Reset()

+ func (x *SetReportIntervalResp) String() string

+ type UnimplementedCollectorServer struct

+ func (UnimplementedCollectorServer) ReportImmediately(context.Context, *ReportImmediatelyReq) (*ReportImmediatelyResp, error)

+ func (UnimplementedCollectorServer) SetReportInterval(context.Context, *SetReportIntervalReq) (*SetReportIntervalResp, error)

+ type UnsafeCollectorServer interface