di

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2023 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DeviceInteract_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "di.DeviceInteract",
	HandlerType: (*DeviceInteractServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "sendAction",
			Handler:    _DeviceInteract_SendAction_Handler,
		},
		{
			MethodName: "actionRead",
			Handler:    _DeviceInteract_ActionRead_Handler,
		},
		{
			MethodName: "sendProperty",
			Handler:    _DeviceInteract_SendProperty_Handler,
		},
		{
			MethodName: "propertyRead",
			Handler:    _DeviceInteract_PropertyRead_Handler,
		},
		{
			MethodName: "sendMsg",
			Handler:    _DeviceInteract_SendMsg_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/di.proto",
}

DeviceInteract_ServiceDesc is the grpc.ServiceDesc for DeviceInteract service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DeviceMsg_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "di.DeviceMsg",
	HandlerType: (*DeviceMsgServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "sdkLogIndex",
			Handler:    _DeviceMsg_SdkLogIndex_Handler,
		},
		{
			MethodName: "hubLogIndex",
			Handler:    _DeviceMsg_HubLogIndex_Handler,
		},
		{
			MethodName: "propertyLatestIndex",
			Handler:    _DeviceMsg_PropertyLatestIndex_Handler,
		},
		{
			MethodName: "propertyLogIndex",
			Handler:    _DeviceMsg_PropertyLogIndex_Handler,
		},
		{
			MethodName: "eventLogIndex",
			Handler:    _DeviceMsg_EventLogIndex_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/di.proto",
}

DeviceMsg_ServiceDesc is the grpc.ServiceDesc for DeviceMsg service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_proto_di_proto protoreflect.FileDescriptor

Functions

func RegisterDeviceInteractServer 

func RegisterDeviceInteractServer(s grpc.ServiceRegistrar, srv DeviceInteractServer)

func RegisterDeviceMsgServer 

func RegisterDeviceMsgServer(s grpc.ServiceRegistrar, srv DeviceMsgServer)

Types

type DeviceInteractClient 

type DeviceInteractClient interface {
	//调用设备行为
	SendAction(ctx context.Context, in *SendActionReq, opts ...grpc.CallOption) (*SendActionResp, error)
	//获取异步调用设备行为的结果
	ActionRead(ctx context.Context, in *RespReadReq, opts ...grpc.CallOption) (*SendActionResp, error)
	//调用设备属性
	SendProperty(ctx context.Context, in *SendPropertyReq, opts ...grpc.CallOption) (*SendPropertyResp, error)
	//获取异步调用设备属性的结果
	PropertyRead(ctx context.Context, in *RespReadReq, opts ...grpc.CallOption) (*SendPropertyResp, error)
	//发送消息给设备
	SendMsg(ctx context.Context, in *SendMsgReq, opts ...grpc.CallOption) (*SendMsgResp, error)
}

DeviceInteractClient is the client API for DeviceInteract 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 NewDeviceInteractClient 

func NewDeviceInteractClient(cc grpc.ClientConnInterface) DeviceInteractClient

type DeviceInteractServer 

type DeviceInteractServer interface {
	//调用设备行为
	SendAction(context.Context, *SendActionReq) (*SendActionResp, error)
	//获取异步调用设备行为的结果
	ActionRead(context.Context, *RespReadReq) (*SendActionResp, error)
	//调用设备属性
	SendProperty(context.Context, *SendPropertyReq) (*SendPropertyResp, error)
	//获取异步调用设备属性的结果
	PropertyRead(context.Context, *RespReadReq) (*SendPropertyResp, error)
	//发送消息给设备
	SendMsg(context.Context, *SendMsgReq) (*SendMsgResp, error)
	// contains filtered or unexported methods
}

DeviceInteractServer is the server API for DeviceInteract service. All implementations must embed UnimplementedDeviceInteractServer for forward compatibility

type DeviceMsgClient 

type DeviceMsgClient interface {
	//获取设备sdk调试日志
	SdkLogIndex(ctx context.Context, in *SdkLogIndexReq, opts ...grpc.CallOption) (*SdkLogIndexResp, error)
	//获取设备调试信息记录登入登出,操作
	HubLogIndex(ctx context.Context, in *HubLogIndexReq, opts ...grpc.CallOption) (*HubLogIndexResp, error)
	//获取设备数据信息
	PropertyLatestIndex(ctx context.Context, in *PropertyLatestIndexReq, opts ...grpc.CallOption) (*PropertyIndexResp, error)
	//获取设备数据信息
	PropertyLogIndex(ctx context.Context, in *PropertyLogIndexReq, opts ...grpc.CallOption) (*PropertyIndexResp, error)
	//获取设备数据信息
	EventLogIndex(ctx context.Context, in *EventLogIndexReq, opts ...grpc.CallOption) (*EventIndexResp, error)
}

DeviceMsgClient is the client API for DeviceMsg 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 NewDeviceMsgClient 

func NewDeviceMsgClient(cc grpc.ClientConnInterface) DeviceMsgClient

type DeviceMsgServer 

type DeviceMsgServer interface {
	//获取设备sdk调试日志
	SdkLogIndex(context.Context, *SdkLogIndexReq) (*SdkLogIndexResp, error)
	//获取设备调试信息记录登入登出,操作
	HubLogIndex(context.Context, *HubLogIndexReq) (*HubLogIndexResp, error)
	//获取设备数据信息
	PropertyLatestIndex(context.Context, *PropertyLatestIndexReq) (*PropertyIndexResp, error)
	//获取设备数据信息
	PropertyLogIndex(context.Context, *PropertyLogIndexReq) (*PropertyIndexResp, error)
	//获取设备数据信息
	EventLogIndex(context.Context, *EventLogIndexReq) (*EventIndexResp, error)
	// contains filtered or unexported methods
}

