Documentation
¶
Overview ¶
This file is auto-generated, don't edit it. Thanks.
Index ¶
- type ChangeResourceGroupRequest
- func (s ChangeResourceGroupRequest) GoString() string
- func (s *ChangeResourceGroupRequest) SetRegionId(v string) *ChangeResourceGroupRequest
- func (s *ChangeResourceGroupRequest) SetResourceGroupId(v string) *ChangeResourceGroupRequest
- func (s *ChangeResourceGroupRequest) SetResourceId(v string) *ChangeResourceGroupRequest
- func (s *ChangeResourceGroupRequest) SetResourceType(v string) *ChangeResourceGroupRequest
- func (s ChangeResourceGroupRequest) String() string
- type ChangeResourceGroupResponse
- func (s ChangeResourceGroupResponse) GoString() string
- func (s *ChangeResourceGroupResponse) SetBody(v *ChangeResourceGroupResponseBody) *ChangeResourceGroupResponse
- func (s *ChangeResourceGroupResponse) SetHeaders(v map[string]*string) *ChangeResourceGroupResponse
- func (s *ChangeResourceGroupResponse) SetStatusCode(v int32) *ChangeResourceGroupResponse
- func (s ChangeResourceGroupResponse) String() string
- type ChangeResourceGroupResponseBody
- func (s ChangeResourceGroupResponseBody) GoString() string
- func (s *ChangeResourceGroupResponseBody) SetCode(v string) *ChangeResourceGroupResponseBody
- func (s *ChangeResourceGroupResponseBody) SetData(v bool) *ChangeResourceGroupResponseBody
- func (s *ChangeResourceGroupResponseBody) SetDynamicCode(v string) *ChangeResourceGroupResponseBody
- func (s *ChangeResourceGroupResponseBody) SetDynamicMessage(v string) *ChangeResourceGroupResponseBody
- func (s *ChangeResourceGroupResponseBody) SetHttpStatusCode(v int32) *ChangeResourceGroupResponseBody
- func (s *ChangeResourceGroupResponseBody) SetMessage(v string) *ChangeResourceGroupResponseBody
- func (s *ChangeResourceGroupResponseBody) SetRequestId(v string) *ChangeResourceGroupResponseBody
- func (s *ChangeResourceGroupResponseBody) SetSuccess(v bool) *ChangeResourceGroupResponseBody
- func (s ChangeResourceGroupResponseBody) String() string
- type Client
- func (client *Client) ChangeResourceGroup(request *ChangeResourceGroupRequest) (_result *ChangeResourceGroupResponse, _err error)
- func (client *Client) ChangeResourceGroupWithOptions(request *ChangeResourceGroupRequest, headers map[string]*string, ...) (_result *ChangeResourceGroupResponse, _err error)
- func (client *Client) CreateConsumerGroup(instanceId *string, consumerGroupId *string, ...) (_result *CreateConsumerGroupResponse, _err error)
- func (client *Client) CreateConsumerGroupWithOptions(instanceId *string, consumerGroupId *string, ...) (_result *CreateConsumerGroupResponse, _err error)
- func (client *Client) CreateInstance(request *CreateInstanceRequest) (_result *CreateInstanceResponse, _err error)
- func (client *Client) CreateInstanceWithOptions(request *CreateInstanceRequest, headers map[string]*string, ...) (_result *CreateInstanceResponse, _err error)
- func (client *Client) CreateTopic(instanceId *string, topicName *string, request *CreateTopicRequest) (_result *CreateTopicResponse, _err error)
- func (client *Client) CreateTopicWithOptions(instanceId *string, topicName *string, request *CreateTopicRequest, ...) (_result *CreateTopicResponse, _err error)
- func (client *Client) DeleteConsumerGroup(instanceId *string, consumerGroupId *string) (_result *DeleteConsumerGroupResponse, _err error)
- func (client *Client) DeleteConsumerGroupWithOptions(instanceId *string, consumerGroupId *string, headers map[string]*string, ...) (_result *DeleteConsumerGroupResponse, _err error)
- func (client *Client) DeleteInstance(instanceId *string) (_result *DeleteInstanceResponse, _err error)
- func (client *Client) DeleteInstanceWithOptions(instanceId *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *DeleteInstanceResponse, _err error)
- func (client *Client) DeleteTopic(instanceId *string, topicName *string) (_result *DeleteTopicResponse, _err error)
- func (client *Client) DeleteTopicWithOptions(instanceId *string, topicName *string, headers map[string]*string, ...) (_result *DeleteTopicResponse, _err error)
- func (client *Client) GetConsumerGroup(instanceId *string, consumerGroupId *string) (_result *GetConsumerGroupResponse, _err error)
- func (client *Client) GetConsumerGroupWithOptions(instanceId *string, consumerGroupId *string, headers map[string]*string, ...) (_result *GetConsumerGroupResponse, _err error)
- func (client *Client) GetEndpoint(productId *string, regionId *string, endpointRule *string, network *string, ...) (_result *string, _err error)
- func (client *Client) GetInstance(instanceId *string) (_result *GetInstanceResponse, _err error)
- func (client *Client) GetInstanceWithOptions(instanceId *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *GetInstanceResponse, _err error)
- func (client *Client) GetTopic(instanceId *string, topicName *string) (_result *GetTopicResponse, _err error)
- func (client *Client) GetTopicWithOptions(instanceId *string, topicName *string, headers map[string]*string, ...) (_result *GetTopicResponse, _err error)
- func (client *Client) Init(config *openapi.Config) (_err error)
- func (client *Client) ListAvailableZones() (_result *ListAvailableZonesResponse, _err error)
- func (client *Client) ListAvailableZonesWithOptions(headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListAvailableZonesResponse, _err error)
- func (client *Client) ListConsumerConnections(instanceId *string, consumerGroupId *string) (_result *ListConsumerConnectionsResponse, _err error)
- func (client *Client) ListConsumerConnectionsWithOptions(instanceId *string, consumerGroupId *string, headers map[string]*string, ...) (_result *ListConsumerConnectionsResponse, _err error)
- func (client *Client) ListConsumerGroupSubscriptions(instanceId *string, consumerGroupId *string) (_result *ListConsumerGroupSubscriptionsResponse, _err error)
- func (client *Client) ListConsumerGroupSubscriptionsWithOptions(instanceId *string, consumerGroupId *string, headers map[string]*string, ...) (_result *ListConsumerGroupSubscriptionsResponse, _err error)
- func (client *Client) ListConsumerGroups(instanceId *string, request *ListConsumerGroupsRequest) (_result *ListConsumerGroupsResponse, _err error)
- func (client *Client) ListConsumerGroupsWithOptions(instanceId *string, request *ListConsumerGroupsRequest, ...) (_result *ListConsumerGroupsResponse, _err error)
- func (client *Client) ListInstances(request *ListInstancesRequest) (_result *ListInstancesResponse, _err error)
- func (client *Client) ListInstancesWithOptions(tmpReq *ListInstancesRequest, headers map[string]*string, ...) (_result *ListInstancesResponse, _err error)
- func (client *Client) ListRegions() (_result *ListRegionsResponse, _err error)
- func (client *Client) ListRegionsWithOptions(headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListRegionsResponse, _err error)
- func (client *Client) ListTopicSubscriptions(instanceId *string, topicName *string) (_result *ListTopicSubscriptionsResponse, _err error)
- func (client *Client) ListTopicSubscriptionsWithOptions(instanceId *string, topicName *string, headers map[string]*string, ...) (_result *ListTopicSubscriptionsResponse, _err error)
- func (client *Client) ListTopics(instanceId *string, request *ListTopicsRequest) (_result *ListTopicsResponse, _err error)
- func (client *Client) ListTopicsWithOptions(instanceId *string, tmpReq *ListTopicsRequest, headers map[string]*string, ...) (_result *ListTopicsResponse, _err error)
- func (client *Client) ResetConsumeOffset(instanceId *string, consumerGroupId *string, topicName *string, ...) (_result *ResetConsumeOffsetResponse, _err error)
- func (client *Client) ResetConsumeOffsetWithOptions(instanceId *string, consumerGroupId *string, topicName *string, ...) (_result *ResetConsumeOffsetResponse, _err error)
- func (client *Client) UpdateConsumerGroup(instanceId *string, consumerGroupId *string, ...) (_result *UpdateConsumerGroupResponse, _err error)
- func (client *Client) UpdateConsumerGroupWithOptions(instanceId *string, consumerGroupId *string, ...) (_result *UpdateConsumerGroupResponse, _err error)
- func (client *Client) UpdateInstance(instanceId *string, request *UpdateInstanceRequest) (_result *UpdateInstanceResponse, _err error)
- func (client *Client) UpdateInstanceWithOptions(instanceId *string, request *UpdateInstanceRequest, headers map[string]*string, ...) (_result *UpdateInstanceResponse, _err error)
- func (client *Client) UpdateTopic(instanceId *string, topicName *string, request *UpdateTopicRequest) (_result *UpdateTopicResponse, _err error)
- func (client *Client) UpdateTopicWithOptions(instanceId *string, topicName *string, request *UpdateTopicRequest, ...) (_result *UpdateTopicResponse, _err error)
- type CreateConsumerGroupRequest
- func (s CreateConsumerGroupRequest) GoString() string
- func (s *CreateConsumerGroupRequest) SetConsumeRetryPolicy(v *CreateConsumerGroupRequestConsumeRetryPolicy) *CreateConsumerGroupRequest
- func (s *CreateConsumerGroupRequest) SetDeliveryOrderType(v string) *CreateConsumerGroupRequest
- func (s *CreateConsumerGroupRequest) SetRemark(v string) *CreateConsumerGroupRequest
- func (s CreateConsumerGroupRequest) String() string
- type CreateConsumerGroupRequestConsumeRetryPolicy
- func (s CreateConsumerGroupRequestConsumeRetryPolicy) GoString() string
- func (s *CreateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic(v string) *CreateConsumerGroupRequestConsumeRetryPolicy
- func (s *CreateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes(v int32) *CreateConsumerGroupRequestConsumeRetryPolicy
- func (s *CreateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy(v string) *CreateConsumerGroupRequestConsumeRetryPolicy
- func (s CreateConsumerGroupRequestConsumeRetryPolicy) String() string
- type CreateConsumerGroupResponse
- func (s CreateConsumerGroupResponse) GoString() string
- func (s *CreateConsumerGroupResponse) SetBody(v *CreateConsumerGroupResponseBody) *CreateConsumerGroupResponse
- func (s *CreateConsumerGroupResponse) SetHeaders(v map[string]*string) *CreateConsumerGroupResponse
- func (s *CreateConsumerGroupResponse) SetStatusCode(v int32) *CreateConsumerGroupResponse
- func (s CreateConsumerGroupResponse) String() string
- type CreateConsumerGroupResponseBody
- func (s CreateConsumerGroupResponseBody) GoString() string
- func (s *CreateConsumerGroupResponseBody) SetCode(v string) *CreateConsumerGroupResponseBody
- func (s *CreateConsumerGroupResponseBody) SetData(v bool) *CreateConsumerGroupResponseBody
- func (s *CreateConsumerGroupResponseBody) SetDynamicCode(v string) *CreateConsumerGroupResponseBody
- func (s *CreateConsumerGroupResponseBody) SetDynamicMessage(v string) *CreateConsumerGroupResponseBody
- func (s *CreateConsumerGroupResponseBody) SetHttpStatusCode(v int32) *CreateConsumerGroupResponseBody
- func (s *CreateConsumerGroupResponseBody) SetMessage(v string) *CreateConsumerGroupResponseBody
- func (s *CreateConsumerGroupResponseBody) SetRequestId(v string) *CreateConsumerGroupResponseBody
- func (s *CreateConsumerGroupResponseBody) SetSuccess(v bool) *CreateConsumerGroupResponseBody
- func (s CreateConsumerGroupResponseBody) String() string
- type CreateInstanceRequest
- func (s CreateInstanceRequest) GoString() string
- func (s *CreateInstanceRequest) SetAutoRenew(v bool) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetAutoRenewPeriod(v int32) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetClientToken(v string) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetCommodityCode(v string) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetInstanceName(v string) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetNetworkInfo(v *CreateInstanceRequestNetworkInfo) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetPaymentType(v string) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetPeriod(v int32) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetPeriodUnit(v string) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetProductInfo(v *CreateInstanceRequestProductInfo) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetRemark(v string) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetResourceGroupId(v string) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetSeriesCode(v string) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetServiceCode(v string) *CreateInstanceRequest
- func (s *CreateInstanceRequest) SetSubSeriesCode(v string) *CreateInstanceRequest
- func (s CreateInstanceRequest) String() string
- type CreateInstanceRequestNetworkInfo
- func (s CreateInstanceRequestNetworkInfo) GoString() string
- func (s *CreateInstanceRequestNetworkInfo) SetInternetInfo(v *CreateInstanceRequestNetworkInfoInternetInfo) *CreateInstanceRequestNetworkInfo
- func (s *CreateInstanceRequestNetworkInfo) SetVpcInfo(v *CreateInstanceRequestNetworkInfoVpcInfo) *CreateInstanceRequestNetworkInfo
- func (s CreateInstanceRequestNetworkInfo) String() string
- type CreateInstanceRequestNetworkInfoInternetInfo
- func (s CreateInstanceRequestNetworkInfoInternetInfo) GoString() string
- func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutBandwidth(v int32) *CreateInstanceRequestNetworkInfoInternetInfo
- func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutType(v string) *CreateInstanceRequestNetworkInfoInternetInfo
- func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetInternetSpec(v string) *CreateInstanceRequestNetworkInfoInternetInfo
- func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist(v []*string) *CreateInstanceRequestNetworkInfoInternetInfo
- func (s CreateInstanceRequestNetworkInfoInternetInfo) String() string
- type CreateInstanceRequestNetworkInfoVpcInfo
- func (s CreateInstanceRequestNetworkInfoVpcInfo) GoString() string
- func (s *CreateInstanceRequestNetworkInfoVpcInfo) SetSecurityGroupIds(v string) *CreateInstanceRequestNetworkInfoVpcInfo
- func (s *CreateInstanceRequestNetworkInfoVpcInfo) SetVSwitchId(v string) *CreateInstanceRequestNetworkInfoVpcInfo
- func (s *CreateInstanceRequestNetworkInfoVpcInfo) SetVSwitches(v []*CreateInstanceRequestNetworkInfoVpcInfoVSwitches) *CreateInstanceRequestNetworkInfoVpcInfo
- func (s *CreateInstanceRequestNetworkInfoVpcInfo) SetVpcId(v string) *CreateInstanceRequestNetworkInfoVpcInfo
- func (s CreateInstanceRequestNetworkInfoVpcInfo) String() string
- type CreateInstanceRequestNetworkInfoVpcInfoVSwitches
- type CreateInstanceRequestProductInfo
- func (s CreateInstanceRequestProductInfo) GoString() string
- func (s *CreateInstanceRequestProductInfo) SetAutoScaling(v bool) *CreateInstanceRequestProductInfo
- func (s *CreateInstanceRequestProductInfo) SetChargeType(v string) *CreateInstanceRequestProductInfo
- func (s *CreateInstanceRequestProductInfo) SetIntranetSpec(v string) *CreateInstanceRequestProductInfo
- func (s *CreateInstanceRequestProductInfo) SetMessageRetentionTime(v int32) *CreateInstanceRequestProductInfo
- func (s *CreateInstanceRequestProductInfo) SetMsgProcessSpec(v string) *CreateInstanceRequestProductInfo
- func (s *CreateInstanceRequestProductInfo) SetSendReceiveRatio(v float32) *CreateInstanceRequestProductInfo
- func (s CreateInstanceRequestProductInfo) String() string
- type CreateInstanceResponse
- func (s CreateInstanceResponse) GoString() string
- func (s *CreateInstanceResponse) SetBody(v *CreateInstanceResponseBody) *CreateInstanceResponse
- func (s *CreateInstanceResponse) SetHeaders(v map[string]*string) *CreateInstanceResponse
- func (s *CreateInstanceResponse) SetStatusCode(v int32) *CreateInstanceResponse
- func (s CreateInstanceResponse) String() string
- type CreateInstanceResponseBody
- func (s CreateInstanceResponseBody) GoString() string
- func (s *CreateInstanceResponseBody) SetCode(v string) *CreateInstanceResponseBody
- func (s *CreateInstanceResponseBody) SetData(v string) *CreateInstanceResponseBody
- func (s *CreateInstanceResponseBody) SetDynamicCode(v string) *CreateInstanceResponseBody
- func (s *CreateInstanceResponseBody) SetDynamicMessage(v string) *CreateInstanceResponseBody
- func (s *CreateInstanceResponseBody) SetHttpStatusCode(v int32) *CreateInstanceResponseBody
- func (s *CreateInstanceResponseBody) SetMessage(v string) *CreateInstanceResponseBody
- func (s *CreateInstanceResponseBody) SetRequestId(v string) *CreateInstanceResponseBody
- func (s *CreateInstanceResponseBody) SetSuccess(v bool) *CreateInstanceResponseBody
- func (s CreateInstanceResponseBody) String() string
- type CreateTopicRequest
- type CreateTopicResponse
- func (s CreateTopicResponse) GoString() string
- func (s *CreateTopicResponse) SetBody(v *CreateTopicResponseBody) *CreateTopicResponse
- func (s *CreateTopicResponse) SetHeaders(v map[string]*string) *CreateTopicResponse
- func (s *CreateTopicResponse) SetStatusCode(v int32) *CreateTopicResponse
- func (s CreateTopicResponse) String() string
- type CreateTopicResponseBody
- func (s CreateTopicResponseBody) GoString() string
- func (s *CreateTopicResponseBody) SetCode(v string) *CreateTopicResponseBody
- func (s *CreateTopicResponseBody) SetData(v bool) *CreateTopicResponseBody
- func (s *CreateTopicResponseBody) SetDynamicCode(v string) *CreateTopicResponseBody
- func (s *CreateTopicResponseBody) SetDynamicMessage(v string) *CreateTopicResponseBody
- func (s *CreateTopicResponseBody) SetHttpStatusCode(v int32) *CreateTopicResponseBody
- func (s *CreateTopicResponseBody) SetMessage(v string) *CreateTopicResponseBody
- func (s *CreateTopicResponseBody) SetRequestId(v string) *CreateTopicResponseBody
- func (s *CreateTopicResponseBody) SetSuccess(v bool) *CreateTopicResponseBody
- func (s CreateTopicResponseBody) String() string
- type DeleteConsumerGroupResponse
- func (s DeleteConsumerGroupResponse) GoString() string
- func (s *DeleteConsumerGroupResponse) SetBody(v *DeleteConsumerGroupResponseBody) *DeleteConsumerGroupResponse
- func (s *DeleteConsumerGroupResponse) SetHeaders(v map[string]*string) *DeleteConsumerGroupResponse
- func (s *DeleteConsumerGroupResponse) SetStatusCode(v int32) *DeleteConsumerGroupResponse
- func (s DeleteConsumerGroupResponse) String() string
- type DeleteConsumerGroupResponseBody
- func (s DeleteConsumerGroupResponseBody) GoString() string
- func (s *DeleteConsumerGroupResponseBody) SetCode(v string) *DeleteConsumerGroupResponseBody
- func (s *DeleteConsumerGroupResponseBody) SetData(v bool) *DeleteConsumerGroupResponseBody
- func (s *DeleteConsumerGroupResponseBody) SetDynamicCode(v string) *DeleteConsumerGroupResponseBody
- func (s *DeleteConsumerGroupResponseBody) SetDynamicMessage(v string) *DeleteConsumerGroupResponseBody
- func (s *DeleteConsumerGroupResponseBody) SetHttpStatusCode(v int32) *DeleteConsumerGroupResponseBody
- func (s *DeleteConsumerGroupResponseBody) SetMessage(v string) *DeleteConsumerGroupResponseBody
- func (s *DeleteConsumerGroupResponseBody) SetRequestId(v string) *DeleteConsumerGroupResponseBody
- func (s *DeleteConsumerGroupResponseBody) SetSuccess(v bool) *DeleteConsumerGroupResponseBody
- func (s DeleteConsumerGroupResponseBody) String() string
- type DeleteInstanceResponse
- func (s DeleteInstanceResponse) GoString() string
- func (s *DeleteInstanceResponse) SetBody(v *DeleteInstanceResponseBody) *DeleteInstanceResponse
- func (s *DeleteInstanceResponse) SetHeaders(v map[string]*string) *DeleteInstanceResponse
- func (s *DeleteInstanceResponse) SetStatusCode(v int32) *DeleteInstanceResponse
- func (s DeleteInstanceResponse) String() string
- type DeleteInstanceResponseBody
- func (s DeleteInstanceResponseBody) GoString() string
- func (s *DeleteInstanceResponseBody) SetCode(v string) *DeleteInstanceResponseBody
- func (s *DeleteInstanceResponseBody) SetData(v bool) *DeleteInstanceResponseBody
- func (s *DeleteInstanceResponseBody) SetDynamicCode(v string) *DeleteInstanceResponseBody
- func (s *DeleteInstanceResponseBody) SetDynamicMessage(v string) *DeleteInstanceResponseBody
- func (s *DeleteInstanceResponseBody) SetHttpStatusCode(v int32) *DeleteInstanceResponseBody
- func (s *DeleteInstanceResponseBody) SetMessage(v string) *DeleteInstanceResponseBody
- func (s *DeleteInstanceResponseBody) SetRequestId(v string) *DeleteInstanceResponseBody
- func (s *DeleteInstanceResponseBody) SetSuccess(v bool) *DeleteInstanceResponseBody
- func (s DeleteInstanceResponseBody) String() string
- type DeleteTopicResponse
- func (s DeleteTopicResponse) GoString() string
- func (s *DeleteTopicResponse) SetBody(v *DeleteTopicResponseBody) *DeleteTopicResponse
- func (s *DeleteTopicResponse) SetHeaders(v map[string]*string) *DeleteTopicResponse
- func (s *DeleteTopicResponse) SetStatusCode(v int32) *DeleteTopicResponse
- func (s DeleteTopicResponse) String() string
- type DeleteTopicResponseBody
- func (s DeleteTopicResponseBody) GoString() string
- func (s *DeleteTopicResponseBody) SetCode(v string) *DeleteTopicResponseBody
- func (s *DeleteTopicResponseBody) SetData(v bool) *DeleteTopicResponseBody
- func (s *DeleteTopicResponseBody) SetDynamicCode(v string) *DeleteTopicResponseBody
- func (s *DeleteTopicResponseBody) SetDynamicMessage(v string) *DeleteTopicResponseBody
- func (s *DeleteTopicResponseBody) SetHttpStatusCode(v int32) *DeleteTopicResponseBody
- func (s *DeleteTopicResponseBody) SetMessage(v string) *DeleteTopicResponseBody
- func (s *DeleteTopicResponseBody) SetRequestId(v string) *DeleteTopicResponseBody
- func (s *DeleteTopicResponseBody) SetSuccess(v bool) *DeleteTopicResponseBody
- func (s DeleteTopicResponseBody) String() string
- type GetConsumerGroupResponse
- func (s GetConsumerGroupResponse) GoString() string
- func (s *GetConsumerGroupResponse) SetBody(v *GetConsumerGroupResponseBody) *GetConsumerGroupResponse
- func (s *GetConsumerGroupResponse) SetHeaders(v map[string]*string) *GetConsumerGroupResponse
- func (s *GetConsumerGroupResponse) SetStatusCode(v int32) *GetConsumerGroupResponse
- func (s GetConsumerGroupResponse) String() string
- type GetConsumerGroupResponseBody
- func (s GetConsumerGroupResponseBody) GoString() string
- func (s *GetConsumerGroupResponseBody) SetCode(v string) *GetConsumerGroupResponseBody
- func (s *GetConsumerGroupResponseBody) SetData(v *GetConsumerGroupResponseBodyData) *GetConsumerGroupResponseBody
- func (s *GetConsumerGroupResponseBody) SetDynamicCode(v string) *GetConsumerGroupResponseBody
- func (s *GetConsumerGroupResponseBody) SetDynamicMessage(v string) *GetConsumerGroupResponseBody
- func (s *GetConsumerGroupResponseBody) SetHttpStatusCode(v int32) *GetConsumerGroupResponseBody
- func (s *GetConsumerGroupResponseBody) SetMessage(v string) *GetConsumerGroupResponseBody
- func (s *GetConsumerGroupResponseBody) SetRequestId(v string) *GetConsumerGroupResponseBody
- func (s *GetConsumerGroupResponseBody) SetSuccess(v bool) *GetConsumerGroupResponseBody
- func (s GetConsumerGroupResponseBody) String() string
- type GetConsumerGroupResponseBodyData
- func (s GetConsumerGroupResponseBodyData) GoString() string
- func (s *GetConsumerGroupResponseBodyData) SetConsumeRetryPolicy(v *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) *GetConsumerGroupResponseBodyData
- func (s *GetConsumerGroupResponseBodyData) SetConsumerGroupId(v string) *GetConsumerGroupResponseBodyData
- func (s *GetConsumerGroupResponseBodyData) SetCreateTime(v string) *GetConsumerGroupResponseBodyData
- func (s *GetConsumerGroupResponseBodyData) SetDeliveryOrderType(v string) *GetConsumerGroupResponseBodyData
- func (s *GetConsumerGroupResponseBodyData) SetInstanceId(v string) *GetConsumerGroupResponseBodyData
- func (s *GetConsumerGroupResponseBodyData) SetRegionId(v string) *GetConsumerGroupResponseBodyData
- func (s *GetConsumerGroupResponseBodyData) SetRemark(v string) *GetConsumerGroupResponseBodyData
- func (s *GetConsumerGroupResponseBodyData) SetStatus(v string) *GetConsumerGroupResponseBodyData
- func (s *GetConsumerGroupResponseBodyData) SetUpdateTime(v string) *GetConsumerGroupResponseBodyData
- func (s GetConsumerGroupResponseBodyData) String() string
- type GetConsumerGroupResponseBodyDataConsumeRetryPolicy
- func (s GetConsumerGroupResponseBodyDataConsumeRetryPolicy) GoString() string
- func (s *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetDeadLetterTargetTopic(v string) *GetConsumerGroupResponseBodyDataConsumeRetryPolicy
- func (s *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetMaxRetryTimes(v int32) *GetConsumerGroupResponseBodyDataConsumeRetryPolicy
- func (s *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetRetryPolicy(v string) *GetConsumerGroupResponseBodyDataConsumeRetryPolicy
- func (s GetConsumerGroupResponseBodyDataConsumeRetryPolicy) String() string
- type GetInstanceResponse
- func (s GetInstanceResponse) GoString() string
- func (s *GetInstanceResponse) SetBody(v *GetInstanceResponseBody) *GetInstanceResponse
- func (s *GetInstanceResponse) SetHeaders(v map[string]*string) *GetInstanceResponse
- func (s *GetInstanceResponse) SetStatusCode(v int32) *GetInstanceResponse
- func (s GetInstanceResponse) String() string
- type GetInstanceResponseBody
- func (s GetInstanceResponseBody) GoString() string
- func (s *GetInstanceResponseBody) SetCode(v string) *GetInstanceResponseBody
- func (s *GetInstanceResponseBody) SetData(v *GetInstanceResponseBodyData) *GetInstanceResponseBody
- func (s *GetInstanceResponseBody) SetDynamicCode(v string) *GetInstanceResponseBody
- func (s *GetInstanceResponseBody) SetDynamicMessage(v string) *GetInstanceResponseBody
- func (s *GetInstanceResponseBody) SetHttpStatusCode(v int32) *GetInstanceResponseBody
- func (s *GetInstanceResponseBody) SetMessage(v string) *GetInstanceResponseBody
- func (s *GetInstanceResponseBody) SetRequestId(v string) *GetInstanceResponseBody
- func (s *GetInstanceResponseBody) SetSuccess(v bool) *GetInstanceResponseBody
- func (s GetInstanceResponseBody) String() string
- type GetInstanceResponseBodyData
- func (s GetInstanceResponseBodyData) GoString() string
- func (s *GetInstanceResponseBodyData) SetAccountInfo(v *GetInstanceResponseBodyDataAccountInfo) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetAclInfo(v *GetInstanceResponseBodyDataAclInfo) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetBid(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetCommodityCode(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetCreateTime(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetExpireTime(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetExtConfig(v *GetInstanceResponseBodyDataExtConfig) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetGroupCount(v int64) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetInstanceId(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetInstanceName(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetInstanceQuotas(v []*GetInstanceResponseBodyDataInstanceQuotas) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetNetworkInfo(v *GetInstanceResponseBodyDataNetworkInfo) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetPaymentType(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetProductInfo(v *GetInstanceResponseBodyDataProductInfo) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetRegionId(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetReleaseTime(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetRemark(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetResourceGroupId(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetSeriesCode(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetServiceCode(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetSoftware(v *GetInstanceResponseBodyDataSoftware) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetStartTime(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetStatus(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetSubSeriesCode(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetTags(v []*GetInstanceResponseBodyDataTags) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetTopicCount(v int64) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetUpdateTime(v string) *GetInstanceResponseBodyData
- func (s *GetInstanceResponseBodyData) SetUserId(v string) *GetInstanceResponseBodyData
- func (s GetInstanceResponseBodyData) String() string
- type GetInstanceResponseBodyDataAccountInfo
- type GetInstanceResponseBodyDataAclInfo
- func (s GetInstanceResponseBodyDataAclInfo) GoString() string
- func (s *GetInstanceResponseBodyDataAclInfo) SetAclType(v string) *GetInstanceResponseBodyDataAclInfo
- func (s *GetInstanceResponseBodyDataAclInfo) SetAclTypes(v []*string) *GetInstanceResponseBodyDataAclInfo
- func (s *GetInstanceResponseBodyDataAclInfo) SetDefaultVpcAuthFree(v bool) *GetInstanceResponseBodyDataAclInfo
- func (s GetInstanceResponseBodyDataAclInfo) String() string
- type GetInstanceResponseBodyDataExtConfig
- func (s GetInstanceResponseBodyDataExtConfig) GoString() string
- func (s *GetInstanceResponseBodyDataExtConfig) SetAclType(v string) *GetInstanceResponseBodyDataExtConfig
- func (s *GetInstanceResponseBodyDataExtConfig) SetAutoScaling(v bool) *GetInstanceResponseBodyDataExtConfig
- func (s *GetInstanceResponseBodyDataExtConfig) SetFlowOutBandwidth(v int32) *GetInstanceResponseBodyDataExtConfig
- func (s *GetInstanceResponseBodyDataExtConfig) SetFlowOutType(v string) *GetInstanceResponseBodyDataExtConfig
- func (s *GetInstanceResponseBodyDataExtConfig) SetInternetSpec(v string) *GetInstanceResponseBodyDataExtConfig
- func (s *GetInstanceResponseBodyDataExtConfig) SetMessageRetentionTime(v int32) *GetInstanceResponseBodyDataExtConfig
- func (s *GetInstanceResponseBodyDataExtConfig) SetMsgProcessSpec(v string) *GetInstanceResponseBodyDataExtConfig
- func (s *GetInstanceResponseBodyDataExtConfig) SetSendReceiveRatio(v float32) *GetInstanceResponseBodyDataExtConfig
- func (s *GetInstanceResponseBodyDataExtConfig) SetSupportAutoScaling(v bool) *GetInstanceResponseBodyDataExtConfig
- func (s GetInstanceResponseBodyDataExtConfig) String() string
- type GetInstanceResponseBodyDataInstanceQuotas
- func (s GetInstanceResponseBodyDataInstanceQuotas) GoString() string
- func (s *GetInstanceResponseBodyDataInstanceQuotas) SetFreeCount(v float64) *GetInstanceResponseBodyDataInstanceQuotas
- func (s *GetInstanceResponseBodyDataInstanceQuotas) SetQuotaName(v string) *GetInstanceResponseBodyDataInstanceQuotas
- func (s *GetInstanceResponseBodyDataInstanceQuotas) SetTotalCount(v float64) *GetInstanceResponseBodyDataInstanceQuotas
- func (s *GetInstanceResponseBodyDataInstanceQuotas) SetUsedCount(v float64) *GetInstanceResponseBodyDataInstanceQuotas
- func (s GetInstanceResponseBodyDataInstanceQuotas) String() string
- type GetInstanceResponseBodyDataNetworkInfo
- func (s GetInstanceResponseBodyDataNetworkInfo) GoString() string
- func (s *GetInstanceResponseBodyDataNetworkInfo) SetEndpoints(v []*GetInstanceResponseBodyDataNetworkInfoEndpoints) *GetInstanceResponseBodyDataNetworkInfo
- func (s *GetInstanceResponseBodyDataNetworkInfo) SetInternetInfo(v *GetInstanceResponseBodyDataNetworkInfoInternetInfo) *GetInstanceResponseBodyDataNetworkInfo
- func (s *GetInstanceResponseBodyDataNetworkInfo) SetVpcInfo(v *GetInstanceResponseBodyDataNetworkInfoVpcInfo) *GetInstanceResponseBodyDataNetworkInfo
- func (s GetInstanceResponseBodyDataNetworkInfo) String() string
- type GetInstanceResponseBodyDataNetworkInfoEndpoints
- func (s GetInstanceResponseBodyDataNetworkInfoEndpoints) GoString() string
- func (s *GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointType(v string) *GetInstanceResponseBodyDataNetworkInfoEndpoints
- func (s *GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointUrl(v string) *GetInstanceResponseBodyDataNetworkInfoEndpoints
- func (s *GetInstanceResponseBodyDataNetworkInfoEndpoints) SetIpWhitelist(v []*string) *GetInstanceResponseBodyDataNetworkInfoEndpoints
- func (s GetInstanceResponseBodyDataNetworkInfoEndpoints) String() string
- type GetInstanceResponseBodyDataNetworkInfoInternetInfo
- func (s GetInstanceResponseBodyDataNetworkInfoInternetInfo) GoString() string
- func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutBandwidth(v int32) *GetInstanceResponseBodyDataNetworkInfoInternetInfo
- func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutType(v string) *GetInstanceResponseBodyDataNetworkInfoInternetInfo
- func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetInternetSpec(v string) *GetInstanceResponseBodyDataNetworkInfoInternetInfo
- func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetIpWhitelist(v []*string) *GetInstanceResponseBodyDataNetworkInfoInternetInfo
- func (s GetInstanceResponseBodyDataNetworkInfoInternetInfo) String() string
- type GetInstanceResponseBodyDataNetworkInfoVpcInfo
- func (s GetInstanceResponseBodyDataNetworkInfoVpcInfo) GoString() string
- func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetSecurityGroupIds(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfo
- func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVSwitchId(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfo
- func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVSwitches(v []*GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) *GetInstanceResponseBodyDataNetworkInfoVpcInfo
- func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVpcId(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfo
- func (s GetInstanceResponseBodyDataNetworkInfoVpcInfo) String() string
- type GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches
- func (s GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) GoString() string
- func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) SetVSwitchId(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches
- func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) SetZoneId(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches
- func (s GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) String() string
- type GetInstanceResponseBodyDataProductInfo
- func (s GetInstanceResponseBodyDataProductInfo) GoString() string
- func (s *GetInstanceResponseBodyDataProductInfo) SetAutoScaling(v bool) *GetInstanceResponseBodyDataProductInfo
- func (s *GetInstanceResponseBodyDataProductInfo) SetMessageRetentionTime(v int32) *GetInstanceResponseBodyDataProductInfo
- func (s *GetInstanceResponseBodyDataProductInfo) SetMsgProcessSpec(v string) *GetInstanceResponseBodyDataProductInfo
- func (s *GetInstanceResponseBodyDataProductInfo) SetSendReceiveRatio(v float32) *GetInstanceResponseBodyDataProductInfo
- func (s *GetInstanceResponseBodyDataProductInfo) SetSupportAutoScaling(v bool) *GetInstanceResponseBodyDataProductInfo
- func (s *GetInstanceResponseBodyDataProductInfo) SetTraceOn(v bool) *GetInstanceResponseBodyDataProductInfo
- func (s GetInstanceResponseBodyDataProductInfo) String() string
- type GetInstanceResponseBodyDataSoftware
- func (s GetInstanceResponseBodyDataSoftware) GoString() string
- func (s *GetInstanceResponseBodyDataSoftware) SetMaintainTime(v string) *GetInstanceResponseBodyDataSoftware
- func (s *GetInstanceResponseBodyDataSoftware) SetSoftwareVersion(v string) *GetInstanceResponseBodyDataSoftware
- func (s *GetInstanceResponseBodyDataSoftware) SetUpgradeMethod(v string) *GetInstanceResponseBodyDataSoftware
- func (s GetInstanceResponseBodyDataSoftware) String() string
- type GetInstanceResponseBodyDataTags
- func (s GetInstanceResponseBodyDataTags) GoString() string
- func (s *GetInstanceResponseBodyDataTags) SetKey(v string) *GetInstanceResponseBodyDataTags
- func (s *GetInstanceResponseBodyDataTags) SetValue(v string) *GetInstanceResponseBodyDataTags
- func (s GetInstanceResponseBodyDataTags) String() string
- type GetTopicResponse
- func (s GetTopicResponse) GoString() string
- func (s *GetTopicResponse) SetBody(v *GetTopicResponseBody) *GetTopicResponse
- func (s *GetTopicResponse) SetHeaders(v map[string]*string) *GetTopicResponse
- func (s *GetTopicResponse) SetStatusCode(v int32) *GetTopicResponse
- func (s GetTopicResponse) String() string
- type GetTopicResponseBody
- func (s GetTopicResponseBody) GoString() string
- func (s *GetTopicResponseBody) SetCode(v string) *GetTopicResponseBody
- func (s *GetTopicResponseBody) SetData(v *GetTopicResponseBodyData) *GetTopicResponseBody
- func (s *GetTopicResponseBody) SetDynamicCode(v string) *GetTopicResponseBody
- func (s *GetTopicResponseBody) SetDynamicMessage(v string) *GetTopicResponseBody
- func (s *GetTopicResponseBody) SetHttpStatusCode(v int32) *GetTopicResponseBody
- func (s *GetTopicResponseBody) SetMessage(v string) *GetTopicResponseBody
- func (s *GetTopicResponseBody) SetRequestId(v string) *GetTopicResponseBody
- func (s *GetTopicResponseBody) SetSuccess(v bool) *GetTopicResponseBody
- func (s GetTopicResponseBody) String() string
- type GetTopicResponseBodyData
- func (s GetTopicResponseBodyData) GoString() string
- func (s *GetTopicResponseBodyData) SetCreateTime(v string) *GetTopicResponseBodyData
- func (s *GetTopicResponseBodyData) SetInstanceId(v string) *GetTopicResponseBodyData
- func (s *GetTopicResponseBodyData) SetMessageType(v string) *GetTopicResponseBodyData
- func (s *GetTopicResponseBodyData) SetRegionId(v string) *GetTopicResponseBodyData
- func (s *GetTopicResponseBodyData) SetRemark(v string) *GetTopicResponseBodyData
- func (s *GetTopicResponseBodyData) SetStatus(v string) *GetTopicResponseBodyData
- func (s *GetTopicResponseBodyData) SetTopicName(v string) *GetTopicResponseBodyData
- func (s *GetTopicResponseBodyData) SetUpdateTime(v string) *GetTopicResponseBodyData
- func (s GetTopicResponseBodyData) String() string
- type ListAvailableZonesResponse
- func (s ListAvailableZonesResponse) GoString() string
- func (s *ListAvailableZonesResponse) SetBody(v *ListAvailableZonesResponseBody) *ListAvailableZonesResponse
- func (s *ListAvailableZonesResponse) SetHeaders(v map[string]*string) *ListAvailableZonesResponse
- func (s *ListAvailableZonesResponse) SetStatusCode(v int32) *ListAvailableZonesResponse
- func (s ListAvailableZonesResponse) String() string
- type ListAvailableZonesResponseBody
- func (s ListAvailableZonesResponseBody) GoString() string
- func (s *ListAvailableZonesResponseBody) SetCode(v string) *ListAvailableZonesResponseBody
- func (s *ListAvailableZonesResponseBody) SetData(v []*ListAvailableZonesResponseBodyData) *ListAvailableZonesResponseBody
- func (s *ListAvailableZonesResponseBody) SetDynamicCode(v string) *ListAvailableZonesResponseBody
- func (s *ListAvailableZonesResponseBody) SetDynamicMessage(v string) *ListAvailableZonesResponseBody
- func (s *ListAvailableZonesResponseBody) SetHttpStatusCode(v int32) *ListAvailableZonesResponseBody
- func (s *ListAvailableZonesResponseBody) SetMessage(v string) *ListAvailableZonesResponseBody
- func (s *ListAvailableZonesResponseBody) SetRequestId(v string) *ListAvailableZonesResponseBody
- func (s *ListAvailableZonesResponseBody) SetSuccess(v bool) *ListAvailableZonesResponseBody
- func (s ListAvailableZonesResponseBody) String() string
- type ListAvailableZonesResponseBodyData
- func (s ListAvailableZonesResponseBodyData) GoString() string
- func (s *ListAvailableZonesResponseBodyData) SetCreateTime(v string) *ListAvailableZonesResponseBodyData
- func (s *ListAvailableZonesResponseBodyData) SetUpdateTime(v string) *ListAvailableZonesResponseBodyData
- func (s *ListAvailableZonesResponseBodyData) SetZoneId(v string) *ListAvailableZonesResponseBodyData
- func (s *ListAvailableZonesResponseBodyData) SetZoneName(v string) *ListAvailableZonesResponseBodyData
- func (s ListAvailableZonesResponseBodyData) String() string
- type ListConsumerConnectionsResponse
- func (s ListConsumerConnectionsResponse) GoString() string
- func (s *ListConsumerConnectionsResponse) SetBody(v *ListConsumerConnectionsResponseBody) *ListConsumerConnectionsResponse
- func (s *ListConsumerConnectionsResponse) SetHeaders(v map[string]*string) *ListConsumerConnectionsResponse
- func (s *ListConsumerConnectionsResponse) SetStatusCode(v int32) *ListConsumerConnectionsResponse
- func (s ListConsumerConnectionsResponse) String() string
- type ListConsumerConnectionsResponseBody
- func (s ListConsumerConnectionsResponseBody) GoString() string
- func (s *ListConsumerConnectionsResponseBody) SetCode(v string) *ListConsumerConnectionsResponseBody
- func (s *ListConsumerConnectionsResponseBody) SetData(v *ListConsumerConnectionsResponseBodyData) *ListConsumerConnectionsResponseBody
- func (s *ListConsumerConnectionsResponseBody) SetDynamicCode(v string) *ListConsumerConnectionsResponseBody
- func (s *ListConsumerConnectionsResponseBody) SetDynamicMessage(v string) *ListConsumerConnectionsResponseBody
- func (s *ListConsumerConnectionsResponseBody) SetHttpStatusCode(v int32) *ListConsumerConnectionsResponseBody
- func (s *ListConsumerConnectionsResponseBody) SetMessage(v string) *ListConsumerConnectionsResponseBody
- func (s *ListConsumerConnectionsResponseBody) SetRequestId(v string) *ListConsumerConnectionsResponseBody
- func (s *ListConsumerConnectionsResponseBody) SetSuccess(v bool) *ListConsumerConnectionsResponseBody
- func (s ListConsumerConnectionsResponseBody) String() string
- type ListConsumerConnectionsResponseBodyData
- func (s ListConsumerConnectionsResponseBodyData) GoString() string
- func (s *ListConsumerConnectionsResponseBodyData) SetConnections(v []*ListConsumerConnectionsResponseBodyDataConnections) *ListConsumerConnectionsResponseBodyData
- func (s *ListConsumerConnectionsResponseBodyData) SetConsumerGroupId(v string) *ListConsumerConnectionsResponseBodyData
- func (s *ListConsumerConnectionsResponseBodyData) SetInstanceId(v string) *ListConsumerConnectionsResponseBodyData
- func (s *ListConsumerConnectionsResponseBodyData) SetRegionId(v string) *ListConsumerConnectionsResponseBodyData
- func (s ListConsumerConnectionsResponseBodyData) String() string
- type ListConsumerConnectionsResponseBodyDataConnections
- func (s ListConsumerConnectionsResponseBodyDataConnections) GoString() string
- func (s *ListConsumerConnectionsResponseBodyDataConnections) SetClientId(v string) *ListConsumerConnectionsResponseBodyDataConnections
- func (s *ListConsumerConnectionsResponseBodyDataConnections) SetEgressIp(v string) *ListConsumerConnectionsResponseBodyDataConnections
- func (s *ListConsumerConnectionsResponseBodyDataConnections) SetHostname(v string) *ListConsumerConnectionsResponseBodyDataConnections
- func (s *ListConsumerConnectionsResponseBodyDataConnections) SetLanguage(v string) *ListConsumerConnectionsResponseBodyDataConnections
- func (s *ListConsumerConnectionsResponseBodyDataConnections) SetMessageModel(v string) *ListConsumerConnectionsResponseBodyDataConnections
- func (s *ListConsumerConnectionsResponseBodyDataConnections) SetVersion(v string) *ListConsumerConnectionsResponseBodyDataConnections
- func (s ListConsumerConnectionsResponseBodyDataConnections) String() string
- type ListConsumerGroupSubscriptionsResponse
- func (s ListConsumerGroupSubscriptionsResponse) GoString() string
- func (s *ListConsumerGroupSubscriptionsResponse) SetBody(v *ListConsumerGroupSubscriptionsResponseBody) *ListConsumerGroupSubscriptionsResponse
- func (s *ListConsumerGroupSubscriptionsResponse) SetHeaders(v map[string]*string) *ListConsumerGroupSubscriptionsResponse
- func (s *ListConsumerGroupSubscriptionsResponse) SetStatusCode(v int32) *ListConsumerGroupSubscriptionsResponse
- func (s ListConsumerGroupSubscriptionsResponse) String() string
- type ListConsumerGroupSubscriptionsResponseBody
- func (s ListConsumerGroupSubscriptionsResponseBody) GoString() string
- func (s *ListConsumerGroupSubscriptionsResponseBody) SetCode(v string) *ListConsumerGroupSubscriptionsResponseBody
- func (s *ListConsumerGroupSubscriptionsResponseBody) SetData(v []*ListConsumerGroupSubscriptionsResponseBodyData) *ListConsumerGroupSubscriptionsResponseBody
- func (s *ListConsumerGroupSubscriptionsResponseBody) SetDynamicCode(v string) *ListConsumerGroupSubscriptionsResponseBody
- func (s *ListConsumerGroupSubscriptionsResponseBody) SetDynamicMessage(v string) *ListConsumerGroupSubscriptionsResponseBody
- func (s *ListConsumerGroupSubscriptionsResponseBody) SetHttpStatusCode(v int32) *ListConsumerGroupSubscriptionsResponseBody
- func (s *ListConsumerGroupSubscriptionsResponseBody) SetMessage(v string) *ListConsumerGroupSubscriptionsResponseBody
- func (s *ListConsumerGroupSubscriptionsResponseBody) SetRequestId(v string) *ListConsumerGroupSubscriptionsResponseBody
- func (s *ListConsumerGroupSubscriptionsResponseBody) SetSuccess(v bool) *ListConsumerGroupSubscriptionsResponseBody
- func (s ListConsumerGroupSubscriptionsResponseBody) String() string
- type ListConsumerGroupSubscriptionsResponseBodyData
- func (s ListConsumerGroupSubscriptionsResponseBodyData) GoString() string
- func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetConsistency(v bool) *ListConsumerGroupSubscriptionsResponseBodyData
- func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetConsumerGroupId(v string) *ListConsumerGroupSubscriptionsResponseBodyData
- func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpression(v string) *ListConsumerGroupSubscriptionsResponseBodyData
- func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpressionType(v string) *ListConsumerGroupSubscriptionsResponseBodyData
- func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetMessageModel(v string) *ListConsumerGroupSubscriptionsResponseBodyData
- func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetSubscriptionStatus(v string) *ListConsumerGroupSubscriptionsResponseBodyData
- func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetTopicCreated(v bool) *ListConsumerGroupSubscriptionsResponseBodyData
- func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetTopicName(v string) *ListConsumerGroupSubscriptionsResponseBodyData
- func (s ListConsumerGroupSubscriptionsResponseBodyData) String() string
- type ListConsumerGroupsRequest
- func (s ListConsumerGroupsRequest) GoString() string
- func (s *ListConsumerGroupsRequest) SetFilter(v string) *ListConsumerGroupsRequest
- func (s *ListConsumerGroupsRequest) SetPageNumber(v int32) *ListConsumerGroupsRequest
- func (s *ListConsumerGroupsRequest) SetPageSize(v int32) *ListConsumerGroupsRequest
- func (s ListConsumerGroupsRequest) String() string
- type ListConsumerGroupsResponse
- func (s ListConsumerGroupsResponse) GoString() string
- func (s *ListConsumerGroupsResponse) SetBody(v *ListConsumerGroupsResponseBody) *ListConsumerGroupsResponse
- func (s *ListConsumerGroupsResponse) SetHeaders(v map[string]*string) *ListConsumerGroupsResponse
- func (s *ListConsumerGroupsResponse) SetStatusCode(v int32) *ListConsumerGroupsResponse
- func (s ListConsumerGroupsResponse) String() string
- type ListConsumerGroupsResponseBody
- func (s ListConsumerGroupsResponseBody) GoString() string
- func (s *ListConsumerGroupsResponseBody) SetCode(v string) *ListConsumerGroupsResponseBody
- func (s *ListConsumerGroupsResponseBody) SetData(v *ListConsumerGroupsResponseBodyData) *ListConsumerGroupsResponseBody
- func (s *ListConsumerGroupsResponseBody) SetDynamicCode(v string) *ListConsumerGroupsResponseBody
- func (s *ListConsumerGroupsResponseBody) SetDynamicMessage(v string) *ListConsumerGroupsResponseBody
- func (s *ListConsumerGroupsResponseBody) SetHttpStatusCode(v int32) *ListConsumerGroupsResponseBody
- func (s *ListConsumerGroupsResponseBody) SetMessage(v string) *ListConsumerGroupsResponseBody
- func (s *ListConsumerGroupsResponseBody) SetRequestId(v string) *ListConsumerGroupsResponseBody
- func (s *ListConsumerGroupsResponseBody) SetSuccess(v bool) *ListConsumerGroupsResponseBody
- func (s ListConsumerGroupsResponseBody) String() string
- type ListConsumerGroupsResponseBodyData
- func (s ListConsumerGroupsResponseBodyData) GoString() string
- func (s *ListConsumerGroupsResponseBodyData) SetList(v []*ListConsumerGroupsResponseBodyDataList) *ListConsumerGroupsResponseBodyData
- func (s *ListConsumerGroupsResponseBodyData) SetPageNumber(v int64) *ListConsumerGroupsResponseBodyData
- func (s *ListConsumerGroupsResponseBodyData) SetPageSize(v int64) *ListConsumerGroupsResponseBodyData
- func (s *ListConsumerGroupsResponseBodyData) SetTotalCount(v int64) *ListConsumerGroupsResponseBodyData
- func (s ListConsumerGroupsResponseBodyData) String() string
- type ListConsumerGroupsResponseBodyDataList
- func (s ListConsumerGroupsResponseBodyDataList) GoString() string
- func (s *ListConsumerGroupsResponseBodyDataList) SetConsumerGroupId(v string) *ListConsumerGroupsResponseBodyDataList
- func (s *ListConsumerGroupsResponseBodyDataList) SetCreateTime(v string) *ListConsumerGroupsResponseBodyDataList
- func (s *ListConsumerGroupsResponseBodyDataList) SetInstanceId(v string) *ListConsumerGroupsResponseBodyDataList
- func (s *ListConsumerGroupsResponseBodyDataList) SetRegionId(v string) *ListConsumerGroupsResponseBodyDataList
- func (s *ListConsumerGroupsResponseBodyDataList) SetRemark(v string) *ListConsumerGroupsResponseBodyDataList
- func (s *ListConsumerGroupsResponseBodyDataList) SetStatus(v string) *ListConsumerGroupsResponseBodyDataList
- func (s *ListConsumerGroupsResponseBodyDataList) SetUpdateTime(v string) *ListConsumerGroupsResponseBodyDataList
- func (s ListConsumerGroupsResponseBodyDataList) String() string
- type ListInstancesRequest
- func (s ListInstancesRequest) GoString() string
- func (s *ListInstancesRequest) SetFilter(v string) *ListInstancesRequest
- func (s *ListInstancesRequest) SetPageNumber(v int32) *ListInstancesRequest
- func (s *ListInstancesRequest) SetPageSize(v int32) *ListInstancesRequest
- func (s *ListInstancesRequest) SetResourceGroupId(v string) *ListInstancesRequest
- func (s *ListInstancesRequest) SetSeriesCodes(v []*string) *ListInstancesRequest
- func (s *ListInstancesRequest) SetTags(v string) *ListInstancesRequest
- func (s ListInstancesRequest) String() string
- type ListInstancesResponse
- func (s ListInstancesResponse) GoString() string
- func (s *ListInstancesResponse) SetBody(v *ListInstancesResponseBody) *ListInstancesResponse
- func (s *ListInstancesResponse) SetHeaders(v map[string]*string) *ListInstancesResponse
- func (s *ListInstancesResponse) SetStatusCode(v int32) *ListInstancesResponse
- func (s ListInstancesResponse) String() string
- type ListInstancesResponseBody
- func (s ListInstancesResponseBody) GoString() string
- func (s *ListInstancesResponseBody) SetCode(v string) *ListInstancesResponseBody
- func (s *ListInstancesResponseBody) SetData(v *ListInstancesResponseBodyData) *ListInstancesResponseBody
- func (s *ListInstancesResponseBody) SetDynamicCode(v string) *ListInstancesResponseBody
- func (s *ListInstancesResponseBody) SetDynamicMessage(v string) *ListInstancesResponseBody
- func (s *ListInstancesResponseBody) SetHttpStatusCode(v int32) *ListInstancesResponseBody
- func (s *ListInstancesResponseBody) SetMessage(v string) *ListInstancesResponseBody
- func (s *ListInstancesResponseBody) SetRequestId(v string) *ListInstancesResponseBody
- func (s *ListInstancesResponseBody) SetSuccess(v bool) *ListInstancesResponseBody
- func (s ListInstancesResponseBody) String() string
- type ListInstancesResponseBodyData
- func (s ListInstancesResponseBodyData) GoString() string
- func (s *ListInstancesResponseBodyData) SetList(v []*ListInstancesResponseBodyDataList) *ListInstancesResponseBodyData
- func (s *ListInstancesResponseBodyData) SetPageNumber(v int64) *ListInstancesResponseBodyData
- func (s *ListInstancesResponseBodyData) SetPageSize(v int64) *ListInstancesResponseBodyData
- func (s *ListInstancesResponseBodyData) SetTotalCount(v int64) *ListInstancesResponseBodyData
- func (s ListInstancesResponseBodyData) String() string
- type ListInstancesResponseBodyDataList
- func (s ListInstancesResponseBodyDataList) GoString() string
- func (s *ListInstancesResponseBodyDataList) SetCommodityCode(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetCreateTime(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetExpireTime(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetGroupCount(v int64) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetInstanceId(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetInstanceName(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetPaymentType(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetProductInfo(v *ListInstancesResponseBodyDataListProductInfo) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetRegionId(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetReleaseTime(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetRemark(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetResourceGroupId(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetSeriesCode(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetServiceCode(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetStartTime(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetStatus(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetSubSeriesCode(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetTags(v []*ListInstancesResponseBodyDataListTags) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetTopicCount(v int64) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetUpdateTime(v string) *ListInstancesResponseBodyDataList
- func (s *ListInstancesResponseBodyDataList) SetUserId(v string) *ListInstancesResponseBodyDataList
- func (s ListInstancesResponseBodyDataList) String() string
- type ListInstancesResponseBodyDataListProductInfo
- type ListInstancesResponseBodyDataListTags
- func (s ListInstancesResponseBodyDataListTags) GoString() string
- func (s *ListInstancesResponseBodyDataListTags) SetKey(v string) *ListInstancesResponseBodyDataListTags
- func (s *ListInstancesResponseBodyDataListTags) SetValue(v string) *ListInstancesResponseBodyDataListTags
- func (s ListInstancesResponseBodyDataListTags) String() string
- type ListInstancesShrinkRequest
- func (s ListInstancesShrinkRequest) GoString() string
- func (s *ListInstancesShrinkRequest) SetFilter(v string) *ListInstancesShrinkRequest
- func (s *ListInstancesShrinkRequest) SetPageNumber(v int32) *ListInstancesShrinkRequest
- func (s *ListInstancesShrinkRequest) SetPageSize(v int32) *ListInstancesShrinkRequest
- func (s *ListInstancesShrinkRequest) SetResourceGroupId(v string) *ListInstancesShrinkRequest
- func (s *ListInstancesShrinkRequest) SetSeriesCodesShrink(v string) *ListInstancesShrinkRequest
- func (s *ListInstancesShrinkRequest) SetTags(v string) *ListInstancesShrinkRequest
- func (s ListInstancesShrinkRequest) String() string
- type ListRegionsResponse
- func (s ListRegionsResponse) GoString() string
- func (s *ListRegionsResponse) SetBody(v *ListRegionsResponseBody) *ListRegionsResponse
- func (s *ListRegionsResponse) SetHeaders(v map[string]*string) *ListRegionsResponse
- func (s *ListRegionsResponse) SetStatusCode(v int32) *ListRegionsResponse
- func (s ListRegionsResponse) String() string
- type ListRegionsResponseBody
- func (s ListRegionsResponseBody) GoString() string
- func (s *ListRegionsResponseBody) SetCode(v string) *ListRegionsResponseBody
- func (s *ListRegionsResponseBody) SetData(v []*ListRegionsResponseBodyData) *ListRegionsResponseBody
- func (s *ListRegionsResponseBody) SetDynamicCode(v string) *ListRegionsResponseBody
- func (s *ListRegionsResponseBody) SetDynamicMessage(v string) *ListRegionsResponseBody
- func (s *ListRegionsResponseBody) SetHttpStatusCode(v int32) *ListRegionsResponseBody
- func (s *ListRegionsResponseBody) SetMessage(v string) *ListRegionsResponseBody
- func (s *ListRegionsResponseBody) SetRequestId(v string) *ListRegionsResponseBody
- func (s *ListRegionsResponseBody) SetSuccess(v bool) *ListRegionsResponseBody
- func (s ListRegionsResponseBody) String() string
- type ListRegionsResponseBodyData
- func (s ListRegionsResponseBodyData) GoString() string
- func (s *ListRegionsResponseBodyData) SetCreateTime(v string) *ListRegionsResponseBodyData
- func (s *ListRegionsResponseBodyData) SetRegionId(v string) *ListRegionsResponseBodyData
- func (s *ListRegionsResponseBodyData) SetRegionName(v string) *ListRegionsResponseBodyData
- func (s *ListRegionsResponseBodyData) SetSupportRocketmqV4(v bool) *ListRegionsResponseBodyData
- func (s *ListRegionsResponseBodyData) SetSupportRocketmqV5(v bool) *ListRegionsResponseBodyData
- func (s *ListRegionsResponseBodyData) SetTags(v []*ListRegionsResponseBodyDataTags) *ListRegionsResponseBodyData
- func (s *ListRegionsResponseBodyData) SetUpdateTime(v string) *ListRegionsResponseBodyData
- func (s ListRegionsResponseBodyData) String() string
- type ListRegionsResponseBodyDataTags
- func (s ListRegionsResponseBodyDataTags) GoString() string
- func (s *ListRegionsResponseBodyDataTags) SetTagCode(v string) *ListRegionsResponseBodyDataTags
- func (s *ListRegionsResponseBodyDataTags) SetTagValue(v interface{}) *ListRegionsResponseBodyDataTags
- func (s ListRegionsResponseBodyDataTags) String() string
- type ListTopicSubscriptionsResponse
- func (s ListTopicSubscriptionsResponse) GoString() string
- func (s *ListTopicSubscriptionsResponse) SetBody(v *ListTopicSubscriptionsResponseBody) *ListTopicSubscriptionsResponse
- func (s *ListTopicSubscriptionsResponse) SetHeaders(v map[string]*string) *ListTopicSubscriptionsResponse
- func (s *ListTopicSubscriptionsResponse) SetStatusCode(v int32) *ListTopicSubscriptionsResponse
- func (s ListTopicSubscriptionsResponse) String() string
- type ListTopicSubscriptionsResponseBody
- func (s ListTopicSubscriptionsResponseBody) GoString() string
- func (s *ListTopicSubscriptionsResponseBody) SetCode(v string) *ListTopicSubscriptionsResponseBody
- func (s *ListTopicSubscriptionsResponseBody) SetData(v []*ListTopicSubscriptionsResponseBodyData) *ListTopicSubscriptionsResponseBody
- func (s *ListTopicSubscriptionsResponseBody) SetDynamicCode(v string) *ListTopicSubscriptionsResponseBody
- func (s *ListTopicSubscriptionsResponseBody) SetDynamicMessage(v string) *ListTopicSubscriptionsResponseBody
- func (s *ListTopicSubscriptionsResponseBody) SetHttpStatusCode(v int32) *ListTopicSubscriptionsResponseBody
- func (s *ListTopicSubscriptionsResponseBody) SetMessage(v string) *ListTopicSubscriptionsResponseBody
- func (s *ListTopicSubscriptionsResponseBody) SetRequestId(v string) *ListTopicSubscriptionsResponseBody
- func (s *ListTopicSubscriptionsResponseBody) SetSuccess(v bool) *ListTopicSubscriptionsResponseBody
- func (s ListTopicSubscriptionsResponseBody) String() string
- type ListTopicSubscriptionsResponseBodyData
- func (s ListTopicSubscriptionsResponseBodyData) GoString() string
- func (s *ListTopicSubscriptionsResponseBodyData) SetConsistency(v string) *ListTopicSubscriptionsResponseBodyData
- func (s *ListTopicSubscriptionsResponseBodyData) SetConsumerGroupId(v string) *ListTopicSubscriptionsResponseBodyData
- func (s *ListTopicSubscriptionsResponseBodyData) SetFilterExpression(v string) *ListTopicSubscriptionsResponseBodyData
- func (s *ListTopicSubscriptionsResponseBodyData) SetFilterExpressionType(v string) *ListTopicSubscriptionsResponseBodyData
- func (s *ListTopicSubscriptionsResponseBodyData) SetMessageModel(v string) *ListTopicSubscriptionsResponseBodyData
- func (s *ListTopicSubscriptionsResponseBodyData) SetSubscriptionStatus(v string) *ListTopicSubscriptionsResponseBodyData
- func (s *ListTopicSubscriptionsResponseBodyData) SetTopicName(v string) *ListTopicSubscriptionsResponseBodyData
- func (s ListTopicSubscriptionsResponseBodyData) String() string
- type ListTopicsRequest
- func (s ListTopicsRequest) GoString() string
- func (s *ListTopicsRequest) SetFilter(v string) *ListTopicsRequest
- func (s *ListTopicsRequest) SetMessageTypes(v []*string) *ListTopicsRequest
- func (s *ListTopicsRequest) SetPageNumber(v int32) *ListTopicsRequest
- func (s *ListTopicsRequest) SetPageSize(v int32) *ListTopicsRequest
- func (s ListTopicsRequest) String() string
- type ListTopicsResponse
- func (s ListTopicsResponse) GoString() string
- func (s *ListTopicsResponse) SetBody(v *ListTopicsResponseBody) *ListTopicsResponse
- func (s *ListTopicsResponse) SetHeaders(v map[string]*string) *ListTopicsResponse
- func (s *ListTopicsResponse) SetStatusCode(v int32) *ListTopicsResponse
- func (s ListTopicsResponse) String() string
- type ListTopicsResponseBody
- func (s ListTopicsResponseBody) GoString() string
- func (s *ListTopicsResponseBody) SetCode(v string) *ListTopicsResponseBody
- func (s *ListTopicsResponseBody) SetData(v *ListTopicsResponseBodyData) *ListTopicsResponseBody
- func (s *ListTopicsResponseBody) SetDynamicCode(v string) *ListTopicsResponseBody
- func (s *ListTopicsResponseBody) SetDynamicMessage(v string) *ListTopicsResponseBody
- func (s *ListTopicsResponseBody) SetHttpStatusCode(v int32) *ListTopicsResponseBody
- func (s *ListTopicsResponseBody) SetMessage(v string) *ListTopicsResponseBody
- func (s *ListTopicsResponseBody) SetRequestId(v string) *ListTopicsResponseBody
- func (s *ListTopicsResponseBody) SetSuccess(v bool) *ListTopicsResponseBody
- func (s ListTopicsResponseBody) String() string
- type ListTopicsResponseBodyData
- func (s ListTopicsResponseBodyData) GoString() string
- func (s *ListTopicsResponseBodyData) SetList(v []*ListTopicsResponseBodyDataList) *ListTopicsResponseBodyData
- func (s *ListTopicsResponseBodyData) SetPageNumber(v int64) *ListTopicsResponseBodyData
- func (s *ListTopicsResponseBodyData) SetPageSize(v int64) *ListTopicsResponseBodyData
- func (s *ListTopicsResponseBodyData) SetTotalCount(v int64) *ListTopicsResponseBodyData
- func (s ListTopicsResponseBodyData) String() string
- type ListTopicsResponseBodyDataList
- func (s ListTopicsResponseBodyDataList) GoString() string
- func (s *ListTopicsResponseBodyDataList) SetCreateTime(v string) *ListTopicsResponseBodyDataList
- func (s *ListTopicsResponseBodyDataList) SetInstanceId(v string) *ListTopicsResponseBodyDataList
- func (s *ListTopicsResponseBodyDataList) SetMessageType(v string) *ListTopicsResponseBodyDataList
- func (s *ListTopicsResponseBodyDataList) SetRegionId(v string) *ListTopicsResponseBodyDataList
- func (s *ListTopicsResponseBodyDataList) SetRemark(v string) *ListTopicsResponseBodyDataList
- func (s *ListTopicsResponseBodyDataList) SetStatus(v string) *ListTopicsResponseBodyDataList
- func (s *ListTopicsResponseBodyDataList) SetTopicName(v string) *ListTopicsResponseBodyDataList
- func (s *ListTopicsResponseBodyDataList) SetUpdateTime(v string) *ListTopicsResponseBodyDataList
- func (s ListTopicsResponseBodyDataList) String() string
- type ListTopicsShrinkRequest
- func (s ListTopicsShrinkRequest) GoString() string
- func (s *ListTopicsShrinkRequest) SetFilter(v string) *ListTopicsShrinkRequest
- func (s *ListTopicsShrinkRequest) SetMessageTypesShrink(v string) *ListTopicsShrinkRequest
- func (s *ListTopicsShrinkRequest) SetPageNumber(v int32) *ListTopicsShrinkRequest
- func (s *ListTopicsShrinkRequest) SetPageSize(v int32) *ListTopicsShrinkRequest
- func (s ListTopicsShrinkRequest) String() string
- type ResetConsumeOffsetRequest
- type ResetConsumeOffsetResponse
- func (s ResetConsumeOffsetResponse) GoString() string
- func (s *ResetConsumeOffsetResponse) SetBody(v *ResetConsumeOffsetResponseBody) *ResetConsumeOffsetResponse
- func (s *ResetConsumeOffsetResponse) SetHeaders(v map[string]*string) *ResetConsumeOffsetResponse
- func (s *ResetConsumeOffsetResponse) SetStatusCode(v int32) *ResetConsumeOffsetResponse
- func (s ResetConsumeOffsetResponse) String() string
- type ResetConsumeOffsetResponseBody
- func (s ResetConsumeOffsetResponseBody) GoString() string
- func (s *ResetConsumeOffsetResponseBody) SetCode(v string) *ResetConsumeOffsetResponseBody
- func (s *ResetConsumeOffsetResponseBody) SetDynamicCode(v string) *ResetConsumeOffsetResponseBody
- func (s *ResetConsumeOffsetResponseBody) SetDynamicMessage(v string) *ResetConsumeOffsetResponseBody
- func (s *ResetConsumeOffsetResponseBody) SetHttpStatusCode(v int32) *ResetConsumeOffsetResponseBody
- func (s *ResetConsumeOffsetResponseBody) SetMessage(v string) *ResetConsumeOffsetResponseBody
- func (s *ResetConsumeOffsetResponseBody) SetRequestId(v string) *ResetConsumeOffsetResponseBody
- func (s *ResetConsumeOffsetResponseBody) SetSuccess(v bool) *ResetConsumeOffsetResponseBody
- func (s ResetConsumeOffsetResponseBody) String() string
- type UpdateConsumerGroupRequest
- func (s UpdateConsumerGroupRequest) GoString() string
- func (s *UpdateConsumerGroupRequest) SetConsumeRetryPolicy(v *UpdateConsumerGroupRequestConsumeRetryPolicy) *UpdateConsumerGroupRequest
- func (s *UpdateConsumerGroupRequest) SetDeliveryOrderType(v string) *UpdateConsumerGroupRequest
- func (s *UpdateConsumerGroupRequest) SetRemark(v string) *UpdateConsumerGroupRequest
- func (s UpdateConsumerGroupRequest) String() string
- type UpdateConsumerGroupRequestConsumeRetryPolicy
- func (s UpdateConsumerGroupRequestConsumeRetryPolicy) GoString() string
- func (s *UpdateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic(v string) *UpdateConsumerGroupRequestConsumeRetryPolicy
- func (s *UpdateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes(v int32) *UpdateConsumerGroupRequestConsumeRetryPolicy
- func (s *UpdateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy(v string) *UpdateConsumerGroupRequestConsumeRetryPolicy
- func (s UpdateConsumerGroupRequestConsumeRetryPolicy) String() string
- type UpdateConsumerGroupResponse
- func (s UpdateConsumerGroupResponse) GoString() string
- func (s *UpdateConsumerGroupResponse) SetBody(v *UpdateConsumerGroupResponseBody) *UpdateConsumerGroupResponse
- func (s *UpdateConsumerGroupResponse) SetHeaders(v map[string]*string) *UpdateConsumerGroupResponse
- func (s *UpdateConsumerGroupResponse) SetStatusCode(v int32) *UpdateConsumerGroupResponse
- func (s UpdateConsumerGroupResponse) String() string
- type UpdateConsumerGroupResponseBody
- func (s UpdateConsumerGroupResponseBody) GoString() string
- func (s *UpdateConsumerGroupResponseBody) SetCode(v string) *UpdateConsumerGroupResponseBody
- func (s *UpdateConsumerGroupResponseBody) SetData(v bool) *UpdateConsumerGroupResponseBody
- func (s *UpdateConsumerGroupResponseBody) SetDynamicCode(v string) *UpdateConsumerGroupResponseBody
- func (s *UpdateConsumerGroupResponseBody) SetDynamicMessage(v string) *UpdateConsumerGroupResponseBody
- func (s *UpdateConsumerGroupResponseBody) SetHttpStatusCode(v int32) *UpdateConsumerGroupResponseBody
- func (s *UpdateConsumerGroupResponseBody) SetMessage(v string) *UpdateConsumerGroupResponseBody
- func (s *UpdateConsumerGroupResponseBody) SetRequestId(v string) *UpdateConsumerGroupResponseBody
- func (s *UpdateConsumerGroupResponseBody) SetSuccess(v bool) *UpdateConsumerGroupResponseBody
- func (s UpdateConsumerGroupResponseBody) String() string
- type UpdateInstanceRequest
- func (s UpdateInstanceRequest) GoString() string
- func (s *UpdateInstanceRequest) SetAclInfo(v *UpdateInstanceRequestAclInfo) *UpdateInstanceRequest
- func (s *UpdateInstanceRequest) SetInstanceName(v string) *UpdateInstanceRequest
- func (s *UpdateInstanceRequest) SetNetworkInfo(v *UpdateInstanceRequestNetworkInfo) *UpdateInstanceRequest
- func (s *UpdateInstanceRequest) SetProductInfo(v *UpdateInstanceRequestProductInfo) *UpdateInstanceRequest
- func (s *UpdateInstanceRequest) SetRemark(v string) *UpdateInstanceRequest
- func (s UpdateInstanceRequest) String() string
- type UpdateInstanceRequestAclInfo
- func (s UpdateInstanceRequestAclInfo) GoString() string
- func (s *UpdateInstanceRequestAclInfo) SetAclTypes(v []*string) *UpdateInstanceRequestAclInfo
- func (s *UpdateInstanceRequestAclInfo) SetDefaultVpcAuthFree(v bool) *UpdateInstanceRequestAclInfo
- func (s UpdateInstanceRequestAclInfo) String() string
- type UpdateInstanceRequestNetworkInfo
- type UpdateInstanceRequestNetworkInfoInternetInfo
- type UpdateInstanceRequestProductInfo
- func (s UpdateInstanceRequestProductInfo) GoString() string
- func (s *UpdateInstanceRequestProductInfo) SetAutoScaling(v bool) *UpdateInstanceRequestProductInfo
- func (s *UpdateInstanceRequestProductInfo) SetMessageRetentionTime(v int32) *UpdateInstanceRequestProductInfo
- func (s *UpdateInstanceRequestProductInfo) SetSendReceiveRatio(v float32) *UpdateInstanceRequestProductInfo
- func (s *UpdateInstanceRequestProductInfo) SetTraceOn(v bool) *UpdateInstanceRequestProductInfo
- func (s UpdateInstanceRequestProductInfo) String() string
- type UpdateInstanceResponse
- func (s UpdateInstanceResponse) GoString() string
- func (s *UpdateInstanceResponse) SetBody(v *UpdateInstanceResponseBody) *UpdateInstanceResponse
- func (s *UpdateInstanceResponse) SetHeaders(v map[string]*string) *UpdateInstanceResponse
- func (s *UpdateInstanceResponse) SetStatusCode(v int32) *UpdateInstanceResponse
- func (s UpdateInstanceResponse) String() string
- type UpdateInstanceResponseBody
- func (s UpdateInstanceResponseBody) GoString() string
- func (s *UpdateInstanceResponseBody) SetCode(v string) *UpdateInstanceResponseBody
- func (s *UpdateInstanceResponseBody) SetData(v bool) *UpdateInstanceResponseBody
- func (s *UpdateInstanceResponseBody) SetDynamicCode(v string) *UpdateInstanceResponseBody
- func (s *UpdateInstanceResponseBody) SetDynamicMessage(v string) *UpdateInstanceResponseBody
- func (s *UpdateInstanceResponseBody) SetHttpStatusCode(v int32) *UpdateInstanceResponseBody
- func (s *UpdateInstanceResponseBody) SetMessage(v string) *UpdateInstanceResponseBody
- func (s *UpdateInstanceResponseBody) SetRequestId(v string) *UpdateInstanceResponseBody
- func (s *UpdateInstanceResponseBody) SetSuccess(v bool) *UpdateInstanceResponseBody
- func (s UpdateInstanceResponseBody) String() string
- type UpdateTopicRequest
- type UpdateTopicResponse
- func (s UpdateTopicResponse) GoString() string
- func (s *UpdateTopicResponse) SetBody(v *UpdateTopicResponseBody) *UpdateTopicResponse
- func (s *UpdateTopicResponse) SetHeaders(v map[string]*string) *UpdateTopicResponse
- func (s *UpdateTopicResponse) SetStatusCode(v int32) *UpdateTopicResponse
- func (s UpdateTopicResponse) String() string
- type UpdateTopicResponseBody
- func (s UpdateTopicResponseBody) GoString() string
- func (s *UpdateTopicResponseBody) SetCode(v string) *UpdateTopicResponseBody
- func (s *UpdateTopicResponseBody) SetData(v bool) *UpdateTopicResponseBody
- func (s *UpdateTopicResponseBody) SetDynamicCode(v string) *UpdateTopicResponseBody
- func (s *UpdateTopicResponseBody) SetDynamicMessage(v string) *UpdateTopicResponseBody
- func (s *UpdateTopicResponseBody) SetHttpStatusCode(v int32) *UpdateTopicResponseBody
- func (s *UpdateTopicResponseBody) SetMessage(v string) *UpdateTopicResponseBody
- func (s *UpdateTopicResponseBody) SetRequestId(v string) *UpdateTopicResponseBody
- func (s *UpdateTopicResponseBody) SetSuccess(v bool) *UpdateTopicResponseBody
- func (s UpdateTopicResponseBody) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChangeResourceGroupRequest ¶ added in v1.0.4
type ChangeResourceGroupRequest struct {
// The ID of the region in which the instance resides.
//
// This parameter is required.
//
// example:
//
// cn-hangzhou
RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
// The ID of the resource group to which the instance is changed.
//
// You can call the [ListResourceGroups](https://www.alibabacloud.com/help/resource-management/latest/listresourcegroups) operation to query existing resource groups.
//
// This parameter is required.
//
// example:
//
// rg-9gLOoK****
ResourceGroupId *string `json:"resourceGroupId,omitempty" xml:"resourceGroupId,omitempty"`
// The ID of the resource. Set this parameter to the ID of the ApsaraMQ for RocketMQ instance whose resource group you want to change.
//
// This parameter is required.
//
// example:
//
// c2c5d1274a8d4317a13bc5b0d4******
ResourceId *string `json:"resourceId,omitempty" xml:"resourceId,omitempty"`
// The type of resource.
//
// Set this parameter to **instance**. The value of this parameter cannot be changed.
//
// This parameter is required.
//
// example:
//
// instance
ResourceType *string `json:"resourceType,omitempty" xml:"resourceType,omitempty"`
}
func (ChangeResourceGroupRequest) GoString ¶ added in v1.0.4
func (s ChangeResourceGroupRequest) GoString() string
func (*ChangeResourceGroupRequest) SetRegionId ¶ added in v1.0.4
func (s *ChangeResourceGroupRequest) SetRegionId(v string) *ChangeResourceGroupRequest
func (*ChangeResourceGroupRequest) SetResourceGroupId ¶ added in v1.0.4
func (s *ChangeResourceGroupRequest) SetResourceGroupId(v string) *ChangeResourceGroupRequest
func (*ChangeResourceGroupRequest) SetResourceId ¶ added in v1.0.4
func (s *ChangeResourceGroupRequest) SetResourceId(v string) *ChangeResourceGroupRequest
func (*ChangeResourceGroupRequest) SetResourceType ¶ added in v1.0.4
func (s *ChangeResourceGroupRequest) SetResourceType(v string) *ChangeResourceGroupRequest
func (ChangeResourceGroupRequest) String ¶ added in v1.0.4
func (s ChangeResourceGroupRequest) String() string
type ChangeResourceGroupResponse ¶ added in v1.0.4
type ChangeResourceGroupResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *ChangeResourceGroupResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (ChangeResourceGroupResponse) GoString ¶ added in v1.0.4
func (s ChangeResourceGroupResponse) GoString() string
func (*ChangeResourceGroupResponse) SetBody ¶ added in v1.0.4
func (s *ChangeResourceGroupResponse) SetBody(v *ChangeResourceGroupResponseBody) *ChangeResourceGroupResponse
func (*ChangeResourceGroupResponse) SetHeaders ¶ added in v1.0.4
func (s *ChangeResourceGroupResponse) SetHeaders(v map[string]*string) *ChangeResourceGroupResponse
func (*ChangeResourceGroupResponse) SetStatusCode ¶ added in v1.0.4
func (s *ChangeResourceGroupResponse) SetStatusCode(v int32) *ChangeResourceGroupResponse
func (ChangeResourceGroupResponse) String ¶ added in v1.0.4
func (s ChangeResourceGroupResponse) String() string
type ChangeResourceGroupResponseBody ¶ added in v1.0.4
type ChangeResourceGroupResponseBody struct {
// The error code returned if the call failed.
//
// example:
//
// Instance.NotFound
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The returned result.
//
// example:
//
// true
Data *bool `json:"data,omitempty" xml:"data,omitempty"`
// The dynamic error code.
//
// example:
//
// InstanceId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// instanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code returned.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// The instance cannot be found.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. Each request has a unique ID. You can use this ID to troubleshoot issues.
//
// example:
//
// AF9A8B10-C426-530F-A0DD-96320B39****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call was successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (ChangeResourceGroupResponseBody) GoString ¶ added in v1.0.4
func (s ChangeResourceGroupResponseBody) GoString() string
func (*ChangeResourceGroupResponseBody) SetCode ¶ added in v1.0.4
func (s *ChangeResourceGroupResponseBody) SetCode(v string) *ChangeResourceGroupResponseBody
func (*ChangeResourceGroupResponseBody) SetData ¶ added in v1.0.4
func (s *ChangeResourceGroupResponseBody) SetData(v bool) *ChangeResourceGroupResponseBody
func (*ChangeResourceGroupResponseBody) SetDynamicCode ¶ added in v1.0.4
func (s *ChangeResourceGroupResponseBody) SetDynamicCode(v string) *ChangeResourceGroupResponseBody
func (*ChangeResourceGroupResponseBody) SetDynamicMessage ¶ added in v1.0.4
func (s *ChangeResourceGroupResponseBody) SetDynamicMessage(v string) *ChangeResourceGroupResponseBody
func (*ChangeResourceGroupResponseBody) SetHttpStatusCode ¶ added in v1.0.4
func (s *ChangeResourceGroupResponseBody) SetHttpStatusCode(v int32) *ChangeResourceGroupResponseBody
func (*ChangeResourceGroupResponseBody) SetMessage ¶ added in v1.0.4
func (s *ChangeResourceGroupResponseBody) SetMessage(v string) *ChangeResourceGroupResponseBody
func (*ChangeResourceGroupResponseBody) SetRequestId ¶ added in v1.0.4
func (s *ChangeResourceGroupResponseBody) SetRequestId(v string) *ChangeResourceGroupResponseBody
func (*ChangeResourceGroupResponseBody) SetSuccess ¶ added in v1.0.4
func (s *ChangeResourceGroupResponseBody) SetSuccess(v bool) *ChangeResourceGroupResponseBody
func (ChangeResourceGroupResponseBody) String ¶ added in v1.0.4
func (s ChangeResourceGroupResponseBody) String() string
type Client ¶
func (*Client) ChangeResourceGroup ¶ added in v1.0.4
func (client *Client) ChangeResourceGroup(request *ChangeResourceGroupRequest) (_result *ChangeResourceGroupResponse, _err error)
Summary:
Changes the resource group to which a ApsaraMQ for RocketMQ instance belongs.
@param request - ChangeResourceGroupRequest
@return ChangeResourceGroupResponse
func (*Client) ChangeResourceGroupWithOptions ¶ added in v1.0.4
func (client *Client) ChangeResourceGroupWithOptions(request *ChangeResourceGroupRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *ChangeResourceGroupResponse, _err error)
Summary:
Changes the resource group to which a ApsaraMQ for RocketMQ instance belongs.
@param request - ChangeResourceGroupRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return ChangeResourceGroupResponse
func (*Client) CreateConsumerGroup ¶
func (client *Client) CreateConsumerGroup(instanceId *string, consumerGroupId *string, request *CreateConsumerGroupRequest) (_result *CreateConsumerGroupResponse, _err error)
Summary:
Creates a consumer group.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - CreateConsumerGroupRequest
@return CreateConsumerGroupResponse
func (*Client) CreateConsumerGroupWithOptions ¶
func (client *Client) CreateConsumerGroupWithOptions(instanceId *string, consumerGroupId *string, request *CreateConsumerGroupRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *CreateConsumerGroupResponse, _err error)
Summary:
Creates a consumer group.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - CreateConsumerGroupRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return CreateConsumerGroupResponse
func (*Client) CreateInstance ¶ added in v1.0.2
func (client *Client) CreateInstance(request *CreateInstanceRequest) (_result *CreateInstanceResponse, _err error)
Summary:
Creates an ApsaraMQ for RocketMQ 5.x instance.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - CreateInstanceRequest
@return CreateInstanceResponse
func (*Client) CreateInstanceWithOptions ¶ added in v1.0.2
func (client *Client) CreateInstanceWithOptions(request *CreateInstanceRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *CreateInstanceResponse, _err error)
Summary:
Creates an ApsaraMQ for RocketMQ 5.x instance.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - CreateInstanceRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return CreateInstanceResponse
func (*Client) CreateTopic ¶
func (client *Client) CreateTopic(instanceId *string, topicName *string, request *CreateTopicRequest) (_result *CreateTopicResponse, _err error)
Summary:
Creates a topic.
@param request - CreateTopicRequest
@return CreateTopicResponse
func (*Client) CreateTopicWithOptions ¶
func (client *Client) CreateTopicWithOptions(instanceId *string, topicName *string, request *CreateTopicRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *CreateTopicResponse, _err error)
Summary:
Creates a topic.
@param request - CreateTopicRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return CreateTopicResponse
func (*Client) DeleteConsumerGroup ¶
func (client *Client) DeleteConsumerGroup(instanceId *string, consumerGroupId *string) (_result *DeleteConsumerGroupResponse, _err error)
Summary:
Deletes a specified consumer group.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
After you delete a consumer group, the consumer client associated with the consumer group cannot consume messages. Exercise caution when you call this operation.
@return DeleteConsumerGroupResponse
func (*Client) DeleteConsumerGroupWithOptions ¶
func (client *Client) DeleteConsumerGroupWithOptions(instanceId *string, consumerGroupId *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *DeleteConsumerGroupResponse, _err error)
Summary:
Deletes a specified consumer group.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
After you delete a consumer group, the consumer client associated with the consumer group cannot consume messages. Exercise caution when you call this operation.
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return DeleteConsumerGroupResponse
func (*Client) DeleteInstance ¶
func (client *Client) DeleteInstance(instanceId *string) (_result *DeleteInstanceResponse, _err error)
Summary:
Deletes a ApsaraMQ for RocketMQ instance.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
After an instance is deleted, the instance cannot be restored. Exercise caution when you call this operation.
This operation is used to delete a pay-as-you-go instance. A subscription instance is automatically released after it expires. You do not need to manually delete a subscription instance.
@return DeleteInstanceResponse
func (*Client) DeleteInstanceWithOptions ¶
func (client *Client) DeleteInstanceWithOptions(instanceId *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *DeleteInstanceResponse, _err error)
Summary:
Deletes a ApsaraMQ for RocketMQ instance.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
After an instance is deleted, the instance cannot be restored. Exercise caution when you call this operation.
This operation is used to delete a pay-as-you-go instance. A subscription instance is automatically released after it expires. You do not need to manually delete a subscription instance.
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return DeleteInstanceResponse
func (*Client) DeleteTopic ¶
func (client *Client) DeleteTopic(instanceId *string, topicName *string) (_result *DeleteTopicResponse, _err error)
Summary:
Deletes a specified topic.
Description:
If you delete the topic, the publishing and subscription relationships that are established based on the topic are cleared. Exercise caution when you call this operation.
@return DeleteTopicResponse
func (*Client) DeleteTopicWithOptions ¶
func (client *Client) DeleteTopicWithOptions(instanceId *string, topicName *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *DeleteTopicResponse, _err error)
Summary:
Deletes a specified topic.
Description:
If you delete the topic, the publishing and subscription relationships that are established based on the topic are cleared. Exercise caution when you call this operation.
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return DeleteTopicResponse
func (*Client) GetConsumerGroup ¶
func (client *Client) GetConsumerGroup(instanceId *string, consumerGroupId *string) (_result *GetConsumerGroupResponse, _err error)
Summary:
Queries the details of a specified consumer group.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@return GetConsumerGroupResponse
func (*Client) GetConsumerGroupWithOptions ¶
func (client *Client) GetConsumerGroupWithOptions(instanceId *string, consumerGroupId *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *GetConsumerGroupResponse, _err error)
Summary:
Queries the details of a specified consumer group.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return GetConsumerGroupResponse
func (*Client) GetEndpoint ¶
func (*Client) GetInstance ¶
func (client *Client) GetInstance(instanceId *string) (_result *GetInstanceResponse, _err error)
Summary:
Queries the detailed information about an instance.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@return GetInstanceResponse
func (*Client) GetInstanceWithOptions ¶
func (client *Client) GetInstanceWithOptions(instanceId *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *GetInstanceResponse, _err error)
Summary:
Queries the detailed information about an instance.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return GetInstanceResponse
func (*Client) GetTopic ¶
func (client *Client) GetTopic(instanceId *string, topicName *string) (_result *GetTopicResponse, _err error)
Summary:
Queries the details of a specified topic.
@return GetTopicResponse
func (*Client) GetTopicWithOptions ¶
func (client *Client) GetTopicWithOptions(instanceId *string, topicName *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *GetTopicResponse, _err error)
Summary:
Queries the details of a specified topic.
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return GetTopicResponse
func (*Client) ListAvailableZones ¶ added in v1.2.0
func (client *Client) ListAvailableZones() (_result *ListAvailableZonesResponse, _err error)
Summary:
查询支持的可用区
@return ListAvailableZonesResponse
func (*Client) ListAvailableZonesWithOptions ¶ added in v1.2.0
func (client *Client) ListAvailableZonesWithOptions(headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListAvailableZonesResponse, _err error)
Summary:
查询支持的可用区
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return ListAvailableZonesResponse
func (*Client) ListConsumerConnections ¶ added in v1.3.0
func (client *Client) ListConsumerConnections(instanceId *string, consumerGroupId *string) (_result *ListConsumerConnectionsResponse, _err error)
Summary:
查询消费者客户端连接信息
@return ListConsumerConnectionsResponse
func (*Client) ListConsumerConnectionsWithOptions ¶ added in v1.3.0
func (client *Client) ListConsumerConnectionsWithOptions(instanceId *string, consumerGroupId *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListConsumerConnectionsResponse, _err error)
Summary:
查询消费者客户端连接信息
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return ListConsumerConnectionsResponse
func (*Client) ListConsumerGroupSubscriptions ¶ added in v1.1.0
func (client *Client) ListConsumerGroupSubscriptions(instanceId *string, consumerGroupId *string) (_result *ListConsumerGroupSubscriptionsResponse, _err error)
Summary:
Queries the subscriptions of a consumer group.
@return ListConsumerGroupSubscriptionsResponse
func (*Client) ListConsumerGroupSubscriptionsWithOptions ¶ added in v1.1.0
func (client *Client) ListConsumerGroupSubscriptionsWithOptions(instanceId *string, consumerGroupId *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListConsumerGroupSubscriptionsResponse, _err error)
Summary:
Queries the subscriptions of a consumer group.
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return ListConsumerGroupSubscriptionsResponse
func (*Client) ListConsumerGroups ¶
func (client *Client) ListConsumerGroups(instanceId *string, request *ListConsumerGroupsRequest) (_result *ListConsumerGroupsResponse, _err error)
Summary:
Queries the consumer groups in a specified instance.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - ListConsumerGroupsRequest
@return ListConsumerGroupsResponse
func (*Client) ListConsumerGroupsWithOptions ¶
func (client *Client) ListConsumerGroupsWithOptions(instanceId *string, request *ListConsumerGroupsRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListConsumerGroupsResponse, _err error)
Summary:
Queries the consumer groups in a specified instance.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - ListConsumerGroupsRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return ListConsumerGroupsResponse
func (*Client) ListInstances ¶
func (client *Client) ListInstances(request *ListInstancesRequest) (_result *ListInstancesResponse, _err error)
Summary:
Queries instances.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - ListInstancesRequest
@return ListInstancesResponse
func (*Client) ListInstancesWithOptions ¶
func (client *Client) ListInstancesWithOptions(tmpReq *ListInstancesRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListInstancesResponse, _err error)
Summary:
Queries instances.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param tmpReq - ListInstancesRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return ListInstancesResponse
func (*Client) ListRegions ¶ added in v1.2.0
func (client *Client) ListRegions() (_result *ListRegionsResponse, _err error)
Summary:
查询region列表
@return ListRegionsResponse
func (*Client) ListRegionsWithOptions ¶ added in v1.2.0
func (client *Client) ListRegionsWithOptions(headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListRegionsResponse, _err error)
Summary:
查询region列表
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return ListRegionsResponse
func (*Client) ListTopicSubscriptions ¶ added in v1.3.0
func (client *Client) ListTopicSubscriptions(instanceId *string, topicName *string) (_result *ListTopicSubscriptionsResponse, _err error)
Summary:
查询主题订阅关系列表
@return ListTopicSubscriptionsResponse
func (*Client) ListTopicSubscriptionsWithOptions ¶ added in v1.3.0
func (client *Client) ListTopicSubscriptionsWithOptions(instanceId *string, topicName *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListTopicSubscriptionsResponse, _err error)
Summary:
查询主题订阅关系列表
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return ListTopicSubscriptionsResponse
func (*Client) ListTopics ¶
func (client *Client) ListTopics(instanceId *string, request *ListTopicsRequest) (_result *ListTopicsResponse, _err error)
Summary:
Queries the topics in a specified instance.
@param request - ListTopicsRequest
@return ListTopicsResponse
func (*Client) ListTopicsWithOptions ¶
func (client *Client) ListTopicsWithOptions(instanceId *string, tmpReq *ListTopicsRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListTopicsResponse, _err error)
Summary:
Queries the topics in a specified instance.
@param tmpReq - ListTopicsRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return ListTopicsResponse
func (*Client) ResetConsumeOffset ¶ added in v1.1.0
func (client *Client) ResetConsumeOffset(instanceId *string, consumerGroupId *string, topicName *string, request *ResetConsumeOffsetRequest) (_result *ResetConsumeOffsetResponse, _err error)
Summary:
Resets the consumer offset of a consumer group.
@param request - ResetConsumeOffsetRequest
@return ResetConsumeOffsetResponse
func (*Client) ResetConsumeOffsetWithOptions ¶ added in v1.1.0
func (client *Client) ResetConsumeOffsetWithOptions(instanceId *string, consumerGroupId *string, topicName *string, request *ResetConsumeOffsetRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *ResetConsumeOffsetResponse, _err error)
Summary:
Resets the consumer offset of a consumer group.
@param request - ResetConsumeOffsetRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return ResetConsumeOffsetResponse
func (*Client) UpdateConsumerGroup ¶
func (client *Client) UpdateConsumerGroup(instanceId *string, consumerGroupId *string, request *UpdateConsumerGroupRequest) (_result *UpdateConsumerGroupResponse, _err error)
Summary:
Updates the basic information about and the consumption retry policy of a consumer group.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - UpdateConsumerGroupRequest
@return UpdateConsumerGroupResponse
func (*Client) UpdateConsumerGroupWithOptions ¶
func (client *Client) UpdateConsumerGroupWithOptions(instanceId *string, consumerGroupId *string, request *UpdateConsumerGroupRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *UpdateConsumerGroupResponse, _err error)
Summary:
Updates the basic information about and the consumption retry policy of a consumer group.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - UpdateConsumerGroupRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return UpdateConsumerGroupResponse
func (*Client) UpdateInstance ¶
func (client *Client) UpdateInstance(instanceId *string, request *UpdateInstanceRequest) (_result *UpdateInstanceResponse, _err error)
Summary:
Updates the basic information and specifications of an ApsaraMQ for RocketMQ instance.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - UpdateInstanceRequest
@return UpdateInstanceResponse
func (*Client) UpdateInstanceWithOptions ¶
func (client *Client) UpdateInstanceWithOptions(instanceId *string, request *UpdateInstanceRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *UpdateInstanceResponse, _err error)
Summary:
Updates the basic information and specifications of an ApsaraMQ for RocketMQ instance.
Description:
> API operations provided by Alibaba Cloud are used to manage and query resources of Alibaba Cloud services. We recommend that you integrate these API operations only in management systems. Do not use these API operations in the core system of messaging services. Otherwise, system risks may occur.
@param request - UpdateInstanceRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return UpdateInstanceResponse
func (*Client) UpdateTopic ¶
func (client *Client) UpdateTopic(instanceId *string, topicName *string, request *UpdateTopicRequest) (_result *UpdateTopicResponse, _err error)
Summary:
Updates the basic information about a topic.
@param request - UpdateTopicRequest
@return UpdateTopicResponse
func (*Client) UpdateTopicWithOptions ¶
func (client *Client) UpdateTopicWithOptions(instanceId *string, topicName *string, request *UpdateTopicRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *UpdateTopicResponse, _err error)
Summary:
Updates the basic information about a topic.
@param request - UpdateTopicRequest
@param headers - map
@param runtime - runtime options for this request RuntimeOptions
@return UpdateTopicResponse
type CreateConsumerGroupRequest ¶
type CreateConsumerGroupRequest struct {
// The consumption retry policy that you want to configure for the consumer group. For more information, see [Consumption retry](https://help.aliyun.com/document_detail/440356.html).
//
// This parameter is required.
ConsumeRetryPolicy *CreateConsumerGroupRequestConsumeRetryPolicy `json:"consumeRetryPolicy,omitempty" xml:"consumeRetryPolicy,omitempty" type:"Struct"`
// The message delivery order of the consumer group.
//
// Valid values:
//
// - Concurrently: concurrent delivery
//
// - Orderly: ordered delivery
//
// This parameter is required.
//
// example:
//
// Concurrently
DeliveryOrderType *string `json:"deliveryOrderType,omitempty" xml:"deliveryOrderType,omitempty"`
// The remarks on the consumer group.
//
// example:
//
// This is the remark for test.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
}
func (CreateConsumerGroupRequest) GoString ¶
func (s CreateConsumerGroupRequest) GoString() string
func (*CreateConsumerGroupRequest) SetConsumeRetryPolicy ¶
func (s *CreateConsumerGroupRequest) SetConsumeRetryPolicy(v *CreateConsumerGroupRequestConsumeRetryPolicy) *CreateConsumerGroupRequest
func (*CreateConsumerGroupRequest) SetDeliveryOrderType ¶
func (s *CreateConsumerGroupRequest) SetDeliveryOrderType(v string) *CreateConsumerGroupRequest
func (*CreateConsumerGroupRequest) SetRemark ¶
func (s *CreateConsumerGroupRequest) SetRemark(v string) *CreateConsumerGroupRequest
func (CreateConsumerGroupRequest) String ¶
func (s CreateConsumerGroupRequest) String() string
type CreateConsumerGroupRequestConsumeRetryPolicy ¶
type CreateConsumerGroupRequestConsumeRetryPolicy struct {
// The dead-letter topic.
//
// If a consumer still fails to consume a message after the message is retried for a specified number of times, the message is delivered to a dead-letter topic for subsequent business recovery or troubleshooting. For more information, see [Consumption retry and dead-letter messages](https://help.aliyun.com/document_detail/440356.html).
//
// example:
//
// DLQ_mqtest
DeadLetterTargetTopic *string `json:"deadLetterTargetTopic,omitempty" xml:"deadLetterTargetTopic,omitempty"`
// The maximum number of retries.
//
// example:
//
// 16
MaxRetryTimes *int32 `json:"maxRetryTimes,omitempty" xml:"maxRetryTimes,omitempty"`
// The retry policy. For more information, see [Message retry](https://help.aliyun.com/document_detail/440356.html).
//
// Valid values:
//
// - FixedRetryPolicy: Failed messages are retried at a fixed interval.
//
// - DefaultRetryPolicy: Failed messages are retried at incremental intervals as the number of retries increases.
//
// This parameter is required.
//
// example:
//
// DefaultRetryPolicy
RetryPolicy *string `json:"retryPolicy,omitempty" xml:"retryPolicy,omitempty"`
}
func (CreateConsumerGroupRequestConsumeRetryPolicy) GoString ¶
func (s CreateConsumerGroupRequestConsumeRetryPolicy) GoString() string
func (*CreateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic ¶ added in v1.0.3
func (s *CreateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic(v string) *CreateConsumerGroupRequestConsumeRetryPolicy
func (*CreateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes ¶
func (s *CreateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes(v int32) *CreateConsumerGroupRequestConsumeRetryPolicy
func (*CreateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy ¶
func (s *CreateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy(v string) *CreateConsumerGroupRequestConsumeRetryPolicy
func (CreateConsumerGroupRequestConsumeRetryPolicy) String ¶
func (s CreateConsumerGroupRequestConsumeRetryPolicy) String() string
type CreateConsumerGroupResponse ¶
type CreateConsumerGroupResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *CreateConsumerGroupResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (CreateConsumerGroupResponse) GoString ¶
func (s CreateConsumerGroupResponse) GoString() string
func (*CreateConsumerGroupResponse) SetBody ¶
func (s *CreateConsumerGroupResponse) SetBody(v *CreateConsumerGroupResponseBody) *CreateConsumerGroupResponse
func (*CreateConsumerGroupResponse) SetHeaders ¶
func (s *CreateConsumerGroupResponse) SetHeaders(v map[string]*string) *CreateConsumerGroupResponse
func (*CreateConsumerGroupResponse) SetStatusCode ¶
func (s *CreateConsumerGroupResponse) SetStatusCode(v int32) *CreateConsumerGroupResponse
func (CreateConsumerGroupResponse) String ¶
func (s CreateConsumerGroupResponse) String() string
type CreateConsumerGroupResponseBody ¶
type CreateConsumerGroupResponseBody struct {
// The error code.
//
// example:
//
// InvalidConsumerGroupId
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The result data that is returned.
//
// example:
//
// true
Data *bool `json:"data,omitempty" xml:"data,omitempty"`
// The dynamic error code.
//
// example:
//
// ConsumerGroupId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// consumerGroupId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// Parameter consumerGroupId is invalid.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. The system generates a unique ID for each request. You can troubleshoot issues based on the request ID.
//
// example:
//
// AF9A8B10-C426-530F-A0DD-96320B39****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (CreateConsumerGroupResponseBody) GoString ¶
func (s CreateConsumerGroupResponseBody) GoString() string
func (*CreateConsumerGroupResponseBody) SetCode ¶
func (s *CreateConsumerGroupResponseBody) SetCode(v string) *CreateConsumerGroupResponseBody
func (*CreateConsumerGroupResponseBody) SetData ¶
func (s *CreateConsumerGroupResponseBody) SetData(v bool) *CreateConsumerGroupResponseBody
func (*CreateConsumerGroupResponseBody) SetDynamicCode ¶
func (s *CreateConsumerGroupResponseBody) SetDynamicCode(v string) *CreateConsumerGroupResponseBody
func (*CreateConsumerGroupResponseBody) SetDynamicMessage ¶
func (s *CreateConsumerGroupResponseBody) SetDynamicMessage(v string) *CreateConsumerGroupResponseBody
func (*CreateConsumerGroupResponseBody) SetHttpStatusCode ¶
func (s *CreateConsumerGroupResponseBody) SetHttpStatusCode(v int32) *CreateConsumerGroupResponseBody
func (*CreateConsumerGroupResponseBody) SetMessage ¶
func (s *CreateConsumerGroupResponseBody) SetMessage(v string) *CreateConsumerGroupResponseBody
func (*CreateConsumerGroupResponseBody) SetRequestId ¶
func (s *CreateConsumerGroupResponseBody) SetRequestId(v string) *CreateConsumerGroupResponseBody
func (*CreateConsumerGroupResponseBody) SetSuccess ¶
func (s *CreateConsumerGroupResponseBody) SetSuccess(v bool) *CreateConsumerGroupResponseBody
func (CreateConsumerGroupResponseBody) String ¶
func (s CreateConsumerGroupResponseBody) String() string
type CreateInstanceRequest ¶ added in v1.0.2
type CreateInstanceRequest struct {
// Specifies whether to enable auto-renewal for the instance. This parameter takes effect only if you set PaymentType to Subscription.
//
// - true: enable
//
// - false: disable
//
// example:
//
// true
AutoRenew *bool `json:"autoRenew,omitempty" xml:"autoRenew,omitempty"`
// The auto-renewal cycle of the instance. This parameter takes effect only if you set autoRenew to true. Unit: months.
//
// Valid values:
//
// - Monthly renewal: 1, 2, 3, 6, and 12
//
// example:
//
// 3
AutoRenewPeriod *int32 `json:"autoRenewPeriod,omitempty" xml:"autoRenewPeriod,omitempty"`
// The commodity code.
//
// - ons_rmqpost_public_intl: pay-as-you-go
//
// - ons_rmqsub_public_intl: subscription
//
// example:
//
// ons_ rmqpost_public_cn
CommodityCode *string `json:"commodityCode,omitempty" xml:"commodityCode,omitempty"`
// The name of the instance that you want to create.
//
// If you do not configure this parameter, the instance ID is used as the instance name.
//
// example:
//
// rmq-cn-72u3048uxxx
InstanceName *string `json:"instanceName,omitempty" xml:"instanceName,omitempty"`
// The network configurations.
//
// This parameter is required.
NetworkInfo *CreateInstanceRequestNetworkInfo `json:"networkInfo,omitempty" xml:"networkInfo,omitempty" type:"Struct"`
// The billing method of the instance. ApsaraMQ for RocketMQ supports the subscription and pay-as-you-go billing methods.
//
// Valid values:
//
// - PayAsYouGo: This billing method allows you to use resources before you pay for the resources.
//
// - Subscription: This billing method allows you to use resources after you pay for the resources.
//
// For more information, see [Billing methods](https://help.aliyun.com/document_detail/427234.html).
//
// This parameter is required.
//
// example:
//
// Subscription
PaymentType *string `json:"paymentType,omitempty" xml:"paymentType,omitempty"`
// The subscription duration of the instance. This parameter takes effect only if you set PaymentType to Subscription.
//
// Valid values:
//
// - Monthly subscription: 1, 2, 3, 4, 5, and 6
//
// - Yearly subscription: 1, 2, and 3
//
// example:
//
// 3
Period *int32 `json:"period,omitempty" xml:"period,omitempty"`
// The unit of the subscription duration.
//
// Valid values:
//
// - Month
//
// - Year
//
// example:
//
// Month
PeriodUnit *string `json:"periodUnit,omitempty" xml:"periodUnit,omitempty"`
// The information about the instance specifications.
ProductInfo *CreateInstanceRequestProductInfo `json:"productInfo,omitempty" xml:"productInfo,omitempty" type:"Struct"`
// The instance description.
//
// example:
//
// This is the remark for test.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
// The resource group ID.
//
// example:
//
// rg-aekzy6pist7uuna
ResourceGroupId *string `json:"resourceGroupId,omitempty" xml:"resourceGroupId,omitempty"`
// The primary edition of the instance. For information about the differences between primary edition instances, see [Instance selection](https://help.aliyun.com/document_detail/444722.html).
//
// Valid values:
//
// - standard: Standard Edition
//
// - ultimate: Enterprise Platinum Edition
//
// - professional: Professional Edition
//
// > After an instance is created, you can only upgrade the primary edition of the instance. The following editions are sorted in ascending order: Standard Edition, Professional Edition, Enterprise Platinum Edition. For example, you can upgrade an instance of Standard Edition to Professional Edition, but cannot downgrade an instance of Professional Edition to Standard Edition.
//
// This parameter is required.
//
// example:
//
// standard
SeriesCode *string `json:"seriesCode,omitempty" xml:"seriesCode,omitempty"`
// The code of the service to which the instance belongs. The service code of ApsaraMQ for RocketMQ is rmq.
//
// This parameter is required.
//
// example:
//
// rmq
ServiceCode *string `json:"serviceCode,omitempty" xml:"serviceCode,omitempty"`
// The sub-category edition of the instance. For information about the differences between sub-category edition instances, see [Instance selection](https://help.aliyun.com/document_detail/444722.html).
//
// Valid values:
//
// - cluster_ha: High-availability Cluster Edition
//
// - single_node: Standalone Edition
//
// - serverless: Serverless Edition
//
// If you set seriesCode to ultimate, you can set this parameter to only cluster_ha.
//
// > After an instance is created, you cannot change the sub-category edition of the instance.
//
// This parameter is required.
//
// example:
//
// cluster_ha
SubSeriesCode *string `json:"subSeriesCode,omitempty" xml:"subSeriesCode,omitempty"`
// The client token that is used to ensure the idempotence of the request. You can use the client to generate the value of this parameter, but you must ensure that the value is unique among different requests. The token can contain only ASCII characters and cannot exceed 64 characters in length.
//
// example:
//
// c2c5d1274a8d4317a13bc5b0d4******
ClientToken *string `json:"clientToken,omitempty" xml:"clientToken,omitempty"`
}
func (CreateInstanceRequest) GoString ¶ added in v1.0.2
func (s CreateInstanceRequest) GoString() string
func (*CreateInstanceRequest) SetAutoRenew ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetAutoRenew(v bool) *CreateInstanceRequest
func (*CreateInstanceRequest) SetAutoRenewPeriod ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetAutoRenewPeriod(v int32) *CreateInstanceRequest
func (*CreateInstanceRequest) SetClientToken ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetClientToken(v string) *CreateInstanceRequest
func (*CreateInstanceRequest) SetCommodityCode ¶ added in v1.1.2
func (s *CreateInstanceRequest) SetCommodityCode(v string) *CreateInstanceRequest
func (*CreateInstanceRequest) SetInstanceName ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetInstanceName(v string) *CreateInstanceRequest
func (*CreateInstanceRequest) SetNetworkInfo ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetNetworkInfo(v *CreateInstanceRequestNetworkInfo) *CreateInstanceRequest
func (*CreateInstanceRequest) SetPaymentType ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetPaymentType(v string) *CreateInstanceRequest
func (*CreateInstanceRequest) SetPeriod ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetPeriod(v int32) *CreateInstanceRequest
func (*CreateInstanceRequest) SetPeriodUnit ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetPeriodUnit(v string) *CreateInstanceRequest
func (*CreateInstanceRequest) SetProductInfo ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetProductInfo(v *CreateInstanceRequestProductInfo) *CreateInstanceRequest
func (*CreateInstanceRequest) SetRemark ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetRemark(v string) *CreateInstanceRequest
func (*CreateInstanceRequest) SetResourceGroupId ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetResourceGroupId(v string) *CreateInstanceRequest
func (*CreateInstanceRequest) SetSeriesCode ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetSeriesCode(v string) *CreateInstanceRequest
func (*CreateInstanceRequest) SetServiceCode ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetServiceCode(v string) *CreateInstanceRequest
func (*CreateInstanceRequest) SetSubSeriesCode ¶ added in v1.0.2
func (s *CreateInstanceRequest) SetSubSeriesCode(v string) *CreateInstanceRequest
func (CreateInstanceRequest) String ¶ added in v1.0.2
func (s CreateInstanceRequest) String() string
type CreateInstanceRequestNetworkInfo ¶ added in v1.0.2
type CreateInstanceRequestNetworkInfo struct {
// The Internet-related configurations.
//
// This parameter is required.
InternetInfo *CreateInstanceRequestNetworkInfoInternetInfo `json:"internetInfo,omitempty" xml:"internetInfo,omitempty" type:"Struct"`
// The virtual private cloud (VPC)-related configurations.
//
// This parameter is required.
VpcInfo *CreateInstanceRequestNetworkInfoVpcInfo `json:"vpcInfo,omitempty" xml:"vpcInfo,omitempty" type:"Struct"`
}
func (CreateInstanceRequestNetworkInfo) GoString ¶ added in v1.0.2
func (s CreateInstanceRequestNetworkInfo) GoString() string
func (*CreateInstanceRequestNetworkInfo) SetInternetInfo ¶ added in v1.0.2
func (s *CreateInstanceRequestNetworkInfo) SetInternetInfo(v *CreateInstanceRequestNetworkInfoInternetInfo) *CreateInstanceRequestNetworkInfo
func (*CreateInstanceRequestNetworkInfo) SetVpcInfo ¶ added in v1.0.2
func (s *CreateInstanceRequestNetworkInfo) SetVpcInfo(v *CreateInstanceRequestNetworkInfoVpcInfo) *CreateInstanceRequestNetworkInfo
func (CreateInstanceRequestNetworkInfo) String ¶ added in v1.0.2
func (s CreateInstanceRequestNetworkInfo) String() string
type CreateInstanceRequestNetworkInfoInternetInfo ¶ added in v1.0.2
type CreateInstanceRequestNetworkInfoInternetInfo struct {
// The Internet bandwidth. Unit: MB/s.
//
// This parameter is required only if you set flowOutType to payByBandwidth.
//
// Valid values: 1 to 1000.
//
// example:
//
// 100
FlowOutBandwidth *int32 `json:"flowOutBandwidth,omitempty" xml:"flowOutBandwidth,omitempty"`
// The billing method of Internet usage.
//
// Valid values:
//
// - payByBandwidth: pay-by-bandwidth. If Internet access is enabled for an instance, specify this value for the parameter.
//
// - payByTraffic: pay-by-traffic. If Internet access is enabled for an instance, specify this value for the parameter.
//
// - uninvolved: No billing method is involved. If Internet access is disabled for an instance, specify this value for the parameter.
//
// This parameter is required.
//
// example:
//
// uninvolved
FlowOutType *string `json:"flowOutType,omitempty" xml:"flowOutType,omitempty"`
// Specifies whether to enable the Internet access feature.
//
// Valid values:
//
// - enable
//
// - disable
//
// By default, ApsaraMQ for RocketMQ allows you to access instances in VPCs. If you enable Internet access for an instance, you can access the instance over the Internet. After you enable this feature, you are charged for outbound Internet traffic. For more information, see [Internet access fee](https://help.aliyun.com/document_detail/427240.html).
//
// This parameter is required.
//
// example:
//
// disable
InternetSpec *string `json:"internetSpec,omitempty" xml:"internetSpec,omitempty"`
// The whitelist that includes the IP addresses that are allowed to access the ApsaraMQ for RocketMQ broker over the Internet. This parameter can be configured only if you use a public endpoint to access the instance.
//
// - If you do not configure an IP address whitelist, all CIDR blocks are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
//
// - If configure an IP address whitlist, only the IP addresses in the whitelist are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
IpWhitelist []*string `json:"ipWhitelist,omitempty" xml:"ipWhitelist,omitempty" type:"Repeated"`
}
func (CreateInstanceRequestNetworkInfoInternetInfo) GoString ¶ added in v1.0.2
func (s CreateInstanceRequestNetworkInfoInternetInfo) GoString() string
func (*CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutBandwidth ¶ added in v1.0.2
func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutBandwidth(v int32) *CreateInstanceRequestNetworkInfoInternetInfo
func (*CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutType ¶ added in v1.0.2
func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutType(v string) *CreateInstanceRequestNetworkInfoInternetInfo
func (*CreateInstanceRequestNetworkInfoInternetInfo) SetInternetSpec ¶ added in v1.0.2
func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetInternetSpec(v string) *CreateInstanceRequestNetworkInfoInternetInfo
func (*CreateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist ¶ added in v1.0.2
func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist(v []*string) *CreateInstanceRequestNetworkInfoInternetInfo
func (CreateInstanceRequestNetworkInfoInternetInfo) String ¶ added in v1.0.2
func (s CreateInstanceRequestNetworkInfoInternetInfo) String() string
type CreateInstanceRequestNetworkInfoVpcInfo ¶ added in v1.0.2
type CreateInstanceRequestNetworkInfoVpcInfo struct {
// The ID of the security group to which the instance belongs.
//
// example:
//
// sg-bp17hpmgz96tvnsdy6so
SecurityGroupIds *string `json:"securityGroupIds,omitempty" xml:"securityGroupIds,omitempty"`
// Deprecated
//
// The ID of the vSwitch with which you want to associate the instance, If there are multiple vSwitchs, please concatenate them using the "|" character.
//
// > After an ApsaraMQ for RocketMQ instance is created, you cannot change the vSwitch with which the instance is associated. If you want to change the vSwitch with which the instance is associated, you must release the instance and purchase a new instance.
//
// example:
//
// vsw-uf6gwtbn6etadpv*******
VSwitchId *string `json:"vSwitchId,omitempty" xml:"vSwitchId,omitempty"`
VSwitches []*CreateInstanceRequestNetworkInfoVpcInfoVSwitches `json:"vSwitches,omitempty" xml:"vSwitches,omitempty" type:"Repeated"`
// The ID of the VPC in which you want to deploy the instance.
//
// > After an ApsaraMQ for RocketMQ instance is created, you cannot change the VPC in which the instance is deployed. If you want to change the VPC in which the instance is deployed, you must release the instance and create a new instance.
//
// This parameter is required.
//
// example:
//
// vpc-wz9qt50xhtj9krb******
VpcId *string `json:"vpcId,omitempty" xml:"vpcId,omitempty"`
}
func (CreateInstanceRequestNetworkInfoVpcInfo) GoString ¶ added in v1.0.2
func (s CreateInstanceRequestNetworkInfoVpcInfo) GoString() string
func (*CreateInstanceRequestNetworkInfoVpcInfo) SetSecurityGroupIds ¶ added in v1.1.2
func (s *CreateInstanceRequestNetworkInfoVpcInfo) SetSecurityGroupIds(v string) *CreateInstanceRequestNetworkInfoVpcInfo
func (*CreateInstanceRequestNetworkInfoVpcInfo) SetVSwitchId ¶ added in v1.0.2
func (s *CreateInstanceRequestNetworkInfoVpcInfo) SetVSwitchId(v string) *CreateInstanceRequestNetworkInfoVpcInfo
func (*CreateInstanceRequestNetworkInfoVpcInfo) SetVSwitches ¶ added in v1.4.4
func (s *CreateInstanceRequestNetworkInfoVpcInfo) SetVSwitches(v []*CreateInstanceRequestNetworkInfoVpcInfoVSwitches) *CreateInstanceRequestNetworkInfoVpcInfo
func (*CreateInstanceRequestNetworkInfoVpcInfo) SetVpcId ¶ added in v1.0.2
func (s *CreateInstanceRequestNetworkInfoVpcInfo) SetVpcId(v string) *CreateInstanceRequestNetworkInfoVpcInfo
func (CreateInstanceRequestNetworkInfoVpcInfo) String ¶ added in v1.0.2
func (s CreateInstanceRequestNetworkInfoVpcInfo) String() string
type CreateInstanceRequestNetworkInfoVpcInfoVSwitches ¶ added in v1.4.4
type CreateInstanceRequestNetworkInfoVpcInfoVSwitches struct {
VSwitchId *string `json:"vSwitchId,omitempty" xml:"vSwitchId,omitempty"`
}
func (CreateInstanceRequestNetworkInfoVpcInfoVSwitches) GoString ¶ added in v1.4.4
func (s CreateInstanceRequestNetworkInfoVpcInfoVSwitches) GoString() string
func (*CreateInstanceRequestNetworkInfoVpcInfoVSwitches) SetVSwitchId ¶ added in v1.4.4
func (s *CreateInstanceRequestNetworkInfoVpcInfoVSwitches) SetVSwitchId(v string) *CreateInstanceRequestNetworkInfoVpcInfoVSwitches
func (CreateInstanceRequestNetworkInfoVpcInfoVSwitches) String ¶ added in v1.4.4
func (s CreateInstanceRequestNetworkInfoVpcInfoVSwitches) String() string
type CreateInstanceRequestProductInfo ¶ added in v1.0.2
type CreateInstanceRequestProductInfo struct {
// Specifies whether to enable the elastic TPS feature for the instance.
//
// Valid values:
//
// - true: enable
//
// - false: disable
//
// After you enable the elastic TPS feature for an ApsaraMQ for RocketMQ instance, you can use a specific number of TPS that exceeds the specification limit. You are charged for using the elastic TPS feature. For more information, see [Computing fees](https://help.aliyun.com/document_detail/427237.html).
//
// > The elastic TPS feature is supported only by instances of specific editions. For more information, see [Instance editions](https://help.aliyun.com/document_detail/444715.html).
//
// example:
//
// true
AutoScaling *bool `json:"autoScaling,omitempty" xml:"autoScaling,omitempty"`
// The billing method.
//
// Valid values:
//
// - provisioned
//
// - ondemand
//
// example:
//
// provisioned
ChargeType *string `json:"chargeType,omitempty" xml:"chargeType,omitempty"`
// This parameter is no longer used. You do not need to configure this parameter.
//
// example:
//
// xxxx
IntranetSpec *string `json:"intranetSpec,omitempty" xml:"intranetSpec,omitempty"`
// The retention period of messages. Unit: hours.
//
// For information about the valid values of this parameter, see the "Limits on resource quotas" section of the [Limits](https://help.aliyun.com/document_detail/440347.html) topic.
//
// ApsaraMQ for RocketMQ supports serverless scaling of message storage. You are charged storage fees based on your actual storage usage. You can change the retention period of messages to manage storage capacity. For more information, see [Storage fees](https://help.aliyun.com/document_detail/427238.html).
//
// example:
//
// 72
MessageRetentionTime *int32 `json:"messageRetentionTime,omitempty" xml:"messageRetentionTime,omitempty"`
// The computing specification that specifies the messaging transactions per second (TPS) of the instance. For information about computing specification limits, see [Instance specifications](https://help.aliyun.com/document_detail/444715.html).
//
// This parameter is required.
//
// example:
//
// rmq.s2.2xlarge
MsgProcessSpec *string `json:"msgProcessSpec,omitempty" xml:"msgProcessSpec,omitempty"`
// The proportion of message sending TPS to the messaging TPS on the instance.
//
// For example, you create an instance whose peak messaging TPS is specified as 1,000 and the proportion of message sending TPS is specified as 0.8. In this case, the peak message sending TPS is 800 and the peak message receiving TPS is 200 on the instance.
//
// Valid values: 0 to 1. Default value: 0.5.
//
// example:
//
// 0.5
SendReceiveRatio *float32 `json:"sendReceiveRatio,omitempty" xml:"sendReceiveRatio,omitempty"`
}
func (CreateInstanceRequestProductInfo) GoString ¶ added in v1.0.2
func (s CreateInstanceRequestProductInfo) GoString() string
func (*CreateInstanceRequestProductInfo) SetAutoScaling ¶ added in v1.0.2
func (s *CreateInstanceRequestProductInfo) SetAutoScaling(v bool) *CreateInstanceRequestProductInfo
func (*CreateInstanceRequestProductInfo) SetChargeType ¶ added in v1.1.2
func (s *CreateInstanceRequestProductInfo) SetChargeType(v string) *CreateInstanceRequestProductInfo
func (*CreateInstanceRequestProductInfo) SetIntranetSpec ¶ added in v1.1.2
func (s *CreateInstanceRequestProductInfo) SetIntranetSpec(v string) *CreateInstanceRequestProductInfo
func (*CreateInstanceRequestProductInfo) SetMessageRetentionTime ¶ added in v1.0.2
func (s *CreateInstanceRequestProductInfo) SetMessageRetentionTime(v int32) *CreateInstanceRequestProductInfo
func (*CreateInstanceRequestProductInfo) SetMsgProcessSpec ¶ added in v1.0.2
func (s *CreateInstanceRequestProductInfo) SetMsgProcessSpec(v string) *CreateInstanceRequestProductInfo
func (*CreateInstanceRequestProductInfo) SetSendReceiveRatio ¶ added in v1.0.2
func (s *CreateInstanceRequestProductInfo) SetSendReceiveRatio(v float32) *CreateInstanceRequestProductInfo
func (CreateInstanceRequestProductInfo) String ¶ added in v1.0.2
func (s CreateInstanceRequestProductInfo) String() string
type CreateInstanceResponse ¶ added in v1.0.2
type CreateInstanceResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *CreateInstanceResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (CreateInstanceResponse) GoString ¶ added in v1.0.2
func (s CreateInstanceResponse) GoString() string
func (*CreateInstanceResponse) SetBody ¶ added in v1.0.2
func (s *CreateInstanceResponse) SetBody(v *CreateInstanceResponseBody) *CreateInstanceResponse
func (*CreateInstanceResponse) SetHeaders ¶ added in v1.0.2
func (s *CreateInstanceResponse) SetHeaders(v map[string]*string) *CreateInstanceResponse
func (*CreateInstanceResponse) SetStatusCode ¶ added in v1.0.2
func (s *CreateInstanceResponse) SetStatusCode(v int32) *CreateInstanceResponse
func (CreateInstanceResponse) String ¶ added in v1.0.2
func (s CreateInstanceResponse) String() string
type CreateInstanceResponseBody ¶ added in v1.0.2
type CreateInstanceResponseBody struct {
// The error code returned if the call failed.
//
// example:
//
// 200
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The ID of the created instance.
//
// example:
//
// rmq-cn-7e22ody****
Data *string `json:"data,omitempty" xml:"data,omitempty"`
// The dynamic error code.
//
// example:
//
// InstanceId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// instanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code returned.
//
// example:
//
// 200
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// Success
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. Each request has a unique ID. You can use this ID to troubleshoot issues.
//
// example:
//
// AF9A8B10-C426-530F-A0DD-96320B39****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call was successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (CreateInstanceResponseBody) GoString ¶ added in v1.0.2
func (s CreateInstanceResponseBody) GoString() string
func (*CreateInstanceResponseBody) SetCode ¶ added in v1.0.2
func (s *CreateInstanceResponseBody) SetCode(v string) *CreateInstanceResponseBody
func (*CreateInstanceResponseBody) SetData ¶ added in v1.0.2
func (s *CreateInstanceResponseBody) SetData(v string) *CreateInstanceResponseBody
func (*CreateInstanceResponseBody) SetDynamicCode ¶ added in v1.0.2
func (s *CreateInstanceResponseBody) SetDynamicCode(v string) *CreateInstanceResponseBody
func (*CreateInstanceResponseBody) SetDynamicMessage ¶ added in v1.0.2
func (s *CreateInstanceResponseBody) SetDynamicMessage(v string) *CreateInstanceResponseBody
func (*CreateInstanceResponseBody) SetHttpStatusCode ¶ added in v1.0.2
func (s *CreateInstanceResponseBody) SetHttpStatusCode(v int32) *CreateInstanceResponseBody
func (*CreateInstanceResponseBody) SetMessage ¶ added in v1.0.2
func (s *CreateInstanceResponseBody) SetMessage(v string) *CreateInstanceResponseBody
func (*CreateInstanceResponseBody) SetRequestId ¶ added in v1.0.2
func (s *CreateInstanceResponseBody) SetRequestId(v string) *CreateInstanceResponseBody
func (*CreateInstanceResponseBody) SetSuccess ¶ added in v1.0.2
func (s *CreateInstanceResponseBody) SetSuccess(v bool) *CreateInstanceResponseBody
func (CreateInstanceResponseBody) String ¶ added in v1.0.2
func (s CreateInstanceResponseBody) String() string
type CreateTopicRequest ¶
type CreateTopicRequest struct {
// The type of messages in the topic that you want to create.
//
// Valid values:
//
// - TRANSACTION: transactional messages
//
// - FIFO: ordered messages
//
// - DELAY: scheduled messages or delayed Message
//
// - NORMAL: normal messages
//
// > The type of messages in the topic must be the same as the type of messages that you want to send. For example, if you create a topic whose message type is ordered messages, the topic can be used to send and receive only ordered messages.
//
// example:
//
// NORMAL
MessageType *string `json:"messageType,omitempty" xml:"messageType,omitempty"`
// The description of the topic that you want to create.
//
// example:
//
// This is the remark for test.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
}
func (CreateTopicRequest) GoString ¶
func (s CreateTopicRequest) GoString() string
func (*CreateTopicRequest) SetMessageType ¶
func (s *CreateTopicRequest) SetMessageType(v string) *CreateTopicRequest
func (*CreateTopicRequest) SetRemark ¶
func (s *CreateTopicRequest) SetRemark(v string) *CreateTopicRequest
func (CreateTopicRequest) String ¶
func (s CreateTopicRequest) String() string
type CreateTopicResponse ¶
type CreateTopicResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *CreateTopicResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (CreateTopicResponse) GoString ¶
func (s CreateTopicResponse) GoString() string
func (*CreateTopicResponse) SetBody ¶
func (s *CreateTopicResponse) SetBody(v *CreateTopicResponseBody) *CreateTopicResponse
func (*CreateTopicResponse) SetHeaders ¶
func (s *CreateTopicResponse) SetHeaders(v map[string]*string) *CreateTopicResponse
func (*CreateTopicResponse) SetStatusCode ¶
func (s *CreateTopicResponse) SetStatusCode(v int32) *CreateTopicResponse
func (CreateTopicResponse) String ¶
func (s CreateTopicResponse) String() string
type CreateTopicResponseBody ¶
type CreateTopicResponseBody struct {
// The error code returned if the call failed.
//
// example:
//
// Topic.Existed
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The returned result.
//
// example:
//
// true
Data *bool `json:"data,omitempty" xml:"data,omitempty"`
// The dynamic error code.
//
// example:
//
// TopicName
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// topicName
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code returned.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// The topic already exists.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. Each request has a unique ID. You can use this ID to troubleshoot issues.
//
// example:
//
// AF9A8B10-C426-530F-A0DD-96320B39****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call was successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (CreateTopicResponseBody) GoString ¶
func (s CreateTopicResponseBody) GoString() string
func (*CreateTopicResponseBody) SetCode ¶
func (s *CreateTopicResponseBody) SetCode(v string) *CreateTopicResponseBody
func (*CreateTopicResponseBody) SetData ¶
func (s *CreateTopicResponseBody) SetData(v bool) *CreateTopicResponseBody
func (*CreateTopicResponseBody) SetDynamicCode ¶
func (s *CreateTopicResponseBody) SetDynamicCode(v string) *CreateTopicResponseBody
func (*CreateTopicResponseBody) SetDynamicMessage ¶
func (s *CreateTopicResponseBody) SetDynamicMessage(v string) *CreateTopicResponseBody
func (*CreateTopicResponseBody) SetHttpStatusCode ¶
func (s *CreateTopicResponseBody) SetHttpStatusCode(v int32) *CreateTopicResponseBody
func (*CreateTopicResponseBody) SetMessage ¶
func (s *CreateTopicResponseBody) SetMessage(v string) *CreateTopicResponseBody
func (*CreateTopicResponseBody) SetRequestId ¶
func (s *CreateTopicResponseBody) SetRequestId(v string) *CreateTopicResponseBody
func (*CreateTopicResponseBody) SetSuccess ¶
func (s *CreateTopicResponseBody) SetSuccess(v bool) *CreateTopicResponseBody
func (CreateTopicResponseBody) String ¶
func (s CreateTopicResponseBody) String() string
type DeleteConsumerGroupResponse ¶
type DeleteConsumerGroupResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *DeleteConsumerGroupResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (DeleteConsumerGroupResponse) GoString ¶
func (s DeleteConsumerGroupResponse) GoString() string
func (*DeleteConsumerGroupResponse) SetBody ¶
func (s *DeleteConsumerGroupResponse) SetBody(v *DeleteConsumerGroupResponseBody) *DeleteConsumerGroupResponse
func (*DeleteConsumerGroupResponse) SetHeaders ¶
func (s *DeleteConsumerGroupResponse) SetHeaders(v map[string]*string) *DeleteConsumerGroupResponse
func (*DeleteConsumerGroupResponse) SetStatusCode ¶
func (s *DeleteConsumerGroupResponse) SetStatusCode(v int32) *DeleteConsumerGroupResponse
func (DeleteConsumerGroupResponse) String ¶
func (s DeleteConsumerGroupResponse) String() string
type DeleteConsumerGroupResponseBody ¶
type DeleteConsumerGroupResponseBody struct {
// The error code.
//
// example:
//
// InvalidConsumerGroupId
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The result data that is returned.
//
// example:
//
// true
Data *bool `json:"data,omitempty" xml:"data,omitempty"`
// The dynamic error code.
//
// example:
//
// ConsumerGroupId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// consumerGroupId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// Parameter consumerGroupId is invalid.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. The system generates a unique ID for each request. You can troubleshoot issues based on the request ID.
//
// example:
//
// C7F94090-3358-506A-97DC-34BC803C****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (DeleteConsumerGroupResponseBody) GoString ¶
func (s DeleteConsumerGroupResponseBody) GoString() string
func (*DeleteConsumerGroupResponseBody) SetCode ¶
func (s *DeleteConsumerGroupResponseBody) SetCode(v string) *DeleteConsumerGroupResponseBody
func (*DeleteConsumerGroupResponseBody) SetData ¶
func (s *DeleteConsumerGroupResponseBody) SetData(v bool) *DeleteConsumerGroupResponseBody
func (*DeleteConsumerGroupResponseBody) SetDynamicCode ¶
func (s *DeleteConsumerGroupResponseBody) SetDynamicCode(v string) *DeleteConsumerGroupResponseBody
func (*DeleteConsumerGroupResponseBody) SetDynamicMessage ¶
func (s *DeleteConsumerGroupResponseBody) SetDynamicMessage(v string) *DeleteConsumerGroupResponseBody
func (*DeleteConsumerGroupResponseBody) SetHttpStatusCode ¶
func (s *DeleteConsumerGroupResponseBody) SetHttpStatusCode(v int32) *DeleteConsumerGroupResponseBody
func (*DeleteConsumerGroupResponseBody) SetMessage ¶
func (s *DeleteConsumerGroupResponseBody) SetMessage(v string) *DeleteConsumerGroupResponseBody
func (*DeleteConsumerGroupResponseBody) SetRequestId ¶
func (s *DeleteConsumerGroupResponseBody) SetRequestId(v string) *DeleteConsumerGroupResponseBody
func (*DeleteConsumerGroupResponseBody) SetSuccess ¶
func (s *DeleteConsumerGroupResponseBody) SetSuccess(v bool) *DeleteConsumerGroupResponseBody
func (DeleteConsumerGroupResponseBody) String ¶
func (s DeleteConsumerGroupResponseBody) String() string
type DeleteInstanceResponse ¶
type DeleteInstanceResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *DeleteInstanceResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (DeleteInstanceResponse) GoString ¶
func (s DeleteInstanceResponse) GoString() string
func (*DeleteInstanceResponse) SetBody ¶
func (s *DeleteInstanceResponse) SetBody(v *DeleteInstanceResponseBody) *DeleteInstanceResponse
func (*DeleteInstanceResponse) SetHeaders ¶
func (s *DeleteInstanceResponse) SetHeaders(v map[string]*string) *DeleteInstanceResponse
func (*DeleteInstanceResponse) SetStatusCode ¶
func (s *DeleteInstanceResponse) SetStatusCode(v int32) *DeleteInstanceResponse
func (DeleteInstanceResponse) String ¶
func (s DeleteInstanceResponse) String() string
type DeleteInstanceResponseBody ¶
type DeleteInstanceResponseBody struct {
// The error code returned if the call failed.
//
// example:
//
// MissingInstanceId
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The returned result.
//
// example:
//
// true
Data *bool `json:"data,omitempty" xml:"data,omitempty"`
// The dynamic error code.
//
// example:
//
// InstanceId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// instanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code returned.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// Parameter instanceId is mandatory for this action .
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. Each request has a unique ID. You can use this ID to troubleshoot issues.
//
// example:
//
// 048242AA-BADA-5F29-B2CD-ED9FA344467F
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call was successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (DeleteInstanceResponseBody) GoString ¶
func (s DeleteInstanceResponseBody) GoString() string
func (*DeleteInstanceResponseBody) SetCode ¶
func (s *DeleteInstanceResponseBody) SetCode(v string) *DeleteInstanceResponseBody
func (*DeleteInstanceResponseBody) SetData ¶
func (s *DeleteInstanceResponseBody) SetData(v bool) *DeleteInstanceResponseBody
func (*DeleteInstanceResponseBody) SetDynamicCode ¶
func (s *DeleteInstanceResponseBody) SetDynamicCode(v string) *DeleteInstanceResponseBody
func (*DeleteInstanceResponseBody) SetDynamicMessage ¶
func (s *DeleteInstanceResponseBody) SetDynamicMessage(v string) *DeleteInstanceResponseBody
func (*DeleteInstanceResponseBody) SetHttpStatusCode ¶
func (s *DeleteInstanceResponseBody) SetHttpStatusCode(v int32) *DeleteInstanceResponseBody
func (*DeleteInstanceResponseBody) SetMessage ¶
func (s *DeleteInstanceResponseBody) SetMessage(v string) *DeleteInstanceResponseBody
func (*DeleteInstanceResponseBody) SetRequestId ¶
func (s *DeleteInstanceResponseBody) SetRequestId(v string) *DeleteInstanceResponseBody
func (*DeleteInstanceResponseBody) SetSuccess ¶
func (s *DeleteInstanceResponseBody) SetSuccess(v bool) *DeleteInstanceResponseBody
func (DeleteInstanceResponseBody) String ¶
func (s DeleteInstanceResponseBody) String() string
type DeleteTopicResponse ¶
type DeleteTopicResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *DeleteTopicResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (DeleteTopicResponse) GoString ¶
func (s DeleteTopicResponse) GoString() string
func (*DeleteTopicResponse) SetBody ¶
func (s *DeleteTopicResponse) SetBody(v *DeleteTopicResponseBody) *DeleteTopicResponse
func (*DeleteTopicResponse) SetHeaders ¶
func (s *DeleteTopicResponse) SetHeaders(v map[string]*string) *DeleteTopicResponse
func (*DeleteTopicResponse) SetStatusCode ¶
func (s *DeleteTopicResponse) SetStatusCode(v int32) *DeleteTopicResponse
func (DeleteTopicResponse) String ¶
func (s DeleteTopicResponse) String() string
type DeleteTopicResponseBody ¶
type DeleteTopicResponseBody struct {
// The error code.
//
// example:
//
// Topic.NotFound
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The result data that is returned.
//
// example:
//
// true
Data *bool `json:"data,omitempty" xml:"data,omitempty"`
// The dynamic error code.
//
// example:
//
// TopicName
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// topicName
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// The topic cannot be found.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. The system generates a unique ID for each request. You can troubleshoot issues based on the request ID.
//
// example:
//
// AF9A8B10-C426-530F-A0DD-96320B39****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (DeleteTopicResponseBody) GoString ¶
func (s DeleteTopicResponseBody) GoString() string
func (*DeleteTopicResponseBody) SetCode ¶
func (s *DeleteTopicResponseBody) SetCode(v string) *DeleteTopicResponseBody
func (*DeleteTopicResponseBody) SetData ¶
func (s *DeleteTopicResponseBody) SetData(v bool) *DeleteTopicResponseBody
func (*DeleteTopicResponseBody) SetDynamicCode ¶
func (s *DeleteTopicResponseBody) SetDynamicCode(v string) *DeleteTopicResponseBody
func (*DeleteTopicResponseBody) SetDynamicMessage ¶
func (s *DeleteTopicResponseBody) SetDynamicMessage(v string) *DeleteTopicResponseBody
func (*DeleteTopicResponseBody) SetHttpStatusCode ¶
func (s *DeleteTopicResponseBody) SetHttpStatusCode(v int32) *DeleteTopicResponseBody
func (*DeleteTopicResponseBody) SetMessage ¶
func (s *DeleteTopicResponseBody) SetMessage(v string) *DeleteTopicResponseBody
func (*DeleteTopicResponseBody) SetRequestId ¶
func (s *DeleteTopicResponseBody) SetRequestId(v string) *DeleteTopicResponseBody
func (*DeleteTopicResponseBody) SetSuccess ¶
func (s *DeleteTopicResponseBody) SetSuccess(v bool) *DeleteTopicResponseBody
func (DeleteTopicResponseBody) String ¶
func (s DeleteTopicResponseBody) String() string
type GetConsumerGroupResponse ¶
type GetConsumerGroupResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *GetConsumerGroupResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (GetConsumerGroupResponse) GoString ¶
func (s GetConsumerGroupResponse) GoString() string
func (*GetConsumerGroupResponse) SetBody ¶
func (s *GetConsumerGroupResponse) SetBody(v *GetConsumerGroupResponseBody) *GetConsumerGroupResponse
func (*GetConsumerGroupResponse) SetHeaders ¶
func (s *GetConsumerGroupResponse) SetHeaders(v map[string]*string) *GetConsumerGroupResponse
func (*GetConsumerGroupResponse) SetStatusCode ¶
func (s *GetConsumerGroupResponse) SetStatusCode(v int32) *GetConsumerGroupResponse
func (GetConsumerGroupResponse) String ¶
func (s GetConsumerGroupResponse) String() string
type GetConsumerGroupResponseBody ¶
type GetConsumerGroupResponseBody struct {
// The error code.
//
// example:
//
// InvalidConsumerGroupId
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The result data that is returned.
Data *GetConsumerGroupResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Struct"`
// The dynamic error code.
//
// example:
//
// ConsumerGroupId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// consumerGroupId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// Parameter consumerGroupId is invalid.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. The system generates a unique ID for each request. You can troubleshoot issues based on the request ID.
//
// example:
//
// C7F94090-3358-506A-97DC-34BC803C****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (GetConsumerGroupResponseBody) GoString ¶
func (s GetConsumerGroupResponseBody) GoString() string
func (*GetConsumerGroupResponseBody) SetCode ¶
func (s *GetConsumerGroupResponseBody) SetCode(v string) *GetConsumerGroupResponseBody
func (*GetConsumerGroupResponseBody) SetData ¶
func (s *GetConsumerGroupResponseBody) SetData(v *GetConsumerGroupResponseBodyData) *GetConsumerGroupResponseBody
func (*GetConsumerGroupResponseBody) SetDynamicCode ¶
func (s *GetConsumerGroupResponseBody) SetDynamicCode(v string) *GetConsumerGroupResponseBody
func (*GetConsumerGroupResponseBody) SetDynamicMessage ¶
func (s *GetConsumerGroupResponseBody) SetDynamicMessage(v string) *GetConsumerGroupResponseBody
func (*GetConsumerGroupResponseBody) SetHttpStatusCode ¶
func (s *GetConsumerGroupResponseBody) SetHttpStatusCode(v int32) *GetConsumerGroupResponseBody
func (*GetConsumerGroupResponseBody) SetMessage ¶
func (s *GetConsumerGroupResponseBody) SetMessage(v string) *GetConsumerGroupResponseBody
func (*GetConsumerGroupResponseBody) SetRequestId ¶
func (s *GetConsumerGroupResponseBody) SetRequestId(v string) *GetConsumerGroupResponseBody
func (*GetConsumerGroupResponseBody) SetSuccess ¶
func (s *GetConsumerGroupResponseBody) SetSuccess(v bool) *GetConsumerGroupResponseBody
func (GetConsumerGroupResponseBody) String ¶
func (s GetConsumerGroupResponseBody) String() string
type GetConsumerGroupResponseBodyData ¶
type GetConsumerGroupResponseBodyData struct {
// The consumption retry policy that you want to configure for the consumer group. For more information, see [Consumption retry](https://help.aliyun.com/document_detail/440356.html).
ConsumeRetryPolicy *GetConsumerGroupResponseBodyDataConsumeRetryPolicy `json:"consumeRetryPolicy,omitempty" xml:"consumeRetryPolicy,omitempty" type:"Struct"`
// The ID of the consumer group.
//
// example:
//
// CID-TEST
ConsumerGroupId *string `json:"consumerGroupId,omitempty" xml:"consumerGroupId,omitempty"`
// The time when the consumer group was created.
//
// example:
//
// 2022-08-01 20:05:50
CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
// The message delivery order of the consumer group.
//
// Valid values:
//
// - Concurrently
//
// <!-- -->
//
// :
//
// <!-- -->
//
// concurrent delivery
//
// <!-- -->
//
// - Orderly
//
// <!-- -->
//
// :
//
// <!-- -->
//
// ordered delivery
//
// <!-- -->
//
// example:
//
// Concurrently
DeliveryOrderType *string `json:"deliveryOrderType,omitempty" xml:"deliveryOrderType,omitempty"`
// The ID of the instance.
//
// example:
//
// rmq-cn-7e22ody****
InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
// The ID of the region in which the instance resides.
//
// example:
//
// cn-hangzhou
RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
// The remarks on the consumer group.
//
// example:
//
// This is the remark for test.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
// The state of the consumer group.
//
// Valid values:
//
// - RUNNING
//
// <!-- -->
//
// : The consumer group is
//
// <!-- -->
//
// running
//
// <!-- -->
//
// .
//
// - CREATING
//
// <!-- -->
//
// : The consumer group is
//
// <!-- -->
//
// being created
//
// <!-- -->
//
// .
//
// example:
//
// RUNNING
Status *string `json:"status,omitempty" xml:"status,omitempty"`
// The time when the consumer group was last updated.
//
// example:
//
// 2022-08-01 20:05:50
UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
}
func (GetConsumerGroupResponseBodyData) GoString ¶
func (s GetConsumerGroupResponseBodyData) GoString() string
func (*GetConsumerGroupResponseBodyData) SetConsumeRetryPolicy ¶
func (s *GetConsumerGroupResponseBodyData) SetConsumeRetryPolicy(v *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) *GetConsumerGroupResponseBodyData
func (*GetConsumerGroupResponseBodyData) SetConsumerGroupId ¶
func (s *GetConsumerGroupResponseBodyData) SetConsumerGroupId(v string) *GetConsumerGroupResponseBodyData
func (*GetConsumerGroupResponseBodyData) SetCreateTime ¶
func (s *GetConsumerGroupResponseBodyData) SetCreateTime(v string) *GetConsumerGroupResponseBodyData
func (*GetConsumerGroupResponseBodyData) SetDeliveryOrderType ¶
func (s *GetConsumerGroupResponseBodyData) SetDeliveryOrderType(v string) *GetConsumerGroupResponseBodyData
func (*GetConsumerGroupResponseBodyData) SetInstanceId ¶
func (s *GetConsumerGroupResponseBodyData) SetInstanceId(v string) *GetConsumerGroupResponseBodyData
func (*GetConsumerGroupResponseBodyData) SetRegionId ¶
func (s *GetConsumerGroupResponseBodyData) SetRegionId(v string) *GetConsumerGroupResponseBodyData
func (*GetConsumerGroupResponseBodyData) SetRemark ¶
func (s *GetConsumerGroupResponseBodyData) SetRemark(v string) *GetConsumerGroupResponseBodyData
func (*GetConsumerGroupResponseBodyData) SetStatus ¶
func (s *GetConsumerGroupResponseBodyData) SetStatus(v string) *GetConsumerGroupResponseBodyData
func (*GetConsumerGroupResponseBodyData) SetUpdateTime ¶
func (s *GetConsumerGroupResponseBodyData) SetUpdateTime(v string) *GetConsumerGroupResponseBodyData
func (GetConsumerGroupResponseBodyData) String ¶
func (s GetConsumerGroupResponseBodyData) String() string
type GetConsumerGroupResponseBodyDataConsumeRetryPolicy ¶
type GetConsumerGroupResponseBodyDataConsumeRetryPolicy struct {
// The dead-letter topic.
//
// If a consumer still fails to consume a message after the message is retried for a specified number of times, the message is delivered to a dead-letter topic for subsequent business recovery or troubleshooting. For more information, see [Consumption retry and dead-letter messages](https://help.aliyun.com/document_detail/440356.html).
//
// example:
//
// DLQ_mqtest
DeadLetterTargetTopic *string `json:"deadLetterTargetTopic,omitempty" xml:"deadLetterTargetTopic,omitempty"`
// The maximum number of retries.
//
// example:
//
// 16
MaxRetryTimes *int32 `json:"maxRetryTimes,omitempty" xml:"maxRetryTimes,omitempty"`
// The retry policy.
//
// Valid values:
//
// - FixedRetryPolicy
//
// <!-- -->
//
// :
//
// <!-- -->
//
// Failed messages are retried at a fixed interval
//
// <!-- -->
//
// .
//
// - DefaultRetryPolicy
//
// <!-- -->
//
// :
//
// <!-- -->
//
// Failed messages are retried at incremental intervals as the number of retries increases
//
// <!-- -->
//
// .
//
// example:
//
// DefaultRetryPolicy
RetryPolicy *string `json:"retryPolicy,omitempty" xml:"retryPolicy,omitempty"`
}
func (GetConsumerGroupResponseBodyDataConsumeRetryPolicy) GoString ¶
func (s GetConsumerGroupResponseBodyDataConsumeRetryPolicy) GoString() string
func (*GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetDeadLetterTargetTopic ¶ added in v1.0.3
func (s *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetDeadLetterTargetTopic(v string) *GetConsumerGroupResponseBodyDataConsumeRetryPolicy
func (*GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetMaxRetryTimes ¶
func (s *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetMaxRetryTimes(v int32) *GetConsumerGroupResponseBodyDataConsumeRetryPolicy
func (*GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetRetryPolicy ¶
func (s *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetRetryPolicy(v string) *GetConsumerGroupResponseBodyDataConsumeRetryPolicy
func (GetConsumerGroupResponseBodyDataConsumeRetryPolicy) String ¶
func (s GetConsumerGroupResponseBodyDataConsumeRetryPolicy) String() string
type GetInstanceResponse ¶
type GetInstanceResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *GetInstanceResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (GetInstanceResponse) GoString ¶
func (s GetInstanceResponse) GoString() string
func (*GetInstanceResponse) SetBody ¶
func (s *GetInstanceResponse) SetBody(v *GetInstanceResponseBody) *GetInstanceResponse
func (*GetInstanceResponse) SetHeaders ¶
func (s *GetInstanceResponse) SetHeaders(v map[string]*string) *GetInstanceResponse
func (*GetInstanceResponse) SetStatusCode ¶
func (s *GetInstanceResponse) SetStatusCode(v int32) *GetInstanceResponse
func (GetInstanceResponse) String ¶
func (s GetInstanceResponse) String() string
type GetInstanceResponseBody ¶
type GetInstanceResponseBody struct {
// The error code returned if the call failed.
//
// example:
//
// MissingInstanceId
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The returned data.
Data *GetInstanceResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Struct"`
// The dynamic error code.
//
// example:
//
// InstanceId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// instanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code returned.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// Parameter instanceId is mandatory for this action .
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. Each request has a unique ID. You can use this ID to troubleshoot issues.
//
// example:
//
// 05AB7FBD-F1D3-5D87-BF78-BD782249****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call was successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (GetInstanceResponseBody) GoString ¶
func (s GetInstanceResponseBody) GoString() string
func (*GetInstanceResponseBody) SetCode ¶
func (s *GetInstanceResponseBody) SetCode(v string) *GetInstanceResponseBody
func (*GetInstanceResponseBody) SetData ¶
func (s *GetInstanceResponseBody) SetData(v *GetInstanceResponseBodyData) *GetInstanceResponseBody
func (*GetInstanceResponseBody) SetDynamicCode ¶
func (s *GetInstanceResponseBody) SetDynamicCode(v string) *GetInstanceResponseBody
func (*GetInstanceResponseBody) SetDynamicMessage ¶
func (s *GetInstanceResponseBody) SetDynamicMessage(v string) *GetInstanceResponseBody
func (*GetInstanceResponseBody) SetHttpStatusCode ¶
func (s *GetInstanceResponseBody) SetHttpStatusCode(v int32) *GetInstanceResponseBody
func (*GetInstanceResponseBody) SetMessage ¶
func (s *GetInstanceResponseBody) SetMessage(v string) *GetInstanceResponseBody
func (*GetInstanceResponseBody) SetRequestId ¶
func (s *GetInstanceResponseBody) SetRequestId(v string) *GetInstanceResponseBody
func (*GetInstanceResponseBody) SetSuccess ¶
func (s *GetInstanceResponseBody) SetSuccess(v bool) *GetInstanceResponseBody
func (GetInstanceResponseBody) String ¶
func (s GetInstanceResponseBody) String() string
type GetInstanceResponseBodyData ¶
type GetInstanceResponseBodyData struct {
// The account information.
AccountInfo *GetInstanceResponseBodyDataAccountInfo `json:"accountInfo,omitempty" xml:"accountInfo,omitempty" type:"Struct"`
// The information about access control.
AclInfo *GetInstanceResponseBodyDataAclInfo `json:"aclInfo,omitempty" xml:"aclInfo,omitempty" type:"Struct"`
// The business ID (BID) of the commodity.
//
// example:
//
// 26842
Bid *string `json:"bid,omitempty" xml:"bid,omitempty"`
// The commodity code of the instance. The commodity code of a ApsaraMQ for RocketMQ 5.0 instance has a similar format as ons_rmqsub_public_cn.
//
// example:
//
// ons_rmqsub_public_cn
CommodityCode *string `json:"commodityCode,omitempty" xml:"commodityCode,omitempty"`
// The time when the instance was created.
//
// example:
//
// 2022-08-01 00:00:00
CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
// The time when the instance expires.
//
// example:
//
// 2022-09-01 00:00:00
ExpireTime *string `json:"expireTime,omitempty" xml:"expireTime,omitempty"`
// Deprecated
//
// The extended configurations. We recommend you configure productInfo, internetInfo, or aclInfo instead of this parameter.
ExtConfig *GetInstanceResponseBodyDataExtConfig `json:"extConfig,omitempty" xml:"extConfig,omitempty" type:"Struct"`
// The number of groups.
//
// example:
//
// 10
GroupCount *int64 `json:"groupCount,omitempty" xml:"groupCount,omitempty"`
// The ID of the instance
//
// example:
//
// rmq-cn-7e22ody****
InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
// The name of the instance.
//
// example:
//
// test instance
InstanceName *string `json:"instanceName,omitempty" xml:"instanceName,omitempty"`
// The instance quotas.
InstanceQuotas []*GetInstanceResponseBodyDataInstanceQuotas `json:"instanceQuotas,omitempty" xml:"instanceQuotas,omitempty" type:"Repeated"`
// The network information.
NetworkInfo *GetInstanceResponseBodyDataNetworkInfo `json:"networkInfo,omitempty" xml:"networkInfo,omitempty" type:"Struct"`
// The billing method of the instance.
//
// Valid values:
//
// - PayAsYouGo: pay-as-you-go
//
// - Subscription
//
// example:
//
// Subscription
PaymentType *string `json:"paymentType,omitempty" xml:"paymentType,omitempty"`
// The extended configurations of the instance.
ProductInfo *GetInstanceResponseBodyDataProductInfo `json:"productInfo,omitempty" xml:"productInfo,omitempty" type:"Struct"`
// The ID of the region in which the instance resides.
//
// example:
//
// cn-hangzhou
RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
// The time when the instance was released.
//
// example:
//
// 2022-09-07 00:00:00
ReleaseTime *string `json:"releaseTime,omitempty" xml:"releaseTime,omitempty"`
// The description of the instance.
//
// example:
//
// This is remark for instance.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
// The ID of the resource group.
//
// example:
//
// rg-acfm3tmjruyribi
ResourceGroupId *string `json:"resourceGroupId,omitempty" xml:"resourceGroupId,omitempty"`
// The primary edition of the instance. For information about the differences between primary edition instances, see [Instance selection](https://help.aliyun.com/document_detail/444722.html).
//
// Valid values:
//
// - standard: Standard Edition
//
// - ultimate: Enterprise Platinum Edition
//
// - professional: Professional Edition
//
// example:
//
// standard
SeriesCode *string `json:"seriesCode,omitempty" xml:"seriesCode,omitempty"`
// The code of the service to which the instance belongs. The service code of ApsaraMQ for RocketMQ is rmq.
//
// example:
//
// rmq
ServiceCode *string `json:"serviceCode,omitempty" xml:"serviceCode,omitempty"`
// The instance software information.
Software *GetInstanceResponseBodyDataSoftware `json:"software,omitempty" xml:"software,omitempty" type:"Struct"`
// The time when the instance was started.
//
// example:
//
// 2022-08-01 00:00:00
StartTime *string `json:"startTime,omitempty" xml:"startTime,omitempty"`
// The status of the instance.
//
// Valid values:
//
// - RELEASED
//
// - RUNNING
//
// - STOPPED
//
// - CHANGING
//
// - CREATING
//
// example:
//
// RUNNING
Status *string `json:"status,omitempty" xml:"status,omitempty"`
// The sub-category edition of the instance. For information about the differences between sub-category edition instances, see [Instance selection](https://help.aliyun.com/document_detail/444722.html).
//
// Valid values:
//
// - cluster_ha: Cluster High-availability Edition
//
// - single_node: Standalone Edition
//
// example:
//
// cluster_ha
SubSeriesCode *string `json:"subSeriesCode,omitempty" xml:"subSeriesCode,omitempty"`
// The resource tags.
Tags []*GetInstanceResponseBodyDataTags `json:"tags,omitempty" xml:"tags,omitempty" type:"Repeated"`
// The number of topics.
//
// example:
//
// 10
TopicCount *int64 `json:"topicCount,omitempty" xml:"topicCount,omitempty"`
// The time when the instance was last modified.
//
// example:
//
// 2022-08-02 00:00:00
UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
// The ID of the user who owns the instance.
//
// example:
//
// 111111111111111
UserId *string `json:"userId,omitempty" xml:"userId,omitempty"`
}
func (GetInstanceResponseBodyData) GoString ¶
func (s GetInstanceResponseBodyData) GoString() string
func (*GetInstanceResponseBodyData) SetAccountInfo ¶
func (s *GetInstanceResponseBodyData) SetAccountInfo(v *GetInstanceResponseBodyDataAccountInfo) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetAclInfo ¶ added in v1.0.2
func (s *GetInstanceResponseBodyData) SetAclInfo(v *GetInstanceResponseBodyDataAclInfo) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetBid ¶
func (s *GetInstanceResponseBodyData) SetBid(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetCommodityCode ¶
func (s *GetInstanceResponseBodyData) SetCommodityCode(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetCreateTime ¶
func (s *GetInstanceResponseBodyData) SetCreateTime(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetExpireTime ¶
func (s *GetInstanceResponseBodyData) SetExpireTime(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetExtConfig ¶
func (s *GetInstanceResponseBodyData) SetExtConfig(v *GetInstanceResponseBodyDataExtConfig) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetGroupCount ¶ added in v1.0.1
func (s *GetInstanceResponseBodyData) SetGroupCount(v int64) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetInstanceId ¶
func (s *GetInstanceResponseBodyData) SetInstanceId(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetInstanceName ¶
func (s *GetInstanceResponseBodyData) SetInstanceName(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetInstanceQuotas ¶
func (s *GetInstanceResponseBodyData) SetInstanceQuotas(v []*GetInstanceResponseBodyDataInstanceQuotas) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetNetworkInfo ¶
func (s *GetInstanceResponseBodyData) SetNetworkInfo(v *GetInstanceResponseBodyDataNetworkInfo) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetPaymentType ¶
func (s *GetInstanceResponseBodyData) SetPaymentType(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetProductInfo ¶ added in v1.0.2
func (s *GetInstanceResponseBodyData) SetProductInfo(v *GetInstanceResponseBodyDataProductInfo) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetRegionId ¶
func (s *GetInstanceResponseBodyData) SetRegionId(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetReleaseTime ¶
func (s *GetInstanceResponseBodyData) SetReleaseTime(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetRemark ¶
func (s *GetInstanceResponseBodyData) SetRemark(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetResourceGroupId ¶
func (s *GetInstanceResponseBodyData) SetResourceGroupId(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetSeriesCode ¶
func (s *GetInstanceResponseBodyData) SetSeriesCode(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetServiceCode ¶
func (s *GetInstanceResponseBodyData) SetServiceCode(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetSoftware ¶ added in v1.0.6
func (s *GetInstanceResponseBodyData) SetSoftware(v *GetInstanceResponseBodyDataSoftware) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetStartTime ¶
func (s *GetInstanceResponseBodyData) SetStartTime(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetStatus ¶
func (s *GetInstanceResponseBodyData) SetStatus(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetSubSeriesCode ¶
func (s *GetInstanceResponseBodyData) SetSubSeriesCode(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetTags ¶ added in v1.1.0
func (s *GetInstanceResponseBodyData) SetTags(v []*GetInstanceResponseBodyDataTags) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetTopicCount ¶ added in v1.0.1
func (s *GetInstanceResponseBodyData) SetTopicCount(v int64) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetUpdateTime ¶
func (s *GetInstanceResponseBodyData) SetUpdateTime(v string) *GetInstanceResponseBodyData
func (*GetInstanceResponseBodyData) SetUserId ¶
func (s *GetInstanceResponseBodyData) SetUserId(v string) *GetInstanceResponseBodyData
func (GetInstanceResponseBodyData) String ¶
func (s GetInstanceResponseBodyData) String() string
type GetInstanceResponseBodyDataAccountInfo ¶
type GetInstanceResponseBodyDataAccountInfo struct {
// The username of the instance. If you access a ApsaraMQ for RocketMQ instance over the Internet, you must configure the username and password of the instance in the SDK code for authentication.
//
// example:
//
// 6W0xz2uPfiwp****
Username *string `json:"username,omitempty" xml:"username,omitempty"`
}
func (GetInstanceResponseBodyDataAccountInfo) GoString ¶
func (s GetInstanceResponseBodyDataAccountInfo) GoString() string
func (*GetInstanceResponseBodyDataAccountInfo) SetUsername ¶
func (s *GetInstanceResponseBodyDataAccountInfo) SetUsername(v string) *GetInstanceResponseBodyDataAccountInfo
func (GetInstanceResponseBodyDataAccountInfo) String ¶
func (s GetInstanceResponseBodyDataAccountInfo) String() string
type GetInstanceResponseBodyDataAclInfo ¶ added in v1.0.2
type GetInstanceResponseBodyDataAclInfo struct {
// Deprecated
//
// The authentication type of the instance. This parameter is no longer in use. We recommend that you configure aclTypes.
//
// Valid values:
//
// - default: intelligent identity authentication
//
// - apache_acl:access control list (ACL) identity authentication**
//
// example:
//
// default
AclType *string `json:"aclType,omitempty" xml:"aclType,omitempty"`
// The authentication types of the instance.
AclTypes []*string `json:"aclTypes,omitempty" xml:"aclTypes,omitempty" type:"Repeated"`
// Indicates whether the authentication-free in VPCs feature is enabled.
//
// Valid values:
//
// - true
//
// <!-- -->
//
// <!-- -->
//
// <!-- -->
//
// - false
//
// <!-- -->
//
// <!-- -->
//
// <!-- -->
//
// example:
//
// true
DefaultVpcAuthFree *bool `json:"defaultVpcAuthFree,omitempty" xml:"defaultVpcAuthFree,omitempty"`
}
func (GetInstanceResponseBodyDataAclInfo) GoString ¶ added in v1.0.2
func (s GetInstanceResponseBodyDataAclInfo) GoString() string
func (*GetInstanceResponseBodyDataAclInfo) SetAclType ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataAclInfo) SetAclType(v string) *GetInstanceResponseBodyDataAclInfo
func (*GetInstanceResponseBodyDataAclInfo) SetAclTypes ¶ added in v1.4.1
func (s *GetInstanceResponseBodyDataAclInfo) SetAclTypes(v []*string) *GetInstanceResponseBodyDataAclInfo
func (*GetInstanceResponseBodyDataAclInfo) SetDefaultVpcAuthFree ¶ added in v1.4.1
func (s *GetInstanceResponseBodyDataAclInfo) SetDefaultVpcAuthFree(v bool) *GetInstanceResponseBodyDataAclInfo
func (GetInstanceResponseBodyDataAclInfo) String ¶ added in v1.0.2
func (s GetInstanceResponseBodyDataAclInfo) String() string
type GetInstanceResponseBodyDataExtConfig ¶
type GetInstanceResponseBodyDataExtConfig struct {
// The authentication type of the instance.
//
// Valid values:
//
// - default: intelligent authentication
//
// example:
//
// default
AclType *string `json:"aclType,omitempty" xml:"aclType,omitempty"`
// Specifies whether to enable the elastic TPS feature for the instance.
//
// Valid values:
//
// - true: enable
//
// - false: disable
//
// This parameter is valid only when the supportAutoScaling parameter is set to enable.
//
// example:
//
// true
AutoScaling *bool `json:"autoScaling,omitempty" xml:"autoScaling,omitempty"`
// The Internet bandwidth. Unit: MB/s.
//
// example:
//
// 10
FlowOutBandwidth *int32 `json:"flowOutBandwidth,omitempty" xml:"flowOutBandwidth,omitempty"`
// The metering method for Internet usage.
//
// Valid values:
//
// - PayByTraffic: pay-by-traffic
//
// - paybybandwidth: pay-by-bandwidth
//
// - uninvolved: N/A
//
// example:
//
// payByBandwidth
FlowOutType *string `json:"flowOutType,omitempty" xml:"flowOutType,omitempty"`
// Specifies whether to enable the Internet access feature.
//
// Valid values:
//
// - enable
//
// - disable
//
// By default, ApsaraMQ for RocketMQ instances are accessed in virtual private clouds (VPCs). If you enable the Internet access feature, you are charged for Internet outbound bandwidth. For more information, see [Internet access fee](https://help.aliyun.com/document_detail/427240.html).
//
// example:
//
// enable
InternetSpec *string `json:"internetSpec,omitempty" xml:"internetSpec,omitempty"`
// The retention period of messages. Unit: hours.
//
// For information about the valid values of this parameter, see the "Limits on resource quotas" section in [Usage limits](https://help.aliyun.com/document_detail/440347.html).
//
// The storage of messages in ApsaraMQ for RocketMQ is serverless and scalable. You are charged for message storage based on your actual usage. You can change the retention period of messages to adjust storage capacity. For more information, see [Storage fee](https://help.aliyun.com/document_detail/427238.html).
//
// example:
//
// 72
MessageRetentionTime *int32 `json:"messageRetentionTime,omitempty" xml:"messageRetentionTime,omitempty"`
// The computing specification that is used to send and receive messages. For information about the upper limit of TPS, see [Instance specifications](https://help.aliyun.com/document_detail/444715.html).
//
// example:
//
// rmq.s2.2xlarge
MsgProcessSpec *string `json:"msgProcessSpec,omitempty" xml:"msgProcessSpec,omitempty"`
// The ratio between sent messages and received messages in the instance.
//
// example:
//
// 0.5
SendReceiveRatio *float32 `json:"sendReceiveRatio,omitempty" xml:"sendReceiveRatio,omitempty"`
// Specifies whether the elastic TPS feature is supported by the instance.
//
// Valid values:
//
// - true: enable
//
// - false: disable
//
// After you enable the elastic TPS feature for a ApsaraMQ for RocketMQ instance, you can use a specific amount of TPS that exceeds the specification limit. You are charged for the elastic TPS feature. For more information, see [Computing fee](https://help.aliyun.com/document_detail/427237.html).
//
// > The elastic TPS feature is supported only by specific instance editions. For more information, see [Instance specifications](https://help.aliyun.com/document_detail/444715.html).
//
// example:
//
// true
SupportAutoScaling *bool `json:"supportAutoScaling,omitempty" xml:"supportAutoScaling,omitempty"`
}
func (GetInstanceResponseBodyDataExtConfig) GoString ¶
func (s GetInstanceResponseBodyDataExtConfig) GoString() string
func (*GetInstanceResponseBodyDataExtConfig) SetAclType ¶
func (s *GetInstanceResponseBodyDataExtConfig) SetAclType(v string) *GetInstanceResponseBodyDataExtConfig
func (*GetInstanceResponseBodyDataExtConfig) SetAutoScaling ¶
func (s *GetInstanceResponseBodyDataExtConfig) SetAutoScaling(v bool) *GetInstanceResponseBodyDataExtConfig
func (*GetInstanceResponseBodyDataExtConfig) SetFlowOutBandwidth ¶
func (s *GetInstanceResponseBodyDataExtConfig) SetFlowOutBandwidth(v int32) *GetInstanceResponseBodyDataExtConfig
func (*GetInstanceResponseBodyDataExtConfig) SetFlowOutType ¶
func (s *GetInstanceResponseBodyDataExtConfig) SetFlowOutType(v string) *GetInstanceResponseBodyDataExtConfig
func (*GetInstanceResponseBodyDataExtConfig) SetInternetSpec ¶
func (s *GetInstanceResponseBodyDataExtConfig) SetInternetSpec(v string) *GetInstanceResponseBodyDataExtConfig
func (*GetInstanceResponseBodyDataExtConfig) SetMessageRetentionTime ¶
func (s *GetInstanceResponseBodyDataExtConfig) SetMessageRetentionTime(v int32) *GetInstanceResponseBodyDataExtConfig
func (*GetInstanceResponseBodyDataExtConfig) SetMsgProcessSpec ¶
func (s *GetInstanceResponseBodyDataExtConfig) SetMsgProcessSpec(v string) *GetInstanceResponseBodyDataExtConfig
func (*GetInstanceResponseBodyDataExtConfig) SetSendReceiveRatio ¶
func (s *GetInstanceResponseBodyDataExtConfig) SetSendReceiveRatio(v float32) *GetInstanceResponseBodyDataExtConfig
func (*GetInstanceResponseBodyDataExtConfig) SetSupportAutoScaling ¶
func (s *GetInstanceResponseBodyDataExtConfig) SetSupportAutoScaling(v bool) *GetInstanceResponseBodyDataExtConfig
func (GetInstanceResponseBodyDataExtConfig) String ¶
func (s GetInstanceResponseBodyDataExtConfig) String() string
type GetInstanceResponseBodyDataInstanceQuotas ¶
type GetInstanceResponseBodyDataInstanceQuotas struct {
// The number of topics that are free of charge on the instance.
//
// example:
//
// 20
FreeCount *float64 `json:"freeCount,omitempty" xml:"freeCount,omitempty"`
// The quota name.
//
// Valid value:
//
// - TOPIC_COUNT: the number of topics that can be created on the instance
//
// example:
//
// TOPIC_COUNT
QuotaName *string `json:"quotaName,omitempty" xml:"quotaName,omitempty"`
// The total number of topics on the instance.
//
// example:
//
// 100
TotalCount *float64 `json:"totalCount,omitempty" xml:"totalCount,omitempty"`
// The number of used topics on the instance.
//
// example:
//
// 10
UsedCount *float64 `json:"usedCount,omitempty" xml:"usedCount,omitempty"`
}
func (GetInstanceResponseBodyDataInstanceQuotas) GoString ¶
func (s GetInstanceResponseBodyDataInstanceQuotas) GoString() string
func (*GetInstanceResponseBodyDataInstanceQuotas) SetFreeCount ¶
func (s *GetInstanceResponseBodyDataInstanceQuotas) SetFreeCount(v float64) *GetInstanceResponseBodyDataInstanceQuotas
func (*GetInstanceResponseBodyDataInstanceQuotas) SetQuotaName ¶
func (s *GetInstanceResponseBodyDataInstanceQuotas) SetQuotaName(v string) *GetInstanceResponseBodyDataInstanceQuotas
func (*GetInstanceResponseBodyDataInstanceQuotas) SetTotalCount ¶
func (s *GetInstanceResponseBodyDataInstanceQuotas) SetTotalCount(v float64) *GetInstanceResponseBodyDataInstanceQuotas
func (*GetInstanceResponseBodyDataInstanceQuotas) SetUsedCount ¶
func (s *GetInstanceResponseBodyDataInstanceQuotas) SetUsedCount(v float64) *GetInstanceResponseBodyDataInstanceQuotas
func (GetInstanceResponseBodyDataInstanceQuotas) String ¶
func (s GetInstanceResponseBodyDataInstanceQuotas) String() string
type GetInstanceResponseBodyDataNetworkInfo ¶
type GetInstanceResponseBodyDataNetworkInfo struct {
// The information about endpoints.
Endpoints []*GetInstanceResponseBodyDataNetworkInfoEndpoints `json:"endpoints,omitempty" xml:"endpoints,omitempty" type:"Repeated"`
// The information about the Internet.
InternetInfo *GetInstanceResponseBodyDataNetworkInfoInternetInfo `json:"internetInfo,omitempty" xml:"internetInfo,omitempty" type:"Struct"`
// The virtual private cloud (VPC) information.
VpcInfo *GetInstanceResponseBodyDataNetworkInfoVpcInfo `json:"vpcInfo,omitempty" xml:"vpcInfo,omitempty" type:"Struct"`
}
func (GetInstanceResponseBodyDataNetworkInfo) GoString ¶
func (s GetInstanceResponseBodyDataNetworkInfo) GoString() string
func (*GetInstanceResponseBodyDataNetworkInfo) SetEndpoints ¶
func (s *GetInstanceResponseBodyDataNetworkInfo) SetEndpoints(v []*GetInstanceResponseBodyDataNetworkInfoEndpoints) *GetInstanceResponseBodyDataNetworkInfo
func (*GetInstanceResponseBodyDataNetworkInfo) SetInternetInfo ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataNetworkInfo) SetInternetInfo(v *GetInstanceResponseBodyDataNetworkInfoInternetInfo) *GetInstanceResponseBodyDataNetworkInfo
func (*GetInstanceResponseBodyDataNetworkInfo) SetVpcInfo ¶
func (GetInstanceResponseBodyDataNetworkInfo) String ¶
func (s GetInstanceResponseBodyDataNetworkInfo) String() string
type GetInstanceResponseBodyDataNetworkInfoEndpoints ¶
type GetInstanceResponseBodyDataNetworkInfoEndpoints struct {
// The type of the endpoint that is used to access the instance.
//
// Valid values:
//
// - TCP_VPC: VPC endpoint
//
// - TCP_INTERNET:public endpoint
//
// example:
//
// TCP_INTERNET
EndpointType *string `json:"endpointType,omitempty" xml:"endpointType,omitempty"`
// The endpoint that is used to access the instance.
//
// example:
//
// rmq-cn-c4d2tbk****-vpc.cn-hangzhou.rmq.aliyuncs.com:8080
EndpointUrl *string `json:"endpointUrl,omitempty" xml:"endpointUrl,omitempty"`
// The whitelist that includes the IP addresses that are allowed to access the ApsaraMQ for RocketMQ broker over the Internet. This parameter can be configured only if you use the public endpoint to access the instance.
//
// - If you do not configure an IP address whitelist, all CIDR blocks are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
//
// - If you configure an IP address whitelist, only the IP addresses in the whitelist are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
//
// We recommend that you configure internetInfo.ipWhitelist instead of this parameter.
//
// example:
//
// 192.168.x.x/24
IpWhitelist []*string `json:"ipWhitelist,omitempty" xml:"ipWhitelist,omitempty" type:"Repeated"`
}
func (GetInstanceResponseBodyDataNetworkInfoEndpoints) GoString ¶
func (s GetInstanceResponseBodyDataNetworkInfoEndpoints) GoString() string
func (*GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointType ¶
func (s *GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointType(v string) *GetInstanceResponseBodyDataNetworkInfoEndpoints
func (*GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointUrl ¶
func (s *GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointUrl(v string) *GetInstanceResponseBodyDataNetworkInfoEndpoints
func (*GetInstanceResponseBodyDataNetworkInfoEndpoints) SetIpWhitelist ¶
func (s *GetInstanceResponseBodyDataNetworkInfoEndpoints) SetIpWhitelist(v []*string) *GetInstanceResponseBodyDataNetworkInfoEndpoints
func (GetInstanceResponseBodyDataNetworkInfoEndpoints) String ¶
func (s GetInstanceResponseBodyDataNetworkInfoEndpoints) String() string
type GetInstanceResponseBodyDataNetworkInfoInternetInfo ¶ added in v1.0.2
type GetInstanceResponseBodyDataNetworkInfoInternetInfo struct {
// The Internet bandwidth. Unit: MB/s.
//
// example:
//
// 1
FlowOutBandwidth *int32 `json:"flowOutBandwidth,omitempty" xml:"flowOutBandwidth,omitempty"`
// The metering method for Internet usage.
//
// Valid values:
//
// - PayByBandwidth: pay-by-bandwidth. If the Internet access feature is enabled, specify this value for the parameter.
//
// - uninvolved: N/A. If the Internet access feature is not enabled, specify this value for the parameter.
//
// example:
//
// payByBandwidth
FlowOutType *string `json:"flowOutType,omitempty" xml:"flowOutType,omitempty"`
// Specifies whether to enable the Internet access feature.
//
// Valid values:
//
// - enable
//
// - disable
//
// By default, ApsaraMQ for RocketMQ instances are accessed in virtual private clouds (VPCs). If you enable the Internet access feature, you are charged for Internet outbound bandwidth. For more information, see [Internet access fee](https://help.aliyun.com/document_detail/427240.html).
//
// example:
//
// enable
InternetSpec *string `json:"internetSpec,omitempty" xml:"internetSpec,omitempty"`
// The whitelist that includes the IP addresses that are allowed to access the ApsaraMQ for RocketMQ broker.
//
// - If this parameter is not configured, all IP addresses are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
//
// - If this parameter is configured, only the IP addresses that are included in the whitelist can access the ApsaraMQ for RocketMQ broker over the Internet.
IpWhitelist []*string `json:"ipWhitelist,omitempty" xml:"ipWhitelist,omitempty" type:"Repeated"`
}
func (GetInstanceResponseBodyDataNetworkInfoInternetInfo) GoString ¶ added in v1.0.2
func (s GetInstanceResponseBodyDataNetworkInfoInternetInfo) GoString() string
func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutBandwidth ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutBandwidth(v int32) *GetInstanceResponseBodyDataNetworkInfoInternetInfo
func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutType ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutType(v string) *GetInstanceResponseBodyDataNetworkInfoInternetInfo
func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetInternetSpec ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetInternetSpec(v string) *GetInstanceResponseBodyDataNetworkInfoInternetInfo
func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetIpWhitelist ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetIpWhitelist(v []*string) *GetInstanceResponseBodyDataNetworkInfoInternetInfo
func (GetInstanceResponseBodyDataNetworkInfoInternetInfo) String ¶ added in v1.0.2
func (s GetInstanceResponseBodyDataNetworkInfoInternetInfo) String() string
type GetInstanceResponseBodyDataNetworkInfoVpcInfo ¶
type GetInstanceResponseBodyDataNetworkInfoVpcInfo struct {
// The security group ID.
//
// example:
//
// sg-hp35r2hc3a3sv8q2sb16
SecurityGroupIds *string `json:"securityGroupIds,omitempty" xml:"securityGroupIds,omitempty"`
// Deprecated
//
// The ID of the vSwitch with which the instance is associated.
//
// example:
//
// vsw-uf6gwtbn6etadpvz7****
VSwitchId *string `json:"vSwitchId,omitempty" xml:"vSwitchId,omitempty"`
VSwitches []*GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches `json:"vSwitches,omitempty" xml:"vSwitches,omitempty" type:"Repeated"`
// The ID of the VPC with which the instance is associated.
//
// example:
//
// vpc-uf6of9452b2pba82c****
VpcId *string `json:"vpcId,omitempty" xml:"vpcId,omitempty"`
}
func (GetInstanceResponseBodyDataNetworkInfoVpcInfo) GoString ¶
func (s GetInstanceResponseBodyDataNetworkInfoVpcInfo) GoString() string
func (*GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetSecurityGroupIds ¶ added in v1.1.2
func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetSecurityGroupIds(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfo
func (*GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVSwitchId ¶
func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVSwitchId(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfo
func (*GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVSwitches ¶ added in v1.4.2
func (*GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVpcId ¶
func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVpcId(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfo
func (GetInstanceResponseBodyDataNetworkInfoVpcInfo) String ¶
func (s GetInstanceResponseBodyDataNetworkInfoVpcInfo) String() string
type GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches ¶ added in v1.4.2
type GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches struct {
VSwitchId *string `json:"vSwitchId,omitempty" xml:"vSwitchId,omitempty"`
ZoneId *string `json:"zoneId,omitempty" xml:"zoneId,omitempty"`
}
func (GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) GoString ¶ added in v1.4.2
func (s GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) GoString() string
func (*GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) SetVSwitchId ¶ added in v1.4.2
func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) SetVSwitchId(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches
func (GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) String ¶ added in v1.4.2
func (s GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) String() string
type GetInstanceResponseBodyDataProductInfo ¶ added in v1.0.2
type GetInstanceResponseBodyDataProductInfo struct {
// Specifies whether to enable the elastic TPS feature for the instance.
//
// Valid values:
//
// - true: enable
//
// - false: disable
//
// This parameter is valid only when the supportAutoScaling parameter is set to enable.
//
// example:
//
// true
AutoScaling *bool `json:"autoScaling,omitempty" xml:"autoScaling,omitempty"`
// The retention period of messages. Unit: hours.
//
// For information about the valid values of this parameter, see the "Limits on resource quotas" section in [Usage limits](https://help.aliyun.com/document_detail/440347.html).
//
// The storage of messages in ApsaraMQ for RocketMQ is serverless and scalable. You are charged for message storage based on your actual usage. You can change the retention period of messages to adjust storage capacity. For more information, see [Storage fee](https://help.aliyun.com/document_detail/427238.html).
//
// example:
//
// 72
MessageRetentionTime *int32 `json:"messageRetentionTime,omitempty" xml:"messageRetentionTime,omitempty"`
// The computing specification that is used to send and receive messages. For information about the upper limit of TPS, see [Instance specifications](https://help.aliyun.com/document_detail/444715.html).
//
// example:
//
// rmq.s2.2xlarge
MsgProcessSpec *string `json:"msgProcessSpec,omitempty" xml:"msgProcessSpec,omitempty"`
// The ratio between sent messages and received messages in the instance.
//
// example:
//
// 0.5
SendReceiveRatio *float32 `json:"sendReceiveRatio,omitempty" xml:"sendReceiveRatio,omitempty"`
// Specifies whether to enable the elastic TPS feature for the instance.
//
// Valid values:
//
// - true: enable
//
// - false: disable
//
// After you enable the elastic TPS feature for a ApsaraMQ for RocketMQ instance, you can use a specific amount of TPS that exceeds the specification limit. You are charged for the elastic TPS feature. For more information, see [Computing fee](https://help.aliyun.com/document_detail/427237.html).
//
// > The elastic TPS feature is supported by only specific instance editions. For more information, see [Instance specifications](https://help.aliyun.com/document_detail/444715.html).
//
// example:
//
// true
SupportAutoScaling *bool `json:"supportAutoScaling,omitempty" xml:"supportAutoScaling,omitempty"`
// Indicates whether the message trace feature is enabled. Valid values:
//
// - true
//
// - false
//
// This parameter is not in use. By default, the message trace feature is enabled for ApsaraMQ for RocketMQ instances, regardless of whether this parameter is configured.
//
// example:
//
// true
TraceOn *bool `json:"traceOn,omitempty" xml:"traceOn,omitempty"`
}
func (GetInstanceResponseBodyDataProductInfo) GoString ¶ added in v1.0.2
func (s GetInstanceResponseBodyDataProductInfo) GoString() string
func (*GetInstanceResponseBodyDataProductInfo) SetAutoScaling ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataProductInfo) SetAutoScaling(v bool) *GetInstanceResponseBodyDataProductInfo
func (*GetInstanceResponseBodyDataProductInfo) SetMessageRetentionTime ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataProductInfo) SetMessageRetentionTime(v int32) *GetInstanceResponseBodyDataProductInfo
func (*GetInstanceResponseBodyDataProductInfo) SetMsgProcessSpec ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataProductInfo) SetMsgProcessSpec(v string) *GetInstanceResponseBodyDataProductInfo
func (*GetInstanceResponseBodyDataProductInfo) SetSendReceiveRatio ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataProductInfo) SetSendReceiveRatio(v float32) *GetInstanceResponseBodyDataProductInfo
func (*GetInstanceResponseBodyDataProductInfo) SetSupportAutoScaling ¶ added in v1.0.2
func (s *GetInstanceResponseBodyDataProductInfo) SetSupportAutoScaling(v bool) *GetInstanceResponseBodyDataProductInfo
func (*GetInstanceResponseBodyDataProductInfo) SetTraceOn ¶ added in v1.1.2
func (s *GetInstanceResponseBodyDataProductInfo) SetTraceOn(v bool) *GetInstanceResponseBodyDataProductInfo
func (GetInstanceResponseBodyDataProductInfo) String ¶ added in v1.0.2
func (s GetInstanceResponseBodyDataProductInfo) String() string
type GetInstanceResponseBodyDataSoftware ¶ added in v1.0.6
type GetInstanceResponseBodyDataSoftware struct {
// The period of upgrade time.
//
// example:
//
// 02:00-06:00
MaintainTime *string `json:"maintainTime,omitempty" xml:"maintainTime,omitempty"`
// The version of software.
//
// example:
//
// 5.0-rmq-20230619-1
SoftwareVersion *string `json:"softwareVersion,omitempty" xml:"softwareVersion,omitempty"`
// The upgrade method.
//
// Valid values:
//
// - Auto: automatic upgrade
//
// - Manual: manual upgrade
//
// example:
//
// auto
UpgradeMethod *string `json:"upgradeMethod,omitempty" xml:"upgradeMethod,omitempty"`
}
func (GetInstanceResponseBodyDataSoftware) GoString ¶ added in v1.0.6
func (s GetInstanceResponseBodyDataSoftware) GoString() string
func (*GetInstanceResponseBodyDataSoftware) SetMaintainTime ¶ added in v1.0.6
func (s *GetInstanceResponseBodyDataSoftware) SetMaintainTime(v string) *GetInstanceResponseBodyDataSoftware
func (*GetInstanceResponseBodyDataSoftware) SetSoftwareVersion ¶ added in v1.0.6
func (s *GetInstanceResponseBodyDataSoftware) SetSoftwareVersion(v string) *GetInstanceResponseBodyDataSoftware
func (*GetInstanceResponseBodyDataSoftware) SetUpgradeMethod ¶ added in v1.0.6
func (s *GetInstanceResponseBodyDataSoftware) SetUpgradeMethod(v string) *GetInstanceResponseBodyDataSoftware
func (GetInstanceResponseBodyDataSoftware) String ¶ added in v1.0.6
func (s GetInstanceResponseBodyDataSoftware) String() string
type GetInstanceResponseBodyDataTags ¶ added in v1.1.0
type GetInstanceResponseBodyDataTags struct {
// The tag key of the resource.
//
// example:
//
// key
Key *string `json:"key,omitempty" xml:"key,omitempty"`
// The tag value of the resource.
//
// example:
//
// value
Value *string `json:"value,omitempty" xml:"value,omitempty"`
}
func (GetInstanceResponseBodyDataTags) GoString ¶ added in v1.1.0
func (s GetInstanceResponseBodyDataTags) GoString() string
func (*GetInstanceResponseBodyDataTags) SetKey ¶ added in v1.1.0
func (s *GetInstanceResponseBodyDataTags) SetKey(v string) *GetInstanceResponseBodyDataTags
func (*GetInstanceResponseBodyDataTags) SetValue ¶ added in v1.1.0
func (s *GetInstanceResponseBodyDataTags) SetValue(v string) *GetInstanceResponseBodyDataTags
func (GetInstanceResponseBodyDataTags) String ¶ added in v1.1.0
func (s GetInstanceResponseBodyDataTags) String() string
type GetTopicResponse ¶
type GetTopicResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *GetTopicResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (GetTopicResponse) GoString ¶
func (s GetTopicResponse) GoString() string
func (*GetTopicResponse) SetBody ¶
func (s *GetTopicResponse) SetBody(v *GetTopicResponseBody) *GetTopicResponse
func (*GetTopicResponse) SetHeaders ¶
func (s *GetTopicResponse) SetHeaders(v map[string]*string) *GetTopicResponse
func (*GetTopicResponse) SetStatusCode ¶
func (s *GetTopicResponse) SetStatusCode(v int32) *GetTopicResponse
func (GetTopicResponse) String ¶
func (s GetTopicResponse) String() string
type GetTopicResponseBody ¶
type GetTopicResponseBody struct {
// The error code.
//
// example:
//
// Topic.NotFound
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The result data that is returned.
Data *GetTopicResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Struct"`
// The dynamic error code.
//
// example:
//
// TopicName
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// topicName
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// The topic cannot be found.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. The system generates a unique ID for each request. You can troubleshoot issues based on the request ID.
//
// example:
//
// AF9A8B10-C426-530F-A0DD-96320B39****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (GetTopicResponseBody) GoString ¶
func (s GetTopicResponseBody) GoString() string
func (*GetTopicResponseBody) SetCode ¶
func (s *GetTopicResponseBody) SetCode(v string) *GetTopicResponseBody
func (*GetTopicResponseBody) SetData ¶
func (s *GetTopicResponseBody) SetData(v *GetTopicResponseBodyData) *GetTopicResponseBody
func (*GetTopicResponseBody) SetDynamicCode ¶
func (s *GetTopicResponseBody) SetDynamicCode(v string) *GetTopicResponseBody
func (*GetTopicResponseBody) SetDynamicMessage ¶
func (s *GetTopicResponseBody) SetDynamicMessage(v string) *GetTopicResponseBody
func (*GetTopicResponseBody) SetHttpStatusCode ¶
func (s *GetTopicResponseBody) SetHttpStatusCode(v int32) *GetTopicResponseBody
func (*GetTopicResponseBody) SetMessage ¶
func (s *GetTopicResponseBody) SetMessage(v string) *GetTopicResponseBody
func (*GetTopicResponseBody) SetRequestId ¶
func (s *GetTopicResponseBody) SetRequestId(v string) *GetTopicResponseBody
func (*GetTopicResponseBody) SetSuccess ¶
func (s *GetTopicResponseBody) SetSuccess(v bool) *GetTopicResponseBody
func (GetTopicResponseBody) String ¶
func (s GetTopicResponseBody) String() string
type GetTopicResponseBodyData ¶
type GetTopicResponseBodyData struct {
// The time when the topic was created.
//
// example:
//
// 2022-08-01 20:05:50
CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
// The ID of the instance.
//
// example:
//
// rmq-cn-7e22ody****
InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
// The message type of the topic.
//
// Valid values:
//
// - TRANSACTION: transactional message
//
// - FIFO: ordered message
//
// - DELAY: scheduled or delayed message
//
// - NORMAL: normal message
//
// example:
//
// NORMAL
MessageType *string `json:"messageType,omitempty" xml:"messageType,omitempty"`
// The ID of the region in which the instance resides.
//
// example:
//
// cn-hangzhou
RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
// The remarks on the topic.
//
// example:
//
// This is the remark for test.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
// The state of the topic.
//
// Valid values:
//
// - RUNNING: The topic is running.
//
// - CREATING: The topic is being created.
//
// example:
//
// RUNNING
Status *string `json:"status,omitempty" xml:"status,omitempty"`
// The name of the topic.
//
// example:
//
// topic_test
TopicName *string `json:"topicName,omitempty" xml:"topicName,omitempty"`
// The time when the topic was last updated.
//
// example:
//
// 2022-08-01 20:05:50
UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
}
func (GetTopicResponseBodyData) GoString ¶
func (s GetTopicResponseBodyData) GoString() string
func (*GetTopicResponseBodyData) SetCreateTime ¶
func (s *GetTopicResponseBodyData) SetCreateTime(v string) *GetTopicResponseBodyData
func (*GetTopicResponseBodyData) SetInstanceId ¶
func (s *GetTopicResponseBodyData) SetInstanceId(v string) *GetTopicResponseBodyData
func (*GetTopicResponseBodyData) SetMessageType ¶
func (s *GetTopicResponseBodyData) SetMessageType(v string) *GetTopicResponseBodyData
func (*GetTopicResponseBodyData) SetRegionId ¶
func (s *GetTopicResponseBodyData) SetRegionId(v string) *GetTopicResponseBodyData
func (*GetTopicResponseBodyData) SetRemark ¶
func (s *GetTopicResponseBodyData) SetRemark(v string) *GetTopicResponseBodyData
func (*GetTopicResponseBodyData) SetStatus ¶
func (s *GetTopicResponseBodyData) SetStatus(v string) *GetTopicResponseBodyData
func (*GetTopicResponseBodyData) SetTopicName ¶
func (s *GetTopicResponseBodyData) SetTopicName(v string) *GetTopicResponseBodyData
func (*GetTopicResponseBodyData) SetUpdateTime ¶
func (s *GetTopicResponseBodyData) SetUpdateTime(v string) *GetTopicResponseBodyData
func (GetTopicResponseBodyData) String ¶
func (s GetTopicResponseBodyData) String() string
type ListAvailableZonesResponse ¶ added in v1.2.0
type ListAvailableZonesResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *ListAvailableZonesResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (ListAvailableZonesResponse) GoString ¶ added in v1.2.0
func (s ListAvailableZonesResponse) GoString() string
func (*ListAvailableZonesResponse) SetBody ¶ added in v1.2.0
func (s *ListAvailableZonesResponse) SetBody(v *ListAvailableZonesResponseBody) *ListAvailableZonesResponse
func (*ListAvailableZonesResponse) SetHeaders ¶ added in v1.2.0
func (s *ListAvailableZonesResponse) SetHeaders(v map[string]*string) *ListAvailableZonesResponse
func (*ListAvailableZonesResponse) SetStatusCode ¶ added in v1.2.0
func (s *ListAvailableZonesResponse) SetStatusCode(v int32) *ListAvailableZonesResponse
func (ListAvailableZonesResponse) String ¶ added in v1.2.0
func (s ListAvailableZonesResponse) String() string
type ListAvailableZonesResponseBody ¶ added in v1.2.0
type ListAvailableZonesResponseBody struct {
// example:
//
// Topic.NotFound
Code *string `json:"code,omitempty" xml:"code,omitempty"`
Data []*ListAvailableZonesResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Repeated"`
// example:
//
// InstanceId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// example:
//
// InstanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// example:
//
// 200
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// example:
//
// Parameter instanceId is mandatory for this action .
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// example:
//
// AF9A8B10-C426-530F-A0DD-96320B39****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (ListAvailableZonesResponseBody) GoString ¶ added in v1.2.0
func (s ListAvailableZonesResponseBody) GoString() string
func (*ListAvailableZonesResponseBody) SetCode ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBody) SetCode(v string) *ListAvailableZonesResponseBody
func (*ListAvailableZonesResponseBody) SetData ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBody) SetData(v []*ListAvailableZonesResponseBodyData) *ListAvailableZonesResponseBody
func (*ListAvailableZonesResponseBody) SetDynamicCode ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBody) SetDynamicCode(v string) *ListAvailableZonesResponseBody
func (*ListAvailableZonesResponseBody) SetDynamicMessage ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBody) SetDynamicMessage(v string) *ListAvailableZonesResponseBody
func (*ListAvailableZonesResponseBody) SetHttpStatusCode ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBody) SetHttpStatusCode(v int32) *ListAvailableZonesResponseBody
func (*ListAvailableZonesResponseBody) SetMessage ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBody) SetMessage(v string) *ListAvailableZonesResponseBody
func (*ListAvailableZonesResponseBody) SetRequestId ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBody) SetRequestId(v string) *ListAvailableZonesResponseBody
func (*ListAvailableZonesResponseBody) SetSuccess ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBody) SetSuccess(v bool) *ListAvailableZonesResponseBody
func (ListAvailableZonesResponseBody) String ¶ added in v1.2.0
func (s ListAvailableZonesResponseBody) String() string
type ListAvailableZonesResponseBodyData ¶ added in v1.2.0
type ListAvailableZonesResponseBodyData struct {
// example:
//
// 2022-08-01 20:05:50
CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
// example:
//
// 2022-08-01 20:05:50
UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
// example:
//
// cn-qingdao-b
ZoneId *string `json:"zoneId,omitempty" xml:"zoneId,omitempty"`
// example:
//
// ha-cn-t9b30w902vm_qrs
ZoneName *string `json:"zoneName,omitempty" xml:"zoneName,omitempty"`
}
func (ListAvailableZonesResponseBodyData) GoString ¶ added in v1.2.0
func (s ListAvailableZonesResponseBodyData) GoString() string
func (*ListAvailableZonesResponseBodyData) SetCreateTime ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBodyData) SetCreateTime(v string) *ListAvailableZonesResponseBodyData
func (*ListAvailableZonesResponseBodyData) SetUpdateTime ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBodyData) SetUpdateTime(v string) *ListAvailableZonesResponseBodyData
func (*ListAvailableZonesResponseBodyData) SetZoneId ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBodyData) SetZoneId(v string) *ListAvailableZonesResponseBodyData
func (*ListAvailableZonesResponseBodyData) SetZoneName ¶ added in v1.2.0
func (s *ListAvailableZonesResponseBodyData) SetZoneName(v string) *ListAvailableZonesResponseBodyData
func (ListAvailableZonesResponseBodyData) String ¶ added in v1.2.0
func (s ListAvailableZonesResponseBodyData) String() string
type ListConsumerConnectionsResponse ¶ added in v1.3.0
type ListConsumerConnectionsResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *ListConsumerConnectionsResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (ListConsumerConnectionsResponse) GoString ¶ added in v1.3.0
func (s ListConsumerConnectionsResponse) GoString() string
func (*ListConsumerConnectionsResponse) SetBody ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponse) SetBody(v *ListConsumerConnectionsResponseBody) *ListConsumerConnectionsResponse
func (*ListConsumerConnectionsResponse) SetHeaders ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponse) SetHeaders(v map[string]*string) *ListConsumerConnectionsResponse
func (*ListConsumerConnectionsResponse) SetStatusCode ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponse) SetStatusCode(v int32) *ListConsumerConnectionsResponse
func (ListConsumerConnectionsResponse) String ¶ added in v1.3.0
func (s ListConsumerConnectionsResponse) String() string
type ListConsumerConnectionsResponseBody ¶ added in v1.3.0
type ListConsumerConnectionsResponseBody struct {
// example:
//
// MissingPageNumber
Code *string `json:"code,omitempty" xml:"code,omitempty"`
Data *ListConsumerConnectionsResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Struct"`
// example:
//
// InstanceId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// example:
//
// instanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// example:
//
// 200
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// example:
//
// The instance cannot be found.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// example:
//
// A3620115-6F1F-5CFB-AA3F-BBD4853B2EC4
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (ListConsumerConnectionsResponseBody) GoString ¶ added in v1.3.0
func (s ListConsumerConnectionsResponseBody) GoString() string
func (*ListConsumerConnectionsResponseBody) SetCode ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBody) SetCode(v string) *ListConsumerConnectionsResponseBody
func (*ListConsumerConnectionsResponseBody) SetDynamicCode ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBody) SetDynamicCode(v string) *ListConsumerConnectionsResponseBody
func (*ListConsumerConnectionsResponseBody) SetDynamicMessage ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBody) SetDynamicMessage(v string) *ListConsumerConnectionsResponseBody
func (*ListConsumerConnectionsResponseBody) SetHttpStatusCode ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBody) SetHttpStatusCode(v int32) *ListConsumerConnectionsResponseBody
func (*ListConsumerConnectionsResponseBody) SetMessage ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBody) SetMessage(v string) *ListConsumerConnectionsResponseBody
func (*ListConsumerConnectionsResponseBody) SetRequestId ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBody) SetRequestId(v string) *ListConsumerConnectionsResponseBody
func (*ListConsumerConnectionsResponseBody) SetSuccess ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBody) SetSuccess(v bool) *ListConsumerConnectionsResponseBody
func (ListConsumerConnectionsResponseBody) String ¶ added in v1.3.0
func (s ListConsumerConnectionsResponseBody) String() string
type ListConsumerConnectionsResponseBodyData ¶ added in v1.3.0
type ListConsumerConnectionsResponseBodyData struct {
Connections []*ListConsumerConnectionsResponseBodyDataConnections `json:"connections,omitempty" xml:"connections,omitempty" type:"Repeated"`
// example:
//
// CID-TEST
ConsumerGroupId *string `json:"consumerGroupId,omitempty" xml:"consumerGroupId,omitempty"`
// example:
//
// rmq-cn-7e22ody****
InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
// example:
//
// cn-hangzhou
RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
}
func (ListConsumerConnectionsResponseBodyData) GoString ¶ added in v1.3.0
func (s ListConsumerConnectionsResponseBodyData) GoString() string
func (*ListConsumerConnectionsResponseBodyData) SetConnections ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBodyData) SetConnections(v []*ListConsumerConnectionsResponseBodyDataConnections) *ListConsumerConnectionsResponseBodyData
func (*ListConsumerConnectionsResponseBodyData) SetConsumerGroupId ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBodyData) SetConsumerGroupId(v string) *ListConsumerConnectionsResponseBodyData
func (*ListConsumerConnectionsResponseBodyData) SetInstanceId ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBodyData) SetInstanceId(v string) *ListConsumerConnectionsResponseBodyData
func (*ListConsumerConnectionsResponseBodyData) SetRegionId ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBodyData) SetRegionId(v string) *ListConsumerConnectionsResponseBodyData
func (ListConsumerConnectionsResponseBodyData) String ¶ added in v1.3.0
func (s ListConsumerConnectionsResponseBodyData) String() string
type ListConsumerConnectionsResponseBodyDataConnections ¶ added in v1.3.0
type ListConsumerConnectionsResponseBodyDataConnections struct {
// example:
//
// 172.17.135.197@17392#1936705963#551717232#9873695589062458
ClientId *string `json:"clientId,omitempty" xml:"clientId,omitempty"`
// example:
//
// xx.xx.xx.xx
EgressIp *string `json:"egressIp,omitempty" xml:"egressIp,omitempty"`
// example:
//
// vos
Hostname *string `json:"hostname,omitempty" xml:"hostname,omitempty"`
// example:
//
// java
Language *string `json:"language,omitempty" xml:"language,omitempty"`
// example:
//
// BROADCASTING
MessageModel *string `json:"messageModel,omitempty" xml:"messageModel,omitempty"`
// example:
//
// 1.0
Version *string `json:"version,omitempty" xml:"version,omitempty"`
}
func (ListConsumerConnectionsResponseBodyDataConnections) GoString ¶ added in v1.3.0
func (s ListConsumerConnectionsResponseBodyDataConnections) GoString() string
func (*ListConsumerConnectionsResponseBodyDataConnections) SetClientId ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBodyDataConnections) SetClientId(v string) *ListConsumerConnectionsResponseBodyDataConnections
func (*ListConsumerConnectionsResponseBodyDataConnections) SetEgressIp ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBodyDataConnections) SetEgressIp(v string) *ListConsumerConnectionsResponseBodyDataConnections
func (*ListConsumerConnectionsResponseBodyDataConnections) SetHostname ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBodyDataConnections) SetHostname(v string) *ListConsumerConnectionsResponseBodyDataConnections
func (*ListConsumerConnectionsResponseBodyDataConnections) SetLanguage ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBodyDataConnections) SetLanguage(v string) *ListConsumerConnectionsResponseBodyDataConnections
func (*ListConsumerConnectionsResponseBodyDataConnections) SetMessageModel ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBodyDataConnections) SetMessageModel(v string) *ListConsumerConnectionsResponseBodyDataConnections
func (*ListConsumerConnectionsResponseBodyDataConnections) SetVersion ¶ added in v1.3.0
func (s *ListConsumerConnectionsResponseBodyDataConnections) SetVersion(v string) *ListConsumerConnectionsResponseBodyDataConnections
func (ListConsumerConnectionsResponseBodyDataConnections) String ¶ added in v1.3.0
func (s ListConsumerConnectionsResponseBodyDataConnections) String() string
type ListConsumerGroupSubscriptionsResponse ¶ added in v1.1.0
type ListConsumerGroupSubscriptionsResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *ListConsumerGroupSubscriptionsResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (ListConsumerGroupSubscriptionsResponse) GoString ¶ added in v1.1.0
func (s ListConsumerGroupSubscriptionsResponse) GoString() string
func (*ListConsumerGroupSubscriptionsResponse) SetHeaders ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponse) SetHeaders(v map[string]*string) *ListConsumerGroupSubscriptionsResponse
func (*ListConsumerGroupSubscriptionsResponse) SetStatusCode ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponse) SetStatusCode(v int32) *ListConsumerGroupSubscriptionsResponse
func (ListConsumerGroupSubscriptionsResponse) String ¶ added in v1.1.0
func (s ListConsumerGroupSubscriptionsResponse) String() string
type ListConsumerGroupSubscriptionsResponseBody ¶ added in v1.1.0
type ListConsumerGroupSubscriptionsResponseBody struct {
// The returned error code.
//
// example:
//
// MissingInstanceId
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The returned data.
Data []*ListConsumerGroupSubscriptionsResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Repeated"`
// The returned dynamic error code.
//
// example:
//
// InstanceId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The returned dynamic error message.
//
// example:
//
// InstanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The returned HTTP status code.
//
// example:
//
// 200
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The returned error message.
//
// example:
//
// Parameter instanceId is mandatory for this action .
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The request ID.
//
// example:
//
// 5F4D9D5F-625B-59FF-BD4F-DA8284575DB4
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the request is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (ListConsumerGroupSubscriptionsResponseBody) GoString ¶ added in v1.1.0
func (s ListConsumerGroupSubscriptionsResponseBody) GoString() string
func (*ListConsumerGroupSubscriptionsResponseBody) SetCode ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBody) SetCode(v string) *ListConsumerGroupSubscriptionsResponseBody
func (*ListConsumerGroupSubscriptionsResponseBody) SetDynamicCode ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBody) SetDynamicCode(v string) *ListConsumerGroupSubscriptionsResponseBody
func (*ListConsumerGroupSubscriptionsResponseBody) SetDynamicMessage ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBody) SetDynamicMessage(v string) *ListConsumerGroupSubscriptionsResponseBody
func (*ListConsumerGroupSubscriptionsResponseBody) SetHttpStatusCode ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBody) SetHttpStatusCode(v int32) *ListConsumerGroupSubscriptionsResponseBody
func (*ListConsumerGroupSubscriptionsResponseBody) SetMessage ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBody) SetMessage(v string) *ListConsumerGroupSubscriptionsResponseBody
func (*ListConsumerGroupSubscriptionsResponseBody) SetRequestId ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBody) SetRequestId(v string) *ListConsumerGroupSubscriptionsResponseBody
func (*ListConsumerGroupSubscriptionsResponseBody) SetSuccess ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBody) SetSuccess(v bool) *ListConsumerGroupSubscriptionsResponseBody
func (ListConsumerGroupSubscriptionsResponseBody) String ¶ added in v1.1.0
func (s ListConsumerGroupSubscriptionsResponseBody) String() string
type ListConsumerGroupSubscriptionsResponseBodyData ¶ added in v1.1.0
type ListConsumerGroupSubscriptionsResponseBodyData struct {
Consistency *bool `json:"consistency,omitempty" xml:"consistency,omitempty"`
// The consumer group ID.
//
// example:
//
// CID-TEST
ConsumerGroupId *string `json:"consumerGroupId,omitempty" xml:"consumerGroupId,omitempty"`
// The filter expression.
//
// example:
//
// *
FilterExpression *string `json:"filterExpression,omitempty" xml:"filterExpression,omitempty"`
// The type of the filter expression. Valid values: SQL, TAG, and UNSPECIFIED.
//
// example:
//
// SQL
FilterExpressionType *string `json:"filterExpressionType,omitempty" xml:"filterExpressionType,omitempty"`
// The consumption mode. Valid values: BROADCASTING and CLUSTERING.
//
// example:
//
// BROADCASTING
MessageModel *string `json:"messageModel,omitempty" xml:"messageModel,omitempty"`
// The subscription status. Valid values: ONLINE and OFFLINE.
//
// example:
//
// ONLINE
SubscriptionStatus *string `json:"subscriptionStatus,omitempty" xml:"subscriptionStatus,omitempty"`
// Indicates whether the topic is created.
//
// example:
//
// true
TopicCreated *bool `json:"topicCreated,omitempty" xml:"topicCreated,omitempty"`
// The topic to which the consumer group subscribes.
//
// example:
//
// topic_test
TopicName *string `json:"topicName,omitempty" xml:"topicName,omitempty"`
}
func (ListConsumerGroupSubscriptionsResponseBodyData) GoString ¶ added in v1.1.0
func (s ListConsumerGroupSubscriptionsResponseBodyData) GoString() string
func (*ListConsumerGroupSubscriptionsResponseBodyData) SetConsistency ¶ added in v1.4.2
func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetConsistency(v bool) *ListConsumerGroupSubscriptionsResponseBodyData
func (*ListConsumerGroupSubscriptionsResponseBodyData) SetConsumerGroupId ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetConsumerGroupId(v string) *ListConsumerGroupSubscriptionsResponseBodyData
func (*ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpression ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpression(v string) *ListConsumerGroupSubscriptionsResponseBodyData
func (*ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpressionType ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpressionType(v string) *ListConsumerGroupSubscriptionsResponseBodyData
func (*ListConsumerGroupSubscriptionsResponseBodyData) SetMessageModel ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetMessageModel(v string) *ListConsumerGroupSubscriptionsResponseBodyData
func (*ListConsumerGroupSubscriptionsResponseBodyData) SetSubscriptionStatus ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetSubscriptionStatus(v string) *ListConsumerGroupSubscriptionsResponseBodyData
func (*ListConsumerGroupSubscriptionsResponseBodyData) SetTopicCreated ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetTopicCreated(v bool) *ListConsumerGroupSubscriptionsResponseBodyData
func (*ListConsumerGroupSubscriptionsResponseBodyData) SetTopicName ¶ added in v1.1.0
func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetTopicName(v string) *ListConsumerGroupSubscriptionsResponseBodyData
func (ListConsumerGroupSubscriptionsResponseBodyData) String ¶ added in v1.1.0
func (s ListConsumerGroupSubscriptionsResponseBodyData) String() string
type ListConsumerGroupsRequest ¶
type ListConsumerGroupsRequest struct {
// The condition that you want to use to filter consumer groups in the instance. If you leave this parameter empty, all consumer groups in the instance are queried.
//
// example:
//
// CID-TEST
Filter *string `json:"filter,omitempty" xml:"filter,omitempty"`
// The number of the page to return.
//
// This parameter is required.
//
// example:
//
// 1
PageNumber *int32 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
// The number of entries to return on each page.
//
// This parameter is required.
//
// example:
//
// 10
PageSize *int32 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
}
func (ListConsumerGroupsRequest) GoString ¶
func (s ListConsumerGroupsRequest) GoString() string
func (*ListConsumerGroupsRequest) SetFilter ¶
func (s *ListConsumerGroupsRequest) SetFilter(v string) *ListConsumerGroupsRequest
func (*ListConsumerGroupsRequest) SetPageNumber ¶
func (s *ListConsumerGroupsRequest) SetPageNumber(v int32) *ListConsumerGroupsRequest
func (*ListConsumerGroupsRequest) SetPageSize ¶
func (s *ListConsumerGroupsRequest) SetPageSize(v int32) *ListConsumerGroupsRequest
func (ListConsumerGroupsRequest) String ¶
func (s ListConsumerGroupsRequest) String() string
type ListConsumerGroupsResponse ¶
type ListConsumerGroupsResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *ListConsumerGroupsResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (ListConsumerGroupsResponse) GoString ¶
func (s ListConsumerGroupsResponse) GoString() string
func (*ListConsumerGroupsResponse) SetBody ¶
func (s *ListConsumerGroupsResponse) SetBody(v *ListConsumerGroupsResponseBody) *ListConsumerGroupsResponse
func (*ListConsumerGroupsResponse) SetHeaders ¶
func (s *ListConsumerGroupsResponse) SetHeaders(v map[string]*string) *ListConsumerGroupsResponse
func (*ListConsumerGroupsResponse) SetStatusCode ¶
func (s *ListConsumerGroupsResponse) SetStatusCode(v int32) *ListConsumerGroupsResponse
func (ListConsumerGroupsResponse) String ¶
func (s ListConsumerGroupsResponse) String() string
type ListConsumerGroupsResponseBody ¶
type ListConsumerGroupsResponseBody struct {
// The error code.
//
// example:
//
// MissingInstanceId
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The result data that is returned.
Data *ListConsumerGroupsResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Struct"`
// The dynamic error code.
//
// example:
//
// InstanceId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// instanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// Parameter InstanceId is mandatory for this action .
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. The system generates a unique ID for each request. You can troubleshoot issues based on the request ID.
//
// example:
//
// 5503A460-98ED-5543-92CF-4853DE28****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (ListConsumerGroupsResponseBody) GoString ¶
func (s ListConsumerGroupsResponseBody) GoString() string
func (*ListConsumerGroupsResponseBody) SetCode ¶
func (s *ListConsumerGroupsResponseBody) SetCode(v string) *ListConsumerGroupsResponseBody
func (*ListConsumerGroupsResponseBody) SetData ¶
func (s *ListConsumerGroupsResponseBody) SetData(v *ListConsumerGroupsResponseBodyData) *ListConsumerGroupsResponseBody
func (*ListConsumerGroupsResponseBody) SetDynamicCode ¶
func (s *ListConsumerGroupsResponseBody) SetDynamicCode(v string) *ListConsumerGroupsResponseBody
func (*ListConsumerGroupsResponseBody) SetDynamicMessage ¶
func (s *ListConsumerGroupsResponseBody) SetDynamicMessage(v string) *ListConsumerGroupsResponseBody
func (*ListConsumerGroupsResponseBody) SetHttpStatusCode ¶
func (s *ListConsumerGroupsResponseBody) SetHttpStatusCode(v int32) *ListConsumerGroupsResponseBody
func (*ListConsumerGroupsResponseBody) SetMessage ¶
func (s *ListConsumerGroupsResponseBody) SetMessage(v string) *ListConsumerGroupsResponseBody
func (*ListConsumerGroupsResponseBody) SetRequestId ¶
func (s *ListConsumerGroupsResponseBody) SetRequestId(v string) *ListConsumerGroupsResponseBody
func (*ListConsumerGroupsResponseBody) SetSuccess ¶
func (s *ListConsumerGroupsResponseBody) SetSuccess(v bool) *ListConsumerGroupsResponseBody
func (ListConsumerGroupsResponseBody) String ¶
func (s ListConsumerGroupsResponseBody) String() string
type ListConsumerGroupsResponseBodyData ¶
type ListConsumerGroupsResponseBodyData struct {
// The paginated data.
List []*ListConsumerGroupsResponseBodyDataList `json:"list,omitempty" xml:"list,omitempty" type:"Repeated"`
// The page number of the returned page.
//
// example:
//
// 1
PageNumber *int64 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
// The number of entries returned per page.
//
// example:
//
// 10
PageSize *int64 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
// The total number of returned entries.
//
// example:
//
// 1
TotalCount *int64 `json:"totalCount,omitempty" xml:"totalCount,omitempty"`
}
func (ListConsumerGroupsResponseBodyData) GoString ¶
func (s ListConsumerGroupsResponseBodyData) GoString() string
func (*ListConsumerGroupsResponseBodyData) SetList ¶
func (s *ListConsumerGroupsResponseBodyData) SetList(v []*ListConsumerGroupsResponseBodyDataList) *ListConsumerGroupsResponseBodyData
func (*ListConsumerGroupsResponseBodyData) SetPageNumber ¶
func (s *ListConsumerGroupsResponseBodyData) SetPageNumber(v int64) *ListConsumerGroupsResponseBodyData
func (*ListConsumerGroupsResponseBodyData) SetPageSize ¶
func (s *ListConsumerGroupsResponseBodyData) SetPageSize(v int64) *ListConsumerGroupsResponseBodyData
func (*ListConsumerGroupsResponseBodyData) SetTotalCount ¶
func (s *ListConsumerGroupsResponseBodyData) SetTotalCount(v int64) *ListConsumerGroupsResponseBodyData
func (ListConsumerGroupsResponseBodyData) String ¶
func (s ListConsumerGroupsResponseBodyData) String() string
type ListConsumerGroupsResponseBodyDataList ¶
type ListConsumerGroupsResponseBodyDataList struct {
// The ID of the consumer group.
//
// example:
//
// GID-TEST
ConsumerGroupId *string `json:"consumerGroupId,omitempty" xml:"consumerGroupId,omitempty"`
// The time when the consumer group was created.
//
// example:
//
// 2022-08-01 20:05:50
CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
// The ID of the instance.
//
// example:
//
// rmq-cn-7e22ody****
InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
// The ID of the region in which the instance resides.
//
// example:
//
// cn-hangzhou
RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
// The remarks on the consumer group.
//
// example:
//
// This is the remark for test.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
// The state of the consumer group.
//
// Valid values:
//
// - RUNNING
//
// <!-- -->
//
// : The consumer group is
//
// <!-- -->
//
// running
//
// <!-- -->
//
// .
//
// - CREATING
//
// <!-- -->
//
// : The consumer group is
//
// <!-- -->
//
// being created
//
// <!-- -->
//
// .
//
// example:
//
// RUNNING
Status *string `json:"status,omitempty" xml:"status,omitempty"`
// The time when the consumer group was last updated.
//
// example:
//
// 2022-08-01 20:05:50
UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
}
func (ListConsumerGroupsResponseBodyDataList) GoString ¶
func (s ListConsumerGroupsResponseBodyDataList) GoString() string
func (*ListConsumerGroupsResponseBodyDataList) SetConsumerGroupId ¶
func (s *ListConsumerGroupsResponseBodyDataList) SetConsumerGroupId(v string) *ListConsumerGroupsResponseBodyDataList
func (*ListConsumerGroupsResponseBodyDataList) SetCreateTime ¶
func (s *ListConsumerGroupsResponseBodyDataList) SetCreateTime(v string) *ListConsumerGroupsResponseBodyDataList
func (*ListConsumerGroupsResponseBodyDataList) SetInstanceId ¶
func (s *ListConsumerGroupsResponseBodyDataList) SetInstanceId(v string) *ListConsumerGroupsResponseBodyDataList
func (*ListConsumerGroupsResponseBodyDataList) SetRegionId ¶
func (s *ListConsumerGroupsResponseBodyDataList) SetRegionId(v string) *ListConsumerGroupsResponseBodyDataList
func (*ListConsumerGroupsResponseBodyDataList) SetRemark ¶
func (s *ListConsumerGroupsResponseBodyDataList) SetRemark(v string) *ListConsumerGroupsResponseBodyDataList
func (*ListConsumerGroupsResponseBodyDataList) SetStatus ¶
func (s *ListConsumerGroupsResponseBodyDataList) SetStatus(v string) *ListConsumerGroupsResponseBodyDataList
func (*ListConsumerGroupsResponseBodyDataList) SetUpdateTime ¶
func (s *ListConsumerGroupsResponseBodyDataList) SetUpdateTime(v string) *ListConsumerGroupsResponseBodyDataList
func (ListConsumerGroupsResponseBodyDataList) String ¶
func (s ListConsumerGroupsResponseBodyDataList) String() string
type ListInstancesRequest ¶
type ListInstancesRequest struct {
// The filter condition that is used to query instances. If you do not configure this parameter, all instances are queried.
//
// example:
//
// rmq-cn-7e22ody****
Filter *string `json:"filter,omitempty" xml:"filter,omitempty"`
// The number of the page to return.
//
// Valid values: 1 to 100000000.
//
// If the value that you specify for this parameter is less than 1, the system uses 1 as the value. If the value that you specify for this parameter is greater than 100000000, the system uses 100000000 as the value.
//
// example:
//
// 1
PageNumber *int32 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
// The number of entries returned on each page.
//
// Valid values: 10 to 200.
//
// If the value that you specify for this parameter is less than 10, the system uses 10 as the value. If the value that you specify for this parameter is greater than 200, the system uses 200 as the value.
//
// example:
//
// 10
PageSize *int32 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
// The ID of the resource group to which the instance belongs.
//
// example:
//
// rg-acfmx7caj******
ResourceGroupId *string `json:"resourceGroupId,omitempty" xml:"resourceGroupId,omitempty"`
SeriesCodes []*string `json:"seriesCodes,omitempty" xml:"seriesCodes,omitempty" type:"Repeated"`
// The tags that are used to filter instances.
//
// example:
//
// [{"key": "rmq-test", "value": "test"}]
Tags *string `json:"tags,omitempty" xml:"tags,omitempty"`
}
func (ListInstancesRequest) GoString ¶
func (s ListInstancesRequest) GoString() string
func (*ListInstancesRequest) SetFilter ¶
func (s *ListInstancesRequest) SetFilter(v string) *ListInstancesRequest
func (*ListInstancesRequest) SetPageNumber ¶
func (s *ListInstancesRequest) SetPageNumber(v int32) *ListInstancesRequest
func (*ListInstancesRequest) SetPageSize ¶
func (s *ListInstancesRequest) SetPageSize(v int32) *ListInstancesRequest
func (*ListInstancesRequest) SetResourceGroupId ¶
func (s *ListInstancesRequest) SetResourceGroupId(v string) *ListInstancesRequest
func (*ListInstancesRequest) SetSeriesCodes ¶ added in v1.4.5
func (s *ListInstancesRequest) SetSeriesCodes(v []*string) *ListInstancesRequest
func (*ListInstancesRequest) SetTags ¶ added in v1.1.0
func (s *ListInstancesRequest) SetTags(v string) *ListInstancesRequest
func (ListInstancesRequest) String ¶
func (s ListInstancesRequest) String() string
type ListInstancesResponse ¶
type ListInstancesResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *ListInstancesResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (ListInstancesResponse) GoString ¶
func (s ListInstancesResponse) GoString() string
func (*ListInstancesResponse) SetBody ¶
func (s *ListInstancesResponse) SetBody(v *ListInstancesResponseBody) *ListInstancesResponse
func (*ListInstancesResponse) SetHeaders ¶
func (s *ListInstancesResponse) SetHeaders(v map[string]*string) *ListInstancesResponse
func (*ListInstancesResponse) SetStatusCode ¶
func (s *ListInstancesResponse) SetStatusCode(v int32) *ListInstancesResponse
func (ListInstancesResponse) String ¶
func (s ListInstancesResponse) String() string
type ListInstancesResponseBody ¶
type ListInstancesResponseBody struct {
// The error code returned if the call failed.
//
// example:
//
// MissingPageNumber
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The returned data.
Data *ListInstancesResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Struct"`
// The dynamic error code.
//
// example:
//
// PageNumber
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// pageNumber
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code returned.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// Parameter pageNumber is mandatory for this action .
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. Each request has a unique ID. You can use this ID to troubleshoot issues.
//
// example:
//
// 84445A20-2B50-5306-A3C0-AF99FC1833C6
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call was successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (ListInstancesResponseBody) GoString ¶
func (s ListInstancesResponseBody) GoString() string
func (*ListInstancesResponseBody) SetCode ¶
func (s *ListInstancesResponseBody) SetCode(v string) *ListInstancesResponseBody
func (*ListInstancesResponseBody) SetData ¶
func (s *ListInstancesResponseBody) SetData(v *ListInstancesResponseBodyData) *ListInstancesResponseBody
func (*ListInstancesResponseBody) SetDynamicCode ¶
func (s *ListInstancesResponseBody) SetDynamicCode(v string) *ListInstancesResponseBody
func (*ListInstancesResponseBody) SetDynamicMessage ¶
func (s *ListInstancesResponseBody) SetDynamicMessage(v string) *ListInstancesResponseBody
func (*ListInstancesResponseBody) SetHttpStatusCode ¶
func (s *ListInstancesResponseBody) SetHttpStatusCode(v int32) *ListInstancesResponseBody
func (*ListInstancesResponseBody) SetMessage ¶
func (s *ListInstancesResponseBody) SetMessage(v string) *ListInstancesResponseBody
func (*ListInstancesResponseBody) SetRequestId ¶
func (s *ListInstancesResponseBody) SetRequestId(v string) *ListInstancesResponseBody
func (*ListInstancesResponseBody) SetSuccess ¶
func (s *ListInstancesResponseBody) SetSuccess(v bool) *ListInstancesResponseBody
func (ListInstancesResponseBody) String ¶
func (s ListInstancesResponseBody) String() string
type ListInstancesResponseBodyData ¶
type ListInstancesResponseBodyData struct {
// The paginated data.
List []*ListInstancesResponseBodyDataList `json:"list,omitempty" xml:"list,omitempty" type:"Repeated"`
// The page number of the returned page.
//
// example:
//
// 1
PageNumber *int64 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
// The number of entries returned on each page.
//
// example:
//
// 10
PageSize *int64 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
// The total number of returned entries.
//
// example:
//
// 100
TotalCount *int64 `json:"totalCount,omitempty" xml:"totalCount,omitempty"`
}
func (ListInstancesResponseBodyData) GoString ¶
func (s ListInstancesResponseBodyData) GoString() string
func (*ListInstancesResponseBodyData) SetList ¶
func (s *ListInstancesResponseBodyData) SetList(v []*ListInstancesResponseBodyDataList) *ListInstancesResponseBodyData
func (*ListInstancesResponseBodyData) SetPageNumber ¶
func (s *ListInstancesResponseBodyData) SetPageNumber(v int64) *ListInstancesResponseBodyData
func (*ListInstancesResponseBodyData) SetPageSize ¶
func (s *ListInstancesResponseBodyData) SetPageSize(v int64) *ListInstancesResponseBodyData
func (*ListInstancesResponseBodyData) SetTotalCount ¶
func (s *ListInstancesResponseBodyData) SetTotalCount(v int64) *ListInstancesResponseBodyData
func (ListInstancesResponseBodyData) String ¶
func (s ListInstancesResponseBodyData) String() string
type ListInstancesResponseBodyDataList ¶
type ListInstancesResponseBodyDataList struct {
// The commodity code of the instance. The commodity code of ApsaraMQ for RocketMQ 5.0 instances has a similar format to ons_rmqsub_public_cn.
//
// example:
//
// ons_rmqsub_public_cn
CommodityCode *string `json:"commodityCode,omitempty" xml:"commodityCode,omitempty"`
// The time when the instance was created.
//
// example:
//
// 2022-08-01 00:00:00
CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
// The time when the instance expires.
//
// example:
//
// 2022-09-01 00:00:00
ExpireTime *string `json:"expireTime,omitempty" xml:"expireTime,omitempty"`
// The number of consumer groups that are created on the instance.
//
// example:
//
// 10
GroupCount *int64 `json:"groupCount,omitempty" xml:"groupCount,omitempty"`
// The instance ID.
//
// example:
//
// rmq-cn-7e22ody****
InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
// The instance name.
//
// example:
//
// test instance
InstanceName *string `json:"instanceName,omitempty" xml:"instanceName,omitempty"`
// The billing method of the instance.
//
// Valid values:
//
// - PayAsYouGo
//
// - Subscription
//
// example:
//
// Subscription
PaymentType *string `json:"paymentType,omitempty" xml:"paymentType,omitempty"`
// The product information of instance.
ProductInfo *ListInstancesResponseBodyDataListProductInfo `json:"productInfo,omitempty" xml:"productInfo,omitempty" type:"Struct"`
// The ID of the region in which the instance resides.
//
// example:
//
// cn-hangzhou
RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
// The time when the instance was released.
//
// example:
//
// 2022-09-07 00:00:00
ReleaseTime *string `json:"releaseTime,omitempty" xml:"releaseTime,omitempty"`
// The instance description.
//
// example:
//
// This is remark for instance.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
// The ID of the resource group to which the instance belongs.
//
// example:
//
// rg-acfmx7caj******
ResourceGroupId *string `json:"resourceGroupId,omitempty" xml:"resourceGroupId,omitempty"`
// The primary edition of the instance.
//
// Valid values:
//
// - standard: Standard Edition
//
// - ultimate: Enterprise Platinum Edition
//
// - professional: Professional Edition
//
// example:
//
// standard
SeriesCode *string `json:"seriesCode,omitempty" xml:"seriesCode,omitempty"`
// The code of the service to which the instance belongs. The service code of ApsaraMQ for RocketMQ is rmq.
//
// example:
//
// rmq
ServiceCode *string `json:"serviceCode,omitempty" xml:"serviceCode,omitempty"`
// The time when the instance was started.
//
// example:
//
// 2022-08-01 00:00:00
StartTime *string `json:"startTime,omitempty" xml:"startTime,omitempty"`
// The instance status.
//
// Valid values:
//
// - RELEASED
//
// - RUNNING
//
// - STOPPED
//
// - CHANGING
//
// - CREATING
//
// example:
//
// RUNNING
Status *string `json:"status,omitempty" xml:"status,omitempty"`
// The sub-category edition of the instance.
//
// Valid values:
//
// - cluster_ha: Cluster High-availability Edition
//
// - single_node: Standalone Edition
//
// example:
//
// cluster_ha
SubSeriesCode *string `json:"subSeriesCode,omitempty" xml:"subSeriesCode,omitempty"`
// The resource tags.
Tags []*ListInstancesResponseBodyDataListTags `json:"tags,omitempty" xml:"tags,omitempty" type:"Repeated"`
// The number of topics that are created on the instance.
//
// example:
//
// 20
TopicCount *int64 `json:"topicCount,omitempty" xml:"topicCount,omitempty"`
// The time when the instance was last modified.
//
// example:
//
// 2022-08-02 00:00:00
UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
// The ID of the user who owns the instance.
//
// example:
//
// 6W0xz2uPfiwp****
UserId *string `json:"userId,omitempty" xml:"userId,omitempty"`
}
func (ListInstancesResponseBodyDataList) GoString ¶
func (s ListInstancesResponseBodyDataList) GoString() string
func (*ListInstancesResponseBodyDataList) SetCommodityCode ¶
func (s *ListInstancesResponseBodyDataList) SetCommodityCode(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetCreateTime ¶
func (s *ListInstancesResponseBodyDataList) SetCreateTime(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetExpireTime ¶
func (s *ListInstancesResponseBodyDataList) SetExpireTime(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetGroupCount ¶
func (s *ListInstancesResponseBodyDataList) SetGroupCount(v int64) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetInstanceId ¶
func (s *ListInstancesResponseBodyDataList) SetInstanceId(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetInstanceName ¶
func (s *ListInstancesResponseBodyDataList) SetInstanceName(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetPaymentType ¶
func (s *ListInstancesResponseBodyDataList) SetPaymentType(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetProductInfo ¶ added in v1.1.2
func (s *ListInstancesResponseBodyDataList) SetProductInfo(v *ListInstancesResponseBodyDataListProductInfo) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetRegionId ¶
func (s *ListInstancesResponseBodyDataList) SetRegionId(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetReleaseTime ¶
func (s *ListInstancesResponseBodyDataList) SetReleaseTime(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetRemark ¶
func (s *ListInstancesResponseBodyDataList) SetRemark(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetResourceGroupId ¶
func (s *ListInstancesResponseBodyDataList) SetResourceGroupId(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetSeriesCode ¶
func (s *ListInstancesResponseBodyDataList) SetSeriesCode(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetServiceCode ¶
func (s *ListInstancesResponseBodyDataList) SetServiceCode(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetStartTime ¶
func (s *ListInstancesResponseBodyDataList) SetStartTime(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetStatus ¶
func (s *ListInstancesResponseBodyDataList) SetStatus(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetSubSeriesCode ¶
func (s *ListInstancesResponseBodyDataList) SetSubSeriesCode(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetTags ¶ added in v1.1.0
func (s *ListInstancesResponseBodyDataList) SetTags(v []*ListInstancesResponseBodyDataListTags) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetTopicCount ¶
func (s *ListInstancesResponseBodyDataList) SetTopicCount(v int64) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetUpdateTime ¶
func (s *ListInstancesResponseBodyDataList) SetUpdateTime(v string) *ListInstancesResponseBodyDataList
func (*ListInstancesResponseBodyDataList) SetUserId ¶
func (s *ListInstancesResponseBodyDataList) SetUserId(v string) *ListInstancesResponseBodyDataList
func (ListInstancesResponseBodyDataList) String ¶
func (s ListInstancesResponseBodyDataList) String() string
type ListInstancesResponseBodyDataListProductInfo ¶ added in v1.1.2
type ListInstancesResponseBodyDataListProductInfo struct {
// Whether to enable tracking capability. Non-serverless instances are enabled by default, and serverless instances are optional for users.
//
// example:
//
// true
TraceOn *bool `json:"traceOn,omitempty" xml:"traceOn,omitempty"`
}
func (ListInstancesResponseBodyDataListProductInfo) GoString ¶ added in v1.1.2
func (s ListInstancesResponseBodyDataListProductInfo) GoString() string
func (*ListInstancesResponseBodyDataListProductInfo) SetTraceOn ¶ added in v1.1.2
func (s *ListInstancesResponseBodyDataListProductInfo) SetTraceOn(v bool) *ListInstancesResponseBodyDataListProductInfo
func (ListInstancesResponseBodyDataListProductInfo) String ¶ added in v1.1.2
func (s ListInstancesResponseBodyDataListProductInfo) String() string
type ListInstancesResponseBodyDataListTags ¶ added in v1.1.0
type ListInstancesResponseBodyDataListTags struct {
// The tag key of the resource.
//
// example:
//
// key
Key *string `json:"key,omitempty" xml:"key,omitempty"`
// The tag value of the resource.
//
// example:
//
// value
Value *string `json:"value,omitempty" xml:"value,omitempty"`
}
func (ListInstancesResponseBodyDataListTags) GoString ¶ added in v1.1.0
func (s ListInstancesResponseBodyDataListTags) GoString() string
func (*ListInstancesResponseBodyDataListTags) SetKey ¶ added in v1.1.0
func (s *ListInstancesResponseBodyDataListTags) SetKey(v string) *ListInstancesResponseBodyDataListTags
func (*ListInstancesResponseBodyDataListTags) SetValue ¶ added in v1.1.0
func (s *ListInstancesResponseBodyDataListTags) SetValue(v string) *ListInstancesResponseBodyDataListTags
func (ListInstancesResponseBodyDataListTags) String ¶ added in v1.1.0
func (s ListInstancesResponseBodyDataListTags) String() string
type ListInstancesShrinkRequest ¶ added in v1.4.5
type ListInstancesShrinkRequest struct {
// The filter condition that is used to query instances. If you do not configure this parameter, all instances are queried.
//
// example:
//
// rmq-cn-7e22ody****
Filter *string `json:"filter,omitempty" xml:"filter,omitempty"`
// The number of the page to return.
//
// Valid values: 1 to 100000000.
//
// If the value that you specify for this parameter is less than 1, the system uses 1 as the value. If the value that you specify for this parameter is greater than 100000000, the system uses 100000000 as the value.
//
// example:
//
// 1
PageNumber *int32 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
// The number of entries returned on each page.
//
// Valid values: 10 to 200.
//
// If the value that you specify for this parameter is less than 10, the system uses 10 as the value. If the value that you specify for this parameter is greater than 200, the system uses 200 as the value.
//
// example:
//
// 10
PageSize *int32 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
// The ID of the resource group to which the instance belongs.
//
// example:
//
// rg-acfmx7caj******
ResourceGroupId *string `json:"resourceGroupId,omitempty" xml:"resourceGroupId,omitempty"`
SeriesCodesShrink *string `json:"seriesCodes,omitempty" xml:"seriesCodes,omitempty"`
// The tags that are used to filter instances.
//
// example:
//
// [{"key": "rmq-test", "value": "test"}]
Tags *string `json:"tags,omitempty" xml:"tags,omitempty"`
}
func (ListInstancesShrinkRequest) GoString ¶ added in v1.4.5
func (s ListInstancesShrinkRequest) GoString() string
func (*ListInstancesShrinkRequest) SetFilter ¶ added in v1.4.5
func (s *ListInstancesShrinkRequest) SetFilter(v string) *ListInstancesShrinkRequest
func (*ListInstancesShrinkRequest) SetPageNumber ¶ added in v1.4.5
func (s *ListInstancesShrinkRequest) SetPageNumber(v int32) *ListInstancesShrinkRequest
func (*ListInstancesShrinkRequest) SetPageSize ¶ added in v1.4.5
func (s *ListInstancesShrinkRequest) SetPageSize(v int32) *ListInstancesShrinkRequest
func (*ListInstancesShrinkRequest) SetResourceGroupId ¶ added in v1.4.5
func (s *ListInstancesShrinkRequest) SetResourceGroupId(v string) *ListInstancesShrinkRequest
func (*ListInstancesShrinkRequest) SetSeriesCodesShrink ¶ added in v1.4.5
func (s *ListInstancesShrinkRequest) SetSeriesCodesShrink(v string) *ListInstancesShrinkRequest
func (*ListInstancesShrinkRequest) SetTags ¶ added in v1.4.5
func (s *ListInstancesShrinkRequest) SetTags(v string) *ListInstancesShrinkRequest
func (ListInstancesShrinkRequest) String ¶ added in v1.4.5
func (s ListInstancesShrinkRequest) String() string
type ListRegionsResponse ¶ added in v1.2.0
type ListRegionsResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *ListRegionsResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (ListRegionsResponse) GoString ¶ added in v1.2.0
func (s ListRegionsResponse) GoString() string
func (*ListRegionsResponse) SetBody ¶ added in v1.2.0
func (s *ListRegionsResponse) SetBody(v *ListRegionsResponseBody) *ListRegionsResponse
func (*ListRegionsResponse) SetHeaders ¶ added in v1.2.0
func (s *ListRegionsResponse) SetHeaders(v map[string]*string) *ListRegionsResponse
func (*ListRegionsResponse) SetStatusCode ¶ added in v1.2.0
func (s *ListRegionsResponse) SetStatusCode(v int32) *ListRegionsResponse
func (ListRegionsResponse) String ¶ added in v1.2.0
func (s ListRegionsResponse) String() string
type ListRegionsResponseBody ¶ added in v1.2.0
type ListRegionsResponseBody struct {
// example:
//
// MissingPageNumber
Code *string `json:"code,omitempty" xml:"code,omitempty"`
Data []*ListRegionsResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Repeated"`
// example:
//
// ConsumerGroupId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// example:
//
// instanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// example:
//
// 200
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// example:
//
// Parameter instanceId is mandatory for this action .
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// example:
//
// 0B962390-D84B-5D44-8C11-79DF40299D41
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (ListRegionsResponseBody) GoString ¶ added in v1.2.0
func (s ListRegionsResponseBody) GoString() string
func (*ListRegionsResponseBody) SetCode ¶ added in v1.2.0
func (s *ListRegionsResponseBody) SetCode(v string) *ListRegionsResponseBody
func (*ListRegionsResponseBody) SetData ¶ added in v1.2.0
func (s *ListRegionsResponseBody) SetData(v []*ListRegionsResponseBodyData) *ListRegionsResponseBody
func (*ListRegionsResponseBody) SetDynamicCode ¶ added in v1.2.0
func (s *ListRegionsResponseBody) SetDynamicCode(v string) *ListRegionsResponseBody
func (*ListRegionsResponseBody) SetDynamicMessage ¶ added in v1.2.0
func (s *ListRegionsResponseBody) SetDynamicMessage(v string) *ListRegionsResponseBody
func (*ListRegionsResponseBody) SetHttpStatusCode ¶ added in v1.2.0
func (s *ListRegionsResponseBody) SetHttpStatusCode(v int32) *ListRegionsResponseBody
func (*ListRegionsResponseBody) SetMessage ¶ added in v1.2.0
func (s *ListRegionsResponseBody) SetMessage(v string) *ListRegionsResponseBody
func (*ListRegionsResponseBody) SetRequestId ¶ added in v1.2.0
func (s *ListRegionsResponseBody) SetRequestId(v string) *ListRegionsResponseBody
func (*ListRegionsResponseBody) SetSuccess ¶ added in v1.2.0
func (s *ListRegionsResponseBody) SetSuccess(v bool) *ListRegionsResponseBody
func (ListRegionsResponseBody) String ¶ added in v1.2.0
func (s ListRegionsResponseBody) String() string
type ListRegionsResponseBodyData ¶ added in v1.2.0
type ListRegionsResponseBodyData struct {
// example:
//
// 2022-08-01 20:05:50
CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
// example:
//
// cn-hangzhou
RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
RegionName *string `json:"regionName,omitempty" xml:"regionName,omitempty"`
// example:
//
// true
SupportRocketmqV4 *bool `json:"supportRocketmqV4,omitempty" xml:"supportRocketmqV4,omitempty"`
// example:
//
// true
SupportRocketmqV5 *bool `json:"supportRocketmqV5,omitempty" xml:"supportRocketmqV5,omitempty"`
Tags []*ListRegionsResponseBodyDataTags `json:"tags,omitempty" xml:"tags,omitempty" type:"Repeated"`
// example:
//
// 2022-08-01 20:05:50
UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
}
func (ListRegionsResponseBodyData) GoString ¶ added in v1.2.0
func (s ListRegionsResponseBodyData) GoString() string
func (*ListRegionsResponseBodyData) SetCreateTime ¶ added in v1.2.0
func (s *ListRegionsResponseBodyData) SetCreateTime(v string) *ListRegionsResponseBodyData
func (*ListRegionsResponseBodyData) SetRegionId ¶ added in v1.2.0
func (s *ListRegionsResponseBodyData) SetRegionId(v string) *ListRegionsResponseBodyData
func (*ListRegionsResponseBodyData) SetRegionName ¶ added in v1.2.0
func (s *ListRegionsResponseBodyData) SetRegionName(v string) *ListRegionsResponseBodyData
func (*ListRegionsResponseBodyData) SetSupportRocketmqV4 ¶ added in v1.2.0
func (s *ListRegionsResponseBodyData) SetSupportRocketmqV4(v bool) *ListRegionsResponseBodyData
func (*ListRegionsResponseBodyData) SetSupportRocketmqV5 ¶ added in v1.2.0
func (s *ListRegionsResponseBodyData) SetSupportRocketmqV5(v bool) *ListRegionsResponseBodyData
func (*ListRegionsResponseBodyData) SetTags ¶ added in v1.2.0
func (s *ListRegionsResponseBodyData) SetTags(v []*ListRegionsResponseBodyDataTags) *ListRegionsResponseBodyData
func (*ListRegionsResponseBodyData) SetUpdateTime ¶ added in v1.2.0
func (s *ListRegionsResponseBodyData) SetUpdateTime(v string) *ListRegionsResponseBodyData
func (ListRegionsResponseBodyData) String ¶ added in v1.2.0
func (s ListRegionsResponseBodyData) String() string
type ListRegionsResponseBodyDataTags ¶ added in v1.2.0
type ListRegionsResponseBodyDataTags struct {
// example:
//
// xx
TagCode *string `json:"tagCode,omitempty" xml:"tagCode,omitempty"`
// example:
//
// xx
TagValue interface{} `json:"tagValue,omitempty" xml:"tagValue,omitempty"`
}
func (ListRegionsResponseBodyDataTags) GoString ¶ added in v1.2.0
func (s ListRegionsResponseBodyDataTags) GoString() string
func (*ListRegionsResponseBodyDataTags) SetTagCode ¶ added in v1.2.0
func (s *ListRegionsResponseBodyDataTags) SetTagCode(v string) *ListRegionsResponseBodyDataTags
func (*ListRegionsResponseBodyDataTags) SetTagValue ¶ added in v1.2.0
func (s *ListRegionsResponseBodyDataTags) SetTagValue(v interface{}) *ListRegionsResponseBodyDataTags
func (ListRegionsResponseBodyDataTags) String ¶ added in v1.2.0
func (s ListRegionsResponseBodyDataTags) String() string
type ListTopicSubscriptionsResponse ¶ added in v1.3.0
type ListTopicSubscriptionsResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *ListTopicSubscriptionsResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (ListTopicSubscriptionsResponse) GoString ¶ added in v1.3.0
func (s ListTopicSubscriptionsResponse) GoString() string
func (*ListTopicSubscriptionsResponse) SetBody ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponse) SetBody(v *ListTopicSubscriptionsResponseBody) *ListTopicSubscriptionsResponse
func (*ListTopicSubscriptionsResponse) SetHeaders ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponse) SetHeaders(v map[string]*string) *ListTopicSubscriptionsResponse
func (*ListTopicSubscriptionsResponse) SetStatusCode ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponse) SetStatusCode(v int32) *ListTopicSubscriptionsResponse
func (ListTopicSubscriptionsResponse) String ¶ added in v1.3.0
func (s ListTopicSubscriptionsResponse) String() string
type ListTopicSubscriptionsResponseBody ¶ added in v1.3.0
type ListTopicSubscriptionsResponseBody struct {
// example:
//
// MissingInstanceId
Code *string `json:"code,omitempty" xml:"code,omitempty"`
Data []*ListTopicSubscriptionsResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Repeated"`
// example:
//
// Topic
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// example:
//
// instanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// example:
//
// 200
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// example:
//
// The instance cannot be found.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// example:
//
// 92A9BE4E-B794-50C8-979C-0456E4D32943
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (ListTopicSubscriptionsResponseBody) GoString ¶ added in v1.3.0
func (s ListTopicSubscriptionsResponseBody) GoString() string
func (*ListTopicSubscriptionsResponseBody) SetCode ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBody) SetCode(v string) *ListTopicSubscriptionsResponseBody
func (*ListTopicSubscriptionsResponseBody) SetData ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBody) SetData(v []*ListTopicSubscriptionsResponseBodyData) *ListTopicSubscriptionsResponseBody
func (*ListTopicSubscriptionsResponseBody) SetDynamicCode ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBody) SetDynamicCode(v string) *ListTopicSubscriptionsResponseBody
func (*ListTopicSubscriptionsResponseBody) SetDynamicMessage ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBody) SetDynamicMessage(v string) *ListTopicSubscriptionsResponseBody
func (*ListTopicSubscriptionsResponseBody) SetHttpStatusCode ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBody) SetHttpStatusCode(v int32) *ListTopicSubscriptionsResponseBody
func (*ListTopicSubscriptionsResponseBody) SetMessage ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBody) SetMessage(v string) *ListTopicSubscriptionsResponseBody
func (*ListTopicSubscriptionsResponseBody) SetRequestId ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBody) SetRequestId(v string) *ListTopicSubscriptionsResponseBody
func (*ListTopicSubscriptionsResponseBody) SetSuccess ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBody) SetSuccess(v bool) *ListTopicSubscriptionsResponseBody
func (ListTopicSubscriptionsResponseBody) String ¶ added in v1.3.0
func (s ListTopicSubscriptionsResponseBody) String() string
type ListTopicSubscriptionsResponseBodyData ¶ added in v1.3.0
type ListTopicSubscriptionsResponseBodyData struct {
Consistency *string `json:"consistency,omitempty" xml:"consistency,omitempty"`
// example:
//
// CID-TEST
ConsumerGroupId *string `json:"consumerGroupId,omitempty" xml:"consumerGroupId,omitempty"`
// example:
//
// *
FilterExpression *string `json:"filterExpression,omitempty" xml:"filterExpression,omitempty"`
// example:
//
// SQL
FilterExpressionType *string `json:"filterExpressionType,omitempty" xml:"filterExpressionType,omitempty"`
// example:
//
// BROADCASTING
MessageModel *string `json:"messageModel,omitempty" xml:"messageModel,omitempty"`
// example:
//
// ONLINE
SubscriptionStatus *string `json:"subscriptionStatus,omitempty" xml:"subscriptionStatus,omitempty"`
// example:
//
// topic_test
TopicName *string `json:"topicName,omitempty" xml:"topicName,omitempty"`
}
func (ListTopicSubscriptionsResponseBodyData) GoString ¶ added in v1.3.0
func (s ListTopicSubscriptionsResponseBodyData) GoString() string
func (*ListTopicSubscriptionsResponseBodyData) SetConsistency ¶ added in v1.4.2
func (s *ListTopicSubscriptionsResponseBodyData) SetConsistency(v string) *ListTopicSubscriptionsResponseBodyData
func (*ListTopicSubscriptionsResponseBodyData) SetConsumerGroupId ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBodyData) SetConsumerGroupId(v string) *ListTopicSubscriptionsResponseBodyData
func (*ListTopicSubscriptionsResponseBodyData) SetFilterExpression ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBodyData) SetFilterExpression(v string) *ListTopicSubscriptionsResponseBodyData
func (*ListTopicSubscriptionsResponseBodyData) SetFilterExpressionType ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBodyData) SetFilterExpressionType(v string) *ListTopicSubscriptionsResponseBodyData
func (*ListTopicSubscriptionsResponseBodyData) SetMessageModel ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBodyData) SetMessageModel(v string) *ListTopicSubscriptionsResponseBodyData
func (*ListTopicSubscriptionsResponseBodyData) SetSubscriptionStatus ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBodyData) SetSubscriptionStatus(v string) *ListTopicSubscriptionsResponseBodyData
func (*ListTopicSubscriptionsResponseBodyData) SetTopicName ¶ added in v1.3.0
func (s *ListTopicSubscriptionsResponseBodyData) SetTopicName(v string) *ListTopicSubscriptionsResponseBodyData
func (ListTopicSubscriptionsResponseBodyData) String ¶ added in v1.3.0
func (s ListTopicSubscriptionsResponseBodyData) String() string
type ListTopicsRequest ¶
type ListTopicsRequest struct {
// The condition that you want to use to filter topics in the instance. If you leave this parameter empty, all topics in the instance are queried.
//
// example:
//
// topic_test
Filter *string `json:"filter,omitempty" xml:"filter,omitempty"`
// The message types of the topics.
MessageTypes []*string `json:"messageTypes,omitempty" xml:"messageTypes,omitempty" type:"Repeated"`
// The number of the page to return.
//
// example:
//
// 1
PageNumber *int32 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
// The number of entries to return on each page.
//
// example:
//
// 3
PageSize *int32 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
}
func (ListTopicsRequest) GoString ¶
func (s ListTopicsRequest) GoString() string
func (*ListTopicsRequest) SetFilter ¶
func (s *ListTopicsRequest) SetFilter(v string) *ListTopicsRequest
func (*ListTopicsRequest) SetMessageTypes ¶ added in v1.0.3
func (s *ListTopicsRequest) SetMessageTypes(v []*string) *ListTopicsRequest
func (*ListTopicsRequest) SetPageNumber ¶
func (s *ListTopicsRequest) SetPageNumber(v int32) *ListTopicsRequest
func (*ListTopicsRequest) SetPageSize ¶
func (s *ListTopicsRequest) SetPageSize(v int32) *ListTopicsRequest
func (ListTopicsRequest) String ¶
func (s ListTopicsRequest) String() string
type ListTopicsResponse ¶
type ListTopicsResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *ListTopicsResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (ListTopicsResponse) GoString ¶
func (s ListTopicsResponse) GoString() string
func (*ListTopicsResponse) SetBody ¶
func (s *ListTopicsResponse) SetBody(v *ListTopicsResponseBody) *ListTopicsResponse
func (*ListTopicsResponse) SetHeaders ¶
func (s *ListTopicsResponse) SetHeaders(v map[string]*string) *ListTopicsResponse
func (*ListTopicsResponse) SetStatusCode ¶
func (s *ListTopicsResponse) SetStatusCode(v int32) *ListTopicsResponse
func (ListTopicsResponse) String ¶
func (s ListTopicsResponse) String() string
type ListTopicsResponseBody ¶
type ListTopicsResponseBody struct {
// The error code.
//
// example:
//
// Topic.NotFound
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The result data that is returned.
Data *ListTopicsResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Struct"`
// The dynamic error code.
//
// example:
//
// TopicName
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// topicName
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// The topic cannot be found.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. The system generates a unique ID for each request. You can troubleshoot issues based on the request ID.
//
// example:
//
// AF9A8B10-C426-530F-A0DD-96320B39****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (ListTopicsResponseBody) GoString ¶
func (s ListTopicsResponseBody) GoString() string
func (*ListTopicsResponseBody) SetCode ¶
func (s *ListTopicsResponseBody) SetCode(v string) *ListTopicsResponseBody
func (*ListTopicsResponseBody) SetData ¶
func (s *ListTopicsResponseBody) SetData(v *ListTopicsResponseBodyData) *ListTopicsResponseBody
func (*ListTopicsResponseBody) SetDynamicCode ¶
func (s *ListTopicsResponseBody) SetDynamicCode(v string) *ListTopicsResponseBody
func (*ListTopicsResponseBody) SetDynamicMessage ¶
func (s *ListTopicsResponseBody) SetDynamicMessage(v string) *ListTopicsResponseBody
func (*ListTopicsResponseBody) SetHttpStatusCode ¶
func (s *ListTopicsResponseBody) SetHttpStatusCode(v int32) *ListTopicsResponseBody
func (*ListTopicsResponseBody) SetMessage ¶
func (s *ListTopicsResponseBody) SetMessage(v string) *ListTopicsResponseBody
func (*ListTopicsResponseBody) SetRequestId ¶
func (s *ListTopicsResponseBody) SetRequestId(v string) *ListTopicsResponseBody
func (*ListTopicsResponseBody) SetSuccess ¶
func (s *ListTopicsResponseBody) SetSuccess(v bool) *ListTopicsResponseBody
func (ListTopicsResponseBody) String ¶
func (s ListTopicsResponseBody) String() string
type ListTopicsResponseBodyData ¶
type ListTopicsResponseBodyData struct {
// The paginated data.
List []*ListTopicsResponseBodyDataList `json:"list,omitempty" xml:"list,omitempty" type:"Repeated"`
// The page number of the returned page.
//
// example:
//
// 1
PageNumber *int64 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
// The number of entries returned per page.
//
// example:
//
// 3
PageSize *int64 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
// The total number of returned entries.
//
// example:
//
// 1
TotalCount *int64 `json:"totalCount,omitempty" xml:"totalCount,omitempty"`
}
func (ListTopicsResponseBodyData) GoString ¶
func (s ListTopicsResponseBodyData) GoString() string
func (*ListTopicsResponseBodyData) SetList ¶
func (s *ListTopicsResponseBodyData) SetList(v []*ListTopicsResponseBodyDataList) *ListTopicsResponseBodyData
func (*ListTopicsResponseBodyData) SetPageNumber ¶
func (s *ListTopicsResponseBodyData) SetPageNumber(v int64) *ListTopicsResponseBodyData
func (*ListTopicsResponseBodyData) SetPageSize ¶
func (s *ListTopicsResponseBodyData) SetPageSize(v int64) *ListTopicsResponseBodyData
func (*ListTopicsResponseBodyData) SetTotalCount ¶
func (s *ListTopicsResponseBodyData) SetTotalCount(v int64) *ListTopicsResponseBodyData
func (ListTopicsResponseBodyData) String ¶
func (s ListTopicsResponseBodyData) String() string
type ListTopicsResponseBodyDataList ¶
type ListTopicsResponseBodyDataList struct {
// The time when the topic was created.
//
// example:
//
// 2022-08-01 20:05:50
CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
// The ID of the instance.
//
// example:
//
// rmq-cn-7e22ody****
InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
// The message type of the topic.
//
// Valid values:
//
// - TRANSACTION
//
// <!-- -->
//
// :
//
// <!-- -->
//
// transactional message
//
// <!-- -->
//
// - FIFO
//
// <!-- -->
//
// :
//
// <!-- -->
//
// ordered message
//
// <!-- -->
//
// - DELAY
//
// <!-- -->
//
// :
//
// <!-- -->
//
// scheduled or delayed message
//
// <!-- -->
//
// - NORMAL
//
// <!-- -->
//
// :
//
// <!-- -->
//
// normal message
//
// <!-- -->
//
// example:
//
// NORMAL
MessageType *string `json:"messageType,omitempty" xml:"messageType,omitempty"`
// The ID of the region in which the instance resides.
//
// example:
//
// cn-hangzhou
RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
// The remarks on the topic.
//
// example:
//
// This is the remark for test.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
// The state of the topic.
//
// Valid values:
//
// - RUNNING
//
// <!-- -->
//
// : The topic is
//
// <!-- -->
//
// running
//
// <!-- -->
//
// .
//
// - CREATING
//
// <!-- -->
//
// : The topic is
//
// <!-- -->
//
// being created
//
// <!-- -->
//
// .
//
// example:
//
// RUNNING
Status *string `json:"status,omitempty" xml:"status,omitempty"`
// The name of the topic.
//
// example:
//
// topic_test
TopicName *string `json:"topicName,omitempty" xml:"topicName,omitempty"`
// The time when the topic was last updated.
//
// example:
//
// 2022-08-01 20:05:50
UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
}
func (ListTopicsResponseBodyDataList) GoString ¶
func (s ListTopicsResponseBodyDataList) GoString() string
func (*ListTopicsResponseBodyDataList) SetCreateTime ¶
func (s *ListTopicsResponseBodyDataList) SetCreateTime(v string) *ListTopicsResponseBodyDataList
func (*ListTopicsResponseBodyDataList) SetInstanceId ¶
func (s *ListTopicsResponseBodyDataList) SetInstanceId(v string) *ListTopicsResponseBodyDataList
func (*ListTopicsResponseBodyDataList) SetMessageType ¶
func (s *ListTopicsResponseBodyDataList) SetMessageType(v string) *ListTopicsResponseBodyDataList
func (*ListTopicsResponseBodyDataList) SetRegionId ¶
func (s *ListTopicsResponseBodyDataList) SetRegionId(v string) *ListTopicsResponseBodyDataList
func (*ListTopicsResponseBodyDataList) SetRemark ¶
func (s *ListTopicsResponseBodyDataList) SetRemark(v string) *ListTopicsResponseBodyDataList
func (*ListTopicsResponseBodyDataList) SetStatus ¶
func (s *ListTopicsResponseBodyDataList) SetStatus(v string) *ListTopicsResponseBodyDataList
func (*ListTopicsResponseBodyDataList) SetTopicName ¶
func (s *ListTopicsResponseBodyDataList) SetTopicName(v string) *ListTopicsResponseBodyDataList
func (*ListTopicsResponseBodyDataList) SetUpdateTime ¶
func (s *ListTopicsResponseBodyDataList) SetUpdateTime(v string) *ListTopicsResponseBodyDataList
func (ListTopicsResponseBodyDataList) String ¶
func (s ListTopicsResponseBodyDataList) String() string
type ListTopicsShrinkRequest ¶ added in v1.0.3
type ListTopicsShrinkRequest struct {
// The condition that you want to use to filter topics in the instance. If you leave this parameter empty, all topics in the instance are queried.
//
// example:
//
// topic_test
Filter *string `json:"filter,omitempty" xml:"filter,omitempty"`
// The message types of the topics.
MessageTypesShrink *string `json:"messageTypes,omitempty" xml:"messageTypes,omitempty"`
// The number of the page to return.
//
// example:
//
// 1
PageNumber *int32 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
// The number of entries to return on each page.
//
// example:
//
// 3
PageSize *int32 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
}
func (ListTopicsShrinkRequest) GoString ¶ added in v1.0.3
func (s ListTopicsShrinkRequest) GoString() string
func (*ListTopicsShrinkRequest) SetFilter ¶ added in v1.0.3
func (s *ListTopicsShrinkRequest) SetFilter(v string) *ListTopicsShrinkRequest
func (*ListTopicsShrinkRequest) SetMessageTypesShrink ¶ added in v1.0.3
func (s *ListTopicsShrinkRequest) SetMessageTypesShrink(v string) *ListTopicsShrinkRequest
func (*ListTopicsShrinkRequest) SetPageNumber ¶ added in v1.0.3
func (s *ListTopicsShrinkRequest) SetPageNumber(v int32) *ListTopicsShrinkRequest
func (*ListTopicsShrinkRequest) SetPageSize ¶ added in v1.0.3
func (s *ListTopicsShrinkRequest) SetPageSize(v int32) *ListTopicsShrinkRequest
func (ListTopicsShrinkRequest) String ¶ added in v1.0.3
func (s ListTopicsShrinkRequest) String() string
type ResetConsumeOffsetRequest ¶ added in v1.1.0
type ResetConsumeOffsetRequest struct {
// The time when the consumer offset is reset.
//
// example:
//
// 2023-03-22 12:17:08
ResetTime *string `json:"resetTime,omitempty" xml:"resetTime,omitempty"`
// The method that is used to reset the consumer offset. Valid values: LATEST_OFFSET and SPECIFIED_TIME.
//
// example:
//
// LATEST_OFFSET
ResetType *string `json:"resetType,omitempty" xml:"resetType,omitempty"`
}
func (ResetConsumeOffsetRequest) GoString ¶ added in v1.1.0
func (s ResetConsumeOffsetRequest) GoString() string
func (*ResetConsumeOffsetRequest) SetResetTime ¶ added in v1.1.0
func (s *ResetConsumeOffsetRequest) SetResetTime(v string) *ResetConsumeOffsetRequest
func (*ResetConsumeOffsetRequest) SetResetType ¶ added in v1.1.0
func (s *ResetConsumeOffsetRequest) SetResetType(v string) *ResetConsumeOffsetRequest
func (ResetConsumeOffsetRequest) String ¶ added in v1.1.0
func (s ResetConsumeOffsetRequest) String() string
type ResetConsumeOffsetResponse ¶ added in v1.1.0
type ResetConsumeOffsetResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *ResetConsumeOffsetResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (ResetConsumeOffsetResponse) GoString ¶ added in v1.1.0
func (s ResetConsumeOffsetResponse) GoString() string
func (*ResetConsumeOffsetResponse) SetBody ¶ added in v1.1.0
func (s *ResetConsumeOffsetResponse) SetBody(v *ResetConsumeOffsetResponseBody) *ResetConsumeOffsetResponse
func (*ResetConsumeOffsetResponse) SetHeaders ¶ added in v1.1.0
func (s *ResetConsumeOffsetResponse) SetHeaders(v map[string]*string) *ResetConsumeOffsetResponse
func (*ResetConsumeOffsetResponse) SetStatusCode ¶ added in v1.1.0
func (s *ResetConsumeOffsetResponse) SetStatusCode(v int32) *ResetConsumeOffsetResponse
func (ResetConsumeOffsetResponse) String ¶ added in v1.1.0
func (s ResetConsumeOffsetResponse) String() string
type ResetConsumeOffsetResponseBody ¶ added in v1.1.0
type ResetConsumeOffsetResponseBody struct {
// The returned error code.
//
// example:
//
// MissingInstanceId
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The returned dynamic error code.
//
// example:
//
// InstanceId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The returned dynamic error message.
//
// example:
//
// instanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The returned HTTP status code.
//
// example:
//
// 200
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The returned error message.
//
// example:
//
// The instance cannot be found.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The request ID.
//
// example:
//
// F9A95891-EAD4-5A2B-8A30-676CD18921AF
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the request is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (ResetConsumeOffsetResponseBody) GoString ¶ added in v1.1.0
func (s ResetConsumeOffsetResponseBody) GoString() string
func (*ResetConsumeOffsetResponseBody) SetCode ¶ added in v1.1.0
func (s *ResetConsumeOffsetResponseBody) SetCode(v string) *ResetConsumeOffsetResponseBody
func (*ResetConsumeOffsetResponseBody) SetDynamicCode ¶ added in v1.1.0
func (s *ResetConsumeOffsetResponseBody) SetDynamicCode(v string) *ResetConsumeOffsetResponseBody
func (*ResetConsumeOffsetResponseBody) SetDynamicMessage ¶ added in v1.1.0
func (s *ResetConsumeOffsetResponseBody) SetDynamicMessage(v string) *ResetConsumeOffsetResponseBody
func (*ResetConsumeOffsetResponseBody) SetHttpStatusCode ¶ added in v1.1.0
func (s *ResetConsumeOffsetResponseBody) SetHttpStatusCode(v int32) *ResetConsumeOffsetResponseBody
func (*ResetConsumeOffsetResponseBody) SetMessage ¶ added in v1.1.0
func (s *ResetConsumeOffsetResponseBody) SetMessage(v string) *ResetConsumeOffsetResponseBody
func (*ResetConsumeOffsetResponseBody) SetRequestId ¶ added in v1.1.0
func (s *ResetConsumeOffsetResponseBody) SetRequestId(v string) *ResetConsumeOffsetResponseBody
func (*ResetConsumeOffsetResponseBody) SetSuccess ¶ added in v1.1.0
func (s *ResetConsumeOffsetResponseBody) SetSuccess(v bool) *ResetConsumeOffsetResponseBody
func (ResetConsumeOffsetResponseBody) String ¶ added in v1.1.0
func (s ResetConsumeOffsetResponseBody) String() string
type UpdateConsumerGroupRequest ¶
type UpdateConsumerGroupRequest struct {
// The new consumption retry policy that you want to configure for the consumer group. For more information, see [Consumption retry](https://help.aliyun.com/document_detail/440356.html).
//
// This parameter is required.
ConsumeRetryPolicy *UpdateConsumerGroupRequestConsumeRetryPolicy `json:"consumeRetryPolicy,omitempty" xml:"consumeRetryPolicy,omitempty" type:"Struct"`
// The new message delivery order of the consumer group.
//
// Valid values:
//
// - Concurrently: concurrent delivery
//
// - Orderly: ordered delivery
//
// This parameter is required.
//
// example:
//
// Concurrently
DeliveryOrderType *string `json:"deliveryOrderType,omitempty" xml:"deliveryOrderType,omitempty"`
// The new remarks on the consumer group.
//
// example:
//
// This is the remark for test.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
}
func (UpdateConsumerGroupRequest) GoString ¶
func (s UpdateConsumerGroupRequest) GoString() string
func (*UpdateConsumerGroupRequest) SetConsumeRetryPolicy ¶
func (s *UpdateConsumerGroupRequest) SetConsumeRetryPolicy(v *UpdateConsumerGroupRequestConsumeRetryPolicy) *UpdateConsumerGroupRequest
func (*UpdateConsumerGroupRequest) SetDeliveryOrderType ¶
func (s *UpdateConsumerGroupRequest) SetDeliveryOrderType(v string) *UpdateConsumerGroupRequest
func (*UpdateConsumerGroupRequest) SetRemark ¶
func (s *UpdateConsumerGroupRequest) SetRemark(v string) *UpdateConsumerGroupRequest
func (UpdateConsumerGroupRequest) String ¶
func (s UpdateConsumerGroupRequest) String() string
type UpdateConsumerGroupRequestConsumeRetryPolicy ¶
type UpdateConsumerGroupRequestConsumeRetryPolicy struct {
// The dead-letter topic.
//
// If a consumer still fails to consume a message after the message is retried for a specified number of times, the message is delivered to a dead-letter topic for subsequent business recovery or troubleshooting. For more information, see [Consumption retry and dead-letter messages](https://help.aliyun.com/document_detail/440356.html).
//
// example:
//
// DLQ_mqtest
DeadLetterTargetTopic *string `json:"deadLetterTargetTopic,omitempty" xml:"deadLetterTargetTopic,omitempty"`
// The maximum number of retries.
//
// example:
//
// 16
MaxRetryTimes *int32 `json:"maxRetryTimes,omitempty" xml:"maxRetryTimes,omitempty"`
// The retry policy. For more information, see [Message retry](https://help.aliyun.com/document_detail/440356.html).
//
// Valid values:
//
// - FixedRetryPolicy: Failed messages are retried at a fixed interval.
//
// - DefaultRetryPolicy: Failed messages are retried at incremental intervals as the number of retries increases.
//
// This parameter is required.
//
// example:
//
// DefaultRetryPolicy
RetryPolicy *string `json:"retryPolicy,omitempty" xml:"retryPolicy,omitempty"`
}
func (UpdateConsumerGroupRequestConsumeRetryPolicy) GoString ¶
func (s UpdateConsumerGroupRequestConsumeRetryPolicy) GoString() string
func (*UpdateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic ¶ added in v1.0.4
func (s *UpdateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic(v string) *UpdateConsumerGroupRequestConsumeRetryPolicy
func (*UpdateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes ¶
func (s *UpdateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes(v int32) *UpdateConsumerGroupRequestConsumeRetryPolicy
func (*UpdateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy ¶
func (s *UpdateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy(v string) *UpdateConsumerGroupRequestConsumeRetryPolicy
func (UpdateConsumerGroupRequestConsumeRetryPolicy) String ¶
func (s UpdateConsumerGroupRequestConsumeRetryPolicy) String() string
type UpdateConsumerGroupResponse ¶
type UpdateConsumerGroupResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *UpdateConsumerGroupResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (UpdateConsumerGroupResponse) GoString ¶
func (s UpdateConsumerGroupResponse) GoString() string
func (*UpdateConsumerGroupResponse) SetBody ¶
func (s *UpdateConsumerGroupResponse) SetBody(v *UpdateConsumerGroupResponseBody) *UpdateConsumerGroupResponse
func (*UpdateConsumerGroupResponse) SetHeaders ¶
func (s *UpdateConsumerGroupResponse) SetHeaders(v map[string]*string) *UpdateConsumerGroupResponse
func (*UpdateConsumerGroupResponse) SetStatusCode ¶
func (s *UpdateConsumerGroupResponse) SetStatusCode(v int32) *UpdateConsumerGroupResponse
func (UpdateConsumerGroupResponse) String ¶
func (s UpdateConsumerGroupResponse) String() string
type UpdateConsumerGroupResponseBody ¶
type UpdateConsumerGroupResponseBody struct {
// The error code.
//
// example:
//
// InvalidDeliveryOrderType
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The result data that is returned.
//
// example:
//
// true
Data *bool `json:"data,omitempty" xml:"data,omitempty"`
// The dynamic error code.
//
// example:
//
// DeliveryOrderType
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// deliveryOrderType
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// Parameter deliveryOrderType is invalid.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. The system generates a unique ID for each request. You can troubleshoot issues based on the request ID.
//
// example:
//
// C7F94090-3358-506A-97DC-34BC803C****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (UpdateConsumerGroupResponseBody) GoString ¶
func (s UpdateConsumerGroupResponseBody) GoString() string
func (*UpdateConsumerGroupResponseBody) SetCode ¶
func (s *UpdateConsumerGroupResponseBody) SetCode(v string) *UpdateConsumerGroupResponseBody
func (*UpdateConsumerGroupResponseBody) SetData ¶
func (s *UpdateConsumerGroupResponseBody) SetData(v bool) *UpdateConsumerGroupResponseBody
func (*UpdateConsumerGroupResponseBody) SetDynamicCode ¶
func (s *UpdateConsumerGroupResponseBody) SetDynamicCode(v string) *UpdateConsumerGroupResponseBody
func (*UpdateConsumerGroupResponseBody) SetDynamicMessage ¶
func (s *UpdateConsumerGroupResponseBody) SetDynamicMessage(v string) *UpdateConsumerGroupResponseBody
func (*UpdateConsumerGroupResponseBody) SetHttpStatusCode ¶
func (s *UpdateConsumerGroupResponseBody) SetHttpStatusCode(v int32) *UpdateConsumerGroupResponseBody
func (*UpdateConsumerGroupResponseBody) SetMessage ¶
func (s *UpdateConsumerGroupResponseBody) SetMessage(v string) *UpdateConsumerGroupResponseBody
func (*UpdateConsumerGroupResponseBody) SetRequestId ¶
func (s *UpdateConsumerGroupResponseBody) SetRequestId(v string) *UpdateConsumerGroupResponseBody
func (*UpdateConsumerGroupResponseBody) SetSuccess ¶
func (s *UpdateConsumerGroupResponseBody) SetSuccess(v bool) *UpdateConsumerGroupResponseBody
func (UpdateConsumerGroupResponseBody) String ¶
func (s UpdateConsumerGroupResponseBody) String() string
type UpdateInstanceRequest ¶
type UpdateInstanceRequest struct {
// The access control list for the instance.
AclInfo *UpdateInstanceRequestAclInfo `json:"aclInfo,omitempty" xml:"aclInfo,omitempty" type:"Struct"`
// The updated name of the instance.
//
// example:
//
// test_instance
InstanceName *string `json:"instanceName,omitempty" xml:"instanceName,omitempty"`
// The updated network information about the instance.
NetworkInfo *UpdateInstanceRequestNetworkInfo `json:"networkInfo,omitempty" xml:"networkInfo,omitempty" type:"Struct"`
// Additional configurations of the instance.
ProductInfo *UpdateInstanceRequestProductInfo `json:"productInfo,omitempty" xml:"productInfo,omitempty" type:"Struct"`
// The updated description of the instance.
//
// example:
//
// This is the remark for test.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
}
func (UpdateInstanceRequest) GoString ¶
func (s UpdateInstanceRequest) GoString() string
func (*UpdateInstanceRequest) SetAclInfo ¶ added in v1.4.1
func (s *UpdateInstanceRequest) SetAclInfo(v *UpdateInstanceRequestAclInfo) *UpdateInstanceRequest
func (*UpdateInstanceRequest) SetInstanceName ¶
func (s *UpdateInstanceRequest) SetInstanceName(v string) *UpdateInstanceRequest
func (*UpdateInstanceRequest) SetNetworkInfo ¶
func (s *UpdateInstanceRequest) SetNetworkInfo(v *UpdateInstanceRequestNetworkInfo) *UpdateInstanceRequest
func (*UpdateInstanceRequest) SetProductInfo ¶ added in v1.0.2
func (s *UpdateInstanceRequest) SetProductInfo(v *UpdateInstanceRequestProductInfo) *UpdateInstanceRequest
func (*UpdateInstanceRequest) SetRemark ¶
func (s *UpdateInstanceRequest) SetRemark(v string) *UpdateInstanceRequest
func (UpdateInstanceRequest) String ¶
func (s UpdateInstanceRequest) String() string
type UpdateInstanceRequestAclInfo ¶ added in v1.4.1
type UpdateInstanceRequestAclInfo struct {
// The authentication type of the instance.
AclTypes []*string `json:"aclTypes,omitempty" xml:"aclTypes,omitempty" type:"Repeated"`
// Indicates whether the authentication-free in VPCs feature is enabled.
//
// Indicates whether the authentication-free in VPCs feature is enabled.
//
// Valid values:
//
// - true
//
// - false
DefaultVpcAuthFree *bool `json:"defaultVpcAuthFree,omitempty" xml:"defaultVpcAuthFree,omitempty"`
}
func (UpdateInstanceRequestAclInfo) GoString ¶ added in v1.4.1
func (s UpdateInstanceRequestAclInfo) GoString() string
func (*UpdateInstanceRequestAclInfo) SetAclTypes ¶ added in v1.4.1
func (s *UpdateInstanceRequestAclInfo) SetAclTypes(v []*string) *UpdateInstanceRequestAclInfo
func (*UpdateInstanceRequestAclInfo) SetDefaultVpcAuthFree ¶ added in v1.4.1
func (s *UpdateInstanceRequestAclInfo) SetDefaultVpcAuthFree(v bool) *UpdateInstanceRequestAclInfo
func (UpdateInstanceRequestAclInfo) String ¶ added in v1.4.1
func (s UpdateInstanceRequestAclInfo) String() string
type UpdateInstanceRequestNetworkInfo ¶
type UpdateInstanceRequestNetworkInfo struct {
// The information about the Internet over which the instance is accessed. This parameter takes effect only if the Internet access feature is enabled for the instance.
InternetInfo *UpdateInstanceRequestNetworkInfoInternetInfo `json:"internetInfo,omitempty" xml:"internetInfo,omitempty" type:"Struct"`
}
func (UpdateInstanceRequestNetworkInfo) GoString ¶
func (s UpdateInstanceRequestNetworkInfo) GoString() string
func (*UpdateInstanceRequestNetworkInfo) SetInternetInfo ¶ added in v1.0.2
func (s *UpdateInstanceRequestNetworkInfo) SetInternetInfo(v *UpdateInstanceRequestNetworkInfoInternetInfo) *UpdateInstanceRequestNetworkInfo
func (UpdateInstanceRequestNetworkInfo) String ¶
func (s UpdateInstanceRequestNetworkInfo) String() string
type UpdateInstanceRequestNetworkInfoInternetInfo ¶ added in v1.0.2
type UpdateInstanceRequestNetworkInfoInternetInfo struct {
// The whitelist that includes the IP addresses that are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
//
// - If you do not configure an IP address whitelist, all CIDR blocks are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
//
// - If you configure an IP address whitelist, only the IP addresses in the whitelist are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
IpWhitelist []*string `json:"ipWhitelist,omitempty" xml:"ipWhitelist,omitempty" type:"Repeated"`
}
func (UpdateInstanceRequestNetworkInfoInternetInfo) GoString ¶ added in v1.0.2
func (s UpdateInstanceRequestNetworkInfoInternetInfo) GoString() string
func (*UpdateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist ¶ added in v1.0.2
func (s *UpdateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist(v []*string) *UpdateInstanceRequestNetworkInfoInternetInfo
func (UpdateInstanceRequestNetworkInfoInternetInfo) String ¶ added in v1.0.2
func (s UpdateInstanceRequestNetworkInfoInternetInfo) String() string
type UpdateInstanceRequestProductInfo ¶ added in v1.0.2
type UpdateInstanceRequestProductInfo struct {
// Specifies whether to enable the elastic transactions per second (TPS) feature for the instance.
//
// Valid values:
//
// - true
//
// - false
//
// After you enable the elastic TPS feature for an ApsaraMQ for RocketMQ instance, you can use a specific number of TPS that exceeds the specification limit. You are charged for using the elastic TPS feature. For more information, see [Computing fees](https://help.aliyun.com/document_detail/427237.html).
//
// > The elastic TPS feature is supported only by specific instance editions. For more information, see [Instance editions](https://help.aliyun.com/document_detail/444715.html).
//
// example:
//
// true
AutoScaling *bool `json:"autoScaling,omitempty" xml:"autoScaling,omitempty"`
// The retention period of messages. Unit: hours.
//
// For information about the valid values of this parameter, see the "Limits on resource quotas" section of the [Limits](https://help.aliyun.com/document_detail/440347.html) topic.
//
// ApsaraMQ for RocketMQ supports serverless scaling of message storage. You are charged storage fees based on your actual storage usage. You can change the retention period of messages to manage storage capacity. For more information, see [Storage fees](https://help.aliyun.com/document_detail/427238.html).
//
// example:
//
// 72
MessageRetentionTime *int32 `json:"messageRetentionTime,omitempty" xml:"messageRetentionTime,omitempty"`
// The ratio of the number of messages that you can send to the number of messages that you can receive on the instance.
//
// Value values: 0.25 to 1.
//
// example:
//
// 0.5
SendReceiveRatio *float32 `json:"sendReceiveRatio,omitempty" xml:"sendReceiveRatio,omitempty"`
// Specifies whether to enable the message trace feature.
//
// - true
//
// - false
//
// This parameter is not in use. By default, the message trace feature is enabled for ApsaraMQ for RocketMQ instances, regardless of whether this parameter is configured.
//
// example:
//
// true
TraceOn *bool `json:"traceOn,omitempty" xml:"traceOn,omitempty"`
}
func (UpdateInstanceRequestProductInfo) GoString ¶ added in v1.0.2
func (s UpdateInstanceRequestProductInfo) GoString() string
func (*UpdateInstanceRequestProductInfo) SetAutoScaling ¶ added in v1.0.2
func (s *UpdateInstanceRequestProductInfo) SetAutoScaling(v bool) *UpdateInstanceRequestProductInfo
func (*UpdateInstanceRequestProductInfo) SetMessageRetentionTime ¶ added in v1.0.2
func (s *UpdateInstanceRequestProductInfo) SetMessageRetentionTime(v int32) *UpdateInstanceRequestProductInfo
func (*UpdateInstanceRequestProductInfo) SetSendReceiveRatio ¶ added in v1.0.2
func (s *UpdateInstanceRequestProductInfo) SetSendReceiveRatio(v float32) *UpdateInstanceRequestProductInfo
func (*UpdateInstanceRequestProductInfo) SetTraceOn ¶ added in v1.1.2
func (s *UpdateInstanceRequestProductInfo) SetTraceOn(v bool) *UpdateInstanceRequestProductInfo
func (UpdateInstanceRequestProductInfo) String ¶ added in v1.0.2
func (s UpdateInstanceRequestProductInfo) String() string
type UpdateInstanceResponse ¶
type UpdateInstanceResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *UpdateInstanceResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (UpdateInstanceResponse) GoString ¶
func (s UpdateInstanceResponse) GoString() string
func (*UpdateInstanceResponse) SetBody ¶
func (s *UpdateInstanceResponse) SetBody(v *UpdateInstanceResponseBody) *UpdateInstanceResponse
func (*UpdateInstanceResponse) SetHeaders ¶
func (s *UpdateInstanceResponse) SetHeaders(v map[string]*string) *UpdateInstanceResponse
func (*UpdateInstanceResponse) SetStatusCode ¶
func (s *UpdateInstanceResponse) SetStatusCode(v int32) *UpdateInstanceResponse
func (UpdateInstanceResponse) String ¶
func (s UpdateInstanceResponse) String() string
type UpdateInstanceResponseBody ¶
type UpdateInstanceResponseBody struct {
// The error code.
//
// example:
//
// MissingInstanceId
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The result data that is returned.
//
// example:
//
// true
Data *bool `json:"data,omitempty" xml:"data,omitempty"`
// The dynamic error code.
//
// example:
//
// InstanceId
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// instanceId
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// Parameter instanceId is mandatory for this action .
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. The system generates a unique ID for each request. You can troubleshoot issues based on the request ID.
//
// example:
//
// AA87DE09-DA44-52F4-9515-78B1B607****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (UpdateInstanceResponseBody) GoString ¶
func (s UpdateInstanceResponseBody) GoString() string
func (*UpdateInstanceResponseBody) SetCode ¶
func (s *UpdateInstanceResponseBody) SetCode(v string) *UpdateInstanceResponseBody
func (*UpdateInstanceResponseBody) SetData ¶
func (s *UpdateInstanceResponseBody) SetData(v bool) *UpdateInstanceResponseBody
func (*UpdateInstanceResponseBody) SetDynamicCode ¶
func (s *UpdateInstanceResponseBody) SetDynamicCode(v string) *UpdateInstanceResponseBody
func (*UpdateInstanceResponseBody) SetDynamicMessage ¶
func (s *UpdateInstanceResponseBody) SetDynamicMessage(v string) *UpdateInstanceResponseBody
func (*UpdateInstanceResponseBody) SetHttpStatusCode ¶
func (s *UpdateInstanceResponseBody) SetHttpStatusCode(v int32) *UpdateInstanceResponseBody
func (*UpdateInstanceResponseBody) SetMessage ¶
func (s *UpdateInstanceResponseBody) SetMessage(v string) *UpdateInstanceResponseBody
func (*UpdateInstanceResponseBody) SetRequestId ¶
func (s *UpdateInstanceResponseBody) SetRequestId(v string) *UpdateInstanceResponseBody
func (*UpdateInstanceResponseBody) SetSuccess ¶
func (s *UpdateInstanceResponseBody) SetSuccess(v bool) *UpdateInstanceResponseBody
func (UpdateInstanceResponseBody) String ¶
func (s UpdateInstanceResponseBody) String() string
type UpdateTopicRequest ¶
type UpdateTopicRequest struct {
// The new remarks on the topic.
//
// example:
//
// This is the remark for test.
Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
}
func (UpdateTopicRequest) GoString ¶
func (s UpdateTopicRequest) GoString() string
func (*UpdateTopicRequest) SetRemark ¶
func (s *UpdateTopicRequest) SetRemark(v string) *UpdateTopicRequest
func (UpdateTopicRequest) String ¶
func (s UpdateTopicRequest) String() string
type UpdateTopicResponse ¶
type UpdateTopicResponse struct {
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
Body *UpdateTopicResponseBody `json:"body,omitempty" xml:"body,omitempty"`
}
func (UpdateTopicResponse) GoString ¶
func (s UpdateTopicResponse) GoString() string
func (*UpdateTopicResponse) SetBody ¶
func (s *UpdateTopicResponse) SetBody(v *UpdateTopicResponseBody) *UpdateTopicResponse
func (*UpdateTopicResponse) SetHeaders ¶
func (s *UpdateTopicResponse) SetHeaders(v map[string]*string) *UpdateTopicResponse
func (*UpdateTopicResponse) SetStatusCode ¶
func (s *UpdateTopicResponse) SetStatusCode(v int32) *UpdateTopicResponse
func (UpdateTopicResponse) String ¶
func (s UpdateTopicResponse) String() string
type UpdateTopicResponseBody ¶
type UpdateTopicResponseBody struct {
// The error code.
//
// example:
//
// Topic.NotFound
Code *string `json:"code,omitempty" xml:"code,omitempty"`
// The result data that is returned.
//
// example:
//
// true
Data *bool `json:"data,omitempty" xml:"data,omitempty"`
// The dynamic error code.
//
// example:
//
// TopicName
DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
// The dynamic error message.
//
// example:
//
// topicName
DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
// The HTTP status code.
//
// example:
//
// 400
HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
// The error message.
//
// example:
//
// The topic cannot be found.
Message *string `json:"message,omitempty" xml:"message,omitempty"`
// The ID of the request. The system generates a unique ID for each request. You can troubleshoot issues based on the request ID.
//
// example:
//
// AF9A8B10-C426-530F-A0DD-96320B39****
RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
// Indicates whether the call is successful.
//
// example:
//
// true
Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}
func (UpdateTopicResponseBody) GoString ¶
func (s UpdateTopicResponseBody) GoString() string
func (*UpdateTopicResponseBody) SetCode ¶
func (s *UpdateTopicResponseBody) SetCode(v string) *UpdateTopicResponseBody
func (*UpdateTopicResponseBody) SetData ¶
func (s *UpdateTopicResponseBody) SetData(v bool) *UpdateTopicResponseBody
func (*UpdateTopicResponseBody) SetDynamicCode ¶
func (s *UpdateTopicResponseBody) SetDynamicCode(v string) *UpdateTopicResponseBody
func (*UpdateTopicResponseBody) SetDynamicMessage ¶
func (s *UpdateTopicResponseBody) SetDynamicMessage(v string) *UpdateTopicResponseBody
func (*UpdateTopicResponseBody) SetHttpStatusCode ¶
func (s *UpdateTopicResponseBody) SetHttpStatusCode(v int32) *UpdateTopicResponseBody
func (*UpdateTopicResponseBody) SetMessage ¶
func (s *UpdateTopicResponseBody) SetMessage(v string) *UpdateTopicResponseBody
func (*UpdateTopicResponseBody) SetRequestId ¶
func (s *UpdateTopicResponseBody) SetRequestId(v string) *UpdateTopicResponseBody
func (*UpdateTopicResponseBody) SetSuccess ¶
func (s *UpdateTopicResponseBody) SetSuccess(v bool) *UpdateTopicResponseBody
func (UpdateTopicResponseBody) String ¶
func (s UpdateTopicResponseBody) String() string