ONS SDK Auto Released By wenting.ywt,Version：1.53.75

Signed-off-by: haowei.yao <haowei.yao@alibaba-inc.com>

ChangeLog.txt

@@ -1,3 +1,8 @@
+2019-03-27 Version: 1.53.75
+1, Add DLQ message openAPI.
+2, Add Query the subscription relational openAPI.
+3, Remove white list restrictions.
+
 2019-03-21 Version: 1.53.74
 1, Update Dependency
 

services/ons/ons_dlq_message_get_by_id.go

@@ -0,0 +1,108 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// OnsDLQMessageGetById invokes the ons.OnsDLQMessageGetById API synchronously
+// api document: https://help.aliyun.com/api/ons/onsdlqmessagegetbyid.html
+func (client *Client) OnsDLQMessageGetById(request *OnsDLQMessageGetByIdRequest) (response *OnsDLQMessageGetByIdResponse, err error) {
+	response = CreateOnsDLQMessageGetByIdResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// OnsDLQMessageGetByIdWithChan invokes the ons.OnsDLQMessageGetById API asynchronously
+// api document: https://help.aliyun.com/api/ons/onsdlqmessagegetbyid.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) OnsDLQMessageGetByIdWithChan(request *OnsDLQMessageGetByIdRequest) (<-chan *OnsDLQMessageGetByIdResponse, <-chan error) {
+	responseChan := make(chan *OnsDLQMessageGetByIdResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.OnsDLQMessageGetById(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// OnsDLQMessageGetByIdWithCallback invokes the ons.OnsDLQMessageGetById API asynchronously
+// api document: https://help.aliyun.com/api/ons/onsdlqmessagegetbyid.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) OnsDLQMessageGetByIdWithCallback(request *OnsDLQMessageGetByIdRequest, callback func(response *OnsDLQMessageGetByIdResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *OnsDLQMessageGetByIdResponse
+		var err error
+		defer close(result)
+		response, err = client.OnsDLQMessageGetById(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// OnsDLQMessageGetByIdRequest is the request struct for api OnsDLQMessageGetById
+type OnsDLQMessageGetByIdRequest struct {
+	*requests.RpcRequest
+	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
+	InstanceId   string           `position:"Query" name:"InstanceId"`
+	GroupId      string           `position:"Query" name:"GroupId"`
+	MsgId        string           `position:"Query" name:"MsgId"`
+}
+
+// OnsDLQMessageGetByIdResponse is the response struct for api OnsDLQMessageGetById
+type OnsDLQMessageGetByIdResponse struct {
+	*responses.BaseResponse
+	RequestId string `json:"RequestId" xml:"RequestId"`
+	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
+	Data      Data   `json:"Data" xml:"Data"`
+}
+
+// CreateOnsDLQMessageGetByIdRequest creates a request to invoke OnsDLQMessageGetById API
+func CreateOnsDLQMessageGetByIdRequest() (request *OnsDLQMessageGetByIdRequest) {
+	request = &OnsDLQMessageGetByIdRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Ons", "2019-02-14", "OnsDLQMessageGetById", "ons", "openAPI")
+	return
+}
+
+// CreateOnsDLQMessageGetByIdResponse creates a response to parse from OnsDLQMessageGetById response
+func CreateOnsDLQMessageGetByIdResponse() (response *OnsDLQMessageGetByIdResponse) {
+	response = &OnsDLQMessageGetByIdResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/ons/ons_dlq_message_page_query_by_group_id.go

@@ -0,0 +1,112 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// OnsDLQMessagePageQueryByGroupId invokes the ons.OnsDLQMessagePageQueryByGroupId API synchronously
+// api document: https://help.aliyun.com/api/ons/onsdlqmessagepagequerybygroupid.html
+func (client *Client) OnsDLQMessagePageQueryByGroupId(request *OnsDLQMessagePageQueryByGroupIdRequest) (response *OnsDLQMessagePageQueryByGroupIdResponse, err error) {
+	response = CreateOnsDLQMessagePageQueryByGroupIdResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// OnsDLQMessagePageQueryByGroupIdWithChan invokes the ons.OnsDLQMessagePageQueryByGroupId API asynchronously
+// api document: https://help.aliyun.com/api/ons/onsdlqmessagepagequerybygroupid.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) OnsDLQMessagePageQueryByGroupIdWithChan(request *OnsDLQMessagePageQueryByGroupIdRequest) (<-chan *OnsDLQMessagePageQueryByGroupIdResponse, <-chan error) {
+	responseChan := make(chan *OnsDLQMessagePageQueryByGroupIdResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.OnsDLQMessagePageQueryByGroupId(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// OnsDLQMessagePageQueryByGroupIdWithCallback invokes the ons.OnsDLQMessagePageQueryByGroupId API asynchronously
+// api document: https://help.aliyun.com/api/ons/onsdlqmessagepagequerybygroupid.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) OnsDLQMessagePageQueryByGroupIdWithCallback(request *OnsDLQMessagePageQueryByGroupIdRequest, callback func(response *OnsDLQMessagePageQueryByGroupIdResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *OnsDLQMessagePageQueryByGroupIdResponse
+		var err error
+		defer close(result)
+		response, err = client.OnsDLQMessagePageQueryByGroupId(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// OnsDLQMessagePageQueryByGroupIdRequest is the request struct for api OnsDLQMessagePageQueryByGroupId
+type OnsDLQMessagePageQueryByGroupIdRequest struct {
+	*requests.RpcRequest
+	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
+	InstanceId   string           `position:"Query" name:"InstanceId"`
+	GroupId      string           `position:"Query" name:"GroupId"`
+	PageSize     requests.Integer `position:"Query" name:"PageSize"`
+	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"`
+}
+
+// OnsDLQMessagePageQueryByGroupIdResponse is the response struct for api OnsDLQMessagePageQueryByGroupId
+type OnsDLQMessagePageQueryByGroupIdResponse struct {
+	*responses.BaseResponse
+	RequestId  string     `json:"RequestId" xml:"RequestId"`
+	HelpUrl    string     `json:"HelpUrl" xml:"HelpUrl"`
+	MsgFoundDo MsgFoundDo `json:"MsgFoundDo" xml:"MsgFoundDo"`
+}
+
+// CreateOnsDLQMessagePageQueryByGroupIdRequest creates a request to invoke OnsDLQMessagePageQueryByGroupId API
+func CreateOnsDLQMessagePageQueryByGroupIdRequest() (request *OnsDLQMessagePageQueryByGroupIdRequest) {
+	request = &OnsDLQMessagePageQueryByGroupIdRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Ons", "2019-02-14", "OnsDLQMessagePageQueryByGroupId", "ons", "openAPI")
+	return
+}
+
+// CreateOnsDLQMessagePageQueryByGroupIdResponse creates a response to parse from OnsDLQMessagePageQueryByGroupId response
+func CreateOnsDLQMessagePageQueryByGroupIdResponse() (response *OnsDLQMessagePageQueryByGroupIdResponse) {
+	response = &OnsDLQMessagePageQueryByGroupIdResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/ons/ons_dlq_message_resend_by_id.go

@@ -0,0 +1,108 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// OnsDLQMessageResendById invokes the ons.OnsDLQMessageResendById API synchronously
+// api document: https://help.aliyun.com/api/ons/onsdlqmessageresendbyid.html
+func (client *Client) OnsDLQMessageResendById(request *OnsDLQMessageResendByIdRequest) (response *OnsDLQMessageResendByIdResponse, err error) {
+	response = CreateOnsDLQMessageResendByIdResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// OnsDLQMessageResendByIdWithChan invokes the ons.OnsDLQMessageResendById API asynchronously
+// api document: https://help.aliyun.com/api/ons/onsdlqmessageresendbyid.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) OnsDLQMessageResendByIdWithChan(request *OnsDLQMessageResendByIdRequest) (<-chan *OnsDLQMessageResendByIdResponse, <-chan error) {
+	responseChan := make(chan *OnsDLQMessageResendByIdResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.OnsDLQMessageResendById(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// OnsDLQMessageResendByIdWithCallback invokes the ons.OnsDLQMessageResendById API asynchronously
+// api document: https://help.aliyun.com/api/ons/onsdlqmessageresendbyid.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) OnsDLQMessageResendByIdWithCallback(request *OnsDLQMessageResendByIdRequest, callback func(response *OnsDLQMessageResendByIdResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *OnsDLQMessageResendByIdResponse
+		var err error
+		defer close(result)
+		response, err = client.OnsDLQMessageResendById(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// OnsDLQMessageResendByIdRequest is the request struct for api OnsDLQMessageResendById
+type OnsDLQMessageResendByIdRequest struct {
+	*requests.RpcRequest
+	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
+	InstanceId   string           `position:"Query" name:"InstanceId"`
+	GroupId      string           `position:"Query" name:"GroupId"`
+	MsgId        string           `position:"Query" name:"MsgId"`
+}
+
+// OnsDLQMessageResendByIdResponse is the response struct for api OnsDLQMessageResendById
+type OnsDLQMessageResendByIdResponse struct {
+	*responses.BaseResponse
+	RequestId string                        `json:"RequestId" xml:"RequestId"`
+	HelpUrl   string                        `json:"HelpUrl" xml:"HelpUrl"`
+	Data      DataInOnsDLQMessageResendById `json:"Data" xml:"Data"`
+}
+
+// CreateOnsDLQMessageResendByIdRequest creates a request to invoke OnsDLQMessageResendById API
+func CreateOnsDLQMessageResendByIdRequest() (request *OnsDLQMessageResendByIdRequest) {
+	request = &OnsDLQMessageResendByIdRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Ons", "2019-02-14", "OnsDLQMessageResendById", "ons", "openAPI")
+	return
+}
+
+// CreateOnsDLQMessageResendByIdResponse creates a response to parse from OnsDLQMessageResendById response
+func CreateOnsDLQMessageResendByIdResponse() (response *OnsDLQMessageResendByIdResponse) {
+	response = &OnsDLQMessageResendByIdResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/ons/ons_group_sub_detail.go

@@ -0,0 +1,106 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// OnsGroupSubDetail invokes the ons.OnsGroupSubDetail API synchronously
+// api document: https://help.aliyun.com/api/ons/onsgroupsubdetail.html
+func (client *Client) OnsGroupSubDetail(request *OnsGroupSubDetailRequest) (response *OnsGroupSubDetailResponse, err error) {
+	response = CreateOnsGroupSubDetailResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// OnsGroupSubDetailWithChan invokes the ons.OnsGroupSubDetail API asynchronously
+// api document: https://help.aliyun.com/api/ons/onsgroupsubdetail.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) OnsGroupSubDetailWithChan(request *OnsGroupSubDetailRequest) (<-chan *OnsGroupSubDetailResponse, <-chan error) {
+	responseChan := make(chan *OnsGroupSubDetailResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.OnsGroupSubDetail(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// OnsGroupSubDetailWithCallback invokes the ons.OnsGroupSubDetail API asynchronously
+// api document: https://help.aliyun.com/api/ons/onsgroupsubdetail.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) OnsGroupSubDetailWithCallback(request *OnsGroupSubDetailRequest, callback func(response *OnsGroupSubDetailResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *OnsGroupSubDetailResponse
+		var err error
+		defer close(result)
+		response, err = client.OnsGroupSubDetail(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// OnsGroupSubDetailRequest is the request struct for api OnsGroupSubDetail
+type OnsGroupSubDetailRequest struct {
+	*requests.RpcRequest
+	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
+	InstanceId   string           `position:"Query" name:"InstanceId"`
+	GroupId      string           `position:"Query" name:"GroupId"`
+}
+
+// OnsGroupSubDetailResponse is the response struct for api OnsGroupSubDetail
+type OnsGroupSubDetailResponse struct {
+	*responses.BaseResponse
+	RequestId string `json:"RequestId" xml:"RequestId"`
+	Data      Data   `json:"Data" xml:"Data"`
+}
+
+// CreateOnsGroupSubDetailRequest creates a request to invoke OnsGroupSubDetail API
+func CreateOnsGroupSubDetailRequest() (request *OnsGroupSubDetailRequest) {
+	request = &OnsGroupSubDetailRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Ons", "2019-02-14", "OnsGroupSubDetail", "ons", "openAPI")
+	return
+}
+
+// CreateOnsGroupSubDetailResponse creates a response to parse from OnsGroupSubDetail response
+func CreateOnsGroupSubDetailResponse() (response *OnsGroupSubDetailResponse) {
+	response = &OnsGroupSubDetailResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/ons/ons_topic_sub_detail.go

@@ -0,0 +1,106 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// OnsTopicSubDetail invokes the ons.OnsTopicSubDetail API synchronously
+// api document: https://help.aliyun.com/api/ons/onstopicsubdetail.html
+func (client *Client) OnsTopicSubDetail(request *OnsTopicSubDetailRequest) (response *OnsTopicSubDetailResponse, err error) {
+	response = CreateOnsTopicSubDetailResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// OnsTopicSubDetailWithChan invokes the ons.OnsTopicSubDetail API asynchronously
+// api document: https://help.aliyun.com/api/ons/onstopicsubdetail.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) OnsTopicSubDetailWithChan(request *OnsTopicSubDetailRequest) (<-chan *OnsTopicSubDetailResponse, <-chan error) {
+	responseChan := make(chan *OnsTopicSubDetailResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.OnsTopicSubDetail(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// OnsTopicSubDetailWithCallback invokes the ons.OnsTopicSubDetail API asynchronously
+// api document: https://help.aliyun.com/api/ons/onstopicsubdetail.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) OnsTopicSubDetailWithCallback(request *OnsTopicSubDetailRequest, callback func(response *OnsTopicSubDetailResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *OnsTopicSubDetailResponse
+		var err error
+		defer close(result)
+		response, err = client.OnsTopicSubDetail(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// OnsTopicSubDetailRequest is the request struct for api OnsTopicSubDetail
+type OnsTopicSubDetailRequest struct {
+	*requests.RpcRequest
+	PreventCache requests.Integer `position:"Query" name:"PreventCache"`
+	InstanceId   string           `position:"Query" name:"InstanceId"`
+	Topic        string           `position:"Query" name:"Topic"`
+}
+
+// OnsTopicSubDetailResponse is the response struct for api OnsTopicSubDetail
+type OnsTopicSubDetailResponse struct {
+	*responses.BaseResponse
+	RequestId string `json:"RequestId" xml:"RequestId"`
+	Data      Data   `json:"Data" xml:"Data"`
+}
+
+// CreateOnsTopicSubDetailRequest creates a request to invoke OnsTopicSubDetail API
+func CreateOnsTopicSubDetailRequest() (request *OnsTopicSubDetailRequest) {
+	request = &OnsTopicSubDetailRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Ons", "2019-02-14", "OnsTopicSubDetail", "ons", "openAPI")
+	return
+}
+
+// CreateOnsTopicSubDetailResponse creates a response to parse from OnsTopicSubDetail response
+func CreateOnsTopicSubDetailResponse() (response *OnsTopicSubDetailResponse) {
+	response = &OnsTopicSubDetailResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/ons/struct_data.go

@@ -30,15 +30,17 @@ type Data struct {
 	MaxTimeStamp               int                                      `json:"MaxTimeStamp" xml:"MaxTimeStamp"`
 	InstanceId                 string                                   `json:"InstanceId" xml:"InstanceId"`
 	ConsumeTps                 float64                                  `json:"ConsumeTps" xml:"ConsumeTps"`
+	GroupId                    string                                   `json:"GroupId" xml:"GroupId"`
 	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"`
+	TotalDiff                  int                                      `json:"TotalDiff" xml:"TotalDiff"`
 	Body                       string                                   `json:"Body" xml:"Body"`
 	BornHost                   string                                   `json:"BornHost" xml:"BornHost"`
 	MinTimeStamp               int                                      `json:"MinTimeStamp" xml:"MinTimeStamp"`
 	LastTimeStamp              int                                      `json:"LastTimeStamp" xml:"LastTimeStamp"`
+	MessageModel               string                                   `json:"MessageModel" xml:"MessageModel"`
 	InstanceType               int                                      `json:"InstanceType" xml:"InstanceType"`
 	BodyCRC                    int                                      `json:"BodyCRC" xml:"BodyCRC"`
 	MsgId                      string                                   `json:"MsgId" xml:"MsgId"`
@@ -47,10 +49,12 @@ type Data struct {
 	StoreHost                  string                                   `json:"StoreHost" xml:"StoreHost"`
 	YUnit                      string                                   `json:"YUnit" xml:"YUnit"`
 	LastTimestamp              int                                      `json:"LastTimestamp" xml:"LastTimestamp"`
+	Perm                       int                                      `json:"Perm" xml:"Perm"`
 	ConnectionSet              ConnectionSet                            `json:"ConnectionSet" xml:"ConnectionSet"`
-	PropertyList               PropertyListInOnsMessageGetByMsgId       `json:"PropertyList" xml:"PropertyList"`
+	PropertyList               PropertyListInOnsDLQMessageGetById       `json:"PropertyList" xml:"PropertyList"`
 	Records                    RecordsInOnsMqttQueryHistoryOnline       `json:"Records" xml:"Records"`
 	ConsumerConnectionInfoList ConsumerConnectionInfoList               `json:"ConsumerConnectionInfoList" xml:"ConsumerConnectionInfoList"`
 	DetailInTopicList          DetailInTopicListInOnsConsumerAccumulate `json:"DetailInTopicList" xml:"DetailInTopicList"`
+	SubscriptionDataList       SubscriptionDataListInOnsGroupSubDetail  `json:"SubscriptionDataList" xml:"SubscriptionDataList"`
 	ConnectionList             ConnectionList                           `json:"ConnectionList" xml:"ConnectionList"`
 }

services/ons/struct_data_in_ons_dlq_message_resend_by_id.go

@@ -0,0 +1,21 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// DataInOnsDLQMessageResendById is a nested struct in ons response
+type DataInOnsDLQMessageResendById struct {
+	MsgId []string `json:"MsgId" xml:"MsgId"`
+}

services/ons/struct_instance_base_info.go

@@ -17,10 +17,11 @@ package ons
 
 // InstanceBaseInfo is a nested struct in ons response
 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"`
+	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"`
+	IndependentNaming bool      `json:"IndependentNaming" xml:"IndependentNaming"`
+	Endpoints         Endpoints `json:"Endpoints" xml:"Endpoints"`
 }

services/ons/struct_instance_vo.go

@@ -17,9 +17,10 @@ package ons
 
 // InstanceVO is a nested struct in ons response
 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"`
+	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"`
+	IndependentNaming bool   `json:"IndependentNaming" xml:"IndependentNaming"`
 }

services/ons/struct_msg_found_do.go

@@ -17,8 +17,8 @@ package ons
 
 // MsgFoundDo is a nested struct in ons response
 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"`
+	TaskId       string                                        `json:"TaskId" xml:"TaskId"`
+	MaxPageCount int                                           `json:"MaxPageCount" xml:"MaxPageCount"`
+	CurrentPage  int                                           `json:"CurrentPage" xml:"CurrentPage"`
+	MsgFoundList MsgFoundListInOnsDLQMessagePageQueryByGroupId `json:"MsgFoundList" xml:"MsgFoundList"`
 }

services/ons/struct_msg_found_list_in_ons_dlq_message_page_query_by_group_id.go

@@ -0,0 +1,21 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// MsgFoundListInOnsDLQMessagePageQueryByGroupId is a nested struct in ons response
+type MsgFoundListInOnsDLQMessagePageQueryByGroupId struct {
+	OnsRestMessageDo []OnsRestMessageDo `json:"OnsRestMessageDo" xml:"OnsRestMessageDo"`
+}

services/ons/struct_msg_found_list.go → services/ons/struct_msg_found_list_in_ons_message_page_query_by_topic.go

@@ -15,7 +15,7 @@ package ons
 // Code generated by Alibaba Cloud SDK Code Generator.
 // Changes may cause incorrect behavior and will be lost if the code is regenerated.
 
-// MsgFoundList is a nested struct in ons response
-type MsgFoundList struct {
+// MsgFoundListInOnsMessagePageQueryByTopic is a nested struct in ons response
+type MsgFoundListInOnsMessagePageQueryByTopic struct {
 	OnsRestMessageDo []OnsRestMessageDo `json:"OnsRestMessageDo" xml:"OnsRestMessageDo"`
 }

services/ons/struct_ons_rest_message_do.go

@@ -17,18 +17,18 @@ package ons
 
 // OnsRestMessageDo is a nested struct in ons response
 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"`
+	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   PropertyListInOnsDLQMessagePageQueryByGroupId `json:"PropertyList" xml:"PropertyList"`
 }

services/ons/struct_property_list_in_ons_dlq_message_get_by_id.go

@@ -0,0 +1,21 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// PropertyListInOnsDLQMessageGetById is a nested struct in ons response
+type PropertyListInOnsDLQMessageGetById struct {
+	MessageProperty []MessageProperty `json:"MessageProperty" xml:"MessageProperty"`
+}

services/ons/struct_property_list_in_ons_dlq_message_page_query_by_group_id.go

@@ -0,0 +1,21 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// PropertyListInOnsDLQMessagePageQueryByGroupId is a nested struct in ons response
+type PropertyListInOnsDLQMessagePageQueryByGroupId struct {
+	MessageProperty []MessageProperty `json:"MessageProperty" xml:"MessageProperty"`
+}

services/ons/struct_publish_info_do.go

@@ -21,7 +21,7 @@ type PublishInfoDo struct {
 	Owner             string `json:"Owner" xml:"Owner"`
 	Relation          int    `json:"Relation" xml:"Relation"`
 	RelationName      string `json:"RelationName" xml:"RelationName"`
-	UpdateTime        int    `json:"UpdateTime" xml:"UpdateTime"`
+	CreateTime        int    `json:"CreateTime" xml:"CreateTime"`
 	Remark            string `json:"Remark" xml:"Remark"`
 	MessageType       int    `json:"MessageType" xml:"MessageType"`
 	InstanceId        string `json:"InstanceId" xml:"InstanceId"`

services/ons/struct_subscription_data_list_in_ons_group_sub_detail.go

@@ -0,0 +1,21 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// SubscriptionDataListInOnsGroupSubDetail is a nested struct in ons response
+type SubscriptionDataListInOnsGroupSubDetail struct {
+	SubscriptionDataListItem []SubscriptionDataListItem `json:"SubscriptionDataListItem" xml:"SubscriptionDataListItem"`
+}

services/ons/struct_subscription_data_list_in_ons_topic_sub_detail.go

@@ -0,0 +1,21 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// SubscriptionDataListInOnsTopicSubDetail is a nested struct in ons response
+type SubscriptionDataListInOnsTopicSubDetail struct {
+	SubscriptionDataListItem []SubscriptionDataListItem `json:"SubscriptionDataListItem" xml:"SubscriptionDataListItem"`
+}

services/ons/struct_subscription_data_list_item.go

@@ -0,0 +1,24 @@
+package ons
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// SubscriptionDataListItem is a nested struct in ons response
+type SubscriptionDataListItem struct {
+	MessageModel string `json:"MessageModel" xml:"MessageModel"`
+	SubString    string `json:"SubString" xml:"SubString"`
+	GroupId      string `json:"GroupId" xml:"GroupId"`
+	Topic        string `json:"Topic" xml:"Topic"`
+}