client

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2023 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.
	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.
	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.
	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.
	ResourceType *string `json:"resourceType,omitempty" xml:"resourceType,omitempty"`
}

func (ChangeResourceGroupRequest) GoString added in v1.0.4 

func (s ChangeResourceGroupRequest) GoString() string

func (*ChangeResourceGroupRequest) SetRegionId added in v1.0.4 

func (s *ChangeResourceGroupRequest) SetRegionId(v string) *ChangeResourceGroupRequest

func (*ChangeResourceGroupRequest) SetResourceGroupId added in v1.0.4 

func (s *ChangeResourceGroupRequest) SetResourceGroupId(v string) *ChangeResourceGroupRequest

func (*ChangeResourceGroupRequest) SetResourceId added in v1.0.4 

func (s *ChangeResourceGroupRequest) SetResourceId(v string) *ChangeResourceGroupRequest

func (*ChangeResourceGroupRequest) SetResourceType added in v1.0.4 

func (s *ChangeResourceGroupRequest) SetResourceType(v string) *ChangeResourceGroupRequest

func (ChangeResourceGroupRequest) String added in v1.0.4 

func (s ChangeResourceGroupRequest) String() string

type ChangeResourceGroupResponse added in v1.0.4 

type ChangeResourceGroupResponse struct {
	Headers    map[string]*string               `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                           `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *ChangeResourceGroupResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (ChangeResourceGroupResponse) GoString added in v1.0.4 

func (s ChangeResourceGroupResponse) GoString() string

func (*ChangeResourceGroupResponse) SetBody added in v1.0.4 

func (s *ChangeResourceGroupResponse) SetBody(v *ChangeResourceGroupResponseBody) *ChangeResourceGroupResponse

func (*ChangeResourceGroupResponse) SetHeaders added in v1.0.4 

func (s *ChangeResourceGroupResponse) SetHeaders(v map[string]*string) *ChangeResourceGroupResponse

func (*ChangeResourceGroupResponse) SetStatusCode added in v1.0.4 

func (s *ChangeResourceGroupResponse) SetStatusCode(v int32) *ChangeResourceGroupResponse

func (ChangeResourceGroupResponse) String added in v1.0.4 

func (s ChangeResourceGroupResponse) String() string

type ChangeResourceGroupResponseBody added in v1.0.4 

type ChangeResourceGroupResponseBody struct {
	// The error code returned if the call failed.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The returned result.
	Data *bool `json:"data,omitempty" xml:"data,omitempty"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code returned.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call was successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (ChangeResourceGroupResponseBody) GoString added in v1.0.4 

func (s ChangeResourceGroupResponseBody) GoString() string

func (*ChangeResourceGroupResponseBody) SetCode added in v1.0.4 

func (s *ChangeResourceGroupResponseBody) SetCode(v string) *ChangeResourceGroupResponseBody

func (*ChangeResourceGroupResponseBody) SetData added in v1.0.4 

func (s *ChangeResourceGroupResponseBody) SetData(v bool) *ChangeResourceGroupResponseBody

func (*ChangeResourceGroupResponseBody) SetDynamicCode added in v1.0.4 

func (s *ChangeResourceGroupResponseBody) SetDynamicCode(v string) *ChangeResourceGroupResponseBody

func (*ChangeResourceGroupResponseBody) SetDynamicMessage added in v1.0.4 

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

func (*ChangeResourceGroupResponseBody) SetHttpStatusCode added in v1.0.4 

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

func (*ChangeResourceGroupResponseBody) SetMessage added in v1.0.4 

func (s *ChangeResourceGroupResponseBody) SetMessage(v string) *ChangeResourceGroupResponseBody

func (*ChangeResourceGroupResponseBody) SetRequestId added in v1.0.4 

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

func (*ChangeResourceGroupResponseBody) SetSuccess added in v1.0.4 

func (s *ChangeResourceGroupResponseBody) SetSuccess(v bool) *ChangeResourceGroupResponseBody

func (ChangeResourceGroupResponseBody) String added in v1.0.4 

func (s ChangeResourceGroupResponseBody) String() string

type Client 

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)

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)

func (*Client) CreateConsumerGroup 

func (client *Client) CreateConsumerGroup(instanceId *string, consumerGroupId *string, request *CreateConsumerGroupRequest) (_result *CreateConsumerGroupResponse, _err error)

*

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

*

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

*

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

*

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

func (*Client) CreateTopicWithOptions 

func (client *Client) CreateTopicWithOptions(instanceId *string, topicName *string, request *CreateTopicRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *CreateTopicResponse, _err error)

func (*Client) DeleteConsumerGroup 

func (client *Client) DeleteConsumerGroup(instanceId *string, consumerGroupId *string) (_result *DeleteConsumerGroupResponse, _err error)

*

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

*

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

*

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

*

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

*

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

*

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

*

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

*

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

*

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

*

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

func (*Client) GetTopicWithOptions 

func (client *Client) GetTopicWithOptions(instanceId *string, topicName *string, headers map[string]*string, runtime *util.RuntimeOptions) (_result *GetTopicResponse, _err error)

func (*Client) Init 

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

func (*Client) ListConsumerGroupSubscriptions added in v1.1.0 

func (client *Client) ListConsumerGroupSubscriptions(instanceId *string, consumerGroupId *string) (_result *ListConsumerGroupSubscriptionsResponse, _err error)

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)

func (*Client) ListConsumerGroups 

func (client *Client) ListConsumerGroups(instanceId *string, request *ListConsumerGroupsRequest) (_result *ListConsumerGroupsResponse, _err error)

*

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

*

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

*

  • > 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(request *ListInstancesRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListInstancesResponse, _err error)

*

  • > 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
  • @param headers map
  • @param runtime runtime options for this request RuntimeOptions
  • @return ListInstancesResponse

func (*Client) ListTopics 

func (client *Client) ListTopics(instanceId *string, request *ListTopicsRequest) (_result *ListTopicsResponse, _err error)

func (*Client) ListTopicsWithOptions 

func (client *Client) ListTopicsWithOptions(instanceId *string, tmpReq *ListTopicsRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *ListTopicsResponse, _err error)

func (*Client) ResetConsumeOffset added in v1.1.0 

func (client *Client) ResetConsumeOffset(instanceId *string, consumerGroupId *string, topicName *string, request *ResetConsumeOffsetRequest) (_result *ResetConsumeOffsetResponse, _err error)

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)

func (*Client) UpdateConsumerGroup 

func (client *Client) UpdateConsumerGroup(instanceId *string, consumerGroupId *string, request *UpdateConsumerGroupRequest) (_result *UpdateConsumerGroupResponse, _err error)

*

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

*

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

*

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

*

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

func (*Client) UpdateTopicWithOptions 

func (client *Client) UpdateTopicWithOptions(instanceId *string, topicName *string, request *UpdateTopicRequest, headers map[string]*string, runtime *util.RuntimeOptions) (_result *UpdateTopicResponse, _err error)

type CreateConsumerGroupRequest 

type CreateConsumerGroupRequest struct {
	// The consumption retry policy that you want to configure for the consumer group. For more information, see [Consumption retry](~~440356~~).
	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
	DeliveryOrderType *string `json:"deliveryOrderType,omitempty" xml:"deliveryOrderType,omitempty"`
	// The remarks on the consumer group.
	Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
}

func (CreateConsumerGroupRequest) GoString 

func (s CreateConsumerGroupRequest) GoString() string

func (*CreateConsumerGroupRequest) SetConsumeRetryPolicy 

func (s *CreateConsumerGroupRequest) SetConsumeRetryPolicy(v *CreateConsumerGroupRequestConsumeRetryPolicy) *CreateConsumerGroupRequest

func (*CreateConsumerGroupRequest) SetDeliveryOrderType 

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

func (*CreateConsumerGroupRequest) SetRemark 

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

func (CreateConsumerGroupRequest) String 

func (s CreateConsumerGroupRequest) String() string

type CreateConsumerGroupRequestConsumeRetryPolicy 

type CreateConsumerGroupRequestConsumeRetryPolicy struct {
	// The dead-letter topic.
	//
	// If a consumer still fails to consume a message after the message is retried for a specified number of times, the message is delivered to a dead-letter topic for subsequent business recovery or troubleshooting. For more information, see [Consumption retry and dead-letter messages](~~440356~~).
	DeadLetterTargetTopic *string `json:"deadLetterTargetTopic,omitempty" xml:"deadLetterTargetTopic,omitempty"`
	// The maximum number of retries.
	MaxRetryTimes *int32 `json:"maxRetryTimes,omitempty" xml:"maxRetryTimes,omitempty"`
	// The retry policy. For more information, see [Message retry](~~440356~~).
	//
	// 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.
	RetryPolicy *string `json:"retryPolicy,omitempty" xml:"retryPolicy,omitempty"`
}

func (CreateConsumerGroupRequestConsumeRetryPolicy) GoString 

func (s CreateConsumerGroupRequestConsumeRetryPolicy) GoString() string

func (*CreateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic added in v1.0.3 

func (s *CreateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic(v string) *CreateConsumerGroupRequestConsumeRetryPolicy

func (*CreateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes 

func (s *CreateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes(v int32) *CreateConsumerGroupRequestConsumeRetryPolicy

func (*CreateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy 

func (s *CreateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy(v string) *CreateConsumerGroupRequestConsumeRetryPolicy

func (CreateConsumerGroupRequestConsumeRetryPolicy) String 

func (s CreateConsumerGroupRequestConsumeRetryPolicy) String() string

type CreateConsumerGroupResponse 

type CreateConsumerGroupResponse struct {
	Headers    map[string]*string               `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                           `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *CreateConsumerGroupResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (CreateConsumerGroupResponse) GoString 

func (s CreateConsumerGroupResponse) GoString() string

func (*CreateConsumerGroupResponse) SetBody 

func (s *CreateConsumerGroupResponse) SetBody(v *CreateConsumerGroupResponseBody) *CreateConsumerGroupResponse

func (*CreateConsumerGroupResponse) SetHeaders 

func (s *CreateConsumerGroupResponse) SetHeaders(v map[string]*string) *CreateConsumerGroupResponse

func (*CreateConsumerGroupResponse) SetStatusCode 

func (s *CreateConsumerGroupResponse) SetStatusCode(v int32) *CreateConsumerGroupResponse

func (CreateConsumerGroupResponse) String 

func (s CreateConsumerGroupResponse) String() string

type CreateConsumerGroupResponseBody 

type CreateConsumerGroupResponseBody struct {
	// The error code.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The result data that is returned.
	Data *bool `json:"data,omitempty" xml:"data,omitempty"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call is successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (CreateConsumerGroupResponseBody) GoString 

func (s CreateConsumerGroupResponseBody) GoString() string

func (*CreateConsumerGroupResponseBody) SetCode 

func (s *CreateConsumerGroupResponseBody) SetCode(v string) *CreateConsumerGroupResponseBody

func (*CreateConsumerGroupResponseBody) SetData 

func (s *CreateConsumerGroupResponseBody) SetData(v bool) *CreateConsumerGroupResponseBody

func (*CreateConsumerGroupResponseBody) SetDynamicCode 

func (s *CreateConsumerGroupResponseBody) SetDynamicCode(v string) *CreateConsumerGroupResponseBody

func (*CreateConsumerGroupResponseBody) SetDynamicMessage 

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

func (*CreateConsumerGroupResponseBody) SetHttpStatusCode 

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

func (*CreateConsumerGroupResponseBody) SetMessage 

func (s *CreateConsumerGroupResponseBody) SetMessage(v string) *CreateConsumerGroupResponseBody

func (*CreateConsumerGroupResponseBody) SetRequestId 

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

func (*CreateConsumerGroupResponseBody) SetSuccess 

func (s *CreateConsumerGroupResponseBody) SetSuccess(v bool) *CreateConsumerGroupResponseBody

func (CreateConsumerGroupResponseBody) String 

func (s CreateConsumerGroupResponseBody) String() string

type CreateInstanceRequest added in v1.0.2 

type CreateInstanceRequest struct {
	// Specifies whether to enable auto-renewal. This parameter takes effect only when the PaymentType parameter is set to Subscription.
	//
	// *   true: enable
	// *   false: disable
	AutoRenew *bool `json:"autoRenew,omitempty" xml:"autoRenew,omitempty"`
	// The auto-renewal cycle of the instance. This parameter takes effect only when the autoRenew parameter is set to true. Unit: months.
	//
	// Valid values:
	//
	// *   Monthly renewal: 1, 2, 3, 6, and 12
	AutoRenewPeriod *int32 `json:"autoRenewPeriod,omitempty" xml:"autoRenewPeriod,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.
	InstanceName *string `json:"instanceName,omitempty" xml:"instanceName,omitempty"`
	// The information about the network.
	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: pay-as-you go. 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](~~427234~~).
	PaymentType *string `json:"paymentType,omitempty" xml:"paymentType,omitempty"`
	// The subscription duration of the instance. This parameter takes effect only when the PaymentType parameter is set to Subscription.
	//
	// Valid values:
	//
	// *   Monthly subscription: 1, 2, 3, 4, 5, and 6
	// *   Yearly subscription: 1, 2, and 3
	Period *int32 `json:"period,omitempty" xml:"period,omitempty"`
	// The unit of the subscription duration.
	//
	// Valid values:
	//
	// *   Month
	// *   Year
	PeriodUnit *string `json:"periodUnit,omitempty" xml:"periodUnit,omitempty"`
	// The information about the instance specification.
	ProductInfo *CreateInstanceRequestProductInfo `json:"productInfo,omitempty" xml:"productInfo,omitempty" type:"Struct"`
	// The description of the instance.
	Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
	// The ID of the resource group.
	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](~~444722~~).
	//
	// Valid values:
	//
	// *   standard: Standard Edition
	// *   ultimate: Enterprise Platinum Edition
	// *   professional: Professional Edition
	//
	// > After you create a ApsaraMQ for RocketMQ instance, you can only upgrade the primary edition of the instance. The following editions are sorted in ascending order: Standard Edition, Professional Edition, and Platinum Edition. For example, an instance of Standard Edition can be upgraded to Professional Edition. However, an instance of Professional Edition cannot be downgraded to Standard Edition.
	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.
	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](~~444722~~).
	//
	// Valid values:
	//
	// *   cluster_ha: Cluster High-availability Edition
	// *   single_node: Standalone Edition
	//
	// If you set the seriesCode parameter to ultimate, you can set this parameter to only cluster_ha.
	//
	// > After you create a ApsaraMQ for RocketMQ instance, you cannot change the sub-category edition of the instance.
	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.
	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) SetInstanceName added in v1.0.2 

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

func (*CreateInstanceRequest) SetNetworkInfo added in v1.0.2 

func (s *CreateInstanceRequest) SetNetworkInfo(v *CreateInstanceRequestNetworkInfo) *CreateInstanceRequest

func (*CreateInstanceRequest) SetPaymentType added in v1.0.2 

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

func (*CreateInstanceRequest) SetPeriod added in v1.0.2 

func (s *CreateInstanceRequest) SetPeriod(v int32) *CreateInstanceRequest

func (*CreateInstanceRequest) SetPeriodUnit added in v1.0.2 

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

func (*CreateInstanceRequest) SetProductInfo added in v1.0.2 

func (s *CreateInstanceRequest) SetProductInfo(v *CreateInstanceRequestProductInfo) *CreateInstanceRequest

func (*CreateInstanceRequest) SetRemark added in v1.0.2 

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

func (*CreateInstanceRequest) SetResourceGroupId added in v1.0.2 

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

func (*CreateInstanceRequest) SetSeriesCode added in v1.0.2 

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

func (*CreateInstanceRequest) SetServiceCode added in v1.0.2 

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

func (*CreateInstanceRequest) SetSubSeriesCode added in v1.0.2 

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

func (CreateInstanceRequest) String added in v1.0.2 

func (s CreateInstanceRequest) String() string

type CreateInstanceRequestNetworkInfo added in v1.0.2 

type CreateInstanceRequestNetworkInfo struct {
	// The Internet-related configurations.
	InternetInfo *CreateInstanceRequestNetworkInfoInternetInfo `json:"internetInfo,omitempty" xml:"internetInfo,omitempty" type:"Struct"`
	// The virtual private cloud (VPC)-related configurations.
	VpcInfo *CreateInstanceRequestNetworkInfoVpcInfo `json:"vpcInfo,omitempty" xml:"vpcInfo,omitempty" type:"Struct"`
}

func (CreateInstanceRequestNetworkInfo) GoString added in v1.0.2 

func (s CreateInstanceRequestNetworkInfo) GoString() string

func (*CreateInstanceRequestNetworkInfo) SetInternetInfo added in v1.0.2 

func (s *CreateInstanceRequestNetworkInfo) SetInternetInfo(v *CreateInstanceRequestNetworkInfoInternetInfo) *CreateInstanceRequestNetworkInfo

func (*CreateInstanceRequestNetworkInfo) SetVpcInfo added in v1.0.2 

func (s *CreateInstanceRequestNetworkInfo) SetVpcInfo(v *CreateInstanceRequestNetworkInfoVpcInfo) *CreateInstanceRequestNetworkInfo

func (CreateInstanceRequestNetworkInfo) String added in v1.0.2 

func (s CreateInstanceRequestNetworkInfo) String() string

type CreateInstanceRequestNetworkInfoInternetInfo added in v1.0.2 

type CreateInstanceRequestNetworkInfoInternetInfo struct {
	// The Internet bandwidth. Unit: MB/s.
	//
	// This parameter is required only when the flowOutType parameter is set to payByBandwidth.
	//
	// Valid values: 1 to 1000.
	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 disabled, specify this value for the parameter.
	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 VPCs. If you enable the Internet access feature, you are charged for Internet outbound bandwidth. For more information, see [Internet access fee](~~427240~~).
	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 when you use a public endpoint 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 (CreateInstanceRequestNetworkInfoInternetInfo) GoString added in v1.0.2 

func (s CreateInstanceRequestNetworkInfoInternetInfo) GoString() string

func (*CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutBandwidth added in v1.0.2 

func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutBandwidth(v int32) *CreateInstanceRequestNetworkInfoInternetInfo

func (*CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutType added in v1.0.2 

func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetFlowOutType(v string) *CreateInstanceRequestNetworkInfoInternetInfo

func (*CreateInstanceRequestNetworkInfoInternetInfo) SetInternetSpec added in v1.0.2 

func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetInternetSpec(v string) *CreateInstanceRequestNetworkInfoInternetInfo

func (*CreateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist added in v1.0.2 

func (s *CreateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist(v []*string) *CreateInstanceRequestNetworkInfoInternetInfo

func (CreateInstanceRequestNetworkInfoInternetInfo) String added in v1.0.2 

func (s CreateInstanceRequestNetworkInfoInternetInfo) String() string

type CreateInstanceRequestNetworkInfoVpcInfo added in v1.0.2 

type CreateInstanceRequestNetworkInfoVpcInfo struct {
	// The ID of the vSwitch with which the instance is associated.
	//
	// > After you create a ApsaraMQ for RocketMQ instance, you cannot change the vSwitch to which the instance is connected. If you want to change the vSwitch with which a ApsaraMQ for RocketMQ is associated, you must release the instance and purchase a new instance.
	VSwitchId *string `json:"vSwitchId,omitempty" xml:"vSwitchId,omitempty"`
	// The ID of the VPC with which the instance that you want to create is associated.
	//
	// > After you create a ApsaraMQ for RocketMQ instance, you cannot change the VPC in which the instance is created. If you want to change the VPC with which a ApsaraMQ for RocketMQ is associated, you must release the instance and purchase a new instance.
	VpcId *string `json:"vpcId,omitempty" xml:"vpcId,omitempty"`
}

func (CreateInstanceRequestNetworkInfoVpcInfo) GoString added in v1.0.2 

func (s CreateInstanceRequestNetworkInfoVpcInfo) GoString() string

func (*CreateInstanceRequestNetworkInfoVpcInfo) SetVSwitchId added in v1.0.2 

func (s *CreateInstanceRequestNetworkInfoVpcInfo) SetVSwitchId(v string) *CreateInstanceRequestNetworkInfoVpcInfo

func (*CreateInstanceRequestNetworkInfoVpcInfo) SetVpcId added in v1.0.2 

func (s *CreateInstanceRequestNetworkInfoVpcInfo) SetVpcId(v string) *CreateInstanceRequestNetworkInfoVpcInfo

func (CreateInstanceRequestNetworkInfoVpcInfo) String added in v1.0.2 

func (s CreateInstanceRequestNetworkInfoVpcInfo) String() string

type 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 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](~~427237~~).
	//
	// > The elastic TPS feature is supported by only specific instance editions. For more information, see [Instance specifications](~~444715~~).
	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](~~440347~~).
	//
	// 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](~~427238~~).
	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](~~444715~~).
	MsgProcessSpec *string `json:"msgProcessSpec,omitempty" xml:"msgProcessSpec,omitempty"`
	// The ratio between sent messages and received messages in the instance.
	//
	// Value values: 0.2 to 0.5.
	SendReceiveRatio *float32 `json:"sendReceiveRatio,omitempty" xml:"sendReceiveRatio,omitempty"`
}

func (CreateInstanceRequestProductInfo) GoString added in v1.0.2 

func (s CreateInstanceRequestProductInfo) GoString() string

func (*CreateInstanceRequestProductInfo) SetAutoScaling added in v1.0.2 

func (s *CreateInstanceRequestProductInfo) SetAutoScaling(v bool) *CreateInstanceRequestProductInfo

func (*CreateInstanceRequestProductInfo) SetMessageRetentionTime added in v1.0.2 

func (s *CreateInstanceRequestProductInfo) SetMessageRetentionTime(v int32) *CreateInstanceRequestProductInfo

func (*CreateInstanceRequestProductInfo) SetMsgProcessSpec added in v1.0.2 

func (s *CreateInstanceRequestProductInfo) SetMsgProcessSpec(v string) *CreateInstanceRequestProductInfo

func (*CreateInstanceRequestProductInfo) SetSendReceiveRatio added in v1.0.2 

func (s *CreateInstanceRequestProductInfo) SetSendReceiveRatio(v float32) *CreateInstanceRequestProductInfo

func (CreateInstanceRequestProductInfo) String added in v1.0.2 

func (s CreateInstanceRequestProductInfo) String() string

type CreateInstanceResponse added in v1.0.2 

type CreateInstanceResponse struct {
	Headers    map[string]*string          `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                      `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *CreateInstanceResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (CreateInstanceResponse) GoString added in v1.0.2 

func (s CreateInstanceResponse) GoString() string

func (*CreateInstanceResponse) SetBody added in v1.0.2 

func (s *CreateInstanceResponse) SetBody(v *CreateInstanceResponseBody) *CreateInstanceResponse

func (*CreateInstanceResponse) SetHeaders added in v1.0.2 

func (s *CreateInstanceResponse) SetHeaders(v map[string]*string) *CreateInstanceResponse

func (*CreateInstanceResponse) SetStatusCode added in v1.0.2 

func (s *CreateInstanceResponse) SetStatusCode(v int32) *CreateInstanceResponse

func (CreateInstanceResponse) String added in v1.0.2 

func (s CreateInstanceResponse) String() string

type CreateInstanceResponseBody added in v1.0.2 

type CreateInstanceResponseBody struct {
	// The error code returned if the call failed.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The ID of the created instance.
	Data *string `json:"data,omitempty" xml:"data,omitempty"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code returned.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call was successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (CreateInstanceResponseBody) GoString added in v1.0.2 

func (s CreateInstanceResponseBody) GoString() string

func (*CreateInstanceResponseBody) SetCode added in v1.0.2 

func (s *CreateInstanceResponseBody) SetCode(v string) *CreateInstanceResponseBody

func (*CreateInstanceResponseBody) SetData added in v1.0.2 

func (s *CreateInstanceResponseBody) SetData(v string) *CreateInstanceResponseBody

func (*CreateInstanceResponseBody) SetDynamicCode added in v1.0.2 

func (s *CreateInstanceResponseBody) SetDynamicCode(v string) *CreateInstanceResponseBody

func (*CreateInstanceResponseBody) SetDynamicMessage added in v1.0.2 

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

func (*CreateInstanceResponseBody) SetHttpStatusCode added in v1.0.2 

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

func (*CreateInstanceResponseBody) SetMessage added in v1.0.2 

func (s *CreateInstanceResponseBody) SetMessage(v string) *CreateInstanceResponseBody

func (*CreateInstanceResponseBody) SetRequestId added in v1.0.2 

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

func (*CreateInstanceResponseBody) SetSuccess added in v1.0.2 

func (s *CreateInstanceResponseBody) SetSuccess(v bool) *CreateInstanceResponseBody

func (CreateInstanceResponseBody) String added in v1.0.2 

func (s CreateInstanceResponseBody) String() string

type CreateTopicRequest 

type CreateTopicRequest struct {
	// The type of messages in the topic that you want to create.
	//
	// Valid values:
	//
	// *   TRANSACTION: transactional messages
	// *   FIFO: ordered messages
	// *   DELAY: scheduled messages or delayed Message
	// *   NORMAL: normal messages
	//
	// > The type of messages in the topic must be the same as the type of messages that you want to send. For example, if you create a topic whose message type is ordered messages, the topic can be used to send and receive only ordered messages.
	MessageType *string `json:"messageType,omitempty" xml:"messageType,omitempty"`
	// The description of the topic that you want to create.
	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" require:"true"`
	StatusCode *int32                   `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *CreateTopicResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (CreateTopicResponse) GoString 

func (s CreateTopicResponse) GoString() string

func (*CreateTopicResponse) SetBody 

func (s *CreateTopicResponse) SetBody(v *CreateTopicResponseBody) *CreateTopicResponse

func (*CreateTopicResponse) SetHeaders 

func (s *CreateTopicResponse) SetHeaders(v map[string]*string) *CreateTopicResponse

func (*CreateTopicResponse) SetStatusCode 

func (s *CreateTopicResponse) SetStatusCode(v int32) *CreateTopicResponse

func (CreateTopicResponse) String 

func (s CreateTopicResponse) String() string

type CreateTopicResponseBody 

type CreateTopicResponseBody struct {
	// The error code returned if the call failed.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The returned result.
	Data *bool `json:"data,omitempty" xml:"data,omitempty"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code returned.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call was successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (CreateTopicResponseBody) GoString 

func (s CreateTopicResponseBody) GoString() string

func (*CreateTopicResponseBody) SetCode 

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

func (*CreateTopicResponseBody) SetData 

func (s *CreateTopicResponseBody) SetData(v bool) *CreateTopicResponseBody

func (*CreateTopicResponseBody) SetDynamicCode 

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

func (*CreateTopicResponseBody) SetDynamicMessage 

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

func (*CreateTopicResponseBody) SetHttpStatusCode 

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

func (*CreateTopicResponseBody) SetMessage 

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

func (*CreateTopicResponseBody) SetRequestId 

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

func (*CreateTopicResponseBody) SetSuccess 

func (s *CreateTopicResponseBody) SetSuccess(v bool) *CreateTopicResponseBody

func (CreateTopicResponseBody) String 

func (s CreateTopicResponseBody) String() string

type DeleteConsumerGroupResponse 

type DeleteConsumerGroupResponse struct {
	Headers    map[string]*string               `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                           `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *DeleteConsumerGroupResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (DeleteConsumerGroupResponse) GoString 

func (s DeleteConsumerGroupResponse) GoString() string

func (*DeleteConsumerGroupResponse) SetBody 

func (s *DeleteConsumerGroupResponse) SetBody(v *DeleteConsumerGroupResponseBody) *DeleteConsumerGroupResponse

func (*DeleteConsumerGroupResponse) SetHeaders 

func (s *DeleteConsumerGroupResponse) SetHeaders(v map[string]*string) *DeleteConsumerGroupResponse

func (*DeleteConsumerGroupResponse) SetStatusCode 

func (s *DeleteConsumerGroupResponse) SetStatusCode(v int32) *DeleteConsumerGroupResponse

func (DeleteConsumerGroupResponse) String 

func (s DeleteConsumerGroupResponse) String() string

type DeleteConsumerGroupResponseBody 

type DeleteConsumerGroupResponseBody struct {
	// The error code.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The result data that is returned.
	Data *bool `json:"data,omitempty" xml:"data,omitempty"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call is successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (DeleteConsumerGroupResponseBody) GoString 

func (s DeleteConsumerGroupResponseBody) GoString() string

func (*DeleteConsumerGroupResponseBody) SetCode 

func (s *DeleteConsumerGroupResponseBody) SetCode(v string) *DeleteConsumerGroupResponseBody

func (*DeleteConsumerGroupResponseBody) SetData 

func (s *DeleteConsumerGroupResponseBody) SetData(v bool) *DeleteConsumerGroupResponseBody

func (*DeleteConsumerGroupResponseBody) SetDynamicCode 

func (s *DeleteConsumerGroupResponseBody) SetDynamicCode(v string) *DeleteConsumerGroupResponseBody

func (*DeleteConsumerGroupResponseBody) SetDynamicMessage 

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

func (*DeleteConsumerGroupResponseBody) SetHttpStatusCode 

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

func (*DeleteConsumerGroupResponseBody) SetMessage 

func (s *DeleteConsumerGroupResponseBody) SetMessage(v string) *DeleteConsumerGroupResponseBody

func (*DeleteConsumerGroupResponseBody) SetRequestId 

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

func (*DeleteConsumerGroupResponseBody) SetSuccess 

func (s *DeleteConsumerGroupResponseBody) SetSuccess(v bool) *DeleteConsumerGroupResponseBody

func (DeleteConsumerGroupResponseBody) String 

func (s DeleteConsumerGroupResponseBody) String() string

type DeleteInstanceResponse 

type DeleteInstanceResponse struct {
	Headers    map[string]*string          `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                      `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *DeleteInstanceResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (DeleteInstanceResponse) GoString 

func (s DeleteInstanceResponse) GoString() string

func (*DeleteInstanceResponse) SetBody 

func (s *DeleteInstanceResponse) SetBody(v *DeleteInstanceResponseBody) *DeleteInstanceResponse

func (*DeleteInstanceResponse) SetHeaders 

func (s *DeleteInstanceResponse) SetHeaders(v map[string]*string) *DeleteInstanceResponse

func (*DeleteInstanceResponse) SetStatusCode 

func (s *DeleteInstanceResponse) SetStatusCode(v int32) *DeleteInstanceResponse

func (DeleteInstanceResponse) String 

func (s DeleteInstanceResponse) String() string

type DeleteInstanceResponseBody 

type DeleteInstanceResponseBody struct {
	// The error code returned if the call failed.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The returned result.
	Data *bool `json:"data,omitempty" xml:"data,omitempty"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code returned.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call was successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (DeleteInstanceResponseBody) GoString 

func (s DeleteInstanceResponseBody) GoString() string

func (*DeleteInstanceResponseBody) SetCode 

func (s *DeleteInstanceResponseBody) SetCode(v string) *DeleteInstanceResponseBody

func (*DeleteInstanceResponseBody) SetData 

func (s *DeleteInstanceResponseBody) SetData(v bool) *DeleteInstanceResponseBody

func (*DeleteInstanceResponseBody) SetDynamicCode 

func (s *DeleteInstanceResponseBody) SetDynamicCode(v string) *DeleteInstanceResponseBody

func (*DeleteInstanceResponseBody) SetDynamicMessage 

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

func (*DeleteInstanceResponseBody) SetHttpStatusCode 

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

func (*DeleteInstanceResponseBody) SetMessage 

func (s *DeleteInstanceResponseBody) SetMessage(v string) *DeleteInstanceResponseBody

func (*DeleteInstanceResponseBody) SetRequestId 

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

func (*DeleteInstanceResponseBody) SetSuccess 

func (s *DeleteInstanceResponseBody) SetSuccess(v bool) *DeleteInstanceResponseBody

func (DeleteInstanceResponseBody) String 

func (s DeleteInstanceResponseBody) String() string

type DeleteTopicResponse 

type DeleteTopicResponse struct {
	Headers    map[string]*string       `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                   `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *DeleteTopicResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (DeleteTopicResponse) GoString 

func (s DeleteTopicResponse) GoString() string

func (*DeleteTopicResponse) SetBody 

func (s *DeleteTopicResponse) SetBody(v *DeleteTopicResponseBody) *DeleteTopicResponse

func (*DeleteTopicResponse) SetHeaders 

func (s *DeleteTopicResponse) SetHeaders(v map[string]*string) *DeleteTopicResponse

func (*DeleteTopicResponse) SetStatusCode 

func (s *DeleteTopicResponse) SetStatusCode(v int32) *DeleteTopicResponse

func (DeleteTopicResponse) String 

func (s DeleteTopicResponse) String() string

type DeleteTopicResponseBody 

type DeleteTopicResponseBody struct {
	// The error code.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The result data that is returned.
	Data *bool `json:"data,omitempty" xml:"data,omitempty"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call is successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (DeleteTopicResponseBody) GoString 

func (s DeleteTopicResponseBody) GoString() string

func (*DeleteTopicResponseBody) SetCode 

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

func (*DeleteTopicResponseBody) SetData 

func (s *DeleteTopicResponseBody) SetData(v bool) *DeleteTopicResponseBody

func (*DeleteTopicResponseBody) SetDynamicCode 

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

func (*DeleteTopicResponseBody) SetDynamicMessage 

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

func (*DeleteTopicResponseBody) SetHttpStatusCode 

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

func (*DeleteTopicResponseBody) SetMessage 

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

func (*DeleteTopicResponseBody) SetRequestId 

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

func (*DeleteTopicResponseBody) SetSuccess 

func (s *DeleteTopicResponseBody) SetSuccess(v bool) *DeleteTopicResponseBody

func (DeleteTopicResponseBody) String 

func (s DeleteTopicResponseBody) String() string

type GetConsumerGroupResponse 

type GetConsumerGroupResponse struct {
	Headers    map[string]*string            `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                        `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *GetConsumerGroupResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (GetConsumerGroupResponse) GoString 

func (s GetConsumerGroupResponse) GoString() string

func (*GetConsumerGroupResponse) SetBody 

func (s *GetConsumerGroupResponse) SetBody(v *GetConsumerGroupResponseBody) *GetConsumerGroupResponse

func (*GetConsumerGroupResponse) SetHeaders 

func (s *GetConsumerGroupResponse) SetHeaders(v map[string]*string) *GetConsumerGroupResponse

func (*GetConsumerGroupResponse) SetStatusCode 

func (s *GetConsumerGroupResponse) SetStatusCode(v int32) *GetConsumerGroupResponse

func (GetConsumerGroupResponse) String 

func (s GetConsumerGroupResponse) String() string

type GetConsumerGroupResponseBody 

type GetConsumerGroupResponseBody struct {
	// The error code.
	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.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call is successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (GetConsumerGroupResponseBody) GoString 

func (s GetConsumerGroupResponseBody) GoString() string

func (*GetConsumerGroupResponseBody) SetCode 

func (s *GetConsumerGroupResponseBody) SetCode(v string) *GetConsumerGroupResponseBody

func (*GetConsumerGroupResponseBody) SetData 

func (s *GetConsumerGroupResponseBody) SetData(v *GetConsumerGroupResponseBodyData) *GetConsumerGroupResponseBody

func (*GetConsumerGroupResponseBody) SetDynamicCode 

func (s *GetConsumerGroupResponseBody) SetDynamicCode(v string) *GetConsumerGroupResponseBody

func (*GetConsumerGroupResponseBody) SetDynamicMessage 

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

func (*GetConsumerGroupResponseBody) SetHttpStatusCode 

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

func (*GetConsumerGroupResponseBody) SetMessage 

func (s *GetConsumerGroupResponseBody) SetMessage(v string) *GetConsumerGroupResponseBody

func (*GetConsumerGroupResponseBody) SetRequestId 

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

func (*GetConsumerGroupResponseBody) SetSuccess 

func (s *GetConsumerGroupResponseBody) SetSuccess(v bool) *GetConsumerGroupResponseBody

func (GetConsumerGroupResponseBody) String 

func (s GetConsumerGroupResponseBody) String() string

type GetConsumerGroupResponseBodyData 

type GetConsumerGroupResponseBodyData struct {
	// The consumption retry policy that you want to configure for the consumer group. For more information, see [Consumption retry](~~440356~~).
	ConsumeRetryPolicy *GetConsumerGroupResponseBodyDataConsumeRetryPolicy `json:"consumeRetryPolicy,omitempty" xml:"consumeRetryPolicy,omitempty" type:"Struct"`
	// The ID of the consumer group.
	ConsumerGroupId *string `json:"consumerGroupId,omitempty" xml:"consumerGroupId,omitempty"`
	// The time when the consumer group was created.
	CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
	// The message delivery order of the consumer group.
	//
	// Valid values:
	//
	// *   Concurrently
	//
	//     <!-- -->
	//
	//     :
	//
	//     <!-- -->
	//
	//     concurrent delivery
	//
	//     <!-- -->
	//
	// *   Orderly
	//
	//     <!-- -->
	//
	//     :
	//
	//     <!-- -->
	//
	//     ordered delivery
	//
	//     <!-- -->
	DeliveryOrderType *string `json:"deliveryOrderType,omitempty" xml:"deliveryOrderType,omitempty"`
	// The ID of the instance.
	InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
	// The ID of the region in which the instance resides.
	RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
	// The remarks on the consumer group.
	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
	//
	//     <!-- -->
	//
	//     .
	Status *string `json:"status,omitempty" xml:"status,omitempty"`
	// The time when the consumer group was last updated.
	UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
}

func (GetConsumerGroupResponseBodyData) GoString 

func (s GetConsumerGroupResponseBodyData) GoString() string

func (*GetConsumerGroupResponseBodyData) SetConsumeRetryPolicy 

func (s *GetConsumerGroupResponseBodyData) SetConsumeRetryPolicy(v *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) *GetConsumerGroupResponseBodyData

func (*GetConsumerGroupResponseBodyData) SetConsumerGroupId 

func (s *GetConsumerGroupResponseBodyData) SetConsumerGroupId(v string) *GetConsumerGroupResponseBodyData

func (*GetConsumerGroupResponseBodyData) SetCreateTime 

func (s *GetConsumerGroupResponseBodyData) SetCreateTime(v string) *GetConsumerGroupResponseBodyData

func (*GetConsumerGroupResponseBodyData) SetDeliveryOrderType 

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

func (*GetConsumerGroupResponseBodyData) SetInstanceId 

func (s *GetConsumerGroupResponseBodyData) SetInstanceId(v string) *GetConsumerGroupResponseBodyData

func (*GetConsumerGroupResponseBodyData) SetRegionId 

func (s *GetConsumerGroupResponseBodyData) SetRegionId(v string) *GetConsumerGroupResponseBodyData

func (*GetConsumerGroupResponseBodyData) SetRemark 

func (s *GetConsumerGroupResponseBodyData) SetRemark(v string) *GetConsumerGroupResponseBodyData

func (*GetConsumerGroupResponseBodyData) SetStatus 

func (s *GetConsumerGroupResponseBodyData) SetStatus(v string) *GetConsumerGroupResponseBodyData

func (*GetConsumerGroupResponseBodyData) SetUpdateTime 

func (s *GetConsumerGroupResponseBodyData) SetUpdateTime(v string) *GetConsumerGroupResponseBodyData

func (GetConsumerGroupResponseBodyData) String 

func (s GetConsumerGroupResponseBodyData) String() string

type GetConsumerGroupResponseBodyDataConsumeRetryPolicy 

type GetConsumerGroupResponseBodyDataConsumeRetryPolicy struct {
	// The dead-letter topic.
	//
	// If a consumer still fails to consume a message after the message is retried for a specified number of times, the message is delivered to a dead-letter topic for subsequent business recovery or troubleshooting. For more information, see [Consumption retry and dead-letter messages](~~440356~~).
	DeadLetterTargetTopic *string `json:"deadLetterTargetTopic,omitempty" xml:"deadLetterTargetTopic,omitempty"`
	// The maximum number of retries.
	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
	//
	//     <!-- -->
	//
	//     .
	RetryPolicy *string `json:"retryPolicy,omitempty" xml:"retryPolicy,omitempty"`
}

func (GetConsumerGroupResponseBodyDataConsumeRetryPolicy) GoString 

func (s GetConsumerGroupResponseBodyDataConsumeRetryPolicy) GoString() string

func (*GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetDeadLetterTargetTopic added in v1.0.3 

func (s *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetDeadLetterTargetTopic(v string) *GetConsumerGroupResponseBodyDataConsumeRetryPolicy

func (*GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetMaxRetryTimes 

func (s *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetMaxRetryTimes(v int32) *GetConsumerGroupResponseBodyDataConsumeRetryPolicy

func (*GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetRetryPolicy 

func (s *GetConsumerGroupResponseBodyDataConsumeRetryPolicy) SetRetryPolicy(v string) *GetConsumerGroupResponseBodyDataConsumeRetryPolicy

func (GetConsumerGroupResponseBodyDataConsumeRetryPolicy) String 

func (s GetConsumerGroupResponseBodyDataConsumeRetryPolicy) String() string

type GetInstanceResponse 

type GetInstanceResponse struct {
	Headers    map[string]*string       `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                   `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *GetInstanceResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (GetInstanceResponse) GoString 

func (s GetInstanceResponse) GoString() string

func (*GetInstanceResponse) SetBody 

func (s *GetInstanceResponse) SetBody(v *GetInstanceResponseBody) *GetInstanceResponse

func (*GetInstanceResponse) SetHeaders 

func (s *GetInstanceResponse) SetHeaders(v map[string]*string) *GetInstanceResponse

func (*GetInstanceResponse) SetStatusCode 

func (s *GetInstanceResponse) SetStatusCode(v int32) *GetInstanceResponse

func (GetInstanceResponse) String 

func (s GetInstanceResponse) String() string

type GetInstanceResponseBody 

type GetInstanceResponseBody struct {
	// The error code returned if the call failed.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The returned result.
	Data *GetInstanceResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Struct"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code returned.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call was successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (GetInstanceResponseBody) GoString 

func (s GetInstanceResponseBody) GoString() string

func (*GetInstanceResponseBody) SetCode 

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

func (*GetInstanceResponseBody) SetData 

func (s *GetInstanceResponseBody) SetData(v *GetInstanceResponseBodyData) *GetInstanceResponseBody

func (*GetInstanceResponseBody) SetDynamicCode 

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

func (*GetInstanceResponseBody) SetDynamicMessage 

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

func (*GetInstanceResponseBody) SetHttpStatusCode 

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

func (*GetInstanceResponseBody) SetMessage 

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

func (*GetInstanceResponseBody) SetRequestId 

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

func (*GetInstanceResponseBody) SetSuccess 

func (s *GetInstanceResponseBody) SetSuccess(v bool) *GetInstanceResponseBody

func (GetInstanceResponseBody) String 

func (s GetInstanceResponseBody) String() string

type GetInstanceResponseBodyData 

type GetInstanceResponseBodyData struct {
	// The account information.
	AccountInfo *GetInstanceResponseBodyDataAccountInfo `json:"accountInfo,omitempty" xml:"accountInfo,omitempty" type:"Struct"`
	// The information about access control.
	AclInfo *GetInstanceResponseBodyDataAclInfo `json:"aclInfo,omitempty" xml:"aclInfo,omitempty" type:"Struct"`
	// The business ID (BID) of the commodity.
	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.
	CommodityCode *string `json:"commodityCode,omitempty" xml:"commodityCode,omitempty"`
	// The time when the instance was created.
	CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
	// The time when the instance expires.
	ExpireTime *string `json:"expireTime,omitempty" xml:"expireTime,omitempty"`
	// The extended configurations. We recommend you configure the productInfo, internetInfo, or aclInfo parameter instead of this parameter.
	ExtConfig  *GetInstanceResponseBodyDataExtConfig `json:"extConfig,omitempty" xml:"extConfig,omitempty" type:"Struct"`
	GroupCount *int64                                `json:"groupCount,omitempty" xml:"groupCount,omitempty"`
	// The ID of the instance
	InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
	// The name of the instance.
	InstanceName *string `json:"instanceName,omitempty" xml:"instanceName,omitempty"`
	// The quotas in the instance.
	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
	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.
	RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
	// The time when the instance was released.
	ReleaseTime *string `json:"releaseTime,omitempty" xml:"releaseTime,omitempty"`
	// The description of the instance.
	Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
	// The ID of the resource group.
	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](~~444722~~).
	//
	// Valid values:
	//
	// *   standard: Standard Edition
	// *   ultimate: Enterprise Platinum Edition
	// *   professional: Professional Edition
	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.
	ServiceCode *string                              `json:"serviceCode,omitempty" xml:"serviceCode,omitempty"`
	Software    *GetInstanceResponseBodyDataSoftware `json:"software,omitempty" xml:"software,omitempty" type:"Struct"`
	// The time when the instance was started.
	StartTime *string `json:"startTime,omitempty" xml:"startTime,omitempty"`
	// The status of the instance.
	//
	// Valid values:
	//
	// *   RELEASED
	// *   RUNNING
	// *   STOPPED
	// *   CHANGING
	// *   CREATING
	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](~~444722~~).
	//
	// Valid values:
	//
	// *   cluster_ha: Cluster High-availability Edition
	// *   single_node: Standalone Edition
	SubSeriesCode *string                            `json:"subSeriesCode,omitempty" xml:"subSeriesCode,omitempty"`
	Tags          []*GetInstanceResponseBodyDataTags `json:"tags,omitempty" xml:"tags,omitempty" type:"Repeated"`
	TopicCount    *int64                             `json:"topicCount,omitempty" xml:"topicCount,omitempty"`
	// The time when the instance was last modified.
	UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
	// The ID of the user who owns the instance.
	UserId *string `json:"userId,omitempty" xml:"userId,omitempty"`
}

func (GetInstanceResponseBodyData) GoString 

func (s GetInstanceResponseBodyData) GoString() string

func (*GetInstanceResponseBodyData) SetAccountInfo 

func (s *GetInstanceResponseBodyData) SetAccountInfo(v *GetInstanceResponseBodyDataAccountInfo) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetAclInfo added in v1.0.2 

func (s *GetInstanceResponseBodyData) SetAclInfo(v *GetInstanceResponseBodyDataAclInfo) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetBid 

func (s *GetInstanceResponseBodyData) SetBid(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetCommodityCode 

func (s *GetInstanceResponseBodyData) SetCommodityCode(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetCreateTime 

func (s *GetInstanceResponseBodyData) SetCreateTime(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetExpireTime 

func (s *GetInstanceResponseBodyData) SetExpireTime(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetExtConfig 

func (s *GetInstanceResponseBodyData) SetExtConfig(v *GetInstanceResponseBodyDataExtConfig) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetGroupCount added in v1.0.1 

func (s *GetInstanceResponseBodyData) SetGroupCount(v int64) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetInstanceId 

func (s *GetInstanceResponseBodyData) SetInstanceId(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetInstanceName 

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

func (*GetInstanceResponseBodyData) SetInstanceQuotas 

func (s *GetInstanceResponseBodyData) SetInstanceQuotas(v []*GetInstanceResponseBodyDataInstanceQuotas) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetNetworkInfo 

func (s *GetInstanceResponseBodyData) SetNetworkInfo(v *GetInstanceResponseBodyDataNetworkInfo) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetPaymentType 

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

func (*GetInstanceResponseBodyData) SetProductInfo added in v1.0.2 

func (s *GetInstanceResponseBodyData) SetProductInfo(v *GetInstanceResponseBodyDataProductInfo) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetRegionId 

func (s *GetInstanceResponseBodyData) SetRegionId(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetReleaseTime 

func (s *GetInstanceResponseBodyData) SetReleaseTime(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetRemark 

func (s *GetInstanceResponseBodyData) SetRemark(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetResourceGroupId 

func (s *GetInstanceResponseBodyData) SetResourceGroupId(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetSeriesCode 

func (s *GetInstanceResponseBodyData) SetSeriesCode(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetServiceCode 

func (s *GetInstanceResponseBodyData) SetServiceCode(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetSoftware added in v1.0.6 

func (s *GetInstanceResponseBodyData) SetSoftware(v *GetInstanceResponseBodyDataSoftware) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetStartTime 

func (s *GetInstanceResponseBodyData) SetStartTime(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetStatus 

func (s *GetInstanceResponseBodyData) SetStatus(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetSubSeriesCode 

func (s *GetInstanceResponseBodyData) SetSubSeriesCode(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetTags added in v1.1.0 

func (s *GetInstanceResponseBodyData) SetTags(v []*GetInstanceResponseBodyDataTags) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetTopicCount added in v1.0.1 

func (s *GetInstanceResponseBodyData) SetTopicCount(v int64) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetUpdateTime 

func (s *GetInstanceResponseBodyData) SetUpdateTime(v string) *GetInstanceResponseBodyData

func (*GetInstanceResponseBodyData) SetUserId 

func (s *GetInstanceResponseBodyData) SetUserId(v string) *GetInstanceResponseBodyData

func (GetInstanceResponseBodyData) String 

func (s GetInstanceResponseBodyData) String() string

type GetInstanceResponseBodyDataAccountInfo 

type GetInstanceResponseBodyDataAccountInfo struct {
	// The username of the instance. If you access a ApsaraMQ for RocketMQ instance over the Internet, you must configure the username and password of the instance in the SDK code for authentication.
	Username *string `json:"username,omitempty" xml:"username,omitempty"`
}

func (GetInstanceResponseBodyDataAccountInfo) GoString 

func (s GetInstanceResponseBodyDataAccountInfo) GoString() string

func (*GetInstanceResponseBodyDataAccountInfo) SetUsername 

func (s *GetInstanceResponseBodyDataAccountInfo) SetUsername(v string) *GetInstanceResponseBodyDataAccountInfo

func (GetInstanceResponseBodyDataAccountInfo) String 

func (s GetInstanceResponseBodyDataAccountInfo) String() string

type GetInstanceResponseBodyDataAclInfo added in v1.0.2 

type GetInstanceResponseBodyDataAclInfo struct {
	// The authentication type of the instance.
	//
	// Valid values:
	//
	// *   default: intelligent authentication
	AclType *string `json:"aclType,omitempty" xml:"aclType,omitempty"`
}

func (GetInstanceResponseBodyDataAclInfo) GoString added in v1.0.2 

func (s GetInstanceResponseBodyDataAclInfo) GoString() string

func (*GetInstanceResponseBodyDataAclInfo) SetAclType added in v1.0.2 

func (s *GetInstanceResponseBodyDataAclInfo) SetAclType(v string) *GetInstanceResponseBodyDataAclInfo

func (GetInstanceResponseBodyDataAclInfo) String added in v1.0.2 

func (s GetInstanceResponseBodyDataAclInfo) String() string

type GetInstanceResponseBodyDataExtConfig 

type GetInstanceResponseBodyDataExtConfig struct {
	// The authentication type of the instance.
	//
	// Valid values:
	//
	// *   default: intelligent authentication
	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.
	AutoScaling *bool `json:"autoScaling,omitempty" xml:"autoScaling,omitempty"`
	// The Internet bandwidth. Unit: MB/s.
	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
	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](~~427240~~).
	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](~~440347~~).
	//
	// 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](~~427238~~).
	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](~~444715~~).
	MsgProcessSpec *string `json:"msgProcessSpec,omitempty" xml:"msgProcessSpec,omitempty"`
	// The ratio between sent messages and received messages in the instance.
	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](~~427237~~).
	//
	// > The elastic TPS feature is supported only by specific instance editions. For more information, see [Instance specifications](~~444715~~).
	SupportAutoScaling *bool `json:"supportAutoScaling,omitempty" xml:"supportAutoScaling,omitempty"`
}

func (GetInstanceResponseBodyDataExtConfig) GoString 

func (s GetInstanceResponseBodyDataExtConfig) GoString() string

func (*GetInstanceResponseBodyDataExtConfig) SetAclType 

func (s *GetInstanceResponseBodyDataExtConfig) SetAclType(v string) *GetInstanceResponseBodyDataExtConfig

func (*GetInstanceResponseBodyDataExtConfig) SetAutoScaling 

func (s *GetInstanceResponseBodyDataExtConfig) SetAutoScaling(v bool) *GetInstanceResponseBodyDataExtConfig

func (*GetInstanceResponseBodyDataExtConfig) SetFlowOutBandwidth 

func (s *GetInstanceResponseBodyDataExtConfig) SetFlowOutBandwidth(v int32) *GetInstanceResponseBodyDataExtConfig

func (*GetInstanceResponseBodyDataExtConfig) SetFlowOutType 

func (s *GetInstanceResponseBodyDataExtConfig) SetFlowOutType(v string) *GetInstanceResponseBodyDataExtConfig

func (*GetInstanceResponseBodyDataExtConfig) SetInternetSpec 

func (s *GetInstanceResponseBodyDataExtConfig) SetInternetSpec(v string) *GetInstanceResponseBodyDataExtConfig

func (*GetInstanceResponseBodyDataExtConfig) SetMessageRetentionTime 

func (s *GetInstanceResponseBodyDataExtConfig) SetMessageRetentionTime(v int32) *GetInstanceResponseBodyDataExtConfig

func (*GetInstanceResponseBodyDataExtConfig) SetMsgProcessSpec 

func (s *GetInstanceResponseBodyDataExtConfig) SetMsgProcessSpec(v string) *GetInstanceResponseBodyDataExtConfig

func (*GetInstanceResponseBodyDataExtConfig) SetSendReceiveRatio 

func (s *GetInstanceResponseBodyDataExtConfig) SetSendReceiveRatio(v float32) *GetInstanceResponseBodyDataExtConfig

func (*GetInstanceResponseBodyDataExtConfig) SetSupportAutoScaling 

func (s *GetInstanceResponseBodyDataExtConfig) SetSupportAutoScaling(v bool) *GetInstanceResponseBodyDataExtConfig

func (GetInstanceResponseBodyDataExtConfig) String 

func (s GetInstanceResponseBodyDataExtConfig) String() string

type GetInstanceResponseBodyDataInstanceQuotas 

type GetInstanceResponseBodyDataInstanceQuotas struct {
	// The number of free topics in the instance.
	FreeCount *float64 `json:"freeCount,omitempty" xml:"freeCount,omitempty"`
	// The name of the quota.
	//
	// Valid values:
	//
	// *   TOPIC_COUNT: the number of topics that you can create in the instance
	QuotaName *string `json:"quotaName,omitempty" xml:"quotaName,omitempty"`
	// The total number of topics in the instance.
	TotalCount *float64 `json:"totalCount,omitempty" xml:"totalCount,omitempty"`
	// The number of used topics in the instance.
	UsedCount *float64 `json:"usedCount,omitempty" xml:"usedCount,omitempty"`
}

func (GetInstanceResponseBodyDataInstanceQuotas) GoString 

func (s GetInstanceResponseBodyDataInstanceQuotas) GoString() string

func (*GetInstanceResponseBodyDataInstanceQuotas) SetFreeCount 

func (s *GetInstanceResponseBodyDataInstanceQuotas) SetFreeCount(v float64) *GetInstanceResponseBodyDataInstanceQuotas

func (*GetInstanceResponseBodyDataInstanceQuotas) SetQuotaName 

func (s *GetInstanceResponseBodyDataInstanceQuotas) SetQuotaName(v string) *GetInstanceResponseBodyDataInstanceQuotas

func (*GetInstanceResponseBodyDataInstanceQuotas) SetTotalCount 

func (s *GetInstanceResponseBodyDataInstanceQuotas) SetTotalCount(v float64) *GetInstanceResponseBodyDataInstanceQuotas

func (*GetInstanceResponseBodyDataInstanceQuotas) SetUsedCount 

func (s *GetInstanceResponseBodyDataInstanceQuotas) SetUsedCount(v float64) *GetInstanceResponseBodyDataInstanceQuotas

func (GetInstanceResponseBodyDataInstanceQuotas) String 

func (s GetInstanceResponseBodyDataInstanceQuotas) String() string

type GetInstanceResponseBodyDataNetworkInfo 

type GetInstanceResponseBodyDataNetworkInfo struct {
	// The information about endpoints.
	Endpoints []*GetInstanceResponseBodyDataNetworkInfoEndpoints `json:"endpoints,omitempty" xml:"endpoints,omitempty" type:"Repeated"`
	// The information about the Internet.
	InternetInfo *GetInstanceResponseBodyDataNetworkInfoInternetInfo `json:"internetInfo,omitempty" xml:"internetInfo,omitempty" type:"Struct"`
	// The information about the VPC.
	VpcInfo *GetInstanceResponseBodyDataNetworkInfoVpcInfo `json:"vpcInfo,omitempty" xml:"vpcInfo,omitempty" type:"Struct"`
}

func (GetInstanceResponseBodyDataNetworkInfo) GoString 

func (s GetInstanceResponseBodyDataNetworkInfo) GoString() string

func (*GetInstanceResponseBodyDataNetworkInfo) SetEndpoints 

func (s *GetInstanceResponseBodyDataNetworkInfo) SetEndpoints(v []*GetInstanceResponseBodyDataNetworkInfoEndpoints) *GetInstanceResponseBodyDataNetworkInfo

func (*GetInstanceResponseBodyDataNetworkInfo) SetInternetInfo added in v1.0.2 

func (s *GetInstanceResponseBodyDataNetworkInfo) SetInternetInfo(v *GetInstanceResponseBodyDataNetworkInfoInternetInfo) *GetInstanceResponseBodyDataNetworkInfo

func (*GetInstanceResponseBodyDataNetworkInfo) SetVpcInfo 

func (s *GetInstanceResponseBodyDataNetworkInfo) SetVpcInfo(v *GetInstanceResponseBodyDataNetworkInfoVpcInfo) *GetInstanceResponseBodyDataNetworkInfo

func (GetInstanceResponseBodyDataNetworkInfo) String 

func (s GetInstanceResponseBodyDataNetworkInfo) String() string

type GetInstanceResponseBodyDataNetworkInfoEndpoints 

type GetInstanceResponseBodyDataNetworkInfoEndpoints struct {
	// The type of the endpoint that is used to access the instance.
	//
	// Valid values:
	//
	// *   TCP_VPC: VPC endpoint
	// *   TCP_INTERNET: public endpoint
	EndpointType *string `json:"endpointType,omitempty" xml:"endpointType,omitempty"`
	// The endpoint that is used to access the instance.
	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 when you use a public endpoint 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.
	//
	// We recommend that you configure the internetInfo.ipWhitelist parameter instead of this parameter.
	IpWhitelist []*string `json:"ipWhitelist,omitempty" xml:"ipWhitelist,omitempty" type:"Repeated"`
}

func (GetInstanceResponseBodyDataNetworkInfoEndpoints) GoString 

func (s GetInstanceResponseBodyDataNetworkInfoEndpoints) GoString() string

func (*GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointType 

func (s *GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointType(v string) *GetInstanceResponseBodyDataNetworkInfoEndpoints

func (*GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointUrl 

func (s *GetInstanceResponseBodyDataNetworkInfoEndpoints) SetEndpointUrl(v string) *GetInstanceResponseBodyDataNetworkInfoEndpoints

func (*GetInstanceResponseBodyDataNetworkInfoEndpoints) SetIpWhitelist 

func (s *GetInstanceResponseBodyDataNetworkInfoEndpoints) SetIpWhitelist(v []*string) *GetInstanceResponseBodyDataNetworkInfoEndpoints

func (GetInstanceResponseBodyDataNetworkInfoEndpoints) String 

func (s GetInstanceResponseBodyDataNetworkInfoEndpoints) String() string

type GetInstanceResponseBodyDataNetworkInfoInternetInfo added in v1.0.2 

type GetInstanceResponseBodyDataNetworkInfoInternetInfo struct {
	// The Internet bandwidth. Unit: MB/s.
	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.
	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](~~427240~~).
	InternetSpec *string `json:"internetSpec,omitempty" xml:"internetSpec,omitempty"`
	// The whitelist that includes the IP addresses that are allowed to access the ApsaraMQ for RocketMQ broker.
	//
	// *   If this parameter is not configured, all IP addresses are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
	// *   If this parameter is configured, only the IP addresses that are included in the whitelist can access the ApsaraMQ for RocketMQ broker over the Internet.
	IpWhitelist []*string `json:"ipWhitelist,omitempty" xml:"ipWhitelist,omitempty" type:"Repeated"`
}

func (GetInstanceResponseBodyDataNetworkInfoInternetInfo) GoString added in v1.0.2 

func (s GetInstanceResponseBodyDataNetworkInfoInternetInfo) GoString() string

func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutBandwidth added in v1.0.2 

func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutBandwidth(v int32) *GetInstanceResponseBodyDataNetworkInfoInternetInfo

func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutType added in v1.0.2 

func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetFlowOutType(v string) *GetInstanceResponseBodyDataNetworkInfoInternetInfo

func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetInternetSpec added in v1.0.2 

func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetInternetSpec(v string) *GetInstanceResponseBodyDataNetworkInfoInternetInfo

func (*GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetIpWhitelist added in v1.0.2 

func (s *GetInstanceResponseBodyDataNetworkInfoInternetInfo) SetIpWhitelist(v []*string) *GetInstanceResponseBodyDataNetworkInfoInternetInfo

func (GetInstanceResponseBodyDataNetworkInfoInternetInfo) String added in v1.0.2 

func (s GetInstanceResponseBodyDataNetworkInfoInternetInfo) String() string

type GetInstanceResponseBodyDataNetworkInfoVpcInfo 

type GetInstanceResponseBodyDataNetworkInfoVpcInfo struct {
	// The ID of the vSwitch with which the instance is associated.
	VSwitchId *string `json:"vSwitchId,omitempty" xml:"vSwitchId,omitempty"`
	// The ID of the VPC with which the instance is associated.
	VpcId *string `json:"vpcId,omitempty" xml:"vpcId,omitempty"`
}

func (GetInstanceResponseBodyDataNetworkInfoVpcInfo) GoString 

func (s GetInstanceResponseBodyDataNetworkInfoVpcInfo) GoString() string

func (*GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVSwitchId 

func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVSwitchId(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfo

func (*GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVpcId 

func (s *GetInstanceResponseBodyDataNetworkInfoVpcInfo) SetVpcId(v string) *GetInstanceResponseBodyDataNetworkInfoVpcInfo

func (GetInstanceResponseBodyDataNetworkInfoVpcInfo) String 

func (s GetInstanceResponseBodyDataNetworkInfoVpcInfo) String() string

type GetInstanceResponseBodyDataProductInfo added in v1.0.2 

type GetInstanceResponseBodyDataProductInfo struct {
	// Specifies whether to enable the elastic TPS feature for the instance.
	//
	// Valid values:
	//
	// *   true: enable
	// *   false: disable
	//
	// This parameter is valid only when the supportAutoScaling parameter is set to enable.
	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](~~440347~~).
	//
	// 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](~~427238~~).
	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](~~444715~~).
	MsgProcessSpec *string `json:"msgProcessSpec,omitempty" xml:"msgProcessSpec,omitempty"`
	// The ratio between sent messages and received messages in the instance.
	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](~~427237~~).
	//
	// > The elastic TPS feature is supported by only specific instance editions. For more information, see [Instance specifications](~~444715~~).
	SupportAutoScaling *bool `json:"supportAutoScaling,omitempty" xml:"supportAutoScaling,omitempty"`
}

func (GetInstanceResponseBodyDataProductInfo) GoString added in v1.0.2 

func (s GetInstanceResponseBodyDataProductInfo) GoString() string

func (*GetInstanceResponseBodyDataProductInfo) SetAutoScaling added in v1.0.2 

func (s *GetInstanceResponseBodyDataProductInfo) SetAutoScaling(v bool) *GetInstanceResponseBodyDataProductInfo

func (*GetInstanceResponseBodyDataProductInfo) SetMessageRetentionTime added in v1.0.2 

func (s *GetInstanceResponseBodyDataProductInfo) SetMessageRetentionTime(v int32) *GetInstanceResponseBodyDataProductInfo

func (*GetInstanceResponseBodyDataProductInfo) SetMsgProcessSpec added in v1.0.2 

func (s *GetInstanceResponseBodyDataProductInfo) SetMsgProcessSpec(v string) *GetInstanceResponseBodyDataProductInfo

func (*GetInstanceResponseBodyDataProductInfo) SetSendReceiveRatio added in v1.0.2 

func (s *GetInstanceResponseBodyDataProductInfo) SetSendReceiveRatio(v float32) *GetInstanceResponseBodyDataProductInfo

func (*GetInstanceResponseBodyDataProductInfo) SetSupportAutoScaling added in v1.0.2 

func (s *GetInstanceResponseBodyDataProductInfo) SetSupportAutoScaling(v bool) *GetInstanceResponseBodyDataProductInfo

func (GetInstanceResponseBodyDataProductInfo) String added in v1.0.2 

func (s GetInstanceResponseBodyDataProductInfo) String() string

type GetInstanceResponseBodyDataSoftware added in v1.0.6 

type GetInstanceResponseBodyDataSoftware struct {
	MaintainTime    *string `json:"maintainTime,omitempty" xml:"maintainTime,omitempty"`
	SoftwareVersion *string `json:"softwareVersion,omitempty" xml:"softwareVersion,omitempty"`
	UpgradeMethod   *string `json:"upgradeMethod,omitempty" xml:"upgradeMethod,omitempty"`
}

func (GetInstanceResponseBodyDataSoftware) GoString added in v1.0.6 

func (s GetInstanceResponseBodyDataSoftware) GoString() string

func (*GetInstanceResponseBodyDataSoftware) SetMaintainTime added in v1.0.6 

func (s *GetInstanceResponseBodyDataSoftware) SetMaintainTime(v string) *GetInstanceResponseBodyDataSoftware

func (*GetInstanceResponseBodyDataSoftware) SetSoftwareVersion added in v1.0.6 

func (s *GetInstanceResponseBodyDataSoftware) SetSoftwareVersion(v string) *GetInstanceResponseBodyDataSoftware

func (*GetInstanceResponseBodyDataSoftware) SetUpgradeMethod added in v1.0.6 

func (s *GetInstanceResponseBodyDataSoftware) SetUpgradeMethod(v string) *GetInstanceResponseBodyDataSoftware

func (GetInstanceResponseBodyDataSoftware) String added in v1.0.6 

func (s GetInstanceResponseBodyDataSoftware) String() string

type GetInstanceResponseBodyDataTags added in v1.1.0 

type GetInstanceResponseBodyDataTags struct {
	Key   *string `json:"key,omitempty" xml:"key,omitempty"`
	Value *string `json:"value,omitempty" xml:"value,omitempty"`
}

func (GetInstanceResponseBodyDataTags) GoString added in v1.1.0 

func (s GetInstanceResponseBodyDataTags) GoString() string

func (*GetInstanceResponseBodyDataTags) SetKey added in v1.1.0 

func (s *GetInstanceResponseBodyDataTags) SetKey(v string) *GetInstanceResponseBodyDataTags

func (*GetInstanceResponseBodyDataTags) SetValue added in v1.1.0 

func (s *GetInstanceResponseBodyDataTags) SetValue(v string) *GetInstanceResponseBodyDataTags

func (GetInstanceResponseBodyDataTags) String added in v1.1.0 

func (s GetInstanceResponseBodyDataTags) String() string

type GetTopicResponse 

type GetTopicResponse struct {
	Headers    map[string]*string    `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *GetTopicResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (GetTopicResponse) GoString 

func (s GetTopicResponse) GoString() string

func (*GetTopicResponse) SetBody 

func (s *GetTopicResponse) SetBody(v *GetTopicResponseBody) *GetTopicResponse

func (*GetTopicResponse) SetHeaders 

func (s *GetTopicResponse) SetHeaders(v map[string]*string) *GetTopicResponse

func (*GetTopicResponse) SetStatusCode 

func (s *GetTopicResponse) SetStatusCode(v int32) *GetTopicResponse

func (GetTopicResponse) String 

func (s GetTopicResponse) String() string

type GetTopicResponseBody 

type GetTopicResponseBody struct {
	// The error code.
	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.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call is successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (GetTopicResponseBody) GoString 

func (s GetTopicResponseBody) GoString() string

func (*GetTopicResponseBody) SetCode 

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

func (*GetTopicResponseBody) SetData 

func (s *GetTopicResponseBody) SetData(v *GetTopicResponseBodyData) *GetTopicResponseBody

func (*GetTopicResponseBody) SetDynamicCode 

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

func (*GetTopicResponseBody) SetDynamicMessage 

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

func (*GetTopicResponseBody) SetHttpStatusCode 

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

func (*GetTopicResponseBody) SetMessage 

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

func (*GetTopicResponseBody) SetRequestId 

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

func (*GetTopicResponseBody) SetSuccess 

func (s *GetTopicResponseBody) SetSuccess(v bool) *GetTopicResponseBody

func (GetTopicResponseBody) String 

func (s GetTopicResponseBody) String() string

type GetTopicResponseBodyData 

type GetTopicResponseBodyData struct {
	// The time when the topic was created.
	CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
	// The ID of the instance.
	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
	MessageType *string `json:"messageType,omitempty" xml:"messageType,omitempty"`
	// The ID of the region in which the instance resides.
	RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
	// The remarks on the topic.
	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.
	Status *string `json:"status,omitempty" xml:"status,omitempty"`
	// The name of the topic.
	TopicName *string `json:"topicName,omitempty" xml:"topicName,omitempty"`
	// The time when the topic was last updated.
	UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
}

func (GetTopicResponseBodyData) GoString 

func (s GetTopicResponseBodyData) GoString() string

func (*GetTopicResponseBodyData) SetCreateTime 

func (s *GetTopicResponseBodyData) SetCreateTime(v string) *GetTopicResponseBodyData

func (*GetTopicResponseBodyData) SetInstanceId 

func (s *GetTopicResponseBodyData) SetInstanceId(v string) *GetTopicResponseBodyData

func (*GetTopicResponseBodyData) SetMessageType 

func (s *GetTopicResponseBodyData) SetMessageType(v string) *GetTopicResponseBodyData

func (*GetTopicResponseBodyData) SetRegionId 

func (s *GetTopicResponseBodyData) SetRegionId(v string) *GetTopicResponseBodyData

func (*GetTopicResponseBodyData) SetRemark 

func (s *GetTopicResponseBodyData) SetRemark(v string) *GetTopicResponseBodyData

func (*GetTopicResponseBodyData) SetStatus 

func (s *GetTopicResponseBodyData) SetStatus(v string) *GetTopicResponseBodyData

func (*GetTopicResponseBodyData) SetTopicName 

func (s *GetTopicResponseBodyData) SetTopicName(v string) *GetTopicResponseBodyData

func (*GetTopicResponseBodyData) SetUpdateTime 

func (s *GetTopicResponseBodyData) SetUpdateTime(v string) *GetTopicResponseBodyData

func (GetTopicResponseBodyData) String 

func (s GetTopicResponseBodyData) String() string

type ListConsumerGroupSubscriptionsResponse added in v1.1.0 

type ListConsumerGroupSubscriptionsResponse struct {
	Headers    map[string]*string                          `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                                      `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *ListConsumerGroupSubscriptionsResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (ListConsumerGroupSubscriptionsResponse) GoString added in v1.1.0 

func (s ListConsumerGroupSubscriptionsResponse) GoString() string

func (*ListConsumerGroupSubscriptionsResponse) SetBody added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponse) SetBody(v *ListConsumerGroupSubscriptionsResponseBody) *ListConsumerGroupSubscriptionsResponse

func (*ListConsumerGroupSubscriptionsResponse) SetHeaders added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponse) SetHeaders(v map[string]*string) *ListConsumerGroupSubscriptionsResponse

func (*ListConsumerGroupSubscriptionsResponse) SetStatusCode added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponse) SetStatusCode(v int32) *ListConsumerGroupSubscriptionsResponse

func (ListConsumerGroupSubscriptionsResponse) String added in v1.1.0 

func (s ListConsumerGroupSubscriptionsResponse) String() string

type ListConsumerGroupSubscriptionsResponseBody added in v1.1.0 

type ListConsumerGroupSubscriptionsResponseBody struct {
	Code           *string                                           `json:"code,omitempty" xml:"code,omitempty"`
	Data           []*ListConsumerGroupSubscriptionsResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Repeated"`
	DynamicCode    *string                                           `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	DynamicMessage *string                                           `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	HttpStatusCode *int32                                            `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	Message        *string                                           `json:"message,omitempty" xml:"message,omitempty"`
	RequestId      *string                                           `json:"requestId,omitempty" xml:"requestId,omitempty"`
	Success        *bool                                             `json:"success,omitempty" xml:"success,omitempty"`
}

func (ListConsumerGroupSubscriptionsResponseBody) GoString added in v1.1.0 

func (s ListConsumerGroupSubscriptionsResponseBody) GoString() string

func (*ListConsumerGroupSubscriptionsResponseBody) SetCode added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBody) SetCode(v string) *ListConsumerGroupSubscriptionsResponseBody

func (*ListConsumerGroupSubscriptionsResponseBody) SetData added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBody) SetData(v []*ListConsumerGroupSubscriptionsResponseBodyData) *ListConsumerGroupSubscriptionsResponseBody

func (*ListConsumerGroupSubscriptionsResponseBody) SetDynamicCode added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBody) SetDynamicCode(v string) *ListConsumerGroupSubscriptionsResponseBody

func (*ListConsumerGroupSubscriptionsResponseBody) SetDynamicMessage added in v1.1.0 

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

func (*ListConsumerGroupSubscriptionsResponseBody) SetHttpStatusCode added in v1.1.0 

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

func (*ListConsumerGroupSubscriptionsResponseBody) SetMessage added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBody) SetMessage(v string) *ListConsumerGroupSubscriptionsResponseBody

func (*ListConsumerGroupSubscriptionsResponseBody) SetRequestId added in v1.1.0 

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

func (*ListConsumerGroupSubscriptionsResponseBody) SetSuccess added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBody) SetSuccess(v bool) *ListConsumerGroupSubscriptionsResponseBody

func (ListConsumerGroupSubscriptionsResponseBody) String added in v1.1.0 

func (s ListConsumerGroupSubscriptionsResponseBody) String() string

type ListConsumerGroupSubscriptionsResponseBodyData added in v1.1.0 

type ListConsumerGroupSubscriptionsResponseBodyData struct {
	ConsumerGroupId      *string `json:"consumerGroupId,omitempty" xml:"consumerGroupId,omitempty"`
	FilterExpression     *string `json:"filterExpression,omitempty" xml:"filterExpression,omitempty"`
	FilterExpressionType *string `json:"filterExpressionType,omitempty" xml:"filterExpressionType,omitempty"`
	MessageModel         *string `json:"messageModel,omitempty" xml:"messageModel,omitempty"`
	SubscriptionStatus   *string `json:"subscriptionStatus,omitempty" xml:"subscriptionStatus,omitempty"`
	TopicCreated         *bool   `json:"topicCreated,omitempty" xml:"topicCreated,omitempty"`
	TopicName            *string `json:"topicName,omitempty" xml:"topicName,omitempty"`
}

func (ListConsumerGroupSubscriptionsResponseBodyData) GoString added in v1.1.0 

func (s ListConsumerGroupSubscriptionsResponseBodyData) GoString() string

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetConsumerGroupId added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetConsumerGroupId(v string) *ListConsumerGroupSubscriptionsResponseBodyData

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpression added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpression(v string) *ListConsumerGroupSubscriptionsResponseBodyData

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpressionType added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetFilterExpressionType(v string) *ListConsumerGroupSubscriptionsResponseBodyData

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetMessageModel added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetMessageModel(v string) *ListConsumerGroupSubscriptionsResponseBodyData

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetSubscriptionStatus added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetSubscriptionStatus(v string) *ListConsumerGroupSubscriptionsResponseBodyData

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetTopicCreated added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetTopicCreated(v bool) *ListConsumerGroupSubscriptionsResponseBodyData

func (*ListConsumerGroupSubscriptionsResponseBodyData) SetTopicName added in v1.1.0 

func (s *ListConsumerGroupSubscriptionsResponseBodyData) SetTopicName(v string) *ListConsumerGroupSubscriptionsResponseBodyData

func (ListConsumerGroupSubscriptionsResponseBodyData) String added in v1.1.0 

func (s ListConsumerGroupSubscriptionsResponseBodyData) String() string

type ListConsumerGroupsRequest 

type ListConsumerGroupsRequest struct {
	// The condition that you want to use to filter consumer groups in the instance. If you leave this parameter empty, all consumer groups in the instance are queried.
	Filter *string `json:"filter,omitempty" xml:"filter,omitempty"`
	// The number of the page to return.
	PageNumber *int32 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
	// The number of entries to return on each page.
	PageSize *int32 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
}

func (ListConsumerGroupsRequest) GoString 

func (s ListConsumerGroupsRequest) GoString() string

func (*ListConsumerGroupsRequest) SetFilter 

func (s *ListConsumerGroupsRequest) SetFilter(v string) *ListConsumerGroupsRequest

func (*ListConsumerGroupsRequest) SetPageNumber 

func (s *ListConsumerGroupsRequest) SetPageNumber(v int32) *ListConsumerGroupsRequest

func (*ListConsumerGroupsRequest) SetPageSize 

func (s *ListConsumerGroupsRequest) SetPageSize(v int32) *ListConsumerGroupsRequest

func (ListConsumerGroupsRequest) String 

func (s ListConsumerGroupsRequest) String() string

type ListConsumerGroupsResponse 

type ListConsumerGroupsResponse struct {
	Headers    map[string]*string              `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                          `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *ListConsumerGroupsResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (ListConsumerGroupsResponse) GoString 

func (s ListConsumerGroupsResponse) GoString() string

func (*ListConsumerGroupsResponse) SetBody 

func (s *ListConsumerGroupsResponse) SetBody(v *ListConsumerGroupsResponseBody) *ListConsumerGroupsResponse

func (*ListConsumerGroupsResponse) SetHeaders 

func (s *ListConsumerGroupsResponse) SetHeaders(v map[string]*string) *ListConsumerGroupsResponse

func (*ListConsumerGroupsResponse) SetStatusCode 

func (s *ListConsumerGroupsResponse) SetStatusCode(v int32) *ListConsumerGroupsResponse

func (ListConsumerGroupsResponse) String 

func (s ListConsumerGroupsResponse) String() string

type ListConsumerGroupsResponseBody 

type ListConsumerGroupsResponseBody struct {
	// The error code.
	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.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call is successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (ListConsumerGroupsResponseBody) GoString 

func (s ListConsumerGroupsResponseBody) GoString() string

func (*ListConsumerGroupsResponseBody) SetCode 

func (s *ListConsumerGroupsResponseBody) SetCode(v string) *ListConsumerGroupsResponseBody

func (*ListConsumerGroupsResponseBody) SetData 

func (s *ListConsumerGroupsResponseBody) SetData(v *ListConsumerGroupsResponseBodyData) *ListConsumerGroupsResponseBody

func (*ListConsumerGroupsResponseBody) SetDynamicCode 

func (s *ListConsumerGroupsResponseBody) SetDynamicCode(v string) *ListConsumerGroupsResponseBody

func (*ListConsumerGroupsResponseBody) SetDynamicMessage 

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

func (*ListConsumerGroupsResponseBody) SetHttpStatusCode 

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

func (*ListConsumerGroupsResponseBody) SetMessage 

func (s *ListConsumerGroupsResponseBody) SetMessage(v string) *ListConsumerGroupsResponseBody

func (*ListConsumerGroupsResponseBody) SetRequestId 

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

func (*ListConsumerGroupsResponseBody) SetSuccess 

func (s *ListConsumerGroupsResponseBody) SetSuccess(v bool) *ListConsumerGroupsResponseBody

func (ListConsumerGroupsResponseBody) String 

func (s ListConsumerGroupsResponseBody) String() string

type ListConsumerGroupsResponseBodyData 

type ListConsumerGroupsResponseBodyData struct {
	// The paginated data.
	List []*ListConsumerGroupsResponseBodyDataList `json:"list,omitempty" xml:"list,omitempty" type:"Repeated"`
	// The page number of the returned page.
	PageNumber *int64 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
	// The number of entries returned per page.
	PageSize *int64 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
	// The total number of returned entries.
	TotalCount *int64 `json:"totalCount,omitempty" xml:"totalCount,omitempty"`
}

func (ListConsumerGroupsResponseBodyData) GoString 

func (s ListConsumerGroupsResponseBodyData) GoString() string

func (*ListConsumerGroupsResponseBodyData) SetList 

func (s *ListConsumerGroupsResponseBodyData) SetList(v []*ListConsumerGroupsResponseBodyDataList) *ListConsumerGroupsResponseBodyData

func (*ListConsumerGroupsResponseBodyData) SetPageNumber 

func (s *ListConsumerGroupsResponseBodyData) SetPageNumber(v int64) *ListConsumerGroupsResponseBodyData

func (*ListConsumerGroupsResponseBodyData) SetPageSize 

func (s *ListConsumerGroupsResponseBodyData) SetPageSize(v int64) *ListConsumerGroupsResponseBodyData

func (*ListConsumerGroupsResponseBodyData) SetTotalCount 

func (s *ListConsumerGroupsResponseBodyData) SetTotalCount(v int64) *ListConsumerGroupsResponseBodyData

func (ListConsumerGroupsResponseBodyData) String 

func (s ListConsumerGroupsResponseBodyData) String() string

type ListConsumerGroupsResponseBodyDataList 

type ListConsumerGroupsResponseBodyDataList struct {
	// The ID of the consumer group.
	ConsumerGroupId *string `json:"consumerGroupId,omitempty" xml:"consumerGroupId,omitempty"`
	// The time when the consumer group was created.
	CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
	// The ID of the instance.
	InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
	// The ID of the region in which the instance resides.
	RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
	// The remarks on the consumer group.
	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
	//
	//     <!-- -->
	//
	//     .
	Status *string `json:"status,omitempty" xml:"status,omitempty"`
	// The time when the consumer group was last updated.
	UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
}

func (ListConsumerGroupsResponseBodyDataList) GoString 

func (s ListConsumerGroupsResponseBodyDataList) GoString() string

func (*ListConsumerGroupsResponseBodyDataList) SetConsumerGroupId 

func (s *ListConsumerGroupsResponseBodyDataList) SetConsumerGroupId(v string) *ListConsumerGroupsResponseBodyDataList

func (*ListConsumerGroupsResponseBodyDataList) SetCreateTime 

func (s *ListConsumerGroupsResponseBodyDataList) SetCreateTime(v string) *ListConsumerGroupsResponseBodyDataList

func (*ListConsumerGroupsResponseBodyDataList) SetInstanceId 

func (s *ListConsumerGroupsResponseBodyDataList) SetInstanceId(v string) *ListConsumerGroupsResponseBodyDataList

func (*ListConsumerGroupsResponseBodyDataList) SetRegionId 

func (s *ListConsumerGroupsResponseBodyDataList) SetRegionId(v string) *ListConsumerGroupsResponseBodyDataList

func (*ListConsumerGroupsResponseBodyDataList) SetRemark 

func (s *ListConsumerGroupsResponseBodyDataList) SetRemark(v string) *ListConsumerGroupsResponseBodyDataList

func (*ListConsumerGroupsResponseBodyDataList) SetStatus 

func (s *ListConsumerGroupsResponseBodyDataList) SetStatus(v string) *ListConsumerGroupsResponseBodyDataList

func (*ListConsumerGroupsResponseBodyDataList) SetUpdateTime 

func (s *ListConsumerGroupsResponseBodyDataList) SetUpdateTime(v string) *ListConsumerGroupsResponseBodyDataList

func (ListConsumerGroupsResponseBodyDataList) String 

func (s ListConsumerGroupsResponseBodyDataList) String() string

type ListInstancesRequest 

type ListInstancesRequest struct {
	// The filter condition that is used to query instances. If you do not configure this parameter, all instances are queried.
	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.
	PageNumber *int32 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
	// The number of entries returned on each page.
	//
	// Value 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.
	PageSize *int32 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
	// The ID of the resource group to which the instance belongs.
	ResourceGroupId *string `json:"resourceGroupId,omitempty" xml:"resourceGroupId,omitempty"`
	Tags            *string `json:"tags,omitempty" xml:"tags,omitempty"`
}

func (ListInstancesRequest) GoString 

func (s ListInstancesRequest) GoString() string

func (*ListInstancesRequest) SetFilter 

func (s *ListInstancesRequest) SetFilter(v string) *ListInstancesRequest

func (*ListInstancesRequest) SetPageNumber 

func (s *ListInstancesRequest) SetPageNumber(v int32) *ListInstancesRequest

func (*ListInstancesRequest) SetPageSize 

func (s *ListInstancesRequest) SetPageSize(v int32) *ListInstancesRequest

func (*ListInstancesRequest) SetResourceGroupId 

func (s *ListInstancesRequest) SetResourceGroupId(v string) *ListInstancesRequest

func (*ListInstancesRequest) SetTags added in v1.1.0 

func (s *ListInstancesRequest) SetTags(v string) *ListInstancesRequest

func (ListInstancesRequest) String 

func (s ListInstancesRequest) String() string

type ListInstancesResponse 

type ListInstancesResponse struct {
	Headers    map[string]*string         `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                     `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *ListInstancesResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (ListInstancesResponse) GoString 

func (s ListInstancesResponse) GoString() string

func (*ListInstancesResponse) SetBody 

func (s *ListInstancesResponse) SetBody(v *ListInstancesResponseBody) *ListInstancesResponse

func (*ListInstancesResponse) SetHeaders 

func (s *ListInstancesResponse) SetHeaders(v map[string]*string) *ListInstancesResponse

func (*ListInstancesResponse) SetStatusCode 

func (s *ListInstancesResponse) SetStatusCode(v int32) *ListInstancesResponse

func (ListInstancesResponse) String 

func (s ListInstancesResponse) String() string

type ListInstancesResponseBody 

type ListInstancesResponseBody struct {
	// The error code returned if the call failed.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The returned result.
	Data *ListInstancesResponseBodyData `json:"data,omitempty" xml:"data,omitempty" type:"Struct"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code returned.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call was successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (ListInstancesResponseBody) GoString 

func (s ListInstancesResponseBody) GoString() string

func (*ListInstancesResponseBody) SetCode 

func (s *ListInstancesResponseBody) SetCode(v string) *ListInstancesResponseBody

func (*ListInstancesResponseBody) SetData 

func (s *ListInstancesResponseBody) SetData(v *ListInstancesResponseBodyData) *ListInstancesResponseBody

func (*ListInstancesResponseBody) SetDynamicCode 

func (s *ListInstancesResponseBody) SetDynamicCode(v string) *ListInstancesResponseBody

func (*ListInstancesResponseBody) SetDynamicMessage 

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

func (*ListInstancesResponseBody) SetHttpStatusCode 

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

func (*ListInstancesResponseBody) SetMessage 

func (s *ListInstancesResponseBody) SetMessage(v string) *ListInstancesResponseBody

func (*ListInstancesResponseBody) SetRequestId 

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

func (*ListInstancesResponseBody) SetSuccess 

func (s *ListInstancesResponseBody) SetSuccess(v bool) *ListInstancesResponseBody

func (ListInstancesResponseBody) String 

func (s ListInstancesResponseBody) String() string

type ListInstancesResponseBodyData 

type ListInstancesResponseBodyData struct {
	// The page number of the returned page.
	List []*ListInstancesResponseBodyDataList `json:"list,omitempty" xml:"list,omitempty" type:"Repeated"`
	// The page number of the returned page.
	PageNumber *int64 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
	// The number of entries returned on each page.
	PageSize *int64 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
	// The total number of returned entries.
	TotalCount *int64 `json:"totalCount,omitempty" xml:"totalCount,omitempty"`
}

func (ListInstancesResponseBodyData) GoString 

func (s ListInstancesResponseBodyData) GoString() string

func (*ListInstancesResponseBodyData) SetList 

func (s *ListInstancesResponseBodyData) SetList(v []*ListInstancesResponseBodyDataList) *ListInstancesResponseBodyData

func (*ListInstancesResponseBodyData) SetPageNumber 

func (s *ListInstancesResponseBodyData) SetPageNumber(v int64) *ListInstancesResponseBodyData

func (*ListInstancesResponseBodyData) SetPageSize 

func (s *ListInstancesResponseBodyData) SetPageSize(v int64) *ListInstancesResponseBodyData

func (*ListInstancesResponseBodyData) SetTotalCount 

func (s *ListInstancesResponseBodyData) SetTotalCount(v int64) *ListInstancesResponseBodyData

func (ListInstancesResponseBodyData) String 

func (s ListInstancesResponseBodyData) String() string

type ListInstancesResponseBodyDataList 

type ListInstancesResponseBodyDataList struct {
	// The commodity code of the instance. The commodity code of a ApsaraMQ for RocketMQ 5.0 instance has a similar format as ons_rmqsub_public_cn.
	CommodityCode *string `json:"commodityCode,omitempty" xml:"commodityCode,omitempty"`
	// The time when the instance was created.
	CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
	// The time when the instance expires.
	ExpireTime *string `json:"expireTime,omitempty" xml:"expireTime,omitempty"`
	// The number of consumer groups created in the instance.
	GroupCount *int64 `json:"groupCount,omitempty" xml:"groupCount,omitempty"`
	// The ID of the instance
	InstanceId *string `json:"instanceId,omitempty" xml:"instanceId,omitempty"`
	// The name of the instance.
	InstanceName *string `json:"instanceName,omitempty" xml:"instanceName,omitempty"`
	// The billing method of the instance.
	//
	// Valid values:
	//
	// *   PayAsYouGo: pay-as-you-go
	// *   Subscription
	PaymentType *string `json:"paymentType,omitempty" xml:"paymentType,omitempty"`
	// The ID of the region in which the instance resides.
	RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
	// The time when the instance was released.
	ReleaseTime *string `json:"releaseTime,omitempty" xml:"releaseTime,omitempty"`
	// The description of the instance.
	Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
	// The ID of the resource group to which the instance belongs.
	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
	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.
	ServiceCode *string `json:"serviceCode,omitempty" xml:"serviceCode,omitempty"`
	// The time when the instance was started.
	StartTime *string `json:"startTime,omitempty" xml:"startTime,omitempty"`
	// The status of the instance.
	//
	// Valid values:
	//
	// *   RELEASED
	// *   RUNNING
	// *   STOPPED
	// *   CHANGING
	// *   CREATING
	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
	SubSeriesCode *string                                  `json:"subSeriesCode,omitempty" xml:"subSeriesCode,omitempty"`
	Tags          []*ListInstancesResponseBodyDataListTags `json:"tags,omitempty" xml:"tags,omitempty" type:"Repeated"`
	// The number of topics created in the instance.
	TopicCount *int64 `json:"topicCount,omitempty" xml:"topicCount,omitempty"`
	// The time when the instance was last modified.
	UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
	// The ID of the user who owns the instance.
	UserId *string `json:"userId,omitempty" xml:"userId,omitempty"`
}

func (ListInstancesResponseBodyDataList) GoString 

func (s ListInstancesResponseBodyDataList) GoString() string

func (*ListInstancesResponseBodyDataList) SetCommodityCode 

func (s *ListInstancesResponseBodyDataList) SetCommodityCode(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetCreateTime 

func (s *ListInstancesResponseBodyDataList) SetCreateTime(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetExpireTime 

func (s *ListInstancesResponseBodyDataList) SetExpireTime(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetGroupCount 

func (s *ListInstancesResponseBodyDataList) SetGroupCount(v int64) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetInstanceId 

func (s *ListInstancesResponseBodyDataList) SetInstanceId(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetInstanceName 

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

func (*ListInstancesResponseBodyDataList) SetPaymentType 

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

func (*ListInstancesResponseBodyDataList) SetRegionId 

func (s *ListInstancesResponseBodyDataList) SetRegionId(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetReleaseTime 

func (s *ListInstancesResponseBodyDataList) SetReleaseTime(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetRemark 

func (s *ListInstancesResponseBodyDataList) SetRemark(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetResourceGroupId 

func (s *ListInstancesResponseBodyDataList) SetResourceGroupId(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetSeriesCode 

func (s *ListInstancesResponseBodyDataList) SetSeriesCode(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetServiceCode 

func (s *ListInstancesResponseBodyDataList) SetServiceCode(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetStartTime 

func (s *ListInstancesResponseBodyDataList) SetStartTime(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetStatus 

func (s *ListInstancesResponseBodyDataList) SetStatus(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetSubSeriesCode 

func (s *ListInstancesResponseBodyDataList) SetSubSeriesCode(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetTags added in v1.1.0 

func (s *ListInstancesResponseBodyDataList) SetTags(v []*ListInstancesResponseBodyDataListTags) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetTopicCount 

func (s *ListInstancesResponseBodyDataList) SetTopicCount(v int64) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetUpdateTime 

func (s *ListInstancesResponseBodyDataList) SetUpdateTime(v string) *ListInstancesResponseBodyDataList

func (*ListInstancesResponseBodyDataList) SetUserId 

func (s *ListInstancesResponseBodyDataList) SetUserId(v string) *ListInstancesResponseBodyDataList

func (ListInstancesResponseBodyDataList) String 

func (s ListInstancesResponseBodyDataList) String() string

type ListInstancesResponseBodyDataListTags added in v1.1.0 

type ListInstancesResponseBodyDataListTags struct {
	Key   *string `json:"key,omitempty" xml:"key,omitempty"`
	Value *string `json:"value,omitempty" xml:"value,omitempty"`
}

func (ListInstancesResponseBodyDataListTags) GoString added in v1.1.0 

func (s ListInstancesResponseBodyDataListTags) GoString() string

func (*ListInstancesResponseBodyDataListTags) SetKey added in v1.1.0 

func (s *ListInstancesResponseBodyDataListTags) SetKey(v string) *ListInstancesResponseBodyDataListTags

func (*ListInstancesResponseBodyDataListTags) SetValue added in v1.1.0 

func (s *ListInstancesResponseBodyDataListTags) SetValue(v string) *ListInstancesResponseBodyDataListTags

func (ListInstancesResponseBodyDataListTags) String added in v1.1.0 

func (s ListInstancesResponseBodyDataListTags) String() string

type 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.
	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.
	PageNumber *int32 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
	// The number of entries to return on each page.
	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" require:"true"`
	StatusCode *int32                  `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *ListTopicsResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (ListTopicsResponse) GoString 

func (s ListTopicsResponse) GoString() string

func (*ListTopicsResponse) SetBody 

func (s *ListTopicsResponse) SetBody(v *ListTopicsResponseBody) *ListTopicsResponse

func (*ListTopicsResponse) SetHeaders 

func (s *ListTopicsResponse) SetHeaders(v map[string]*string) *ListTopicsResponse

func (*ListTopicsResponse) SetStatusCode 

func (s *ListTopicsResponse) SetStatusCode(v int32) *ListTopicsResponse

func (ListTopicsResponse) String 

func (s ListTopicsResponse) String() string

type ListTopicsResponseBody 

type ListTopicsResponseBody struct {
	// The error code.
	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.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call is successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (ListTopicsResponseBody) GoString 

func (s ListTopicsResponseBody) GoString() string

func (*ListTopicsResponseBody) SetCode 

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

func (*ListTopicsResponseBody) SetData 

func (s *ListTopicsResponseBody) SetData(v *ListTopicsResponseBodyData) *ListTopicsResponseBody

func (*ListTopicsResponseBody) SetDynamicCode 

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

func (*ListTopicsResponseBody) SetDynamicMessage 

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

func (*ListTopicsResponseBody) SetHttpStatusCode 

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

func (*ListTopicsResponseBody) SetMessage 

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

func (*ListTopicsResponseBody) SetRequestId 

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

func (*ListTopicsResponseBody) SetSuccess 

func (s *ListTopicsResponseBody) SetSuccess(v bool) *ListTopicsResponseBody

func (ListTopicsResponseBody) String 

func (s ListTopicsResponseBody) String() string

type ListTopicsResponseBodyData 

type ListTopicsResponseBodyData struct {
	// The paginated data.
	List []*ListTopicsResponseBodyDataList `json:"list,omitempty" xml:"list,omitempty" type:"Repeated"`
	// The page number of the returned page.
	PageNumber *int64 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
	// The number of entries returned per page.
	PageSize *int64 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
	// The total number of returned entries.
	TotalCount *int64 `json:"totalCount,omitempty" xml:"totalCount,omitempty"`
}

func (ListTopicsResponseBodyData) GoString 

func (s ListTopicsResponseBodyData) GoString() string

func (*ListTopicsResponseBodyData) SetList 

func (s *ListTopicsResponseBodyData) SetList(v []*ListTopicsResponseBodyDataList) *ListTopicsResponseBodyData

func (*ListTopicsResponseBodyData) SetPageNumber 

func (s *ListTopicsResponseBodyData) SetPageNumber(v int64) *ListTopicsResponseBodyData

func (*ListTopicsResponseBodyData) SetPageSize 

func (s *ListTopicsResponseBodyData) SetPageSize(v int64) *ListTopicsResponseBodyData

func (*ListTopicsResponseBodyData) SetTotalCount 

func (s *ListTopicsResponseBodyData) SetTotalCount(v int64) *ListTopicsResponseBodyData

func (ListTopicsResponseBodyData) String 

func (s ListTopicsResponseBodyData) String() string

type ListTopicsResponseBodyDataList 

type ListTopicsResponseBodyDataList struct {
	// The time when the topic was created.
	CreateTime *string `json:"createTime,omitempty" xml:"createTime,omitempty"`
	// The ID of the instance.
	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
	//
	//     <!-- -->
	MessageType *string `json:"messageType,omitempty" xml:"messageType,omitempty"`
	// The ID of the region in which the instance resides.
	RegionId *string `json:"regionId,omitempty" xml:"regionId,omitempty"`
	// The remarks on the topic.
	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
	//
	//     <!-- -->
	//
	//     .
	Status *string `json:"status,omitempty" xml:"status,omitempty"`
	// The name of the topic.
	TopicName *string `json:"topicName,omitempty" xml:"topicName,omitempty"`
	// The time when the topic was last updated.
	UpdateTime *string `json:"updateTime,omitempty" xml:"updateTime,omitempty"`
}

func (ListTopicsResponseBodyDataList) GoString 

func (s ListTopicsResponseBodyDataList) GoString() string

func (*ListTopicsResponseBodyDataList) SetCreateTime 

func (s *ListTopicsResponseBodyDataList) SetCreateTime(v string) *ListTopicsResponseBodyDataList

func (*ListTopicsResponseBodyDataList) SetInstanceId 

func (s *ListTopicsResponseBodyDataList) SetInstanceId(v string) *ListTopicsResponseBodyDataList

func (*ListTopicsResponseBodyDataList) SetMessageType 

func (s *ListTopicsResponseBodyDataList) SetMessageType(v string) *ListTopicsResponseBodyDataList

func (*ListTopicsResponseBodyDataList) SetRegionId 

func (s *ListTopicsResponseBodyDataList) SetRegionId(v string) *ListTopicsResponseBodyDataList

func (*ListTopicsResponseBodyDataList) SetRemark 

func (s *ListTopicsResponseBodyDataList) SetRemark(v string) *ListTopicsResponseBodyDataList

func (*ListTopicsResponseBodyDataList) SetStatus 

func (s *ListTopicsResponseBodyDataList) SetStatus(v string) *ListTopicsResponseBodyDataList

func (*ListTopicsResponseBodyDataList) SetTopicName 

func (s *ListTopicsResponseBodyDataList) SetTopicName(v string) *ListTopicsResponseBodyDataList

func (*ListTopicsResponseBodyDataList) SetUpdateTime 

func (s *ListTopicsResponseBodyDataList) SetUpdateTime(v string) *ListTopicsResponseBodyDataList

func (ListTopicsResponseBodyDataList) String 

func (s ListTopicsResponseBodyDataList) String() string

type ListTopicsShrinkRequest added in v1.0.3 

type ListTopicsShrinkRequest struct {
	// The condition that you want to use to filter topics in the instance. If you leave this parameter empty, all topics in the instance are queried.
	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.
	PageNumber *int32 `json:"pageNumber,omitempty" xml:"pageNumber,omitempty"`
	// The number of entries to return on each page.
	PageSize *int32 `json:"pageSize,omitempty" xml:"pageSize,omitempty"`
}

func (ListTopicsShrinkRequest) GoString added in v1.0.3 

func (s ListTopicsShrinkRequest) GoString() string

func (*ListTopicsShrinkRequest) SetFilter added in v1.0.3 

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

func (*ListTopicsShrinkRequest) SetMessageTypesShrink added in v1.0.3 

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

func (*ListTopicsShrinkRequest) SetPageNumber added in v1.0.3 

func (s *ListTopicsShrinkRequest) SetPageNumber(v int32) *ListTopicsShrinkRequest

func (*ListTopicsShrinkRequest) SetPageSize added in v1.0.3 

func (s *ListTopicsShrinkRequest) SetPageSize(v int32) *ListTopicsShrinkRequest

func (ListTopicsShrinkRequest) String added in v1.0.3 

func (s ListTopicsShrinkRequest) String() string

type ResetConsumeOffsetRequest added in v1.1.0 

type ResetConsumeOffsetRequest struct {
	ResetTime *string `json:"resetTime,omitempty" xml:"resetTime,omitempty"`
	ResetType *string `json:"resetType,omitempty" xml:"resetType,omitempty"`
}

func (ResetConsumeOffsetRequest) GoString added in v1.1.0 

func (s ResetConsumeOffsetRequest) GoString() string

func (*ResetConsumeOffsetRequest) SetResetTime added in v1.1.0 

func (s *ResetConsumeOffsetRequest) SetResetTime(v string) *ResetConsumeOffsetRequest

func (*ResetConsumeOffsetRequest) SetResetType added in v1.1.0 

func (s *ResetConsumeOffsetRequest) SetResetType(v string) *ResetConsumeOffsetRequest

func (ResetConsumeOffsetRequest) String added in v1.1.0 

func (s ResetConsumeOffsetRequest) String() string

type ResetConsumeOffsetResponse added in v1.1.0 

type ResetConsumeOffsetResponse struct {
	Headers    map[string]*string              `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                          `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *ResetConsumeOffsetResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (ResetConsumeOffsetResponse) GoString added in v1.1.0 

func (s ResetConsumeOffsetResponse) GoString() string

func (*ResetConsumeOffsetResponse) SetBody added in v1.1.0 

func (s *ResetConsumeOffsetResponse) SetBody(v *ResetConsumeOffsetResponseBody) *ResetConsumeOffsetResponse

func (*ResetConsumeOffsetResponse) SetHeaders added in v1.1.0 

func (s *ResetConsumeOffsetResponse) SetHeaders(v map[string]*string) *ResetConsumeOffsetResponse

func (*ResetConsumeOffsetResponse) SetStatusCode added in v1.1.0 

func (s *ResetConsumeOffsetResponse) SetStatusCode(v int32) *ResetConsumeOffsetResponse

func (ResetConsumeOffsetResponse) String added in v1.1.0 

func (s ResetConsumeOffsetResponse) String() string

type ResetConsumeOffsetResponseBody added in v1.1.0 

type ResetConsumeOffsetResponseBody struct {
	Code           *string `json:"code,omitempty" xml:"code,omitempty"`
	DynamicCode    *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	HttpStatusCode *int32  `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	Message        *string `json:"message,omitempty" xml:"message,omitempty"`
	RequestId      *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	Success        *bool   `json:"success,omitempty" xml:"success,omitempty"`
}

func (ResetConsumeOffsetResponseBody) GoString added in v1.1.0 

func (s ResetConsumeOffsetResponseBody) GoString() string

func (*ResetConsumeOffsetResponseBody) SetCode added in v1.1.0 

func (s *ResetConsumeOffsetResponseBody) SetCode(v string) *ResetConsumeOffsetResponseBody

func (*ResetConsumeOffsetResponseBody) SetDynamicCode added in v1.1.0 

func (s *ResetConsumeOffsetResponseBody) SetDynamicCode(v string) *ResetConsumeOffsetResponseBody

func (*ResetConsumeOffsetResponseBody) SetDynamicMessage added in v1.1.0 

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

func (*ResetConsumeOffsetResponseBody) SetHttpStatusCode added in v1.1.0 

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

func (*ResetConsumeOffsetResponseBody) SetMessage added in v1.1.0 

func (s *ResetConsumeOffsetResponseBody) SetMessage(v string) *ResetConsumeOffsetResponseBody

func (*ResetConsumeOffsetResponseBody) SetRequestId added in v1.1.0 

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

func (*ResetConsumeOffsetResponseBody) SetSuccess added in v1.1.0 

func (s *ResetConsumeOffsetResponseBody) SetSuccess(v bool) *ResetConsumeOffsetResponseBody

func (ResetConsumeOffsetResponseBody) String added in v1.1.0 

func (s ResetConsumeOffsetResponseBody) String() string

type UpdateConsumerGroupRequest 

type UpdateConsumerGroupRequest struct {
	// The new consumption retry policy that you want to configure for the consumer group. For more information, see [Consumption retry](~~440356~~).
	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
	DeliveryOrderType *string `json:"deliveryOrderType,omitempty" xml:"deliveryOrderType,omitempty"`
	// The new remarks on the consumer group.
	Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
}

func (UpdateConsumerGroupRequest) GoString 

func (s UpdateConsumerGroupRequest) GoString() string

func (*UpdateConsumerGroupRequest) SetConsumeRetryPolicy 

func (s *UpdateConsumerGroupRequest) SetConsumeRetryPolicy(v *UpdateConsumerGroupRequestConsumeRetryPolicy) *UpdateConsumerGroupRequest

func (*UpdateConsumerGroupRequest) SetDeliveryOrderType 

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

func (*UpdateConsumerGroupRequest) SetRemark 

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

func (UpdateConsumerGroupRequest) String 

func (s UpdateConsumerGroupRequest) String() string

type UpdateConsumerGroupRequestConsumeRetryPolicy 

type UpdateConsumerGroupRequestConsumeRetryPolicy struct {
	// The dead-letter topic.
	//
	// If a consumer still fails to consume a message after the message is retried for a specified number of times, the message is delivered to a dead-letter topic for subsequent business recovery or troubleshooting. For more information, see [Consumption retry and dead-letter messages](~~440356~~).
	DeadLetterTargetTopic *string `json:"deadLetterTargetTopic,omitempty" xml:"deadLetterTargetTopic,omitempty"`
	// The maximum number of retries.
	MaxRetryTimes *int32 `json:"maxRetryTimes,omitempty" xml:"maxRetryTimes,omitempty"`
	// The retry policy. For more information, see [Message retry](~~440356~~).
	//
	// 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.
	RetryPolicy *string `json:"retryPolicy,omitempty" xml:"retryPolicy,omitempty"`
}

func (UpdateConsumerGroupRequestConsumeRetryPolicy) GoString 

func (s UpdateConsumerGroupRequestConsumeRetryPolicy) GoString() string

func (*UpdateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic added in v1.0.4 

func (s *UpdateConsumerGroupRequestConsumeRetryPolicy) SetDeadLetterTargetTopic(v string) *UpdateConsumerGroupRequestConsumeRetryPolicy

func (*UpdateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes 

func (s *UpdateConsumerGroupRequestConsumeRetryPolicy) SetMaxRetryTimes(v int32) *UpdateConsumerGroupRequestConsumeRetryPolicy

func (*UpdateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy 

func (s *UpdateConsumerGroupRequestConsumeRetryPolicy) SetRetryPolicy(v string) *UpdateConsumerGroupRequestConsumeRetryPolicy

func (UpdateConsumerGroupRequestConsumeRetryPolicy) String 

func (s UpdateConsumerGroupRequestConsumeRetryPolicy) String() string

type UpdateConsumerGroupResponse 

type UpdateConsumerGroupResponse struct {
	Headers    map[string]*string               `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                           `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *UpdateConsumerGroupResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (UpdateConsumerGroupResponse) GoString 

func (s UpdateConsumerGroupResponse) GoString() string

func (*UpdateConsumerGroupResponse) SetBody 

func (s *UpdateConsumerGroupResponse) SetBody(v *UpdateConsumerGroupResponseBody) *UpdateConsumerGroupResponse

func (*UpdateConsumerGroupResponse) SetHeaders 

func (s *UpdateConsumerGroupResponse) SetHeaders(v map[string]*string) *UpdateConsumerGroupResponse

func (*UpdateConsumerGroupResponse) SetStatusCode 

func (s *UpdateConsumerGroupResponse) SetStatusCode(v int32) *UpdateConsumerGroupResponse

func (UpdateConsumerGroupResponse) String 

func (s UpdateConsumerGroupResponse) String() string

type UpdateConsumerGroupResponseBody 

type UpdateConsumerGroupResponseBody struct {
	// The error code.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The result data that is returned.
	Data *bool `json:"data,omitempty" xml:"data,omitempty"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call is successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (UpdateConsumerGroupResponseBody) GoString 

func (s UpdateConsumerGroupResponseBody) GoString() string

func (*UpdateConsumerGroupResponseBody) SetCode 

func (s *UpdateConsumerGroupResponseBody) SetCode(v string) *UpdateConsumerGroupResponseBody

func (*UpdateConsumerGroupResponseBody) SetData 

func (s *UpdateConsumerGroupResponseBody) SetData(v bool) *UpdateConsumerGroupResponseBody

func (*UpdateConsumerGroupResponseBody) SetDynamicCode 

func (s *UpdateConsumerGroupResponseBody) SetDynamicCode(v string) *UpdateConsumerGroupResponseBody

func (*UpdateConsumerGroupResponseBody) SetDynamicMessage 

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

func (*UpdateConsumerGroupResponseBody) SetHttpStatusCode 

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

func (*UpdateConsumerGroupResponseBody) SetMessage 

func (s *UpdateConsumerGroupResponseBody) SetMessage(v string) *UpdateConsumerGroupResponseBody

func (*UpdateConsumerGroupResponseBody) SetRequestId 

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

func (*UpdateConsumerGroupResponseBody) SetSuccess 

func (s *UpdateConsumerGroupResponseBody) SetSuccess(v bool) *UpdateConsumerGroupResponseBody

func (UpdateConsumerGroupResponseBody) String 

func (s UpdateConsumerGroupResponseBody) String() string

type UpdateInstanceRequest 

type UpdateInstanceRequest struct {
	// The new name of the instance.
	InstanceName *string `json:"instanceName,omitempty" xml:"instanceName,omitempty"`
	// The new network information about the instance.
	NetworkInfo *UpdateInstanceRequestNetworkInfo `json:"networkInfo,omitempty" xml:"networkInfo,omitempty" type:"Struct"`
	// The extended configurations of the instance.
	ProductInfo *UpdateInstanceRequestProductInfo `json:"productInfo,omitempty" xml:"productInfo,omitempty" type:"Struct"`
	// The new remarks on the instance.
	Remark *string `json:"remark,omitempty" xml:"remark,omitempty"`
}

func (UpdateInstanceRequest) GoString 

func (s UpdateInstanceRequest) GoString() string

func (*UpdateInstanceRequest) SetInstanceName 

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

func (*UpdateInstanceRequest) SetNetworkInfo 

func (s *UpdateInstanceRequest) SetNetworkInfo(v *UpdateInstanceRequestNetworkInfo) *UpdateInstanceRequest

func (*UpdateInstanceRequest) SetProductInfo added in v1.0.2 

func (s *UpdateInstanceRequest) SetProductInfo(v *UpdateInstanceRequestProductInfo) *UpdateInstanceRequest

func (*UpdateInstanceRequest) SetRemark 

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

func (UpdateInstanceRequest) String 

func (s UpdateInstanceRequest) String() string

type UpdateInstanceRequestNetworkInfo 

type UpdateInstanceRequestNetworkInfo struct {
	// The Internet information about the instance. This parameter takes effect only when the Internet access feature is enabled for the instance.
	InternetInfo *UpdateInstanceRequestNetworkInfoInternetInfo `json:"internetInfo,omitempty" xml:"internetInfo,omitempty" type:"Struct"`
}

func (UpdateInstanceRequestNetworkInfo) GoString 

func (s UpdateInstanceRequestNetworkInfo) GoString() string

func (*UpdateInstanceRequestNetworkInfo) SetInternetInfo added in v1.0.2 

func (s *UpdateInstanceRequestNetworkInfo) SetInternetInfo(v *UpdateInstanceRequestNetworkInfoInternetInfo) *UpdateInstanceRequestNetworkInfo

func (UpdateInstanceRequestNetworkInfo) String 

func (s UpdateInstanceRequestNetworkInfo) String() string

type UpdateInstanceRequestNetworkInfoInternetInfo added in v1.0.2 

type UpdateInstanceRequestNetworkInfoInternetInfo struct {
	// The IP address whitelist that allows access to the instance over the Internet.
	//
	// *   If you do not configure an IP address whitelist, all IP addresses are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
	// *   If you configure an IP address whitelist, only IP addresses in the whitelist are allowed to access the ApsaraMQ for RocketMQ broker over the Internet.
	IpWhitelist []*string `json:"ipWhitelist,omitempty" xml:"ipWhitelist,omitempty" type:"Repeated"`
}

func (UpdateInstanceRequestNetworkInfoInternetInfo) GoString added in v1.0.2 

func (s UpdateInstanceRequestNetworkInfoInternetInfo) GoString() string

func (*UpdateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist added in v1.0.2 

func (s *UpdateInstanceRequestNetworkInfoInternetInfo) SetIpWhitelist(v []*string) *UpdateInstanceRequestNetworkInfoInternetInfo

func (UpdateInstanceRequestNetworkInfoInternetInfo) String added in v1.0.2 

func (s UpdateInstanceRequestNetworkInfoInternetInfo) String() string

type UpdateInstanceRequestProductInfo added in v1.0.2 

type UpdateInstanceRequestProductInfo struct {
	// Specifies whether to enable burst scaling for the instance.
	//
	// Valid values:
	//
	// *   true
	// *   false
	//
	// After you enable burst scaling, the system allows the actual messaging transactions per second (TPS) of the ApsaraMQ for RocketMQ instance to exceed the upper limit of the basic computing specification. You are charged for the extra TPS. For more information, see [Computing fee](~~427237~~).
	//
	// > Only specific types of instances support burst scaling. For more information, see [Instance specifications](~~444715~~).
	AutoScaling *bool `json:"autoScaling,omitempty" xml:"autoScaling,omitempty"`
	// The retention period of messages. Unit: hours.
	//
	// For more information about the valid values, see the "Limits on resource quotas" section of the [Usage limits](~~440347~~) topic.
	//
	// The storage of ApsaraMQ for RocketMQ messages is in serverless scaling mode. You are charged based on the actual used storage. You can adjust the storage retention period to reduce storage usage and costs. For more information, see [Storage fees](~~427238~~).
	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 in the instance.
	//
	// Value values: 0.25 to 1.
	SendReceiveRatio *float32 `json:"sendReceiveRatio,omitempty" xml:"sendReceiveRatio,omitempty"`
}

func (UpdateInstanceRequestProductInfo) GoString added in v1.0.2 

func (s UpdateInstanceRequestProductInfo) GoString() string

func (*UpdateInstanceRequestProductInfo) SetAutoScaling added in v1.0.2 

func (s *UpdateInstanceRequestProductInfo) SetAutoScaling(v bool) *UpdateInstanceRequestProductInfo

func (*UpdateInstanceRequestProductInfo) SetMessageRetentionTime added in v1.0.2 

func (s *UpdateInstanceRequestProductInfo) SetMessageRetentionTime(v int32) *UpdateInstanceRequestProductInfo

func (*UpdateInstanceRequestProductInfo) SetSendReceiveRatio added in v1.0.2 

func (s *UpdateInstanceRequestProductInfo) SetSendReceiveRatio(v float32) *UpdateInstanceRequestProductInfo

func (UpdateInstanceRequestProductInfo) String added in v1.0.2 

func (s UpdateInstanceRequestProductInfo) String() string

type UpdateInstanceResponse 

type UpdateInstanceResponse struct {
	Headers    map[string]*string          `json:"headers,omitempty" xml:"headers,omitempty" require:"true"`
	StatusCode *int32                      `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *UpdateInstanceResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (UpdateInstanceResponse) GoString 

func (s UpdateInstanceResponse) GoString() string

func (*UpdateInstanceResponse) SetBody 

func (s *UpdateInstanceResponse) SetBody(v *UpdateInstanceResponseBody) *UpdateInstanceResponse

func (*UpdateInstanceResponse) SetHeaders 

func (s *UpdateInstanceResponse) SetHeaders(v map[string]*string) *UpdateInstanceResponse

func (*UpdateInstanceResponse) SetStatusCode 

func (s *UpdateInstanceResponse) SetStatusCode(v int32) *UpdateInstanceResponse

func (UpdateInstanceResponse) String 

func (s UpdateInstanceResponse) String() string

type UpdateInstanceResponseBody 

type UpdateInstanceResponseBody struct {
	// The error code.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The result data that is returned.
	Data *bool `json:"data,omitempty" xml:"data,omitempty"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call is successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (UpdateInstanceResponseBody) GoString 

func (s UpdateInstanceResponseBody) GoString() string

func (*UpdateInstanceResponseBody) SetCode 

func (s *UpdateInstanceResponseBody) SetCode(v string) *UpdateInstanceResponseBody

func (*UpdateInstanceResponseBody) SetData 

func (s *UpdateInstanceResponseBody) SetData(v bool) *UpdateInstanceResponseBody

func (*UpdateInstanceResponseBody) SetDynamicCode 

func (s *UpdateInstanceResponseBody) SetDynamicCode(v string) *UpdateInstanceResponseBody

func (*UpdateInstanceResponseBody) SetDynamicMessage 

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

func (*UpdateInstanceResponseBody) SetHttpStatusCode 

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

func (*UpdateInstanceResponseBody) SetMessage 

func (s *UpdateInstanceResponseBody) SetMessage(v string) *UpdateInstanceResponseBody

func (*UpdateInstanceResponseBody) SetRequestId 

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

func (*UpdateInstanceResponseBody) SetSuccess 

func (s *UpdateInstanceResponseBody) SetSuccess(v bool) *UpdateInstanceResponseBody

func (UpdateInstanceResponseBody) String 

func (s UpdateInstanceResponseBody) String() string

type UpdateTopicRequest 

type UpdateTopicRequest struct {
	// The new remarks on the topic.
	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" require:"true"`
	StatusCode *int32                   `json:"statusCode,omitempty" xml:"statusCode,omitempty" require:"true"`
	Body       *UpdateTopicResponseBody `json:"body,omitempty" xml:"body,omitempty" require:"true"`
}

func (UpdateTopicResponse) GoString 

func (s UpdateTopicResponse) GoString() string

func (*UpdateTopicResponse) SetBody 

func (s *UpdateTopicResponse) SetBody(v *UpdateTopicResponseBody) *UpdateTopicResponse

func (*UpdateTopicResponse) SetHeaders 

func (s *UpdateTopicResponse) SetHeaders(v map[string]*string) *UpdateTopicResponse

func (*UpdateTopicResponse) SetStatusCode 

func (s *UpdateTopicResponse) SetStatusCode(v int32) *UpdateTopicResponse

func (UpdateTopicResponse) String 

func (s UpdateTopicResponse) String() string

type UpdateTopicResponseBody 

type UpdateTopicResponseBody struct {
	// The error code.
	Code *string `json:"code,omitempty" xml:"code,omitempty"`
	// The result data that is returned.
	Data *bool `json:"data,omitempty" xml:"data,omitempty"`
	// The dynamic error code.
	DynamicCode *string `json:"dynamicCode,omitempty" xml:"dynamicCode,omitempty"`
	// The dynamic error message.
	DynamicMessage *string `json:"dynamicMessage,omitempty" xml:"dynamicMessage,omitempty"`
	// The HTTP status code.
	HttpStatusCode *int32 `json:"httpStatusCode,omitempty" xml:"httpStatusCode,omitempty"`
	// The error message.
	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.
	RequestId *string `json:"requestId,omitempty" xml:"requestId,omitempty"`
	// Indicates whether the call is successful.
	Success *bool `json:"success,omitempty" xml:"success,omitempty"`
}

func (UpdateTopicResponseBody) GoString 

func (s UpdateTopicResponseBody) GoString() string

func (*UpdateTopicResponseBody) SetCode 

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

func (*UpdateTopicResponseBody) SetData 

func (s *UpdateTopicResponseBody) SetData(v bool) *UpdateTopicResponseBody

func (*UpdateTopicResponseBody) SetDynamicCode 

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

func (*UpdateTopicResponseBody) SetDynamicMessage 

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

func (*UpdateTopicResponseBody) SetHttpStatusCode 

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

func (*UpdateTopicResponseBody) SetMessage 

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

func (*UpdateTopicResponseBody) SetRequestId 

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

func (*UpdateTopicResponseBody) SetSuccess 

func (s *UpdateTopicResponseBody) SetSuccess(v bool) *UpdateTopicResponseBody

func (UpdateTopicResponseBody) String 

func (s UpdateTopicResponseBody) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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