DeviceMsgServer is the server API for DeviceMsg service. All implementations must embed UnimplementedDeviceMsgServer for forward compatibility

type EventIndex 

type EventIndex struct {
	Timestamp int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` //发生时间戳(毫秒时间戳)
	Type      string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`            // 事件类型: 信息:info  告警alert  故障:fault
	DataID    string `protobuf:"bytes,3,opt,name=dataID,proto3" json:"dataID,omitempty"`        //属性id
	Params    string `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`        //获取到的值
	// contains filtered or unexported fields
}

设备的日志数据

func (*EventIndex) Descriptor deprecated 

func (*EventIndex) Descriptor() ([]byte, []int)

Deprecated: Use EventIndex.ProtoReflect.Descriptor instead.

func (*EventIndex) GetDataID 

func (x *EventIndex) GetDataID() string

func (*EventIndex) GetParams 

func (x *EventIndex) GetParams() string

func (*EventIndex) GetTimestamp 

func (x *EventIndex) GetTimestamp() int64

func (*EventIndex) GetType 

func (x *EventIndex) GetType() string

func (*EventIndex) ProtoMessage 

func (*EventIndex) ProtoMessage()

func (*EventIndex) ProtoReflect 

func (x *EventIndex) ProtoReflect() protoreflect.Message

func (*EventIndex) Reset 

func (x *EventIndex) Reset()

func (*EventIndex) String 

func (x *EventIndex) String() string

type EventIndexResp 

type EventIndexResp struct {
	Total int64         `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` //总数
	List  []*EventIndex `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

获取对应日志信息

func (*EventIndexResp) Descriptor deprecated 

func (*EventIndexResp) Descriptor() ([]byte, []int)

Deprecated: Use EventIndexResp.ProtoReflect.Descriptor instead.

func (*EventIndexResp) GetList 

func (x *EventIndexResp) GetList() []*EventIndex

func (*EventIndexResp) GetTotal 

func (x *EventIndexResp) GetTotal() int64

func (*EventIndexResp) ProtoMessage 

func (*EventIndexResp) ProtoMessage()

func (*EventIndexResp) ProtoReflect 

func (x *EventIndexResp) ProtoReflect() protoreflect.Message

func (*EventIndexResp) Reset 

func (x *EventIndexResp) Reset()

func (*EventIndexResp) String 

func (x *EventIndexResp) String() string

type EventLogIndexReq 

type EventLogIndexReq struct {
	Page        *PageInfo `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"`               //使用了聚合函数及间隔的时候无效
	ProductID   string    `protobuf:"bytes,2,opt,name=productID,proto3" json:"productID,omitempty"`     //产品id (必填)
	DeviceNames []string  `protobuf:"bytes,3,rep,name=deviceNames,proto3" json:"deviceNames,omitempty"` //设备名(不填获取产品下所有设备)
	DataID      string    `protobuf:"bytes,4,opt,name=dataID,proto3" json:"dataID,omitempty"`           //获取的具体标识符的数据(必填)
	TimeStart   int64     `protobuf:"varint,5,opt,name=timeStart,proto3" json:"timeStart,omitempty"`    //获取时间的开始(毫秒时间戳)
	TimeEnd     int64     `protobuf:"varint,6,opt,name=timeEnd,proto3" json:"timeEnd,omitempty"`        //时间的结束(毫秒时间戳)
	Types       []string  `protobuf:"bytes,7,rep,name=types,proto3" json:"types,omitempty"`             //类型 事件类型: 信息:info  告警alert  故障:fault
	// contains filtered or unexported fields
}

获取对应日志信息

func (*EventLogIndexReq) Descriptor deprecated 

func (*EventLogIndexReq) Descriptor() ([]byte, []int)

Deprecated: Use EventLogIndexReq.ProtoReflect.Descriptor instead.

func (*EventLogIndexReq) GetDataID 

func (x *EventLogIndexReq) GetDataID() string

func (*EventLogIndexReq) GetDeviceNames 

func (x *EventLogIndexReq) GetDeviceNames() []string

func (*EventLogIndexReq) GetPage 

func (x *EventLogIndexReq) GetPage() *PageInfo

func (*EventLogIndexReq) GetProductID 

func (x *EventLogIndexReq) GetProductID() string

func (*EventLogIndexReq) GetTimeEnd 

func (x *EventLogIndexReq) GetTimeEnd() int64

func (*EventLogIndexReq) GetTimeStart 

func (x *EventLogIndexReq) GetTimeStart() int64

func (*EventLogIndexReq) GetTypes 

func (x *EventLogIndexReq) GetTypes() []string

func (*EventLogIndexReq) ProtoMessage 

func (*EventLogIndexReq) ProtoMessage()

func (*EventLogIndexReq) ProtoReflect 

func (x *EventLogIndexReq) ProtoReflect() protoreflect.Message

func (*EventLogIndexReq) Reset 

func (x *EventLogIndexReq) Reset()

func (*EventLogIndexReq) String 

func (x *EventLogIndexReq) String() string

type HubLogIndex 

type HubLogIndex struct {
	Timestamp  int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`   //发生时间戳(毫秒时间戳)
	Action     string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`          //操作类型;connected:上线 disconnected:下线  property:属性 event:事件 action:操作 thing:物模型提交的操作为匹配的日志
	RequestID  string `protobuf:"bytes,3,opt,name=requestID,proto3" json:"requestID,omitempty"`    //请求ID
	TranceID   string `protobuf:"bytes,4,opt,name=tranceID,proto3" json:"tranceID,omitempty"`      //服务器端事务id
	Topic      string `protobuf:"bytes,5,opt,name=topic,proto3" json:"topic,omitempty"`            //主题
	Content    string `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"`        //具体内容
	ResultType int64  `protobuf:"varint,7,opt,name=resultType,proto3" json:"resultType,omitempty"` //请求结果状态
	// contains filtered or unexported fields
}

设备的日志数据

func (*HubLogIndex) Descriptor deprecated 

func (*HubLogIndex) Descriptor() ([]byte, []int)

Deprecated: Use HubLogIndex.ProtoReflect.Descriptor instead.

func (*HubLogIndex) GetAction 

func (x *HubLogIndex) GetAction() string

func (*HubLogIndex) GetContent 

func (x *HubLogIndex) GetContent() string

func (*HubLogIndex) GetRequestID 

func (x *HubLogIndex) GetRequestID() string

func (*HubLogIndex) GetResultType 

func (x *HubLogIndex) GetResultType() int64

func (*HubLogIndex) GetTimestamp 

func (x *HubLogIndex) GetTimestamp() int64

func (*HubLogIndex) GetTopic 

func (x *HubLogIndex) GetTopic() string

func (*HubLogIndex) GetTranceID 

func (x *HubLogIndex) GetTranceID() string

func (*HubLogIndex) ProtoMessage 

func (*HubLogIndex) ProtoMessage()

func (*HubLogIndex) ProtoReflect 

func (x *HubLogIndex) ProtoReflect() protoreflect.Message

func (*HubLogIndex) Reset 

func (x *HubLogIndex) Reset()

func (*HubLogIndex) String 

func (x *HubLogIndex) String() string

type HubLogIndexReq 

type HubLogIndexReq struct {
	ProductID  string    `protobuf:"bytes,1,opt,name=productID,proto3" json:"productID,omitempty"`   //产品id
	DeviceName string    `protobuf:"bytes,2,opt,name=deviceName,proto3" json:"deviceName,omitempty"` //设备名
	TimeStart  int64     `protobuf:"varint,3,opt,name=timeStart,proto3" json:"timeStart,omitempty"`  //获取时间的开始(毫秒时间戳)
	TimeEnd    int64     `protobuf:"varint,4,opt,name=timeEnd,proto3" json:"timeEnd,omitempty"`      //时间的结束(毫秒时间戳)
	Page       *PageInfo `protobuf:"bytes,5,opt,name=page,proto3" json:"page,omitempty"`             //分页信息
	Actions    []string  `protobuf:"bytes,6,rep,name=actions,proto3" json:"actions,omitempty"`       //过滤操作类型 connected:上线 disconnected:下线  property:属性 event:事件 action:操作 thing:物模型提交的操作为匹配的日志
	Topics     []string  `protobuf:"bytes,7,rep,name=topics,proto3" json:"topics,omitempty"`         //过滤主题
	Content    string    `protobuf:"bytes,8,opt,name=content,proto3" json:"content,omitempty"`       //过滤内容
	RequestID  string    `protobuf:"bytes,9,opt,name=requestID,proto3" json:"requestID,omitempty"`   //过滤请求ID
	// contains filtered or unexported fields
}

实时获取对应信息

func (*HubLogIndexReq) Descriptor deprecated 

func (*HubLogIndexReq) Descriptor() ([]byte, []int)

Deprecated: Use HubLogIndexReq.ProtoReflect.Descriptor instead.

func (*HubLogIndexReq) GetActions 

func (x *HubLogIndexReq) GetActions() []string

func (*HubLogIndexReq) GetContent 

func (x *HubLogIndexReq) GetContent() string

func (*HubLogIndexReq) GetDeviceName 

func (x *HubLogIndexReq) GetDeviceName() string

func (*HubLogIndexReq) GetPage 

func (x *HubLogIndexReq) GetPage() *PageInfo

func (*HubLogIndexReq) GetProductID 

func (x *HubLogIndexReq) GetProductID() string

func (*HubLogIndexReq) GetRequestID 

func (x *HubLogIndexReq) GetRequestID() string

func (*HubLogIndexReq) GetTimeEnd 

func (x *HubLogIndexReq) GetTimeEnd() int64

func (*HubLogIndexReq) GetTimeStart 

func (x *HubLogIndexReq) GetTimeStart() int64

func (*HubLogIndexReq) GetTopics 

func (x *HubLogIndexReq) GetTopics() []string

func (*HubLogIndexReq) ProtoMessage 

func (*HubLogIndexReq) ProtoMessage()

func (*HubLogIndexReq) ProtoReflect 

func (x *HubLogIndexReq) ProtoReflect() protoreflect.Message

func (*HubLogIndexReq) Reset 

func (x *HubLogIndexReq) Reset()

func (*HubLogIndexReq) String 

func (x *HubLogIndexReq) String() string

type HubLogIndexResp 

