ons

Documentation

Index

• 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 NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName 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) OnsConsumerAccumulate(request *OnsConsumerAccumulateRequest) (response *OnsConsumerAccumulateResponse, err error)
  • func (client *Client) OnsConsumerAccumulateWithCallback(request *OnsConsumerAccumulateRequest, ...) <-chan int
  • func (client *Client) OnsConsumerAccumulateWithChan(request *OnsConsumerAccumulateRequest) (<-chan *OnsConsumerAccumulateResponse, <-chan error)
  • func (client *Client) OnsConsumerGetConnection(request *OnsConsumerGetConnectionRequest) (response *OnsConsumerGetConnectionResponse, err error)
  • func (client *Client) OnsConsumerGetConnectionWithCallback(request *OnsConsumerGetConnectionRequest, ...) <-chan int
  • func (client *Client) OnsConsumerGetConnectionWithChan(request *OnsConsumerGetConnectionRequest) (<-chan *OnsConsumerGetConnectionResponse, <-chan error)
  • func (client *Client) OnsConsumerResetOffset(request *OnsConsumerResetOffsetRequest) (response *OnsConsumerResetOffsetResponse, err error)
  • func (client *Client) OnsConsumerResetOffsetWithCallback(request *OnsConsumerResetOffsetRequest, ...) <-chan int
  • func (client *Client) OnsConsumerResetOffsetWithChan(request *OnsConsumerResetOffsetRequest) (<-chan *OnsConsumerResetOffsetResponse, <-chan error)
  • func (client *Client) OnsConsumerStatus(request *OnsConsumerStatusRequest) (response *OnsConsumerStatusResponse, err error)
  • func (client *Client) OnsConsumerStatusWithCallback(request *OnsConsumerStatusRequest, ...) <-chan int
  • func (client *Client) OnsConsumerStatusWithChan(request *OnsConsumerStatusRequest) (<-chan *OnsConsumerStatusResponse, <-chan error)
  • func (client *Client) OnsConsumerTimeSpan(request *OnsConsumerTimeSpanRequest) (response *OnsConsumerTimeSpanResponse, err error)
  • func (client *Client) OnsConsumerTimeSpanWithCallback(request *OnsConsumerTimeSpanRequest, ...) <-chan int
  • func (client *Client) OnsConsumerTimeSpanWithChan(request *OnsConsumerTimeSpanRequest) (<-chan *OnsConsumerTimeSpanResponse, <-chan error)
  • func (client *Client) OnsGroupConsumerUpdate(request *OnsGroupConsumerUpdateRequest) (response *OnsGroupConsumerUpdateResponse, err error)
  • func (client *Client) OnsGroupConsumerUpdateWithCallback(request *OnsGroupConsumerUpdateRequest, ...) <-chan int
  • func (client *Client) OnsGroupConsumerUpdateWithChan(request *OnsGroupConsumerUpdateRequest) (<-chan *OnsGroupConsumerUpdateResponse, <-chan error)
  • func (client *Client) OnsGroupCreate(request *OnsGroupCreateRequest) (response *OnsGroupCreateResponse, err error)
  • func (client *Client) OnsGroupCreateWithCallback(request *OnsGroupCreateRequest, ...) <-chan int
  • func (client *Client) OnsGroupCreateWithChan(request *OnsGroupCreateRequest) (<-chan *OnsGroupCreateResponse, <-chan error)
  • func (client *Client) OnsGroupDelete(request *OnsGroupDeleteRequest) (response *OnsGroupDeleteResponse, err error)
  • func (client *Client) OnsGroupDeleteWithCallback(request *OnsGroupDeleteRequest, ...) <-chan int
  • func (client *Client) OnsGroupDeleteWithChan(request *OnsGroupDeleteRequest) (<-chan *OnsGroupDeleteResponse, <-chan error)
  • func (client *Client) OnsGroupList(request *OnsGroupListRequest) (response *OnsGroupListResponse, err error)
  • func (client *Client) OnsGroupListWithCallback(request *OnsGroupListRequest, ...) <-chan int
  • func (client *Client) OnsGroupListWithChan(request *OnsGroupListRequest) (<-chan *OnsGroupListResponse, <-chan error)
  • func (client *Client) OnsInstanceBaseInfo(request *OnsInstanceBaseInfoRequest) (response *OnsInstanceBaseInfoResponse, err error)
  • func (client *Client) OnsInstanceBaseInfoWithCallback(request *OnsInstanceBaseInfoRequest, ...) <-chan int
  • func (client *Client) OnsInstanceBaseInfoWithChan(request *OnsInstanceBaseInfoRequest) (<-chan *OnsInstanceBaseInfoResponse, <-chan error)
  • func (client *Client) OnsInstanceCreate(request *OnsInstanceCreateRequest) (response *OnsInstanceCreateResponse, err error)
  • func (client *Client) OnsInstanceCreateWithCallback(request *OnsInstanceCreateRequest, ...) <-chan int
  • func (client *Client) OnsInstanceCreateWithChan(request *OnsInstanceCreateRequest) (<-chan *OnsInstanceCreateResponse, <-chan error)
  • func (client *Client) OnsInstanceDelete(request *OnsInstanceDeleteRequest) (response *OnsInstanceDeleteResponse, err error)
  • func (client *Client) OnsInstanceDeleteWithCallback(request *OnsInstanceDeleteRequest, ...) <-chan int
  • func (client *Client) OnsInstanceDeleteWithChan(request *OnsInstanceDeleteRequest) (<-chan *OnsInstanceDeleteResponse, <-chan error)
  • func (client *Client) OnsInstanceInServiceList(request *OnsInstanceInServiceListRequest) (response *OnsInstanceInServiceListResponse, err error)
  • func (client *Client) OnsInstanceInServiceListWithCallback(request *OnsInstanceInServiceListRequest, ...) <-chan int
  • func (client *Client) OnsInstanceInServiceListWithChan(request *OnsInstanceInServiceListRequest) (<-chan *OnsInstanceInServiceListResponse, <-chan error)
  • func (client *Client) OnsInstanceUpdate(request *OnsInstanceUpdateRequest) (response *OnsInstanceUpdateResponse, err error)
  • func (client *Client) OnsInstanceUpdateWithCallback(request *OnsInstanceUpdateRequest, ...) <-chan int
  • func (client *Client) OnsInstanceUpdateWithChan(request *OnsInstanceUpdateRequest) (<-chan *OnsInstanceUpdateResponse, <-chan error)
  • func (client *Client) OnsMessageGetByKey(request *OnsMessageGetByKeyRequest) (response *OnsMessageGetByKeyResponse, err error)
  • func (client *Client) OnsMessageGetByKeyWithCallback(request *OnsMessageGetByKeyRequest, ...) <-chan int
  • func (client *Client) OnsMessageGetByKeyWithChan(request *OnsMessageGetByKeyRequest) (<-chan *OnsMessageGetByKeyResponse, <-chan error)
  • func (client *Client) OnsMessageGetByMsgId(request *OnsMessageGetByMsgIdRequest) (response *OnsMessageGetByMsgIdResponse, err error)
  • func (client *Client) OnsMessageGetByMsgIdWithCallback(request *OnsMessageGetByMsgIdRequest, ...) <-chan int
  • func (client *Client) OnsMessageGetByMsgIdWithChan(request *OnsMessageGetByMsgIdRequest) (<-chan *OnsMessageGetByMsgIdResponse, <-chan error)
  • func (client *Client) OnsMessagePageQueryByTopic(request *OnsMessagePageQueryByTopicRequest) (response *OnsMessagePageQueryByTopicResponse, err error)
  • func (client *Client) OnsMessagePageQueryByTopicWithCallback(request *OnsMessagePageQueryByTopicRequest, ...) <-chan int
  • func (client *Client) OnsMessagePageQueryByTopicWithChan(request *OnsMessagePageQueryByTopicRequest) (<-chan *OnsMessagePageQueryByTopicResponse, <-chan error)
  • func (client *Client) OnsMessagePush(request *OnsMessagePushRequest) (response *OnsMessagePushResponse, err error)
  • func (client *Client) OnsMessagePushWithCallback(request *OnsMessagePushRequest, ...) <-chan int
  • func (client *Client) OnsMessagePushWithChan(request *OnsMessagePushRequest) (<-chan *OnsMessagePushResponse, <-chan error)
  • func (client *Client) OnsMessageSend(request *OnsMessageSendRequest) (response *OnsMessageSendResponse, err error)
  • func (client *Client) OnsMessageSendWithCallback(request *OnsMessageSendRequest, ...) <-chan int
  • func (client *Client) OnsMessageSendWithChan(request *OnsMessageSendRequest) (<-chan *OnsMessageSendResponse, <-chan error)
  • func (client *Client) OnsMessageTrace(request *OnsMessageTraceRequest) (response *OnsMessageTraceResponse, err error)
  • func (client *Client) OnsMessageTraceWithCallback(request *OnsMessageTraceRequest, ...) <-chan int
  • func (client *Client) OnsMessageTraceWithChan(request *OnsMessageTraceRequest) (<-chan *OnsMessageTraceResponse, <-chan error)
  • func (client *Client) OnsMqttGroupIdCreate(request *OnsMqttGroupIdCreateRequest) (response *OnsMqttGroupIdCreateResponse, err error)
  • func (client *Client) OnsMqttGroupIdCreateWithCallback(request *OnsMqttGroupIdCreateRequest, ...) <-chan int
  • func (client *Client) OnsMqttGroupIdCreateWithChan(request *OnsMqttGroupIdCreateRequest) (<-chan *OnsMqttGroupIdCreateResponse, <-chan error)
  • func (client *Client) OnsMqttGroupIdDelete(request *OnsMqttGroupIdDeleteRequest) (response *OnsMqttGroupIdDeleteResponse, err error)
  • func (client *Client) OnsMqttGroupIdDeleteWithCallback(request *OnsMqttGroupIdDeleteRequest, ...) <-chan int
  • func (client *Client) OnsMqttGroupIdDeleteWithChan(request *OnsMqttGroupIdDeleteRequest) (<-chan *OnsMqttGroupIdDeleteResponse, <-chan error)
  • func (client *Client) OnsMqttGroupIdList(request *OnsMqttGroupIdListRequest) (response *OnsMqttGroupIdListResponse, err error)
  • func (client *Client) OnsMqttGroupIdListWithCallback(request *OnsMqttGroupIdListRequest, ...) <-chan int
  • func (client *Client) OnsMqttGroupIdListWithChan(request *OnsMqttGroupIdListRequest) (<-chan *OnsMqttGroupIdListResponse, <-chan error)
  • func (client *Client) OnsMqttQueryClientByClientId(request *OnsMqttQueryClientByClientIdRequest) (response *OnsMqttQueryClientByClientIdResponse, err error)
  • func (client *Client) OnsMqttQueryClientByClientIdWithCallback(request *OnsMqttQueryClientByClientIdRequest, ...) <-chan int
  • func (client *Client) OnsMqttQueryClientByClientIdWithChan(request *OnsMqttQueryClientByClientIdRequest) (<-chan *OnsMqttQueryClientByClientIdResponse, <-chan error)
  • func (client *Client) OnsMqttQueryClientByGroupId(request *OnsMqttQueryClientByGroupIdRequest) (response *OnsMqttQueryClientByGroupIdResponse, err error)
  • func (client *Client) OnsMqttQueryClientByGroupIdWithCallback(request *OnsMqttQueryClientByGroupIdRequest, ...) <-chan int
  • func (client *Client) OnsMqttQueryClientByGroupIdWithChan(request *OnsMqttQueryClientByGroupIdRequest) (<-chan *OnsMqttQueryClientByGroupIdResponse, <-chan error)
  • func (client *Client) OnsMqttQueryClientByTopic(request *OnsMqttQueryClientByTopicRequest) (response *OnsMqttQueryClientByTopicResponse, err error)
  • func (client *Client) OnsMqttQueryClientByTopicWithCallback(request *OnsMqttQueryClientByTopicRequest, ...) <-chan int
  • func (client *Client) OnsMqttQueryClientByTopicWithChan(request *OnsMqttQueryClientByTopicRequest) (<-chan *OnsMqttQueryClientByTopicResponse, <-chan error)
  • func (client *Client) OnsMqttQueryHistoryOnline(request *OnsMqttQueryHistoryOnlineRequest) (response *OnsMqttQueryHistoryOnlineResponse, err error)
  • func (client *Client) OnsMqttQueryHistoryOnlineWithCallback(request *OnsMqttQueryHistoryOnlineRequest, ...) <-chan int
  • func (client *Client) OnsMqttQueryHistoryOnlineWithChan(request *OnsMqttQueryHistoryOnlineRequest) (<-chan *OnsMqttQueryHistoryOnlineResponse, <-chan error)
  • func (client *Client) OnsMqttQueryMsgTransTrend(request *OnsMqttQueryMsgTransTrendRequest) (response *OnsMqttQueryMsgTransTrendResponse, err error)
  • func (client *Client) OnsMqttQueryMsgTransTrendWithCallback(request *OnsMqttQueryMsgTransTrendRequest, ...) <-chan int
  • func (client *Client) OnsMqttQueryMsgTransTrendWithChan(request *OnsMqttQueryMsgTransTrendRequest) (<-chan *OnsMqttQueryMsgTransTrendResponse, <-chan error)
  • func (client *Client) OnsRegionList(request *OnsRegionListRequest) (response *OnsRegionListResponse, err error)
  • func (client *Client) OnsRegionListWithCallback(request *OnsRegionListRequest, ...) <-chan int
  • func (client *Client) OnsRegionListWithChan(request *OnsRegionListRequest) (<-chan *OnsRegionListResponse, <-chan error)
  • func (client *Client) OnsTopicCreate(request *OnsTopicCreateRequest) (response *OnsTopicCreateResponse, err error)
  • func (client *Client) OnsTopicCreateWithCallback(request *OnsTopicCreateRequest, ...) <-chan int
  • func (client *Client) OnsTopicCreateWithChan(request *OnsTopicCreateRequest) (<-chan *OnsTopicCreateResponse, <-chan error)
  • func (client *Client) OnsTopicDelete(request *OnsTopicDeleteRequest) (response *OnsTopicDeleteResponse, err error)
  • func (client *Client) OnsTopicDeleteWithCallback(request *OnsTopicDeleteRequest, ...) <-chan int
  • func (client *Client) OnsTopicDeleteWithChan(request *OnsTopicDeleteRequest) (<-chan *OnsTopicDeleteResponse, <-chan error)
  • func (client *Client) OnsTopicList(request *OnsTopicListRequest) (response *OnsTopicListResponse, err error)
  • func (client *Client) OnsTopicListWithCallback(request *OnsTopicListRequest, ...) <-chan int
  • func (client *Client) OnsTopicListWithChan(request *OnsTopicListRequest) (<-chan *OnsTopicListResponse, <-chan error)
  • func (client *Client) OnsTopicStatus(request *OnsTopicStatusRequest) (response *OnsTopicStatusResponse, err error)
  • func (client *Client) OnsTopicStatusWithCallback(request *OnsTopicStatusRequest, ...) <-chan int
  • func (client *Client) OnsTopicStatusWithChan(request *OnsTopicStatusRequest) (<-chan *OnsTopicStatusResponse, <-chan error)
  • func (client *Client) OnsTopicUpdate(request *OnsTopicUpdateRequest) (response *OnsTopicUpdateResponse, err error)
  • func (client *Client) OnsTopicUpdateWithCallback(request *OnsTopicUpdateRequest, ...) <-chan int
  • func (client *Client) OnsTopicUpdateWithChan(request *OnsTopicUpdateRequest) (<-chan *OnsTopicUpdateResponse, <-chan error)
  • func (client *Client) OnsTraceGetResult(request *OnsTraceGetResultRequest) (response *OnsTraceGetResultResponse, err error)
  • func (client *Client) OnsTraceGetResultWithCallback(request *OnsTraceGetResultRequest, ...) <-chan int
  • func (client *Client) OnsTraceGetResultWithChan(request *OnsTraceGetResultRequest) (<-chan *OnsTraceGetResultResponse, <-chan error)
  • func (client *Client) OnsTraceQueryByMsgId(request *OnsTraceQueryByMsgIdRequest) (response *OnsTraceQueryByMsgIdResponse, err error)
  • func (client *Client) OnsTraceQueryByMsgIdWithCallback(request *OnsTraceQueryByMsgIdRequest, ...) <-chan int
  • func (client *Client) OnsTraceQueryByMsgIdWithChan(request *OnsTraceQueryByMsgIdRequest) (<-chan *OnsTraceQueryByMsgIdResponse, <-chan error)
  • func (client *Client) OnsTraceQueryByMsgKey(request *OnsTraceQueryByMsgKeyRequest) (response *OnsTraceQueryByMsgKeyResponse, err error)
  • func (client *Client) OnsTraceQueryByMsgKeyWithCallback(request *OnsTraceQueryByMsgKeyRequest, ...) <-chan int
  • func (client *Client) OnsTraceQueryByMsgKeyWithChan(request *OnsTraceQueryByMsgKeyRequest) (<-chan *OnsTraceQueryByMsgKeyResponse, <-chan error)
  • func (client *Client) OnsTrendGroupOutputTps(request *OnsTrendGroupOutputTpsRequest) (response *OnsTrendGroupOutputTpsResponse, err error)
  • func (client *Client) OnsTrendGroupOutputTpsWithCallback(request *OnsTrendGroupOutputTpsRequest, ...) <-chan int
  • func (client *Client) OnsTrendGroupOutputTpsWithChan(request *OnsTrendGroupOutputTpsRequest) (<-chan *OnsTrendGroupOutputTpsResponse, <-chan error)
  • func (client *Client) OnsTrendTopicInputTps(request *OnsTrendTopicInputTpsRequest) (response *OnsTrendTopicInputTpsResponse, err error)
  • func (client *Client) OnsTrendTopicInputTpsWithCallback(request *OnsTrendTopicInputTpsRequest, ...) <-chan int
  • func (client *Client) OnsTrendTopicInputTpsWithChan(request *OnsTrendTopicInputTpsRequest) (<-chan *OnsTrendTopicInputTpsResponse, <-chan error)
  • func (client *Client) OnsWarnCreate(request *OnsWarnCreateRequest) (response *OnsWarnCreateResponse, err error)
  • func (client *Client) OnsWarnCreateWithCallback(request *OnsWarnCreateRequest, ...) <-chan int
  • func (client *Client) OnsWarnCreateWithChan(request *OnsWarnCreateRequest) (<-chan *OnsWarnCreateResponse, <-chan error)
  • func (client *Client) OnsWarnDelete(request *OnsWarnDeleteRequest) (response *OnsWarnDeleteResponse, err error)
  • func (client *Client) OnsWarnDeleteWithCallback(request *OnsWarnDeleteRequest, ...) <-chan int
  • func (client *Client) OnsWarnDeleteWithChan(request *OnsWarnDeleteRequest) (<-chan *OnsWarnDeleteResponse, <-chan error)
