client

package
v1.4.5 Latest Latest
Warning

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

Go to latest
Published: Jul 25, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

This file is auto-generated, don't edit it. Thanks.

Index

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 (*ChangeResourceGroupRequest) SetResourceGroupId added in v1.0.4

func (*ChangeResourceGroupRequest) SetResourceId added in v1.0.4

func (*ChangeResourceGroupRequest) SetResourceType added in v1.0.4

func (ChangeResourceGroupRequest) String added in v1.0.4

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 (*ChangeResourceGroupResponse) SetHeaders added in v1.0.4

func (*ChangeResourceGroupResponse) SetStatusCode added in v1.0.4

func (ChangeResourceGroupResponse) String added in v1.0.4

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 (*ChangeResourceGroupResponseBody) SetCode added in v1.0.4

func (*ChangeResourceGroupResponseBody) SetData added in v1.0.4

func (*ChangeResourceGroupResponseBody) SetDynamicCode added in v1.0.4

func (*ChangeResourceGroupResponseBody) SetDynamicMessage added in v1.0.4

func (*ChangeResourceGroupResponseBody) SetHttpStatusCode added in v1.0.4

func (*ChangeResourceGroupResponseBody) SetMessage added in v1.0.4

func (*ChangeResourceGroupResponseBody) SetRequestId added in v1.0.4

func (*ChangeResourceGroupResponseBody) SetSuccess added in v1.0.4

func (ChangeResourceGroupResponseBody) String added in v1.0.4

type Client

type Client struct {
	openapi.Client
}

func NewClient

func NewClient(config *openapi.Config) (*Client, error)

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 *Client) GetEndpoint(productId *string, regionId *string, endpointRule *string, network *string, suffix *string, endpointMap map[string]*string, endpoint *string) (_result *string, _err error)

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) Init

func (client *Client) Init(config *openapi.Config) (_err error)

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) SetDeliveryOrderType

func (s *CreateConsumerGroupRequest) SetDeliveryOrderType(v string) *CreateConsumerGroupRequest

func (*CreateConsumerGroupRequest) SetRemark

