Documentation ¶
Index ¶
- Variables
- func GetEndpointMap() map[string]string
- func GetEndpointType() string
- func SetClientProperty(client *Client, propertyName string, propertyValue interface{})
- func SetEndpointDataToClient(client *Client)
- type ApplyTokenRequest
- type ApplyTokenResponse
- type BatchQuerySessionByClientIdsRequest
- type BatchQuerySessionByClientIdsResponse
- type Client
- func NewClient() (client *Client, err error)
- func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
- func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error)
- func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
- func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)
- func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)
- func NewClientWithRamRoleArnAndPolicy(regionId string, ...) (client *Client, err error)
- func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)
- func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)
- func (client *Client) ApplyToken(request *ApplyTokenRequest) (response *ApplyTokenResponse, err error)
- func (client *Client) ApplyTokenWithCallback(request *ApplyTokenRequest, ...) <-chan int
- func (client *Client) ApplyTokenWithChan(request *ApplyTokenRequest) (<-chan *ApplyTokenResponse, <-chan error)
- func (client *Client) BatchQuerySessionByClientIds(request *BatchQuerySessionByClientIdsRequest) (response *BatchQuerySessionByClientIdsResponse, err error)
- func (client *Client) BatchQuerySessionByClientIdsWithCallback(request *BatchQuerySessionByClientIdsRequest, ...) <-chan int
- func (client *Client) BatchQuerySessionByClientIdsWithChan(request *BatchQuerySessionByClientIdsRequest) (<-chan *BatchQuerySessionByClientIdsResponse, <-chan error)
- func (client *Client) CreateGroupId(request *CreateGroupIdRequest) (response *CreateGroupIdResponse, err error)
- func (client *Client) CreateGroupIdWithCallback(request *CreateGroupIdRequest, ...) <-chan int
- func (client *Client) CreateGroupIdWithChan(request *CreateGroupIdRequest) (<-chan *CreateGroupIdResponse, <-chan error)
- func (client *Client) DeleteGroupId(request *DeleteGroupIdRequest) (response *DeleteGroupIdResponse, err error)
- func (client *Client) DeleteGroupIdWithCallback(request *DeleteGroupIdRequest, ...) <-chan int
- func (client *Client) DeleteGroupIdWithChan(request *DeleteGroupIdRequest) (<-chan *DeleteGroupIdResponse, <-chan error)
- func (client *Client) GetDeviceCredential(request *GetDeviceCredentialRequest) (response *GetDeviceCredentialResponse, err error)
- func (client *Client) GetDeviceCredentialWithCallback(request *GetDeviceCredentialRequest, ...) <-chan int
- func (client *Client) GetDeviceCredentialWithChan(request *GetDeviceCredentialRequest) (<-chan *GetDeviceCredentialResponse, <-chan error)
- func (client *Client) ListGroupId(request *ListGroupIdRequest) (response *ListGroupIdResponse, err error)
- func (client *Client) ListGroupIdWithCallback(request *ListGroupIdRequest, ...) <-chan int
- func (client *Client) ListGroupIdWithChan(request *ListGroupIdRequest) (<-chan *ListGroupIdResponse, <-chan error)
- func (client *Client) QuerySessionByClientId(request *QuerySessionByClientIdRequest) (response *QuerySessionByClientIdResponse, err error)
- func (client *Client) QuerySessionByClientIdWithCallback(request *QuerySessionByClientIdRequest, ...) <-chan int
- func (client *Client) QuerySessionByClientIdWithChan(request *QuerySessionByClientIdRequest) (<-chan *QuerySessionByClientIdResponse, <-chan error)
- func (client *Client) QueryToken(request *QueryTokenRequest) (response *QueryTokenResponse, err error)
- func (client *Client) QueryTokenWithCallback(request *QueryTokenRequest, ...) <-chan int
- func (client *Client) QueryTokenWithChan(request *QueryTokenRequest) (<-chan *QueryTokenResponse, <-chan error)
- func (client *Client) RefreshDeviceCredential(request *RefreshDeviceCredentialRequest) (response *RefreshDeviceCredentialResponse, err error)
- func (client *Client) RefreshDeviceCredentialWithCallback(request *RefreshDeviceCredentialRequest, ...) <-chan int
- func (client *Client) RefreshDeviceCredentialWithChan(request *RefreshDeviceCredentialRequest) (<-chan *RefreshDeviceCredentialResponse, <-chan error)
- func (client *Client) RegisterDeviceCredential(request *RegisterDeviceCredentialRequest) (response *RegisterDeviceCredentialResponse, err error)
- func (client *Client) RegisterDeviceCredentialWithCallback(request *RegisterDeviceCredentialRequest, ...) <-chan int
- func (client *Client) RegisterDeviceCredentialWithChan(request *RegisterDeviceCredentialRequest) (<-chan *RegisterDeviceCredentialResponse, <-chan error)
- func (client *Client) RevokeToken(request *RevokeTokenRequest) (response *RevokeTokenResponse, err error)
- func (client *Client) RevokeTokenWithCallback(request *RevokeTokenRequest, ...) <-chan int
- func (client *Client) RevokeTokenWithChan(request *RevokeTokenRequest) (<-chan *RevokeTokenResponse, <-chan error)
- func (client *Client) SendMessage(request *SendMessageRequest) (response *SendMessageResponse, err error)
- func (client *Client) SendMessageWithCallback(request *SendMessageRequest, ...) <-chan int
- func (client *Client) SendMessageWithChan(request *SendMessageRequest) (<-chan *SendMessageResponse, <-chan error)
- func (client *Client) UnRegisterDeviceCredential(request *UnRegisterDeviceCredentialRequest) (response *UnRegisterDeviceCredentialResponse, err error)
- func (client *Client) UnRegisterDeviceCredentialWithCallback(request *UnRegisterDeviceCredentialRequest, ...) <-chan int
- func (client *Client) UnRegisterDeviceCredentialWithChan(request *UnRegisterDeviceCredentialRequest) (<-chan *UnRegisterDeviceCredentialResponse, <-chan error)
- type CreateGroupIdRequest
- type CreateGroupIdResponse
- type Data
- type DeleteGroupIdRequest
- type DeleteGroupIdResponse
- type DeviceCredential
- type GetDeviceCredentialRequest
- type GetDeviceCredentialResponse
- type ListGroupIdRequest
- type ListGroupIdResponse
- type MqttGroupIdDo
- type OnlineStatusList
- type OnlineStatusListItem
- type QuerySessionByClientIdRequest
- type QuerySessionByClientIdResponse
- type QueryTokenRequest
- type QueryTokenResponse
- type RefreshDeviceCredentialRequest
- type RefreshDeviceCredentialResponse
- type RegisterDeviceCredentialRequest
- type RegisterDeviceCredentialResponse
- type RevokeTokenRequest
- type RevokeTokenResponse
- type SendMessageRequest
- type SendMessageResponse
- type UnRegisterDeviceCredentialRequest
- type UnRegisterDeviceCredentialResponse
Constants ¶
This section is empty.
Variables ¶
var EndpointMap map[string]string
EndpointMap Endpoint Data
var EndpointType = "regional"
EndpointType regional or central
Functions ¶
func GetEndpointMap ¶ added in v1.61.161
GetEndpointMap Get Endpoint Data Map
func GetEndpointType ¶ added in v1.61.161
func GetEndpointType() string
GetEndpointType Get Endpoint Type Value
func SetClientProperty ¶ added in v1.61.161
SetClientProperty Set Property by Reflect
func SetEndpointDataToClient ¶ added in v1.61.161
func SetEndpointDataToClient(client *Client)
SetEndpointDataToClient Set EndpointMap and ENdpointType
Types ¶
type ApplyTokenRequest ¶
type ApplyTokenRequest struct { *requests.RpcRequest ExpireTime requests.Integer `position:"Query" name:"ExpireTime"` Resources string `position:"Query" name:"Resources"` InstanceId string `position:"Query" name:"InstanceId"` Actions string `position:"Query" name:"Actions"` }
ApplyTokenRequest is the request struct for api ApplyToken
func CreateApplyTokenRequest ¶
func CreateApplyTokenRequest() (request *ApplyTokenRequest)
CreateApplyTokenRequest creates a request to invoke ApplyToken API
type ApplyTokenResponse ¶
type ApplyTokenResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Token string `json:"Token" xml:"Token"` }
ApplyTokenResponse is the response struct for api ApplyToken
func CreateApplyTokenResponse ¶
func CreateApplyTokenResponse() (response *ApplyTokenResponse)
CreateApplyTokenResponse creates a response to parse from ApplyToken response
type BatchQuerySessionByClientIdsRequest ¶
type BatchQuerySessionByClientIdsRequest struct { *requests.RpcRequest ClientIdList *[]string `position:"Query" name:"ClientIdList" type:"Repeated"` InstanceId string `position:"Query" name:"InstanceId"` }
BatchQuerySessionByClientIdsRequest is the request struct for api BatchQuerySessionByClientIds
func CreateBatchQuerySessionByClientIdsRequest ¶
func CreateBatchQuerySessionByClientIdsRequest() (request *BatchQuerySessionByClientIdsRequest)
CreateBatchQuerySessionByClientIdsRequest creates a request to invoke BatchQuerySessionByClientIds API
type BatchQuerySessionByClientIdsResponse ¶
type BatchQuerySessionByClientIdsResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` OnlineStatusList []OnlineStatusListItem `json:"OnlineStatusList" xml:"OnlineStatusList"` }
BatchQuerySessionByClientIdsResponse is the response struct for api BatchQuerySessionByClientIds
func CreateBatchQuerySessionByClientIdsResponse ¶
func CreateBatchQuerySessionByClientIdsResponse() (response *BatchQuerySessionByClientIdsResponse)
CreateBatchQuerySessionByClientIdsResponse creates a response to parse from BatchQuerySessionByClientIds response
type Client ¶
Client is the sdk client struct, each func corresponds to an OpenAPI
func NewClientWithAccessKey ¶
func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
NewClientWithAccessKey is a shortcut to create sdk client with accesskey usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithEcsRamRole ¶
NewClientWithEcsRamRole is a shortcut to create sdk client with ecs ram role usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithOptions ¶
func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
NewClientWithOptions creates a sdk client with regionId/sdkConfig/credential this is the common api to create a sdk client
func NewClientWithProvider ¶
func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)
NewClientWithProvider creates a sdk client with providers usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRamRoleArn ¶
func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)
NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRamRoleArnAndPolicy ¶
func NewClientWithRamRoleArnAndPolicy(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName, policy string) (client *Client, err error)
NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn and policy usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRsaKeyPair ¶
func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)
NewClientWithRsaKeyPair is a shortcut to create sdk client with rsa key pair usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithStsToken ¶
func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)
NewClientWithStsToken is a shortcut to create sdk client with sts token usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func (*Client) ApplyToken ¶
func (client *Client) ApplyToken(request *ApplyTokenRequest) (response *ApplyTokenResponse, err error)
ApplyToken invokes the onsmqtt.ApplyToken API synchronously
func (*Client) ApplyTokenWithCallback ¶
func (client *Client) ApplyTokenWithCallback(request *ApplyTokenRequest, callback func(response *ApplyTokenResponse, err error)) <-chan int
ApplyTokenWithCallback invokes the onsmqtt.ApplyToken API asynchronously
func (*Client) ApplyTokenWithChan ¶
func (client *Client) ApplyTokenWithChan(request *ApplyTokenRequest) (<-chan *ApplyTokenResponse, <-chan error)
ApplyTokenWithChan invokes the onsmqtt.ApplyToken API asynchronously
func (*Client) BatchQuerySessionByClientIds ¶
func (client *Client) BatchQuerySessionByClientIds(request *BatchQuerySessionByClientIdsRequest) (response *BatchQuerySessionByClientIdsResponse, err error)
BatchQuerySessionByClientIds invokes the onsmqtt.BatchQuerySessionByClientIds API synchronously
func (*Client) BatchQuerySessionByClientIdsWithCallback ¶
func (client *Client) BatchQuerySessionByClientIdsWithCallback(request *BatchQuerySessionByClientIdsRequest, callback func(response *BatchQuerySessionByClientIdsResponse, err error)) <-chan int
BatchQuerySessionByClientIdsWithCallback invokes the onsmqtt.BatchQuerySessionByClientIds API asynchronously
func (*Client) BatchQuerySessionByClientIdsWithChan ¶
func (client *Client) BatchQuerySessionByClientIdsWithChan(request *BatchQuerySessionByClientIdsRequest) (<-chan *BatchQuerySessionByClientIdsResponse, <-chan error)
BatchQuerySessionByClientIdsWithChan invokes the onsmqtt.BatchQuerySessionByClientIds API asynchronously
func (*Client) CreateGroupId ¶ added in v1.61.135
func (client *Client) CreateGroupId(request *CreateGroupIdRequest) (response *CreateGroupIdResponse, err error)
CreateGroupId invokes the onsmqtt.CreateGroupId API synchronously
func (*Client) CreateGroupIdWithCallback ¶ added in v1.61.135
func (client *Client) CreateGroupIdWithCallback(request *CreateGroupIdRequest, callback func(response *CreateGroupIdResponse, err error)) <-chan int
CreateGroupIdWithCallback invokes the onsmqtt.CreateGroupId API asynchronously
func (*Client) CreateGroupIdWithChan ¶ added in v1.61.135
func (client *Client) CreateGroupIdWithChan(request *CreateGroupIdRequest) (<-chan *CreateGroupIdResponse, <-chan error)
CreateGroupIdWithChan invokes the onsmqtt.CreateGroupId API asynchronously
func (*Client) DeleteGroupId ¶ added in v1.61.135
func (client *Client) DeleteGroupId(request *DeleteGroupIdRequest) (response *DeleteGroupIdResponse, err error)
DeleteGroupId invokes the onsmqtt.DeleteGroupId API synchronously
func (*Client) DeleteGroupIdWithCallback ¶ added in v1.61.135
func (client *Client) DeleteGroupIdWithCallback(request *DeleteGroupIdRequest, callback func(response *DeleteGroupIdResponse, err error)) <-chan int
DeleteGroupIdWithCallback invokes the onsmqtt.DeleteGroupId API asynchronously
func (*Client) DeleteGroupIdWithChan ¶ added in v1.61.135
func (client *Client) DeleteGroupIdWithChan(request *DeleteGroupIdRequest) (<-chan *DeleteGroupIdResponse, <-chan error)
DeleteGroupIdWithChan invokes the onsmqtt.DeleteGroupId API asynchronously
func (*Client) GetDeviceCredential ¶ added in v1.61.898
func (client *Client) GetDeviceCredential(request *GetDeviceCredentialRequest) (response *GetDeviceCredentialResponse, err error)
GetDeviceCredential invokes the onsmqtt.GetDeviceCredential API synchronously
func (*Client) GetDeviceCredentialWithCallback ¶ added in v1.61.898
func (client *Client) GetDeviceCredentialWithCallback(request *GetDeviceCredentialRequest, callback func(response *GetDeviceCredentialResponse, err error)) <-chan int
GetDeviceCredentialWithCallback invokes the onsmqtt.GetDeviceCredential API asynchronously
func (*Client) GetDeviceCredentialWithChan ¶ added in v1.61.898
func (client *Client) GetDeviceCredentialWithChan(request *GetDeviceCredentialRequest) (<-chan *GetDeviceCredentialResponse, <-chan error)
GetDeviceCredentialWithChan invokes the onsmqtt.GetDeviceCredential API asynchronously
func (*Client) ListGroupId ¶ added in v1.61.135
func (client *Client) ListGroupId(request *ListGroupIdRequest) (response *ListGroupIdResponse, err error)
ListGroupId invokes the onsmqtt.ListGroupId API synchronously
func (*Client) ListGroupIdWithCallback ¶ added in v1.61.135
func (client *Client) ListGroupIdWithCallback(request *ListGroupIdRequest, callback func(response *ListGroupIdResponse, err error)) <-chan int
ListGroupIdWithCallback invokes the onsmqtt.ListGroupId API asynchronously
func (*Client) ListGroupIdWithChan ¶ added in v1.61.135
func (client *Client) ListGroupIdWithChan(request *ListGroupIdRequest) (<-chan *ListGroupIdResponse, <-chan error)
ListGroupIdWithChan invokes the onsmqtt.ListGroupId API asynchronously
func (*Client) QuerySessionByClientId ¶
func (client *Client) QuerySessionByClientId(request *QuerySessionByClientIdRequest) (response *QuerySessionByClientIdResponse, err error)
QuerySessionByClientId invokes the onsmqtt.QuerySessionByClientId API synchronously
func (*Client) QuerySessionByClientIdWithCallback ¶
func (client *Client) QuerySessionByClientIdWithCallback(request *QuerySessionByClientIdRequest, callback func(response *QuerySessionByClientIdResponse, err error)) <-chan int
QuerySessionByClientIdWithCallback invokes the onsmqtt.QuerySessionByClientId API asynchronously
func (*Client) QuerySessionByClientIdWithChan ¶
func (client *Client) QuerySessionByClientIdWithChan(request *QuerySessionByClientIdRequest) (<-chan *QuerySessionByClientIdResponse, <-chan error)
QuerySessionByClientIdWithChan invokes the onsmqtt.QuerySessionByClientId API asynchronously
func (*Client) QueryToken ¶
func (client *Client) QueryToken(request *QueryTokenRequest) (response *QueryTokenResponse, err error)
QueryToken invokes the onsmqtt.QueryToken API synchronously
func (*Client) QueryTokenWithCallback ¶
func (client *Client) QueryTokenWithCallback(request *QueryTokenRequest, callback func(response *QueryTokenResponse, err error)) <-chan int
QueryTokenWithCallback invokes the onsmqtt.QueryToken API asynchronously
func (*Client) QueryTokenWithChan ¶
func (client *Client) QueryTokenWithChan(request *QueryTokenRequest) (<-chan *QueryTokenResponse, <-chan error)
QueryTokenWithChan invokes the onsmqtt.QueryToken API asynchronously
func (*Client) RefreshDeviceCredential ¶ added in v1.61.898
func (client *Client) RefreshDeviceCredential(request *RefreshDeviceCredentialRequest) (response *RefreshDeviceCredentialResponse, err error)
RefreshDeviceCredential invokes the onsmqtt.RefreshDeviceCredential API synchronously
func (*Client) RefreshDeviceCredentialWithCallback ¶ added in v1.61.898
func (client *Client) RefreshDeviceCredentialWithCallback(request *RefreshDeviceCredentialRequest, callback func(response *RefreshDeviceCredentialResponse, err error)) <-chan int
RefreshDeviceCredentialWithCallback invokes the onsmqtt.RefreshDeviceCredential API asynchronously
func (*Client) RefreshDeviceCredentialWithChan ¶ added in v1.61.898
func (client *Client) RefreshDeviceCredentialWithChan(request *RefreshDeviceCredentialRequest) (<-chan *RefreshDeviceCredentialResponse, <-chan error)
RefreshDeviceCredentialWithChan invokes the onsmqtt.RefreshDeviceCredential API asynchronously
func (*Client) RegisterDeviceCredential ¶ added in v1.61.898
func (client *Client) RegisterDeviceCredential(request *RegisterDeviceCredentialRequest) (response *RegisterDeviceCredentialResponse, err error)
RegisterDeviceCredential invokes the onsmqtt.RegisterDeviceCredential API synchronously
func (*Client) RegisterDeviceCredentialWithCallback ¶ added in v1.61.898
func (client *Client) RegisterDeviceCredentialWithCallback(request *RegisterDeviceCredentialRequest, callback func(response *RegisterDeviceCredentialResponse, err error)) <-chan int
RegisterDeviceCredentialWithCallback invokes the onsmqtt.RegisterDeviceCredential API asynchronously
func (*Client) RegisterDeviceCredentialWithChan ¶ added in v1.61.898
func (client *Client) RegisterDeviceCredentialWithChan(request *RegisterDeviceCredentialRequest) (<-chan *RegisterDeviceCredentialResponse, <-chan error)
RegisterDeviceCredentialWithChan invokes the onsmqtt.RegisterDeviceCredential API asynchronously
func (*Client) RevokeToken ¶
func (client *Client) RevokeToken(request *RevokeTokenRequest) (response *RevokeTokenResponse, err error)
RevokeToken invokes the onsmqtt.RevokeToken API synchronously
func (*Client) RevokeTokenWithCallback ¶
func (client *Client) RevokeTokenWithCallback(request *RevokeTokenRequest, callback func(response *RevokeTokenResponse, err error)) <-chan int
RevokeTokenWithCallback invokes the onsmqtt.RevokeToken API asynchronously
func (*Client) RevokeTokenWithChan ¶
func (client *Client) RevokeTokenWithChan(request *RevokeTokenRequest) (<-chan *RevokeTokenResponse, <-chan error)
RevokeTokenWithChan invokes the onsmqtt.RevokeToken API asynchronously
func (*Client) SendMessage ¶
func (client *Client) SendMessage(request *SendMessageRequest) (response *SendMessageResponse, err error)
SendMessage invokes the onsmqtt.SendMessage API synchronously
func (*Client) SendMessageWithCallback ¶
func (client *Client) SendMessageWithCallback(request *SendMessageRequest, callback func(response *SendMessageResponse, err error)) <-chan int
SendMessageWithCallback invokes the onsmqtt.SendMessage API asynchronously
func (*Client) SendMessageWithChan ¶
func (client *Client) SendMessageWithChan(request *SendMessageRequest) (<-chan *SendMessageResponse, <-chan error)
SendMessageWithChan invokes the onsmqtt.SendMessage API asynchronously
func (*Client) UnRegisterDeviceCredential ¶ added in v1.61.898
func (client *Client) UnRegisterDeviceCredential(request *UnRegisterDeviceCredentialRequest) (response *UnRegisterDeviceCredentialResponse, err error)
UnRegisterDeviceCredential invokes the onsmqtt.UnRegisterDeviceCredential API synchronously
func (*Client) UnRegisterDeviceCredentialWithCallback ¶ added in v1.61.898
func (client *Client) UnRegisterDeviceCredentialWithCallback(request *UnRegisterDeviceCredentialRequest, callback func(response *UnRegisterDeviceCredentialResponse, err error)) <-chan int
UnRegisterDeviceCredentialWithCallback invokes the onsmqtt.UnRegisterDeviceCredential API asynchronously
func (*Client) UnRegisterDeviceCredentialWithChan ¶ added in v1.61.898
func (client *Client) UnRegisterDeviceCredentialWithChan(request *UnRegisterDeviceCredentialRequest) (<-chan *UnRegisterDeviceCredentialResponse, <-chan error)
UnRegisterDeviceCredentialWithChan invokes the onsmqtt.UnRegisterDeviceCredential API asynchronously
type CreateGroupIdRequest ¶ added in v1.61.135
type CreateGroupIdRequest struct { *requests.RpcRequest GroupId string `position:"Query" name:"GroupId"` InstanceId string `position:"Query" name:"InstanceId"` }
CreateGroupIdRequest is the request struct for api CreateGroupId
func CreateCreateGroupIdRequest ¶ added in v1.61.135
func CreateCreateGroupIdRequest() (request *CreateGroupIdRequest)
CreateCreateGroupIdRequest creates a request to invoke CreateGroupId API
type CreateGroupIdResponse ¶ added in v1.61.135
type CreateGroupIdResponse struct { *responses.BaseResponse HelpUrl string `json:"HelpUrl" xml:"HelpUrl"` RequestId string `json:"RequestId" xml:"RequestId"` }
CreateGroupIdResponse is the response struct for api CreateGroupId
func CreateCreateGroupIdResponse ¶ added in v1.61.135
func CreateCreateGroupIdResponse() (response *CreateGroupIdResponse)
CreateCreateGroupIdResponse creates a response to parse from CreateGroupId response
type Data ¶ added in v1.61.135
type Data struct {
MqttGroupIdDo []MqttGroupIdDo `json:"MqttGroupIdDo" xml:"MqttGroupIdDo"`
}
Data is a nested struct in onsmqtt response
type DeleteGroupIdRequest ¶ added in v1.61.135
type DeleteGroupIdRequest struct { *requests.RpcRequest GroupId string `position:"Query" name:"GroupId"` InstanceId string `position:"Query" name:"InstanceId"` }
DeleteGroupIdRequest is the request struct for api DeleteGroupId
func CreateDeleteGroupIdRequest ¶ added in v1.61.135
func CreateDeleteGroupIdRequest() (request *DeleteGroupIdRequest)
CreateDeleteGroupIdRequest creates a request to invoke DeleteGroupId API
type DeleteGroupIdResponse ¶ added in v1.61.135
type DeleteGroupIdResponse struct { *responses.BaseResponse HelpUrl string `json:"HelpUrl" xml:"HelpUrl"` RequestId string `json:"RequestId" xml:"RequestId"` }
DeleteGroupIdResponse is the response struct for api DeleteGroupId
func CreateDeleteGroupIdResponse ¶ added in v1.61.135
func CreateDeleteGroupIdResponse() (response *DeleteGroupIdResponse)
CreateDeleteGroupIdResponse creates a response to parse from DeleteGroupId response
type DeviceCredential ¶ added in v1.61.898
type DeviceCredential struct { DeviceAccessKeySecret string `json:"DeviceAccessKeySecret" xml:"DeviceAccessKeySecret"` DeviceAccessKeyId string `json:"DeviceAccessKeyId" xml:"DeviceAccessKeyId"` ClientId string `json:"ClientId" xml:"ClientId"` UpdateTime int64 `json:"UpdateTime" xml:"UpdateTime"` InstanceId string `json:"InstanceId" xml:"InstanceId"` CreateTime int64 `json:"CreateTime" xml:"CreateTime"` }
DeviceCredential is a nested struct in onsmqtt response
type GetDeviceCredentialRequest ¶ added in v1.61.898
type GetDeviceCredentialRequest struct { *requests.RpcRequest ClientId string `position:"Query" name:"ClientId"` InstanceId string `position:"Query" name:"InstanceId"` }
GetDeviceCredentialRequest is the request struct for api GetDeviceCredential
func CreateGetDeviceCredentialRequest ¶ added in v1.61.898
func CreateGetDeviceCredentialRequest() (request *GetDeviceCredentialRequest)
CreateGetDeviceCredentialRequest creates a request to invoke GetDeviceCredential API
type GetDeviceCredentialResponse ¶ added in v1.61.898
type GetDeviceCredentialResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` DeviceCredential DeviceCredential `json:"DeviceCredential" xml:"DeviceCredential"` }
GetDeviceCredentialResponse is the response struct for api GetDeviceCredential
func CreateGetDeviceCredentialResponse ¶ added in v1.61.898
func CreateGetDeviceCredentialResponse() (response *GetDeviceCredentialResponse)
CreateGetDeviceCredentialResponse creates a response to parse from GetDeviceCredential response
type ListGroupIdRequest ¶ added in v1.61.135
type ListGroupIdRequest struct { *requests.RpcRequest InstanceId string `position:"Query" name:"InstanceId"` }
ListGroupIdRequest is the request struct for api ListGroupId
func CreateListGroupIdRequest ¶ added in v1.61.135
func CreateListGroupIdRequest() (request *ListGroupIdRequest)
CreateListGroupIdRequest creates a request to invoke ListGroupId API
type ListGroupIdResponse ¶ added in v1.61.135
type ListGroupIdResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Data []MqttGroupIdDo `json:"Data" xml:"Data"` }
ListGroupIdResponse is the response struct for api ListGroupId
func CreateListGroupIdResponse ¶ added in v1.61.135
func CreateListGroupIdResponse() (response *ListGroupIdResponse)
CreateListGroupIdResponse creates a response to parse from ListGroupId response
type MqttGroupIdDo ¶ added in v1.61.135
type MqttGroupIdDo struct { CreateTime int64 `json:"CreateTime" xml:"CreateTime"` GroupId string `json:"GroupId" xml:"GroupId"` IndependentNaming bool `json:"IndependentNaming" xml:"IndependentNaming"` InstanceId string `json:"InstanceId" xml:"InstanceId"` UpdateTime int64 `json:"UpdateTime" xml:"UpdateTime"` }
MqttGroupIdDo is a nested struct in onsmqtt response
type OnlineStatusList ¶
type OnlineStatusList struct {
OnlineStatusListItem []OnlineStatusListItem `json:"OnlineStatusList" xml:"OnlineStatusList"`
}
OnlineStatusList is a nested struct in onsmqtt response
type OnlineStatusListItem ¶
type OnlineStatusListItem struct { ClientId string `json:"ClientId" xml:"ClientId"` OnlineStatus bool `json:"OnlineStatus" xml:"OnlineStatus"` }
OnlineStatusListItem is a nested struct in onsmqtt response
type QuerySessionByClientIdRequest ¶
type QuerySessionByClientIdRequest struct { *requests.RpcRequest ClientId string `position:"Query" name:"ClientId"` InstanceId string `position:"Query" name:"InstanceId"` }
QuerySessionByClientIdRequest is the request struct for api QuerySessionByClientId
func CreateQuerySessionByClientIdRequest ¶
func CreateQuerySessionByClientIdRequest() (request *QuerySessionByClientIdRequest)
CreateQuerySessionByClientIdRequest creates a request to invoke QuerySessionByClientId API
type QuerySessionByClientIdResponse ¶
type QuerySessionByClientIdResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` OnlineStatus bool `json:"OnlineStatus" xml:"OnlineStatus"` }
QuerySessionByClientIdResponse is the response struct for api QuerySessionByClientId
func CreateQuerySessionByClientIdResponse ¶
func CreateQuerySessionByClientIdResponse() (response *QuerySessionByClientIdResponse)
CreateQuerySessionByClientIdResponse creates a response to parse from QuerySessionByClientId response
type QueryTokenRequest ¶
type QueryTokenRequest struct { *requests.RpcRequest Token string `position:"Query" name:"Token"` InstanceId string `position:"Query" name:"InstanceId"` }
QueryTokenRequest is the request struct for api QueryToken
func CreateQueryTokenRequest ¶
func CreateQueryTokenRequest() (request *QueryTokenRequest)
CreateQueryTokenRequest creates a request to invoke QueryToken API
type QueryTokenResponse ¶
type QueryTokenResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` TokenStatus bool `json:"TokenStatus" xml:"TokenStatus"` }
QueryTokenResponse is the response struct for api QueryToken
func CreateQueryTokenResponse ¶
func CreateQueryTokenResponse() (response *QueryTokenResponse)
CreateQueryTokenResponse creates a response to parse from QueryToken response
type RefreshDeviceCredentialRequest ¶ added in v1.61.898
type RefreshDeviceCredentialRequest struct { *requests.RpcRequest ClientId string `position:"Query" name:"ClientId"` InstanceId string `position:"Query" name:"InstanceId"` }
RefreshDeviceCredentialRequest is the request struct for api RefreshDeviceCredential
func CreateRefreshDeviceCredentialRequest ¶ added in v1.61.898
func CreateRefreshDeviceCredentialRequest() (request *RefreshDeviceCredentialRequest)
CreateRefreshDeviceCredentialRequest creates a request to invoke RefreshDeviceCredential API
type RefreshDeviceCredentialResponse ¶ added in v1.61.898
type RefreshDeviceCredentialResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` DeviceCredential DeviceCredential `json:"DeviceCredential" xml:"DeviceCredential"` }
RefreshDeviceCredentialResponse is the response struct for api RefreshDeviceCredential
func CreateRefreshDeviceCredentialResponse ¶ added in v1.61.898
func CreateRefreshDeviceCredentialResponse() (response *RefreshDeviceCredentialResponse)
CreateRefreshDeviceCredentialResponse creates a response to parse from RefreshDeviceCredential response
type RegisterDeviceCredentialRequest ¶ added in v1.61.898
type RegisterDeviceCredentialRequest struct { *requests.RpcRequest ClientId string `position:"Query" name:"ClientId"` InstanceId string `position:"Query" name:"InstanceId"` }
RegisterDeviceCredentialRequest is the request struct for api RegisterDeviceCredential
func CreateRegisterDeviceCredentialRequest ¶ added in v1.61.898
func CreateRegisterDeviceCredentialRequest() (request *RegisterDeviceCredentialRequest)
CreateRegisterDeviceCredentialRequest creates a request to invoke RegisterDeviceCredential API
type RegisterDeviceCredentialResponse ¶ added in v1.61.898
type RegisterDeviceCredentialResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` DeviceCredential DeviceCredential `json:"DeviceCredential" xml:"DeviceCredential"` }
RegisterDeviceCredentialResponse is the response struct for api RegisterDeviceCredential
func CreateRegisterDeviceCredentialResponse ¶ added in v1.61.898
func CreateRegisterDeviceCredentialResponse() (response *RegisterDeviceCredentialResponse)
CreateRegisterDeviceCredentialResponse creates a response to parse from RegisterDeviceCredential response
type RevokeTokenRequest ¶
type RevokeTokenRequest struct { *requests.RpcRequest Token string `position:"Query" name:"Token"` InstanceId string `position:"Query" name:"InstanceId"` }
RevokeTokenRequest is the request struct for api RevokeToken
func CreateRevokeTokenRequest ¶
func CreateRevokeTokenRequest() (request *RevokeTokenRequest)
CreateRevokeTokenRequest creates a request to invoke RevokeToken API
type RevokeTokenResponse ¶
type RevokeTokenResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` }
RevokeTokenResponse is the response struct for api RevokeToken
func CreateRevokeTokenResponse ¶
func CreateRevokeTokenResponse() (response *RevokeTokenResponse)
CreateRevokeTokenResponse creates a response to parse from RevokeToken response
type SendMessageRequest ¶
type SendMessageRequest struct { *requests.RpcRequest MqttTopic string `position:"Query" name:"MqttTopic"` InstanceId string `position:"Query" name:"InstanceId"` Payload string `position:"Query" name:"Payload"` }
SendMessageRequest is the request struct for api SendMessage
func CreateSendMessageRequest ¶
func CreateSendMessageRequest() (request *SendMessageRequest)
CreateSendMessageRequest creates a request to invoke SendMessage API
type SendMessageResponse ¶
type SendMessageResponse struct { *responses.BaseResponse MsgId string `json:"MsgId" xml:"MsgId"` RequestId string `json:"RequestId" xml:"RequestId"` }
SendMessageResponse is the response struct for api SendMessage
func CreateSendMessageResponse ¶
func CreateSendMessageResponse() (response *SendMessageResponse)
CreateSendMessageResponse creates a response to parse from SendMessage response
type UnRegisterDeviceCredentialRequest ¶ added in v1.61.898
type UnRegisterDeviceCredentialRequest struct { *requests.RpcRequest ClientId string `position:"Query" name:"ClientId"` InstanceId string `position:"Query" name:"InstanceId"` }
UnRegisterDeviceCredentialRequest is the request struct for api UnRegisterDeviceCredential
func CreateUnRegisterDeviceCredentialRequest ¶ added in v1.61.898
func CreateUnRegisterDeviceCredentialRequest() (request *UnRegisterDeviceCredentialRequest)
CreateUnRegisterDeviceCredentialRequest creates a request to invoke UnRegisterDeviceCredential API
type UnRegisterDeviceCredentialResponse ¶ added in v1.61.898
type UnRegisterDeviceCredentialResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` }
UnRegisterDeviceCredentialResponse is the response struct for api UnRegisterDeviceCredential
func CreateUnRegisterDeviceCredentialResponse ¶ added in v1.61.898
func CreateUnRegisterDeviceCredentialResponse() (response *UnRegisterDeviceCredentialResponse)
CreateUnRegisterDeviceCredentialResponse creates a response to parse from UnRegisterDeviceCredential response
Source Files ¶
- apply_token.go
- batch_query_session_by_client_ids.go
- client.go
- create_group_id.go
- delete_group_id.go
- endpoint.go
- get_device_credential.go
- list_group_id.go
- query_session_by_client_id.go
- query_token.go
- refresh_device_credential.go
- register_device_credential.go
- revoke_token.go
- send_message.go
- struct_data.go
- struct_device_credential.go
- struct_mqtt_group_id_do.go
- struct_online_status_list.go
- struct_online_status_list_item.go
- un_register_device_credential.go