ons

package
v1.63.65 Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2024 License: Apache-2.0 Imports: 6 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EndpointMap map[string]string

EndpointMap Endpoint Data

View Source 
var EndpointType = "regional"

EndpointType regional or central

Functions

func GetEndpointMap added in v1.60.299 

func GetEndpointMap() map[string]string

GetEndpointMap Get Endpoint Data Map

func GetEndpointType added in v1.60.299 

func GetEndpointType() string

GetEndpointType Get Endpoint Type Value

func SetClientProperty added in v1.60.299 

func SetClientProperty(client *Client, propertyName string, propertyValue interface{})

SetClientProperty Set Property by Reflect

func SetEndpointDataToClient added in v1.60.299 

func SetEndpointDataToClient(client *Client)

SetEndpointDataToClient Set EndpointMap and ENdpointType

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://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

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://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithOptions 

func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)

NewClientWithOptions creates a sdk client with regionId/sdkConfig/credential this is the common api to create a sdk client

func NewClientWithProvider added in v1.60.299 

func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)

NewClientWithProvider creates a sdk client with providers usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithRamRoleArn 

func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)

NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithRamRoleArnAndPolicy added in v1.60.299 

func NewClientWithRamRoleArnAndPolicy(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName, policy string) (client *Client, err error)

NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn and policy usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithRsaKeyPair 

func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)

NewClientWithRsaKeyPair is a shortcut to create sdk client with rsa key pair usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithStsToken 

func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)

NewClientWithStsToken is a shortcut to create sdk client with sts token usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func (*Client) ListTagResources added in v1.61.304 

func (client *Client) ListTagResources(request *ListTagResourcesRequest) (response *ListTagResourcesResponse, err error)

ListTagResources invokes the ons.ListTagResources API synchronously

func (*Client) ListTagResourcesWithCallback added in v1.61.304 

func (client *Client) ListTagResourcesWithCallback(request *ListTagResourcesRequest, callback func(response *ListTagResourcesResponse, err error)) <-chan int

ListTagResourcesWithCallback invokes the ons.ListTagResources API asynchronously

func (*Client) ListTagResourcesWithChan added in v1.61.304 

func (client *Client) ListTagResourcesWithChan(request *ListTagResourcesRequest) (<-chan *ListTagResourcesResponse, <-chan error)

ListTagResourcesWithChan invokes the ons.ListTagResources API asynchronously

func (*Client) OnsConsumerAccumulate 

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

OnsConsumerAccumulate invokes the ons.OnsConsumerAccumulate API synchronously

func (*Client) OnsConsumerAccumulateWithCallback 

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

OnsConsumerAccumulateWithCallback invokes the ons.OnsConsumerAccumulate API asynchronously

func (*Client) OnsConsumerAccumulateWithChan 

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

OnsConsumerAccumulateWithChan invokes the ons.OnsConsumerAccumulate API asynchronously

func (*Client) OnsConsumerGetConnection 

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

OnsConsumerGetConnection invokes the ons.OnsConsumerGetConnection API synchronously

func (*Client) OnsConsumerGetConnectionWithCallback 

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

OnsConsumerGetConnectionWithCallback invokes the ons.OnsConsumerGetConnection API asynchronously

func (*Client) OnsConsumerGetConnectionWithChan 

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

OnsConsumerGetConnectionWithChan invokes the ons.OnsConsumerGetConnection API asynchronously

func (*Client) OnsConsumerResetOffset 

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

OnsConsumerResetOffset invokes the ons.OnsConsumerResetOffset API synchronously

func (*Client) OnsConsumerResetOffsetWithCallback 

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

OnsConsumerResetOffsetWithCallback invokes the ons.OnsConsumerResetOffset API asynchronously

func (*Client) OnsConsumerResetOffsetWithChan 

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

OnsConsumerResetOffsetWithChan invokes the ons.OnsConsumerResetOffset API asynchronously

func (*Client) OnsConsumerStatus 

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

OnsConsumerStatus invokes the ons.OnsConsumerStatus API synchronously

func (*Client) OnsConsumerStatusWithCallback 

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

OnsConsumerStatusWithCallback invokes the ons.OnsConsumerStatus API asynchronously

func (*Client) OnsConsumerStatusWithChan 

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

OnsConsumerStatusWithChan invokes the ons.OnsConsumerStatus API asynchronously

func (*Client) OnsConsumerTimeSpan 

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

OnsConsumerTimeSpan invokes the ons.OnsConsumerTimeSpan API synchronously

func (*Client) OnsConsumerTimeSpanWithCallback 

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

OnsConsumerTimeSpanWithCallback invokes the ons.OnsConsumerTimeSpan API asynchronously

func (*Client) OnsConsumerTimeSpanWithChan 

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

OnsConsumerTimeSpanWithChan invokes the ons.OnsConsumerTimeSpan API asynchronously

func (*Client) OnsDLQMessageGetById 

func (client *Client) OnsDLQMessageGetById(request *OnsDLQMessageGetByIdRequest) (response *OnsDLQMessageGetByIdResponse, err error)

OnsDLQMessageGetById invokes the ons.OnsDLQMessageGetById API synchronously

func (*Client) OnsDLQMessageGetByIdWithCallback 

func (client *Client) OnsDLQMessageGetByIdWithCallback(request *OnsDLQMessageGetByIdRequest, callback func(response *OnsDLQMessageGetByIdResponse, err error)) <-chan int

OnsDLQMessageGetByIdWithCallback invokes the ons.OnsDLQMessageGetById API asynchronously

func (*Client) OnsDLQMessageGetByIdWithChan 

func (client *Client) OnsDLQMessageGetByIdWithChan(request *OnsDLQMessageGetByIdRequest) (<-chan *OnsDLQMessageGetByIdResponse, <-chan error)

OnsDLQMessageGetByIdWithChan invokes the ons.OnsDLQMessageGetById API asynchronously

func (*Client) OnsDLQMessagePageQueryByGroupId 

func (client *Client) OnsDLQMessagePageQueryByGroupId(request *OnsDLQMessagePageQueryByGroupIdRequest) (response *OnsDLQMessagePageQueryByGroupIdResponse, err error)

OnsDLQMessagePageQueryByGroupId invokes the ons.OnsDLQMessagePageQueryByGroupId API synchronously

func (*Client) OnsDLQMessagePageQueryByGroupIdWithCallback 

func (client *Client) OnsDLQMessagePageQueryByGroupIdWithCallback(request *OnsDLQMessagePageQueryByGroupIdRequest, callback func(response *OnsDLQMessagePageQueryByGroupIdResponse, err error)) <-chan int

OnsDLQMessagePageQueryByGroupIdWithCallback invokes the ons.OnsDLQMessagePageQueryByGroupId API asynchronously

func (*Client) OnsDLQMessagePageQueryByGroupIdWithChan 

func (client *Client) OnsDLQMessagePageQueryByGroupIdWithChan(request *OnsDLQMessagePageQueryByGroupIdRequest) (<-chan *OnsDLQMessagePageQueryByGroupIdResponse, <-chan error)

OnsDLQMessagePageQueryByGroupIdWithChan invokes the ons.OnsDLQMessagePageQueryByGroupId API asynchronously

