collector

type CollectorClient interface {
	ReportImmediately(ctx context.Context, in *ReportImmediatelyReq, opts ...grpc.CallOption) (*ReportImmediatelyResp, error)
	SetReportInterval(ctx context.Context, in *SetReportIntervalReq, opts ...grpc.CallOption) (*SetReportIntervalResp, error)
	GetDeviceStreamLog(ctx context.Context, in *GetDeviceStreamLogReq, opts ...grpc.CallOption) (Collector_GetDeviceStreamLogClient, error)
}

type CollectorHTTPClient interface {
	ReportImmediately(ctx context.Context, req *ReportImmediatelyReq, opts ...http.CallOption) (rsp *ReportImmediatelyResp, err error)
	SetReportInterval(ctx context.Context, req *SetReportIntervalReq, opts ...http.CallOption) (rsp *SetReportIntervalResp, err error)
}

type CollectorHTTPClientImpl struct {
	// contains filtered or unexported fields
}

type CollectorHTTPServer interface {
	ReportImmediately(context.Context, *ReportImmediatelyReq) (*ReportImmediatelyResp, error)
	SetReportInterval(context.Context, *SetReportIntervalReq) (*SetReportIntervalResp, error)
}

type CollectorServer interface {
	ReportImmediately(context.Context, *ReportImmediatelyReq) (*ReportImmediatelyResp, error)
	SetReportInterval(context.Context, *SetReportIntervalReq) (*SetReportIntervalResp, error)
	GetDeviceStreamLog(*GetDeviceStreamLogReq, Collector_GetDeviceStreamLogServer) error
	// contains filtered or unexported methods
}

type Collector_GetDeviceStreamLogClient interface {
	Recv() (*GetDeviceStreamLogResp, error)
	grpc.ClientStream
}

type Collector_GetDeviceStreamLogServer interface {
	Send(*GetDeviceStreamLogResp) error
	grpc.ServerStream
}

type GetDeviceStreamLogReq struct {
	Id          uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" form:"id" binding:"required"`                // @gotags: form:"id" binding:"required"
	LevelFilter string `protobuf:"bytes,2,opt,name=level_filter,json=levelFilter,proto3" json:"levelFilter" form:"levelFilter"` // @gotags: form:"levelFilter" json:"levelFilter"
	// contains filtered or unexported fields
}

type GetDeviceStreamLogResp struct {
	Level     uint32 `protobuf:"varint,1,opt,name=level,proto3" json:"level"`         // @gotags: json:"level"
	Message   string `protobuf:"bytes,2,opt,name=message,proto3" json:"message"`      // @gotags: json:"message"
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp"` // @gotags: json:"timestamp"
	// contains filtered or unexported fields
}

type ReportImmediatelyReq struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type ReportImmediatelyResp struct {
	// contains filtered or unexported fields
}

type SetReportIntervalReq struct {
	Id       uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Interval uint64 `protobuf:"varint,2,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

type SetReportIntervalResp struct {
	// contains filtered or unexported fields
}

type UnimplementedCollectorServer struct {
}

type UnsafeCollectorServer interface {
	// contains filtered or unexported methods
}