func (CreateConsumerGroupRequest) 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 (*CreateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic added in v1.0.3

func (*CreateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes

func (*CreateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy

func (CreateConsumerGroupRequestConsumeRetryPolicy) 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 (*CreateConsumerGroupResponse) SetHeaders

func (*CreateConsumerGroupResponse) SetStatusCode

func (CreateConsumerGroupResponse) 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 (*CreateConsumerGroupResponseBody) SetCode

func (*CreateConsumerGroupResponseBody) SetData

func (*CreateConsumerGroupResponseBody) SetDynamicCode

func (*CreateConsumerGroupResponseBody) SetDynamicMessage

func (*CreateConsumerGroupResponseBody) SetHttpStatusCode

func (*CreateConsumerGroupResponseBody) SetMessage

func (*CreateConsumerGroupResponseBody) SetRequestId

func (*CreateConsumerGroupResponseBody) SetSuccess

func (CreateConsumerGroupResponseBody) 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 (*CreateInstanceRequest) SetPaymentType added in v1.0.2

func (s *CreateInstanceRequest) SetPaymentType(v string) *CreateInstanceRequest

func (*CreateInstanceRequest) SetPeriod added in v1.0.2

func (*CreateInstanceRequest) SetPeriodUnit added in v1.0.2

func (s *CreateInstanceRequest) SetPeriodUnit(v string) *CreateInstanceRequest

func (*CreateInstanceRequest) SetProductInfo added in v1.0.2

func (*CreateInstanceRequest) SetRemark added in v1.0.2

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 (*CreateInstanceRequestNetworkInfo) SetInternetInfo added in v1.0.2

func (*CreateInstanceRequestNetworkInfo) SetVpcInfo added in v1.0.2

func (CreateInstanceRequestNetworkInfo) String added in v1.0.2

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 (*CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutBandwidth added in v1.0.2

func (*CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutType added in v1.0.2

func (*CreateInstanceRequestNetworkInfoInternetInfo) SetInternetSpec added in v1.0.2

func (*CreateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist added in v1.0.2

func (CreateInstanceRequestNetworkInfoInternetInfo) String added in v1.0.2

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 (*CreateInstanceRequestNetworkInfoVpcInfo) SetSecurityGroupIds added in v1.1.2

func (*CreateInstanceRequestNetworkInfoVpcInfo) SetVSwitchId added in v1.0.2

func (*CreateInstanceRequestNetworkInfoVpcInfo) SetVSwitches added in v1.4.4

func (*CreateInstanceRequestNetworkInfoVpcInfo) SetVpcId added in v1.0.2

func (CreateInstanceRequestNetworkInfoVpcInfo) String added in v1.0.2

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 (*CreateInstanceRequestNetworkInfoVpcInfoVSwitches) SetVSwitchId added in v1.4.4

func (CreateInstanceRequestNetworkInfoVpcInfoVSwitches) String added in v1.4.4

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 (*CreateInstanceRequestProductInfo) SetAutoScaling added in v1.0.2

func (*CreateInstanceRequestProductInfo) SetChargeType added in v1.1.2

func (*CreateInstanceRequestProductInfo) SetIntranetSpec added in v1.1.2

func (*CreateInstanceRequestProductInfo) SetMessageRetentionTime added in v1.0.2

func (*CreateInstanceRequestProductInfo) SetMsgProcessSpec added in v1.0.2

func (*CreateInstanceRequestProductInfo) SetSendReceiveRatio added in v1.0.2

func (CreateInstanceRequestProductInfo) String added in v1.0.2

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 (*CreateInstanceResponse) SetHeaders added in v1.0.2

func (*CreateInstanceResponse) SetStatusCode added in v1.0.2

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 (*CreateInstanceResponseBody) SetData added in v1.0.2

func (*CreateInstanceResponseBody) SetDynamicCode added in v1.0.2

func (*CreateInstanceResponseBody) SetDynamicMessage added in v1.0.2

func (*CreateInstanceResponseBody) SetHttpStatusCode added in v1.0.2

func (*CreateInstanceResponseBody) SetMessage added in v1.0.2

func (*CreateInstanceResponseBody) SetRequestId added in v1.0.2

func (*CreateInstanceResponseBody) SetSuccess added in v1.0.2

func (CreateInstanceResponseBody) String added in v1.0.2

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 (*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 (*CreateTopicResponseBody) SetData

func (*CreateTopicResponseBody) SetDynamicCode

func (*CreateTopicResponseBody) SetDynamicMessage

func (s *CreateTopicResponseBody) SetDynamicMessage(v string) *CreateTopicResponseBody

func (*CreateTopicResponseBody) SetHttpStatusCode

func (s *CreateTopicResponseBody) SetHttpStatusCode(v int32) *CreateTopicResponseBody

func (*CreateTopicResponseBody) SetMessage

func (*CreateTopicResponseBody) SetRequestId

func (*CreateTopicResponseBody) SetSuccess

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 (*DeleteConsumerGroupResponse) SetHeaders

func (*DeleteConsumerGroupResponse) SetStatusCode

func (DeleteConsumerGroupResponse) 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 (*DeleteConsumerGroupResponseBody) SetCode

func (*DeleteConsumerGroupResponseBody) SetData

func (*DeleteConsumerGroupResponseBody) SetDynamicCode

func (*DeleteConsumerGroupResponseBody) SetDynamicMessage

func (*DeleteConsumerGroupResponseBody) SetHttpStatusCode

func (*DeleteConsumerGroupResponseBody) SetMessage

func (*DeleteConsumerGroupResponseBody) SetRequestId

func (*DeleteConsumerGroupResponseBody) SetSuccess

func (DeleteConsumerGroupResponseBody) 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 (*DeleteInstanceResponse) SetHeaders

func (*DeleteInstanceResponse) SetStatusCode

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 (*DeleteInstanceResponseBody) SetData

func (*DeleteInstanceResponseBody) SetDynamicCode

func (*DeleteInstanceResponseBody) SetDynamicMessage

func (*DeleteInstanceResponseBody) SetHttpStatusCode

func (*DeleteInstanceResponseBody) SetMessage

func (*DeleteInstanceResponseBody) SetRequestId

func (*DeleteInstanceResponseBody) SetSuccess

func (DeleteInstanceResponseBody) 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 (*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 (*DeleteTopicResponseBody) SetData

func (*DeleteTopicResponseBody) SetDynamicCode

func (*DeleteTopicResponseBody) SetDynamicMessage

func (s *DeleteTopicResponseBody) SetDynamicMessage(v string) *DeleteTopicResponseBody

func (*DeleteTopicResponseBody) SetHttpStatusCode

func (s *DeleteTopicResponseBody) SetHttpStatusCode(v int32) *DeleteTopicResponseBody

func (*DeleteTopicResponseBody) SetMessage

func (*DeleteTopicResponseBody) SetRequestId

func (*DeleteTopicResponseBody) SetSuccess

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 (*GetConsumerGroupResponse) SetHeaders

func (*GetConsumerGroupResponse) SetStatusCode

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 (*GetConsumerGroupResponseBody) SetData

func (*GetConsumerGroupResponseBody) SetDynamicCode

func (*GetConsumerGroupResponseBody) SetDynamicMessage

func (*GetConsumerGroupResponseBody) SetHttpStatusCode

func (*GetConsumerGroupResponseBody) SetMessage

func (*GetConsumerGroupResponseBody) SetRequestId

func (*GetConsumerGroupResponseBody) SetSuccess

func (GetConsumerGroupResponseBody) 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 (*GetConsumerGroupResponseBodyData) SetConsumerGroupId

func (*GetConsumerGroupResponseBodyData) SetCreateTime

func (*GetConsumerGroupResponseBodyData) SetDeliveryOrderType

func (*GetConsumerGroupResponseBodyData) SetInstanceId

func (*GetConsumerGroupResponseBodyData) SetRegionId

func (*GetConsumerGroupResponseBodyData) SetRemark

func (*GetConsumerGroupResponseBodyData) SetStatus

func (*GetConsumerGroupResponseBodyData) SetUpdateTime

func (GetConsumerGroupResponseBodyData) 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 (*GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetDeadLetterTargetTopic added in v1.0.3

func (*GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetMaxRetryTimes

func (*GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetRetryPolicy

func (GetConsumerGroupResponseBodyDataConsumeRetryPolicy) 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 (*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 (*GetInstanceResponseBody) SetData

func (*GetInstanceResponseBody) SetDynamicCode

func (*GetInstanceResponseBody) SetDynamicMessage

func (s *GetInstanceResponseBody) SetDynamicMessage(v string) *GetInstanceResponseBody

func (*GetInstanceResponseBody) SetHttpStatusCode

func (s *GetInstanceResponseBody) SetHttpStatusCode(v int32) *GetInstanceResponseBody

func (*GetInstanceResponseBody) SetMessage

func (*GetInstanceResponseBody) SetRequestId

func (*GetInstanceResponseBody) SetSuccess

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 (*GetInstanceResponseBodyData) SetAclInfo added in v1.0.2

func (*GetInstanceResponseBodyData) SetBid

func (*GetInstanceResponseBodyData) SetCommodityCode

func (*GetInstanceResponseBodyData) SetCreateTime

func (*GetInstanceResponseBodyData) SetExpireTime

func (*GetInstanceResponseBodyData) SetExtConfig

func (*GetInstanceResponseBodyData) SetGroupCount added in v1.0.1

func (*GetInstanceResponseBodyData) SetInstanceId

func (*GetInstanceResponseBodyData) SetInstanceName

func (*GetInstanceResponseBodyData) SetInstanceQuotas

func (*GetInstanceResponseBodyData) SetNetworkInfo

func (*GetInstanceResponseBodyData) SetPaymentType

func (*GetInstanceResponseBodyData) SetProductInfo added in v1.0.2

func (*GetInstanceResponseBodyData) SetRegionId

func (*GetInstanceResponseBodyData) SetReleaseTime

func (*GetInstanceResponseBodyData) SetRemark

func (*GetInstanceResponseBodyData) SetResourceGroupId

func (*GetInstanceResponseBodyData) SetSeriesCode

func (*GetInstanceResponseBodyData) SetServiceCode

func (*GetInstanceResponseBodyData) SetSoftware added in v1.0.6

func (*GetInstanceResponseBodyData) SetStartTime

func (*GetInstanceResponseBodyData) SetStatus

func (*GetInstanceResponseBodyData) SetSubSeriesCode

func (*GetInstanceResponseBodyData) SetTags added in v1.1.0

func (*GetInstanceResponseBodyData) SetTopicCount added in v1.0.1

func (*GetInstanceResponseBodyData) SetUpdateTime

func (*GetInstanceResponseBodyData) SetUserId

func (GetInstanceResponseBodyData) 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 (*GetInstanceResponseBodyDataAccountInfo) SetUsername

func (GetInstanceResponseBodyDataAccountInfo) 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 (*GetInstanceResponseBodyDataAclInfo) SetAclType added in v1.0.2

func (*GetInstanceResponseBodyDataAclInfo) SetAclTypes added in v1.4.1

func (*GetInstanceResponseBodyDataAclInfo) SetDefaultVpcAuthFree added in v1.4.1

func (GetInstanceResponseBodyDataAclInfo) String added in v1.0.2

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 (*GetInstanceResponseBodyDataExtConfig) SetAclType

func (*GetInstanceResponseBodyDataExtConfig) SetAutoScaling

func (*GetInstanceResponseBodyDataExtConfig) SetFlowOutBandwidth

func (*GetInstanceResponseBodyDataExtConfig) SetFlowOutType

func (*GetInstanceResponseBodyDataExtConfig) SetInternetSpec

func (*GetInstanceResponseBodyDataExtConfig) SetMessageRetentionTime

func (*GetInstanceResponseBodyDataExtConfig) SetMsgProcessSpec

func (*GetInstanceResponseBodyDataExtConfig) SetSendReceiveRatio

func (*GetInstanceResponseBodyDataExtConfig) SetSupportAutoScaling

func (GetInstanceResponseBodyDataExtConfig) 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 (*GetInstanceResponseBodyDataInstanceQuotas) SetFreeCount

func (*GetInstanceResponseBodyDataInstanceQuotas) SetQuotaName

func (*GetInstanceResponseBodyDataInstanceQuotas) SetTotalCount

func (*GetInstanceResponseBodyDataInstanceQuotas) SetUsedCount

func (GetInstanceResponseBodyDataInstanceQuotas) 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 (*GetInstanceResponseBodyDataNetworkInfo) SetInternetInfo added in v1.0.2

func (GetInstanceResponseBodyDataNetworkInfo) 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 (*GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointType

func (*GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointUrl

func (*GetInstanceResponseBodyDataNetworkInfoEndpoints) SetIpWhitelist

func (GetInstanceResponseBodyDataNetworkInfoEndpoints) 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 (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutBandwidth added in v1.0.2

func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutType added in v1.0.2

func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetInternetSpec added in v1.0.2

func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetIpWhitelist added in v1.0.2

func (GetInstanceResponseBodyDataNetworkInfoInternetInfo) String added in v1.0.2

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 (*GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetSecurityGroupIds added in v1.1.2

func (*GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVSwitchId

func (*GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVSwitches added in v1.4.2

func (*GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVpcId

func (GetInstanceResponseBodyDataNetworkInfoVpcInfo) 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 (*GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) SetVSwitchId added in v1.4.2

func (*GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) SetZoneId added in v1.4.2

func (GetInstanceResponseBodyDataNetworkInfoVpcInfoVSwitches) String added in v1.4.2

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 (*GetInstanceResponseBodyDataProductInfo) SetAutoScaling added in v1.0.2

func (*GetInstanceResponseBodyDataProductInfo) SetMessageRetentionTime added in v1.0.2

func (*GetInstanceResponseBodyDataProductInfo) SetMsgProcessSpec added in v1.0.2

func (*GetInstanceResponseBodyDataProductInfo) SetSendReceiveRatio added in v1.0.2

func (*GetInstanceResponseBodyDataProductInfo) SetSupportAutoScaling added in v1.0.2

func (*GetInstanceResponseBodyDataProductInfo) SetTraceOn added in v1.1.2

func (GetInstanceResponseBodyDataProductInfo) String added in v1.0.2

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 (*GetInstanceResponseBodyDataSoftware) SetMaintainTime added in v1.0.6

func (*GetInstanceResponseBodyDataSoftware) SetSoftwareVersion added in v1.0.6

func (*GetInstanceResponseBodyDataSoftware) SetUpgradeMethod added in v1.0.6

func (GetInstanceResponseBodyDataSoftware) String added in v1.0.6

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 (*GetInstanceResponseBodyDataTags) SetKey added in v1.1.0

func (*GetInstanceResponseBodyDataTags) SetValue added in v1.1.0

func (GetInstanceResponseBodyDataTags) String added in v1.1.0

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 (*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 (*GetTopicResponseBody) SetData

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 (*GetTopicResponseBody) SetRequestId

func (s *GetTopicResponseBody) SetRequestId(v string) *GetTopicResponseBody

func (*GetTopicResponseBody) SetSuccess

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 (*GetTopicResponseBodyData) SetInstanceId

func (*GetTopicResponseBodyData) SetMessageType

func (*GetTopicResponseBodyData) SetRegionId

func (*GetTopicResponseBodyData) SetRemark

func (*GetTopicResponseBodyData) SetStatus

func (*GetTopicResponseBodyData) SetTopicName

func (*GetTopicResponseBodyData) SetUpdateTime

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 (*ListAvailableZonesResponse) SetHeaders added in v1.2.0

func (*ListAvailableZonesResponse) SetStatusCode added in v1.2.0

func (ListAvailableZonesResponse) String added in v1.2.0

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 (*ListAvailableZonesResponseBody) SetCode added in v1.2.0

func (*ListAvailableZonesResponseBody) SetData added in v1.2.0

func (*ListAvailableZonesResponseBody) SetDynamicCode added in v1.2.0

func (*ListAvailableZonesResponseBody) SetDynamicMessage added in v1.2.0

func (*ListAvailableZonesResponseBody) SetHttpStatusCode added in v1.2.0

func (*ListAvailableZonesResponseBody) SetMessage added in v1.2.0

func (*ListAvailableZonesResponseBody) SetRequestId added in v1.2.0

func (*ListAvailableZonesResponseBody) SetSuccess added in v1.2.0

func (ListAvailableZonesResponseBody) String added in v1.2.0

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 (*ListAvailableZonesResponseBodyData) SetCreateTime added in v1.2.0

func (*ListAvailableZonesResponseBodyData) SetUpdateTime added in v1.2.0

func (*ListAvailableZonesResponseBodyData) SetZoneId added in v1.2.0

func (*ListAvailableZonesResponseBodyData) SetZoneName added in v1.2.0

func (ListAvailableZonesResponseBodyData) String added in v1.2.0

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 (*ListConsumerConnectionsResponse) SetBody added in v1.3.0

func (*ListConsumerConnectionsResponse) SetHeaders added in v1.3.0

func (*ListConsumerConnectionsResponse) SetStatusCode added in v1.3.0

func (ListConsumerConnectionsResponse) String added in v1.3.0

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 (*ListConsumerConnectionsResponseBody) SetCode added in v1.3.0

func (*ListConsumerConnectionsResponseBody) SetData added in v1.3.0

func (*ListConsumerConnectionsResponseBody) SetDynamicCode added in v1.3.0

func (*ListConsumerConnectionsResponseBody) SetDynamicMessage added in v1.3.0

func (*ListConsumerConnectionsResponseBody) SetHttpStatusCode added in v1.3.0

func (*ListConsumerConnectionsResponseBody) SetMessage added in v1.3.0

func (*ListConsumerConnectionsResponseBody) SetRequestId added in v1.3.0

func (*ListConsumerConnectionsResponseBody) SetSuccess added in v1.3.0

func (ListConsumerConnectionsResponseBody) String added in v1.3.0

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 (*ListConsumerConnectionsResponseBodyData) SetConnections added in v1.3.0

func (*ListConsumerConnectionsResponseBodyData) SetConsumerGroupId added in v1.3.0

func (*ListConsumerConnectionsResponseBodyData) SetInstanceId added in v1.3.0

func (*ListConsumerConnectionsResponseBodyData) SetRegionId added in v1.3.0

func (ListConsumerConnectionsResponseBodyData) String added in v1.3.0

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 (*ListConsumerConnectionsResponseBodyDataConnections) SetClientId added in v1.3.0

func (*ListConsumerConnectionsResponseBodyDataConnections) SetEgressIp added in v1.3.0

func (*ListConsumerConnectionsResponseBodyDataConnections) SetHostname added in v1.3.0

func (*ListConsumerConnectionsResponseBodyDataConnections) SetLanguage added in v1.3.0

func (*ListConsumerConnectionsResponseBodyDataConnections) SetMessageModel added in v1.3.0

func (*ListConsumerConnectionsResponseBodyDataConnections) SetVersion added in v1.3.0

func (ListConsumerConnectionsResponseBodyDataConnections) String added in v1.3.0

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 (*ListConsumerGroupSubscriptionsResponse) SetBody added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponse) SetHeaders added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponse) SetStatusCode added in v1.1.0

func (ListConsumerGroupSubscriptionsResponse) String added in v1.1.0

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 (*ListConsumerGroupSubscriptionsResponseBody) SetCode added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBody) SetData added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBody) SetDynamicCode added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBody) SetDynamicMessage added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBody) SetHttpStatusCode added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBody) SetMessage added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBody) SetRequestId added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBody) SetSuccess added in v1.1.0

func (ListConsumerGroupSubscriptionsResponseBody) String added in v1.1.0

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 (*ListConsumerGroupSubscriptionsResponseBodyData) SetConsistency added in v1.4.2

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetConsumerGroupId added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpression added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpressionType added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetMessageModel added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetSubscriptionStatus added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetTopicCreated added in v1.1.0

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetTopicName added in v1.1.0

func (ListConsumerGroupSubscriptionsResponseBodyData) String added in v1.1.0

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 (*ListConsumerGroupsRequest) SetPageNumber

func (*ListConsumerGroupsRequest) SetPageSize

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 (*ListConsumerGroupsResponse) SetHeaders

func (*ListConsumerGroupsResponse) SetStatusCode

func (ListConsumerGroupsResponse) 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 (*ListConsumerGroupsResponseBody) SetCode

func (*ListConsumerGroupsResponseBody) SetDynamicCode

func (*ListConsumerGroupsResponseBody) SetDynamicMessage

func (*ListConsumerGroupsResponseBody) SetHttpStatusCode

func (*ListConsumerGroupsResponseBody) SetMessage

func (*ListConsumerGroupsResponseBody) SetRequestId

func (*ListConsumerGroupsResponseBody) SetSuccess

func (ListConsumerGroupsResponseBody) 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 (*ListConsumerGroupsResponseBodyData) SetPageNumber

func (*ListConsumerGroupsResponseBodyData) SetPageSize

func (*ListConsumerGroupsResponseBodyData) SetTotalCount

func (ListConsumerGroupsResponseBodyData) 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 (*ListConsumerGroupsResponseBodyDataList) SetConsumerGroupId

func (*ListConsumerGroupsResponseBodyDataList) SetCreateTime

func (*ListConsumerGroupsResponseBodyDataList) SetInstanceId

func (*ListConsumerGroupsResponseBodyDataList) SetRegionId

func (*ListConsumerGroupsResponseBodyDataList) SetRemark

func (*ListConsumerGroupsResponseBodyDataList) SetStatus

func (*ListConsumerGroupsResponseBodyDataList) SetUpdateTime

func (ListConsumerGroupsResponseBodyDataList) 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 (*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 (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 (*ListInstancesResponse) SetHeaders

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 (*ListInstancesResponseBody) SetData

func (*ListInstancesResponseBody) SetDynamicCode

func (*ListInstancesResponseBody) SetDynamicMessage

func (*ListInstancesResponseBody) SetHttpStatusCode

func (*ListInstancesResponseBody) SetMessage

func (*ListInstancesResponseBody) SetRequestId

func (*ListInstancesResponseBody) SetSuccess

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 (*ListInstancesResponseBodyData) SetList

func (*ListInstancesResponseBodyData) SetPageNumber

func (*ListInstancesResponseBodyData) SetPageSize

func (*ListInstancesResponseBodyData) SetTotalCount

func (ListInstancesResponseBodyData) 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 (*ListInstancesResponseBodyDataList) SetCommodityCode

func (*ListInstancesResponseBodyDataList) SetCreateTime

func (*ListInstancesResponseBodyDataList) SetExpireTime

func (*ListInstancesResponseBodyDataList) SetGroupCount

func (*ListInstancesResponseBodyDataList) SetInstanceId

func (*ListInstancesResponseBodyDataList) SetInstanceName

func (*ListInstancesResponseBodyDataList) SetPaymentType

func (*ListInstancesResponseBodyDataList) SetProductInfo added in v1.1.2

func (*ListInstancesResponseBodyDataList) SetRegionId

func (*ListInstancesResponseBodyDataList) SetReleaseTime

func (*ListInstancesResponseBodyDataList) SetRemark

func (*ListInstancesResponseBodyDataList) SetResourceGroupId

func (*ListInstancesResponseBodyDataList) SetSeriesCode

func (*ListInstancesResponseBodyDataList) SetServiceCode

func (*ListInstancesResponseBodyDataList) SetStartTime

func (*ListInstancesResponseBodyDataList) SetStatus

func (*ListInstancesResponseBodyDataList) SetSubSeriesCode

func (*ListInstancesResponseBodyDataList) SetTags added in v1.1.0

func (*ListInstancesResponseBodyDataList) SetTopicCount

func (*ListInstancesResponseBodyDataList) SetUpdateTime

func (*ListInstancesResponseBodyDataList) SetUserId

func (ListInstancesResponseBodyDataList) 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 (*ListInstancesResponseBodyDataListProductInfo) SetTraceOn added in v1.1.2

func (ListInstancesResponseBodyDataListProductInfo) String added in v1.1.2

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 (*ListInstancesResponseBodyDataListTags) SetKey added in v1.1.0

func (*ListInstancesResponseBodyDataListTags) SetValue added in v1.1.0

func (ListInstancesResponseBodyDataListTags) String added in v1.1.0

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 (*ListInstancesShrinkRequest) SetPageNumber added in v1.4.5

func (*ListInstancesShrinkRequest) SetPageSize added in v1.4.5

func (*ListInstancesShrinkRequest) SetResourceGroupId added in v1.4.5

func (*ListInstancesShrinkRequest) SetSeriesCodesShrink added in v1.4.5

func (s *ListInstancesShrinkRequest) SetSeriesCodesShrink(v string) *ListInstancesShrinkRequest

func (*ListInstancesShrinkRequest) SetTags added in v1.4.5

func (ListInstancesShrinkRequest) String added in v1.4.5

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 (*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 (*ListRegionsResponseBody) SetData added in v1.2.0

func (*ListRegionsResponseBody) SetDynamicCode added in v1.2.0

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 (*ListRegionsResponseBody) SetRequestId added in v1.2.0

func (*ListRegionsResponseBody) SetSuccess added in v1.2.0

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 (*ListRegionsResponseBodyData) SetRegionId added in v1.2.0

func (*ListRegionsResponseBodyData) SetRegionName added in v1.2.0

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 (*ListRegionsResponseBodyData) SetUpdateTime added in v1.2.0

func (ListRegionsResponseBodyData) String added in v1.2.0

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 (*ListRegionsResponseBodyDataTags) SetTagCode added in v1.2.0

func (*ListRegionsResponseBodyDataTags) SetTagValue added in v1.2.0

func (ListRegionsResponseBodyDataTags) String added in v1.2.0

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 (*ListTopicSubscriptionsResponse) SetBody added in v1.3.0

func (*ListTopicSubscriptionsResponse) SetHeaders added in v1.3.0

func (*ListTopicSubscriptionsResponse) SetStatusCode added in v1.3.0

func (ListTopicSubscriptionsResponse) String added in v1.3.0

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 (*ListTopicSubscriptionsResponseBody) SetCode added in v1.3.0

func (*ListTopicSubscriptionsResponseBody) SetData added in v1.3.0

func (*ListTopicSubscriptionsResponseBody) SetDynamicCode added in v1.3.0

func (*ListTopicSubscriptionsResponseBody) SetDynamicMessage added in v1.3.0

func (*ListTopicSubscriptionsResponseBody) SetHttpStatusCode added in v1.3.0

func (*ListTopicSubscriptionsResponseBody) SetMessage added in v1.3.0

func (*ListTopicSubscriptionsResponseBody) SetRequestId added in v1.3.0

func (*ListTopicSubscriptionsResponseBody) SetSuccess added in v1.3.0

func (ListTopicSubscriptionsResponseBody) String added in v1.3.0

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 (*ListTopicSubscriptionsResponseBodyData) SetConsistency added in v1.4.2

func (*ListTopicSubscriptionsResponseBodyData) SetConsumerGroupId added in v1.3.0

func (*ListTopicSubscriptionsResponseBodyData) SetFilterExpression added in v1.3.0

func (*ListTopicSubscriptionsResponseBodyData) SetFilterExpressionType added in v1.3.0

func (*ListTopicSubscriptionsResponseBodyData) SetMessageModel added in v1.3.0

func (*ListTopicSubscriptionsResponseBodyData) SetSubscriptionStatus added in v1.3.0

func (*ListTopicSubscriptionsResponseBodyData) SetTopicName added in v1.3.0

func (ListTopicSubscriptionsResponseBodyData) String added in v1.3.0

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 (*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 (*ListTopicsResponseBody) SetData

func (*ListTopicsResponseBody) SetDynamicCode

func (*ListTopicsResponseBody) SetDynamicMessage

func (s *ListTopicsResponseBody) SetDynamicMessage(v string) *ListTopicsResponseBody

func (*ListTopicsResponseBody) SetHttpStatusCode

func (s *ListTopicsResponseBody) SetHttpStatusCode(v int32) *ListTopicsResponseBody

func (*ListTopicsResponseBody) SetMessage

func (*ListTopicsResponseBody) SetRequestId

func (*ListTopicsResponseBody) SetSuccess

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 (*ListTopicsResponseBodyData) SetPageNumber

func (*ListTopicsResponseBodyData) SetPageSize

func (*ListTopicsResponseBodyData) SetTotalCount

func (ListTopicsResponseBodyData) 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 (*ListTopicsResponseBodyDataList) SetCreateTime

func (*ListTopicsResponseBodyDataList) SetInstanceId

func (*ListTopicsResponseBodyDataList) SetMessageType

func (*ListTopicsResponseBodyDataList) SetRegionId

func (*ListTopicsResponseBodyDataList) SetRemark

func (*ListTopicsResponseBodyDataList) SetStatus

func (*ListTopicsResponseBodyDataList) SetTopicName

func (*ListTopicsResponseBodyDataList) SetUpdateTime

func (ListTopicsResponseBodyDataList) 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 (*ListTopicsShrinkRequest) SetMessageTypesShrink added in v1.0.3

func (s *ListTopicsShrinkRequest) SetMessageTypesShrink(v string) *ListTopicsShrinkRequest

func (*ListTopicsShrinkRequest) SetPageNumber added in v1.0.3

func (*ListTopicsShrinkRequest) SetPageSize added in v1.0.3

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 (*ResetConsumeOffsetRequest) SetResetType added in v1.1.0

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 (*ResetConsumeOffsetResponse) SetHeaders added in v1.1.0

func (*ResetConsumeOffsetResponse) SetStatusCode added in v1.1.0

func (ResetConsumeOffsetResponse) String added in v1.1.0

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 (*ResetConsumeOffsetResponseBody) SetCode added in v1.1.0

func (*ResetConsumeOffsetResponseBody) SetDynamicCode added in v1.1.0

func (*ResetConsumeOffsetResponseBody) SetDynamicMessage added in v1.1.0

func (*ResetConsumeOffsetResponseBody) SetHttpStatusCode added in v1.1.0

func (*ResetConsumeOffsetResponseBody) SetMessage added in v1.1.0

func (*ResetConsumeOffsetResponseBody) SetRequestId added in v1.1.0

func (*ResetConsumeOffsetResponseBody) SetSuccess added in v1.1.0

func (ResetConsumeOffsetResponseBody) String added in v1.1.0

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) SetDeliveryOrderType

func (s *UpdateConsumerGroupRequest) SetDeliveryOrderType(v string) *UpdateConsumerGroupRequest

func (*UpdateConsumerGroupRequest) SetRemark

func (UpdateConsumerGroupRequest) 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 (*UpdateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic added in v1.0.4

func (*UpdateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes

func (*UpdateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy

func (UpdateConsumerGroupRequestConsumeRetryPolicy) 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 (*UpdateConsumerGroupResponse) SetHeaders

func (*UpdateConsumerGroupResponse) SetStatusCode

func (UpdateConsumerGroupResponse) 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 (*UpdateConsumerGroupResponseBody) SetCode

func (*UpdateConsumerGroupResponseBody) SetData

func (*UpdateConsumerGroupResponseBody) SetDynamicCode

func (*UpdateConsumerGroupResponseBody) SetDynamicMessage

func (*UpdateConsumerGroupResponseBody) SetHttpStatusCode

func (*UpdateConsumerGroupResponseBody) SetMessage

func (*UpdateConsumerGroupResponseBody) SetRequestId

func (*UpdateConsumerGroupResponseBody) SetSuccess

func (UpdateConsumerGroupResponseBody) 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 (*UpdateInstanceRequest) SetInstanceName

func (s *UpdateInstanceRequest) SetInstanceName(v string) *UpdateInstanceRequest

func (*UpdateInstanceRequest) SetNetworkInfo

func (*UpdateInstanceRequest) SetProductInfo added in v1.0.2

func (*UpdateInstanceRequest) SetRemark

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 (*UpdateInstanceRequestAclInfo) SetDefaultVpcAuthFree added in v1.4.1

func (s *UpdateInstanceRequestAclInfo) SetDefaultVpcAuthFree(v bool) *UpdateInstanceRequestAclInfo

func (UpdateInstanceRequestAclInfo) String added in v1.4.1

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 (*UpdateInstanceRequestNetworkInfo) SetInternetInfo added in v1.0.2

func (UpdateInstanceRequestNetworkInfo) 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 (*UpdateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist added in v1.0.2

func (UpdateInstanceRequestNetworkInfoInternetInfo) String added in v1.0.2

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 (*UpdateInstanceRequestProductInfo) SetAutoScaling added in v1.0.2

func (*UpdateInstanceRequestProductInfo) SetMessageRetentionTime added in v1.0.2

func (*UpdateInstanceRequestProductInfo) SetSendReceiveRatio added in v1.0.2

func (*UpdateInstanceRequestProductInfo) SetTraceOn added in v1.1.2

func (UpdateInstanceRequestProductInfo) String added in v1.0.2

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 (*UpdateInstanceResponse) SetHeaders

func (*UpdateInstanceResponse) SetStatusCode

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 (*UpdateInstanceResponseBody) SetData

func (*UpdateInstanceResponseBody) SetDynamicCode

func (*UpdateInstanceResponseBody) SetDynamicMessage

func (*UpdateInstanceResponseBody) SetHttpStatusCode

func (*UpdateInstanceResponseBody) SetMessage

func (*UpdateInstanceResponseBody) SetRequestId

func (*UpdateInstanceResponseBody) SetSuccess

func (UpdateInstanceResponseBody) 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 (*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 (*UpdateTopicResponseBody) SetData

func (*UpdateTopicResponseBody) SetDynamicCode

func (*UpdateTopicResponseBody) SetDynamicMessage

func (s *UpdateTopicResponseBody) SetDynamicMessage(v string) *UpdateTopicResponseBody

func (*UpdateTopicResponseBody) SetHttpStatusCode

func (s *UpdateTopicResponseBody) SetHttpStatusCode(v int32) *UpdateTopicResponseBody

func (*UpdateTopicResponseBody) SetMessage

func (*UpdateTopicResponseBody) SetRequestId

func (*UpdateTopicResponseBody) SetSuccess

func (UpdateTopicResponseBody) String

func (s UpdateTopicResponseBody) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL