options

Documentation

Index

• type AMQPOptions
• type DeviceInfo
  • func (deviceInfo *DeviceInfo) GenerateRequest(serviceId string, params interface{}) (req *iot.InvokeThingServiceRequest, err error)
  • func (deviceInfo *DeviceInfo) GenerateSubscribeTopicRequest(topic []string) (req *iot.SubscribeTopicRequest, err error)
  • func (deviceInfo *DeviceInfo) GenerateSyncRequest(payload *ServiceSyncRequestPayload) (req *iot.RRpcRequest, err error)
• type ServiceInvokerOptions
• type ServiceSyncRequestPayload
  • func NewServiceSyncRequestPayload(method string, params interface{}) *ServiceSyncRequestPayload
  • func NewServiceSyncRequestPayloadByIdentifier(serviceId string, params interface{}) *ServiceSyncRequestPayload
  • func (rp *ServiceSyncRequestPayload) Serialize() ([]byte, error)
  • func (rp *ServiceSyncRequestPayload) SerializeBase64() (string, error)
• type ServiceSyncResponse
  • func NewServiceResponseByBase64(base64Payload string) (*ServiceSyncResponse, error)

Types

type AMQPOptions

type AMQPOptions struct {
	Host            string `json:"host"`            // 服务终端节点
	Port            int    `json:"port"`            // 服务终端端口
	InstanceID      string `json:"instanceId"`      // IoT 服务实例标识
	ClientID        string `json:"clientId"`        // 客户端标识
	ConsumerGroupID string `json:"consumerGroupId"` // 消费组标识
	AccessKeyID     string `json:"accessKeyId"`     // 密钥 ID
	AccessKeySecret string `json:"accessKeySecret"` // 密钥
}

AMQPOptions AMQP 服务连接设置

type DeviceInfo

type DeviceInfo struct {
	IotInstanceID string `json:"iotInstanceId"` // 服务实例标识
	ProductKey    string `json:"productKey"`    // 产品标识
	DeviceName    string `json:"deviceName"`    // 设备标识
}

DeviceInfo IoT 设备信息

func (*DeviceInfo) GenerateRequest

func (deviceInfo *DeviceInfo) GenerateRequest(serviceId string, params interface{}) (req *iot.InvokeThingServiceRequest, err error)

GenerateRequest 生成服务的调用请求（异步）

func (*DeviceInfo) GenerateSubscribeTopicRequest

func (deviceInfo *DeviceInfo) GenerateSubscribeTopicRequest(topic []string) (req *iot.SubscribeTopicRequest, err error)

func (*DeviceInfo) GenerateSyncRequest

func (deviceInfo *DeviceInfo) GenerateSyncRequest(payload *ServiceSyncRequestPayload) (req *iot.RRpcRequest, err error)

GenerateSyncRequest 生成服务同步调用请求

type ServiceInvokerOptions

type ServiceInvokerOptions struct {
	RegionID        string // IoT 平台服务地域标识，详情参考 https://help.aliyun.com/document_detail/40654.htm
	AccessKeyID     string // IoT 平台服务访问密钥标识
	AccessKeySecret string // IoT 平台服务访问密钥
}

ServiceInvokerOptions 服务调用者设置

type ServiceSyncRequestPayload

type ServiceSyncRequestPayload struct {
	ID      string      `json:"id"`      // 调用标识
	Version string      `json:"version"` // 协议版本，固定为 "1.0"
	Params  interface{} `json:"params"`  // 输入参数
	Method  string      `json:"method"`  // 服务标识，格式如：thing.service.<serviceId>
}

ServiceSyncRequestPayload 服务调用载荷

func NewServiceSyncRequestPayload

func NewServiceSyncRequestPayload(method string, params interface{}) *ServiceSyncRequestPayload

NewServiceSyncRequestPayload 创建新的服务同步调用载荷

func NewServiceSyncRequestPayloadByIdentifier

func NewServiceSyncRequestPayloadByIdentifier(serviceId string, params interface{}) *ServiceSyncRequestPayload

NewServiceSyncRequestPayloadByIdentifier 使用服务标识创建服务同步调用载荷

func (*ServiceSyncRequestPayload) Serialize

func (rp *ServiceSyncRequestPayload) Serialize() ([]byte, error)

Serialize 序列化服务同步调用载荷

func (*ServiceSyncRequestPayload) SerializeBase64

func (rp *ServiceSyncRequestPayload) SerializeBase64() (string, error)

SerializeBase64 将同步调用载荷序列化为 Base64 字符串

type ServiceSyncResponse

type ServiceSyncResponse struct {
	ID   string      `json:"id"`             // 响应标识
	Code int         `json:"code"`           // 响应状态标识，详情参考 https://help.aliyun.com/document_detail/89309.htm
	Data interface{} `json:"data,omitempty"` // 响应参数
}

ServiceSyncResponse 服务同步调用响应

func NewServiceResponseByBase64

func NewServiceResponseByBase64(base64Payload string) (*ServiceSyncResponse, error)

NewServiceResponseByBase64 通过 Base64 字符串创建服务响应对象