func (*Client) OnsDLQMessageResendById 

func (client *Client) OnsDLQMessageResendById(request *OnsDLQMessageResendByIdRequest) (response *OnsDLQMessageResendByIdResponse, err error)

OnsDLQMessageResendById invokes the ons.OnsDLQMessageResendById API synchronously

func (*Client) OnsDLQMessageResendByIdWithCallback 

func (client *Client) OnsDLQMessageResendByIdWithCallback(request *OnsDLQMessageResendByIdRequest, callback func(response *OnsDLQMessageResendByIdResponse, err error)) <-chan int

OnsDLQMessageResendByIdWithCallback invokes the ons.OnsDLQMessageResendById API asynchronously

func (*Client) OnsDLQMessageResendByIdWithChan 

func (client *Client) OnsDLQMessageResendByIdWithChan(request *OnsDLQMessageResendByIdRequest) (<-chan *OnsDLQMessageResendByIdResponse, <-chan error)

OnsDLQMessageResendByIdWithChan invokes the ons.OnsDLQMessageResendById API asynchronously

func (*Client) OnsGroupConsumerUpdate 

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

OnsGroupConsumerUpdate invokes the ons.OnsGroupConsumerUpdate API synchronously

func (*Client) OnsGroupConsumerUpdateWithCallback 

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

OnsGroupConsumerUpdateWithCallback invokes the ons.OnsGroupConsumerUpdate API asynchronously

func (*Client) OnsGroupConsumerUpdateWithChan 

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

OnsGroupConsumerUpdateWithChan invokes the ons.OnsGroupConsumerUpdate API asynchronously

func (*Client) OnsGroupCreate 

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

OnsGroupCreate invokes the ons.OnsGroupCreate API synchronously

func (*Client) OnsGroupCreateWithCallback 

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

OnsGroupCreateWithCallback invokes the ons.OnsGroupCreate API asynchronously

func (*Client) OnsGroupCreateWithChan 

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

OnsGroupCreateWithChan invokes the ons.OnsGroupCreate API asynchronously

func (*Client) OnsGroupDelete 

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

OnsGroupDelete invokes the ons.OnsGroupDelete API synchronously

func (*Client) OnsGroupDeleteWithCallback 

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

OnsGroupDeleteWithCallback invokes the ons.OnsGroupDelete API asynchronously

func (*Client) OnsGroupDeleteWithChan 

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

OnsGroupDeleteWithChan invokes the ons.OnsGroupDelete API asynchronously

func (*Client) OnsGroupList 

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

OnsGroupList invokes the ons.OnsGroupList API synchronously

func (*Client) OnsGroupListWithCallback 

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

OnsGroupListWithCallback invokes the ons.OnsGroupList API asynchronously

func (*Client) OnsGroupListWithChan 

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

OnsGroupListWithChan invokes the ons.OnsGroupList API asynchronously

func (*Client) OnsGroupSubDetail 

func (client *Client) OnsGroupSubDetail(request *OnsGroupSubDetailRequest) (response *OnsGroupSubDetailResponse, err error)

OnsGroupSubDetail invokes the ons.OnsGroupSubDetail API synchronously

func (*Client) OnsGroupSubDetailWithCallback 

func (client *Client) OnsGroupSubDetailWithCallback(request *OnsGroupSubDetailRequest, callback func(response *OnsGroupSubDetailResponse, err error)) <-chan int

OnsGroupSubDetailWithCallback invokes the ons.OnsGroupSubDetail API asynchronously

func (*Client) OnsGroupSubDetailWithChan 

func (client *Client) OnsGroupSubDetailWithChan(request *OnsGroupSubDetailRequest) (<-chan *OnsGroupSubDetailResponse, <-chan error)

OnsGroupSubDetailWithChan invokes the ons.OnsGroupSubDetail API asynchronously

func (*Client) OnsInstanceBaseInfo 

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

OnsInstanceBaseInfo invokes the ons.OnsInstanceBaseInfo API synchronously

func (*Client) OnsInstanceBaseInfoWithCallback 

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

OnsInstanceBaseInfoWithCallback invokes the ons.OnsInstanceBaseInfo API asynchronously

func (*Client) OnsInstanceBaseInfoWithChan 

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

OnsInstanceBaseInfoWithChan invokes the ons.OnsInstanceBaseInfo API asynchronously

func (*Client) OnsInstanceCreate 

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

OnsInstanceCreate invokes the ons.OnsInstanceCreate API synchronously

func (*Client) OnsInstanceCreateWithCallback 

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

OnsInstanceCreateWithCallback invokes the ons.OnsInstanceCreate API asynchronously

func (*Client) OnsInstanceCreateWithChan 

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

OnsInstanceCreateWithChan invokes the ons.OnsInstanceCreate API asynchronously

func (*Client) OnsInstanceDelete 

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

OnsInstanceDelete invokes the ons.OnsInstanceDelete API synchronously

func (*Client) OnsInstanceDeleteWithCallback 

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

OnsInstanceDeleteWithCallback invokes the ons.OnsInstanceDelete API asynchronously

func (*Client) OnsInstanceDeleteWithChan 

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

OnsInstanceDeleteWithChan invokes the ons.OnsInstanceDelete API asynchronously

func (*Client) OnsInstanceInServiceList 

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

OnsInstanceInServiceList invokes the ons.OnsInstanceInServiceList API synchronously

func (*Client) OnsInstanceInServiceListWithCallback 

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

OnsInstanceInServiceListWithCallback invokes the ons.OnsInstanceInServiceList API asynchronously

func (*Client) OnsInstanceInServiceListWithChan 

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

OnsInstanceInServiceListWithChan invokes the ons.OnsInstanceInServiceList API asynchronously

func (*Client) OnsInstanceUpdate 

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

OnsInstanceUpdate invokes the ons.OnsInstanceUpdate API synchronously

func (*Client) OnsInstanceUpdateWithCallback 

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

OnsInstanceUpdateWithCallback invokes the ons.OnsInstanceUpdate API asynchronously

func (*Client) OnsInstanceUpdateWithChan 

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

OnsInstanceUpdateWithChan invokes the ons.OnsInstanceUpdate API asynchronously

func (*Client) OnsMessageDetail added in v1.62.127 

func (client *Client) OnsMessageDetail(request *OnsMessageDetailRequest) (response *OnsMessageDetailResponse, err error)

OnsMessageDetail invokes the ons.OnsMessageDetail API synchronously

func (*Client) OnsMessageDetailWithCallback added in v1.62.127 

func (client *Client) OnsMessageDetailWithCallback(request *OnsMessageDetailRequest, callback func(response *OnsMessageDetailResponse, err error)) <-chan int

OnsMessageDetailWithCallback invokes the ons.OnsMessageDetail API asynchronously

func (*Client) OnsMessageDetailWithChan added in v1.62.127 

func (client *Client) OnsMessageDetailWithChan(request *OnsMessageDetailRequest) (<-chan *OnsMessageDetailResponse, <-chan error)

OnsMessageDetailWithChan invokes the ons.OnsMessageDetail API asynchronously

func (*Client) OnsMessageGetByKey 

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

OnsMessageGetByKey invokes the ons.OnsMessageGetByKey API synchronously

func (*Client) OnsMessageGetByKeyWithCallback 

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

OnsMessageGetByKeyWithCallback invokes the ons.OnsMessageGetByKey API asynchronously

func (*Client) OnsMessageGetByKeyWithChan 

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

OnsMessageGetByKeyWithChan invokes the ons.OnsMessageGetByKey API asynchronously

func (*Client) OnsMessageGetByMsgId 

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

OnsMessageGetByMsgId invokes the ons.OnsMessageGetByMsgId API synchronously

func (*Client) OnsMessageGetByMsgIdWithCallback 

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

OnsMessageGetByMsgIdWithCallback invokes the ons.OnsMessageGetByMsgId API asynchronously

func (*Client) OnsMessageGetByMsgIdWithChan 

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

OnsMessageGetByMsgIdWithChan invokes the ons.OnsMessageGetByMsgId API asynchronously

func (*Client) OnsMessagePageQueryByTopic 

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

OnsMessagePageQueryByTopic invokes the ons.OnsMessagePageQueryByTopic API synchronously

func (*Client) OnsMessagePageQueryByTopicWithCallback 

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

OnsMessagePageQueryByTopicWithCallback invokes the ons.OnsMessagePageQueryByTopic API asynchronously

func (*Client) OnsMessagePageQueryByTopicWithChan 

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

OnsMessagePageQueryByTopicWithChan invokes the ons.OnsMessagePageQueryByTopic API asynchronously

func (*Client) OnsMessagePush 

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

OnsMessagePush invokes the ons.OnsMessagePush API synchronously

func (*Client) OnsMessagePushWithCallback 

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

OnsMessagePushWithCallback invokes the ons.OnsMessagePush API asynchronously

func (*Client) OnsMessagePushWithChan 

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

OnsMessagePushWithChan invokes the ons.OnsMessagePush API asynchronously

func (*Client) OnsMessageTrace 

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

OnsMessageTrace invokes the ons.OnsMessageTrace API synchronously

func (*Client) OnsMessageTraceWithCallback 

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

OnsMessageTraceWithCallback invokes the ons.OnsMessageTrace API asynchronously

func (*Client) OnsMessageTraceWithChan 

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

OnsMessageTraceWithChan invokes the ons.OnsMessageTrace API asynchronously

func (*Client) OnsRegionList 

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

OnsRegionList invokes the ons.OnsRegionList API synchronously

func (*Client) OnsRegionListWithCallback 

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

OnsRegionListWithCallback invokes the ons.OnsRegionList API asynchronously

func (*Client) OnsRegionListWithChan 

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

OnsRegionListWithChan invokes the ons.OnsRegionList API asynchronously

func (*Client) OnsTopicCreate 

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

OnsTopicCreate invokes the ons.OnsTopicCreate API synchronously

func (*Client) OnsTopicCreateWithCallback 

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

OnsTopicCreateWithCallback invokes the ons.OnsTopicCreate API asynchronously

func (*Client) OnsTopicCreateWithChan 

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

OnsTopicCreateWithChan invokes the ons.OnsTopicCreate API asynchronously

func (*Client) OnsTopicDelete 

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

OnsTopicDelete invokes the ons.OnsTopicDelete API synchronously

func (*Client) OnsTopicDeleteWithCallback 

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

OnsTopicDeleteWithCallback invokes the ons.OnsTopicDelete API asynchronously

func (*Client) OnsTopicDeleteWithChan 

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

OnsTopicDeleteWithChan invokes the ons.OnsTopicDelete API asynchronously

func (*Client) OnsTopicList 

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

OnsTopicList invokes the ons.OnsTopicList API synchronously

func (*Client) OnsTopicListWithCallback 

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

OnsTopicListWithCallback invokes the ons.OnsTopicList API asynchronously

func (*Client) OnsTopicListWithChan 

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

OnsTopicListWithChan invokes the ons.OnsTopicList API asynchronously

func (*Client) OnsTopicStatus 

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

OnsTopicStatus invokes the ons.OnsTopicStatus API synchronously

func (*Client) OnsTopicStatusWithCallback 

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

OnsTopicStatusWithCallback invokes the ons.OnsTopicStatus API asynchronously

func (*Client) OnsTopicStatusWithChan 

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

OnsTopicStatusWithChan invokes the ons.OnsTopicStatus API asynchronously

func (*Client) OnsTopicSubDetail 

func (client *Client) OnsTopicSubDetail(request *OnsTopicSubDetailRequest) (response *OnsTopicSubDetailResponse, err error)

OnsTopicSubDetail invokes the ons.OnsTopicSubDetail API synchronously

func (*Client) OnsTopicSubDetailWithCallback 

func (client *Client) OnsTopicSubDetailWithCallback(request *OnsTopicSubDetailRequest, callback func(response *OnsTopicSubDetailResponse, err error)) <-chan int

OnsTopicSubDetailWithCallback invokes the ons.OnsTopicSubDetail API asynchronously

func (*Client) OnsTopicSubDetailWithChan 

func (client *Client) OnsTopicSubDetailWithChan(request *OnsTopicSubDetailRequest) (<-chan *OnsTopicSubDetailResponse, <-chan error)

OnsTopicSubDetailWithChan invokes the ons.OnsTopicSubDetail API asynchronously

func (*Client) OnsTopicUpdate 

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

OnsTopicUpdate invokes the ons.OnsTopicUpdate API synchronously

func (*Client) OnsTopicUpdateWithCallback 

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

OnsTopicUpdateWithCallback invokes the ons.OnsTopicUpdate API asynchronously

func (*Client) OnsTopicUpdateWithChan 

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

OnsTopicUpdateWithChan invokes the ons.OnsTopicUpdate API asynchronously

func (*Client) OnsTraceGetResult 

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

OnsTraceGetResult invokes the ons.OnsTraceGetResult API synchronously

func (*Client) OnsTraceGetResultWithCallback 

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

OnsTraceGetResultWithCallback invokes the ons.OnsTraceGetResult API asynchronously

func (*Client) OnsTraceGetResultWithChan 

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

OnsTraceGetResultWithChan invokes the ons.OnsTraceGetResult API asynchronously

func (*Client) OnsTraceQueryByMsgId 

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

OnsTraceQueryByMsgId invokes the ons.OnsTraceQueryByMsgId API synchronously

func (*Client) OnsTraceQueryByMsgIdWithCallback 

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

OnsTraceQueryByMsgIdWithCallback invokes the ons.OnsTraceQueryByMsgId API asynchronously

func (*Client) OnsTraceQueryByMsgIdWithChan 

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

OnsTraceQueryByMsgIdWithChan invokes the ons.OnsTraceQueryByMsgId API asynchronously

func (*Client) OnsTraceQueryByMsgKey 

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

OnsTraceQueryByMsgKey invokes the ons.OnsTraceQueryByMsgKey API synchronously

func (*Client) OnsTraceQueryByMsgKeyWithCallback 

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

OnsTraceQueryByMsgKeyWithCallback invokes the ons.OnsTraceQueryByMsgKey API asynchronously

func (*Client) OnsTraceQueryByMsgKeyWithChan 

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

OnsTraceQueryByMsgKeyWithChan invokes the ons.OnsTraceQueryByMsgKey API asynchronously

func (*Client) OnsTrendGroupOutputTps 

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

OnsTrendGroupOutputTps invokes the ons.OnsTrendGroupOutputTps API synchronously

func (*Client) OnsTrendGroupOutputTpsWithCallback 

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

OnsTrendGroupOutputTpsWithCallback invokes the ons.OnsTrendGroupOutputTps API asynchronously

func (*Client) OnsTrendGroupOutputTpsWithChan 

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

OnsTrendGroupOutputTpsWithChan invokes the ons.OnsTrendGroupOutputTps API asynchronously

func (*Client) OnsTrendTopicInputTps 

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

OnsTrendTopicInputTps invokes the ons.OnsTrendTopicInputTps API synchronously

func (*Client) OnsTrendTopicInputTpsWithCallback 

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

OnsTrendTopicInputTpsWithCallback invokes the ons.OnsTrendTopicInputTps API asynchronously

func (*Client) OnsTrendTopicInputTpsWithChan 

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

OnsTrendTopicInputTpsWithChan invokes the ons.OnsTrendTopicInputTps API asynchronously

func (*Client) OpenOnsService added in v1.61.541 

func (client *Client) OpenOnsService(request *OpenOnsServiceRequest) (response *OpenOnsServiceResponse, err error)

OpenOnsService invokes the ons.OpenOnsService API synchronously

func (*Client) OpenOnsServiceWithCallback added in v1.61.541 

func (client *Client) OpenOnsServiceWithCallback(request *OpenOnsServiceRequest, callback func(response *OpenOnsServiceResponse, err error)) <-chan int

OpenOnsServiceWithCallback invokes the ons.OpenOnsService API asynchronously

func (*Client) OpenOnsServiceWithChan added in v1.61.541 

func (client *Client) OpenOnsServiceWithChan(request *OpenOnsServiceRequest) (<-chan *OpenOnsServiceResponse, <-chan error)

OpenOnsServiceWithChan invokes the ons.OpenOnsService API asynchronously

func (*Client) TagResources added in v1.61.304 

func (client *Client) TagResources(request *TagResourcesRequest) (response *TagResourcesResponse, err error)

TagResources invokes the ons.TagResources API synchronously

func (*Client) TagResourcesWithCallback added in v1.61.304 

func (client *Client) TagResourcesWithCallback(request *TagResourcesRequest, callback func(response *TagResourcesResponse, err error)) <-chan int

TagResourcesWithCallback invokes the ons.TagResources API asynchronously

func (*Client) TagResourcesWithChan added in v1.61.304 

func (client *Client) TagResourcesWithChan(request *TagResourcesRequest) (<-chan *TagResourcesResponse, <-chan error)

TagResourcesWithChan invokes the ons.TagResources API asynchronously

func (*Client) UntagResources added in v1.61.304 

func (client *Client) UntagResources(request *UntagResourcesRequest) (response *UntagResourcesResponse, err error)

UntagResources invokes the ons.UntagResources API synchronously

func (*Client) UntagResourcesWithCallback added in v1.61.304 

func (client *Client) UntagResourcesWithCallback(request *UntagResourcesRequest, callback func(response *UntagResourcesResponse, err error)) <-chan int

UntagResourcesWithCallback invokes the ons.UntagResources API asynchronously

func (*Client) UntagResourcesWithChan added in v1.61.304 

func (client *Client) UntagResourcesWithChan(request *UntagResourcesRequest) (<-chan *UntagResourcesResponse, <-chan error)

UntagResourcesWithChan invokes the ons.UntagResources API asynchronously

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"`
	RemoteIP   string `json:"RemoteIP" xml:"RemoteIP"`
}

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 {
	ConsumeModel    string          `json:"ConsumeModel" xml:"ConsumeModel"`
	LastTimeStamp   int64           `json:"LastTimeStamp" xml:"LastTimeStamp"`
	StartTimeStamp  int64           `json:"StartTimeStamp" xml:"StartTimeStamp"`
	Language        string          `json:"Language" xml:"Language"`
	ClientId        string          `json:"ClientId" xml:"ClientId"`
	Connection      string          `json:"Connection" xml:"Connection"`
	Version         string          `json:"Version" xml:"Version"`
	ConsumeType     string          `json:"ConsumeType" xml:"ConsumeType"`
	ThreadCount     int             `json:"ThreadCount" xml:"ThreadCount"`
	RunningDataList RunningDataList `json:"RunningDataList" xml:"RunningDataList"`
	SubscriptionSet SubscriptionSet `json:"SubscriptionSet" xml:"SubscriptionSet"`
	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"`
	Rt                 float64 `json:"Rt" xml:"Rt"`
	Topic              string  `json:"Topic" xml:"Topic"`
	FailedCountPerHour int64   `json:"FailedCountPerHour" xml:"FailedCountPerHour"`
	OkTps              float64 `json:"OkTps" xml:"OkTps"`
	FailedTps          float64 `json:"FailedTps" xml:"FailedTps"`
}

ConsumerRunningDataDo is a nested struct in ons response

type Data 

type Data struct {
	DelayTime                  int64                                    `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              int64                                    `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               int64                                    `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           int64                                    `json:"ConsumeTimeStamp" xml:"ConsumeTimeStamp"`
	TotalCount                 int64                                    `json:"TotalCount" xml:"TotalCount"`
	TotalDiff                  int64                                    `json:"TotalDiff" xml:"TotalDiff"`
	ReconsumeTimes             int                                      `json:"ReconsumeTimes" xml:"ReconsumeTimes"`
	Body                       string                                   `json:"Body" xml:"Body"`
	BornHost                   string                                   `json:"BornHost" xml:"BornHost"`
	MinTimeStamp               int64                                    `json:"MinTimeStamp" xml:"MinTimeStamp"`
	LastTimeStamp              int64                                    `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"`
	StoreTimestamp             int64                                    `json:"StoreTimestamp" xml:"StoreTimestamp"`
	StoreSize                  int                                      `json:"StoreSize" xml:"StoreSize"`
	StoreHost                  string                                   `json:"StoreHost" xml:"StoreHost"`
	YUnit                      string                                   `json:"YUnit" xml:"YUnit"`
	LastTimestamp              int64                                    `json:"LastTimestamp" xml:"LastTimestamp"`
	Perm                       int                                      `json:"Perm" xml:"Perm"`
	DetailInTopicList          DetailInTopicListInOnsConsumerAccumulate `json:"DetailInTopicList" xml:"DetailInTopicList"`
	SubscriptionDataList       SubscriptionDataListInOnsTopicSubDetail  `json:"SubscriptionDataList" xml:"SubscriptionDataList"`
	ConnectionSet              ConnectionSet                            `json:"ConnectionSet" xml:"ConnectionSet"`
	PropertyList               PropertyListInOnsDLQMessageGetById       `json:"PropertyList" xml:"PropertyList"`
	Records                    RecordsInOnsTrendGroupOutputTps          `json:"Records" xml:"Records"`
	ConnectionList             ConnectionList                           `json:"ConnectionList" xml:"ConnectionList"`
	ConsumerConnectionInfoList ConsumerConnectionInfoList               `json:"ConsumerConnectionInfoList" xml:"ConsumerConnectionInfoList"`
}