• type ClientList
• type ConnectionDo
• type ConnectionList
• type ConnectionSet
• type ConsumerConnectionInfoDo
• type ConsumerConnectionInfoList
• type ConsumerRunningDataDo
• type Data
• type DataInOnsGroupList
• type DataInOnsInstanceInServiceList
• type DataInOnsMessageGetByKey
• type DataInOnsMessageTrace
• type DataInOnsMqttGroupIdList
• type DataInOnsRegionList
• type DataInOnsTopicList
• type DetailInTopicDo
• type DetailInTopicListInOnsConsumerAccumulate
• type DetailInTopicListInOnsConsumerStatus
• type Endpoints
• type InstanceBaseInfo
• type InstanceVO
• type Jstack
• type MessageProperty
• type MessageTrack
• type MqttClientInfoDo
• type MqttClientSetDo
• type MqttGroupIdDo
• type MsgFoundDo
• type MsgFoundList
• type OnsConsumerAccumulateRequest
  • func CreateOnsConsumerAccumulateRequest() (request *OnsConsumerAccumulateRequest)
• type OnsConsumerAccumulateResponse
  • func CreateOnsConsumerAccumulateResponse() (response *OnsConsumerAccumulateResponse)
• type OnsConsumerGetConnectionRequest
  • func CreateOnsConsumerGetConnectionRequest() (request *OnsConsumerGetConnectionRequest)
• type OnsConsumerGetConnectionResponse
  • func CreateOnsConsumerGetConnectionResponse() (response *OnsConsumerGetConnectionResponse)
• type OnsConsumerResetOffsetRequest
  • func CreateOnsConsumerResetOffsetRequest() (request *OnsConsumerResetOffsetRequest)
• type OnsConsumerResetOffsetResponse
  • func CreateOnsConsumerResetOffsetResponse() (response *OnsConsumerResetOffsetResponse)
• type OnsConsumerStatusRequest
  • func CreateOnsConsumerStatusRequest() (request *OnsConsumerStatusRequest)
• type OnsConsumerStatusResponse
  • func CreateOnsConsumerStatusResponse() (response *OnsConsumerStatusResponse)
• type OnsConsumerTimeSpanRequest
  • func CreateOnsConsumerTimeSpanRequest() (request *OnsConsumerTimeSpanRequest)
• type OnsConsumerTimeSpanResponse
  • func CreateOnsConsumerTimeSpanResponse() (response *OnsConsumerTimeSpanResponse)
• type OnsGroupConsumerUpdateRequest
  • func CreateOnsGroupConsumerUpdateRequest() (request *OnsGroupConsumerUpdateRequest)
• type OnsGroupConsumerUpdateResponse
  • func CreateOnsGroupConsumerUpdateResponse() (response *OnsGroupConsumerUpdateResponse)
• type OnsGroupCreateRequest
  • func CreateOnsGroupCreateRequest() (request *OnsGroupCreateRequest)
• type OnsGroupCreateResponse
  • func CreateOnsGroupCreateResponse() (response *OnsGroupCreateResponse)
• type OnsGroupDeleteRequest
  • func CreateOnsGroupDeleteRequest() (request *OnsGroupDeleteRequest)
• type OnsGroupDeleteResponse
  • func CreateOnsGroupDeleteResponse() (response *OnsGroupDeleteResponse)
• type OnsGroupListRequest
  • func CreateOnsGroupListRequest() (request *OnsGroupListRequest)
• type OnsGroupListResponse
  • func CreateOnsGroupListResponse() (response *OnsGroupListResponse)
• type OnsInstanceBaseInfoRequest
  • func CreateOnsInstanceBaseInfoRequest() (request *OnsInstanceBaseInfoRequest)
• type OnsInstanceBaseInfoResponse
  • func CreateOnsInstanceBaseInfoResponse() (response *OnsInstanceBaseInfoResponse)
• type OnsInstanceCreateRequest
  • func CreateOnsInstanceCreateRequest() (request *OnsInstanceCreateRequest)
• type OnsInstanceCreateResponse
  • func CreateOnsInstanceCreateResponse() (response *OnsInstanceCreateResponse)
• type OnsInstanceDeleteRequest
  • func CreateOnsInstanceDeleteRequest() (request *OnsInstanceDeleteRequest)
• type OnsInstanceDeleteResponse
  • func CreateOnsInstanceDeleteResponse() (response *OnsInstanceDeleteResponse)
• type OnsInstanceInServiceListRequest
  • func CreateOnsInstanceInServiceListRequest() (request *OnsInstanceInServiceListRequest)
• type OnsInstanceInServiceListResponse
  • func CreateOnsInstanceInServiceListResponse() (response *OnsInstanceInServiceListResponse)
• type OnsInstanceUpdateRequest
  • func CreateOnsInstanceUpdateRequest() (request *OnsInstanceUpdateRequest)
• type OnsInstanceUpdateResponse
  • func CreateOnsInstanceUpdateResponse() (response *OnsInstanceUpdateResponse)
• type OnsMessageGetByKeyRequest
  • func CreateOnsMessageGetByKeyRequest() (request *OnsMessageGetByKeyRequest)
• type OnsMessageGetByKeyResponse
  • func CreateOnsMessageGetByKeyResponse() (response *OnsMessageGetByKeyResponse)
• type OnsMessageGetByMsgIdRequest
  • func CreateOnsMessageGetByMsgIdRequest() (request *OnsMessageGetByMsgIdRequest)
• type OnsMessageGetByMsgIdResponse
  • func CreateOnsMessageGetByMsgIdResponse() (response *OnsMessageGetByMsgIdResponse)
• type OnsMessagePageQueryByTopicRequest
  • func CreateOnsMessagePageQueryByTopicRequest() (request *OnsMessagePageQueryByTopicRequest)
• type OnsMessagePageQueryByTopicResponse
  • func CreateOnsMessagePageQueryByTopicResponse() (response *OnsMessagePageQueryByTopicResponse)
• type OnsMessagePushRequest
  • func CreateOnsMessagePushRequest() (request *OnsMessagePushRequest)
• type OnsMessagePushResponse
  • func CreateOnsMessagePushResponse() (response *OnsMessagePushResponse)
• type OnsMessageSendRequest
  • func CreateOnsMessageSendRequest() (request *OnsMessageSendRequest)
• type OnsMessageSendResponse
  • func CreateOnsMessageSendResponse() (response *OnsMessageSendResponse)
• type OnsMessageTraceRequest
  • func CreateOnsMessageTraceRequest() (request *OnsMessageTraceRequest)
• type OnsMessageTraceResponse
  • func CreateOnsMessageTraceResponse() (response *OnsMessageTraceResponse)
• type OnsMqttGroupIdCreateRequest
  • func CreateOnsMqttGroupIdCreateRequest() (request *OnsMqttGroupIdCreateRequest)
• type OnsMqttGroupIdCreateResponse
  • func CreateOnsMqttGroupIdCreateResponse() (response *OnsMqttGroupIdCreateResponse)
• type OnsMqttGroupIdDeleteRequest
  • func CreateOnsMqttGroupIdDeleteRequest() (request *OnsMqttGroupIdDeleteRequest)
• type OnsMqttGroupIdDeleteResponse
  • func CreateOnsMqttGroupIdDeleteResponse() (response *OnsMqttGroupIdDeleteResponse)
• type OnsMqttGroupIdListRequest
  • func CreateOnsMqttGroupIdListRequest() (request *OnsMqttGroupIdListRequest)
• type OnsMqttGroupIdListResponse
  • func CreateOnsMqttGroupIdListResponse() (response *OnsMqttGroupIdListResponse)
• type OnsMqttQueryClientByClientIdRequest
  • func CreateOnsMqttQueryClientByClientIdRequest() (request *OnsMqttQueryClientByClientIdRequest)
• type OnsMqttQueryClientByClientIdResponse
  • func CreateOnsMqttQueryClientByClientIdResponse() (response *OnsMqttQueryClientByClientIdResponse)
• type OnsMqttQueryClientByGroupIdRequest
  • func CreateOnsMqttQueryClientByGroupIdRequest() (request *OnsMqttQueryClientByGroupIdRequest)
• type OnsMqttQueryClientByGroupIdResponse
  • func CreateOnsMqttQueryClientByGroupIdResponse() (response *OnsMqttQueryClientByGroupIdResponse)
• type OnsMqttQueryClientByTopicRequest
  • func CreateOnsMqttQueryClientByTopicRequest() (request *OnsMqttQueryClientByTopicRequest)
• type OnsMqttQueryClientByTopicResponse
  • func CreateOnsMqttQueryClientByTopicResponse() (response *OnsMqttQueryClientByTopicResponse)
• type OnsMqttQueryHistoryOnlineRequest
  • func CreateOnsMqttQueryHistoryOnlineRequest() (request *OnsMqttQueryHistoryOnlineRequest)
• type OnsMqttQueryHistoryOnlineResponse
  • func CreateOnsMqttQueryHistoryOnlineResponse() (response *OnsMqttQueryHistoryOnlineResponse)
• type OnsMqttQueryMsgTransTrendRequest
  • func CreateOnsMqttQueryMsgTransTrendRequest() (request *OnsMqttQueryMsgTransTrendRequest)
• type OnsMqttQueryMsgTransTrendResponse
  • func CreateOnsMqttQueryMsgTransTrendResponse() (response *OnsMqttQueryMsgTransTrendResponse)
• type OnsRegionListRequest
  • func CreateOnsRegionListRequest() (request *OnsRegionListRequest)
• type OnsRegionListResponse
  • func CreateOnsRegionListResponse() (response *OnsRegionListResponse)
• type OnsRestMessageDo
• type OnsTopicCreateRequest
  • func CreateOnsTopicCreateRequest() (request *OnsTopicCreateRequest)
• type OnsTopicCreateResponse
  • func CreateOnsTopicCreateResponse() (response *OnsTopicCreateResponse)
• type OnsTopicDeleteRequest
  • func CreateOnsTopicDeleteRequest() (request *OnsTopicDeleteRequest)
• type OnsTopicDeleteResponse
  • func CreateOnsTopicDeleteResponse() (response *OnsTopicDeleteResponse)
• type OnsTopicListRequest
  • func CreateOnsTopicListRequest() (request *OnsTopicListRequest)
• type OnsTopicListResponse
  • func CreateOnsTopicListResponse() (response *OnsTopicListResponse)
• type OnsTopicStatusRequest
  • func CreateOnsTopicStatusRequest() (request *OnsTopicStatusRequest)
• type OnsTopicStatusResponse
  • func CreateOnsTopicStatusResponse() (response *OnsTopicStatusResponse)
• type OnsTopicUpdateRequest
  • func CreateOnsTopicUpdateRequest() (request *OnsTopicUpdateRequest)
• type OnsTopicUpdateResponse
  • func CreateOnsTopicUpdateResponse() (response *OnsTopicUpdateResponse)
• type OnsTraceGetResultRequest
  • func CreateOnsTraceGetResultRequest() (request *OnsTraceGetResultRequest)
• type OnsTraceGetResultResponse
  • func CreateOnsTraceGetResultResponse() (response *OnsTraceGetResultResponse)
• type OnsTraceQueryByMsgIdRequest
  • func CreateOnsTraceQueryByMsgIdRequest() (request *OnsTraceQueryByMsgIdRequest)
• type OnsTraceQueryByMsgIdResponse
  • func CreateOnsTraceQueryByMsgIdResponse() (response *OnsTraceQueryByMsgIdResponse)
• type OnsTraceQueryByMsgKeyRequest
  • func CreateOnsTraceQueryByMsgKeyRequest() (request *OnsTraceQueryByMsgKeyRequest)
• type OnsTraceQueryByMsgKeyResponse
  • func CreateOnsTraceQueryByMsgKeyResponse() (response *OnsTraceQueryByMsgKeyResponse)
• type OnsTrendGroupOutputTpsRequest
  • func CreateOnsTrendGroupOutputTpsRequest() (request *OnsTrendGroupOutputTpsRequest)
• type OnsTrendGroupOutputTpsResponse
  • func CreateOnsTrendGroupOutputTpsResponse() (response *OnsTrendGroupOutputTpsResponse)
• type OnsTrendTopicInputTpsRequest
  • func CreateOnsTrendTopicInputTpsRequest() (request *OnsTrendTopicInputTpsRequest)
• type OnsTrendTopicInputTpsResponse
  • func CreateOnsTrendTopicInputTpsResponse() (response *OnsTrendTopicInputTpsResponse)
• type OnsWarnCreateRequest
  • func CreateOnsWarnCreateRequest() (request *OnsWarnCreateRequest)
• type OnsWarnCreateResponse
  • func CreateOnsWarnCreateResponse() (response *OnsWarnCreateResponse)
• type OnsWarnDeleteRequest
  • func CreateOnsWarnDeleteRequest() (request *OnsWarnDeleteRequest)
• type OnsWarnDeleteResponse
  • func CreateOnsWarnDeleteResponse() (response *OnsWarnDeleteResponse)
• type PropertyListInOnsMessageGetByKey
• type PropertyListInOnsMessageGetByMsgId
• type PropertyListInOnsMessagePageQueryByTopic
• type PublishInfoDo
• type RecordsInOnsMqttQueryHistoryOnline
• type RecordsInOnsMqttQueryMsgTransTrend
• type RecordsInOnsTrendGroupOutputTps
• type RecordsInOnsTrendTopicInputTps
• type RegionDo
• type RunningDataList
• type StatsDataDo
• type SubClientInfoDo
• type SubList
• type SubMapDo
• type SubScriptonData
• type SubscribeInfoDo
• type SubscriptionData
• type SubscriptionDo
• type SubscriptionSet
• type TagsSet
• type ThreadTrackDo
• type TraceData
• type TraceList
• type TraceMapDo
• type TrackList

Types

type Client

type Client struct {
	sdk.Client
}

Client is the sdk client struct, each func corresponds to an OpenAPI

func NewClient

func NewClient() (client *Client, err error)

NewClient creates a sdk client with environment variables

func NewClientWithAccessKey

func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)

NewClientWithAccessKey is a shortcut to create sdk client with accesskey usage: https://help.aliyun.com/document_detail/66217.html

func NewClientWithEcsRamRole

func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error)

NewClientWithEcsRamRole is a shortcut to create sdk client with ecs ram role usage: https://help.aliyun.com/document_detail/66223.html

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 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://help.aliyun.com/document_detail/66222.html

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 attention: rsa key pair auth is only Japan regions available

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://help.aliyun.com/document_detail/66222.html

func (*Client) OnsConsumerAccumulate

func (client *Client) OnsConsumerAccumulate(request *OnsConsumerAccumulateRequest) (response *OnsConsumerAccumulateResponse, err error)

OnsConsumerAccumulate invokes the ons.OnsConsumerAccumulate API synchronously api document: https://help.aliyun.com/api/ons/onsconsumeraccumulate.html

func (*Client) OnsConsumerAccumulateWithCallback

func (client *Client) OnsConsumerAccumulateWithCallback(request *OnsConsumerAccumulateRequest, callback func(response *OnsConsumerAccumulateResponse, err error)) <-chan int

OnsConsumerAccumulateWithCallback invokes the ons.OnsConsumerAccumulate API asynchronously api document: https://help.aliyun.com/api/ons/onsconsumeraccumulate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsConsumerAccumulateWithChan

func (client *Client) OnsConsumerAccumulateWithChan(request *OnsConsumerAccumulateRequest) (<-chan *OnsConsumerAccumulateResponse, <-chan error)

OnsConsumerAccumulateWithChan invokes the ons.OnsConsumerAccumulate API asynchronously api document: https://help.aliyun.com/api/ons/onsconsumeraccumulate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsConsumerGetConnection

func (client *Client) OnsConsumerGetConnection(request *OnsConsumerGetConnectionRequest) (response *OnsConsumerGetConnectionResponse, err error)

OnsConsumerGetConnection invokes the ons.OnsConsumerGetConnection API synchronously api document: https://help.aliyun.com/api/ons/onsconsumergetconnection.html

func (*Client) OnsConsumerGetConnectionWithCallback

func (client *Client) OnsConsumerGetConnectionWithCallback(request *OnsConsumerGetConnectionRequest, callback func(response *OnsConsumerGetConnectionResponse, err error)) <-chan int

OnsConsumerGetConnectionWithCallback invokes the ons.OnsConsumerGetConnection API asynchronously api document: https://help.aliyun.com/api/ons/onsconsumergetconnection.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsConsumerGetConnectionWithChan

func (client *Client) OnsConsumerGetConnectionWithChan(request *OnsConsumerGetConnectionRequest) (<-chan *OnsConsumerGetConnectionResponse, <-chan error)

OnsConsumerGetConnectionWithChan invokes the ons.OnsConsumerGetConnection API asynchronously api document: https://help.aliyun.com/api/ons/onsconsumergetconnection.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsConsumerResetOffset

func (client *Client) OnsConsumerResetOffset(request *OnsConsumerResetOffsetRequest) (response *OnsConsumerResetOffsetResponse, err error)

OnsConsumerResetOffset invokes the ons.OnsConsumerResetOffset API synchronously api document: https://help.aliyun.com/api/ons/onsconsumerresetoffset.html

func (*Client) OnsConsumerResetOffsetWithCallback

func (client *Client) OnsConsumerResetOffsetWithCallback(request *OnsConsumerResetOffsetRequest, callback func(response *OnsConsumerResetOffsetResponse, err error)) <-chan int

OnsConsumerResetOffsetWithCallback invokes the ons.OnsConsumerResetOffset API asynchronously api document: https://help.aliyun.com/api/ons/onsconsumerresetoffset.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsConsumerResetOffsetWithChan

func (client *Client) OnsConsumerResetOffsetWithChan(request *OnsConsumerResetOffsetRequest) (<-chan *OnsConsumerResetOffsetResponse, <-chan error)

OnsConsumerResetOffsetWithChan invokes the ons.OnsConsumerResetOffset API asynchronously api document: https://help.aliyun.com/api/ons/onsconsumerresetoffset.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsConsumerStatus

func (client *Client) OnsConsumerStatus(request *OnsConsumerStatusRequest) (response *OnsConsumerStatusResponse, err error)

OnsConsumerStatus invokes the ons.OnsConsumerStatus API synchronously api document: https://help.aliyun.com/api/ons/onsconsumerstatus.html

func (*Client) OnsConsumerStatusWithCallback

func (client *Client) OnsConsumerStatusWithCallback(request *OnsConsumerStatusRequest, callback func(response *OnsConsumerStatusResponse, err error)) <-chan int

OnsConsumerStatusWithCallback invokes the ons.OnsConsumerStatus API asynchronously api document: https://help.aliyun.com/api/ons/onsconsumerstatus.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsConsumerStatusWithChan

func (client *Client) OnsConsumerStatusWithChan(request *OnsConsumerStatusRequest) (<-chan *OnsConsumerStatusResponse, <-chan error)

OnsConsumerStatusWithChan invokes the ons.OnsConsumerStatus API asynchronously api document: https://help.aliyun.com/api/ons/onsconsumerstatus.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsConsumerTimeSpan

func (client *Client) OnsConsumerTimeSpan(request *OnsConsumerTimeSpanRequest) (response *OnsConsumerTimeSpanResponse, err error)

OnsConsumerTimeSpan invokes the ons.OnsConsumerTimeSpan API synchronously api document: https://help.aliyun.com/api/ons/onsconsumertimespan.html

func (*Client) OnsConsumerTimeSpanWithCallback

func (client *Client) OnsConsumerTimeSpanWithCallback(request *OnsConsumerTimeSpanRequest, callback func(response *OnsConsumerTimeSpanResponse, err error)) <-chan int

OnsConsumerTimeSpanWithCallback invokes the ons.OnsConsumerTimeSpan API asynchronously api document: https://help.aliyun.com/api/ons/onsconsumertimespan.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsConsumerTimeSpanWithChan

func (client *Client) OnsConsumerTimeSpanWithChan(request *OnsConsumerTimeSpanRequest) (<-chan *OnsConsumerTimeSpanResponse, <-chan error)

OnsConsumerTimeSpanWithChan invokes the ons.OnsConsumerTimeSpan API asynchronously api document: https://help.aliyun.com/api/ons/onsconsumertimespan.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsGroupConsumerUpdate

func (client *Client) OnsGroupConsumerUpdate(request *OnsGroupConsumerUpdateRequest) (response *OnsGroupConsumerUpdateResponse, err error)

OnsGroupConsumerUpdate invokes the ons.OnsGroupConsumerUpdate API synchronously api document: https://help.aliyun.com/api/ons/onsgroupconsumerupdate.html

func (*Client) OnsGroupConsumerUpdateWithCallback

func (client *Client) OnsGroupConsumerUpdateWithCallback(request *OnsGroupConsumerUpdateRequest, callback func(response *OnsGroupConsumerUpdateResponse, err error)) <-chan int

OnsGroupConsumerUpdateWithCallback invokes the ons.OnsGroupConsumerUpdate API asynchronously api document: https://help.aliyun.com/api/ons/onsgroupconsumerupdate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsGroupConsumerUpdateWithChan

func (client *Client) OnsGroupConsumerUpdateWithChan(request *OnsGroupConsumerUpdateRequest) (<-chan *OnsGroupConsumerUpdateResponse, <-chan error)

OnsGroupConsumerUpdateWithChan invokes the ons.OnsGroupConsumerUpdate API asynchronously api document: https://help.aliyun.com/api/ons/onsgroupconsumerupdate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsGroupCreate

func (client *Client) OnsGroupCreate(request *OnsGroupCreateRequest) (response *OnsGroupCreateResponse, err error)

OnsGroupCreate invokes the ons.OnsGroupCreate API synchronously api document: https://help.aliyun.com/api/ons/onsgroupcreate.html

func (*Client) OnsGroupCreateWithCallback

func (client *Client) OnsGroupCreateWithCallback(request *OnsGroupCreateRequest, callback func(response *OnsGroupCreateResponse, err error)) <-chan int

OnsGroupCreateWithCallback invokes the ons.OnsGroupCreate API asynchronously api document: https://help.aliyun.com/api/ons/onsgroupcreate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsGroupCreateWithChan

func (client *Client) OnsGroupCreateWithChan(request *OnsGroupCreateRequest) (<-chan *OnsGroupCreateResponse, <-chan error)

OnsGroupCreateWithChan invokes the ons.OnsGroupCreate API asynchronously api document: https://help.aliyun.com/api/ons/onsgroupcreate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsGroupDelete

func (client *Client) OnsGroupDelete(request *OnsGroupDeleteRequest) (response *OnsGroupDeleteResponse, err error)

OnsGroupDelete invokes the ons.OnsGroupDelete API synchronously api document: https://help.aliyun.com/api/ons/onsgroupdelete.html

func (*Client) OnsGroupDeleteWithCallback

func (client *Client) OnsGroupDeleteWithCallback(request *OnsGroupDeleteRequest, callback func(response *OnsGroupDeleteResponse, err error)) <-chan int

OnsGroupDeleteWithCallback invokes the ons.OnsGroupDelete API asynchronously api document: https://help.aliyun.com/api/ons/onsgroupdelete.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsGroupDeleteWithChan

func (client *Client) OnsGroupDeleteWithChan(request *OnsGroupDeleteRequest) (<-chan *OnsGroupDeleteResponse, <-chan error)

OnsGroupDeleteWithChan invokes the ons.OnsGroupDelete API asynchronously api document: https://help.aliyun.com/api/ons/onsgroupdelete.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsGroupList

func (client *Client) OnsGroupList(request *OnsGroupListRequest) (response *OnsGroupListResponse, err error)

OnsGroupList invokes the ons.OnsGroupList API synchronously api document: https://help.aliyun.com/api/ons/onsgrouplist.html

func (*Client) OnsGroupListWithCallback

func (client *Client) OnsGroupListWithCallback(request *OnsGroupListRequest, callback func(response *OnsGroupListResponse, err error)) <-chan int

OnsGroupListWithCallback invokes the ons.OnsGroupList API asynchronously api document: https://help.aliyun.com/api/ons/onsgrouplist.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsGroupListWithChan

func (client *Client) OnsGroupListWithChan(request *OnsGroupListRequest) (<-chan *OnsGroupListResponse, <-chan error)

OnsGroupListWithChan invokes the ons.OnsGroupList API asynchronously api document: https://help.aliyun.com/api/ons/onsgrouplist.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsInstanceBaseInfo

func (client *Client) OnsInstanceBaseInfo(request *OnsInstanceBaseInfoRequest) (response *OnsInstanceBaseInfoResponse, err error)

OnsInstanceBaseInfo invokes the ons.OnsInstanceBaseInfo API synchronously api document: https://help.aliyun.com/api/ons/onsinstancebaseinfo.html

func (*Client) OnsInstanceBaseInfoWithCallback

func (client *Client) OnsInstanceBaseInfoWithCallback(request *OnsInstanceBaseInfoRequest, callback func(response *OnsInstanceBaseInfoResponse, err error)) <-chan int

OnsInstanceBaseInfoWithCallback invokes the ons.OnsInstanceBaseInfo API asynchronously api document: https://help.aliyun.com/api/ons/onsinstancebaseinfo.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsInstanceBaseInfoWithChan

func (client *Client) OnsInstanceBaseInfoWithChan(request *OnsInstanceBaseInfoRequest) (<-chan *OnsInstanceBaseInfoResponse, <-chan error)

OnsInstanceBaseInfoWithChan invokes the ons.OnsInstanceBaseInfo API asynchronously api document: https://help.aliyun.com/api/ons/onsinstancebaseinfo.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsInstanceCreate

func (client *Client) OnsInstanceCreate(request *OnsInstanceCreateRequest) (response *OnsInstanceCreateResponse, err error)

OnsInstanceCreate invokes the ons.OnsInstanceCreate API synchronously api document: https://help.aliyun.com/api/ons/onsinstancecreate.html

func (*Client) OnsInstanceCreateWithCallback

func (client *Client) OnsInstanceCreateWithCallback(request *OnsInstanceCreateRequest, callback func(response *OnsInstanceCreateResponse, err error)) <-chan int

OnsInstanceCreateWithCallback invokes the ons.OnsInstanceCreate API asynchronously api document: https://help.aliyun.com/api/ons/onsinstancecreate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsInstanceCreateWithChan

func (client *Client) OnsInstanceCreateWithChan(request *OnsInstanceCreateRequest) (<-chan *OnsInstanceCreateResponse, <-chan error)

OnsInstanceCreateWithChan invokes the ons.OnsInstanceCreate API asynchronously api document: https://help.aliyun.com/api/ons/onsinstancecreate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsInstanceDelete

func (client *Client) OnsInstanceDelete(request *OnsInstanceDeleteRequest) (response *OnsInstanceDeleteResponse, err error)

OnsInstanceDelete invokes the ons.OnsInstanceDelete API synchronously api document: https://help.aliyun.com/api/ons/onsinstancedelete.html

func (*Client) OnsInstanceDeleteWithCallback

func (client *Client) OnsInstanceDeleteWithCallback(request *OnsInstanceDeleteRequest, callback func(response *OnsInstanceDeleteResponse, err error)) <-chan int

OnsInstanceDeleteWithCallback invokes the ons.OnsInstanceDelete API asynchronously api document: https://help.aliyun.com/api/ons/onsinstancedelete.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsInstanceDeleteWithChan

func (client *Client) OnsInstanceDeleteWithChan(request *OnsInstanceDeleteRequest) (<-chan *OnsInstanceDeleteResponse, <-chan error)

OnsInstanceDeleteWithChan invokes the ons.OnsInstanceDelete API asynchronously api document: https://help.aliyun.com/api/ons/onsinstancedelete.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsInstanceInServiceList

func (client *Client) OnsInstanceInServiceList(request *OnsInstanceInServiceListRequest) (response *OnsInstanceInServiceListResponse, err error)

OnsInstanceInServiceList invokes the ons.OnsInstanceInServiceList API synchronously api document: https://help.aliyun.com/api/ons/onsinstanceinservicelist.html

func (*Client) OnsInstanceInServiceListWithCallback

func (client *Client) OnsInstanceInServiceListWithCallback(request *OnsInstanceInServiceListRequest, callback func(response *OnsInstanceInServiceListResponse, err error)) <-chan int

OnsInstanceInServiceListWithCallback invokes the ons.OnsInstanceInServiceList API asynchronously api document: https://help.aliyun.com/api/ons/onsinstanceinservicelist.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsInstanceInServiceListWithChan

func (client *Client) OnsInstanceInServiceListWithChan(request *OnsInstanceInServiceListRequest) (<-chan *OnsInstanceInServiceListResponse, <-chan error)

OnsInstanceInServiceListWithChan invokes the ons.OnsInstanceInServiceList API asynchronously api document: https://help.aliyun.com/api/ons/onsinstanceinservicelist.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsInstanceUpdate

func (client *Client) OnsInstanceUpdate(request *OnsInstanceUpdateRequest) (response *OnsInstanceUpdateResponse, err error)

OnsInstanceUpdate invokes the ons.OnsInstanceUpdate API synchronously api document: https://help.aliyun.com/api/ons/onsinstanceupdate.html

func (*Client) OnsInstanceUpdateWithCallback

func (client *Client) OnsInstanceUpdateWithCallback(request *OnsInstanceUpdateRequest, callback func(response *OnsInstanceUpdateResponse, err error)) <-chan int

OnsInstanceUpdateWithCallback invokes the ons.OnsInstanceUpdate API asynchronously api document: https://help.aliyun.com/api/ons/onsinstanceupdate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsInstanceUpdateWithChan

func (client *Client) OnsInstanceUpdateWithChan(request *OnsInstanceUpdateRequest) (<-chan *OnsInstanceUpdateResponse, <-chan error)

OnsInstanceUpdateWithChan invokes the ons.OnsInstanceUpdate API asynchronously api document: https://help.aliyun.com/api/ons/onsinstanceupdate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessageGetByKey

func (client *Client) OnsMessageGetByKey(request *OnsMessageGetByKeyRequest) (response *OnsMessageGetByKeyResponse, err error)

OnsMessageGetByKey invokes the ons.OnsMessageGetByKey API synchronously api document: https://help.aliyun.com/api/ons/onsmessagegetbykey.html

func (*Client) OnsMessageGetByKeyWithCallback

func (client *Client) OnsMessageGetByKeyWithCallback(request *OnsMessageGetByKeyRequest, callback func(response *OnsMessageGetByKeyResponse, err error)) <-chan int

OnsMessageGetByKeyWithCallback invokes the ons.OnsMessageGetByKey API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagegetbykey.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessageGetByKeyWithChan

func (client *Client) OnsMessageGetByKeyWithChan(request *OnsMessageGetByKeyRequest) (<-chan *OnsMessageGetByKeyResponse, <-chan error)

OnsMessageGetByKeyWithChan invokes the ons.OnsMessageGetByKey API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagegetbykey.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessageGetByMsgId

func (client *Client) OnsMessageGetByMsgId(request *OnsMessageGetByMsgIdRequest) (response *OnsMessageGetByMsgIdResponse, err error)

OnsMessageGetByMsgId invokes the ons.OnsMessageGetByMsgId API synchronously api document: https://help.aliyun.com/api/ons/onsmessagegetbymsgid.html

func (*Client) OnsMessageGetByMsgIdWithCallback

func (client *Client) OnsMessageGetByMsgIdWithCallback(request *OnsMessageGetByMsgIdRequest, callback func(response *OnsMessageGetByMsgIdResponse, err error)) <-chan int

OnsMessageGetByMsgIdWithCallback invokes the ons.OnsMessageGetByMsgId API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagegetbymsgid.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessageGetByMsgIdWithChan

func (client *Client) OnsMessageGetByMsgIdWithChan(request *OnsMessageGetByMsgIdRequest) (<-chan *OnsMessageGetByMsgIdResponse, <-chan error)

OnsMessageGetByMsgIdWithChan invokes the ons.OnsMessageGetByMsgId API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagegetbymsgid.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessagePageQueryByTopic

func (client *Client) OnsMessagePageQueryByTopic(request *OnsMessagePageQueryByTopicRequest) (response *OnsMessagePageQueryByTopicResponse, err error)

OnsMessagePageQueryByTopic invokes the ons.OnsMessagePageQueryByTopic API synchronously api document: https://help.aliyun.com/api/ons/onsmessagepagequerybytopic.html

func (*Client) OnsMessagePageQueryByTopicWithCallback

func (client *Client) OnsMessagePageQueryByTopicWithCallback(request *OnsMessagePageQueryByTopicRequest, callback func(response *OnsMessagePageQueryByTopicResponse, err error)) <-chan int

OnsMessagePageQueryByTopicWithCallback invokes the ons.OnsMessagePageQueryByTopic API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagepagequerybytopic.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessagePageQueryByTopicWithChan

func (client *Client) OnsMessagePageQueryByTopicWithChan(request *OnsMessagePageQueryByTopicRequest) (<-chan *OnsMessagePageQueryByTopicResponse, <-chan error)

OnsMessagePageQueryByTopicWithChan invokes the ons.OnsMessagePageQueryByTopic API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagepagequerybytopic.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessagePush

func (client *Client) OnsMessagePush(request *OnsMessagePushRequest) (response *OnsMessagePushResponse, err error)

OnsMessagePush invokes the ons.OnsMessagePush API synchronously api document: https://help.aliyun.com/api/ons/onsmessagepush.html

func (*Client) OnsMessagePushWithCallback

func (client *Client) OnsMessagePushWithCallback(request *OnsMessagePushRequest, callback func(response *OnsMessagePushResponse, err error)) <-chan int

OnsMessagePushWithCallback invokes the ons.OnsMessagePush API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagepush.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessagePushWithChan

func (client *Client) OnsMessagePushWithChan(request *OnsMessagePushRequest) (<-chan *OnsMessagePushResponse, <-chan error)

OnsMessagePushWithChan invokes the ons.OnsMessagePush API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagepush.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessageSend

func (client *Client) OnsMessageSend(request *OnsMessageSendRequest) (response *OnsMessageSendResponse, err error)

OnsMessageSend invokes the ons.OnsMessageSend API synchronously api document: https://help.aliyun.com/api/ons/onsmessagesend.html

func (*Client) OnsMessageSendWithCallback

func (client *Client) OnsMessageSendWithCallback(request *OnsMessageSendRequest, callback func(response *OnsMessageSendResponse, err error)) <-chan int

OnsMessageSendWithCallback invokes the ons.OnsMessageSend API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagesend.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessageSendWithChan

func (client *Client) OnsMessageSendWithChan(request *OnsMessageSendRequest) (<-chan *OnsMessageSendResponse, <-chan error)

OnsMessageSendWithChan invokes the ons.OnsMessageSend API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagesend.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessageTrace

func (client *Client) OnsMessageTrace(request *OnsMessageTraceRequest) (response *OnsMessageTraceResponse, err error)

OnsMessageTrace invokes the ons.OnsMessageTrace API synchronously api document: https://help.aliyun.com/api/ons/onsmessagetrace.html

func (*Client) OnsMessageTraceWithCallback

func (client *Client) OnsMessageTraceWithCallback(request *OnsMessageTraceRequest, callback func(response *OnsMessageTraceResponse, err error)) <-chan int