type HubLogIndexResp struct {
	Total int64          `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` //总数
	List  []*HubLogIndex `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

实时获取对应信息

func (*HubLogIndexResp) Descriptor deprecated 

func (*HubLogIndexResp) Descriptor() ([]byte, []int)

Deprecated: Use HubLogIndexResp.ProtoReflect.Descriptor instead.

func (*HubLogIndexResp) GetList 

func (x *HubLogIndexResp) GetList() []*HubLogIndex

func (*HubLogIndexResp) GetTotal 

func (x *HubLogIndexResp) GetTotal() int64

func (*HubLogIndexResp) ProtoMessage 

func (*HubLogIndexResp) ProtoMessage()

func (*HubLogIndexResp) ProtoReflect 

func (x *HubLogIndexResp) ProtoReflect() protoreflect.Message

func (*HubLogIndexResp) Reset 

func (x *HubLogIndexResp) Reset()

func (*HubLogIndexResp) String 

func (x *HubLogIndexResp) String() string

type PageInfo 

type PageInfo struct {
	Page int64 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*PageInfo) Descriptor deprecated 

func (*PageInfo) Descriptor() ([]byte, []int)

Deprecated: Use PageInfo.ProtoReflect.Descriptor instead.

func (*PageInfo) GetPage 

func (x *PageInfo) GetPage() int64

func (*PageInfo) GetSize 

func (x *PageInfo) GetSize() int64

func (*PageInfo) ProtoMessage 

func (*PageInfo) ProtoMessage()

func (*PageInfo) ProtoReflect 

func (x *PageInfo) ProtoReflect() protoreflect.Message

func (*PageInfo) Reset 

func (x *PageInfo) Reset()

func (*PageInfo) String 

func (x *PageInfo) String() string

type PropertyIndex 

type PropertyIndex struct {
	Timestamp int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` //发生时间戳(毫秒时间戳)
	DataID    string `protobuf:"bytes,3,opt,name=dataID,proto3" json:"dataID,omitempty"`        //属性id
	Value     string `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`          //获取到的值
	// contains filtered or unexported fields
}

设备的日志数据

func (*PropertyIndex) Descriptor deprecated 

func (*PropertyIndex) Descriptor() ([]byte, []int)

Deprecated: Use PropertyIndex.ProtoReflect.Descriptor instead.

func (*PropertyIndex) GetDataID 

func (x *PropertyIndex) GetDataID() string

func (*PropertyIndex) GetTimestamp 

func (x *PropertyIndex) GetTimestamp() int64

func (*PropertyIndex) GetValue 

func (x *PropertyIndex) GetValue() string

func (*PropertyIndex) ProtoMessage 

func (*PropertyIndex) ProtoMessage()

func (*PropertyIndex) ProtoReflect 

func (x *PropertyIndex) ProtoReflect() protoreflect.Message

func (*PropertyIndex) Reset 

func (x *PropertyIndex) Reset()

func (*PropertyIndex) String 

func (x *PropertyIndex) String() string

type PropertyIndexResp 

type PropertyIndexResp struct {
	Total int64            `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` //总数
	List  []*PropertyIndex `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

获取对应日志信息

func (*PropertyIndexResp) Descriptor deprecated 

func (*PropertyIndexResp) Descriptor() ([]byte, []int)

Deprecated: Use PropertyIndexResp.ProtoReflect.Descriptor instead.

func (*PropertyIndexResp) GetList 

func (x *PropertyIndexResp) GetList() []*PropertyIndex

func (*PropertyIndexResp) GetTotal 

func (x *PropertyIndexResp) GetTotal() int64

func (*PropertyIndexResp) ProtoMessage 

func (*PropertyIndexResp) ProtoMessage()

func (*PropertyIndexResp) ProtoReflect 

func (x *PropertyIndexResp) ProtoReflect() protoreflect.Message

func (*PropertyIndexResp) Reset 

func (x *PropertyIndexResp) Reset()

func (*PropertyIndexResp) String 

func (x *PropertyIndexResp) String() string

type PropertyLatestIndexReq 

type PropertyLatestIndexReq struct {
	DeviceName string   `protobuf:"bytes,1,opt,name=deviceName,proto3" json:"deviceName,omitempty"` //设备名(必填)
	ProductID  string   `protobuf:"bytes,2,opt,name=productID,proto3" json:"productID,omitempty"`   //产品id (必填)
	DataIDs    []string `protobuf:"bytes,3,rep,name=dataIDs,proto3" json:"dataIDs,omitempty"`       //获取的具体标识符的数据 如果不指定则获取所有属性数据,一个属性一条,如果没有获取到的不会返回值
	// contains filtered or unexported fields
}

获取对应日志信息

func (*PropertyLatestIndexReq) Descriptor deprecated 

func (*PropertyLatestIndexReq) Descriptor() ([]byte, []int)

Deprecated: Use PropertyLatestIndexReq.ProtoReflect.Descriptor instead.

func (*PropertyLatestIndexReq) GetDataIDs 

func (x *PropertyLatestIndexReq) GetDataIDs() []string

func (*PropertyLatestIndexReq) GetDeviceName 

func (x *PropertyLatestIndexReq) GetDeviceName() string

func (*PropertyLatestIndexReq) GetProductID 

func (x *PropertyLatestIndexReq) GetProductID() string

func (*PropertyLatestIndexReq) ProtoMessage 

func (*PropertyLatestIndexReq) ProtoMessage()

func (*PropertyLatestIndexReq) ProtoReflect 

func (x *PropertyLatestIndexReq) ProtoReflect() protoreflect.Message

func (*PropertyLatestIndexReq) Reset 

func (x *PropertyLatestIndexReq) Reset()

func (*PropertyLatestIndexReq) String 

func (x *PropertyLatestIndexReq) String() string

type PropertyLogIndexReq 

type PropertyLogIndexReq struct {
	Page        *PageInfo `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"`               //使用了聚合函数及间隔的时候无效
	DeviceNames []string  `protobuf:"bytes,3,rep,name=deviceNames,proto3" json:"deviceNames,omitempty"` //设备名(不填获取产品下所有设备)
	ProductID   string    `protobuf:"bytes,4,opt,name=productID,proto3" json:"productID,omitempty"`     //产品id (必填)
	DataID      string    `protobuf:"bytes,5,opt,name=dataID,proto3" json:"dataID,omitempty"`           //获取的具体标识符的数据(必填)
	TimeStart   int64     `protobuf:"varint,6,opt,name=timeStart,proto3" json:"timeStart,omitempty"`    //获取时间的开始(毫秒时间戳)
	TimeEnd     int64     `protobuf:"varint,7,opt,name=timeEnd,proto3" json:"timeEnd,omitempty"`        //时间的结束(毫秒时间戳)
	Interval    int64     `protobuf:"varint,8,opt,name=interval,proto3" json:"interval,omitempty"`      //间隔(单位毫秒) 如果这个值不为零值 则时间的开始和结束必须有效及聚合函数不应该为空
	ArgFunc     string    `protobuf:"bytes,9,opt,name=argFunc,proto3" json:"argFunc,omitempty"`         //聚合函数 avg:平均值 first:第一个参数 last:最后一个参数 count:总数 twa: 时间加权平均函数 参考:https://docs.taosdata.com/taos-sql/function
	//  /*
	//  FILL 语句指定某一窗口区间数据缺失的情况下的填充模式。填充模式包括以下几种：
	//    不进行填充：NONE（默认填充模式）。
	//    VALUE 填充：固定值填充，此时需要指定填充的数值。例如：FILL(VALUE, 1.23)。
	//    PREV 填充：使用前一个非 NULL 值填充数据。例如：FILL(PREV)。
	//    NULL 填充：使用 NULL 填充数据。例如：FILL(NULL)。
	//    LINEAR 填充：根据前后距离最近的非 NULL 值做线性插值填充。例如：FILL(LINEAR)。
	//    NEXT 填充：使用下一个非 NULL 值填充数据。例如：FILL(NEXT)。
	//  */
	Fill  string `protobuf:"bytes,10,opt,name=fill,proto3" json:"fill,omitempty"`    //填充模式 参考:https://docs.taosdata.com/taos-sql/distinguished/
	Order int32  `protobuf:"varint,11,opt,name=order,proto3" json:"order,omitempty"` //时间排序 0:aes(默认,从久到近排序) 1:desc(时间从近到久排序)
	// contains filtered or unexported fields
}

获取对应日志信息

func (*PropertyLogIndexReq) Descriptor deprecated 

func (*PropertyLogIndexReq) Descriptor() ([]byte, []int)

Deprecated: Use PropertyLogIndexReq.ProtoReflect.Descriptor instead.

func (*PropertyLogIndexReq) GetArgFunc 

func (x *PropertyLogIndexReq) GetArgFunc() string

func (*PropertyLogIndexReq) GetDataID 

func (x *PropertyLogIndexReq) GetDataID() string

func (*PropertyLogIndexReq) GetDeviceNames 

func (x *PropertyLogIndexReq) GetDeviceNames() []string

func (*PropertyLogIndexReq) GetFill 

func (x *PropertyLogIndexReq) GetFill() string

func (*PropertyLogIndexReq) GetInterval 

func (x *PropertyLogIndexReq) GetInterval() int64

func (*PropertyLogIndexReq) GetOrder 

func (x *PropertyLogIndexReq) GetOrder() int32

func (*PropertyLogIndexReq) GetPage 

func (x *PropertyLogIndexReq) GetPage() *PageInfo

func (*PropertyLogIndexReq) GetProductID 

func (x *PropertyLogIndexReq) GetProductID() string

func (*PropertyLogIndexReq) GetTimeEnd 

func (x *PropertyLogIndexReq) GetTimeEnd() int64

func (*PropertyLogIndexReq) GetTimeStart 

func (x *PropertyLogIndexReq) GetTimeStart() int64

func (*PropertyLogIndexReq) ProtoMessage 

func (*PropertyLogIndexReq) ProtoMessage()

func (*PropertyLogIndexReq) ProtoReflect 

func (x *PropertyLogIndexReq) ProtoReflect() protoreflect.Message

func (*PropertyLogIndexReq) Reset 

func (x *PropertyLogIndexReq) Reset()

func (*PropertyLogIndexReq) String 

func (x *PropertyLogIndexReq) String() string

type RespReadReq added in v0.4.1 

type RespReadReq struct {
	ProductID   string `protobuf:"bytes,1,opt,name=productID,proto3" json:"productID,omitempty"`     //产品id
	DeviceName  string `protobuf:"bytes,2,opt,name=deviceName,proto3" json:"deviceName,omitempty"`   //设备名
	ClientToken string `protobuf:"bytes,3,opt,name=clientToken,proto3" json:"clientToken,omitempty"` //调用id
	// contains filtered or unexported fields
}

获取异步消息的请求

func (*RespReadReq) Descriptor deprecated added in v0.4.1 

func (*RespReadReq) Descriptor() ([]byte, []int)

Deprecated: Use RespReadReq.ProtoReflect.Descriptor instead.

func (*RespReadReq) GetClientToken added in v0.4.1 

func (x *RespReadReq) GetClientToken() string

func (*RespReadReq) GetDeviceName added in v0.4.1 

func (x *RespReadReq) GetDeviceName() string

func (*RespReadReq) GetProductID added in v0.4.1 

func (x *RespReadReq) GetProductID() string

func (*RespReadReq) ProtoMessage added in v0.4.1 

func (*RespReadReq) ProtoMessage()

func (*RespReadReq) ProtoReflect added in v0.4.1 

func (x *RespReadReq) ProtoReflect() protoreflect.Message

func (*RespReadReq) Reset added in v0.4.1 

func (x *RespReadReq) Reset()

func (*RespReadReq) String added in v0.4.1 

func (x *RespReadReq) String() string

type Response 

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

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type SdkLogIndex 

type SdkLogIndex struct {
	Timestamp int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` //发生时间戳(毫秒时间戳)
	Loglevel  int64  `protobuf:"varint,2,opt,name=loglevel,proto3" json:"loglevel,omitempty"`   //操作类型;显示相应的操作名称、API名称、服务的method
	Content   string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`      //具体内容
	// contains filtered or unexported fields
}

func (*SdkLogIndex) Descriptor deprecated 

func (*SdkLogIndex) Descriptor() ([]byte, []int)

Deprecated: Use SdkLogIndex.ProtoReflect.Descriptor instead.

func (*SdkLogIndex) GetContent 

func (x *SdkLogIndex) GetContent() string

func (*SdkLogIndex) GetLoglevel 

func (x *SdkLogIndex) GetLoglevel() int64

func (*SdkLogIndex) GetTimestamp 

func (x *SdkLogIndex) GetTimestamp() int64

func (*SdkLogIndex) ProtoMessage 

func (*SdkLogIndex) ProtoMessage()

func (*SdkLogIndex) ProtoReflect 

func (x *SdkLogIndex) ProtoReflect() protoreflect.Message

func (*SdkLogIndex) Reset 

func (x *SdkLogIndex) Reset()

func (*SdkLogIndex) String 

func (x *SdkLogIndex) String() string

type SdkLogIndexReq 

type SdkLogIndexReq struct {
	ProductID  string    `protobuf:"bytes,1,opt,name=productID,proto3" json:"productID,omitempty"`   //产品id
	DeviceName string    `protobuf:"bytes,2,opt,name=deviceName,proto3" json:"deviceName,omitempty"` //设备名
	TimeStart  int64     `protobuf:"varint,3,opt,name=timeStart,proto3" json:"timeStart,omitempty"`  //获取时间的开始
	TimeEnd    int64     `protobuf:"varint,4,opt,name=timeEnd,proto3" json:"timeEnd,omitempty"`      //时间的结束
	LogLevel   int64     `protobuf:"varint,5,opt,name=logLevel,proto3" json:"logLevel,omitempty"`    //日志等级
	Page       *PageInfo `protobuf:"bytes,6,opt,name=page,proto3" json:"page,omitempty"`             //分页信息 只获取一个则不填
	// contains filtered or unexported fields
}

获取sdk调试日志信息

func (*SdkLogIndexReq) Descriptor deprecated 

func (*SdkLogIndexReq) Descriptor() ([]byte, []int)

Deprecated: Use SdkLogIndexReq.ProtoReflect.Descriptor instead.

func (*SdkLogIndexReq) GetDeviceName 

func (x *SdkLogIndexReq) GetDeviceName() string

func (*SdkLogIndexReq) GetLogLevel added in v0.3.0 

func (x *SdkLogIndexReq) GetLogLevel() int64

func (*SdkLogIndexReq) GetPage 

func (x *SdkLogIndexReq) GetPage() *PageInfo

func (*SdkLogIndexReq) GetProductID 

func (x *SdkLogIndexReq) GetProductID() string

func (*SdkLogIndexReq) GetTimeEnd 

func (x *SdkLogIndexReq) GetTimeEnd() int64

func (*SdkLogIndexReq) GetTimeStart 

func (x *SdkLogIndexReq) GetTimeStart() int64

func (*SdkLogIndexReq) ProtoMessage 

func (*SdkLogIndexReq) ProtoMessage()

func (*SdkLogIndexReq) ProtoReflect 

func (x *SdkLogIndexReq) ProtoReflect() protoreflect.Message

func (*SdkLogIndexReq) Reset 

func (x *SdkLogIndexReq) Reset()

func (*SdkLogIndexReq) String 

func (x *SdkLogIndexReq) String() string

type SdkLogIndexResp 

type SdkLogIndexResp struct {
	Total int64          `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` //总数
	List  []*SdkLogIndex `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

sdk调试日志信息

func (*SdkLogIndexResp) Descriptor deprecated 

func (*SdkLogIndexResp) Descriptor() ([]byte, []int)

Deprecated: Use SdkLogIndexResp.ProtoReflect.Descriptor instead.

func (*SdkLogIndexResp) GetList 

func (x *SdkLogIndexResp) GetList() []*SdkLogIndex

func (*SdkLogIndexResp) GetTotal 

func (x *SdkLogIndexResp) GetTotal() int64

func (*SdkLogIndexResp) ProtoMessage 

func (*SdkLogIndexResp) ProtoMessage()

func (*SdkLogIndexResp) ProtoReflect 

func (x *SdkLogIndexResp) ProtoReflect() protoreflect.Message

func (*SdkLogIndexResp) Reset 

func (x *SdkLogIndexResp) Reset()

func (*SdkLogIndexResp) String 

func (x *SdkLogIndexResp) String() string

type SendActionReq 

type SendActionReq struct {
	ProductID   string `protobuf:"bytes,1,opt,name=productID,proto3" json:"productID,omitempty"`     //产品id 获取产品id下的所有设备信息
	DeviceName  string `protobuf:"bytes,2,opt,name=deviceName,proto3" json:"deviceName,omitempty"`   //设备名
	ActionID    string `protobuf:"bytes,3,opt,name=actionID,proto3" json:"actionID,omitempty"`       //产品数据模板中行为功能的标识符，由开发者自行根据设备的应用场景定义
	InputParams string `protobuf:"bytes,4,opt,name=inputParams,proto3" json:"inputParams,omitempty"` //输入参数
	IsAsync     bool   `protobuf:"varint,5,opt,name=isAsync,proto3" json:"isAsync,omitempty"`        //是否异步获取
	// contains filtered or unexported fields
}

func (*SendActionReq) Descriptor deprecated 

func (*SendActionReq) Descriptor() ([]byte, []int)

Deprecated: Use SendActionReq.ProtoReflect.Descriptor instead.

func (*SendActionReq) GetActionID 

func (x *SendActionReq) GetActionID() string

func (*SendActionReq) GetDeviceName 

func (x *SendActionReq) GetDeviceName() string

func (*SendActionReq) GetInputParams 

func (x *SendActionReq) GetInputParams() string

func (*SendActionReq) GetIsAsync added in v0.4.1 

func (x *SendActionReq) GetIsAsync() bool

func (*SendActionReq) GetProductID 

func (x *SendActionReq) GetProductID() string

func (*SendActionReq) ProtoMessage 

func (*SendActionReq) ProtoMessage()

func (*SendActionReq) ProtoReflect 

func (x *SendActionReq) ProtoReflect() protoreflect.Message

func (*SendActionReq) Reset 

func (x *SendActionReq) Reset()

func (*SendActionReq) String 

func (x *SendActionReq) String() string

type SendActionResp 

type SendActionResp struct {
	ClientToken  string `protobuf:"bytes,1,opt,name=clientToken,proto3" json:"clientToken,omitempty"`   //调用id
	OutputParams string `protobuf:"bytes,2,opt,name=outputParams,proto3" json:"outputParams,omitempty"` //输出参数 注意：此字段可能返回 null，表示取不到有效值。
	Status       string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`             //返回状态
	Code         int64  `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`                //设备返回状态码
	// contains filtered or unexported fields
}

func (*SendActionResp) Descriptor deprecated 

func (*SendActionResp) Descriptor() ([]byte, []int)

Deprecated: Use SendActionResp.ProtoReflect.Descriptor instead.

func (*SendActionResp) GetClientToken 

func (x *SendActionResp) GetClientToken() string

func (*SendActionResp) GetCode 

func (x *SendActionResp) GetCode() int64

func (*SendActionResp) GetOutputParams 

func (x *SendActionResp) GetOutputParams() string

func (*SendActionResp) GetStatus 

func (x *SendActionResp) GetStatus() string

func (*SendActionResp) ProtoMessage 

func (*SendActionResp) ProtoMessage()

func (*SendActionResp) ProtoReflect 

func (x *SendActionResp) ProtoReflect() protoreflect.Message

func (*SendActionResp) Reset 

func (x *SendActionResp) Reset()

func (*SendActionResp) String 

func (x *SendActionResp) String() string

type SendMsgReq 

type SendMsgReq struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`     //发送的topic
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` //发送的数据
	// contains filtered or unexported fields
}

func (*SendMsgReq) Descriptor deprecated 

func (*SendMsgReq) Descriptor() ([]byte, []int)

Deprecated: Use SendMsgReq.ProtoReflect.Descriptor instead.

func (*SendMsgReq) GetPayload 

func (x *SendMsgReq) GetPayload() []byte

func (*SendMsgReq) GetTopic 

func (x *SendMsgReq) GetTopic() string

func (*SendMsgReq) ProtoMessage 

func (*SendMsgReq) ProtoMessage()

func (*SendMsgReq) ProtoReflect 

func (x *SendMsgReq) ProtoReflect() protoreflect.Message

func (*SendMsgReq) Reset 

func (x *SendMsgReq) Reset()

func (*SendMsgReq) String 

func (x *SendMsgReq) String() string

type SendMsgResp 

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

func (*SendMsgResp) Descriptor deprecated 

func (*SendMsgResp) Descriptor() ([]byte, []int)

Deprecated: Use SendMsgResp.ProtoReflect.Descriptor instead.

func (*SendMsgResp) ProtoMessage 

func (*SendMsgResp) ProtoMessage()

func (*SendMsgResp) ProtoReflect 

func (x *SendMsgResp) ProtoReflect() protoreflect.Message

func (*SendMsgResp) Reset 

func (x *SendMsgResp) Reset()

func (*SendMsgResp) String 

func (x *SendMsgResp) String() string

type SendPropertyReq 