Data is a nested struct in ons response

type DataInOnsDLQMessageResendById 

type DataInOnsDLQMessageResendById struct {
	MsgId []string `json:"MsgId" xml:"MsgId"`
}

DataInOnsDLQMessageResendById 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 DataInOnsMessageDetail added in v1.62.127 

type DataInOnsMessageDetail struct {
	OffsetId       string            `json:"OffsetId" xml:"OffsetId"`
	StoreSize      int               `json:"StoreSize" xml:"StoreSize"`
	ReconsumeTimes int               `json:"ReconsumeTimes" xml:"ReconsumeTimes"`
	StoreTimestamp int64             `json:"StoreTimestamp" xml:"StoreTimestamp"`
	Body           string            `json:"Body" xml:"Body"`
	InstanceId     string            `json:"InstanceId" xml:"InstanceId"`
	MsgId          string            `json:"MsgId" xml:"MsgId"`
	Flag           int               `json:"Flag" xml:"Flag"`
	StoreHost      string            `json:"StoreHost" xml:"StoreHost"`
	Topic          string            `json:"Topic" xml:"Topic"`
	BornTimestamp  int64             `json:"BornTimestamp" xml:"BornTimestamp"`
	BodyCRC        int               `json:"BodyCRC" xml:"BodyCRC"`
	BornHost       string            `json:"BornHost" xml:"BornHost"`
	PropertyList   []MessageProperty `json:"PropertyList" xml:"PropertyList"`
}

DataInOnsMessageDetail 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 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     int64  `json:"DelayTime" xml:"DelayTime"`
	TotalDiff     int64  `json:"TotalDiff" xml:"TotalDiff"`
	Topic         string `json:"Topic" xml:"Topic"`
	LastTimestamp int64  `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"`
	TcpInternetEndpoint        string `json:"TcpInternetEndpoint" xml:"TcpInternetEndpoint"`
	HttpInternetEndpoint       string `json:"HttpInternetEndpoint" xml:"HttpInternetEndpoint"`
	HttpInternalEndpoint       string `json:"HttpInternalEndpoint" xml:"HttpInternalEndpoint"`
	HttpInternetSecureEndpoint string `json:"HttpInternetSecureEndpoint" xml:"HttpInternetSecureEndpoint"`
}

Endpoints is a nested struct in ons response

type InstanceBaseInfo 

type InstanceBaseInfo struct {
	IndependentNaming bool      `json:"IndependentNaming" xml:"IndependentNaming"`
	MaxTps            int64     `json:"MaxTps" xml:"MaxTps"`
	Remark            string    `json:"Remark" xml:"Remark"`
	InstanceName      string    `json:"InstanceName" xml:"InstanceName"`
	ReleaseTime       int64     `json:"ReleaseTime" xml:"ReleaseTime"`
	TopicCapacity     int       `json:"TopicCapacity" xml:"TopicCapacity"`
	InstanceStatus    int       `json:"InstanceStatus" xml:"InstanceStatus"`
	InstanceId        string    `json:"InstanceId" xml:"InstanceId"`
	InstanceType      int       `json:"InstanceType" xml:"InstanceType"`
	CreateTime        string    `json:"CreateTime" xml:"CreateTime"`
	SpInstanceId      string    `json:"spInstanceId" xml:"spInstanceId"`
	SpInstanceType    int       `json:"spInstanceType" xml:"spInstanceType"`
	Endpoints         Endpoints `json:"Endpoints" xml:"Endpoints"`
}

InstanceBaseInfo is a nested struct in ons response

type InstanceVO 

type InstanceVO struct {
	IndependentNaming bool                           `json:"IndependentNaming" xml:"IndependentNaming"`
	InstanceName      string                         `json:"InstanceName" xml:"InstanceName"`
	ReleaseTime       int64                          `json:"ReleaseTime" xml:"ReleaseTime"`
	InstanceStatus    int                            `json:"InstanceStatus" xml:"InstanceStatus"`
	InstanceId        string                         `json:"InstanceId" xml:"InstanceId"`
	InstanceType      int                            `json:"InstanceType" xml:"InstanceType"`
	CreateTime        int64                          `json:"CreateTime" xml:"CreateTime"`
	Tags              TagsInOnsInstanceInServiceList `json:"Tags" xml:"Tags"`
}

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 ListTagResourcesRequest added in v1.61.304 

type ListTagResourcesRequest struct {
	*requests.RpcRequest
	ResourceId   *[]string              `position:"Query" name:"ResourceId"  type:"Repeated"`
	ResourceType string                 `position:"Query" name:"ResourceType"`
	InstanceId   string                 `position:"Query" name:"InstanceId"`
	NextToken    string                 `position:"Query" name:"NextToken"`
	Tag          *[]ListTagResourcesTag `position:"Query" name:"Tag"  type:"Repeated"`
}

ListTagResourcesRequest is the request struct for api ListTagResources

func CreateListTagResourcesRequest added in v1.61.304 

func CreateListTagResourcesRequest() (request *ListTagResourcesRequest)

CreateListTagResourcesRequest creates a request to invoke ListTagResources API

type ListTagResourcesResponse added in v1.61.304 

type ListTagResourcesResponse struct {
	*responses.BaseResponse
	NextToken    string        `json:"NextToken" xml:"NextToken"`
	RequestId    string        `json:"RequestId" xml:"RequestId"`
	TagResources []TagResource `json:"TagResources" xml:"TagResources"`
}

ListTagResourcesResponse is the response struct for api ListTagResources

func CreateListTagResourcesResponse added in v1.61.304 

func CreateListTagResourcesResponse() (response *ListTagResourcesResponse)

CreateListTagResourcesResponse creates a response to parse from ListTagResources response

type ListTagResourcesTag added in v1.61.304 

type ListTagResourcesTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

ListTagResourcesTag is a repeated param struct in ListTagResourcesRequest

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 {
	ExceptionDesc string `json:"ExceptionDesc" xml:"ExceptionDesc"`
	TrackType     string `json:"TrackType" xml:"TrackType"`
	ConsumerGroup string `json:"ConsumerGroup" xml:"ConsumerGroup"`
	InstanceId    string `json:"InstanceId" xml:"InstanceId"`
}

MessageTrack is a nested struct in ons response

type MsgFoundDo 

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

MsgFoundDo is a nested struct in ons response

type MsgFoundListInOnsDLQMessagePageQueryByGroupId 

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

MsgFoundListInOnsDLQMessagePageQueryByGroupId is a nested struct in ons response

type MsgFoundListInOnsMessagePageQueryByTopic 

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

MsgFoundListInOnsMessagePageQueryByTopic is a nested struct in ons response

type OnsConsumerAccumulateRequest 