OnsMessageTraceWithCallback invokes the ons.OnsMessageTrace API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagetrace.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMessageTraceWithChan

func (client *Client) OnsMessageTraceWithChan(request *OnsMessageTraceRequest) (<-chan *OnsMessageTraceResponse, <-chan error)

OnsMessageTraceWithChan invokes the ons.OnsMessageTrace API asynchronously api document: https://help.aliyun.com/api/ons/onsmessagetrace.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttGroupIdCreate

func (client *Client) OnsMqttGroupIdCreate(request *OnsMqttGroupIdCreateRequest) (response *OnsMqttGroupIdCreateResponse, err error)

OnsMqttGroupIdCreate invokes the ons.OnsMqttGroupIdCreate API synchronously api document: https://help.aliyun.com/api/ons/onsmqttgroupidcreate.html

func (*Client) OnsMqttGroupIdCreateWithCallback

func (client *Client) OnsMqttGroupIdCreateWithCallback(request *OnsMqttGroupIdCreateRequest, callback func(response *OnsMqttGroupIdCreateResponse, err error)) <-chan int

OnsMqttGroupIdCreateWithCallback invokes the ons.OnsMqttGroupIdCreate API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttgroupidcreate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttGroupIdCreateWithChan

func (client *Client) OnsMqttGroupIdCreateWithChan(request *OnsMqttGroupIdCreateRequest) (<-chan *OnsMqttGroupIdCreateResponse, <-chan error)

OnsMqttGroupIdCreateWithChan invokes the ons.OnsMqttGroupIdCreate API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttgroupidcreate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttGroupIdDelete

func (client *Client) OnsMqttGroupIdDelete(request *OnsMqttGroupIdDeleteRequest) (response *OnsMqttGroupIdDeleteResponse, err error)

OnsMqttGroupIdDelete invokes the ons.OnsMqttGroupIdDelete API synchronously api document: https://help.aliyun.com/api/ons/onsmqttgroupiddelete.html

func (*Client) OnsMqttGroupIdDeleteWithCallback

func (client *Client) OnsMqttGroupIdDeleteWithCallback(request *OnsMqttGroupIdDeleteRequest, callback func(response *OnsMqttGroupIdDeleteResponse, err error)) <-chan int

OnsMqttGroupIdDeleteWithCallback invokes the ons.OnsMqttGroupIdDelete API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttgroupiddelete.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttGroupIdDeleteWithChan

func (client *Client) OnsMqttGroupIdDeleteWithChan(request *OnsMqttGroupIdDeleteRequest) (<-chan *OnsMqttGroupIdDeleteResponse, <-chan error)

OnsMqttGroupIdDeleteWithChan invokes the ons.OnsMqttGroupIdDelete API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttgroupiddelete.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttGroupIdList

func (client *Client) OnsMqttGroupIdList(request *OnsMqttGroupIdListRequest) (response *OnsMqttGroupIdListResponse, err error)

OnsMqttGroupIdList invokes the ons.OnsMqttGroupIdList API synchronously api document: https://help.aliyun.com/api/ons/onsmqttgroupidlist.html

func (*Client) OnsMqttGroupIdListWithCallback

func (client *Client) OnsMqttGroupIdListWithCallback(request *OnsMqttGroupIdListRequest, callback func(response *OnsMqttGroupIdListResponse, err error)) <-chan int

OnsMqttGroupIdListWithCallback invokes the ons.OnsMqttGroupIdList API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttgroupidlist.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttGroupIdListWithChan

func (client *Client) OnsMqttGroupIdListWithChan(request *OnsMqttGroupIdListRequest) (<-chan *OnsMqttGroupIdListResponse, <-chan error)

OnsMqttGroupIdListWithChan invokes the ons.OnsMqttGroupIdList API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttgroupidlist.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttQueryClientByClientId

func (client *Client) OnsMqttQueryClientByClientId(request *OnsMqttQueryClientByClientIdRequest) (response *OnsMqttQueryClientByClientIdResponse, err error)

OnsMqttQueryClientByClientId invokes the ons.OnsMqttQueryClientByClientId API synchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryclientbyclientid.html

func (*Client) OnsMqttQueryClientByClientIdWithCallback

func (client *Client) OnsMqttQueryClientByClientIdWithCallback(request *OnsMqttQueryClientByClientIdRequest, callback func(response *OnsMqttQueryClientByClientIdResponse, err error)) <-chan int

OnsMqttQueryClientByClientIdWithCallback invokes the ons.OnsMqttQueryClientByClientId API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryclientbyclientid.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttQueryClientByClientIdWithChan

func (client *Client) OnsMqttQueryClientByClientIdWithChan(request *OnsMqttQueryClientByClientIdRequest) (<-chan *OnsMqttQueryClientByClientIdResponse, <-chan error)

OnsMqttQueryClientByClientIdWithChan invokes the ons.OnsMqttQueryClientByClientId API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryclientbyclientid.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttQueryClientByGroupId

func (client *Client) OnsMqttQueryClientByGroupId(request *OnsMqttQueryClientByGroupIdRequest) (response *OnsMqttQueryClientByGroupIdResponse, err error)

OnsMqttQueryClientByGroupId invokes the ons.OnsMqttQueryClientByGroupId API synchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryclientbygroupid.html

func (*Client) OnsMqttQueryClientByGroupIdWithCallback

func (client *Client) OnsMqttQueryClientByGroupIdWithCallback(request *OnsMqttQueryClientByGroupIdRequest, callback func(response *OnsMqttQueryClientByGroupIdResponse, err error)) <-chan int

OnsMqttQueryClientByGroupIdWithCallback invokes the ons.OnsMqttQueryClientByGroupId API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryclientbygroupid.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttQueryClientByGroupIdWithChan

func (client *Client) OnsMqttQueryClientByGroupIdWithChan(request *OnsMqttQueryClientByGroupIdRequest) (<-chan *OnsMqttQueryClientByGroupIdResponse, <-chan error)

OnsMqttQueryClientByGroupIdWithChan invokes the ons.OnsMqttQueryClientByGroupId API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryclientbygroupid.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttQueryClientByTopic

func (client *Client) OnsMqttQueryClientByTopic(request *OnsMqttQueryClientByTopicRequest) (response *OnsMqttQueryClientByTopicResponse, err error)

OnsMqttQueryClientByTopic invokes the ons.OnsMqttQueryClientByTopic API synchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryclientbytopic.html

func (*Client) OnsMqttQueryClientByTopicWithCallback

func (client *Client) OnsMqttQueryClientByTopicWithCallback(request *OnsMqttQueryClientByTopicRequest, callback func(response *OnsMqttQueryClientByTopicResponse, err error)) <-chan int

OnsMqttQueryClientByTopicWithCallback invokes the ons.OnsMqttQueryClientByTopic API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryclientbytopic.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttQueryClientByTopicWithChan

func (client *Client) OnsMqttQueryClientByTopicWithChan(request *OnsMqttQueryClientByTopicRequest) (<-chan *OnsMqttQueryClientByTopicResponse, <-chan error)

OnsMqttQueryClientByTopicWithChan invokes the ons.OnsMqttQueryClientByTopic API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryclientbytopic.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttQueryHistoryOnline

func (client *Client) OnsMqttQueryHistoryOnline(request *OnsMqttQueryHistoryOnlineRequest) (response *OnsMqttQueryHistoryOnlineResponse, err error)

OnsMqttQueryHistoryOnline invokes the ons.OnsMqttQueryHistoryOnline API synchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryhistoryonline.html

func (*Client) OnsMqttQueryHistoryOnlineWithCallback

func (client *Client) OnsMqttQueryHistoryOnlineWithCallback(request *OnsMqttQueryHistoryOnlineRequest, callback func(response *OnsMqttQueryHistoryOnlineResponse, err error)) <-chan int

OnsMqttQueryHistoryOnlineWithCallback invokes the ons.OnsMqttQueryHistoryOnline API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryhistoryonline.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttQueryHistoryOnlineWithChan

func (client *Client) OnsMqttQueryHistoryOnlineWithChan(request *OnsMqttQueryHistoryOnlineRequest) (<-chan *OnsMqttQueryHistoryOnlineResponse, <-chan error)

OnsMqttQueryHistoryOnlineWithChan invokes the ons.OnsMqttQueryHistoryOnline API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttqueryhistoryonline.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttQueryMsgTransTrend

func (client *Client) OnsMqttQueryMsgTransTrend(request *OnsMqttQueryMsgTransTrendRequest) (response *OnsMqttQueryMsgTransTrendResponse, err error)

OnsMqttQueryMsgTransTrend invokes the ons.OnsMqttQueryMsgTransTrend API synchronously api document: https://help.aliyun.com/api/ons/onsmqttquerymsgtranstrend.html

func (*Client) OnsMqttQueryMsgTransTrendWithCallback

func (client *Client) OnsMqttQueryMsgTransTrendWithCallback(request *OnsMqttQueryMsgTransTrendRequest, callback func(response *OnsMqttQueryMsgTransTrendResponse, err error)) <-chan int

OnsMqttQueryMsgTransTrendWithCallback invokes the ons.OnsMqttQueryMsgTransTrend API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttquerymsgtranstrend.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsMqttQueryMsgTransTrendWithChan

func (client *Client) OnsMqttQueryMsgTransTrendWithChan(request *OnsMqttQueryMsgTransTrendRequest) (<-chan *OnsMqttQueryMsgTransTrendResponse, <-chan error)

OnsMqttQueryMsgTransTrendWithChan invokes the ons.OnsMqttQueryMsgTransTrend API asynchronously api document: https://help.aliyun.com/api/ons/onsmqttquerymsgtranstrend.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsRegionList

func (client *Client) OnsRegionList(request *OnsRegionListRequest) (response *OnsRegionListResponse, err error)

OnsRegionList invokes the ons.OnsRegionList API synchronously api document: https://help.aliyun.com/api/ons/onsregionlist.html

func (*Client) OnsRegionListWithCallback

func (client *Client) OnsRegionListWithCallback(request *OnsRegionListRequest, callback func(response *OnsRegionListResponse, err error)) <-chan int

OnsRegionListWithCallback invokes the ons.OnsRegionList API asynchronously api document: https://help.aliyun.com/api/ons/onsregionlist.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsRegionListWithChan

func (client *Client) OnsRegionListWithChan(request *OnsRegionListRequest) (<-chan *OnsRegionListResponse, <-chan error)

OnsRegionListWithChan invokes the ons.OnsRegionList API asynchronously api document: https://help.aliyun.com/api/ons/onsregionlist.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTopicCreate

func (client *Client) OnsTopicCreate(request *OnsTopicCreateRequest) (response *OnsTopicCreateResponse, err error)

OnsTopicCreate invokes the ons.OnsTopicCreate API synchronously api document: https://help.aliyun.com/api/ons/onstopiccreate.html

func (*Client) OnsTopicCreateWithCallback

func (client *Client) OnsTopicCreateWithCallback(request *OnsTopicCreateRequest, callback func(response *OnsTopicCreateResponse, err error)) <-chan int

OnsTopicCreateWithCallback invokes the ons.OnsTopicCreate API asynchronously api document: https://help.aliyun.com/api/ons/onstopiccreate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTopicCreateWithChan

func (client *Client) OnsTopicCreateWithChan(request *OnsTopicCreateRequest) (<-chan *OnsTopicCreateResponse, <-chan error)

OnsTopicCreateWithChan invokes the ons.OnsTopicCreate API asynchronously api document: https://help.aliyun.com/api/ons/onstopiccreate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTopicDelete

func (client *Client) OnsTopicDelete(request *OnsTopicDeleteRequest) (response *OnsTopicDeleteResponse, err error)

OnsTopicDelete invokes the ons.OnsTopicDelete API synchronously api document: https://help.aliyun.com/api/ons/onstopicdelete.html

func (*Client) OnsTopicDeleteWithCallback

func (client *Client) OnsTopicDeleteWithCallback(request *OnsTopicDeleteRequest, callback func(response *OnsTopicDeleteResponse, err error)) <-chan int

OnsTopicDeleteWithCallback invokes the ons.OnsTopicDelete API asynchronously api document: https://help.aliyun.com/api/ons/onstopicdelete.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTopicDeleteWithChan

func (client *Client) OnsTopicDeleteWithChan(request *OnsTopicDeleteRequest) (<-chan *OnsTopicDeleteResponse, <-chan error)

OnsTopicDeleteWithChan invokes the ons.OnsTopicDelete API asynchronously api document: https://help.aliyun.com/api/ons/onstopicdelete.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTopicList

func (client *Client) OnsTopicList(request *OnsTopicListRequest) (response *OnsTopicListResponse, err error)

OnsTopicList invokes the ons.OnsTopicList API synchronously api document: https://help.aliyun.com/api/ons/onstopiclist.html

func (*Client) OnsTopicListWithCallback

func (client *Client) OnsTopicListWithCallback(request *OnsTopicListRequest, callback func(response *OnsTopicListResponse, err error)) <-chan int

OnsTopicListWithCallback invokes the ons.OnsTopicList API asynchronously api document: https://help.aliyun.com/api/ons/onstopiclist.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTopicListWithChan

func (client *Client) OnsTopicListWithChan(request *OnsTopicListRequest) (<-chan *OnsTopicListResponse, <-chan error)

OnsTopicListWithChan invokes the ons.OnsTopicList API asynchronously api document: https://help.aliyun.com/api/ons/onstopiclist.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTopicStatus

func (client *Client) OnsTopicStatus(request *OnsTopicStatusRequest) (response *OnsTopicStatusResponse, err error)

OnsTopicStatus invokes the ons.OnsTopicStatus API synchronously api document: https://help.aliyun.com/api/ons/onstopicstatus.html

func (*Client) OnsTopicStatusWithCallback

func (client *Client) OnsTopicStatusWithCallback(request *OnsTopicStatusRequest, callback func(response *OnsTopicStatusResponse, err error)) <-chan int

OnsTopicStatusWithCallback invokes the ons.OnsTopicStatus API asynchronously api document: https://help.aliyun.com/api/ons/onstopicstatus.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTopicStatusWithChan

func (client *Client) OnsTopicStatusWithChan(request *OnsTopicStatusRequest) (<-chan *OnsTopicStatusResponse, <-chan error)

OnsTopicStatusWithChan invokes the ons.OnsTopicStatus API asynchronously api document: https://help.aliyun.com/api/ons/onstopicstatus.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTopicUpdate

func (client *Client) OnsTopicUpdate(request *OnsTopicUpdateRequest) (response *OnsTopicUpdateResponse, err error)

OnsTopicUpdate invokes the ons.OnsTopicUpdate API synchronously api document: https://help.aliyun.com/api/ons/onstopicupdate.html

func (*Client) OnsTopicUpdateWithCallback

func (client *Client) OnsTopicUpdateWithCallback(request *OnsTopicUpdateRequest, callback func(response *OnsTopicUpdateResponse, err error)) <-chan int

OnsTopicUpdateWithCallback invokes the ons.OnsTopicUpdate API asynchronously api document: https://help.aliyun.com/api/ons/onstopicupdate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTopicUpdateWithChan

func (client *Client) OnsTopicUpdateWithChan(request *OnsTopicUpdateRequest) (<-chan *OnsTopicUpdateResponse, <-chan error)

OnsTopicUpdateWithChan invokes the ons.OnsTopicUpdate API asynchronously api document: https://help.aliyun.com/api/ons/onstopicupdate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTraceGetResult

func (client *Client) OnsTraceGetResult(request *OnsTraceGetResultRequest) (response *OnsTraceGetResultResponse, err error)

OnsTraceGetResult invokes the ons.OnsTraceGetResult API synchronously api document: https://help.aliyun.com/api/ons/onstracegetresult.html

func (*Client) OnsTraceGetResultWithCallback

func (client *Client) OnsTraceGetResultWithCallback(request *OnsTraceGetResultRequest, callback func(response *OnsTraceGetResultResponse, err error)) <-chan int

OnsTraceGetResultWithCallback invokes the ons.OnsTraceGetResult API asynchronously api document: https://help.aliyun.com/api/ons/onstracegetresult.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTraceGetResultWithChan

func (client *Client) OnsTraceGetResultWithChan(request *OnsTraceGetResultRequest) (<-chan *OnsTraceGetResultResponse, <-chan error)

OnsTraceGetResultWithChan invokes the ons.OnsTraceGetResult API asynchronously api document: https://help.aliyun.com/api/ons/onstracegetresult.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTraceQueryByMsgId

func (client *Client) OnsTraceQueryByMsgId(request *OnsTraceQueryByMsgIdRequest) (response *OnsTraceQueryByMsgIdResponse, err error)

OnsTraceQueryByMsgId invokes the ons.OnsTraceQueryByMsgId API synchronously api document: https://help.aliyun.com/api/ons/onstracequerybymsgid.html

func (*Client) OnsTraceQueryByMsgIdWithCallback

func (client *Client) OnsTraceQueryByMsgIdWithCallback(request *OnsTraceQueryByMsgIdRequest, callback func(response *OnsTraceQueryByMsgIdResponse, err error)) <-chan int

OnsTraceQueryByMsgIdWithCallback invokes the ons.OnsTraceQueryByMsgId API asynchronously api document: https://help.aliyun.com/api/ons/onstracequerybymsgid.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTraceQueryByMsgIdWithChan

func (client *Client) OnsTraceQueryByMsgIdWithChan(request *OnsTraceQueryByMsgIdRequest) (<-chan *OnsTraceQueryByMsgIdResponse, <-chan error)

OnsTraceQueryByMsgIdWithChan invokes the ons.OnsTraceQueryByMsgId API asynchronously api document: https://help.aliyun.com/api/ons/onstracequerybymsgid.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTraceQueryByMsgKey

func (client *Client) OnsTraceQueryByMsgKey(request *OnsTraceQueryByMsgKeyRequest) (response *OnsTraceQueryByMsgKeyResponse, err error)

OnsTraceQueryByMsgKey invokes the ons.OnsTraceQueryByMsgKey API synchronously api document: https://help.aliyun.com/api/ons/onstracequerybymsgkey.html