type SendPropertyReq struct {
	ProductID  string `protobuf:"bytes,1,opt,name=productID,proto3" json:"productID,omitempty"`   //产品id
	DeviceName string `protobuf:"bytes,2,opt,name=deviceName,proto3" json:"deviceName,omitempty"` //设备名
	Data       string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`             //属性数据, JSON格式字符串, 注意字段需要在物模型属性里定义
	IsAsync    bool   `protobuf:"varint,6,opt,name=isAsync,proto3" json:"isAsync,omitempty"`      //是否异步操作 异步情况通过获取接口来获取
	// contains filtered or unexported fields
}

func (*SendPropertyReq) Descriptor deprecated 

func (*SendPropertyReq) Descriptor() ([]byte, []int)

Deprecated: Use SendPropertyReq.ProtoReflect.Descriptor instead.

func (*SendPropertyReq) GetData 

func (x *SendPropertyReq) GetData() string

func (*SendPropertyReq) GetDeviceName 

func (x *SendPropertyReq) GetDeviceName() string

func (*SendPropertyReq) GetIsAsync added in v0.4.1 

func (x *SendPropertyReq) GetIsAsync() bool

func (*SendPropertyReq) GetProductID 

func (x *SendPropertyReq) GetProductID() string

func (*SendPropertyReq) ProtoMessage 

func (*SendPropertyReq) ProtoMessage()

func (*SendPropertyReq) ProtoReflect 

func (x *SendPropertyReq) ProtoReflect() protoreflect.Message

func (*SendPropertyReq) Reset 

func (x *SendPropertyReq) Reset()

func (*SendPropertyReq) String 

func (x *SendPropertyReq) String() string

type SendPropertyResp 

type SendPropertyResp struct {
	Code        int64  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`              //设备返回状态码
	Status      string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`           //返回状态
	ClientToken string `protobuf:"bytes,3,opt,name=clientToken,proto3" json:"clientToken,omitempty"` //调用id
	Data        string `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`               //返回信息
	// contains filtered or unexported fields
}

func (*SendPropertyResp) Descriptor deprecated 

func (*SendPropertyResp) Descriptor() ([]byte, []int)

Deprecated: Use SendPropertyResp.ProtoReflect.Descriptor instead.

func (*SendPropertyResp) GetClientToken 

func (x *SendPropertyResp) GetClientToken() string

func (*SendPropertyResp) GetCode 

func (x *SendPropertyResp) GetCode() int64

func (*SendPropertyResp) GetData 

func (x *SendPropertyResp) GetData() string

func (*SendPropertyResp) GetStatus 

func (x *SendPropertyResp) GetStatus() string

func (*SendPropertyResp) ProtoMessage 

func (*SendPropertyResp) ProtoMessage()

func (*SendPropertyResp) ProtoReflect 

func (x *SendPropertyResp) ProtoReflect() protoreflect.Message

func (*SendPropertyResp) Reset 

func (x *SendPropertyResp) Reset()

func (*SendPropertyResp) String 

func (x *SendPropertyResp) String() string

type UnimplementedDeviceInteractServer 

type UnimplementedDeviceInteractServer struct {
}

UnimplementedDeviceInteractServer must be embedded to have forward compatible implementations.

func (UnimplementedDeviceInteractServer) ActionRead added in v0.4.1 

func (UnimplementedDeviceInteractServer) ActionRead(context.Context, *RespReadReq) (*SendActionResp, error)

func (UnimplementedDeviceInteractServer) PropertyRead added in v0.4.1 

func (UnimplementedDeviceInteractServer) PropertyRead(context.Context, *RespReadReq) (*SendPropertyResp, error)

func (UnimplementedDeviceInteractServer) SendAction 

func (UnimplementedDeviceInteractServer) SendAction(context.Context, *SendActionReq) (*SendActionResp, error)

func (UnimplementedDeviceInteractServer) SendMsg 

func (UnimplementedDeviceInteractServer) SendMsg(context.Context, *SendMsgReq) (*SendMsgResp, error)

func (UnimplementedDeviceInteractServer) SendProperty 

func (UnimplementedDeviceInteractServer) SendProperty(context.Context, *SendPropertyReq) (*SendPropertyResp, error)

type UnimplementedDeviceMsgServer 

type UnimplementedDeviceMsgServer struct {
}

UnimplementedDeviceMsgServer must be embedded to have forward compatible implementations.

func (UnimplementedDeviceMsgServer) EventLogIndex 

func (UnimplementedDeviceMsgServer) EventLogIndex(context.Context, *EventLogIndexReq) (*EventIndexResp, error)

func (UnimplementedDeviceMsgServer) HubLogIndex 

func (UnimplementedDeviceMsgServer) HubLogIndex(context.Context, *HubLogIndexReq) (*HubLogIndexResp, error)

func (UnimplementedDeviceMsgServer) PropertyLatestIndex 

func (UnimplementedDeviceMsgServer) PropertyLatestIndex(context.Context, *PropertyLatestIndexReq) (*PropertyIndexResp, error)

func (UnimplementedDeviceMsgServer) PropertyLogIndex 

func (UnimplementedDeviceMsgServer) PropertyLogIndex(context.Context, *PropertyLogIndexReq) (*PropertyIndexResp, error)

func (UnimplementedDeviceMsgServer) SdkLogIndex 

func (UnimplementedDeviceMsgServer) SdkLogIndex(context.Context, *SdkLogIndexReq) (*SdkLogIndexResp, error)

type UnsafeDeviceInteractServer 

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

UnsafeDeviceInteractServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeviceInteractServer will result in compilation errors.

type UnsafeDeviceMsgServer 

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

UnsafeDeviceMsgServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeviceMsgServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.