type OnsConsumerAccumulateRequest struct {
	*requests.RpcRequest
	GroupId    string           `position:"Query" name:"GroupId"`
	InstanceId string           `position:"Query" name:"InstanceId"`
	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
	GroupId    string `position:"Query" name:"GroupId"`
	InstanceId string `position:"Query" name:"InstanceId"`
}

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
	GroupId        string           `position:"Query" name:"GroupId"`
	ResetTimestamp requests.Integer `position:"Query" name:"ResetTimestamp"`
	Type           requests.Integer `position:"Query" name:"Type"`
	InstanceId     string           `position:"Query" name:"InstanceId"`
	Topic          string           `position:"Query" name:"Topic"`
}

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
	GroupId    string           `position:"Query" name:"GroupId"`
	InstanceId string           `position:"Query" name:"InstanceId"`
	NeedJstack requests.Boolean `position:"Query" name:"NeedJstack"`
	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
	GroupId    string `position:"Query" name:"GroupId"`
	InstanceId string `position:"Query" name:"InstanceId"`
	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 OnsDLQMessageGetByIdRequest 

type OnsDLQMessageGetByIdRequest struct {
	*requests.RpcRequest
	GroupId    string `position:"Query" name:"GroupId"`
	MsgId      string `position:"Query" name:"MsgId"`
	InstanceId string `position:"Query" name:"InstanceId"`
}

OnsDLQMessageGetByIdRequest is the request struct for api OnsDLQMessageGetById

func CreateOnsDLQMessageGetByIdRequest 

func CreateOnsDLQMessageGetByIdRequest() (request *OnsDLQMessageGetByIdRequest)

CreateOnsDLQMessageGetByIdRequest creates a request to invoke OnsDLQMessageGetById API

type OnsDLQMessageGetByIdResponse 

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

OnsDLQMessageGetByIdResponse is the response struct for api OnsDLQMessageGetById

func CreateOnsDLQMessageGetByIdResponse 

func CreateOnsDLQMessageGetByIdResponse() (response *OnsDLQMessageGetByIdResponse)

CreateOnsDLQMessageGetByIdResponse creates a response to parse from OnsDLQMessageGetById response

type OnsDLQMessagePageQueryByGroupIdRequest 

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

OnsDLQMessagePageQueryByGroupIdRequest is the request struct for api OnsDLQMessagePageQueryByGroupId

func CreateOnsDLQMessagePageQueryByGroupIdRequest 

func CreateOnsDLQMessagePageQueryByGroupIdRequest() (request *OnsDLQMessagePageQueryByGroupIdRequest)

CreateOnsDLQMessagePageQueryByGroupIdRequest creates a request to invoke OnsDLQMessagePageQueryByGroupId API

type OnsDLQMessagePageQueryByGroupIdResponse 

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

OnsDLQMessagePageQueryByGroupIdResponse is the response struct for api OnsDLQMessagePageQueryByGroupId

func CreateOnsDLQMessagePageQueryByGroupIdResponse 

func CreateOnsDLQMessagePageQueryByGroupIdResponse() (response *OnsDLQMessagePageQueryByGroupIdResponse)

CreateOnsDLQMessagePageQueryByGroupIdResponse creates a response to parse from OnsDLQMessagePageQueryByGroupId response

type OnsDLQMessageResendByIdRequest 

type OnsDLQMessageResendByIdRequest struct {
	*requests.RpcRequest
	GroupId    string `position:"Query" name:"GroupId"`
	MsgId      string `position:"Query" name:"MsgId"`
	InstanceId string `position:"Query" name:"InstanceId"`
}

OnsDLQMessageResendByIdRequest is the request struct for api OnsDLQMessageResendById

func CreateOnsDLQMessageResendByIdRequest 

func CreateOnsDLQMessageResendByIdRequest() (request *OnsDLQMessageResendByIdRequest)

CreateOnsDLQMessageResendByIdRequest creates a request to invoke OnsDLQMessageResendById API

type OnsDLQMessageResendByIdResponse 

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

OnsDLQMessageResendByIdResponse is the response struct for api OnsDLQMessageResendById

func CreateOnsDLQMessageResendByIdResponse 

func CreateOnsDLQMessageResendByIdResponse() (response *OnsDLQMessageResendByIdResponse)

CreateOnsDLQMessageResendByIdResponse creates a response to parse from OnsDLQMessageResendById response

type OnsGroupConsumerUpdateRequest 

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

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
	GroupId    string `position:"Query" name:"GroupId"`
	Remark     string `position:"Query" name:"Remark"`
	UserId     string `position:"Query" name:"UserId"`
	InstanceId string `position:"Query" name:"InstanceId"`
	GroupType  string `position:"Query" name:"GroupType"`
}

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
	GroupId    string `position:"Query" name:"GroupId"`
	InstanceId string `position:"Query" name:"InstanceId"`
}

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
	GroupId    string             `position:"Query" name:"GroupId"`
	UserId     string             `position:"Query" name:"UserId"`
	InstanceId string             `position:"Query" name:"InstanceId"`
	GroupType  string             `position:"Query" name:"GroupType"`
	Tag        *[]OnsGroupListTag `position:"Query" name:"Tag"  type:"Repeated"`
}

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 OnsGroupListTag added in v1.61.304 

type OnsGroupListTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

OnsGroupListTag is a repeated param struct in OnsGroupListRequest

type OnsGroupSubDetailRequest 

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

OnsGroupSubDetailRequest is the request struct for api OnsGroupSubDetail

func CreateOnsGroupSubDetailRequest 

func CreateOnsGroupSubDetailRequest() (request *OnsGroupSubDetailRequest)

CreateOnsGroupSubDetailRequest creates a request to invoke OnsGroupSubDetail API

type OnsGroupSubDetailResponse 

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

OnsGroupSubDetailResponse is the response struct for api OnsGroupSubDetail

func CreateOnsGroupSubDetailResponse 

func CreateOnsGroupSubDetailResponse() (response *OnsGroupSubDetailResponse)

CreateOnsGroupSubDetailResponse creates a response to parse from OnsGroupSubDetail response

type OnsInstanceBaseInfoRequest 

type OnsInstanceBaseInfoRequest struct {
	*requests.RpcRequest
	UserId     string `position:"Query" name:"UserId"`
	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
	Remark       string `position:"Query" name:"Remark"`
	InstanceName string `position:"Query" name:"InstanceName"`
}

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
	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
	UserId string                         `position:"Query" name:"UserId"`
	Tag    *[]OnsInstanceInServiceListTag `position:"Query" name:"Tag"  type:"Repeated"`
}

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 OnsInstanceInServiceListTag added in v1.61.304 

type OnsInstanceInServiceListTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

OnsInstanceInServiceListTag is a repeated param struct in OnsInstanceInServiceListRequest

type OnsInstanceUpdateRequest 

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

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 OnsMessageDetailRequest added in v1.62.127 

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

OnsMessageDetailRequest is the request struct for api OnsMessageDetail

func CreateOnsMessageDetailRequest added in v1.62.127 

func CreateOnsMessageDetailRequest() (request *OnsMessageDetailRequest)

CreateOnsMessageDetailRequest creates a request to invoke OnsMessageDetail API

type OnsMessageDetailResponse added in v1.62.127 

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

OnsMessageDetailResponse is the response struct for api OnsMessageDetail

func CreateOnsMessageDetailResponse added in v1.62.127 

func CreateOnsMessageDetailResponse() (response *OnsMessageDetailResponse)