func (*Client) OnsTraceQueryByMsgKeyWithCallback

func (client *Client) OnsTraceQueryByMsgKeyWithCallback(request *OnsTraceQueryByMsgKeyRequest, callback func(response *OnsTraceQueryByMsgKeyResponse, err error)) <-chan int

OnsTraceQueryByMsgKeyWithCallback invokes the ons.OnsTraceQueryByMsgKey API asynchronously api document: https://help.aliyun.com/api/ons/onstracequerybymsgkey.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTraceQueryByMsgKeyWithChan

func (client *Client) OnsTraceQueryByMsgKeyWithChan(request *OnsTraceQueryByMsgKeyRequest) (<-chan *OnsTraceQueryByMsgKeyResponse, <-chan error)

OnsTraceQueryByMsgKeyWithChan invokes the ons.OnsTraceQueryByMsgKey API asynchronously api document: https://help.aliyun.com/api/ons/onstracequerybymsgkey.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTrendGroupOutputTps

func (client *Client) OnsTrendGroupOutputTps(request *OnsTrendGroupOutputTpsRequest) (response *OnsTrendGroupOutputTpsResponse, err error)

OnsTrendGroupOutputTps invokes the ons.OnsTrendGroupOutputTps API synchronously api document: https://help.aliyun.com/api/ons/onstrendgroupoutputtps.html

func (*Client) OnsTrendGroupOutputTpsWithCallback

func (client *Client) OnsTrendGroupOutputTpsWithCallback(request *OnsTrendGroupOutputTpsRequest, callback func(response *OnsTrendGroupOutputTpsResponse, err error)) <-chan int

OnsTrendGroupOutputTpsWithCallback invokes the ons.OnsTrendGroupOutputTps API asynchronously api document: https://help.aliyun.com/api/ons/onstrendgroupoutputtps.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTrendGroupOutputTpsWithChan

func (client *Client) OnsTrendGroupOutputTpsWithChan(request *OnsTrendGroupOutputTpsRequest) (<-chan *OnsTrendGroupOutputTpsResponse, <-chan error)

OnsTrendGroupOutputTpsWithChan invokes the ons.OnsTrendGroupOutputTps API asynchronously api document: https://help.aliyun.com/api/ons/onstrendgroupoutputtps.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTrendTopicInputTps

func (client *Client) OnsTrendTopicInputTps(request *OnsTrendTopicInputTpsRequest) (response *OnsTrendTopicInputTpsResponse, err error)

OnsTrendTopicInputTps invokes the ons.OnsTrendTopicInputTps API synchronously api document: https://help.aliyun.com/api/ons/onstrendtopicinputtps.html

func (*Client) OnsTrendTopicInputTpsWithCallback

func (client *Client) OnsTrendTopicInputTpsWithCallback(request *OnsTrendTopicInputTpsRequest, callback func(response *OnsTrendTopicInputTpsResponse, err error)) <-chan int

OnsTrendTopicInputTpsWithCallback invokes the ons.OnsTrendTopicInputTps API asynchronously api document: https://help.aliyun.com/api/ons/onstrendtopicinputtps.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsTrendTopicInputTpsWithChan

func (client *Client) OnsTrendTopicInputTpsWithChan(request *OnsTrendTopicInputTpsRequest) (<-chan *OnsTrendTopicInputTpsResponse, <-chan error)

OnsTrendTopicInputTpsWithChan invokes the ons.OnsTrendTopicInputTps API asynchronously api document: https://help.aliyun.com/api/ons/onstrendtopicinputtps.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsWarnCreate

func (client *Client) OnsWarnCreate(request *OnsWarnCreateRequest) (response *OnsWarnCreateResponse, err error)

OnsWarnCreate invokes the ons.OnsWarnCreate API synchronously api document: https://help.aliyun.com/api/ons/onswarncreate.html

func (*Client) OnsWarnCreateWithCallback

func (client *Client) OnsWarnCreateWithCallback(request *OnsWarnCreateRequest, callback func(response *OnsWarnCreateResponse, err error)) <-chan int

OnsWarnCreateWithCallback invokes the ons.OnsWarnCreate API asynchronously api document: https://help.aliyun.com/api/ons/onswarncreate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsWarnCreateWithChan

func (client *Client) OnsWarnCreateWithChan(request *OnsWarnCreateRequest) (<-chan *OnsWarnCreateResponse, <-chan error)

OnsWarnCreateWithChan invokes the ons.OnsWarnCreate API asynchronously api document: https://help.aliyun.com/api/ons/onswarncreate.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsWarnDelete

func (client *Client) OnsWarnDelete(request *OnsWarnDeleteRequest) (response *OnsWarnDeleteResponse, err error)

OnsWarnDelete invokes the ons.OnsWarnDelete API synchronously api document: https://help.aliyun.com/api/ons/onswarndelete.html

func (*Client) OnsWarnDeleteWithCallback

func (client *Client) OnsWarnDeleteWithCallback(request *OnsWarnDeleteRequest, callback func(response *OnsWarnDeleteResponse, err error)) <-chan int

OnsWarnDeleteWithCallback invokes the ons.OnsWarnDelete API asynchronously api document: https://help.aliyun.com/api/ons/onswarndelete.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) OnsWarnDeleteWithChan

func (client *Client) OnsWarnDeleteWithChan(request *OnsWarnDeleteRequest) (<-chan *OnsWarnDeleteResponse, <-chan error)

OnsWarnDeleteWithChan invokes the ons.OnsWarnDelete API asynchronously api document: https://help.aliyun.com/api/ons/onswarndelete.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

type ClientList

type ClientList struct {
	SubClientInfoDo []SubClientInfoDo `json:"SubClientInfoDo" xml:"SubClientInfoDo"`
}

ClientList is a nested struct in ons response

type ConnectionDo

type ConnectionDo struct {
	ClientAddr string `json:"ClientAddr" xml:"ClientAddr"`
	ClientId   string `json:"ClientId" xml:"ClientId"`
	Version    string `json:"Version" xml:"Version"`
	Language   string `json:"Language" xml:"Language"`
}

ConnectionDo is a nested struct in ons response

type ConnectionList

type ConnectionList struct {
	ConnectionDo []ConnectionDo `json:"ConnectionDo" xml:"ConnectionDo"`
}

ConnectionList is a nested struct in ons response

type ConnectionSet

type ConnectionSet struct {
	ConnectionDo []ConnectionDo `json:"ConnectionDo" xml:"ConnectionDo"`
}

ConnectionSet is a nested struct in ons response

type ConsumerConnectionInfoDo

type ConsumerConnectionInfoDo struct {
	ClientId        string          `json:"ClientId" xml:"ClientId"`
	Connection      string          `json:"Connection" xml:"Connection"`
	Language        string          `json:"Language" xml:"Language"`
	Version         string          `json:"Version" xml:"Version"`
	ConsumeModel    string          `json:"ConsumeModel" xml:"ConsumeModel"`
	ConsumeType     string          `json:"ConsumeType" xml:"ConsumeType"`
	ThreadCount     int             `json:"ThreadCount" xml:"ThreadCount"`
	StartTimeStamp  int             `json:"StartTimeStamp" xml:"StartTimeStamp"`
	LastTimeStamp   int             `json:"LastTimeStamp" xml:"LastTimeStamp"`
	SubscriptionSet SubscriptionSet `json:"SubscriptionSet" xml:"SubscriptionSet"`
	RunningDataList RunningDataList `json:"RunningDataList" xml:"RunningDataList"`
	Jstack          Jstack          `json:"Jstack" xml:"Jstack"`
}

ConsumerConnectionInfoDo is a nested struct in ons response

type ConsumerConnectionInfoList

type ConsumerConnectionInfoList struct {
	ConsumerConnectionInfoDo []ConsumerConnectionInfoDo `json:"ConsumerConnectionInfoDo" xml:"ConsumerConnectionInfoDo"`
}

ConsumerConnectionInfoList is a nested struct in ons response

type ConsumerRunningDataDo

type ConsumerRunningDataDo struct {
	GroupId            string  `json:"GroupId" xml:"GroupId"`
	Topic              string  `json:"Topic" xml:"Topic"`
	Rt                 float64 `json:"Rt" xml:"Rt"`
	OkTps              float64 `json:"OkTps" xml:"OkTps"`
	FailedTps          float64 `json:"FailedTps" xml:"FailedTps"`
	FailedCountPerHour int     `json:"FailedCountPerHour" xml:"FailedCountPerHour"`
}

ConsumerRunningDataDo is a nested struct in ons response

type Data

type Data struct {
	DelayTime                  int                                      `json:"DelayTime" xml:"DelayTime"`
	ConsumeModel               string                                   `json:"ConsumeModel" xml:"ConsumeModel"`
	Title                      string                                   `json:"Title" xml:"Title"`
	Online                     bool                                     `json:"Online" xml:"Online"`
	Flag                       int                                      `json:"Flag" xml:"Flag"`
	BornTimestamp              int                                      `json:"BornTimestamp" xml:"BornTimestamp"`
	RebalanceOK                bool                                     `json:"RebalanceOK" xml:"RebalanceOK"`
	XUnit                      string                                   `json:"XUnit" xml:"XUnit"`
	OffsetId                   string                                   `json:"OffsetId" xml:"OffsetId"`
	SubscriptionSame           bool                                     `json:"SubscriptionSame" xml:"SubscriptionSame"`
	MaxTimeStamp               int                                      `json:"MaxTimeStamp" xml:"MaxTimeStamp"`
	InstanceId                 string                                   `json:"InstanceId" xml:"InstanceId"`
	ConsumeTps                 float64                                  `json:"ConsumeTps" xml:"ConsumeTps"`
	Topic                      string                                   `json:"Topic" xml:"Topic"`
	ConsumeTimeStamp           int                                      `json:"ConsumeTimeStamp" xml:"ConsumeTimeStamp"`
	TotalCount                 int                                      `json:"TotalCount" xml:"TotalCount"`
	TotalDiff                  int                                      `json:"TotalDiff" xml:"TotalDiff"`
	ReconsumeTimes             int                                      `json:"ReconsumeTimes" xml:"ReconsumeTimes"`
	Body                       string                                   `json:"Body" xml:"Body"`
	BornHost                   string                                   `json:"BornHost" xml:"BornHost"`
	MinTimeStamp               int                                      `json:"MinTimeStamp" xml:"MinTimeStamp"`
	LastTimeStamp              int                                      `json:"LastTimeStamp" xml:"LastTimeStamp"`
	InstanceType               int                                      `json:"InstanceType" xml:"InstanceType"`
	BodyCRC                    int                                      `json:"BodyCRC" xml:"BodyCRC"`
	MsgId                      string                                   `json:"MsgId" xml:"MsgId"`
	StoreTimestamp             int                                      `json:"StoreTimestamp" xml:"StoreTimestamp"`
	StoreSize                  int                                      `json:"StoreSize" xml:"StoreSize"`
	StoreHost                  string                                   `json:"StoreHost" xml:"StoreHost"`
	YUnit                      string                                   `json:"YUnit" xml:"YUnit"`
	LastTimestamp              int                                      `json:"LastTimestamp" xml:"LastTimestamp"`
	ConnectionSet              ConnectionSet                            `json:"ConnectionSet" xml:"ConnectionSet"`
	PropertyList               PropertyListInOnsMessageGetByMsgId       `json:"PropertyList" xml:"PropertyList"`
	Records                    RecordsInOnsMqttQueryHistoryOnline       `json:"Records" xml:"Records"`
	ConsumerConnectionInfoList ConsumerConnectionInfoList               `json:"ConsumerConnectionInfoList" xml:"ConsumerConnectionInfoList"`
	DetailInTopicList          DetailInTopicListInOnsConsumerAccumulate `json:"DetailInTopicList" xml:"DetailInTopicList"`
	ConnectionList             ConnectionList                           `json:"ConnectionList" xml:"ConnectionList"`
}

Data is a nested struct in ons response

type DataInOnsGroupList

type DataInOnsGroupList struct {
	SubscribeInfoDo []SubscribeInfoDo `json:"SubscribeInfoDo" xml:"SubscribeInfoDo"`
}

DataInOnsGroupList is a nested struct in ons response

type DataInOnsInstanceInServiceList

type DataInOnsInstanceInServiceList struct {
	InstanceVO []InstanceVO `json:"InstanceVO" xml:"InstanceVO"`
}

DataInOnsInstanceInServiceList is a nested struct in ons response

type DataInOnsMessageGetByKey

type DataInOnsMessageGetByKey struct {
	OnsRestMessageDo []OnsRestMessageDo `json:"OnsRestMessageDo" xml:"OnsRestMessageDo"`
}

DataInOnsMessageGetByKey is a nested struct in ons response

type DataInOnsMessageTrace

type DataInOnsMessageTrace struct {
	MessageTrack []MessageTrack `json:"MessageTrack" xml:"MessageTrack"`
}

DataInOnsMessageTrace is a nested struct in ons response

type DataInOnsMqttGroupIdList

type DataInOnsMqttGroupIdList struct {
	MqttGroupIdDo []MqttGroupIdDo `json:"MqttGroupIdDo" xml:"MqttGroupIdDo"`
}

DataInOnsMqttGroupIdList is a nested struct in ons response

type DataInOnsRegionList

type DataInOnsRegionList struct {
	RegionDo []RegionDo `json:"RegionDo" xml:"RegionDo"`
}

DataInOnsRegionList is a nested struct in ons response

type DataInOnsTopicList

type DataInOnsTopicList struct {
	PublishInfoDo []PublishInfoDo `json:"PublishInfoDo" xml:"PublishInfoDo"`
}

DataInOnsTopicList is a nested struct in ons response

type DetailInTopicDo

type DetailInTopicDo struct {
	DelayTime     int    `json:"DelayTime" xml:"DelayTime"`
	TotalDiff     int    `json:"TotalDiff" xml:"TotalDiff"`
	Topic         string `json:"Topic" xml:"Topic"`
	LastTimestamp int    `json:"LastTimestamp" xml:"LastTimestamp"`
}

DetailInTopicDo is a nested struct in ons response

type DetailInTopicListInOnsConsumerAccumulate

type DetailInTopicListInOnsConsumerAccumulate struct {
	DetailInTopicDo []DetailInTopicDo `json:"DetailInTopicDo" xml:"DetailInTopicDo"`
}

DetailInTopicListInOnsConsumerAccumulate is a nested struct in ons response

type DetailInTopicListInOnsConsumerStatus

type DetailInTopicListInOnsConsumerStatus struct {
	DetailInTopicDo []DetailInTopicDo `json:"DetailInTopicDo" xml:"DetailInTopicDo"`
}

DetailInTopicListInOnsConsumerStatus is a nested struct in ons response

type Endpoints

type Endpoints struct {
	TcpEndpoint                string `json:"TcpEndpoint" xml:"TcpEndpoint"`
	HttpInternetEndpoint       string `json:"HttpInternetEndpoint" xml:"HttpInternetEndpoint"`
	HttpInternetSecureEndpoint string `json:"HttpInternetSecureEndpoint" xml:"HttpInternetSecureEndpoint"`
	HttpInternalEndpoint       string `json:"HttpInternalEndpoint" xml:"HttpInternalEndpoint"`
}

Endpoints is a nested struct in ons response

type InstanceBaseInfo

type InstanceBaseInfo struct {
	InstanceId     string    `json:"InstanceId" xml:"InstanceId"`
	InstanceStatus int       `json:"InstanceStatus" xml:"InstanceStatus"`
	ReleaseTime    int       `json:"ReleaseTime" xml:"ReleaseTime"`
	InstanceType   int       `json:"InstanceType" xml:"InstanceType"`
	InstanceName   string    `json:"InstanceName" xml:"InstanceName"`
	Endpoints      Endpoints `json:"Endpoints" xml:"Endpoints"`
}

InstanceBaseInfo is a nested struct in ons response

type InstanceVO

type InstanceVO struct {
	InstanceId     string `json:"InstanceId" xml:"InstanceId"`
	InstanceStatus int    `json:"InstanceStatus" xml:"InstanceStatus"`
	ReleaseTime    int    `json:"ReleaseTime" xml:"ReleaseTime"`
	InstanceType   int    `json:"InstanceType" xml:"InstanceType"`
	InstanceName   string `json:"InstanceName" xml:"InstanceName"`
}

InstanceVO is a nested struct in ons response

type Jstack

type Jstack struct {
	ThreadTrackDo []ThreadTrackDo `json:"ThreadTrackDo" xml:"ThreadTrackDo"`
}

Jstack is a nested struct in ons response

type MessageProperty

type MessageProperty struct {
	Name  string `json:"Name" xml:"Name"`
	Value string `json:"Value" xml:"Value"`
}

MessageProperty is a nested struct in ons response

type MessageTrack

type MessageTrack struct {
	ConsumerGroup string `json:"ConsumerGroup" xml:"ConsumerGroup"`
	TrackType     string `json:"TrackType" xml:"TrackType"`
	ExceptionDesc string `json:"ExceptionDesc" xml:"ExceptionDesc"`
	InstanceId    string `json:"InstanceId" xml:"InstanceId"`
}

MessageTrack is a nested struct in ons response

type MqttClientInfoDo

type MqttClientInfoDo struct {
	Online          bool            `json:"Online" xml:"Online"`
	ClientId        string          `json:"ClientId" xml:"ClientId"`
	SocketChannel   string          `json:"SocketChannel" xml:"SocketChannel"`
	LastTouch       int             `json:"LastTouch" xml:"LastTouch"`
	SubScriptonData SubScriptonData `json:"SubScriptonData" xml:"SubScriptonData"`
}

MqttClientInfoDo is a nested struct in ons response

type MqttClientSetDo

type MqttClientSetDo struct {
	OnlineCount  int `json:"OnlineCount" xml:"OnlineCount"`
	PersistCount int `json:"PersistCount" xml:"PersistCount"`
}

MqttClientSetDo is a nested struct in ons response

type MqttGroupIdDo

type MqttGroupIdDo struct {
	Id                int    `json:"Id" xml:"Id"`
	ChannelId         int    `json:"ChannelId" xml:"ChannelId"`
	Owner             string `json:"Owner" xml:"Owner"`
	GroupId           string `json:"GroupId" xml:"GroupId"`
	Topic             string `json:"Topic" xml:"Topic"`
	Status            int    `json:"Status" xml:"Status"`
	CreateTime        int    `json:"CreateTime" xml:"CreateTime"`
	UpdateTime        int    `json:"UpdateTime" xml:"UpdateTime"`
	InstanceId        string `json:"InstanceId" xml:"InstanceId"`
	IndependentNaming bool   `json:"IndependentNaming" xml:"IndependentNaming"`
}

MqttGroupIdDo is a nested struct in ons response

type MsgFoundDo

type MsgFoundDo struct {
	TaskId       string       `json:"TaskId" xml:"TaskId"`
	MaxPageCount int          `json:"MaxPageCount" xml:"MaxPageCount"`
	CurrentPage  int          `json:"CurrentPage" xml:"CurrentPage"`
	MsgFoundList MsgFoundList `json:"MsgFoundList" xml:"MsgFoundList"`
}

MsgFoundDo is a nested struct in ons response

type MsgFoundList

type MsgFoundList struct {
	OnsRestMessageDo []OnsRestMessageDo `json:"OnsRestMessageDo" xml:"OnsRestMessageDo"`
}

MsgFoundList is a nested struct in ons response

type OnsConsumerAccumulateRequest

type OnsConsumerAccumulateRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
	Detail       requests.Boolean `position:"Query" name:"Detail"`
}

OnsConsumerAccumulateRequest is the request struct for api OnsConsumerAccumulate

func CreateOnsConsumerAccumulateRequest

func CreateOnsConsumerAccumulateRequest() (request *OnsConsumerAccumulateRequest)

CreateOnsConsumerAccumulateRequest creates a request to invoke OnsConsumerAccumulate API

type OnsConsumerAccumulateResponse

type OnsConsumerAccumulateResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsConsumerAccumulateResponse is the response struct for api OnsConsumerAccumulate

func CreateOnsConsumerAccumulateResponse

func CreateOnsConsumerAccumulateResponse() (response *OnsConsumerAccumulateResponse)

CreateOnsConsumerAccumulateResponse creates a response to parse from OnsConsumerAccumulate response

type OnsConsumerGetConnectionRequest

type OnsConsumerGetConnectionRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
}

OnsConsumerGetConnectionRequest is the request struct for api OnsConsumerGetConnection

func CreateOnsConsumerGetConnectionRequest

func CreateOnsConsumerGetConnectionRequest() (request *OnsConsumerGetConnectionRequest)

CreateOnsConsumerGetConnectionRequest creates a request to invoke OnsConsumerGetConnection API

type OnsConsumerGetConnectionResponse

type OnsConsumerGetConnectionResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsConsumerGetConnectionResponse is the response struct for api OnsConsumerGetConnection

func CreateOnsConsumerGetConnectionResponse

func CreateOnsConsumerGetConnectionResponse() (response *OnsConsumerGetConnectionResponse)

CreateOnsConsumerGetConnectionResponse creates a response to parse from OnsConsumerGetConnection response

type OnsConsumerResetOffsetRequest

type OnsConsumerResetOffsetRequest struct {
	*requests.RpcRequest
	PreventCache   requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId     string           `position:"Query" name:"InstanceId"`
	GroupId        string           `position:"Query" name:"GroupId"`
	Topic          string           `position:"Query" name:"Topic"`
	ResetTimestamp requests.Integer `position:"Query" name:"ResetTimestamp"`
	Type           requests.Integer `position:"Query" name:"Type"`
}

OnsConsumerResetOffsetRequest is the request struct for api OnsConsumerResetOffset

func CreateOnsConsumerResetOffsetRequest

func CreateOnsConsumerResetOffsetRequest() (request *OnsConsumerResetOffsetRequest)

CreateOnsConsumerResetOffsetRequest creates a request to invoke OnsConsumerResetOffset API

type OnsConsumerResetOffsetResponse

type OnsConsumerResetOffsetResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsConsumerResetOffsetResponse is the response struct for api OnsConsumerResetOffset

func CreateOnsConsumerResetOffsetResponse

func CreateOnsConsumerResetOffsetResponse() (response *OnsConsumerResetOffsetResponse)

CreateOnsConsumerResetOffsetResponse creates a response to parse from OnsConsumerResetOffset response

type OnsConsumerStatusRequest

type OnsConsumerStatusRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	NeedJstack   requests.Boolean `position:"Query" name:"NeedJstack"`
	GroupId      string           `position:"Query" name:"GroupId"`
	Detail       requests.Boolean `position:"Query" name:"Detail"`
}

OnsConsumerStatusRequest is the request struct for api OnsConsumerStatus

func CreateOnsConsumerStatusRequest

func CreateOnsConsumerStatusRequest() (request *OnsConsumerStatusRequest)

CreateOnsConsumerStatusRequest creates a request to invoke OnsConsumerStatus API

type OnsConsumerStatusResponse

type OnsConsumerStatusResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsConsumerStatusResponse is the response struct for api OnsConsumerStatus

func CreateOnsConsumerStatusResponse

func CreateOnsConsumerStatusResponse() (response *OnsConsumerStatusResponse)

CreateOnsConsumerStatusResponse creates a response to parse from OnsConsumerStatus response

type OnsConsumerTimeSpanRequest

type OnsConsumerTimeSpanRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
	Topic        string           `position:"Query" name:"Topic"`
}

OnsConsumerTimeSpanRequest is the request struct for api OnsConsumerTimeSpan

func CreateOnsConsumerTimeSpanRequest

func CreateOnsConsumerTimeSpanRequest() (request *OnsConsumerTimeSpanRequest)

CreateOnsConsumerTimeSpanRequest creates a request to invoke OnsConsumerTimeSpan API

type OnsConsumerTimeSpanResponse

type OnsConsumerTimeSpanResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsConsumerTimeSpanResponse is the response struct for api OnsConsumerTimeSpan

func CreateOnsConsumerTimeSpanResponse

func CreateOnsConsumerTimeSpanResponse() (response *OnsConsumerTimeSpanResponse)

CreateOnsConsumerTimeSpanResponse creates a response to parse from OnsConsumerTimeSpan response

type OnsGroupConsumerUpdateRequest

type OnsGroupConsumerUpdateRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	ReadEnable   requests.Boolean `position:"Query" name:"ReadEnable"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
}

OnsGroupConsumerUpdateRequest is the request struct for api OnsGroupConsumerUpdate

func CreateOnsGroupConsumerUpdateRequest

func CreateOnsGroupConsumerUpdateRequest() (request *OnsGroupConsumerUpdateRequest)

CreateOnsGroupConsumerUpdateRequest creates a request to invoke OnsGroupConsumerUpdate API

type OnsGroupConsumerUpdateResponse

type OnsGroupConsumerUpdateResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsGroupConsumerUpdateResponse is the response struct for api OnsGroupConsumerUpdate

func CreateOnsGroupConsumerUpdateResponse

func CreateOnsGroupConsumerUpdateResponse() (response *OnsGroupConsumerUpdateResponse)

CreateOnsGroupConsumerUpdateResponse creates a response to parse from OnsGroupConsumerUpdate response

type OnsGroupCreateRequest

type OnsGroupCreateRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
	Remark       string           `position:"Query" name:"Remark"`
}

OnsGroupCreateRequest is the request struct for api OnsGroupCreate

func CreateOnsGroupCreateRequest

func CreateOnsGroupCreateRequest() (request *OnsGroupCreateRequest)

CreateOnsGroupCreateRequest creates a request to invoke OnsGroupCreate API

type OnsGroupCreateResponse

type OnsGroupCreateResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsGroupCreateResponse is the response struct for api OnsGroupCreate

func CreateOnsGroupCreateResponse

func CreateOnsGroupCreateResponse() (response *OnsGroupCreateResponse)

CreateOnsGroupCreateResponse creates a response to parse from OnsGroupCreate response

type OnsGroupDeleteRequest

type OnsGroupDeleteRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
}

OnsGroupDeleteRequest is the request struct for api OnsGroupDelete

func CreateOnsGroupDeleteRequest

func CreateOnsGroupDeleteRequest() (request *OnsGroupDeleteRequest)

CreateOnsGroupDeleteRequest creates a request to invoke OnsGroupDelete API

type OnsGroupDeleteResponse

type OnsGroupDeleteResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsGroupDeleteResponse is the response struct for api OnsGroupDelete

func CreateOnsGroupDeleteResponse

func CreateOnsGroupDeleteResponse() (response *OnsGroupDeleteResponse)

CreateOnsGroupDeleteResponse creates a response to parse from OnsGroupDelete response

type OnsGroupListRequest

type OnsGroupListRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
}

OnsGroupListRequest is the request struct for api OnsGroupList

func CreateOnsGroupListRequest

func CreateOnsGroupListRequest() (request *OnsGroupListRequest)

CreateOnsGroupListRequest creates a request to invoke OnsGroupList API

type OnsGroupListResponse

type OnsGroupListResponse struct {
	*responses.BaseResponse
	RequestId string             `json:"RequestId" xml:"RequestId"`
	HelpUrl   string             `json:"HelpUrl" xml:"HelpUrl"`
	Data      DataInOnsGroupList `json:"Data" xml:"Data"`
}

OnsGroupListResponse is the response struct for api OnsGroupList

func CreateOnsGroupListResponse

func CreateOnsGroupListResponse() (response *OnsGroupListResponse)

CreateOnsGroupListResponse creates a response to parse from OnsGroupList response

type OnsInstanceBaseInfoRequest

type OnsInstanceBaseInfoRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
}

OnsInstanceBaseInfoRequest is the request struct for api OnsInstanceBaseInfo

func CreateOnsInstanceBaseInfoRequest

func CreateOnsInstanceBaseInfoRequest() (request *OnsInstanceBaseInfoRequest)

CreateOnsInstanceBaseInfoRequest creates a request to invoke OnsInstanceBaseInfo API

type OnsInstanceBaseInfoResponse

type OnsInstanceBaseInfoResponse struct {
	*responses.BaseResponse
	RequestId        string           `json:"RequestId" xml:"RequestId"`
	HelpUrl          string           `json:"HelpUrl" xml:"HelpUrl"`
	InstanceBaseInfo InstanceBaseInfo `json:"InstanceBaseInfo" xml:"InstanceBaseInfo"`
}

OnsInstanceBaseInfoResponse is the response struct for api OnsInstanceBaseInfo

func CreateOnsInstanceBaseInfoResponse

func CreateOnsInstanceBaseInfoResponse() (response *OnsInstanceBaseInfoResponse)

CreateOnsInstanceBaseInfoResponse creates a response to parse from OnsInstanceBaseInfo response

type OnsInstanceCreateRequest

type OnsInstanceCreateRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceName string           `position:"Query" name:"InstanceName"`
	Remark       string           `position:"Query" name:"Remark"`
}

OnsInstanceCreateRequest is the request struct for api OnsInstanceCreate

func CreateOnsInstanceCreateRequest

func CreateOnsInstanceCreateRequest() (request *OnsInstanceCreateRequest)

CreateOnsInstanceCreateRequest creates a request to invoke OnsInstanceCreate API

type OnsInstanceCreateResponse

type OnsInstanceCreateResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsInstanceCreateResponse is the response struct for api OnsInstanceCreate

func CreateOnsInstanceCreateResponse

func CreateOnsInstanceCreateResponse() (response *OnsInstanceCreateResponse)

CreateOnsInstanceCreateResponse creates a response to parse from OnsInstanceCreate response

type OnsInstanceDeleteRequest

type OnsInstanceDeleteRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
}

OnsInstanceDeleteRequest is the request struct for api OnsInstanceDelete

func CreateOnsInstanceDeleteRequest

func CreateOnsInstanceDeleteRequest() (request *OnsInstanceDeleteRequest)

CreateOnsInstanceDeleteRequest creates a request to invoke OnsInstanceDelete API

type OnsInstanceDeleteResponse

type OnsInstanceDeleteResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsInstanceDeleteResponse is the response struct for api OnsInstanceDelete

func CreateOnsInstanceDeleteResponse

func CreateOnsInstanceDeleteResponse() (response *OnsInstanceDeleteResponse)

CreateOnsInstanceDeleteResponse creates a response to parse from OnsInstanceDelete response

type OnsInstanceInServiceListRequest

type OnsInstanceInServiceListRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
}

OnsInstanceInServiceListRequest is the request struct for api OnsInstanceInServiceList

func CreateOnsInstanceInServiceListRequest

func CreateOnsInstanceInServiceListRequest() (request *OnsInstanceInServiceListRequest)

CreateOnsInstanceInServiceListRequest creates a request to invoke OnsInstanceInServiceList API

type OnsInstanceInServiceListResponse

type OnsInstanceInServiceListResponse struct {
	*responses.BaseResponse
	RequestId string                         `json:"RequestId" xml:"RequestId"`
	HelpUrl   string                         `json:"HelpUrl" xml:"HelpUrl"`
	Data      DataInOnsInstanceInServiceList `json:"Data" xml:"Data"`
}

OnsInstanceInServiceListResponse is the response struct for api OnsInstanceInServiceList

func CreateOnsInstanceInServiceListResponse

func CreateOnsInstanceInServiceListResponse() (response *OnsInstanceInServiceListResponse)

CreateOnsInstanceInServiceListResponse creates a response to parse from OnsInstanceInServiceList response

type OnsInstanceUpdateRequest

type OnsInstanceUpdateRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceName string           `position:"Query" name:"InstanceName"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Remark       string           `position:"Query" name:"Remark"`
}

OnsInstanceUpdateRequest is the request struct for api OnsInstanceUpdate

func CreateOnsInstanceUpdateRequest

func CreateOnsInstanceUpdateRequest() (request *OnsInstanceUpdateRequest)

CreateOnsInstanceUpdateRequest creates a request to invoke OnsInstanceUpdate API

type OnsInstanceUpdateResponse

type OnsInstanceUpdateResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsInstanceUpdateResponse is the response struct for api OnsInstanceUpdate

func CreateOnsInstanceUpdateResponse

func CreateOnsInstanceUpdateResponse() (response *OnsInstanceUpdateResponse)

CreateOnsInstanceUpdateResponse creates a response to parse from OnsInstanceUpdate response

type OnsMessageGetByKeyRequest

type OnsMessageGetByKeyRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Topic        string           `position:"Query" name:"Topic"`
	Key          string           `position:"Query" name:"Key"`
}

OnsMessageGetByKeyRequest is the request struct for api OnsMessageGetByKey

func CreateOnsMessageGetByKeyRequest

func CreateOnsMessageGetByKeyRequest() (request *OnsMessageGetByKeyRequest)

CreateOnsMessageGetByKeyRequest creates a request to invoke OnsMessageGetByKey API

type OnsMessageGetByKeyResponse

type OnsMessageGetByKeyResponse struct {
	*responses.BaseResponse
	RequestId string                   `json:"RequestId" xml:"RequestId"`
	HelpUrl   string                   `json:"HelpUrl" xml:"HelpUrl"`
	Data      DataInOnsMessageGetByKey `json:"Data" xml:"Data"`
}

OnsMessageGetByKeyResponse is the response struct for api OnsMessageGetByKey

func CreateOnsMessageGetByKeyResponse

func CreateOnsMessageGetByKeyResponse() (response *OnsMessageGetByKeyResponse)

CreateOnsMessageGetByKeyResponse creates a response to parse from OnsMessageGetByKey response

type OnsMessageGetByMsgIdRequest

type OnsMessageGetByMsgIdRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	MsgId        string           `position:"Query" name:"MsgId"`
	Topic        string           `position:"Query" name:"Topic"`
}

OnsMessageGetByMsgIdRequest is the request struct for api OnsMessageGetByMsgId

func CreateOnsMessageGetByMsgIdRequest

func CreateOnsMessageGetByMsgIdRequest() (request *OnsMessageGetByMsgIdRequest)

CreateOnsMessageGetByMsgIdRequest creates a request to invoke OnsMessageGetByMsgId API

type OnsMessageGetByMsgIdResponse

type OnsMessageGetByMsgIdResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsMessageGetByMsgIdResponse is the response struct for api OnsMessageGetByMsgId

func CreateOnsMessageGetByMsgIdResponse

func CreateOnsMessageGetByMsgIdResponse() (response *OnsMessageGetByMsgIdResponse)

CreateOnsMessageGetByMsgIdResponse creates a response to parse from OnsMessageGetByMsgId response

type OnsMessagePageQueryByTopicRequest

type OnsMessagePageQueryByTopicRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	PageSize     requests.Integer `position:"Query" name:"PageSize"`
	Topic        string           `position:"Query" name:"Topic"`
	EndTime      requests.Integer `position:"Query" name:"EndTime"`
	BeginTime    requests.Integer `position:"Query" name:"BeginTime"`
	CurrentPage  requests.Integer `position:"Query" name:"CurrentPage"`
	TaskId       string           `position:"Query" name:"TaskId"`
}

OnsMessagePageQueryByTopicRequest is the request struct for api OnsMessagePageQueryByTopic

func CreateOnsMessagePageQueryByTopicRequest

func CreateOnsMessagePageQueryByTopicRequest() (request *OnsMessagePageQueryByTopicRequest)

CreateOnsMessagePageQueryByTopicRequest creates a request to invoke OnsMessagePageQueryByTopic API

type OnsMessagePageQueryByTopicResponse

type OnsMessagePageQueryByTopicResponse struct {
	*responses.BaseResponse
	RequestId  string     `json:"RequestId" xml:"RequestId"`
	HelpUrl    string     `json:"HelpUrl" xml:"HelpUrl"`
	MsgFoundDo MsgFoundDo `json:"MsgFoundDo" xml:"MsgFoundDo"`
}

OnsMessagePageQueryByTopicResponse is the response struct for api OnsMessagePageQueryByTopic

func CreateOnsMessagePageQueryByTopicResponse

func CreateOnsMessagePageQueryByTopicResponse() (response *OnsMessagePageQueryByTopicResponse)