CreateOnsMessageDetailResponse creates a response to parse from OnsMessageDetail response

type OnsMessageGetByKeyRequest 

type OnsMessageGetByKeyRequest struct {
	*requests.RpcRequest
	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
	MsgId      string `position:"Query" name:"MsgId"`
	InstanceId string `position:"Query" name:"InstanceId"`
	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
	EndTime     requests.Integer `position:"Query" name:"EndTime"`
	BeginTime   requests.Integer `position:"Query" name:"BeginTime"`
	CurrentPage requests.Integer `position:"Query" name:"CurrentPage"`
	InstanceId  string           `position:"Query" name:"InstanceId"`
	PageSize    requests.Integer `position:"Query" name:"PageSize"`
	Topic       string           `position:"Query" name:"Topic"`
	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
	ClientId   string `position:"Query" name:"ClientId"`
	GroupId    string `position:"Query" name:"GroupId"`
	MsgId      string `position:"Query" name:"MsgId"`
	InstanceId string `position:"Query" name:"InstanceId"`
	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 OnsMessageTraceRequest 

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

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 OnsRegionListRequest 

type OnsRegionListRequest struct {
	*requests.RpcRequest
}

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  int64                                         `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 int64                                         `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"`
}

OnsRestMessageDo is a nested struct in ons response

type OnsTopicCreateRequest 

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

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
	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
	UserId     string             `position:"Query" name:"UserId"`
	InstanceId string             `position:"Query" name:"InstanceId"`
	Topic      string             `position:"Query" name:"Topic"`
	Tag        *[]OnsTopicListTag `position:"Query" name:"Tag"  type:"Repeated"`
}

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 OnsTopicListTag added in v1.61.304 

type OnsTopicListTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

OnsTopicListTag is a repeated param struct in OnsTopicListRequest

type OnsTopicStatusRequest 

type OnsTopicStatusRequest struct {
	*requests.RpcRequest
	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 OnsTopicSubDetailRequest 

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

OnsTopicSubDetailRequest is the request struct for api OnsTopicSubDetail

func CreateOnsTopicSubDetailRequest 

func CreateOnsTopicSubDetailRequest() (request *OnsTopicSubDetailRequest)

CreateOnsTopicSubDetailRequest creates a request to invoke OnsTopicSubDetail API

type OnsTopicSubDetailResponse 

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

OnsTopicSubDetailResponse is the response struct for api OnsTopicSubDetail

func CreateOnsTopicSubDetailResponse 

func CreateOnsTopicSubDetailResponse() (response *OnsTopicSubDetailResponse)

CreateOnsTopicSubDetailResponse creates a response to parse from OnsTopicSubDetail response

type OnsTopicUpdateRequest 

type OnsTopicUpdateRequest struct {
	*requests.RpcRequest
	Perm       requests.Integer `position:"Query" name:"Perm"`
	InstanceId string           `position:"Query" name:"InstanceId"`
	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
	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
	MsgId      string           `position:"Query" name:"MsgId"`
	EndTime    requests.Integer `position:"Query" name:"EndTime"`
	BeginTime  requests.Integer `position:"Query" name:"BeginTime"`
	InstanceId string           `position:"Query" name:"InstanceId"`
	Topic      string           `position:"Query" name:"Topic"`
}

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"`
	QueryId   string `json:"QueryId" xml:"QueryId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

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
	EndTime    requests.Integer `position:"Query" name:"EndTime"`
	BeginTime  requests.Integer `position:"Query" name:"BeginTime"`
	InstanceId string           `position:"Query" name:"InstanceId"`
	Topic      string           `position:"Query" name:"Topic"`
	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"`
	QueryId   string `json:"QueryId" xml:"QueryId"`
	HelpUrl   string `json:"HelpUrl" xml:"HelpUrl"`
}

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
	Period     requests.Integer `position:"Query" name:"Period"`
	GroupId    string           `position:"Query" name:"GroupId"`
	EndTime    requests.Integer `position:"Query" name:"EndTime"`
	BeginTime  requests.Integer `position:"Query" name:"BeginTime"`
	Type       requests.Integer `position:"Query" name:"Type"`
	InstanceId string           `position:"Query" name:"InstanceId"`
	Topic      string           `position:"Query" name:"Topic"`
}

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
	Period     requests.Integer `position:"Query" name:"Period"`
	EndTime    requests.Integer `position:"Query" name:"EndTime"`
	BeginTime  requests.Integer `position:"Query" name:"BeginTime"`
	Type       requests.Integer `position:"Query" name:"Type"`
	InstanceId string           `position:"Query" name:"InstanceId"`
	Topic      string           `position:"Query" name:"Topic"`
}

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 OpenOnsServiceRequest added in v1.61.541 

type OpenOnsServiceRequest struct {
	*requests.RpcRequest
}

OpenOnsServiceRequest is the request struct for api OpenOnsService

func CreateOpenOnsServiceRequest added in v1.61.541 

func CreateOpenOnsServiceRequest() (request *OpenOnsServiceRequest)

CreateOpenOnsServiceRequest creates a request to invoke OpenOnsService API

type OpenOnsServiceResponse added in v1.61.541 

type OpenOnsServiceResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	OrderId   string `json:"OrderId" xml:"OrderId"`
}

OpenOnsServiceResponse is the response struct for api OpenOnsService

func CreateOpenOnsServiceResponse added in v1.61.541 

func CreateOpenOnsServiceResponse() (response *OpenOnsServiceResponse)

CreateOpenOnsServiceResponse creates a response to parse from OpenOnsService response

type PropertyListInOnsDLQMessageGetById 

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

PropertyListInOnsDLQMessageGetById is a nested struct in ons response

type PropertyListInOnsDLQMessagePageQueryByGroupId 

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

PropertyListInOnsDLQMessagePageQueryByGroupId is a nested struct in ons response

type PropertyListInOnsMessageDetail added in v1.62.127 

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

PropertyListInOnsMessageDetail is a nested struct in ons 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 {
	MessageType       int                `json:"MessageType" xml:"MessageType"`
	RelationName      string             `json:"RelationName" xml:"RelationName"`
	Owner             string             `json:"Owner" xml:"Owner"`
	IndependentNaming bool               `json:"IndependentNaming" xml:"IndependentNaming"`
	Remark            string             `json:"Remark" xml:"Remark"`
	Relation          int                `json:"Relation" xml:"Relation"`
	CreateTime        int64              `json:"CreateTime" xml:"CreateTime"`
	Topic             string             `json:"Topic" xml:"Topic"`
	InstanceId        string             `json:"InstanceId" xml:"InstanceId"`
	ServiceStatus     int                `json:"ServiceStatus" xml:"ServiceStatus"`
	Tags              TagsInOnsTopicList `json:"Tags" xml:"Tags"`
}

PublishInfoDo 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 {
	UpdateTime  int64  `json:"UpdateTime" xml:"UpdateTime"`
	RegionName  string `json:"RegionName" xml:"RegionName"`
	ChannelName string `json:"ChannelName" xml:"ChannelName"`
	CreateTime  int64  `json:"CreateTime" xml:"CreateTime"`
	ChannelId   int    `json:"ChannelId" xml:"ChannelId"`
	Id          int64  `json:"Id" xml:"Id"`
	OnsRegionId string `json:"OnsRegionId" xml:"OnsRegionId"`
}

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 int64   `json:"X" xml:"X"`
	Y float64 `json:"Y" xml:"Y"`
}

StatsDataDo is a nested struct in ons response

type SubClientInfoDo 

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

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 {
	FailCount    int        `json:"FailCount" xml:"FailCount"`
	SubGroupName string     `json:"SubGroupName" xml:"SubGroupName"`
	SuccessCount int        `json:"SuccessCount" xml:"SuccessCount"`
	ClientList   ClientList `json:"ClientList" xml:"ClientList"`
}

SubMapDo is a nested struct in ons response

type SubscribeInfoDo 

type SubscribeInfoDo struct {
	Owner             string             `json:"Owner" xml:"Owner"`
	UpdateTime        int64              `json:"UpdateTime" xml:"UpdateTime"`
	IndependentNaming bool               `json:"IndependentNaming" xml:"IndependentNaming"`
	GroupId           string             `json:"GroupId" xml:"GroupId"`
	Remark            string             `json:"Remark" xml:"Remark"`
	CreateTime        int64              `json:"CreateTime" xml:"CreateTime"`
	InstanceId        string             `json:"InstanceId" xml:"InstanceId"`
	GroupType         string             `json:"GroupType" xml:"GroupType"`
	Tags              TagsInOnsGroupList `json:"Tags" xml:"Tags"`
}

SubscribeInfoDo is a nested struct in ons response

type SubscriptionData 

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

SubscriptionData is a nested struct in ons response

type SubscriptionDataListInOnsGroupSubDetail 

type SubscriptionDataListInOnsGroupSubDetail struct {
	SubscriptionDataListItem []SubscriptionDataListItem `json:"SubscriptionDataList" xml:"SubscriptionDataList"`
}

SubscriptionDataListInOnsGroupSubDetail is a nested struct in ons response

type SubscriptionDataListInOnsTopicSubDetail 

type SubscriptionDataListInOnsTopicSubDetail struct {
	SubscriptionDataListItem []SubscriptionDataListItem `json:"SubscriptionDataList" xml:"SubscriptionDataList"`
}

SubscriptionDataListInOnsTopicSubDetail is a nested struct in ons response

type SubscriptionDataListItem 

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"`
}

SubscriptionDataListItem 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 Tag added in v1.61.304 

type Tag struct {
	Key   string `json:"Key" xml:"Key"`
	Value string `json:"Value" xml:"Value"`
}

Tag is a nested struct in ons response

type TagResource added in v1.61.304 

type TagResource struct {
	ResourceType string `json:"ResourceType" xml:"ResourceType"`
	InstanceId   string `json:"InstanceId" xml:"InstanceId"`
	TagValue     string `json:"TagValue" xml:"TagValue"`
	ResourceId   string `json:"ResourceId" xml:"ResourceId"`
	TagKey       string `json:"TagKey" xml:"TagKey"`
}

TagResource is a nested struct in ons response

type TagResources added in v1.61.304 

type TagResources struct {
	TagResource []TagResource `json:"TagResource" xml:"TagResource"`
}

TagResources is a nested struct in ons response

type TagResourcesRequest added in v1.61.304 

type TagResourcesRequest struct {
	*requests.RpcRequest
	ResourceId   *[]string          `position:"Query" name:"ResourceId"  type:"Repeated"`
	ResourceType string             `position:"Query" name:"ResourceType"`
	InstanceId   string             `position:"Query" name:"InstanceId"`
	Tag          *[]TagResourcesTag `position:"Query" name:"Tag"  type:"Repeated"`
}

TagResourcesRequest is the request struct for api TagResources

func CreateTagResourcesRequest added in v1.61.304 

func CreateTagResourcesRequest() (request *TagResourcesRequest)

CreateTagResourcesRequest creates a request to invoke TagResources API

type TagResourcesResponse added in v1.61.304 

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

TagResourcesResponse is the response struct for api TagResources

func CreateTagResourcesResponse added in v1.61.304 

func CreateTagResourcesResponse() (response *TagResourcesResponse)

CreateTagResourcesResponse creates a response to parse from TagResources response

type TagResourcesTag added in v1.61.304 

type TagResourcesTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

TagResourcesTag is a repeated param struct in TagResourcesRequest

type TagsInOnsGroupList added in v1.61.304 

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

TagsInOnsGroupList is a nested struct in ons response

type TagsInOnsInstanceInServiceList added in v1.61.304 

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

TagsInOnsInstanceInServiceList is a nested struct in ons response

type TagsInOnsTopicList added in v1.61.304 

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

TagsInOnsTopicList 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 {
	Status     string    `json:"Status" xml:"Status"`
	MsgKey     string    `json:"MsgKey" xml:"MsgKey"`
	UpdateTime int64     `json:"UpdateTime" xml:"UpdateTime"`
	CreateTime int64     `json:"CreateTime" xml:"CreateTime"`
	Topic      string    `json:"Topic" xml:"Topic"`
	UserId     string    `json:"UserId" xml:"UserId"`
	InstanceId string    `json:"InstanceId" xml:"InstanceId"`
	MsgId      string    `json:"MsgId" xml:"MsgId"`
	QueryId    string    `json:"QueryId" xml:"QueryId"`
	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 {
	Status       string  `json:"Status" xml:"Status"`
	MsgKey       string  `json:"MsgKey" xml:"MsgKey"`
	PubTime      int64   `json:"PubTime" xml:"PubTime"`
	Topic        string  `json:"Topic" xml:"Topic"`
	CostTime     int     `json:"CostTime" xml:"CostTime"`
	Tag          string  `json:"Tag" xml:"Tag"`
	MsgId        string  `json:"MsgId" xml:"MsgId"`
	PubGroupName string  `json:"PubGroupName" xml:"PubGroupName"`
	BornHost     string  `json:"BornHost" xml:"BornHost"`
	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

type UntagResourcesRequest added in v1.61.304 

type UntagResourcesRequest struct {
	*requests.RpcRequest
	All          requests.Boolean `position:"Query" name:"All"`
	ResourceId   *[]string        `position:"Query" name:"ResourceId"  type:"Repeated"`
	ResourceType string           `position:"Query" name:"ResourceType"`
	InstanceId   string           `position:"Query" name:"InstanceId"`
	TagKey       *[]string        `position:"Query" name:"TagKey"  type:"Repeated"`
}

UntagResourcesRequest is the request struct for api UntagResources

func CreateUntagResourcesRequest added in v1.61.304 

func CreateUntagResourcesRequest() (request *UntagResourcesRequest)

CreateUntagResourcesRequest creates a request to invoke UntagResources API

type UntagResourcesResponse added in v1.61.304 

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

UntagResourcesResponse is the response struct for api UntagResources

func CreateUntagResourcesResponse added in v1.61.304 

func CreateUntagResourcesResponse() (response *UntagResourcesResponse)

CreateUntagResourcesResponse creates a response to parse from UntagResources response

Source Files

View all Source files

Jump to

Keyboard shortcuts

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