CreateOnsMessagePageQueryByTopicResponse creates a response to parse from OnsMessagePageQueryByTopic response

type OnsMessagePushRequest

type OnsMessagePushRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	ClientId     string           `position:"Query" name:"ClientId"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
	MsgId        string           `position:"Query" name:"MsgId"`
	Topic        string           `position:"Query" name:"Topic"`
}

OnsMessagePushRequest is the request struct for api OnsMessagePush

func CreateOnsMessagePushRequest

func CreateOnsMessagePushRequest() (request *OnsMessagePushRequest)

CreateOnsMessagePushRequest creates a request to invoke OnsMessagePush API

type OnsMessagePushResponse

type OnsMessagePushResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsMessagePushResponse is the response struct for api OnsMessagePush

func CreateOnsMessagePushResponse

func CreateOnsMessagePushResponse() (response *OnsMessagePushResponse)

CreateOnsMessagePushResponse creates a response to parse from OnsMessagePush response

type OnsMessageSendRequest

type OnsMessageSendRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Topic        string           `position:"Query" name:"Topic"`
	Tag          string           `position:"Query" name:"Tag"`
	Message      string           `position:"Query" name:"Message"`
	Key          string           `position:"Query" name:"Key"`
}

OnsMessageSendRequest is the request struct for api OnsMessageSend

func CreateOnsMessageSendRequest

func CreateOnsMessageSendRequest() (request *OnsMessageSendRequest)

CreateOnsMessageSendRequest creates a request to invoke OnsMessageSend API

type OnsMessageSendResponse

type OnsMessageSendResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      string `json:"Data" xml:"Data"`
}

OnsMessageSendResponse is the response struct for api OnsMessageSend

func CreateOnsMessageSendResponse

func CreateOnsMessageSendResponse() (response *OnsMessageSendResponse)

CreateOnsMessageSendResponse creates a response to parse from OnsMessageSend response

type OnsMessageTraceRequest

type OnsMessageTraceRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Topic        string           `position:"Query" name:"Topic"`
	MsgId        string           `position:"Query" name:"MsgId"`
}

OnsMessageTraceRequest is the request struct for api OnsMessageTrace

func CreateOnsMessageTraceRequest

func CreateOnsMessageTraceRequest() (request *OnsMessageTraceRequest)

CreateOnsMessageTraceRequest creates a request to invoke OnsMessageTrace API

type OnsMessageTraceResponse

type OnsMessageTraceResponse struct {
	*responses.BaseResponse
	RequestId string                `json:"RequestId" xml:"RequestId"`
	HelpUrl   string                `json:"HelpUrl" xml:"HelpUrl"`
	Data      DataInOnsMessageTrace `json:"Data" xml:"Data"`
}

OnsMessageTraceResponse is the response struct for api OnsMessageTrace

func CreateOnsMessageTraceResponse

func CreateOnsMessageTraceResponse() (response *OnsMessageTraceResponse)

CreateOnsMessageTraceResponse creates a response to parse from OnsMessageTrace response

type OnsMqttGroupIdCreateRequest

type OnsMqttGroupIdCreateRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
	Topic        string           `position:"Query" name:"Topic"`
}

OnsMqttGroupIdCreateRequest is the request struct for api OnsMqttGroupIdCreate

func CreateOnsMqttGroupIdCreateRequest

func CreateOnsMqttGroupIdCreateRequest() (request *OnsMqttGroupIdCreateRequest)

CreateOnsMqttGroupIdCreateRequest creates a request to invoke OnsMqttGroupIdCreate API

type OnsMqttGroupIdCreateResponse

type OnsMqttGroupIdCreateResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsMqttGroupIdCreateResponse is the response struct for api OnsMqttGroupIdCreate

func CreateOnsMqttGroupIdCreateResponse

func CreateOnsMqttGroupIdCreateResponse() (response *OnsMqttGroupIdCreateResponse)

CreateOnsMqttGroupIdCreateResponse creates a response to parse from OnsMqttGroupIdCreate response

type OnsMqttGroupIdDeleteRequest

type OnsMqttGroupIdDeleteRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
}

OnsMqttGroupIdDeleteRequest is the request struct for api OnsMqttGroupIdDelete

func CreateOnsMqttGroupIdDeleteRequest

func CreateOnsMqttGroupIdDeleteRequest() (request *OnsMqttGroupIdDeleteRequest)

CreateOnsMqttGroupIdDeleteRequest creates a request to invoke OnsMqttGroupIdDelete API

type OnsMqttGroupIdDeleteResponse

type OnsMqttGroupIdDeleteResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsMqttGroupIdDeleteResponse is the response struct for api OnsMqttGroupIdDelete

func CreateOnsMqttGroupIdDeleteResponse

func CreateOnsMqttGroupIdDeleteResponse() (response *OnsMqttGroupIdDeleteResponse)

CreateOnsMqttGroupIdDeleteResponse creates a response to parse from OnsMqttGroupIdDelete response

type OnsMqttGroupIdListRequest

type OnsMqttGroupIdListRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
}

OnsMqttGroupIdListRequest is the request struct for api OnsMqttGroupIdList

func CreateOnsMqttGroupIdListRequest

func CreateOnsMqttGroupIdListRequest() (request *OnsMqttGroupIdListRequest)

CreateOnsMqttGroupIdListRequest creates a request to invoke OnsMqttGroupIdList API

type OnsMqttGroupIdListResponse

type OnsMqttGroupIdListResponse struct {
	*responses.BaseResponse
	RequestId string                   `json:"RequestId" xml:"RequestId"`
	HelpUrl   string                   `json:"HelpUrl" xml:"HelpUrl"`
	Data      DataInOnsMqttGroupIdList `json:"Data" xml:"Data"`
}

OnsMqttGroupIdListResponse is the response struct for api OnsMqttGroupIdList

func CreateOnsMqttGroupIdListResponse

func CreateOnsMqttGroupIdListResponse() (response *OnsMqttGroupIdListResponse)

CreateOnsMqttGroupIdListResponse creates a response to parse from OnsMqttGroupIdList response

type OnsMqttQueryClientByClientIdRequest

type OnsMqttQueryClientByClientIdRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	ClientId     string           `position:"Query" name:"ClientId"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
}

OnsMqttQueryClientByClientIdRequest is the request struct for api OnsMqttQueryClientByClientId

func CreateOnsMqttQueryClientByClientIdRequest

func CreateOnsMqttQueryClientByClientIdRequest() (request *OnsMqttQueryClientByClientIdRequest)

CreateOnsMqttQueryClientByClientIdRequest creates a request to invoke OnsMqttQueryClientByClientId API

type OnsMqttQueryClientByClientIdResponse

type OnsMqttQueryClientByClientIdResponse struct {
	*responses.BaseResponse
	RequestId        string           `json:"RequestId" xml:"RequestId"`
	HelpUrl          string           `json:"HelpUrl" xml:"HelpUrl"`
	MqttClientInfoDo MqttClientInfoDo `json:"MqttClientInfoDo" xml:"MqttClientInfoDo"`
}

OnsMqttQueryClientByClientIdResponse is the response struct for api OnsMqttQueryClientByClientId

func CreateOnsMqttQueryClientByClientIdResponse

func CreateOnsMqttQueryClientByClientIdResponse() (response *OnsMqttQueryClientByClientIdResponse)

CreateOnsMqttQueryClientByClientIdResponse creates a response to parse from OnsMqttQueryClientByClientId response

type OnsMqttQueryClientByGroupIdRequest

type OnsMqttQueryClientByGroupIdRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
}

OnsMqttQueryClientByGroupIdRequest is the request struct for api OnsMqttQueryClientByGroupId

func CreateOnsMqttQueryClientByGroupIdRequest

func CreateOnsMqttQueryClientByGroupIdRequest() (request *OnsMqttQueryClientByGroupIdRequest)

CreateOnsMqttQueryClientByGroupIdRequest creates a request to invoke OnsMqttQueryClientByGroupId API

type OnsMqttQueryClientByGroupIdResponse

type OnsMqttQueryClientByGroupIdResponse struct {
	*responses.BaseResponse
	RequestId       string          `json:"RequestId" xml:"RequestId"`
	HelpUrl         string          `json:"HelpUrl" xml:"HelpUrl"`
	MqttClientSetDo MqttClientSetDo `json:"MqttClientSetDo" xml:"MqttClientSetDo"`
}

OnsMqttQueryClientByGroupIdResponse is the response struct for api OnsMqttQueryClientByGroupId

func CreateOnsMqttQueryClientByGroupIdResponse

func CreateOnsMqttQueryClientByGroupIdResponse() (response *OnsMqttQueryClientByGroupIdResponse)

CreateOnsMqttQueryClientByGroupIdResponse creates a response to parse from OnsMqttQueryClientByGroupId response

type OnsMqttQueryClientByTopicRequest

type OnsMqttQueryClientByTopicRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	ParentTopic  string           `position:"Query" name:"ParentTopic"`
	SubTopic     string           `position:"Query" name:"SubTopic"`
}

OnsMqttQueryClientByTopicRequest is the request struct for api OnsMqttQueryClientByTopic

func CreateOnsMqttQueryClientByTopicRequest

func CreateOnsMqttQueryClientByTopicRequest() (request *OnsMqttQueryClientByTopicRequest)

CreateOnsMqttQueryClientByTopicRequest creates a request to invoke OnsMqttQueryClientByTopic API

type OnsMqttQueryClientByTopicResponse

type OnsMqttQueryClientByTopicResponse struct {
	*responses.BaseResponse
	RequestId       string          `json:"RequestId" xml:"RequestId"`
	HelpUrl         string          `json:"HelpUrl" xml:"HelpUrl"`
	MqttClientSetDo MqttClientSetDo `json:"MqttClientSetDo" xml:"MqttClientSetDo"`
}

OnsMqttQueryClientByTopicResponse is the response struct for api OnsMqttQueryClientByTopic

func CreateOnsMqttQueryClientByTopicResponse

func CreateOnsMqttQueryClientByTopicResponse() (response *OnsMqttQueryClientByTopicResponse)

CreateOnsMqttQueryClientByTopicResponse creates a response to parse from OnsMqttQueryClientByTopic response

type OnsMqttQueryHistoryOnlineRequest

type OnsMqttQueryHistoryOnlineRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
	EndTime      requests.Integer `position:"Query" name:"EndTime"`
	BeginTime    requests.Integer `position:"Query" name:"BeginTime"`
}

OnsMqttQueryHistoryOnlineRequest is the request struct for api OnsMqttQueryHistoryOnline

func CreateOnsMqttQueryHistoryOnlineRequest

func CreateOnsMqttQueryHistoryOnlineRequest() (request *OnsMqttQueryHistoryOnlineRequest)

CreateOnsMqttQueryHistoryOnlineRequest creates a request to invoke OnsMqttQueryHistoryOnline API

type OnsMqttQueryHistoryOnlineResponse

type OnsMqttQueryHistoryOnlineResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsMqttQueryHistoryOnlineResponse is the response struct for api OnsMqttQueryHistoryOnline

func CreateOnsMqttQueryHistoryOnlineResponse

func CreateOnsMqttQueryHistoryOnlineResponse() (response *OnsMqttQueryHistoryOnlineResponse)

CreateOnsMqttQueryHistoryOnlineResponse creates a response to parse from OnsMqttQueryHistoryOnline response

type OnsMqttQueryMsgTransTrendRequest

type OnsMqttQueryMsgTransTrendRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Qos          requests.Integer `position:"Query" name:"Qos"`
	TransType    string           `position:"Query" name:"TransType"`
	EndTime      requests.Integer `position:"Query" name:"EndTime"`
	BeginTime    requests.Integer `position:"Query" name:"BeginTime"`
	TpsType      string           `position:"Query" name:"TpsType"`
	ParentTopic  string           `position:"Query" name:"ParentTopic"`
	MsgType      string           `position:"Query" name:"MsgType"`
	SubTopic     string           `position:"Query" name:"SubTopic"`
}

OnsMqttQueryMsgTransTrendRequest is the request struct for api OnsMqttQueryMsgTransTrend

func CreateOnsMqttQueryMsgTransTrendRequest

func CreateOnsMqttQueryMsgTransTrendRequest() (request *OnsMqttQueryMsgTransTrendRequest)

CreateOnsMqttQueryMsgTransTrendRequest creates a request to invoke OnsMqttQueryMsgTransTrend API

type OnsMqttQueryMsgTransTrendResponse

type OnsMqttQueryMsgTransTrendResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsMqttQueryMsgTransTrendResponse is the response struct for api OnsMqttQueryMsgTransTrend

func CreateOnsMqttQueryMsgTransTrendResponse

func CreateOnsMqttQueryMsgTransTrendResponse() (response *OnsMqttQueryMsgTransTrendResponse)

CreateOnsMqttQueryMsgTransTrendResponse creates a response to parse from OnsMqttQueryMsgTransTrend response

type OnsRegionListRequest

type OnsRegionListRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
}

OnsRegionListRequest is the request struct for api OnsRegionList

func CreateOnsRegionListRequest

func CreateOnsRegionListRequest() (request *OnsRegionListRequest)

CreateOnsRegionListRequest creates a request to invoke OnsRegionList API

type OnsRegionListResponse

type OnsRegionListResponse struct {
	*responses.BaseResponse
	RequestId string              `json:"RequestId" xml:"RequestId"`
	HelpUrl   string              `json:"HelpUrl" xml:"HelpUrl"`
	Data      DataInOnsRegionList `json:"Data" xml:"Data"`
}

OnsRegionListResponse is the response struct for api OnsRegionList

func CreateOnsRegionListResponse

func CreateOnsRegionListResponse() (response *OnsRegionListResponse)

CreateOnsRegionListResponse creates a response to parse from OnsRegionList response

type OnsRestMessageDo

type OnsRestMessageDo struct {
	ReconsumeTimes int                              `json:"ReconsumeTimes" xml:"ReconsumeTimes"`
	Flag           int                              `json:"Flag" xml:"Flag"`
	BornTimestamp  int                              `json:"BornTimestamp" xml:"BornTimestamp"`
	Body           string                           `json:"Body" xml:"Body"`
	BornHost       string                           `json:"BornHost" xml:"BornHost"`
	OffsetId       string                           `json:"OffsetId" xml:"OffsetId"`
	BodyCRC        int                              `json:"BodyCRC" xml:"BodyCRC"`
	MsgId          string                           `json:"MsgId" xml:"MsgId"`
	StoreTimestamp int                              `json:"StoreTimestamp" xml:"StoreTimestamp"`
	InstanceId     string                           `json:"InstanceId" xml:"InstanceId"`
	StoreSize      int                              `json:"StoreSize" xml:"StoreSize"`
	StoreHost      string                           `json:"StoreHost" xml:"StoreHost"`
	Topic          string                           `json:"Topic" xml:"Topic"`
	PropertyList   PropertyListInOnsMessageGetByKey `json:"PropertyList" xml:"PropertyList"`
}

OnsRestMessageDo is a nested struct in ons response

type OnsTopicCreateRequest

type OnsTopicCreateRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	MessageType  requests.Integer `position:"Query" name:"MessageType"`
	Topic        string           `position:"Query" name:"Topic"`
	Remark       string           `position:"Query" name:"Remark"`
}

OnsTopicCreateRequest is the request struct for api OnsTopicCreate

func CreateOnsTopicCreateRequest

func CreateOnsTopicCreateRequest() (request *OnsTopicCreateRequest)

CreateOnsTopicCreateRequest creates a request to invoke OnsTopicCreate API

type OnsTopicCreateResponse

type OnsTopicCreateResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsTopicCreateResponse is the response struct for api OnsTopicCreate

func CreateOnsTopicCreateResponse

func CreateOnsTopicCreateResponse() (response *OnsTopicCreateResponse)

CreateOnsTopicCreateResponse creates a response to parse from OnsTopicCreate response

type OnsTopicDeleteRequest

type OnsTopicDeleteRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Topic        string           `position:"Query" name:"Topic"`
}

OnsTopicDeleteRequest is the request struct for api OnsTopicDelete

func CreateOnsTopicDeleteRequest

func CreateOnsTopicDeleteRequest() (request *OnsTopicDeleteRequest)

CreateOnsTopicDeleteRequest creates a request to invoke OnsTopicDelete API

type OnsTopicDeleteResponse

type OnsTopicDeleteResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsTopicDeleteResponse is the response struct for api OnsTopicDelete

func CreateOnsTopicDeleteResponse

func CreateOnsTopicDeleteResponse() (response *OnsTopicDeleteResponse)

CreateOnsTopicDeleteResponse creates a response to parse from OnsTopicDelete response

type OnsTopicListRequest

type OnsTopicListRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Topic        string           `position:"Query" name:"Topic"`
}

OnsTopicListRequest is the request struct for api OnsTopicList

func CreateOnsTopicListRequest

func CreateOnsTopicListRequest() (request *OnsTopicListRequest)

CreateOnsTopicListRequest creates a request to invoke OnsTopicList API

type OnsTopicListResponse

type OnsTopicListResponse struct {
	*responses.BaseResponse
	RequestId string             `json:"RequestId" xml:"RequestId"`
	HelpUrl   string             `json:"HelpUrl" xml:"HelpUrl"`
	Data      DataInOnsTopicList `json:"Data" xml:"Data"`
}

OnsTopicListResponse is the response struct for api OnsTopicList

func CreateOnsTopicListResponse

func CreateOnsTopicListResponse() (response *OnsTopicListResponse)

CreateOnsTopicListResponse creates a response to parse from OnsTopicList response

type OnsTopicStatusRequest

type OnsTopicStatusRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Topic        string           `position:"Query" name:"Topic"`
}

OnsTopicStatusRequest is the request struct for api OnsTopicStatus

func CreateOnsTopicStatusRequest

func CreateOnsTopicStatusRequest() (request *OnsTopicStatusRequest)

CreateOnsTopicStatusRequest creates a request to invoke OnsTopicStatus API

type OnsTopicStatusResponse

type OnsTopicStatusResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsTopicStatusResponse is the response struct for api OnsTopicStatus

func CreateOnsTopicStatusResponse

func CreateOnsTopicStatusResponse() (response *OnsTopicStatusResponse)

CreateOnsTopicStatusResponse creates a response to parse from OnsTopicStatus response

type OnsTopicUpdateRequest

type OnsTopicUpdateRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Perm         requests.Integer `position:"Query" name:"Perm"`
	Topic        string           `position:"Query" name:"Topic"`
}

OnsTopicUpdateRequest is the request struct for api OnsTopicUpdate

func CreateOnsTopicUpdateRequest

func CreateOnsTopicUpdateRequest() (request *OnsTopicUpdateRequest)

CreateOnsTopicUpdateRequest creates a request to invoke OnsTopicUpdate API

type OnsTopicUpdateResponse

type OnsTopicUpdateResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsTopicUpdateResponse is the response struct for api OnsTopicUpdate

func CreateOnsTopicUpdateResponse

func CreateOnsTopicUpdateResponse() (response *OnsTopicUpdateResponse)

CreateOnsTopicUpdateResponse creates a response to parse from OnsTopicUpdate response

type OnsTraceGetResultRequest

type OnsTraceGetResultRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	QueryId      string           `position:"Query" name:"QueryId"`
}

OnsTraceGetResultRequest is the request struct for api OnsTraceGetResult

func CreateOnsTraceGetResultRequest

func CreateOnsTraceGetResultRequest() (request *OnsTraceGetResultRequest)

CreateOnsTraceGetResultRequest creates a request to invoke OnsTraceGetResult API

type OnsTraceGetResultResponse

type OnsTraceGetResultResponse struct {
	*responses.BaseResponse
	RequestId string    `json:"RequestId" xml:"RequestId"`
	HelpUrl   string    `json:"HelpUrl" xml:"HelpUrl"`
	TraceData TraceData `json:"TraceData" xml:"TraceData"`
}

OnsTraceGetResultResponse is the response struct for api OnsTraceGetResult

func CreateOnsTraceGetResultResponse

func CreateOnsTraceGetResultResponse() (response *OnsTraceGetResultResponse)

CreateOnsTraceGetResultResponse creates a response to parse from OnsTraceGetResult response

type OnsTraceQueryByMsgIdRequest

type OnsTraceQueryByMsgIdRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Topic        string           `position:"Query" name:"Topic"`
	MsgId        string           `position:"Query" name:"MsgId"`
	EndTime      requests.Integer `position:"Query" name:"EndTime"`
	BeginTime    requests.Integer `position:"Query" name:"BeginTime"`
}

OnsTraceQueryByMsgIdRequest is the request struct for api OnsTraceQueryByMsgId

func CreateOnsTraceQueryByMsgIdRequest

func CreateOnsTraceQueryByMsgIdRequest() (request *OnsTraceQueryByMsgIdRequest)

CreateOnsTraceQueryByMsgIdRequest creates a request to invoke OnsTraceQueryByMsgId API

type OnsTraceQueryByMsgIdResponse

type OnsTraceQueryByMsgIdResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	QueryId   string `json:"QueryId" xml:"QueryId"`
}

OnsTraceQueryByMsgIdResponse is the response struct for api OnsTraceQueryByMsgId

func CreateOnsTraceQueryByMsgIdResponse

func CreateOnsTraceQueryByMsgIdResponse() (response *OnsTraceQueryByMsgIdResponse)

CreateOnsTraceQueryByMsgIdResponse creates a response to parse from OnsTraceQueryByMsgId response

type OnsTraceQueryByMsgKeyRequest

type OnsTraceQueryByMsgKeyRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Topic        string           `position:"Query" name:"Topic"`
	EndTime      requests.Integer `position:"Query" name:"EndTime"`
	BeginTime    requests.Integer `position:"Query" name:"BeginTime"`
	MsgKey       string           `position:"Query" name:"MsgKey"`
}

OnsTraceQueryByMsgKeyRequest is the request struct for api OnsTraceQueryByMsgKey

func CreateOnsTraceQueryByMsgKeyRequest

func CreateOnsTraceQueryByMsgKeyRequest() (request *OnsTraceQueryByMsgKeyRequest)

CreateOnsTraceQueryByMsgKeyRequest creates a request to invoke OnsTraceQueryByMsgKey API

type OnsTraceQueryByMsgKeyResponse

type OnsTraceQueryByMsgKeyResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	QueryId   string `json:"QueryId" xml:"QueryId"`
}

OnsTraceQueryByMsgKeyResponse is the response struct for api OnsTraceQueryByMsgKey

func CreateOnsTraceQueryByMsgKeyResponse

func CreateOnsTraceQueryByMsgKeyResponse() (response *OnsTraceQueryByMsgKeyResponse)

CreateOnsTraceQueryByMsgKeyResponse creates a response to parse from OnsTraceQueryByMsgKey response

type OnsTrendGroupOutputTpsRequest

type OnsTrendGroupOutputTpsRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	Period       requests.Integer `position:"Query" name:"Period"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
	Topic        string           `position:"Query" name:"Topic"`
	EndTime      requests.Integer `position:"Query" name:"EndTime"`
	BeginTime    requests.Integer `position:"Query" name:"BeginTime"`
	Type         requests.Integer `position:"Query" name:"Type"`
}

OnsTrendGroupOutputTpsRequest is the request struct for api OnsTrendGroupOutputTps

func CreateOnsTrendGroupOutputTpsRequest

func CreateOnsTrendGroupOutputTpsRequest() (request *OnsTrendGroupOutputTpsRequest)

CreateOnsTrendGroupOutputTpsRequest creates a request to invoke OnsTrendGroupOutputTps API

type OnsTrendGroupOutputTpsResponse

type OnsTrendGroupOutputTpsResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsTrendGroupOutputTpsResponse is the response struct for api OnsTrendGroupOutputTps

func CreateOnsTrendGroupOutputTpsResponse

func CreateOnsTrendGroupOutputTpsResponse() (response *OnsTrendGroupOutputTpsResponse)

CreateOnsTrendGroupOutputTpsResponse creates a response to parse from OnsTrendGroupOutputTps response

type OnsTrendTopicInputTpsRequest

type OnsTrendTopicInputTpsRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	Period       requests.Integer `position:"Query" name:"Period"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Topic        string           `position:"Query" name:"Topic"`
	EndTime      requests.Integer `position:"Query" name:"EndTime"`
	BeginTime    requests.Integer `position:"Query" name:"BeginTime"`
	Type         requests.Integer `position:"Query" name:"Type"`
}

OnsTrendTopicInputTpsRequest is the request struct for api OnsTrendTopicInputTps

func CreateOnsTrendTopicInputTpsRequest

func CreateOnsTrendTopicInputTpsRequest() (request *OnsTrendTopicInputTpsRequest)

CreateOnsTrendTopicInputTpsRequest creates a request to invoke OnsTrendTopicInputTps API

type OnsTrendTopicInputTpsResponse

type OnsTrendTopicInputTpsResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
	Data      Data   `json:"Data" xml:"Data"`
}

OnsTrendTopicInputTpsResponse is the response struct for api OnsTrendTopicInputTps

func CreateOnsTrendTopicInputTpsResponse

func CreateOnsTrendTopicInputTpsResponse() (response *OnsTrendTopicInputTpsResponse)

CreateOnsTrendTopicInputTpsResponse creates a response to parse from OnsTrendTopicInputTps response

type OnsWarnCreateRequest

type OnsWarnCreateRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	BlockTime    string           `position:"Query" name:"BlockTime"`
	Level        string           `position:"Query" name:"Level"`
	GroupId      string           `position:"Query" name:"GroupId"`
	DelayTime    string           `position:"Query" name:"DelayTime"`
	Topic        string           `position:"Query" name:"Topic"`
	Threshold    string           `position:"Query" name:"Threshold"`
	AlertTime    string           `position:"Query" name:"AlertTime"`
	Contacts     string           `position:"Query" name:"Contacts"`
}

OnsWarnCreateRequest is the request struct for api OnsWarnCreate

func CreateOnsWarnCreateRequest

func CreateOnsWarnCreateRequest() (request *OnsWarnCreateRequest)

CreateOnsWarnCreateRequest creates a request to invoke OnsWarnCreate API

type OnsWarnCreateResponse

type OnsWarnCreateResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsWarnCreateResponse is the response struct for api OnsWarnCreate

func CreateOnsWarnCreateResponse

func CreateOnsWarnCreateResponse() (response *OnsWarnCreateResponse)

CreateOnsWarnCreateResponse creates a response to parse from OnsWarnCreate response

type OnsWarnDeleteRequest

type OnsWarnDeleteRequest struct {
	*requests.RpcRequest
	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	GroupId      string           `position:"Query" name:"GroupId"`
	Topic        string           `position:"Query" name:"Topic"`
}

OnsWarnDeleteRequest is the request struct for api OnsWarnDelete

func CreateOnsWarnDeleteRequest

func CreateOnsWarnDeleteRequest() (request *OnsWarnDeleteRequest)

CreateOnsWarnDeleteRequest creates a request to invoke OnsWarnDelete API

type OnsWarnDeleteResponse

type OnsWarnDeleteResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

OnsWarnDeleteResponse is the response struct for api OnsWarnDelete

func CreateOnsWarnDeleteResponse

func CreateOnsWarnDeleteResponse() (response *OnsWarnDeleteResponse)

CreateOnsWarnDeleteResponse creates a response to parse from OnsWarnDelete response

type PropertyListInOnsMessageGetByKey

type PropertyListInOnsMessageGetByKey struct {
	MessageProperty []MessageProperty `json:"MessageProperty" xml:"MessageProperty"`
}

PropertyListInOnsMessageGetByKey is a nested struct in ons response

type PropertyListInOnsMessageGetByMsgId

type PropertyListInOnsMessageGetByMsgId struct {
	MessageProperty []MessageProperty `json:"MessageProperty" xml:"MessageProperty"`
}

PropertyListInOnsMessageGetByMsgId is a nested struct in ons response

type PropertyListInOnsMessagePageQueryByTopic

type PropertyListInOnsMessagePageQueryByTopic struct {
	MessageProperty []MessageProperty `json:"MessageProperty" xml:"MessageProperty"`
}

PropertyListInOnsMessagePageQueryByTopic is a nested struct in ons response

type PublishInfoDo

type PublishInfoDo struct {
	Topic             string `json:"Topic" xml:"Topic"`
	Owner             string `json:"Owner" xml:"Owner"`
	Relation          int    `json:"Relation" xml:"Relation"`
	RelationName      string `json:"RelationName" xml:"RelationName"`
	UpdateTime        int    `json:"UpdateTime" xml:"UpdateTime"`
	Remark            string `json:"Remark" xml:"Remark"`
	MessageType       int    `json:"MessageType" xml:"MessageType"`
	InstanceId        string `json:"InstanceId" xml:"InstanceId"`
	IndependentNaming bool   `json:"IndependentNaming" xml:"IndependentNaming"`
}

PublishInfoDo is a nested struct in ons response

type RecordsInOnsMqttQueryHistoryOnline

type RecordsInOnsMqttQueryHistoryOnline struct {
	StatsDataDo []StatsDataDo `json:"StatsDataDo" xml:"StatsDataDo"`
}

RecordsInOnsMqttQueryHistoryOnline is a nested struct in ons response

type RecordsInOnsMqttQueryMsgTransTrend

type RecordsInOnsMqttQueryMsgTransTrend struct {
	StatsDataDo []StatsDataDo `json:"StatsDataDo" xml:"StatsDataDo"`
}

RecordsInOnsMqttQueryMsgTransTrend is a nested struct in ons response

type RecordsInOnsTrendGroupOutputTps

type RecordsInOnsTrendGroupOutputTps struct {
	StatsDataDo []StatsDataDo `json:"StatsDataDo" xml:"StatsDataDo"`
}

RecordsInOnsTrendGroupOutputTps is a nested struct in ons response

type RecordsInOnsTrendTopicInputTps

type RecordsInOnsTrendTopicInputTps struct {
	StatsDataDo []StatsDataDo `json:"StatsDataDo" xml:"StatsDataDo"`
}

RecordsInOnsTrendTopicInputTps is a nested struct in ons response

type RegionDo

type RegionDo struct {
	Id          int    `json:"Id" xml:"Id"`
	OnsRegionId string `json:"OnsRegionId" xml:"OnsRegionId"`
	RegionName  string `json:"RegionName" xml:"RegionName"`
	ChannelId   int    `json:"ChannelId" xml:"ChannelId"`
	ChannelName string `json:"ChannelName" xml:"ChannelName"`
	CreateTime  int    `json:"CreateTime" xml:"CreateTime"`
	UpdateTime  int    `json:"UpdateTime" xml:"UpdateTime"`
}

RegionDo is a nested struct in ons response

type RunningDataList

type RunningDataList struct {
	ConsumerRunningDataDo []ConsumerRunningDataDo `json:"ConsumerRunningDataDo" xml:"ConsumerRunningDataDo"`
}

RunningDataList is a nested struct in ons response

type StatsDataDo

type StatsDataDo struct {
	X int     `json:"X" xml:"X"`
	Y float64 `json:"Y" xml:"Y"`
}

StatsDataDo is a nested struct in ons response

type SubClientInfoDo

type SubClientInfoDo struct {
	SubGroupName   string `json:"SubGroupName" xml:"SubGroupName"`
	SubTime        int    `json:"SubTime" xml:"SubTime"`
	ClientHost     string `json:"ClientHost" xml:"ClientHost"`
	ReconsumeTimes int    `json:"ReconsumeTimes" xml:"ReconsumeTimes"`
	CostTime       int    `json:"CostTime" xml:"CostTime"`
	Status         string `json:"Status" xml:"Status"`
}

SubClientInfoDo is a nested struct in ons response

type SubList

type SubList struct {
	SubMapDo []SubMapDo `json:"SubMapDo" xml:"SubMapDo"`
}

SubList is a nested struct in ons response

type SubMapDo

type SubMapDo struct {
	SubGroupName string     `json:"SubGroupName" xml:"SubGroupName"`
	SuccessCount int        `json:"SuccessCount" xml:"SuccessCount"`
	FailCount    int        `json:"FailCount" xml:"FailCount"`
	ClientList   ClientList `json:"ClientList" xml:"ClientList"`
}

SubMapDo is a nested struct in ons response

type SubScriptonData

type SubScriptonData struct {
	SubscriptionDo []SubscriptionDo `json:"SubscriptionDo" xml:"SubscriptionDo"`
}

SubScriptonData is a nested struct in ons response

type SubscribeInfoDo

type SubscribeInfoDo struct {
	Owner             string `json:"Owner" xml:"Owner"`
	GroupId           string `json:"GroupId" xml:"GroupId"`
	UpdateTime        int    `json:"UpdateTime" xml:"UpdateTime"`
	Remark            string `json:"Remark" xml:"Remark"`
	InstanceId        string `json:"InstanceId" xml:"InstanceId"`
	IndependentNaming bool   `json:"IndependentNaming" xml:"IndependentNaming"`
}

SubscribeInfoDo is a nested struct in ons response

type SubscriptionData

type SubscriptionData struct {
	Topic      string  `json:"Topic" xml:"Topic"`
	SubString  string  `json:"SubString" xml:"SubString"`
	SubVersion int     `json:"SubVersion" xml:"SubVersion"`
	TagsSet    TagsSet `json:"TagsSet" xml:"TagsSet"`
}

SubscriptionData is a nested struct in ons response

type SubscriptionDo

type SubscriptionDo struct {
	ParentTopic string `json:"ParentTopic" xml:"ParentTopic"`
	SubTopic    string `json:"SubTopic" xml:"SubTopic"`
	Qos         int    `json:"Qos" xml:"Qos"`
}

SubscriptionDo is a nested struct in ons response

type SubscriptionSet

type SubscriptionSet struct {
	SubscriptionData []SubscriptionData `json:"SubscriptionData" xml:"SubscriptionData"`
}

SubscriptionSet is a nested struct in ons response

type TagsSet

type TagsSet struct {
	Tag []string `json:"Tag" xml:"Tag"`
}

TagsSet is a nested struct in ons response

type ThreadTrackDo

type ThreadTrackDo struct {
	Thread    string    `json:"Thread" xml:"Thread"`
	TrackList TrackList `json:"TrackList" xml:"TrackList"`
}

ThreadTrackDo is a nested struct in ons response

type TraceData

type TraceData struct {
	QueryId    string    `json:"QueryId" xml:"QueryId"`
	UserId     string    `json:"UserId" xml:"UserId"`
	Topic      string    `json:"Topic" xml:"Topic"`
	MsgId      string    `json:"MsgId" xml:"MsgId"`
	MsgKey     string    `json:"MsgKey" xml:"MsgKey"`
	Status     string    `json:"Status" xml:"Status"`
	CreateTime int       `json:"CreateTime" xml:"CreateTime"`
	UpdateTime int       `json:"UpdateTime" xml:"UpdateTime"`
	InstanceId string    `json:"InstanceId" xml:"InstanceId"`
	TraceList  TraceList `json:"TraceList" xml:"TraceList"`
}

TraceData is a nested struct in ons response

type TraceList

type TraceList struct {
	TraceMapDo []TraceMapDo `json:"TraceMapDo" xml:"TraceMapDo"`
}

TraceList is a nested struct in ons response

type TraceMapDo

type TraceMapDo struct {
	PubTime      int     `json:"PubTime" xml:"PubTime"`
	Topic        string  `json:"Topic" xml:"Topic"`
	PubGroupName string  `json:"PubGroupName" xml:"PubGroupName"`
	MsgId        string  `json:"MsgId" xml:"MsgId"`
	Tag          string  `json:"Tag" xml:"Tag"`
	MsgKey       string  `json:"MsgKey" xml:"MsgKey"`
	BornHost     string  `json:"BornHost" xml:"BornHost"`
	CostTime     int     `json:"CostTime" xml:"CostTime"`
	Status       string  `json:"Status" xml:"Status"`
	SubList      SubList `json:"SubList" xml:"SubList"`
}

TraceMapDo is a nested struct in ons response

type TrackList

type TrackList struct {
	Track []string `json:"Track" xml:"Track"`
}

TrackList is a nested struct in ons response