v20200217

package
v3.0.387+incompatible Latest Latest
Warning

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

 Go to latest Published: Feb 24, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// CAM authentication failed.
	AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"

	// Operation failed.
	FAILEDOPERATION = "FailedOperation"

	// Failed to create the cluster.
	FAILEDOPERATION_CREATECLUSTER = "FailedOperation.CreateCluster"

	// Failed to create the environment.
	FAILEDOPERATION_CREATEENVIRONMENT = "FailedOperation.CreateEnvironment"

	// Failed to create the environment role.
	FAILEDOPERATION_CREATEENVIRONMENTROLE = "FailedOperation.CreateEnvironmentRole"

	// Failed to create the namespace.
	FAILEDOPERATION_CREATENAMESPACE = "FailedOperation.CreateNamespace"

	// An error occurred while creating the producer.
	FAILEDOPERATION_CREATEPRODUCERERROR = "FailedOperation.CreateProducerError"

	// An error occurred while creating the TDMQ client.
	FAILEDOPERATION_CREATEPULSARCLIENTERROR = "FailedOperation.CreatePulsarClientError"

	// Failed to create the role.
	FAILEDOPERATION_CREATEROLE = "FailedOperation.CreateRole"

	// Failed to create the key.
	FAILEDOPERATION_CREATESECRETKEY = "FailedOperation.CreateSecretKey"

	// Failed to create the subscription.
	FAILEDOPERATION_CREATESUBSCRIPTION = "FailedOperation.CreateSubscription"

	// Failed to create the topic.
	FAILEDOPERATION_CREATETOPIC = "FailedOperation.CreateTopic"

	// Failed to delete the cluster.
	FAILEDOPERATION_DELETECLUSTER = "FailedOperation.DeleteCluster"

	// Failed to delete the environment role.
	FAILEDOPERATION_DELETEENVIRONMENTROLES = "FailedOperation.DeleteEnvironmentRoles"

	// Failed to delete the environment.
	FAILEDOPERATION_DELETEENVIRONMENTS = "FailedOperation.DeleteEnvironments"

	// Failed to delete the namespace.
	FAILEDOPERATION_DELETENAMESPACE = "FailedOperation.DeleteNamespace"

	// Failed to delete the role.
	FAILEDOPERATION_DELETEROLES = "FailedOperation.DeleteRoles"

	// Failed to delete the subscription.
	FAILEDOPERATION_DELETESUBSCRIPTIONS = "FailedOperation.DeleteSubscriptions"

	// Failed to delete the topic.
	FAILEDOPERATION_DELETETOPICS = "FailedOperation.DeleteTopics"

	// Failed to query the subscription data.
	FAILEDOPERATION_DESCRIBESUBSCRIPTION = "FailedOperation.DescribeSubscription"

	// Failed to get the environment attributes.
	FAILEDOPERATION_GETENVIRONMENTATTRIBUTESFAILED = "FailedOperation.GetEnvironmentAttributesFailed"

	// Failed to get the number of topic partitions.
	FAILEDOPERATION_GETTOPICPARTITIONSFAILED = "FailedOperation.GetTopicPartitionsFailed"

	// The message size exceeds the upper limit of 1 MB.
	FAILEDOPERATION_MAXMESSAGESIZEERROR = "FailedOperation.MaxMessageSizeError"

	// The uploaded `msgID` is incorrect.
	FAILEDOPERATION_MESSAGEIDERROR = "FailedOperation.MessageIDError"

	// You must clear the associated namespace before proceeding.
	FAILEDOPERATION_NAMESPACEINUSE = "FailedOperation.NamespaceInUse"

	// An error occurred while receiving the message.
	FAILEDOPERATION_RECEIVEERROR = "FailedOperation.ReceiveError"

	// Message receiving timed out. Please try again.
	FAILEDOPERATION_RECEIVETIMEOUT = "FailedOperation.ReceiveTimeout"

	// Failed to configure message rewind.
	FAILEDOPERATION_RESETMSGSUBOFFSETBYTIMESTAMPFAILED = "FailedOperation.ResetMsgSubOffsetByTimestampFailed"

	// You must clear the associated role data before proceeding.
	FAILEDOPERATION_ROLEINUSE = "FailedOperation.RoleInUse"

	// Failed to save the key.
	FAILEDOPERATION_SAVESECRETKEY = "FailedOperation.SaveSecretKey"

	// Message sending timed out.
	FAILEDOPERATION_SENDMESSAGETIMEOUTERROR = "FailedOperation.SendMessageTimeoutError"

	// Failed to send the message.
	FAILEDOPERATION_SENDMSGFAILED = "FailedOperation.SendMsgFailed"

	// Failed to configure the message TTL.
	FAILEDOPERATION_SETTTL = "FailedOperation.SetTTL"

	// You must clear the associated topic data before proceeding.
	FAILEDOPERATION_TOPICINUSE = "FailedOperation.TopicInUse"

	// Please use a partition topic.
	FAILEDOPERATION_TOPICTYPEERROR = "FailedOperation.TopicTypeError"

	// Failed to update the environment.
	FAILEDOPERATION_UPDATEENVIRONMENT = "FailedOperation.UpdateEnvironment"

	// Failed to update the environment role.
	FAILEDOPERATION_UPDATEENVIRONMENTROLE = "FailedOperation.UpdateEnvironmentRole"

	// Failed to update the role.
	FAILEDOPERATION_UPDATEROLE = "FailedOperation.UpdateRole"

	// Failed to update the topic.
	FAILEDOPERATION_UPDATETOPIC = "FailedOperation.UpdateTopic"

	// You must clear the associated VPC routing data before proceeding.
	FAILEDOPERATION_VPCINUSE = "FailedOperation.VpcInUse"

	// Internal error.
	INTERNALERROR = "InternalError"

	// The broker service is exceptional.
	INTERNALERROR_BROKERSERVICE = "InternalError.BrokerService"

	// Failed to get attributes.
	INTERNALERROR_GETATTRIBUTESFAILED = "InternalError.GetAttributesFailed"

	// Internal error.
	INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"

	// You can try again.
	INTERNALERROR_RETRY = "InternalError.Retry"

	// System error.
	INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"

	// Incorrect parameter.
	INVALIDPARAMETER = "InvalidParameter"

	// The uploaded tenant name is incorrect.
	INVALIDPARAMETER_TENANTNOTFOUND = "InvalidParameter.TenantNotFound"

	// The correct token was not obtained.
	INVALIDPARAMETER_TOKENNOTFOUND = "InvalidParameter.TokenNotFound"

	// The parameter value is incorrect.
	INVALIDPARAMETERVALUE = "InvalidParameterValue"

	// The cluster name already exists.
	INVALIDPARAMETERVALUE_CLUSTERNAMEDUPLICATION = "InvalidParameterValue.ClusterNameDuplication"

	// The parameter value is out of the value range.
	INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"

	// A required parameter is missing.
	INVALIDPARAMETERVALUE_NEEDMOREPARAMS = "InvalidParameterValue.NeedMoreParams"

	// The message TTL value is invalid.
	INVALIDPARAMETERVALUE_TTL = "InvalidParameterValue.TTL"

	// The uploaded topic name is incorrect.
	INVALIDPARAMETERVALUE_TOPICNOTFOUND = "InvalidParameterValue.TopicNotFound"

	// The quota limit is exceeded.
	LIMITEXCEEDED = "LimitExceeded"

	// The number of clusters under the instance exceeds the limit.
	LIMITEXCEEDED_CLUSTERS = "LimitExceeded.Clusters"

	// The number of environments under the instance exceeds the limit.
	LIMITEXCEEDED_ENVIRONMENTS = "LimitExceeded.Environments"

	// The number of namespaces under the instance exceeds the limit.
	LIMITEXCEEDED_NAMESPACES = "LimitExceeded.Namespaces"

	// The number of subscribers under the instance exceeds the limit.
	LIMITEXCEEDED_SUBSCRIPTIONS = "LimitExceeded.Subscriptions"

	// The number of topics under the instance exceeds the limit.
	LIMITEXCEEDED_TOPICS = "LimitExceeded.Topics"

	// Missing parameter.
	MISSINGPARAMETER = "MissingParameter"

	// A required parameter is missing.
	MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"

	// The subscription is still being consumed.
	OPERATIONDENIED_CONSUMERRUNNING = "OperationDenied.ConsumerRunning"

	// Operations on the default environment are not allowed.
	OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"

	// The resource is in use.
	RESOURCEINUSE = "ResourceInUse"

	// The cluster already exists.
	RESOURCEINUSE_CLUSTER = "ResourceInUse.Cluster"

	// The environment role already exists.
	RESOURCEINUSE_ENVIRONMENTROLE = "ResourceInUse.EnvironmentRole"

	// A namespace with the same name already exists.
	RESOURCEINUSE_NAMESPACE = "ResourceInUse.Namespace"

	// The queue already exists.
	RESOURCEINUSE_QUEUE = "ResourceInUse.Queue"

	// The role already exists.
	RESOURCEINUSE_ROLE = "ResourceInUse.Role"

	// A subscription with the same name already exists.
	RESOURCEINUSE_SUBSCRIPTION = "ResourceInUse.Subscription"

	// A topic with the same name already exists.
	RESOURCEINUSE_TOPIC = "ResourceInUse.Topic"

	// Insufficient resource.
	RESOURCEINSUFFICIENT = "ResourceInsufficient"

	// The resource does not exist.
	RESOURCENOTFOUND = "ResourceNotFound"

	// The service cluster does not exist.
	RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"

	// The cluster does not exist.
	RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

	// The environment does not exist.
	RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"

	// The environment role does not exist.
	RESOURCENOTFOUND_ENVIRONMENTROLE = "ResourceNotFound.EnvironmentRole"

	// The namespace does not exist.
	RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"

	// The role does not exist.
	RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

	// The subscription does not exist.
	RESOURCENOTFOUND_SUBSCRIPTION = "ResourceNotFound.Subscription"

	// The topic does not exist.
	RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

	// The resource is unavailable.
	RESOURCEUNAVAILABLE = "ResourceUnavailable"

	// Assignment exception.
	RESOURCEUNAVAILABLE_CREATEFAILED = "ResourceUnavailable.CreateFailed"

	// You must top up before proceeding.
	RESOURCEUNAVAILABLE_FUNDREQUIRED = "ResourceUnavailable.FundRequired"

	// The system is being upgraded.
	RESOURCEUNAVAILABLE_SYSTEMUPGRADE = "ResourceUnavailable.SystemUpgrade"

	// The resources have been sold out.
	RESOURCESSOLDOUT = "ResourcesSoldOut"

	// Unauthorized operation.
	UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

	// Unknown parameter.
	UNKNOWNPARAMETER = "UnknownParameter"

	// Unsupported operation.
	UNSUPPORTEDOPERATION = "UnsupportedOperation"
)
View Source 
const APIVersion = "2020-02-17"

Variables

This section is empty.

Functions

This section is empty.

Types

type AcknowledgeMessageRequest 

type AcknowledgeMessageRequest struct {
	*tchttp.BaseRequest

	// Unique ID used to identify the message, which can be obtained from the returned value of `receiveMessage`.
	MessageId *string `json:"MessageId,omitempty" name:"MessageId"`

	// Topic name, which can be obtained from the returned value of `receiveMessage` and is better to be the full path of the topic, such as `tenant/namespace/topic`. If it is not specified, `public/default` will be used by default.
	AckTopic *string `json:"AckTopic,omitempty" name:"AckTopic"`

	// Subscriber name, which can be obtained from the returned value of `receiveMessage`. Make sure that it is the same as the subscriber name identified in `receiveMessage`; otherwise, the received message cannot be correctly acknowledged.
	SubName *string `json:"SubName,omitempty" name:"SubName"`
}

func NewAcknowledgeMessageRequest 

func NewAcknowledgeMessageRequest() (request *AcknowledgeMessageRequest)

func (*AcknowledgeMessageRequest) FromJsonString 

func (r *AcknowledgeMessageRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*AcknowledgeMessageRequest) ToJsonString 

func (r *AcknowledgeMessageRequest) ToJsonString() string

type AcknowledgeMessageResponse 

type AcknowledgeMessageResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// If it is an empty string, no error occurred.
		// Note: this field may return null, indicating that no valid values can be obtained.
		ErrorMsg *string `json:"ErrorMsg,omitempty" name:"ErrorMsg"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewAcknowledgeMessageResponse 

func NewAcknowledgeMessageResponse() (response *AcknowledgeMessageResponse)

func (*AcknowledgeMessageResponse) FromJsonString 

func (r *AcknowledgeMessageResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*AcknowledgeMessageResponse) ToJsonString 

func (r *AcknowledgeMessageResponse) ToJsonString() string

type BindCluster 

type BindCluster struct {

	// Physical cluster name
	ClusterName *string `json:"ClusterName,omitempty" name:"ClusterName"`
}

type ClearCmqQueueRequest 

type ClearCmqQueueRequest struct {
	*tchttp.BaseRequest

	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`
}

func NewClearCmqQueueRequest 

func NewClearCmqQueueRequest() (request *ClearCmqQueueRequest)

func (*ClearCmqQueueRequest) FromJsonString 

func (r *ClearCmqQueueRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ClearCmqQueueRequest) ToJsonString 

func (r *ClearCmqQueueRequest) ToJsonString() string

type ClearCmqQueueResponse 

type ClearCmqQueueResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewClearCmqQueueResponse 

func NewClearCmqQueueResponse() (response *ClearCmqQueueResponse)

func (*ClearCmqQueueResponse) FromJsonString 

func (r *ClearCmqQueueResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ClearCmqQueueResponse) ToJsonString 

func (r *ClearCmqQueueResponse) ToJsonString() string

type ClearCmqSubscriptionFilterTagsRequest 

type ClearCmqSubscriptionFilterTagsRequest struct {
	*tchttp.BaseRequest

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`
}

func NewClearCmqSubscriptionFilterTagsRequest 

func NewClearCmqSubscriptionFilterTagsRequest() (request *ClearCmqSubscriptionFilterTagsRequest)

func (*ClearCmqSubscriptionFilterTagsRequest) FromJsonString 

func (r *ClearCmqSubscriptionFilterTagsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ClearCmqSubscriptionFilterTagsRequest) ToJsonString 

func (r *ClearCmqSubscriptionFilterTagsRequest) ToJsonString() string

type ClearCmqSubscriptionFilterTagsResponse 

type ClearCmqSubscriptionFilterTagsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewClearCmqSubscriptionFilterTagsResponse 

func NewClearCmqSubscriptionFilterTagsResponse() (response *ClearCmqSubscriptionFilterTagsResponse)

func (*ClearCmqSubscriptionFilterTagsResponse) FromJsonString 

func (r *ClearCmqSubscriptionFilterTagsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ClearCmqSubscriptionFilterTagsResponse) ToJsonString 

func (r *ClearCmqSubscriptionFilterTagsResponse) ToJsonString() string

type Client 

type Client struct {
	common.Client
}

func NewClient 

func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)

func NewClientWithSecretId 

func NewClientWithSecretId(secretId, secretKey, region string) (client *Client, err error)

Deprecated

func (*Client) AcknowledgeMessage 

func (c *Client) AcknowledgeMessage(request *AcknowledgeMessageRequest) (response *AcknowledgeMessageResponse, err error)

AcknowledgeMessage This API is used to acknowledge the message in the specified topic by the provided `MessageID`.

error code that may be returned: 

FAILEDOPERATION_CREATEPRODUCERERROR = "FailedOperation.CreateProducerError"
FAILEDOPERATION_CREATEPULSARCLIENTERROR = "FailedOperation.CreatePulsarClientError"
FAILEDOPERATION_MAXMESSAGESIZEERROR = "FailedOperation.MaxMessageSizeError"
FAILEDOPERATION_MESSAGEIDERROR = "FailedOperation.MessageIDError"
FAILEDOPERATION_RECEIVEERROR = "FailedOperation.ReceiveError"
FAILEDOPERATION_RECEIVETIMEOUT = "FailedOperation.ReceiveTimeout"
FAILEDOPERATION_TOPICTYPEERROR = "FailedOperation.TopicTypeError"
INVALIDPARAMETER_TENANTNOTFOUND = "InvalidParameter.TenantNotFound"
INVALIDPARAMETER_TOKENNOTFOUND = "InvalidParameter.TokenNotFound"
INVALIDPARAMETERVALUE_TOPICNOTFOUND = "InvalidParameterValue.TopicNotFound"

func (*Client) AcknowledgeMessageWithContext 

func (c *Client) AcknowledgeMessageWithContext(ctx context.Context, request *AcknowledgeMessageRequest) (response *AcknowledgeMessageResponse, err error)

AcknowledgeMessage This API is used to acknowledge the message in the specified topic by the provided `MessageID`.

error code that may be returned: 

FAILEDOPERATION_CREATEPRODUCERERROR = "FailedOperation.CreateProducerError"
FAILEDOPERATION_CREATEPULSARCLIENTERROR = "FailedOperation.CreatePulsarClientError"
FAILEDOPERATION_MAXMESSAGESIZEERROR = "FailedOperation.MaxMessageSizeError"
FAILEDOPERATION_MESSAGEIDERROR = "FailedOperation.MessageIDError"
FAILEDOPERATION_RECEIVEERROR = "FailedOperation.ReceiveError"
FAILEDOPERATION_RECEIVETIMEOUT = "FailedOperation.ReceiveTimeout"
FAILEDOPERATION_TOPICTYPEERROR = "FailedOperation.TopicTypeError"
INVALIDPARAMETER_TENANTNOTFOUND = "InvalidParameter.TenantNotFound"
INVALIDPARAMETER_TOKENNOTFOUND = "InvalidParameter.TokenNotFound"
INVALIDPARAMETERVALUE_TOPICNOTFOUND = "InvalidParameterValue.TopicNotFound"

func (*Client) ClearCmqQueue 

func (c *Client) ClearCmqQueue(request *ClearCmqQueueRequest) (response *ClearCmqQueueResponse, err error)

ClearCmqQueue This API is used to clear the messages in the CMQ message queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) ClearCmqQueueWithContext 

func (c *Client) ClearCmqQueueWithContext(ctx context.Context, request *ClearCmqQueueRequest) (response *ClearCmqQueueResponse, err error)

ClearCmqQueue This API is used to clear the messages in the CMQ message queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) ClearCmqSubscriptionFilterTags 

func (c *Client) ClearCmqSubscriptionFilterTags(request *ClearCmqSubscriptionFilterTagsRequest) (response *ClearCmqSubscriptionFilterTagsResponse, err error)

ClearCmqSubscriptionFilterTags This API is used to clear the message tags of a subscriber.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) ClearCmqSubscriptionFilterTagsWithContext 

func (c *Client) ClearCmqSubscriptionFilterTagsWithContext(ctx context.Context, request *ClearCmqSubscriptionFilterTagsRequest) (response *ClearCmqSubscriptionFilterTagsResponse, err error)

ClearCmqSubscriptionFilterTags This API is used to clear the message tags of a subscriber.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) CreateCluster 

func (c *Client) CreateCluster(request *CreateClusterRequest) (response *CreateClusterResponse, err error)

CreateCluster This API is used to create a cluster.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATECLUSTER = "FailedOperation.CreateCluster"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
LIMITEXCEEDED_CLUSTERS = "LimitExceeded.Clusters"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCEINUSE_CLUSTER = "ResourceInUse.Cluster"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCEUNAVAILABLE_CREATEFAILED = "ResourceUnavailable.CreateFailed"

func (*Client) CreateClusterWithContext 

func (c *Client) CreateClusterWithContext(ctx context.Context, request *CreateClusterRequest) (response *CreateClusterResponse, err error)

CreateCluster This API is used to create a cluster.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATECLUSTER = "FailedOperation.CreateCluster"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
LIMITEXCEEDED_CLUSTERS = "LimitExceeded.Clusters"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCEINUSE_CLUSTER = "ResourceInUse.Cluster"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCEUNAVAILABLE_CREATEFAILED = "ResourceUnavailable.CreateFailed"

func (*Client) CreateCmqQueue 

func (c *Client) CreateCmqQueue(request *CreateCmqQueueRequest) (response *CreateCmqQueueResponse, err error)

CreateCmqQueue This API is used to create a CMQ queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATECLUSTER = "FailedOperation.CreateCluster"
FAILEDOPERATION_CREATETOPIC = "FailedOperation.CreateTopic"
FAILEDOPERATION_SETTTL = "FailedOperation.SetTTL"
INTERNALERROR_BROKERSERVICE = "InternalError.BrokerService"
RESOURCEINUSE_QUEUE = "ResourceInUse.Queue"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCEUNAVAILABLE = "ResourceUnavailable"

func (*Client) CreateCmqQueueWithContext 

func (c *Client) CreateCmqQueueWithContext(ctx context.Context, request *CreateCmqQueueRequest) (response *CreateCmqQueueResponse, err error)

CreateCmqQueue This API is used to create a CMQ queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATECLUSTER = "FailedOperation.CreateCluster"
FAILEDOPERATION_CREATETOPIC = "FailedOperation.CreateTopic"
FAILEDOPERATION_SETTTL = "FailedOperation.SetTTL"
INTERNALERROR_BROKERSERVICE = "InternalError.BrokerService"
RESOURCEINUSE_QUEUE = "ResourceInUse.Queue"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCEUNAVAILABLE = "ResourceUnavailable"

func (*Client) CreateCmqSubscribe 

func (c *Client) CreateCmqSubscribe(request *CreateCmqSubscribeRequest) (response *CreateCmqSubscribeResponse, err error)

CreateCmqSubscribe This API is used to create a CMQ subscription.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
RESOURCEINUSE_SUBSCRIPTION = "ResourceInUse.Subscription"

func (*Client) CreateCmqSubscribeWithContext 

func (c *Client) CreateCmqSubscribeWithContext(ctx context.Context, request *CreateCmqSubscribeRequest) (response *CreateCmqSubscribeResponse, err error)

CreateCmqSubscribe This API is used to create a CMQ subscription.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
RESOURCEINUSE_SUBSCRIPTION = "ResourceInUse.Subscription"

func (*Client) CreateCmqTopic 

func (c *Client) CreateCmqTopic(request *CreateCmqTopicRequest) (response *CreateCmqTopicResponse, err error)

CreateCmqTopic This API is used to create a CMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATECLUSTER = "FailedOperation.CreateCluster"
FAILEDOPERATION_SETTTL = "FailedOperation.SetTTL"
RESOURCEINUSE_TOPIC = "ResourceInUse.Topic"

func (*Client) CreateCmqTopicWithContext 

func (c *Client) CreateCmqTopicWithContext(ctx context.Context, request *CreateCmqTopicRequest) (response *CreateCmqTopicResponse, err error)

CreateCmqTopic This API is used to create a CMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATECLUSTER = "FailedOperation.CreateCluster"
FAILEDOPERATION_SETTTL = "FailedOperation.SetTTL"
RESOURCEINUSE_TOPIC = "ResourceInUse.Topic"

func (*Client) CreateEnvironment 

func (c *Client) CreateEnvironment(request *CreateEnvironmentRequest) (response *CreateEnvironmentResponse, err error)

CreateEnvironment This API is used to create a TDMQ namespace.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATEENVIRONMENT = "FailedOperation.CreateEnvironment"
FAILEDOPERATION_CREATENAMESPACE = "FailedOperation.CreateNamespace"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
INVALIDPARAMETERVALUE_TTL = "InvalidParameterValue.TTL"
LIMITEXCEEDED_ENVIRONMENTS = "LimitExceeded.Environments"
LIMITEXCEEDED_NAMESPACES = "LimitExceeded.Namespaces"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"
RESOURCEINUSE_NAMESPACE = "ResourceInUse.Namespace"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) CreateEnvironmentRole 

func (c *Client) CreateEnvironmentRole(request *CreateEnvironmentRoleRequest) (response *CreateEnvironmentRoleResponse, err error)

CreateEnvironmentRole This API is used to create an environment role.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATEENVIRONMENTROLE = "FailedOperation.CreateEnvironmentRole"
FAILEDOPERATION_UPDATEENVIRONMENTROLE = "FailedOperation.UpdateEnvironmentRole"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCEINUSE_ENVIRONMENTROLE = "ResourceInUse.EnvironmentRole"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

func (*Client) CreateEnvironmentRoleWithContext 

func (c *Client) CreateEnvironmentRoleWithContext(ctx context.Context, request *CreateEnvironmentRoleRequest) (response *CreateEnvironmentRoleResponse, err error)

CreateEnvironmentRole This API is used to create an environment role.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATEENVIRONMENTROLE = "FailedOperation.CreateEnvironmentRole"
FAILEDOPERATION_UPDATEENVIRONMENTROLE = "FailedOperation.UpdateEnvironmentRole"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCEINUSE_ENVIRONMENTROLE = "ResourceInUse.EnvironmentRole"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

func (*Client) CreateEnvironmentWithContext 

func (c *Client) CreateEnvironmentWithContext(ctx context.Context, request *CreateEnvironmentRequest) (response *CreateEnvironmentResponse, err error)

CreateEnvironment This API is used to create a TDMQ namespace.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATEENVIRONMENT = "FailedOperation.CreateEnvironment"
FAILEDOPERATION_CREATENAMESPACE = "FailedOperation.CreateNamespace"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
INVALIDPARAMETERVALUE_TTL = "InvalidParameterValue.TTL"
LIMITEXCEEDED_ENVIRONMENTS = "LimitExceeded.Environments"
LIMITEXCEEDED_NAMESPACES = "LimitExceeded.Namespaces"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"
RESOURCEINUSE_NAMESPACE = "ResourceInUse.Namespace"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) CreateRocketMQCluster 

func (c *Client) CreateRocketMQCluster(request *CreateRocketMQClusterRequest) (response *CreateRocketMQClusterResponse, err error)

CreateRocketMQCluster This API is used to create a RocketMQ cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATECLUSTER = "FailedOperation.CreateCluster"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
LIMITEXCEEDED_CLUSTERS = "LimitExceeded.Clusters"
RESOURCEINUSE = "ResourceInUse"
RESOURCEINSUFFICIENT = "ResourceInsufficient"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) CreateRocketMQClusterWithContext 

func (c *Client) CreateRocketMQClusterWithContext(ctx context.Context, request *CreateRocketMQClusterRequest) (response *CreateRocketMQClusterResponse, err error)

CreateRocketMQCluster This API is used to create a RocketMQ cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATECLUSTER = "FailedOperation.CreateCluster"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
LIMITEXCEEDED_CLUSTERS = "LimitExceeded.Clusters"
RESOURCEINUSE = "ResourceInUse"
RESOURCEINSUFFICIENT = "ResourceInsufficient"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) CreateRocketMQGroup 

func (c *Client) CreateRocketMQGroup(request *CreateRocketMQGroupRequest) (response *CreateRocketMQGroupResponse, err error)

CreateRocketMQGroup This API is used to create a RocketMQ consumer group.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"

func (*Client) CreateRocketMQGroupWithContext 

func (c *Client) CreateRocketMQGroupWithContext(ctx context.Context, request *CreateRocketMQGroupRequest) (response *CreateRocketMQGroupResponse, err error)

CreateRocketMQGroup This API is used to create a RocketMQ consumer group.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"

func (*Client) CreateRocketMQNamespace 

func (c *Client) CreateRocketMQNamespace(request *CreateRocketMQNamespaceRequest) (response *CreateRocketMQNamespaceResponse, err error)

CreateRocketMQNamespace This API is used to create a RocketMQ namespace.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCEINSUFFICIENT = "ResourceInsufficient"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) CreateRocketMQNamespaceWithContext 

func (c *Client) CreateRocketMQNamespaceWithContext(ctx context.Context, request *CreateRocketMQNamespaceRequest) (response *CreateRocketMQNamespaceResponse, err error)

CreateRocketMQNamespace This API is used to create a RocketMQ namespace.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCEINSUFFICIENT = "ResourceInsufficient"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) CreateRocketMQTopic 

func (c *Client) CreateRocketMQTopic(request *CreateRocketMQTopicRequest) (response *CreateRocketMQTopicResponse, err error)

CreateRocketMQTopic This API is used to create a RocketMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"

func (*Client) CreateRocketMQTopicWithContext 

func (c *Client) CreateRocketMQTopicWithContext(ctx context.Context, request *CreateRocketMQTopicRequest) (response *CreateRocketMQTopicResponse, err error)

CreateRocketMQTopic This API is used to create a RocketMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"

func (*Client) CreateRole 

func (c *Client) CreateRole(request *CreateRoleRequest) (response *CreateRoleResponse, err error)

CreateRole This API is used to create a role.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATEROLE = "FailedOperation.CreateRole"
FAILEDOPERATION_CREATESECRETKEY = "FailedOperation.CreateSecretKey"
FAILEDOPERATION_SAVESECRETKEY = "FailedOperation.SaveSecretKey"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCEINUSE_ROLE = "ResourceInUse.Role"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) CreateRoleWithContext 

func (c *Client) CreateRoleWithContext(ctx context.Context, request *CreateRoleRequest) (response *CreateRoleResponse, err error)

CreateRole This API is used to create a role.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATEROLE = "FailedOperation.CreateRole"
FAILEDOPERATION_CREATESECRETKEY = "FailedOperation.CreateSecretKey"
FAILEDOPERATION_SAVESECRETKEY = "FailedOperation.SaveSecretKey"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCEINUSE_ROLE = "ResourceInUse.Role"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) CreateSubscription 

func (c *Client) CreateSubscription(request *CreateSubscriptionRequest) (response *CreateSubscriptionResponse, err error)

CreateSubscription This API is used to create a subscription to a topic.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATESUBSCRIPTION = "FailedOperation.CreateSubscription"
FAILEDOPERATION_GETTOPICPARTITIONSFAILED = "FailedOperation.GetTopicPartitionsFailed"
INTERNALERROR_RETRY = "InternalError.Retry"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
LIMITEXCEEDED_SUBSCRIPTIONS = "LimitExceeded.Subscriptions"
LIMITEXCEEDED_TOPICS = "LimitExceeded.Topics"
RESOURCEINUSE_SUBSCRIPTION = "ResourceInUse.Subscription"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) CreateSubscriptionWithContext 

func (c *Client) CreateSubscriptionWithContext(ctx context.Context, request *CreateSubscriptionRequest) (response *CreateSubscriptionResponse, err error)

CreateSubscription This API is used to create a subscription to a topic.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATESUBSCRIPTION = "FailedOperation.CreateSubscription"
FAILEDOPERATION_GETTOPICPARTITIONSFAILED = "FailedOperation.GetTopicPartitionsFailed"
INTERNALERROR_RETRY = "InternalError.Retry"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
LIMITEXCEEDED_SUBSCRIPTIONS = "LimitExceeded.Subscriptions"
LIMITEXCEEDED_TOPICS = "LimitExceeded.Topics"
RESOURCEINUSE_SUBSCRIPTION = "ResourceInUse.Subscription"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) CreateTopic 

func (c *Client) CreateTopic(request *CreateTopicRequest) (response *CreateTopicResponse, err error)

CreateTopic This API is used to add a message topic in the specified partition and type.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATETOPIC = "FailedOperation.CreateTopic"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
LIMITEXCEEDED_TOPICS = "LimitExceeded.Topics"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCEINUSE_TOPIC = "ResourceInUse.Topic"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"

func (*Client) CreateTopicWithContext 

func (c *Client) CreateTopicWithContext(ctx context.Context, request *CreateTopicRequest) (response *CreateTopicResponse, err error)

CreateTopic This API is used to add a message topic in the specified partition and type.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATETOPIC = "FailedOperation.CreateTopic"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
LIMITEXCEEDED_TOPICS = "LimitExceeded.Topics"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCEINUSE_TOPIC = "ResourceInUse.Topic"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"

func (*Client) DeleteCluster 

func (c *Client) DeleteCluster(request *DeleteClusterRequest) (response *DeleteClusterResponse, err error)

DeleteCluster This API is used to delete a cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETECLUSTER = "FailedOperation.DeleteCluster"
FAILEDOPERATION_NAMESPACEINUSE = "FailedOperation.NamespaceInUse"
FAILEDOPERATION_ROLEINUSE = "FailedOperation.RoleInUse"
FAILEDOPERATION_VPCINUSE = "FailedOperation.VpcInUse"
OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DeleteClusterWithContext 

func (c *Client) DeleteClusterWithContext(ctx context.Context, request *DeleteClusterRequest) (response *DeleteClusterResponse, err error)

DeleteCluster This API is used to delete a cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETECLUSTER = "FailedOperation.DeleteCluster"
FAILEDOPERATION_NAMESPACEINUSE = "FailedOperation.NamespaceInUse"
FAILEDOPERATION_ROLEINUSE = "FailedOperation.RoleInUse"
FAILEDOPERATION_VPCINUSE = "FailedOperation.VpcInUse"
OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DeleteCmqQueue 

func (c *Client) DeleteCmqQueue(request *DeleteCmqQueueRequest) (response *DeleteCmqQueueResponse, err error)

DeleteCmqQueue This API is used to delete a CMQ queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETETOPICS = "FailedOperation.DeleteTopics"

func (*Client) DeleteCmqQueueWithContext 

func (c *Client) DeleteCmqQueueWithContext(ctx context.Context, request *DeleteCmqQueueRequest) (response *DeleteCmqQueueResponse, err error)

DeleteCmqQueue This API is used to delete a CMQ queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETETOPICS = "FailedOperation.DeleteTopics"

func (*Client) DeleteCmqSubscribe 

func (c *Client) DeleteCmqSubscribe(request *DeleteCmqSubscribeRequest) (response *DeleteCmqSubscribeResponse, err error)

DeleteCmqSubscribe This API is used to delete a CMQ subscription.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETETOPICS = "FailedOperation.DeleteTopics"

func (*Client) DeleteCmqSubscribeWithContext 

func (c *Client) DeleteCmqSubscribeWithContext(ctx context.Context, request *DeleteCmqSubscribeRequest) (response *DeleteCmqSubscribeResponse, err error)

DeleteCmqSubscribe This API is used to delete a CMQ subscription.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETETOPICS = "FailedOperation.DeleteTopics"

func (*Client) DeleteCmqTopic 

func (c *Client) DeleteCmqTopic(request *DeleteCmqTopicRequest) (response *DeleteCmqTopicResponse, err error)

DeleteCmqTopic This API is used to delete a CMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) DeleteCmqTopicWithContext 

func (c *Client) DeleteCmqTopicWithContext(ctx context.Context, request *DeleteCmqTopicRequest) (response *DeleteCmqTopicResponse, err error)

DeleteCmqTopic This API is used to delete a CMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) DeleteEnvironmentRoles 

func (c *Client) DeleteEnvironmentRoles(request *DeleteEnvironmentRolesRequest) (response *DeleteEnvironmentRolesResponse, err error)

DeleteEnvironmentRoles This API is used to delete an environment role.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_DELETEENVIRONMENTROLES = "FailedOperation.DeleteEnvironmentRoles"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENTROLE = "ResourceNotFound.EnvironmentRole"

func (*Client) DeleteEnvironmentRolesWithContext 

func (c *Client) DeleteEnvironmentRolesWithContext(ctx context.Context, request *DeleteEnvironmentRolesRequest) (response *DeleteEnvironmentRolesResponse, err error)

DeleteEnvironmentRoles This API is used to delete an environment role.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_DELETEENVIRONMENTROLES = "FailedOperation.DeleteEnvironmentRoles"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENTROLE = "ResourceNotFound.EnvironmentRole"

func (*Client) DeleteEnvironments 

func (c *Client) DeleteEnvironments(request *DeleteEnvironmentsRequest) (response *DeleteEnvironmentsResponse, err error)

DeleteEnvironments This API is used to batch delete namespaces under a tenant.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_DELETEENVIRONMENTS = "FailedOperation.DeleteEnvironments"
FAILEDOPERATION_DELETENAMESPACE = "FailedOperation.DeleteNamespace"
FAILEDOPERATION_ROLEINUSE = "FailedOperation.RoleInUse"
FAILEDOPERATION_TOPICINUSE = "FailedOperation.TopicInUse"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"

func (*Client) DeleteEnvironmentsWithContext 

func (c *Client) DeleteEnvironmentsWithContext(ctx context.Context, request *DeleteEnvironmentsRequest) (response *DeleteEnvironmentsResponse, err error)

DeleteEnvironments This API is used to batch delete namespaces under a tenant.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_DELETEENVIRONMENTS = "FailedOperation.DeleteEnvironments"
FAILEDOPERATION_DELETENAMESPACE = "FailedOperation.DeleteNamespace"
FAILEDOPERATION_ROLEINUSE = "FailedOperation.RoleInUse"
FAILEDOPERATION_TOPICINUSE = "FailedOperation.TopicInUse"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"

func (*Client) DeleteRocketMQCluster 

func (c *Client) DeleteRocketMQCluster(request *DeleteRocketMQClusterRequest) (response *DeleteRocketMQClusterResponse, err error)

DeleteRocketMQCluster This API is used to delete a RocketMQ cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETECLUSTER = "FailedOperation.DeleteCluster"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DeleteRocketMQClusterWithContext 

func (c *Client) DeleteRocketMQClusterWithContext(ctx context.Context, request *DeleteRocketMQClusterRequest) (response *DeleteRocketMQClusterResponse, err error)

DeleteRocketMQCluster This API is used to delete a RocketMQ cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETECLUSTER = "FailedOperation.DeleteCluster"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DeleteRocketMQGroup 

func (c *Client) DeleteRocketMQGroup(request *DeleteRocketMQGroupRequest) (response *DeleteRocketMQGroupResponse, err error)

DeleteRocketMQGroup This API is used to delete a RocketMQ consumer group.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DeleteRocketMQGroupWithContext 

func (c *Client) DeleteRocketMQGroupWithContext(ctx context.Context, request *DeleteRocketMQGroupRequest) (response *DeleteRocketMQGroupResponse, err error)

DeleteRocketMQGroup This API is used to delete a RocketMQ consumer group.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DeleteRocketMQNamespace 

func (c *Client) DeleteRocketMQNamespace(request *DeleteRocketMQNamespaceRequest) (response *DeleteRocketMQNamespaceResponse, err error)

DeleteRocketMQNamespace This API is used to delete a RocketMQ namespace.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_ROLEINUSE = "FailedOperation.RoleInUse"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DeleteRocketMQNamespaceWithContext 

func (c *Client) DeleteRocketMQNamespaceWithContext(ctx context.Context, request *DeleteRocketMQNamespaceRequest) (response *DeleteRocketMQNamespaceResponse, err error)

DeleteRocketMQNamespace This API is used to delete a RocketMQ namespace.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_ROLEINUSE = "FailedOperation.RoleInUse"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DeleteRocketMQTopic 

func (c *Client) DeleteRocketMQTopic(request *DeleteRocketMQTopicRequest) (response *DeleteRocketMQTopicResponse, err error)

DeleteRocketMQTopic This API is used to delete a RocketMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DeleteRocketMQTopicWithContext 

func (c *Client) DeleteRocketMQTopicWithContext(ctx context.Context, request *DeleteRocketMQTopicRequest) (response *DeleteRocketMQTopicResponse, err error)

DeleteRocketMQTopic This API is used to delete a RocketMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DeleteRoles 

func (c *Client) DeleteRoles(request *DeleteRolesRequest) (response *DeleteRolesResponse, err error)

DeleteRoles This API is used to delete one or multiple roles.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETEROLES = "FailedOperation.DeleteRoles"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCEINUSE_ENVIRONMENTROLE = "ResourceInUse.EnvironmentRole"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

func (*Client) DeleteRolesWithContext 

func (c *Client) DeleteRolesWithContext(ctx context.Context, request *DeleteRolesRequest) (response *DeleteRolesResponse, err error)

DeleteRoles This API is used to delete one or multiple roles.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETEROLES = "FailedOperation.DeleteRoles"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCEINUSE_ENVIRONMENTROLE = "ResourceInUse.EnvironmentRole"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

func (*Client) DeleteSubscriptions 

func (c *Client) DeleteSubscriptions(request *DeleteSubscriptionsRequest) (response *DeleteSubscriptionsResponse, err error)

DeleteSubscriptions This API is used to delete a subscription.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_DELETESUBSCRIPTIONS = "FailedOperation.DeleteSubscriptions"
FAILEDOPERATION_GETTOPICPARTITIONSFAILED = "FailedOperation.GetTopicPartitionsFailed"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
OPERATIONDENIED_CONSUMERRUNNING = "OperationDenied.ConsumerRunning"
RESOURCEINUSE_SUBSCRIPTION = "ResourceInUse.Subscription"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_SUBSCRIPTION = "ResourceNotFound.Subscription"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) DeleteSubscriptionsWithContext 

func (c *Client) DeleteSubscriptionsWithContext(ctx context.Context, request *DeleteSubscriptionsRequest) (response *DeleteSubscriptionsResponse, err error)

DeleteSubscriptions This API is used to delete a subscription.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_DELETESUBSCRIPTIONS = "FailedOperation.DeleteSubscriptions"
FAILEDOPERATION_GETTOPICPARTITIONSFAILED = "FailedOperation.GetTopicPartitionsFailed"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
OPERATIONDENIED_CONSUMERRUNNING = "OperationDenied.ConsumerRunning"
RESOURCEINUSE_SUBSCRIPTION = "ResourceInUse.Subscription"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_SUBSCRIPTION = "ResourceNotFound.Subscription"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) DeleteTopics 

func (c *Client) DeleteTopics(request *DeleteTopicsRequest) (response *DeleteTopicsResponse, err error)

DeleteTopics This API is used to batch delete topics.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETETOPICS = "FailedOperation.DeleteTopics"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) DeleteTopicsWithContext 

func (c *Client) DeleteTopicsWithContext(ctx context.Context, request *DeleteTopicsRequest) (response *DeleteTopicsResponse, err error)

DeleteTopics This API is used to batch delete topics.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DELETETOPICS = "FailedOperation.DeleteTopics"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) DescribeBindClusters 

func (c *Client) DescribeBindClusters(request *DescribeBindClustersRequest) (response *DescribeBindClustersResponse, err error)

DescribeBindClusters This API is used to get the list of dedicated clusters bound to a user.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCEUNAVAILABLE_SYSTEMUPGRADE = "ResourceUnavailable.SystemUpgrade"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"
UNKNOWNPARAMETER = "UnknownParameter"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) DescribeBindClustersWithContext 

func (c *Client) DescribeBindClustersWithContext(ctx context.Context, request *DescribeBindClustersRequest) (response *DescribeBindClustersResponse, err error)

DescribeBindClusters This API is used to get the list of dedicated clusters bound to a user.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCEUNAVAILABLE_SYSTEMUPGRADE = "ResourceUnavailable.SystemUpgrade"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"
UNKNOWNPARAMETER = "UnknownParameter"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) DescribeBindVpcs 

func (c *Client) DescribeBindVpcs(request *DescribeBindVpcsRequest) (response *DescribeBindVpcsResponse, err error)

DescribeBindVpcs This API is used to get the tenant-VPC binding relationship.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
INVALIDPARAMETERVALUE_NEEDMOREPARAMS = "InvalidParameterValue.NeedMoreParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"

func (*Client) DescribeBindVpcsWithContext 

func (c *Client) DescribeBindVpcsWithContext(ctx context.Context, request *DescribeBindVpcsRequest) (response *DescribeBindVpcsResponse, err error)

DescribeBindVpcs This API is used to get the tenant-VPC binding relationship.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
INVALIDPARAMETERVALUE_NEEDMOREPARAMS = "InvalidParameterValue.NeedMoreParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"

func (*Client) DescribeClusterDetail 

func (c *Client) DescribeClusterDetail(request *DescribeClusterDetailRequest) (response *DescribeClusterDetailResponse, err error)

DescribeClusterDetail This API is used to get the details of a cluster.

error code that may be returned: 

RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeClusterDetailWithContext 

func (c *Client) DescribeClusterDetailWithContext(ctx context.Context, request *DescribeClusterDetailRequest) (response *DescribeClusterDetailResponse, err error)

DescribeClusterDetail This API is used to get the details of a cluster.

error code that may be returned: 

RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeClusters 

func (c *Client) DescribeClusters(request *DescribeClustersRequest) (response *DescribeClustersResponse, err error)

DescribeClusters This API is used to get the list of clusters.

error code that may be returned: 

RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeClustersWithContext 

func (c *Client) DescribeClustersWithContext(ctx context.Context, request *DescribeClustersRequest) (response *DescribeClustersResponse, err error)

DescribeClusters This API is used to get the list of clusters.

error code that may be returned: 

RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeCmqDeadLetterSourceQueues 

func (c *Client) DescribeCmqDeadLetterSourceQueues(request *DescribeCmqDeadLetterSourceQueuesRequest) (response *DescribeCmqDeadLetterSourceQueuesResponse, err error)

DescribeCmqDeadLetterSourceQueues This API is used to enumerate the source queues of a CMQ dead letter queue.

error code that may be returned: 

RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeCmqDeadLetterSourceQueuesWithContext 

func (c *Client) DescribeCmqDeadLetterSourceQueuesWithContext(ctx context.Context, request *DescribeCmqDeadLetterSourceQueuesRequest) (response *DescribeCmqDeadLetterSourceQueuesResponse, err error)

DescribeCmqDeadLetterSourceQueues This API is used to enumerate the source queues of a CMQ dead letter queue.

error code that may be returned: 

RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeCmqQueueDetail 

func (c *Client) DescribeCmqQueueDetail(request *DescribeCmqQueueDetailRequest) (response *DescribeCmqQueueDetailResponse, err error)

DescribeCmqQueueDetail This API is used to query the details of a CMQ queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeCmqQueueDetailWithContext 

func (c *Client) DescribeCmqQueueDetailWithContext(ctx context.Context, request *DescribeCmqQueueDetailRequest) (response *DescribeCmqQueueDetailResponse, err error)

DescribeCmqQueueDetail This API is used to query the details of a CMQ queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeCmqQueues 

func (c *Client) DescribeCmqQueues(request *DescribeCmqQueuesRequest) (response *DescribeCmqQueuesResponse, err error)

DescribeCmqQueues This API is used to query all CMQ queues.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) DescribeCmqQueuesWithContext 

func (c *Client) DescribeCmqQueuesWithContext(ctx context.Context, request *DescribeCmqQueuesRequest) (response *DescribeCmqQueuesResponse, err error)

DescribeCmqQueues This API is used to query all CMQ queues.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) DescribeCmqSubscriptionDetail 

func (c *Client) DescribeCmqSubscriptionDetail(request *DescribeCmqSubscriptionDetailRequest) (response *DescribeCmqSubscriptionDetailResponse, err error)

DescribeCmqSubscriptionDetail This API is used to query the CMQ subscription details.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) DescribeCmqSubscriptionDetailWithContext 

func (c *Client) DescribeCmqSubscriptionDetailWithContext(ctx context.Context, request *DescribeCmqSubscriptionDetailRequest) (response *DescribeCmqSubscriptionDetailResponse, err error)

DescribeCmqSubscriptionDetail This API is used to query the CMQ subscription details.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) DescribeCmqTopicDetail 

func (c *Client) DescribeCmqTopicDetail(request *DescribeCmqTopicDetailRequest) (response *DescribeCmqTopicDetailResponse, err error)

DescribeCmqTopicDetail This API is used to query the details of a CMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeCmqTopicDetailWithContext 

func (c *Client) DescribeCmqTopicDetailWithContext(ctx context.Context, request *DescribeCmqTopicDetailRequest) (response *DescribeCmqTopicDetailResponse, err error)

DescribeCmqTopicDetail This API is used to query the details of a CMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeCmqTopics 

func (c *Client) DescribeCmqTopics(request *DescribeCmqTopicsRequest) (response *DescribeCmqTopicsResponse, err error)

DescribeCmqTopics This API is used to enumerate all CMQ topics.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) DescribeCmqTopicsWithContext 

func (c *Client) DescribeCmqTopicsWithContext(ctx context.Context, request *DescribeCmqTopicsRequest) (response *DescribeCmqTopicsResponse, err error)

DescribeCmqTopics This API is used to enumerate all CMQ topics.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) DescribeEnvironmentAttributes 

func (c *Client) DescribeEnvironmentAttributes(request *DescribeEnvironmentAttributesRequest) (response *DescribeEnvironmentAttributesResponse, err error)

DescribeEnvironmentAttributes This API is used to get the attributes of the specified namespace.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_GETENVIRONMENTATTRIBUTESFAILED = "FailedOperation.GetEnvironmentAttributesFailed"
INTERNALERROR_BROKERSERVICE = "InternalError.BrokerService"
INTERNALERROR_GETATTRIBUTESFAILED = "InternalError.GetAttributesFailed"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"

func (*Client) DescribeEnvironmentAttributesWithContext 

func (c *Client) DescribeEnvironmentAttributesWithContext(ctx context.Context, request *DescribeEnvironmentAttributesRequest) (response *DescribeEnvironmentAttributesResponse, err error)

DescribeEnvironmentAttributes This API is used to get the attributes of the specified namespace.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_GETENVIRONMENTATTRIBUTESFAILED = "FailedOperation.GetEnvironmentAttributesFailed"
INTERNALERROR_BROKERSERVICE = "InternalError.BrokerService"
INTERNALERROR_GETATTRIBUTESFAILED = "InternalError.GetAttributesFailed"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"

func (*Client) DescribeEnvironmentRoles 

func (c *Client) DescribeEnvironmentRoles(request *DescribeEnvironmentRolesRequest) (response *DescribeEnvironmentRolesResponse, err error)

DescribeEnvironmentRoles This API is used to get the list of namespace roles.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

func (*Client) DescribeEnvironmentRolesWithContext 

func (c *Client) DescribeEnvironmentRolesWithContext(ctx context.Context, request *DescribeEnvironmentRolesRequest) (response *DescribeEnvironmentRolesResponse, err error)

DescribeEnvironmentRoles This API is used to get the list of namespace roles.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

func (*Client) DescribeEnvironments 

func (c *Client) DescribeEnvironments(request *DescribeEnvironmentsRequest) (response *DescribeEnvironmentsResponse, err error)

DescribeEnvironments This API is used to get the list of namespaces under a tenant.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeEnvironmentsWithContext 

func (c *Client) DescribeEnvironmentsWithContext(ctx context.Context, request *DescribeEnvironmentsRequest) (response *DescribeEnvironmentsResponse, err error)

DescribeEnvironments This API is used to get the list of namespaces under a tenant.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribePublisherSummary 

func (c *Client) DescribePublisherSummary(request *DescribePublisherSummaryRequest) (response *DescribePublisherSummaryResponse, err error)

DescribePublisherSummary This API is used to obtain message production overview information.

error code that may be returned: 

RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) DescribePublisherSummaryWithContext 

func (c *Client) DescribePublisherSummaryWithContext(ctx context.Context, request *DescribePublisherSummaryRequest) (response *DescribePublisherSummaryResponse, err error)

DescribePublisherSummary This API is used to obtain message production overview information.

error code that may be returned: 

RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) DescribePublishers 

func (c *Client) DescribePublishers(request *DescribePublishersRequest) (response *DescribePublishersResponse, err error)

DescribePublishers This API is used to obtain the list of producer information.

error code that may be returned: 

RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) DescribePublishersWithContext 

func (c *Client) DescribePublishersWithContext(ctx context.Context, request *DescribePublishersRequest) (response *DescribePublishersResponse, err error)

DescribePublishers This API is used to obtain the list of producer information.

error code that may be returned: 

RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) DescribeRocketMQCluster 

func (c *Client) DescribeRocketMQCluster(request *DescribeRocketMQClusterRequest) (response *DescribeRocketMQClusterResponse, err error)

DescribeRocketMQCluster This API is used to get the information of a specific RocketMQ cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeRocketMQClusterWithContext 

func (c *Client) DescribeRocketMQClusterWithContext(ctx context.Context, request *DescribeRocketMQClusterRequest) (response *DescribeRocketMQClusterResponse, err error)

DescribeRocketMQCluster This API is used to get the information of a specific RocketMQ cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeRocketMQClusters 

func (c *Client) DescribeRocketMQClusters(request *DescribeRocketMQClustersRequest) (response *DescribeRocketMQClustersResponse, err error)

DescribeRocketMQClusters This API is used to get the list of RocketMQ clusters.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeRocketMQClustersWithContext 

func (c *Client) DescribeRocketMQClustersWithContext(ctx context.Context, request *DescribeRocketMQClustersRequest) (response *DescribeRocketMQClustersResponse, err error)

DescribeRocketMQClusters This API is used to get the list of RocketMQ clusters.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeRocketMQGroups 

func (c *Client) DescribeRocketMQGroups(request *DescribeRocketMQGroupsRequest) (response *DescribeRocketMQGroupsResponse, err error)

DescribeRocketMQGroups This API is used to get the list of RocketMQ consumer groups.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeRocketMQGroupsWithContext 

func (c *Client) DescribeRocketMQGroupsWithContext(ctx context.Context, request *DescribeRocketMQGroupsRequest) (response *DescribeRocketMQGroupsResponse, err error)

DescribeRocketMQGroups This API is used to get the list of RocketMQ consumer groups.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeRocketMQNamespaces 

func (c *Client) DescribeRocketMQNamespaces(request *DescribeRocketMQNamespacesRequest) (response *DescribeRocketMQNamespacesResponse, err error)

DescribeRocketMQNamespaces This API is used to get the list of RocketMQ namespaces.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeRocketMQNamespacesWithContext 

func (c *Client) DescribeRocketMQNamespacesWithContext(ctx context.Context, request *DescribeRocketMQNamespacesRequest) (response *DescribeRocketMQNamespacesResponse, err error)

DescribeRocketMQNamespaces This API is used to get the list of RocketMQ namespaces.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeRocketMQTopics 

func (c *Client) DescribeRocketMQTopics(request *DescribeRocketMQTopicsRequest) (response *DescribeRocketMQTopicsResponse, err error)

DescribeRocketMQTopics This API is used to get the list of RocketMQ topics.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeRocketMQTopicsWithContext 

func (c *Client) DescribeRocketMQTopicsWithContext(ctx context.Context, request *DescribeRocketMQTopicsRequest) (response *DescribeRocketMQTopicsResponse, err error)

DescribeRocketMQTopics This API is used to get the list of RocketMQ topics.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_ILLEGALMESSAGE = "InternalError.IllegalMessage"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeRoles 

func (c *Client) DescribeRoles(request *DescribeRolesRequest) (response *DescribeRolesResponse, err error)

DescribeRoles This API is used to get the list of roles.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeRolesWithContext 

func (c *Client) DescribeRolesWithContext(ctx context.Context, request *DescribeRolesRequest) (response *DescribeRolesResponse, err error)

DescribeRoles This API is used to get the list of roles.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"

func (*Client) DescribeSubscriptions 

func (c *Client) DescribeSubscriptions(request *DescribeSubscriptionsRequest) (response *DescribeSubscriptionsResponse, err error)

DescribeSubscriptions This API is used to query the list of subscribers under the specified environment and topic.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DESCRIBESUBSCRIPTION = "FailedOperation.DescribeSubscription"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) DescribeSubscriptionsWithContext 

func (c *Client) DescribeSubscriptionsWithContext(ctx context.Context, request *DescribeSubscriptionsRequest) (response *DescribeSubscriptionsResponse, err error)

DescribeSubscriptions This API is used to query the list of subscribers under the specified environment and topic.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_DESCRIBESUBSCRIPTION = "FailedOperation.DescribeSubscription"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) DescribeTopics 

func (c *Client) DescribeTopics(request *DescribeTopicsRequest) (response *DescribeTopicsResponse, err error)

DescribeTopics This API is used to get the list of topics under an environment.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"

func (*Client) DescribeTopicsWithContext 

func (c *Client) DescribeTopicsWithContext(ctx context.Context, request *DescribeTopicsRequest) (response *DescribeTopicsResponse, err error)

DescribeTopics This API is used to get the list of topics under an environment.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"

func (*Client) ModifyCluster 

func (c *Client) ModifyCluster(request *ModifyClusterRequest) (response *ModifyClusterResponse, err error)

ModifyCluster This API is used to update a cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INVALIDPARAMETERVALUE_CLUSTERNAMEDUPLICATION = "InvalidParameterValue.ClusterNameDuplication"
MISSINGPARAMETER = "MissingParameter"

func (*Client) ModifyClusterWithContext 

func (c *Client) ModifyClusterWithContext(ctx context.Context, request *ModifyClusterRequest) (response *ModifyClusterResponse, err error)

ModifyCluster This API is used to update a cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INVALIDPARAMETERVALUE_CLUSTERNAMEDUPLICATION = "InvalidParameterValue.ClusterNameDuplication"
MISSINGPARAMETER = "MissingParameter"

func (*Client) ModifyCmqQueueAttribute 

func (c *Client) ModifyCmqQueueAttribute(request *ModifyCmqQueueAttributeRequest) (response *ModifyCmqQueueAttributeResponse, err error)

ModifyCmqQueueAttribute This API is used to modify the attributes of a CMQ queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR_BROKERSERVICE = "InternalError.BrokerService"

func (*Client) ModifyCmqQueueAttributeWithContext 

func (c *Client) ModifyCmqQueueAttributeWithContext(ctx context.Context, request *ModifyCmqQueueAttributeRequest) (response *ModifyCmqQueueAttributeResponse, err error)

ModifyCmqQueueAttribute This API is used to modify the attributes of a CMQ queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR_BROKERSERVICE = "InternalError.BrokerService"

func (*Client) ModifyCmqSubscriptionAttribute 

func (c *Client) ModifyCmqSubscriptionAttribute(request *ModifyCmqSubscriptionAttributeRequest) (response *ModifyCmqSubscriptionAttributeResponse, err error)

ModifyCmqSubscriptionAttribute This API is used to modify the attributes of a CMQ subscription.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) ModifyCmqSubscriptionAttributeWithContext 

func (c *Client) ModifyCmqSubscriptionAttributeWithContext(ctx context.Context, request *ModifyCmqSubscriptionAttributeRequest) (response *ModifyCmqSubscriptionAttributeResponse, err error)

ModifyCmqSubscriptionAttribute This API is used to modify the attributes of a CMQ subscription.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) ModifyCmqTopicAttribute 

func (c *Client) ModifyCmqTopicAttribute(request *ModifyCmqTopicAttributeRequest) (response *ModifyCmqTopicAttributeResponse, err error)

ModifyCmqTopicAttribute This API is used to modify the attributes of a CMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) ModifyCmqTopicAttributeWithContext 

func (c *Client) ModifyCmqTopicAttributeWithContext(ctx context.Context, request *ModifyCmqTopicAttributeRequest) (response *ModifyCmqTopicAttributeResponse, err error)

ModifyCmqTopicAttribute This API is used to modify the attributes of a CMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) ModifyEnvironmentAttributes 

func (c *Client) ModifyEnvironmentAttributes(request *ModifyEnvironmentAttributesRequest) (response *ModifyEnvironmentAttributesResponse, err error)

ModifyEnvironmentAttributes This API is used to modify the attributes of the specified namespace.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_SETTTL = "FailedOperation.SetTTL"
FAILEDOPERATION_UPDATEENVIRONMENT = "FailedOperation.UpdateEnvironment"
INTERNALERROR_BROKERSERVICE = "InternalError.BrokerService"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
INVALIDPARAMETERVALUE_TTL = "InvalidParameterValue.TTL"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"
RESOURCEUNAVAILABLE_FUNDREQUIRED = "ResourceUnavailable.FundRequired"

func (*Client) ModifyEnvironmentAttributesWithContext 

func (c *Client) ModifyEnvironmentAttributesWithContext(ctx context.Context, request *ModifyEnvironmentAttributesRequest) (response *ModifyEnvironmentAttributesResponse, err error)

ModifyEnvironmentAttributes This API is used to modify the attributes of the specified namespace.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_SETTTL = "FailedOperation.SetTTL"
FAILEDOPERATION_UPDATEENVIRONMENT = "FailedOperation.UpdateEnvironment"
INTERNALERROR_BROKERSERVICE = "InternalError.BrokerService"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
INVALIDPARAMETERVALUE_TTL = "InvalidParameterValue.TTL"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
OPERATIONDENIED_DEFAULTENVIRONMENT = "OperationDenied.DefaultEnvironment"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_ENVIRONMENT = "ResourceNotFound.Environment"
RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"
RESOURCEUNAVAILABLE_FUNDREQUIRED = "ResourceUnavailable.FundRequired"

func (*Client) ModifyEnvironmentRole 

func (c *Client) ModifyEnvironmentRole(request *ModifyEnvironmentRoleRequest) (response *ModifyEnvironmentRoleResponse, err error)

ModifyEnvironmentRole This API is used to modify an environment role.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_UPDATEENVIRONMENTROLE = "FailedOperation.UpdateEnvironmentRole"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_ENVIRONMENTROLE = "ResourceNotFound.EnvironmentRole"

func (*Client) ModifyEnvironmentRoleWithContext 

func (c *Client) ModifyEnvironmentRoleWithContext(ctx context.Context, request *ModifyEnvironmentRoleRequest) (response *ModifyEnvironmentRoleResponse, err error)

ModifyEnvironmentRole This API is used to modify an environment role.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_UPDATEENVIRONMENTROLE = "FailedOperation.UpdateEnvironmentRole"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_ENVIRONMENTROLE = "ResourceNotFound.EnvironmentRole"

func (*Client) ModifyRocketMQCluster 

func (c *Client) ModifyRocketMQCluster(request *ModifyRocketMQClusterRequest) (response *ModifyRocketMQClusterResponse, err error)

ModifyRocketMQCluster This API is used to update a RocketMQ cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCEINSUFFICIENT = "ResourceInsufficient"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifyRocketMQClusterWithContext 

func (c *Client) ModifyRocketMQClusterWithContext(ctx context.Context, request *ModifyRocketMQClusterRequest) (response *ModifyRocketMQClusterResponse, err error)

ModifyRocketMQCluster This API is used to update a RocketMQ cluster.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCEINSUFFICIENT = "ResourceInsufficient"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifyRocketMQGroup 

func (c *Client) ModifyRocketMQGroup(request *ModifyRocketMQGroupRequest) (response *ModifyRocketMQGroupResponse, err error)

ModifyRocketMQGroup This API is used to update a RocketMQ consumer group.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifyRocketMQGroupWithContext 

func (c *Client) ModifyRocketMQGroupWithContext(ctx context.Context, request *ModifyRocketMQGroupRequest) (response *ModifyRocketMQGroupResponse, err error)

ModifyRocketMQGroup This API is used to update a RocketMQ consumer group.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifyRocketMQNamespace 

func (c *Client) ModifyRocketMQNamespace(request *ModifyRocketMQNamespaceRequest) (response *ModifyRocketMQNamespaceResponse, err error)

ModifyRocketMQNamespace This API is used to update a RocketMQ namespace.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCEINSUFFICIENT = "ResourceInsufficient"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifyRocketMQNamespaceWithContext 

func (c *Client) ModifyRocketMQNamespaceWithContext(ctx context.Context, request *ModifyRocketMQNamespaceRequest) (response *ModifyRocketMQNamespaceResponse, err error)

ModifyRocketMQNamespace This API is used to update a RocketMQ namespace.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCEINSUFFICIENT = "ResourceInsufficient"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifyRocketMQTopic 

func (c *Client) ModifyRocketMQTopic(request *ModifyRocketMQTopicRequest) (response *ModifyRocketMQTopicResponse, err error)

ModifyRocketMQTopic This API is used to update a RocketMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifyRocketMQTopicWithContext 

func (c *Client) ModifyRocketMQTopicWithContext(ctx context.Context, request *ModifyRocketMQTopicRequest) (response *ModifyRocketMQTopicResponse, err error)

ModifyRocketMQTopic This API is used to update a RocketMQ topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifyRole 

func (c *Client) ModifyRole(request *ModifyRoleRequest) (response *ModifyRoleResponse, err error)

ModifyRole This API is used to modify a role.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_UPDATEROLE = "FailedOperation.UpdateRole"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

func (*Client) ModifyRoleWithContext 

func (c *Client) ModifyRoleWithContext(ctx context.Context, request *ModifyRoleRequest) (response *ModifyRoleResponse, err error)

ModifyRole This API is used to modify a role.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_UPDATEROLE = "FailedOperation.UpdateRole"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

func (*Client) ModifyTopic 

func (c *Client) ModifyTopic(request *ModifyTopicRequest) (response *ModifyTopicResponse, err error)

ModifyTopic This API is used to modify the topic remarks and number of partitions.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_GETTOPICPARTITIONSFAILED = "FailedOperation.GetTopicPartitionsFailed"
FAILEDOPERATION_UPDATETOPIC = "FailedOperation.UpdateTopic"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) ModifyTopicWithContext 

func (c *Client) ModifyTopicWithContext(ctx context.Context, request *ModifyTopicRequest) (response *ModifyTopicResponse, err error)

ModifyTopic This API is used to modify the topic remarks and number of partitions.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_GETTOPICPARTITIONSFAILED = "FailedOperation.GetTopicPartitionsFailed"
FAILEDOPERATION_UPDATETOPIC = "FailedOperation.UpdateTopic"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) PublishCmqMsg 

func (c *Client) PublishCmqMsg(request *PublishCmqMsgRequest) (response *PublishCmqMsgResponse, err error)

PublishCmqMsg This API is used to send a CMQ topic message.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) PublishCmqMsgWithContext 

func (c *Client) PublishCmqMsgWithContext(ctx context.Context, request *PublishCmqMsgRequest) (response *PublishCmqMsgResponse, err error)

PublishCmqMsg This API is used to send a CMQ topic message.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) ReceiveMessage 

func (c *Client) ReceiveMessage(request *ReceiveMessageRequest) (response *ReceiveMessageResponse, err error)

ReceiveMessage This API is used to receive messages sent to the specified topic.

error code that may be returned: 

FAILEDOPERATION_CREATEPRODUCERERROR = "FailedOperation.CreateProducerError"
FAILEDOPERATION_CREATEPULSARCLIENTERROR = "FailedOperation.CreatePulsarClientError"
FAILEDOPERATION_MAXMESSAGESIZEERROR = "FailedOperation.MaxMessageSizeError"
FAILEDOPERATION_MESSAGEIDERROR = "FailedOperation.MessageIDError"
FAILEDOPERATION_RECEIVEERROR = "FailedOperation.ReceiveError"
FAILEDOPERATION_RECEIVETIMEOUT = "FailedOperation.ReceiveTimeout"
FAILEDOPERATION_SENDMESSAGETIMEOUTERROR = "FailedOperation.SendMessageTimeoutError"
FAILEDOPERATION_TOPICTYPEERROR = "FailedOperation.TopicTypeError"
INVALIDPARAMETER_TENANTNOTFOUND = "InvalidParameter.TenantNotFound"
INVALIDPARAMETER_TOKENNOTFOUND = "InvalidParameter.TokenNotFound"
INVALIDPARAMETERVALUE_TOPICNOTFOUND = "InvalidParameterValue.TopicNotFound"

func (*Client) ReceiveMessageWithContext 

func (c *Client) ReceiveMessageWithContext(ctx context.Context, request *ReceiveMessageRequest) (response *ReceiveMessageResponse, err error)

ReceiveMessage This API is used to receive messages sent to the specified topic.

error code that may be returned: 

FAILEDOPERATION_CREATEPRODUCERERROR = "FailedOperation.CreateProducerError"
FAILEDOPERATION_CREATEPULSARCLIENTERROR = "FailedOperation.CreatePulsarClientError"
FAILEDOPERATION_MAXMESSAGESIZEERROR = "FailedOperation.MaxMessageSizeError"
FAILEDOPERATION_MESSAGEIDERROR = "FailedOperation.MessageIDError"
FAILEDOPERATION_RECEIVEERROR = "FailedOperation.ReceiveError"
FAILEDOPERATION_RECEIVETIMEOUT = "FailedOperation.ReceiveTimeout"
FAILEDOPERATION_SENDMESSAGETIMEOUTERROR = "FailedOperation.SendMessageTimeoutError"
FAILEDOPERATION_TOPICTYPEERROR = "FailedOperation.TopicTypeError"
INVALIDPARAMETER_TENANTNOTFOUND = "InvalidParameter.TenantNotFound"
INVALIDPARAMETER_TOKENNOTFOUND = "InvalidParameter.TokenNotFound"
INVALIDPARAMETERVALUE_TOPICNOTFOUND = "InvalidParameterValue.TopicNotFound"

func (*Client) ResetMsgSubOffsetByTimestamp 

func (c *Client) ResetMsgSubOffsetByTimestamp(request *ResetMsgSubOffsetByTimestampRequest) (response *ResetMsgSubOffsetByTimestampResponse, err error)

ResetMsgSubOffsetByTimestamp This API is used to rewind a message by timestamp, accurate down to the millisecond.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_RESETMSGSUBOFFSETBYTIMESTAMPFAILED = "FailedOperation.ResetMsgSubOffsetByTimestampFailed"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_SUBSCRIPTION = "ResourceNotFound.Subscription"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) ResetMsgSubOffsetByTimestampWithContext 

func (c *Client) ResetMsgSubOffsetByTimestampWithContext(ctx context.Context, request *ResetMsgSubOffsetByTimestampRequest) (response *ResetMsgSubOffsetByTimestampResponse, err error)

ResetMsgSubOffsetByTimestamp This API is used to rewind a message by timestamp, accurate down to the millisecond.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_RESETMSGSUBOFFSETBYTIMESTAMPFAILED = "FailedOperation.ResetMsgSubOffsetByTimestampFailed"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_BROKERCLUSTER = "ResourceNotFound.BrokerCluster"
RESOURCENOTFOUND_SUBSCRIPTION = "ResourceNotFound.Subscription"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) RewindCmqQueue 

func (c *Client) RewindCmqQueue(request *RewindCmqQueueRequest) (response *RewindCmqQueueResponse, err error)

RewindCmqQueue This API is used to rewind a CMQ queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) RewindCmqQueueWithContext 

func (c *Client) RewindCmqQueueWithContext(ctx context.Context, request *RewindCmqQueueRequest) (response *RewindCmqQueueResponse, err error)

RewindCmqQueue This API is used to rewind a CMQ queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) SendBatchMessages 

func (c *Client) SendBatchMessages(request *SendBatchMessagesRequest) (response *SendBatchMessagesResponse, err error)

SendBatchMessages This API is used to batch send messages.

Note: the batch message sending API in TDMQ is to package messages into a batch on the service side of TDMQ-HTTP and then send the batch as a TCP request inside the service. Therefore, when using this API, you should still follow the logic of sending a single message: each message is an independent HTTP request, and multiple HTTP requests are aggregated into one batch inside the TDMQ-HTTP service and then sent to the server; that is, batch sending messages is the same as sending a single message in terms of usage, and batch aggregation is completed inside the TDMQ-HTTP service.

error code that may be returned: 

FAILEDOPERATION_CREATEPRODUCERERROR = "FailedOperation.CreateProducerError"
FAILEDOPERATION_CREATEPULSARCLIENTERROR = "FailedOperation.CreatePulsarClientError"
FAILEDOPERATION_MAXMESSAGESIZEERROR = "FailedOperation.MaxMessageSizeError"
FAILEDOPERATION_MESSAGEIDERROR = "FailedOperation.MessageIDError"
FAILEDOPERATION_RECEIVEERROR = "FailedOperation.ReceiveError"
FAILEDOPERATION_RECEIVETIMEOUT = "FailedOperation.ReceiveTimeout"
FAILEDOPERATION_SENDMESSAGETIMEOUTERROR = "FailedOperation.SendMessageTimeoutError"
FAILEDOPERATION_TOPICTYPEERROR = "FailedOperation.TopicTypeError"
INVALIDPARAMETER_TENANTNOTFOUND = "InvalidParameter.TenantNotFound"
INVALIDPARAMETER_TOKENNOTFOUND = "InvalidParameter.TokenNotFound"
INVALIDPARAMETERVALUE_TOPICNOTFOUND = "InvalidParameterValue.TopicNotFound"

func (*Client) SendBatchMessagesWithContext 

func (c *Client) SendBatchMessagesWithContext(ctx context.Context, request *SendBatchMessagesRequest) (response *SendBatchMessagesResponse, err error)

SendBatchMessages This API is used to batch send messages.

Note: the batch message sending API in TDMQ is to package messages into a batch on the service side of TDMQ-HTTP and then send the batch as a TCP request inside the service. Therefore, when using this API, you should still follow the logic of sending a single message: each message is an independent HTTP request, and multiple HTTP requests are aggregated into one batch inside the TDMQ-HTTP service and then sent to the server; that is, batch sending messages is the same as sending a single message in terms of usage, and batch aggregation is completed inside the TDMQ-HTTP service.

error code that may be returned: 

FAILEDOPERATION_CREATEPRODUCERERROR = "FailedOperation.CreateProducerError"
FAILEDOPERATION_CREATEPULSARCLIENTERROR = "FailedOperation.CreatePulsarClientError"
FAILEDOPERATION_MAXMESSAGESIZEERROR = "FailedOperation.MaxMessageSizeError"
FAILEDOPERATION_MESSAGEIDERROR = "FailedOperation.MessageIDError"
FAILEDOPERATION_RECEIVEERROR = "FailedOperation.ReceiveError"
FAILEDOPERATION_RECEIVETIMEOUT = "FailedOperation.ReceiveTimeout"
FAILEDOPERATION_SENDMESSAGETIMEOUTERROR = "FailedOperation.SendMessageTimeoutError"
FAILEDOPERATION_TOPICTYPEERROR = "FailedOperation.TopicTypeError"
INVALIDPARAMETER_TENANTNOTFOUND = "InvalidParameter.TenantNotFound"
INVALIDPARAMETER_TOKENNOTFOUND = "InvalidParameter.TokenNotFound"
INVALIDPARAMETERVALUE_TOPICNOTFOUND = "InvalidParameterValue.TopicNotFound"

func (*Client) SendCmqMsg 

func (c *Client) SendCmqMsg(request *SendCmqMsgRequest) (response *SendCmqMsgResponse, err error)

SendCmqMsg This API is used to send a CMQ message.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) SendCmqMsgWithContext 

func (c *Client) SendCmqMsgWithContext(ctx context.Context, request *SendCmqMsgRequest) (response *SendCmqMsgResponse, err error)

SendCmqMsg This API is used to send a CMQ message.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) SendMessages 

func (c *Client) SendMessages(request *SendMessagesRequest) (response *SendMessagesResponse, err error)

SendMessages This API is used to send one message.

error code that may be returned: 

FAILEDOPERATION_CREATEPRODUCERERROR = "FailedOperation.CreateProducerError"
FAILEDOPERATION_CREATEPULSARCLIENTERROR = "FailedOperation.CreatePulsarClientError"
FAILEDOPERATION_MAXMESSAGESIZEERROR = "FailedOperation.MaxMessageSizeError"
FAILEDOPERATION_MESSAGEIDERROR = "FailedOperation.MessageIDError"
FAILEDOPERATION_RECEIVEERROR = "FailedOperation.ReceiveError"
FAILEDOPERATION_RECEIVETIMEOUT = "FailedOperation.ReceiveTimeout"
FAILEDOPERATION_SENDMESSAGETIMEOUTERROR = "FailedOperation.SendMessageTimeoutError"
FAILEDOPERATION_TOPICTYPEERROR = "FailedOperation.TopicTypeError"
INVALIDPARAMETER_TENANTNOTFOUND = "InvalidParameter.TenantNotFound"
INVALIDPARAMETER_TOKENNOTFOUND = "InvalidParameter.TokenNotFound"
INVALIDPARAMETERVALUE_TOPICNOTFOUND = "InvalidParameterValue.TopicNotFound"

func (*Client) SendMessagesWithContext 

func (c *Client) SendMessagesWithContext(ctx context.Context, request *SendMessagesRequest) (response *SendMessagesResponse, err error)

SendMessages This API is used to send one message.

error code that may be returned: 

FAILEDOPERATION_CREATEPRODUCERERROR = "FailedOperation.CreateProducerError"
FAILEDOPERATION_CREATEPULSARCLIENTERROR = "FailedOperation.CreatePulsarClientError"
FAILEDOPERATION_MAXMESSAGESIZEERROR = "FailedOperation.MaxMessageSizeError"
FAILEDOPERATION_MESSAGEIDERROR = "FailedOperation.MessageIDError"
FAILEDOPERATION_RECEIVEERROR = "FailedOperation.ReceiveError"
FAILEDOPERATION_RECEIVETIMEOUT = "FailedOperation.ReceiveTimeout"
FAILEDOPERATION_SENDMESSAGETIMEOUTERROR = "FailedOperation.SendMessageTimeoutError"
FAILEDOPERATION_TOPICTYPEERROR = "FailedOperation.TopicTypeError"
INVALIDPARAMETER_TENANTNOTFOUND = "InvalidParameter.TenantNotFound"
INVALIDPARAMETER_TOKENNOTFOUND = "InvalidParameter.TokenNotFound"
INVALIDPARAMETERVALUE_TOPICNOTFOUND = "InvalidParameterValue.TopicNotFound"

func (*Client) SendMsg 

func (c *Client) SendMsg(request *SendMsgRequest) (response *SendMsgResponse, err error)

SendMsg This API is used to test message sending. It cannot be used in the production environment.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_GETTOPICPARTITIONSFAILED = "FailedOperation.GetTopicPartitionsFailed"
FAILEDOPERATION_SENDMSGFAILED = "FailedOperation.SendMsgFailed"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) SendMsgWithContext 

func (c *Client) SendMsgWithContext(ctx context.Context, request *SendMsgRequest) (response *SendMsgResponse, err error)

SendMsg This API is used to test message sending. It cannot be used in the production environment.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_GETTOPICPARTITIONSFAILED = "FailedOperation.GetTopicPartitionsFailed"
FAILEDOPERATION_SENDMSGFAILED = "FailedOperation.SendMsgFailed"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
INVALIDPARAMETERVALUE_INVALIDPARAMS = "InvalidParameterValue.InvalidParams"
MISSINGPARAMETER_NEEDMOREPARAMS = "MissingParameter.NeedMoreParams"
RESOURCENOTFOUND_CLUSTER = "ResourceNotFound.Cluster"
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"

func (*Client) UnbindCmqDeadLetter 

func (c *Client) UnbindCmqDeadLetter(request *UnbindCmqDeadLetterRequest) (response *UnbindCmqDeadLetterResponse, err error)

UnbindCmqDeadLetter This API is used to unbind a CMQ dead letter queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

func (*Client) UnbindCmqDeadLetterWithContext 

func (c *Client) UnbindCmqDeadLetterWithContext(ctx context.Context, request *UnbindCmqDeadLetterRequest) (response *UnbindCmqDeadLetterResponse, err error)

UnbindCmqDeadLetter This API is used to unbind a CMQ dead letter queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"

type Cluster 

type Cluster struct {

	// Cluster ID.
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Cluster name.
	ClusterName *string `json:"ClusterName,omitempty" name:"ClusterName"`

	// Remarks.
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// �Number of access points
	EndPointNum *int64 `json:"EndPointNum,omitempty" name:"EndPointNum"`

	// Creation time
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// Whether the cluster is healthy. 1: healthy; 0: exceptional
	Healthy *int64 `json:"Healthy,omitempty" name:"Healthy"`

	// Cluster health information
	// Note: this field may return null, indicating that no valid values can be obtained.
	HealthyInfo *string `json:"HealthyInfo,omitempty" name:"HealthyInfo"`

	// Cluster status. 0: creating; 1: normal; 2: terminating; 3: deleted; 4. isolated; 5. creation failed; 6: deletion failed
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// Maximum number of namespaces
	MaxNamespaceNum *int64 `json:"MaxNamespaceNum,omitempty" name:"MaxNamespaceNum"`

	// Maximum number of topics
	MaxTopicNum *int64 `json:"MaxTopicNum,omitempty" name:"MaxTopicNum"`

	// Maximum QPS
	MaxQps *int64 `json:"MaxQps,omitempty" name:"MaxQps"`

	// Maximum message retention period in seconds
	MessageRetentionTime *int64 `json:"MessageRetentionTime,omitempty" name:"MessageRetentionTime"`

	// Maximum storage capacity
	MaxStorageCapacity *int64 `json:"MaxStorageCapacity,omitempty" name:"MaxStorageCapacity"`

	// Cluster version
	// Note: this field may return null, indicating that no valid values can be obtained.
	Version *string `json:"Version,omitempty" name:"Version"`

	// Public network access point
	// Note: this field may return null, indicating that no valid values can be obtained.
	PublicEndPoint *string `json:"PublicEndPoint,omitempty" name:"PublicEndPoint"`

	// VPC access point
	// Note: this field may return null, indicating that no valid values can be obtained.
	VpcEndPoint *string `json:"VpcEndPoint,omitempty" name:"VpcEndPoint"`

	// Number of namespaces
	// Note: this field may return null, indicating that no valid values can be obtained.
	NamespaceNum *int64 `json:"NamespaceNum,omitempty" name:"NamespaceNum"`

	// Limit of used storage in MB
	// Note: this field may return null, indicating that no valid values can be obtained.
	UsedStorageBudget *int64 `json:"UsedStorageBudget,omitempty" name:"UsedStorageBudget"`

	// Maximum message production rate in messages
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxPublishRateInMessages *int64 `json:"MaxPublishRateInMessages,omitempty" name:"MaxPublishRateInMessages"`

	// Maximum message push rate in messages
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxDispatchRateInMessages *int64 `json:"MaxDispatchRateInMessages,omitempty" name:"MaxDispatchRateInMessages"`

	// Maximum message production rate in bytes
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxPublishRateInBytes *int64 `json:"MaxPublishRateInBytes,omitempty" name:"MaxPublishRateInBytes"`

	// Maximum message push rate in bytes
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxDispatchRateInBytes *int64 `json:"MaxDispatchRateInBytes,omitempty" name:"MaxDispatchRateInBytes"`

	// Number of created topics
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicNum *int64 `json:"TopicNum,omitempty" name:"TopicNum"`

	// Maximum message delay in seconds
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxMessageDelayInSeconds *int64 `json:"MaxMessageDelayInSeconds,omitempty" name:"MaxMessageDelayInSeconds"`

	// Whether to enable public network access. If this parameter is left empty, the feature will be enabled by default
	// Note: this field may return null, indicating that no valid values can be obtained.
	PublicAccessEnabled *bool `json:"PublicAccessEnabled,omitempty" name:"PublicAccessEnabled"`

	// Tag
	// Note: this field may return null, indicating that no valid values can be obtained.
	Tags []*Tag `json:"Tags,omitempty" name:"Tags"`
}

type CmqDeadLetterPolicy 

type CmqDeadLetterPolicy struct {

	// Dead letter queue.
	// Note: this field may return null, indicating that no valid values can be obtained.
	DeadLetterQueue *string `json:"DeadLetterQueue,omitempty" name:"DeadLetterQueue"`

	// Dead letter queue policy.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Policy *uint64 `json:"Policy,omitempty" name:"Policy"`

	// Maximum period in seconds before an unconsumed message expires, which is required if `Policy` is 1. Value range: 300–43200. This value should be smaller than `MsgRetentionSeconds` (maximum message retention period)
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitempty" name:"MaxTimeToLive"`

	// Maximum number of receipts.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitempty" name:"MaxReceiveCount"`
}

type CmqDeadLetterSource 

type CmqDeadLetterSource struct {

	// Message queue ID.
	// Note: this field may return null, indicating that no valid values can be obtained.
	QueueId *string `json:"QueueId,omitempty" name:"QueueId"`

	// Message queue name.
	// Note: this field may return null, indicating that no valid values can be obtained.
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`
}

type CmqQueue 

type CmqQueue struct {

	// Message queue ID.
	QueueId *string `json:"QueueId,omitempty" name:"QueueId"`

	// Message queue name.
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`

	// Limit of the number of messages produced per second. The value for consumed messages is 1.1 times this value.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Qps *uint64 `json:"Qps,omitempty" name:"Qps"`

	// Bandwidth limit.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Bps *uint64 `json:"Bps,omitempty" name:"Bps"`

	// Maximum retention period for inflight messages.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxDelaySeconds *uint64 `json:"MaxDelaySeconds,omitempty" name:"MaxDelaySeconds"`

	// Maximum number of heaped messages. The value range is 1,000,000–10,000,000 during the beta test and can be 1,000,000–1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitempty" name:"MaxMsgHeapNum"`

	// Long polling wait time for message reception. Value range: 0–30 seconds. Default value: 0.
	// Note: this field may return null, indicating that no valid values can be obtained.
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitempty" name:"PollingWaitSeconds"`

	// Message retention period. Value range: 60–1296000 seconds (i.e., 1 minute–15 days). Default value: 345600 (i.e., 4 days).
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// Message visibility timeout period. Value range: 1–43200 seconds (i.e., 12 hours). Default value: 30.
	// Note: this field may return null, indicating that no valid values can be obtained.
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitempty" name:"VisibilityTimeout"`

	// Maximum message length. Value range: 1024–1048576 bytes (i.e., 1–1024 KB). Default value: 65536.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// Maximum time range during which a message can be rewound in the queue, which ranges from 0 to 43,200 seconds. 0 indicates that message rewind is disabled.
	// Note: this field may return null, indicating that no valid values can be obtained.
	RewindSeconds *uint64 `json:"RewindSeconds,omitempty" name:"RewindSeconds"`

	// Queue creation time. A Unix timestamp accurate down to the millisecond will be returned.
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateTime *uint64 `json:"CreateTime,omitempty" name:"CreateTime"`

	// Time when the queue attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.
	// Note: this field may return null, indicating that no valid values can be obtained.
	LastModifyTime *uint64 `json:"LastModifyTime,omitempty" name:"LastModifyTime"`

	// Total number of messages in `Active` status (i.e., unconsumed) in the queue, which is an approximate value.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ActiveMsgNum *uint64 `json:"ActiveMsgNum,omitempty" name:"ActiveMsgNum"`

	// Total number of messages in `Inactive` status (i.e., being consumed) in the queue, which is an approximate value.
	// Note: this field may return null, indicating that no valid values can be obtained.
	InactiveMsgNum *uint64 `json:"InactiveMsgNum,omitempty" name:"InactiveMsgNum"`

	// Number of delayed messages.
	// Note: this field may return null, indicating that no valid values can be obtained.
	DelayMsgNum *uint64 `json:"DelayMsgNum,omitempty" name:"DelayMsgNum"`

	// Number of retained messages which have been deleted by the `DelMsg` API but are still within their rewind time range.
	// Note: this field may return null, indicating that no valid values can be obtained.
	RewindMsgNum *uint64 `json:"RewindMsgNum,omitempty" name:"RewindMsgNum"`

	// Minimum unconsumed time of message in seconds.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MinMsgTime *uint64 `json:"MinMsgTime,omitempty" name:"MinMsgTime"`

	// Transaction message queue. true: transaction message type; false: other message types.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Transaction *bool `json:"Transaction,omitempty" name:"Transaction"`

	// Dead letter queue.
	// Note: this field may return null, indicating that no valid values can be obtained.
	DeadLetterSource []*CmqDeadLetterSource `json:"DeadLetterSource,omitempty" name:"DeadLetterSource"`

	// Dead letter queue policy.
	// Note: this field may return null, indicating that no valid values can be obtained.
	DeadLetterPolicy *CmqDeadLetterPolicy `json:"DeadLetterPolicy,omitempty" name:"DeadLetterPolicy"`

	// Transaction message policy.
	// Note: this field may return null, indicating that no valid values can be obtained.
	TransactionPolicy *CmqTransactionPolicy `json:"TransactionPolicy,omitempty" name:"TransactionPolicy"`

	// Creator `Uin`.
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateUin *uint64 `json:"CreateUin,omitempty" name:"CreateUin"`

	// Associated tag.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Tags []*Tag `json:"Tags,omitempty" name:"Tags"`

	// Message trace. true: enabled; false: not enabled
	// Note: this field may return null, indicating that no valid values can be obtained.
	Trace *bool `json:"Trace,omitempty" name:"Trace"`

	// Tenant ID
	// Note: this field may return null, indicating that no valid values can be obtained.
	TenantId *string `json:"TenantId,omitempty" name:"TenantId"`

	// Namespace name
	// Note: this field may return null, indicating that no valid values can be obtained.
	NamespaceName *string `json:"NamespaceName,omitempty" name:"NamespaceName"`

	// Cluster status. 0: creating; 1: normal; 2: terminating; 3: deleted; 4. isolated; 5. creation failed; 6: deletion failed
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// The maximum number of unacknowledged messages.
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	MaxUnackedMsgNum *int64 `json:"MaxUnackedMsgNum,omitempty" name:"MaxUnackedMsgNum"`

	// Maximum size of heaped messages in bytes.
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	MaxMsgBacklogSize *int64 `json:"MaxMsgBacklogSize,omitempty" name:"MaxMsgBacklogSize"`
}

type CmqSubscription 

type CmqSubscription struct {

	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Note: this field may return null, indicating that no valid values can be obtained.
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`

	// Subscription ID, which will be used during monitoring data pull.
	// Note: this field may return null, indicating that no valid values can be obtained.
	SubscriptionId *string `json:"SubscriptionId,omitempty" name:"SubscriptionId"`

	// Subscription owner `APPID`.
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicOwner *uint64 `json:"TopicOwner,omitempty" name:"TopicOwner"`

	// Number of messages to be delivered in the subscription.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgCount *uint64 `json:"MsgCount,omitempty" name:"MsgCount"`

	// Time when the subscription attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.
	// Note: this field may return null, indicating that no valid values can be obtained.
	LastModifyTime *uint64 `json:"LastModifyTime,omitempty" name:"LastModifyTime"`

	// Subscription creation time. A Unix timestamp accurate down to the millisecond will be returned.
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateTime *uint64 `json:"CreateTime,omitempty" name:"CreateTime"`

	// Filtering policy for subscribing to and receiving messages.
	// Note: this field may return null, indicating that no valid values can be obtained.
	BindingKey []*string `json:"BindingKey,omitempty" name:"BindingKey"`

	// Endpoint that receives notifications, which varies by `protocol`: for HTTP, the endpoint must start with `http://`, and the `host` can be a domain or IP; for `queue`, `queueName` should be entered.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Endpoint *string `json:"Endpoint,omitempty" name:"Endpoint"`

	// Filtering policy selected when a subscription is created:
	// If `filterType` is 1, `filterTag` will be used for filtering.
	// If `filterType` is 2, `bindingKey` will be used for filtering.
	// Note: this field may return null, indicating that no valid values can be obtained.
	FilterTags []*string `json:"FilterTags,omitempty" name:"FilterTags"`

	// Subscription protocol. Currently, two protocols are supported: HTTP and queue. To use the HTTP protocol, you need to build your own web server to receive messages. With the queue protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Protocol *string `json:"Protocol,omitempty" name:"Protocol"`

	// CMQ push server retry policy in case an error occurs while pushing a message to the endpoint. Valid values:
	// (1) BACKOFF_RETRY: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message.
	// (2) EXPONENTIAL_DECAY_RETRY: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: EXPONENTIAL_DECAY_RETRY.
	// Note: this field may return null, indicating that no valid values can be obtained.
	NotifyStrategy *string `json:"NotifyStrategy,omitempty" name:"NotifyStrategy"`

	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If `protocol` is `queue`, this value must be `SIMPLIFIED`. If `protocol` is `HTTP`, both values are acceptable, and the default value is `JSON`.
	// Note: this field may return null, indicating that no valid values can be obtained.
	NotifyContentFormat *string `json:"NotifyContentFormat,omitempty" name:"NotifyContentFormat"`
}

type CmqTopic 

type CmqTopic struct {

	// Topic ID.
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicId *string `json:"TopicId,omitempty" name:"TopicId"`

	// Topic name.
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Maximum lifecycle of message in topic. After the period specified by this parameter has elapsed since a message is sent to the topic, the message will be deleted no matter whether it has been successfully pushed to the user. This parameter is measured in seconds and defaulted to one day (86,400 seconds), which cannot be modified.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// Maximum message size, which ranges from 1,024 to 1,048,576 bytes (i.e., 1–1,024 KB). The default value is 65,536.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// Number of messages published per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Qps *uint64 `json:"Qps,omitempty" name:"Qps"`

	// Filtering policy selected when a subscription is created:
	// If `filterType` is 1, `FilterTag` will be used for filtering.
	// If `filterType` is 2, `BindingKey` will be used for filtering.
	// Note: this field may return null, indicating that no valid values can be obtained.
	FilterType *uint64 `json:"FilterType,omitempty" name:"FilterType"`

	// Topic creation time. A Unix timestamp accurate down to the millisecond will be returned.
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateTime *uint64 `json:"CreateTime,omitempty" name:"CreateTime"`

	// Time when the topic attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.
	// Note: this field may return null, indicating that no valid values can be obtained.
	LastModifyTime *uint64 `json:"LastModifyTime,omitempty" name:"LastModifyTime"`

	// Number of current messages in the topic (number of retained messages).
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgCount *uint64 `json:"MsgCount,omitempty" name:"MsgCount"`

	// Creator `Uin`. The `resource` field for CAM authentication is composed of this field.
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateUin *uint64 `json:"CreateUin,omitempty" name:"CreateUin"`

	// Associated tag.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Tags []*Tag `json:"Tags,omitempty" name:"Tags"`

	// Message trace. true: enabled; false: not enabled
	// Note: this field may return null, indicating that no valid values can be obtained.
	Trace *bool `json:"Trace,omitempty" name:"Trace"`

	// Tenant ID
	// Note: this field may return null, indicating that no valid values can be obtained.
	TenantId *string `json:"TenantId,omitempty" name:"TenantId"`

	// Namespace name
	// Note: this field may return null, indicating that no valid values can be obtained.
	NamespaceName *string `json:"NamespaceName,omitempty" name:"NamespaceName"`
}

type CmqTransactionPolicy 

type CmqTransactionPolicy struct {

	// First lookback time.
	// Note: this field may return null, indicating that no valid values can be obtained.
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitempty" name:"FirstQueryInterval"`

	// Maximum number of queries.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitempty" name:"MaxQueryCount"`
}

type Consumer 

type Consumer struct {

	// The time when the consumer started connecting.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConnectedSince *string `json:"ConnectedSince,omitempty" name:"ConnectedSince"`

	// Consumer address.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumerAddr *string `json:"ConsumerAddr,omitempty" name:"ConsumerAddr"`

	// Consumer name.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumerName *string `json:"ConsumerName,omitempty" name:"ConsumerName"`

	// Consumer version.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ClientVersion *string `json:"ClientVersion,omitempty" name:"ClientVersion"`
}

type ConsumersSchedule 

type ConsumersSchedule struct {

	// Current partition ID.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Partitions *uint64 `json:"Partitions,omitempty" name:"Partitions"`

	// Number of messages.
	// Note: this field may return null, indicating that no valid values can be obtained.
	NumberOfEntries *uint64 `json:"NumberOfEntries,omitempty" name:"NumberOfEntries"`

	// Number of retained messages.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgBacklog *uint64 `json:"MsgBacklog,omitempty" name:"MsgBacklog"`

	// Sum of the numbers of messages delivered by the consumer per second.
	MsgRateOut *string `json:"MsgRateOut,omitempty" name:"MsgRateOut"`

	// Number of bytes of messages consumed by the consumer per second.
	MsgThroughputOut *string `json:"MsgThroughputOut,omitempty" name:"MsgThroughputOut"`

	// Percentage of messages discarded due to timeout.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRateExpired *string `json:"MsgRateExpired,omitempty" name:"MsgRateExpired"`
}

type CreateClusterRequest 

type CreateClusterRequest struct {
	*tchttp.BaseRequest

	// Cluster name, which can contain up to 16 letters, digits, hyphens, and underscores.
	ClusterName *string `json:"ClusterName,omitempty" name:"ClusterName"`

	// ID of your dedicated physical cluster. If it is not passed in, cluster resources will be created in a public cluster by default.
	BindClusterId *uint64 `json:"BindClusterId,omitempty" name:"BindClusterId"`

	// Remarks (up to 128 characters).
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Cluster tag list (deprecated).
	Tags []*Tag `json:"Tags,omitempty" name:"Tags"`

	// Whether to enable public network access. If this parameter is left empty, the feature will be enabled by default
	PublicAccessEnabled *bool `json:"PublicAccessEnabled,omitempty" name:"PublicAccessEnabled"`
}

func NewCreateClusterRequest 

func NewCreateClusterRequest() (request *CreateClusterRequest)

func (*CreateClusterRequest) FromJsonString 

func (r *CreateClusterRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateClusterRequest) ToJsonString 

func (r *CreateClusterRequest) ToJsonString() string

type CreateClusterResponse 

type CreateClusterResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Cluster ID
		ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateClusterResponse 

func NewCreateClusterResponse() (response *CreateClusterResponse)

func (*CreateClusterResponse) FromJsonString 

func (r *CreateClusterResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateClusterResponse) ToJsonString 

func (r *CreateClusterResponse) ToJsonString() string

type CreateCmqQueueRequest 

type CreateCmqQueueRequest struct {
	*tchttp.BaseRequest

	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`

	// Maximum number of heaped messages. The value range is 1,000,000–10,000,000 during the beta test and can be 1,000,000–1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitempty" name:"MaxMsgHeapNum"`

	// Long polling wait time for message reception. Value range: 0–30 seconds. Default value: 0.
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitempty" name:"PollingWaitSeconds"`

	// Message visibility timeout period. Value range: 1–43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitempty" name:"VisibilityTimeout"`

	// Maximum message length. Value range: 1024–65536 bytes (i.e., 1–64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// Message retention period. Value range: 60–1296000 seconds (i.e., 1 minute–15 days). Default value: 345600 (i.e., 4 days).
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// Whether to enable the message rewinding feature for a queue. Value range: 0–msgRetentionSeconds, where 0 means not to enable this feature, while `msgRetentionSeconds` indicates that the maximum rewindable period is the message retention period of the queue.
	RewindSeconds *uint64 `json:"RewindSeconds,omitempty" name:"RewindSeconds"`

	// 1: transaction queue; 0: general queue
	Transaction *uint64 `json:"Transaction,omitempty" name:"Transaction"`

	// First lookback interval
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitempty" name:"FirstQueryInterval"`

	// Maximum number of lookbacks
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitempty" name:"MaxQueryCount"`

	// Dead letter queue name
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitempty" name:"DeadLetterQueueName"`

	// Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: `Time-To-Live` has elapsed
	Policy *uint64 `json:"Policy,omitempty" name:"Policy"`

	// Maximum receipt times. Value range: 1–1000
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitempty" name:"MaxReceiveCount"`

	// Maximum period in seconds before an unconsumed message expires, which is required if `policy` is 1. Value range: 300–43200. This value should be smaller than `msgRetentionSeconds` (maximum message retention period)
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitempty" name:"MaxTimeToLive"`

	// Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled
	Trace *bool `json:"Trace,omitempty" name:"Trace"`
}

func NewCreateCmqQueueRequest 

func NewCreateCmqQueueRequest() (request *CreateCmqQueueRequest)

func (*CreateCmqQueueRequest) FromJsonString 

func (r *CreateCmqQueueRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateCmqQueueRequest) ToJsonString 

func (r *CreateCmqQueueRequest) ToJsonString() string

type CreateCmqQueueResponse 

type CreateCmqQueueResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// `queueId` of a successfully created queue
		QueueId *string `json:"QueueId,omitempty" name:"QueueId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateCmqQueueResponse 

func NewCreateCmqQueueResponse() (response *CreateCmqQueueResponse)

func (*CreateCmqQueueResponse) FromJsonString 

func (r *CreateCmqQueueResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateCmqQueueResponse) ToJsonString 

func (r *CreateCmqQueueResponse) ToJsonString() string

type CreateCmqSubscribeRequest 

type CreateCmqSubscribeRequest struct {
	*tchttp.BaseRequest

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`

	// Subscription protocol. Currently, two protocols are supported: HTTP and queue. To use the HTTP protocol, you need to build your own web server to receive messages. With the queue protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	Protocol *string `json:"Protocol,omitempty" name:"Protocol"`

	// `Endpoint` for notification receipt, which is distinguished by `Protocol`. For `http`, `Endpoint` must begin with `http://` and `host` can be a domain name or IP. For `Queue`, enter `QueueName`. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for `Endpoint`, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.
	Endpoint *string `json:"Endpoint,omitempty" name:"Endpoint"`

	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. BACKOFF_RETRY: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. EXPONENTIAL_DECAY_RETRY: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: EXPONENTIAL_DECAY_RETRY.
	NotifyStrategy *string `json:"NotifyStrategy,omitempty" name:"NotifyStrategy"`

	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not configured, no matter whether `MsgTag` is configured, the subscription will receive all messages published to the topic; 2. If the array of `FilterTag` values has a value, only when at least one of the values in the array also exists in the array of `MsgTag` values (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the array of `FilterTag` values has a value, but `MsgTag` is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	FilterTag []*string `json:"FilterTag,omitempty" name:"FilterTag"`

	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` includes up to 15 dots (namely up to 16 segments).
	BindingKey []*string `json:"BindingKey,omitempty" name:"BindingKey"`

	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat *string `json:"NotifyContentFormat,omitempty" name:"NotifyContentFormat"`
}

func NewCreateCmqSubscribeRequest 

func NewCreateCmqSubscribeRequest() (request *CreateCmqSubscribeRequest)

func (*CreateCmqSubscribeRequest) FromJsonString 

func (r *CreateCmqSubscribeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateCmqSubscribeRequest) ToJsonString 

func (r *CreateCmqSubscribeRequest) ToJsonString() string

type CreateCmqSubscribeResponse 

type CreateCmqSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Subscription ID
		SubscriptionId *string `json:"SubscriptionId,omitempty" name:"SubscriptionId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateCmqSubscribeResponse 

func NewCreateCmqSubscribeResponse() (response *CreateCmqSubscribeResponse)

func (*CreateCmqSubscribeResponse) FromJsonString 

func (r *CreateCmqSubscribeResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateCmqSubscribeResponse) ToJsonString 

func (r *CreateCmqSubscribeResponse) ToJsonString() string

type CreateCmqTopicRequest 

type CreateCmqTopicRequest struct {
	*tchttp.BaseRequest

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Maximum message length. Value range: 1024–65536 bytes (i.e., 1–64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// Used to specify the message match policy for the topic. 1: tag match policy (default value); 2: routing match policy.
	FilterType *uint64 `json:"FilterType,omitempty" name:"FilterType"`

	// Message retention period. Value range: 60–86400 seconds (i.e., 1 minute–1 day). Default value: 86400.
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"Trace,omitempty" name:"Trace"`
}

func NewCreateCmqTopicRequest 

func NewCreateCmqTopicRequest() (request *CreateCmqTopicRequest)

func (*CreateCmqTopicRequest) FromJsonString 

func (r *CreateCmqTopicRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateCmqTopicRequest) ToJsonString 

func (r *CreateCmqTopicRequest) ToJsonString() string

type CreateCmqTopicResponse 

type CreateCmqTopicResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Topic ID
		TopicId *string `json:"TopicId,omitempty" name:"TopicId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateCmqTopicResponse 

func NewCreateCmqTopicResponse() (response *CreateCmqTopicResponse)

func (*CreateCmqTopicResponse) FromJsonString 

func (r *CreateCmqTopicResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateCmqTopicResponse) ToJsonString 

func (r *CreateCmqTopicResponse) ToJsonString() string

type CreateEnvironmentRequest 

type CreateEnvironmentRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name, which can contain up to 16 letters, digits, hyphens, and underscores.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Unconsumed message expiration time in seconds. Minimum value: 60; maximum value: 1296000 (15 days).
	MsgTTL *uint64 `json:"MsgTTL,omitempty" name:"MsgTTL"`

	// Remarks (up to 128 characters).
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Message retention policy
	RetentionPolicy *RetentionPolicy `json:"RetentionPolicy,omitempty" name:"RetentionPolicy"`
}

func NewCreateEnvironmentRequest 

func NewCreateEnvironmentRequest() (request *CreateEnvironmentRequest)

func (*CreateEnvironmentRequest) FromJsonString 

func (r *CreateEnvironmentRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateEnvironmentRequest) ToJsonString 

func (r *CreateEnvironmentRequest) ToJsonString() string

type CreateEnvironmentResponse 

type CreateEnvironmentResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Environment (namespace) name.
		EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

		// TTL for unconsumed messages in seconds.
		MsgTTL *uint64 `json:"MsgTTL,omitempty" name:"MsgTTL"`

		// Remarks (up to 128 characters).
		// Note: this field may return null, indicating that no valid values can be obtained.
		Remark *string `json:"Remark,omitempty" name:"Remark"`

		// Namespace ID
		NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateEnvironmentResponse 

func NewCreateEnvironmentResponse() (response *CreateEnvironmentResponse)

func (*CreateEnvironmentResponse) FromJsonString 

func (r *CreateEnvironmentResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateEnvironmentResponse) ToJsonString 

func (r *CreateEnvironmentResponse) ToJsonString() string

type CreateEnvironmentRoleRequest 

type CreateEnvironmentRoleRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Role name.
	RoleName *string `json:"RoleName,omitempty" name:"RoleName"`

	// Permissions, which is a non-empty string array of `produce` and `consume` at the most.
	Permissions []*string `json:"Permissions,omitempty" name:"Permissions"`

	// Cluster ID (required)
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewCreateEnvironmentRoleRequest 

func NewCreateEnvironmentRoleRequest() (request *CreateEnvironmentRoleRequest)

func (*CreateEnvironmentRoleRequest) FromJsonString 

func (r *CreateEnvironmentRoleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateEnvironmentRoleRequest) ToJsonString 

func (r *CreateEnvironmentRoleRequest) ToJsonString() string

type CreateEnvironmentRoleResponse 

type CreateEnvironmentRoleResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateEnvironmentRoleResponse 

func NewCreateEnvironmentRoleResponse() (response *CreateEnvironmentRoleResponse)

func (*CreateEnvironmentRoleResponse) FromJsonString 

func (r *CreateEnvironmentRoleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateEnvironmentRoleResponse) ToJsonString 

func (r *CreateEnvironmentRoleResponse) ToJsonString() string

type CreateRocketMQClusterRequest 

type CreateRocketMQClusterRequest struct {
	*tchttp.BaseRequest

	// Cluster name, which can contain 3–64 letters, digits, hyphens, and underscores
	Name *string `json:"Name,omitempty" name:"Name"`

	// Cluster description (up to 128 characters)
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}

func NewCreateRocketMQClusterRequest 

func NewCreateRocketMQClusterRequest() (request *CreateRocketMQClusterRequest)

func (*CreateRocketMQClusterRequest) FromJsonString 

func (r *CreateRocketMQClusterRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRocketMQClusterRequest) ToJsonString 

func (r *CreateRocketMQClusterRequest) ToJsonString() string

type CreateRocketMQClusterResponse 

type CreateRocketMQClusterResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Cluster ID
		ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateRocketMQClusterResponse 

func NewCreateRocketMQClusterResponse() (response *CreateRocketMQClusterResponse)

func (*CreateRocketMQClusterResponse) FromJsonString 

func (r *CreateRocketMQClusterResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRocketMQClusterResponse) ToJsonString 

func (r *CreateRocketMQClusterResponse) ToJsonString() string

type CreateRocketMQGroupRequest 

type CreateRocketMQGroupRequest struct {
	*tchttp.BaseRequest

	// Group name (8–64 characters)
	GroupId *string `json:"GroupId,omitempty" name:"GroupId"`

	// Namespace. Currently, only one namespace is supported
	Namespaces []*string `json:"Namespaces,omitempty" name:"Namespaces"`

	// Whether to enable consumption
	ReadEnable *bool `json:"ReadEnable,omitempty" name:"ReadEnable"`

	// Whether to enable broadcast consumption
	BroadcastEnable *bool `json:"BroadcastEnable,omitempty" name:"BroadcastEnable"`

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Remarks (up to 128 characters)
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}

func NewCreateRocketMQGroupRequest 

func NewCreateRocketMQGroupRequest() (request *CreateRocketMQGroupRequest)

func (*CreateRocketMQGroupRequest) FromJsonString 

func (r *CreateRocketMQGroupRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRocketMQGroupRequest) ToJsonString 

func (r *CreateRocketMQGroupRequest) ToJsonString() string

type CreateRocketMQGroupResponse 

type CreateRocketMQGroupResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateRocketMQGroupResponse 

func NewCreateRocketMQGroupResponse() (response *CreateRocketMQGroupResponse)

func (*CreateRocketMQGroupResponse) FromJsonString 

func (r *CreateRocketMQGroupResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRocketMQGroupResponse) ToJsonString 

func (r *CreateRocketMQGroupResponse) ToJsonString() string

type CreateRocketMQNamespaceRequest 

type CreateRocketMQNamespaceRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace name, which can contain 3–64 letters, digits, hyphens, and underscores
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

	// Retention time of unconsumed messages in milliseconds. Value range: 60 seconds–15 days
	Ttl *uint64 `json:"Ttl,omitempty" name:"Ttl"`

	// Retention time of persisted messages in milliseconds
	RetentionTime *uint64 `json:"RetentionTime,omitempty" name:"RetentionTime"`

	// Remarks (up to 128 characters)
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}

func NewCreateRocketMQNamespaceRequest 

func NewCreateRocketMQNamespaceRequest() (request *CreateRocketMQNamespaceRequest)

func (*CreateRocketMQNamespaceRequest) FromJsonString 

func (r *CreateRocketMQNamespaceRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRocketMQNamespaceRequest) ToJsonString 

func (r *CreateRocketMQNamespaceRequest) ToJsonString() string

type CreateRocketMQNamespaceResponse 

type CreateRocketMQNamespaceResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateRocketMQNamespaceResponse 

func NewCreateRocketMQNamespaceResponse() (response *CreateRocketMQNamespaceResponse)

func (*CreateRocketMQNamespaceResponse) FromJsonString 

func (r *CreateRocketMQNamespaceResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRocketMQNamespaceResponse) ToJsonString 

func (r *CreateRocketMQNamespaceResponse) ToJsonString() string

type CreateRocketMQTopicRequest 

type CreateRocketMQTopicRequest struct {
	*tchttp.BaseRequest

	// Topic name, which can contain 3–64 letters, digits, hyphens, and underscores
	Topic *string `json:"Topic,omitempty" name:"Topic"`

	// Topic namespace. Currently, you can create topics only in one single namespace.
	Namespaces []*string `json:"Namespaces,omitempty" name:"Namespaces"`

	// Topic type. Valid values: Normal, GlobalOrder, PartitionedOrder.
	Type *string `json:"Type,omitempty" name:"Type"`

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Topic remarks (up to 128 characters)
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Number of partitions, which doesn't take effect for globally sequential messages
	PartitionNum *int64 `json:"PartitionNum,omitempty" name:"PartitionNum"`
}

func NewCreateRocketMQTopicRequest 

func NewCreateRocketMQTopicRequest() (request *CreateRocketMQTopicRequest)

func (*CreateRocketMQTopicRequest) FromJsonString 

func (r *CreateRocketMQTopicRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRocketMQTopicRequest) ToJsonString 

func (r *CreateRocketMQTopicRequest) ToJsonString() string

type CreateRocketMQTopicResponse 

type CreateRocketMQTopicResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateRocketMQTopicResponse 

func NewCreateRocketMQTopicResponse() (response *CreateRocketMQTopicResponse)

func (*CreateRocketMQTopicResponse) FromJsonString 

func (r *CreateRocketMQTopicResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRocketMQTopicResponse) ToJsonString 

func (r *CreateRocketMQTopicResponse) ToJsonString() string

type CreateRoleRequest 

type CreateRoleRequest struct {
	*tchttp.BaseRequest

	// Role name, which can contain up to 32 letters, digits, hyphens, and underscores.
	RoleName *string `json:"RoleName,omitempty" name:"RoleName"`

	// Remarks (up to 128 characters).
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Cluster ID (required)
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewCreateRoleRequest 

func NewCreateRoleRequest() (request *CreateRoleRequest)

func (*CreateRoleRequest) FromJsonString 

func (r *CreateRoleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRoleRequest) ToJsonString 

func (r *CreateRoleRequest) ToJsonString() string

type CreateRoleResponse 

type CreateRoleResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Role name
		RoleName *string `json:"RoleName,omitempty" name:"RoleName"`

		// Role token
		Token *string `json:"Token,omitempty" name:"Token"`

		// Remarks
		// Note: this field may return null, indicating that no valid values can be obtained.
		Remark *string `json:"Remark,omitempty" name:"Remark"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateRoleResponse 

func NewCreateRoleResponse() (response *CreateRoleResponse)

func (*CreateRoleResponse) FromJsonString 

func (r *CreateRoleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRoleResponse) ToJsonString 

func (r *CreateRoleResponse) ToJsonString() string

type CreateSubscriptionRequest 

type CreateSubscriptionRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Topic name.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Subscriber name, which can contain up to 150 letters, digits, hyphens, and underscores.
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`

	// Whether the creation is idempotent; if not, you cannot create subscriptions with the same name.
	IsIdempotent *bool `json:"IsIdempotent,omitempty" name:"IsIdempotent"`

	// Remarks (up to 128 characters).
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Whether to automatically create a dead letter topic and a retry letter topic. true: yes (default value); false: no.
	AutoCreatePolicyTopic *bool `json:"AutoCreatePolicyTopic,omitempty" name:"AutoCreatePolicyTopic"`

	// Naming convention for dead letter and retry letter topics. `LEGACY` indicates to use the legacy naming convention, and `COMMUNITY` indicates to use the naming convention in the Pulsar community.
	PostFixPattern *string `json:"PostFixPattern,omitempty" name:"PostFixPattern"`
}

func NewCreateSubscriptionRequest 

func NewCreateSubscriptionRequest() (request *CreateSubscriptionRequest)

func (*CreateSubscriptionRequest) FromJsonString 

func (r *CreateSubscriptionRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateSubscriptionRequest) ToJsonString 

func (r *CreateSubscriptionRequest) ToJsonString() string

type CreateSubscriptionResponse 

type CreateSubscriptionResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Creation result.
		Result *bool `json:"Result,omitempty" name:"Result"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateSubscriptionResponse 

func NewCreateSubscriptionResponse() (response *CreateSubscriptionResponse)

func (*CreateSubscriptionResponse) FromJsonString 

func (r *CreateSubscriptionResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateSubscriptionResponse) ToJsonString 

func (r *CreateSubscriptionResponse) ToJsonString() string

type CreateTopicRequest 

type CreateTopicRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Topic name, which can contain up to 64 letters, digits, hyphens, and underscores.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// 0: non-partitioned topic; other values: number of partitions in the partitioned topic (up to 128).
	Partitions *uint64 `json:"Partitions,omitempty" name:"Partitions"`

	// 0: general message;
	// 1: globally sequential message;
	// 2: partitionally sequential message;
	// 3: retry letter queue;
	// 4: dead letter queue.
	TopicType *uint64 `json:"TopicType,omitempty" name:"TopicType"`

	// Remarks (up to 128 characters).
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewCreateTopicRequest 

func NewCreateTopicRequest() (request *CreateTopicRequest)

func (*CreateTopicRequest) FromJsonString 

func (r *CreateTopicRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTopicRequest) ToJsonString 

func (r *CreateTopicRequest) ToJsonString() string

type CreateTopicResponse 

type CreateTopicResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Environment (namespace) name.
		EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

		// Topic name.
		TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

		// 0: non-partitioned topic; other values: number of partitions in the partitioned topic.
		Partitions *uint64 `json:"Partitions,omitempty" name:"Partitions"`

		// Remarks (up to 128 characters).
		// Note: this field may return null, indicating that no valid values can be obtained.
		Remark *string `json:"Remark,omitempty" name:"Remark"`

		// 0: general message;
		// 1: globally sequential message;
		// 2: partitionally sequential message;
		// 3: retry letter queue;
		// 4: dead letter queue;
		// 5: transaction message.
		// Note: this field may return null, indicating that no valid values can be obtained.
		TopicType *uint64 `json:"TopicType,omitempty" name:"TopicType"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateTopicResponse 

func NewCreateTopicResponse() (response *CreateTopicResponse)

func (*CreateTopicResponse) FromJsonString 

func (r *CreateTopicResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTopicResponse) ToJsonString 

func (r *CreateTopicResponse) ToJsonString() string

type DeleteClusterRequest 

type DeleteClusterRequest struct {
	*tchttp.BaseRequest

	// ID of the cluster to be deleted.
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDeleteClusterRequest 

func NewDeleteClusterRequest() (request *DeleteClusterRequest)

func (*DeleteClusterRequest) FromJsonString 

func (r *DeleteClusterRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteClusterRequest) ToJsonString 

func (r *DeleteClusterRequest) ToJsonString() string

type DeleteClusterResponse 

type DeleteClusterResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Cluster ID
		ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteClusterResponse 

func NewDeleteClusterResponse() (response *DeleteClusterResponse)

func (*DeleteClusterResponse) FromJsonString 

func (r *DeleteClusterResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteClusterResponse) ToJsonString 

func (r *DeleteClusterResponse) ToJsonString() string

type DeleteCmqQueueRequest 

type DeleteCmqQueueRequest struct {
	*tchttp.BaseRequest

	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`
}

func NewDeleteCmqQueueRequest 

func NewDeleteCmqQueueRequest() (request *DeleteCmqQueueRequest)

func (*DeleteCmqQueueRequest) FromJsonString 

func (r *DeleteCmqQueueRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteCmqQueueRequest) ToJsonString 

func (r *DeleteCmqQueueRequest) ToJsonString() string

type DeleteCmqQueueResponse 

type DeleteCmqQueueResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteCmqQueueResponse 

func NewDeleteCmqQueueResponse() (response *DeleteCmqQueueResponse)

func (*DeleteCmqQueueResponse) FromJsonString 

func (r *DeleteCmqQueueResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteCmqQueueResponse) ToJsonString 

func (r *DeleteCmqQueueResponse) ToJsonString() string

type DeleteCmqSubscribeRequest 

type DeleteCmqSubscribeRequest struct {
	*tchttp.BaseRequest

	// Topic name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`
}

func NewDeleteCmqSubscribeRequest 

func NewDeleteCmqSubscribeRequest() (request *DeleteCmqSubscribeRequest)

func (*DeleteCmqSubscribeRequest) FromJsonString 

func (r *DeleteCmqSubscribeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteCmqSubscribeRequest) ToJsonString 

func (r *DeleteCmqSubscribeRequest) ToJsonString() string

type DeleteCmqSubscribeResponse 

type DeleteCmqSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteCmqSubscribeResponse 

func NewDeleteCmqSubscribeResponse() (response *DeleteCmqSubscribeResponse)

func (*DeleteCmqSubscribeResponse) FromJsonString 

func (r *DeleteCmqSubscribeResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteCmqSubscribeResponse) ToJsonString 

func (r *DeleteCmqSubscribeResponse) ToJsonString() string

type DeleteCmqTopicRequest 

type DeleteCmqTopicRequest struct {
	*tchttp.BaseRequest

	// Topic name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
}

func NewDeleteCmqTopicRequest 

func NewDeleteCmqTopicRequest() (request *DeleteCmqTopicRequest)

func (*DeleteCmqTopicRequest) FromJsonString 

func (r *DeleteCmqTopicRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteCmqTopicRequest) ToJsonString 

func (r *DeleteCmqTopicRequest) ToJsonString() string

type DeleteCmqTopicResponse 

type DeleteCmqTopicResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteCmqTopicResponse 

func NewDeleteCmqTopicResponse() (response *DeleteCmqTopicResponse)

func (*DeleteCmqTopicResponse) FromJsonString 

func (r *DeleteCmqTopicResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteCmqTopicResponse) ToJsonString 

func (r *DeleteCmqTopicResponse) ToJsonString() string

type DeleteEnvironmentRolesRequest 

type DeleteEnvironmentRolesRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Array of role names.
	RoleNames []*string `json:"RoleNames,omitempty" name:"RoleNames"`

	// Cluster ID (required)
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDeleteEnvironmentRolesRequest 

func NewDeleteEnvironmentRolesRequest() (request *DeleteEnvironmentRolesRequest)

func (*DeleteEnvironmentRolesRequest) FromJsonString 

func (r *DeleteEnvironmentRolesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteEnvironmentRolesRequest) ToJsonString 

func (r *DeleteEnvironmentRolesRequest) ToJsonString() string

type DeleteEnvironmentRolesResponse 

type DeleteEnvironmentRolesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteEnvironmentRolesResponse 

func NewDeleteEnvironmentRolesResponse() (response *DeleteEnvironmentRolesResponse)

func (*DeleteEnvironmentRolesResponse) FromJsonString 

func (r *DeleteEnvironmentRolesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteEnvironmentRolesResponse) ToJsonString 

func (r *DeleteEnvironmentRolesResponse) ToJsonString() string

type DeleteEnvironmentsRequest 

type DeleteEnvironmentsRequest struct {
	*tchttp.BaseRequest

	// Array of environments (namespaces). Up to 20 environments can be deleted at a time.
	EnvironmentIds []*string `json:"EnvironmentIds,omitempty" name:"EnvironmentIds"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDeleteEnvironmentsRequest 

func NewDeleteEnvironmentsRequest() (request *DeleteEnvironmentsRequest)

func (*DeleteEnvironmentsRequest) FromJsonString 

func (r *DeleteEnvironmentsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteEnvironmentsRequest) ToJsonString 

func (r *DeleteEnvironmentsRequest) ToJsonString() string

type DeleteEnvironmentsResponse 

type DeleteEnvironmentsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Array of environments (namespaces) successfully deleted.
		EnvironmentIds []*string `json:"EnvironmentIds,omitempty" name:"EnvironmentIds"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteEnvironmentsResponse 

func NewDeleteEnvironmentsResponse() (response *DeleteEnvironmentsResponse)

func (*DeleteEnvironmentsResponse) FromJsonString 

func (r *DeleteEnvironmentsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteEnvironmentsResponse) ToJsonString 

func (r *DeleteEnvironmentsResponse) ToJsonString() string

type DeleteRocketMQClusterRequest 

type DeleteRocketMQClusterRequest struct {
	*tchttp.BaseRequest

	// ID of the cluster to be deleted.
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDeleteRocketMQClusterRequest 

func NewDeleteRocketMQClusterRequest() (request *DeleteRocketMQClusterRequest)

func (*DeleteRocketMQClusterRequest) FromJsonString 

func (r *DeleteRocketMQClusterRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRocketMQClusterRequest) ToJsonString 

func (r *DeleteRocketMQClusterRequest) ToJsonString() string

type DeleteRocketMQClusterResponse 

type DeleteRocketMQClusterResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteRocketMQClusterResponse 

func NewDeleteRocketMQClusterResponse() (response *DeleteRocketMQClusterResponse)

func (*DeleteRocketMQClusterResponse) FromJsonString 

func (r *DeleteRocketMQClusterResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRocketMQClusterResponse) ToJsonString 

func (r *DeleteRocketMQClusterResponse) ToJsonString() string

type DeleteRocketMQGroupRequest 

type DeleteRocketMQGroupRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace name
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

	// Consumer group name
	GroupId *string `json:"GroupId,omitempty" name:"GroupId"`
}

func NewDeleteRocketMQGroupRequest 

func NewDeleteRocketMQGroupRequest() (request *DeleteRocketMQGroupRequest)

func (*DeleteRocketMQGroupRequest) FromJsonString 

func (r *DeleteRocketMQGroupRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRocketMQGroupRequest) ToJsonString 

func (r *DeleteRocketMQGroupRequest) ToJsonString() string

type DeleteRocketMQGroupResponse 

type DeleteRocketMQGroupResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteRocketMQGroupResponse 

func NewDeleteRocketMQGroupResponse() (response *DeleteRocketMQGroupResponse)

func (*DeleteRocketMQGroupResponse) FromJsonString 

func (r *DeleteRocketMQGroupResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRocketMQGroupResponse) ToJsonString 

func (r *DeleteRocketMQGroupResponse) ToJsonString() string

type DeleteRocketMQNamespaceRequest 

type DeleteRocketMQNamespaceRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace name
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`
}

func NewDeleteRocketMQNamespaceRequest 

func NewDeleteRocketMQNamespaceRequest() (request *DeleteRocketMQNamespaceRequest)

func (*DeleteRocketMQNamespaceRequest) FromJsonString 

func (r *DeleteRocketMQNamespaceRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRocketMQNamespaceRequest) ToJsonString 

func (r *DeleteRocketMQNamespaceRequest) ToJsonString() string

type DeleteRocketMQNamespaceResponse 

type DeleteRocketMQNamespaceResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteRocketMQNamespaceResponse 

func NewDeleteRocketMQNamespaceResponse() (response *DeleteRocketMQNamespaceResponse)

func (*DeleteRocketMQNamespaceResponse) FromJsonString 

func (r *DeleteRocketMQNamespaceResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRocketMQNamespaceResponse) ToJsonString 

func (r *DeleteRocketMQNamespaceResponse) ToJsonString() string

type DeleteRocketMQTopicRequest 

type DeleteRocketMQTopicRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace name
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

	// Topic name
	Topic *string `json:"Topic,omitempty" name:"Topic"`
}

func NewDeleteRocketMQTopicRequest 

func NewDeleteRocketMQTopicRequest() (request *DeleteRocketMQTopicRequest)

func (*DeleteRocketMQTopicRequest) FromJsonString 

func (r *DeleteRocketMQTopicRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRocketMQTopicRequest) ToJsonString 

func (r *DeleteRocketMQTopicRequest) ToJsonString() string

type DeleteRocketMQTopicResponse 

type DeleteRocketMQTopicResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteRocketMQTopicResponse 

func NewDeleteRocketMQTopicResponse() (response *DeleteRocketMQTopicResponse)

func (*DeleteRocketMQTopicResponse) FromJsonString 

func (r *DeleteRocketMQTopicResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRocketMQTopicResponse) ToJsonString 

func (r *DeleteRocketMQTopicResponse) ToJsonString() string

type DeleteRolesRequest 

type DeleteRolesRequest struct {
	*tchttp.BaseRequest

	// Array of role names.
	RoleNames []*string `json:"RoleNames,omitempty" name:"RoleNames"`

	// Cluster ID (required)
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDeleteRolesRequest 

func NewDeleteRolesRequest() (request *DeleteRolesRequest)

func (*DeleteRolesRequest) FromJsonString 

func (r *DeleteRolesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRolesRequest) ToJsonString 

func (r *DeleteRolesRequest) ToJsonString() string

type DeleteRolesResponse 

type DeleteRolesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Name array of roles successfully deleted.
		RoleNames []*string `json:"RoleNames,omitempty" name:"RoleNames"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteRolesResponse 

func NewDeleteRolesResponse() (response *DeleteRolesResponse)

func (*DeleteRolesResponse) FromJsonString 

func (r *DeleteRolesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRolesResponse) ToJsonString 

func (r *DeleteRolesResponse) ToJsonString() string

type DeleteSubscriptionsRequest 

type DeleteSubscriptionsRequest struct {
	*tchttp.BaseRequest

	// Set of subscriptions. Up to 20 subscriptions can be deleted at a time.
	SubscriptionTopicSets []*SubscriptionTopic `json:"SubscriptionTopicSets,omitempty" name:"SubscriptionTopicSets"`

	// Pulsar cluster ID.
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Whether to force deletion. Default value: false
	Force *bool `json:"Force,omitempty" name:"Force"`
}

func NewDeleteSubscriptionsRequest 

func NewDeleteSubscriptionsRequest() (request *DeleteSubscriptionsRequest)

func (*DeleteSubscriptionsRequest) FromJsonString 

func (r *DeleteSubscriptionsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteSubscriptionsRequest) ToJsonString 

func (r *DeleteSubscriptionsRequest) ToJsonString() string

type DeleteSubscriptionsResponse 

type DeleteSubscriptionsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Array of successfully deleted subscriptions.
		SubscriptionTopicSets []*SubscriptionTopic `json:"SubscriptionTopicSets,omitempty" name:"SubscriptionTopicSets"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteSubscriptionsResponse 

func NewDeleteSubscriptionsResponse() (response *DeleteSubscriptionsResponse)

func (*DeleteSubscriptionsResponse) FromJsonString 

func (r *DeleteSubscriptionsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteSubscriptionsResponse) ToJsonString 

func (r *DeleteSubscriptionsResponse) ToJsonString() string

type DeleteTopicsRequest 

type DeleteTopicsRequest struct {
	*tchttp.BaseRequest

	// Set of topics. Up to 20 topics can be deleted at a time.
	TopicSets []*TopicRecord `json:"TopicSets,omitempty" name:"TopicSets"`

	// Pulsar cluster ID.
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Whether to force deletion. Default value: false
	Force *bool `json:"Force,omitempty" name:"Force"`
}

func NewDeleteTopicsRequest 

func NewDeleteTopicsRequest() (request *DeleteTopicsRequest)

func (*DeleteTopicsRequest) FromJsonString 

func (r *DeleteTopicsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTopicsRequest) ToJsonString 

func (r *DeleteTopicsRequest) ToJsonString() string

type DeleteTopicsResponse 

type DeleteTopicsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Array of deleted topics.
		TopicSets []*TopicRecord `json:"TopicSets,omitempty" name:"TopicSets"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteTopicsResponse 

func NewDeleteTopicsResponse() (response *DeleteTopicsResponse)

func (*DeleteTopicsResponse) FromJsonString 

func (r *DeleteTopicsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTopicsResponse) ToJsonString 

func (r *DeleteTopicsResponse) ToJsonString() string

type DescribeBindClustersRequest 

type DescribeBindClustersRequest struct {
	*tchttp.BaseRequest
}

func NewDescribeBindClustersRequest 

func NewDescribeBindClustersRequest() (request *DescribeBindClustersRequest)

func (*DescribeBindClustersRequest) FromJsonString 

func (r *DescribeBindClustersRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeBindClustersRequest) ToJsonString 

func (r *DescribeBindClustersRequest) ToJsonString() string

type DescribeBindClustersResponse 

type DescribeBindClustersResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of dedicated clusters
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// List of dedicated clusters
		ClusterSet []*BindCluster `json:"ClusterSet,omitempty" name:"ClusterSet"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeBindClustersResponse 

func NewDescribeBindClustersResponse() (response *DescribeBindClustersResponse)

func (*DescribeBindClustersResponse) FromJsonString 

func (r *DescribeBindClustersResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeBindClustersResponse) ToJsonString 

func (r *DescribeBindClustersResponse) ToJsonString() string

type DescribeBindVpcsRequest 

type DescribeBindVpcsRequest struct {
	*tchttp.BaseRequest

	// Offset. If this parameter is left empty, 0 will be used by default.
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Number of results to be returned. If this parameter is left empty, 10 will be used by default. The maximum value is 20.
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDescribeBindVpcsRequest 

func NewDescribeBindVpcsRequest() (request *DescribeBindVpcsRequest)

func (*DescribeBindVpcsRequest) FromJsonString 

func (r *DescribeBindVpcsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeBindVpcsRequest) ToJsonString 

func (r *DescribeBindVpcsRequest) ToJsonString() string

type DescribeBindVpcsResponse 

type DescribeBindVpcsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of records.
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// Set of VPCs.
		VpcSets []*VpcBindRecord `json:"VpcSets,omitempty" name:"VpcSets"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeBindVpcsResponse 

func NewDescribeBindVpcsResponse() (response *DescribeBindVpcsResponse)

func (*DescribeBindVpcsResponse) FromJsonString 

func (r *DescribeBindVpcsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeBindVpcsResponse) ToJsonString 

func (r *DescribeBindVpcsResponse) ToJsonString() string

type DescribeClusterDetailRequest 

type DescribeClusterDetailRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDescribeClusterDetailRequest 

func NewDescribeClusterDetailRequest() (request *DescribeClusterDetailRequest)

func (*DescribeClusterDetailRequest) FromJsonString 

func (r *DescribeClusterDetailRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeClusterDetailRequest) ToJsonString 

func (r *DescribeClusterDetailRequest) ToJsonString() string

type DescribeClusterDetailResponse 

type DescribeClusterDetailResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Cluster details
		ClusterSet *Cluster `json:"ClusterSet,omitempty" name:"ClusterSet"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeClusterDetailResponse 

func NewDescribeClusterDetailResponse() (response *DescribeClusterDetailResponse)

func (*DescribeClusterDetailResponse) FromJsonString 

func (r *DescribeClusterDetailResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeClusterDetailResponse) ToJsonString 

func (r *DescribeClusterDetailResponse) ToJsonString() string

type DescribeClustersRequest 

type DescribeClustersRequest struct {
	*tchttp.BaseRequest

	// Offset. If this parameter is left empty, 0 will be used by default.
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Number of results to be returned. If this parameter is left empty, 10 will be used by default. The maximum value is 20.
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Filter by list of cluster IDs
	ClusterIdList []*string `json:"ClusterIdList,omitempty" name:"ClusterIdList"`

	// Whether to filter by tag
	IsTagFilter *bool `json:"IsTagFilter,omitempty" name:"IsTagFilter"`

	// Filter. Currently, you can filter only by tag.
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`
}

func NewDescribeClustersRequest 

func NewDescribeClustersRequest() (request *DescribeClustersRequest)

func (*DescribeClustersRequest) FromJsonString 

func (r *DescribeClustersRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeClustersRequest) ToJsonString 

func (r *DescribeClustersRequest) ToJsonString() string

type DescribeClustersResponse 

type DescribeClustersResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of clusters
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// List of cluster information
		ClusterSet []*Cluster `json:"ClusterSet,omitempty" name:"ClusterSet"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeClustersResponse 

func NewDescribeClustersResponse() (response *DescribeClustersResponse)

func (*DescribeClustersResponse) FromJsonString 

func (r *DescribeClustersResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeClustersResponse) ToJsonString 

func (r *DescribeClustersResponse) ToJsonString() string

type DescribeCmqDeadLetterSourceQueuesRequest 

type DescribeCmqDeadLetterSourceQueuesRequest struct {
	*tchttp.BaseRequest

	// Dead letter queue name
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitempty" name:"DeadLetterQueueName"`

	// Starting position of the list of topics to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default.
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Number of topics to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Filter by `SourceQueueName`
	SourceQueueName *string `json:"SourceQueueName,omitempty" name:"SourceQueueName"`
}

func NewDescribeCmqDeadLetterSourceQueuesRequest 

func NewDescribeCmqDeadLetterSourceQueuesRequest() (request *DescribeCmqDeadLetterSourceQueuesRequest)

func (*DescribeCmqDeadLetterSourceQueuesRequest) FromJsonString 

func (r *DescribeCmqDeadLetterSourceQueuesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqDeadLetterSourceQueuesRequest) ToJsonString 

func (r *DescribeCmqDeadLetterSourceQueuesRequest) ToJsonString() string

type DescribeCmqDeadLetterSourceQueuesResponse 

type DescribeCmqDeadLetterSourceQueuesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of eligible queues
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// Source queues of dead letter queue
		QueueSet []*CmqDeadLetterSource `json:"QueueSet,omitempty" name:"QueueSet"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeCmqDeadLetterSourceQueuesResponse 

func NewDescribeCmqDeadLetterSourceQueuesResponse() (response *DescribeCmqDeadLetterSourceQueuesResponse)

func (*DescribeCmqDeadLetterSourceQueuesResponse) FromJsonString 

func (r *DescribeCmqDeadLetterSourceQueuesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqDeadLetterSourceQueuesResponse) ToJsonString 

func (r *DescribeCmqDeadLetterSourceQueuesResponse) ToJsonString() string

type DescribeCmqQueueDetailRequest 

type DescribeCmqQueueDetailRequest struct {
	*tchttp.BaseRequest

	// Exact match by `QueueName`
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`
}

func NewDescribeCmqQueueDetailRequest 

func NewDescribeCmqQueueDetailRequest() (request *DescribeCmqQueueDetailRequest)

func (*DescribeCmqQueueDetailRequest) FromJsonString 

func (r *DescribeCmqQueueDetailRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqQueueDetailRequest) ToJsonString 

func (r *DescribeCmqQueueDetailRequest) ToJsonString() string

type DescribeCmqQueueDetailResponse 

type DescribeCmqQueueDetailResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// List of queue details.
		QueueDescribe *CmqQueue `json:"QueueDescribe,omitempty" name:"QueueDescribe"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeCmqQueueDetailResponse 

func NewDescribeCmqQueueDetailResponse() (response *DescribeCmqQueueDetailResponse)

func (*DescribeCmqQueueDetailResponse) FromJsonString 

func (r *DescribeCmqQueueDetailResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqQueueDetailResponse) ToJsonString 

func (r *DescribeCmqQueueDetailResponse) ToJsonString() string

type DescribeCmqQueuesRequest 

type DescribeCmqQueuesRequest struct {
	*tchttp.BaseRequest

	// Starting position of the list of queues to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Number of queues to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Filter by `QueueName`
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`

	// List of CMQ queue names
	QueueNameList []*string `json:"QueueNameList,omitempty" name:"QueueNameList"`

	// For filtering by tag, this must be configured to `true`.
	IsTagFilter *bool `json:"IsTagFilter,omitempty" name:"IsTagFilter"`

	// Filter. Currently, you can filter only by tag.
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`
}

func NewDescribeCmqQueuesRequest 

func NewDescribeCmqQueuesRequest() (request *DescribeCmqQueuesRequest)

func (*DescribeCmqQueuesRequest) FromJsonString 

func (r *DescribeCmqQueuesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqQueuesRequest) ToJsonString 

func (r *DescribeCmqQueuesRequest) ToJsonString() string

type DescribeCmqQueuesResponse 

type DescribeCmqQueuesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Quantity
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// List of queues
		// Note: this field may return null, indicating that no valid values can be obtained.
		QueueList []*CmqQueue `json:"QueueList,omitempty" name:"QueueList"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeCmqQueuesResponse 

func NewDescribeCmqQueuesResponse() (response *DescribeCmqQueuesResponse)

func (*DescribeCmqQueuesResponse) FromJsonString 

func (r *DescribeCmqQueuesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqQueuesResponse) ToJsonString 

func (r *DescribeCmqQueuesResponse) ToJsonString() string

type DescribeCmqSubscriptionDetailRequest 

type DescribeCmqSubscriptionDetailRequest struct {
	*tchttp.BaseRequest

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Starting position of the list of topics to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Number of topics to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Fuzzy search by `SubscriptionName`
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`
}

func NewDescribeCmqSubscriptionDetailRequest 

func NewDescribeCmqSubscriptionDetailRequest() (request *DescribeCmqSubscriptionDetailRequest)

func (*DescribeCmqSubscriptionDetailRequest) FromJsonString 

func (r *DescribeCmqSubscriptionDetailRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqSubscriptionDetailRequest) ToJsonString 

func (r *DescribeCmqSubscriptionDetailRequest) ToJsonString() string

type DescribeCmqSubscriptionDetailResponse 

type DescribeCmqSubscriptionDetailResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Total number
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// Set of subscription attributes
		// Note: this field may return null, indicating that no valid values can be obtained.
		SubscriptionSet []*CmqSubscription `json:"SubscriptionSet,omitempty" name:"SubscriptionSet"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeCmqSubscriptionDetailResponse 

func NewDescribeCmqSubscriptionDetailResponse() (response *DescribeCmqSubscriptionDetailResponse)

func (*DescribeCmqSubscriptionDetailResponse) FromJsonString 

func (r *DescribeCmqSubscriptionDetailResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqSubscriptionDetailResponse) ToJsonString 

func (r *DescribeCmqSubscriptionDetailResponse) ToJsonString() string

type DescribeCmqTopicDetailRequest 

type DescribeCmqTopicDetailRequest struct {
	*tchttp.BaseRequest

	// Exact match by `TopicName`.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
}

func NewDescribeCmqTopicDetailRequest 

func NewDescribeCmqTopicDetailRequest() (request *DescribeCmqTopicDetailRequest)

func (*DescribeCmqTopicDetailRequest) FromJsonString 

func (r *DescribeCmqTopicDetailRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqTopicDetailRequest) ToJsonString 

func (r *DescribeCmqTopicDetailRequest) ToJsonString() string

type DescribeCmqTopicDetailResponse 

type DescribeCmqTopicDetailResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Topic details
		TopicDescribe *CmqTopic `json:"TopicDescribe,omitempty" name:"TopicDescribe"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeCmqTopicDetailResponse 

func NewDescribeCmqTopicDetailResponse() (response *DescribeCmqTopicDetailResponse)

func (*DescribeCmqTopicDetailResponse) FromJsonString 

func (r *DescribeCmqTopicDetailResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqTopicDetailResponse) ToJsonString 

func (r *DescribeCmqTopicDetailResponse) ToJsonString() string

type DescribeCmqTopicsRequest 

type DescribeCmqTopicsRequest struct {
	*tchttp.BaseRequest

	// Starting position of the list of queues to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Number of queues to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Fuzzy search by `TopicName`
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Filter by list of CMQ topic names
	TopicNameList []*string `json:"TopicNameList,omitempty" name:"TopicNameList"`

	// For filtering by tag, this must be configured to `true`.
	IsTagFilter *bool `json:"IsTagFilter,omitempty" name:"IsTagFilter"`

	// Filter. Currently, you can filter only by tag.
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`
}

func NewDescribeCmqTopicsRequest 

func NewDescribeCmqTopicsRequest() (request *DescribeCmqTopicsRequest)

func (*DescribeCmqTopicsRequest) FromJsonString 

func (r *DescribeCmqTopicsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqTopicsRequest) ToJsonString 

func (r *DescribeCmqTopicsRequest) ToJsonString() string

type DescribeCmqTopicsResponse 

type DescribeCmqTopicsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// List of topics
		// Note: this field may return null, indicating that no valid values can be obtained.
		TopicList []*CmqTopic `json:"TopicList,omitempty" name:"TopicList"`

		// Total number of topics
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeCmqTopicsResponse 

func NewDescribeCmqTopicsResponse() (response *DescribeCmqTopicsResponse)

func (*DescribeCmqTopicsResponse) FromJsonString 

func (r *DescribeCmqTopicsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeCmqTopicsResponse) ToJsonString 

func (r *DescribeCmqTopicsResponse) ToJsonString() string

type DescribeEnvironmentAttributesRequest 

type DescribeEnvironmentAttributesRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDescribeEnvironmentAttributesRequest 

func NewDescribeEnvironmentAttributesRequest() (request *DescribeEnvironmentAttributesRequest)

func (*DescribeEnvironmentAttributesRequest) FromJsonString 

func (r *DescribeEnvironmentAttributesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeEnvironmentAttributesRequest) ToJsonString 

func (r *DescribeEnvironmentAttributesRequest) ToJsonString() string

type DescribeEnvironmentAttributesResponse 

type DescribeEnvironmentAttributesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// TTL for unconsumed messages in seconds. Maximum value: 1296000 seconds (i.e., 15 days).
		MsgTTL *uint64 `json:"MsgTTL,omitempty" name:"MsgTTL"`

		// Consumption rate limit in bytes/second. 0: unlimited.
		RateInByte *uint64 `json:"RateInByte,omitempty" name:"RateInByte"`

		// Consumption rate limit in messages/second. 0: unlimited.
		RateInSize *uint64 `json:"RateInSize,omitempty" name:"RateInSize"`

		// Retention policy for consumed messages in hours. 0: deleted immediately after consumption.
		RetentionHours *uint64 `json:"RetentionHours,omitempty" name:"RetentionHours"`

		// Retention policy for consumed messages in GB. 0: deleted immediately after consumption.
		RetentionSize *uint64 `json:"RetentionSize,omitempty" name:"RetentionSize"`

		// Environment (namespace) name.
		EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

		// Number of replicas.
		Replicas *uint64 `json:"Replicas,omitempty" name:"Replicas"`

		// Remarks.
		Remark *string `json:"Remark,omitempty" name:"Remark"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeEnvironmentAttributesResponse 

func NewDescribeEnvironmentAttributesResponse() (response *DescribeEnvironmentAttributesResponse)

func (*DescribeEnvironmentAttributesResponse) FromJsonString 

func (r *DescribeEnvironmentAttributesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeEnvironmentAttributesResponse) ToJsonString 

func (r *DescribeEnvironmentAttributesResponse) ToJsonString() string

type DescribeEnvironmentRolesRequest 

type DescribeEnvironmentRolesRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name (required).
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Offset. If this parameter is left empty, 0 will be used by default.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// Number of results to be returned. If this parameter is left empty, 10 will be used by default. The maximum value is 20.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Pulsar cluster ID (required)
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Role name
	RoleName *string `json:"RoleName,omitempty" name:"RoleName"`

	// * RoleName
	// Filter by role name for exact query.
	// Type: String
	// Required: no
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`
}

func NewDescribeEnvironmentRolesRequest 

func NewDescribeEnvironmentRolesRequest() (request *DescribeEnvironmentRolesRequest)

func (*DescribeEnvironmentRolesRequest) FromJsonString 

func (r *DescribeEnvironmentRolesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeEnvironmentRolesRequest) ToJsonString 

func (r *DescribeEnvironmentRolesRequest) ToJsonString() string

type DescribeEnvironmentRolesResponse 

type DescribeEnvironmentRolesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of records.
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// Set of namespace roles.
		EnvironmentRoleSets []*EnvironmentRole `json:"EnvironmentRoleSets,omitempty" name:"EnvironmentRoleSets"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeEnvironmentRolesResponse 

func NewDescribeEnvironmentRolesResponse() (response *DescribeEnvironmentRolesResponse)

func (*DescribeEnvironmentRolesResponse) FromJsonString 

func (r *DescribeEnvironmentRolesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeEnvironmentRolesResponse) ToJsonString 

func (r *DescribeEnvironmentRolesResponse) ToJsonString() string

type DescribeEnvironmentsRequest 

type DescribeEnvironmentsRequest struct {
	*tchttp.BaseRequest

	// Fuzzy search by namespace name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Offset. If this parameter is left empty, 0 will be used by default.
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Number of results to be returned. If this parameter is left empty, 10 will be used by default. The maximum value is 20.
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// * EnvironmentId
	// Filter by namespace for exact query.
	// Type: String
	// Required: no
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`
}

func NewDescribeEnvironmentsRequest 

func NewDescribeEnvironmentsRequest() (request *DescribeEnvironmentsRequest)

func (*DescribeEnvironmentsRequest) FromJsonString 

func (r *DescribeEnvironmentsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeEnvironmentsRequest) ToJsonString 

func (r *DescribeEnvironmentsRequest) ToJsonString() string

type DescribeEnvironmentsResponse 

type DescribeEnvironmentsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of namespaces.
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// Array set of namespaces.
		EnvironmentSet []*Environment `json:"EnvironmentSet,omitempty" name:"EnvironmentSet"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeEnvironmentsResponse 

func NewDescribeEnvironmentsResponse() (response *DescribeEnvironmentsResponse)

func (*DescribeEnvironmentsResponse) FromJsonString 

func (r *DescribeEnvironmentsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeEnvironmentsResponse) ToJsonString 

func (r *DescribeEnvironmentsResponse) ToJsonString() string

type DescribePublisherSummaryRequest 

type DescribePublisherSummaryRequest struct {
	*tchttp.BaseRequest

	// Cluster ID.
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace name.
	Namespace *string `json:"Namespace,omitempty" name:"Namespace"`

	// Topic name.
	Topic *string `json:"Topic,omitempty" name:"Topic"`
}

func NewDescribePublisherSummaryRequest 

func NewDescribePublisherSummaryRequest() (request *DescribePublisherSummaryRequest)

func (*DescribePublisherSummaryRequest) FromJsonString 

func (r *DescribePublisherSummaryRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribePublisherSummaryRequest) ToJsonString 

func (r *DescribePublisherSummaryRequest) ToJsonString() string

type DescribePublisherSummaryResponse 

type DescribePublisherSummaryResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Production rate (messages/sec).
		// Note: this field may return `null`, indicating that no valid values can be obtained.
		MsgRateIn *float64 `json:"MsgRateIn,omitempty" name:"MsgRateIn"`

		// Production rate (byte/sec).
		// Note: this field may return `null`, indicating that no valid values can be obtained.
		MsgThroughputIn *float64 `json:"MsgThroughputIn,omitempty" name:"MsgThroughputIn"`

		// The number of producers.
		// Note: this field may return `null`, indicating that no valid values can be obtained.
		PublisherCount *int64 `json:"PublisherCount,omitempty" name:"PublisherCount"`

		// Message storage size in bytes.
		// Note: this field may return `null`, indicating that no valid values can be obtained.
		StorageSize *int64 `json:"StorageSize,omitempty" name:"StorageSize"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribePublisherSummaryResponse 

func NewDescribePublisherSummaryResponse() (response *DescribePublisherSummaryResponse)

func (*DescribePublisherSummaryResponse) FromJsonString 

func (r *DescribePublisherSummaryResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribePublisherSummaryResponse) ToJsonString 

func (r *DescribePublisherSummaryResponse) ToJsonString() string

type DescribePublishersRequest 

type DescribePublishersRequest struct {
	*tchttp.BaseRequest

	// Cluster ID.
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace name.
	Namespace *string `json:"Namespace,omitempty" name:"Namespace"`

	// Topic name.
	Topic *string `json:"Topic,omitempty" name:"Topic"`

	// Parameter filter. The `ProducerName` and `Address` fields are supported.
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// Offset for query. Default value: `0`.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// The number of query results displayed per page. Default value: `20`.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Sort by field.
	Sort *Sort `json:"Sort,omitempty" name:"Sort"`
}

func NewDescribePublishersRequest 

func NewDescribePublishersRequest() (request *DescribePublishersRequest)

func (*DescribePublishersRequest) FromJsonString 

func (r *DescribePublishersRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribePublishersRequest) ToJsonString 

func (r *DescribePublishersRequest) ToJsonString() string

type DescribePublishersResponse 

type DescribePublishersResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Total number of query results.
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// List of producer information.
		// Note: this field may return `null`, indicating that no valid values can be obtained.
		Publishers []*Publisher `json:"Publishers,omitempty" name:"Publishers"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribePublishersResponse 

func NewDescribePublishersResponse() (response *DescribePublishersResponse)

func (*DescribePublishersResponse) FromJsonString 

func (r *DescribePublishersResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribePublishersResponse) ToJsonString 

func (r *DescribePublishersResponse) ToJsonString() string

type DescribeRocketMQClusterRequest 

type DescribeRocketMQClusterRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDescribeRocketMQClusterRequest 

func NewDescribeRocketMQClusterRequest() (request *DescribeRocketMQClusterRequest)

func (*DescribeRocketMQClusterRequest) FromJsonString 

func (r *DescribeRocketMQClusterRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRocketMQClusterRequest) ToJsonString 

func (r *DescribeRocketMQClusterRequest) ToJsonString() string

type DescribeRocketMQClusterResponse 

type DescribeRocketMQClusterResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Cluster information
		ClusterInfo *RocketMQClusterInfo `json:"ClusterInfo,omitempty" name:"ClusterInfo"`

		// Cluster configuration
		ClusterConfig *RocketMQClusterConfig `json:"ClusterConfig,omitempty" name:"ClusterConfig"`

		// Recent cluster usage
		// Note: this field may return null, indicating that no valid values can be obtained.
		ClusterStats *RocketMQClusterRecentStats `json:"ClusterStats,omitempty" name:"ClusterStats"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeRocketMQClusterResponse 

func NewDescribeRocketMQClusterResponse() (response *DescribeRocketMQClusterResponse)

func (*DescribeRocketMQClusterResponse) FromJsonString 

func (r *DescribeRocketMQClusterResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRocketMQClusterResponse) ToJsonString 

func (r *DescribeRocketMQClusterResponse) ToJsonString() string

type DescribeRocketMQClustersRequest 

type DescribeRocketMQClustersRequest struct {
	*tchttp.BaseRequest

	// Offset
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Maximum number
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Search by cluster ID
	IdKeyword *string `json:"IdKeyword,omitempty" name:"IdKeyword"`

	// Search by cluster name
	NameKeyword *string `json:"NameKeyword,omitempty" name:"NameKeyword"`

	// Filter by list of cluster IDs
	ClusterIdList []*string `json:"ClusterIdList,omitempty" name:"ClusterIdList"`

	// For filtering by tag, this must be configured to `true`
	IsTagFilter *bool `json:"IsTagFilter,omitempty" name:"IsTagFilter"`

	// Filter. Currently, you can filter only by tag.
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`
}

func NewDescribeRocketMQClustersRequest 

func NewDescribeRocketMQClustersRequest() (request *DescribeRocketMQClustersRequest)

func (*DescribeRocketMQClustersRequest) FromJsonString 

func (r *DescribeRocketMQClustersRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRocketMQClustersRequest) ToJsonString 

func (r *DescribeRocketMQClustersRequest) ToJsonString() string

type DescribeRocketMQClustersResponse 

type DescribeRocketMQClustersResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Cluster information
		// Note: this field may return null, indicating that no valid values can be obtained.
		ClusterList []*RocketMQClusterDetail `json:"ClusterList,omitempty" name:"ClusterList"`

		// Total number
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeRocketMQClustersResponse 

func NewDescribeRocketMQClustersResponse() (response *DescribeRocketMQClustersResponse)

func (*DescribeRocketMQClustersResponse) FromJsonString 

func (r *DescribeRocketMQClustersResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRocketMQClustersResponse) ToJsonString 

func (r *DescribeRocketMQClustersResponse) ToJsonString() string

type DescribeRocketMQGroupsRequest 

type DescribeRocketMQGroupsRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

	// Offset
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Maximum number
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Topic name, which can be used to query all subscription groups under the topic
	FilterTopic *string `json:"FilterTopic,omitempty" name:"FilterTopic"`

	// Consumer group query by consumer group name. Fuzzy query is supported
	FilterGroup *string `json:"FilterGroup,omitempty" name:"FilterGroup"`

	// Sort by specified field. Valid values: tps, accumulative.
	SortedBy *string `json:"SortedBy,omitempty" name:"SortedBy"`

	// Sort in ascending or descending order. Valid values: asc, desc.
	SortOrder *string `json:"SortOrder,omitempty" name:"SortOrder"`

	// Subscription group name. After it is specified, only the information of the corresponding subscription group will be returned.
	FilterOneGroup *string `json:"FilterOneGroup,omitempty" name:"FilterOneGroup"`
}

func NewDescribeRocketMQGroupsRequest 

func NewDescribeRocketMQGroupsRequest() (request *DescribeRocketMQGroupsRequest)

func (*DescribeRocketMQGroupsRequest) FromJsonString 

func (r *DescribeRocketMQGroupsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRocketMQGroupsRequest) ToJsonString 

func (r *DescribeRocketMQGroupsRequest) ToJsonString() string

type DescribeRocketMQGroupsResponse 

type DescribeRocketMQGroupsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Total number
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// List of subscription groups
		Groups []*RocketMQGroup `json:"Groups,omitempty" name:"Groups"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeRocketMQGroupsResponse 

func NewDescribeRocketMQGroupsResponse() (response *DescribeRocketMQGroupsResponse)

func (*DescribeRocketMQGroupsResponse) FromJsonString 

func (r *DescribeRocketMQGroupsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRocketMQGroupsResponse) ToJsonString 

func (r *DescribeRocketMQGroupsResponse) ToJsonString() string

type DescribeRocketMQNamespacesRequest 

type DescribeRocketMQNamespacesRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Offset
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Maximum number
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Search by name
	NameKeyword *string `json:"NameKeyword,omitempty" name:"NameKeyword"`
}

func NewDescribeRocketMQNamespacesRequest 

func NewDescribeRocketMQNamespacesRequest() (request *DescribeRocketMQNamespacesRequest)

func (*DescribeRocketMQNamespacesRequest) FromJsonString 

func (r *DescribeRocketMQNamespacesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRocketMQNamespacesRequest) ToJsonString 

func (r *DescribeRocketMQNamespacesRequest) ToJsonString() string

type DescribeRocketMQNamespacesResponse 

type DescribeRocketMQNamespacesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// List of namespaces
		Namespaces []*RocketMQNamespace `json:"Namespaces,omitempty" name:"Namespaces"`

		// Total number
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeRocketMQNamespacesResponse 

func NewDescribeRocketMQNamespacesResponse() (response *DescribeRocketMQNamespacesResponse)

func (*DescribeRocketMQNamespacesResponse) FromJsonString 

func (r *DescribeRocketMQNamespacesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRocketMQNamespacesResponse) ToJsonString 

func (r *DescribeRocketMQNamespacesResponse) ToJsonString() string

type DescribeRocketMQTopicsRequest 

type DescribeRocketMQTopicsRequest struct {
	*tchttp.BaseRequest

	// Query offset
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Query limit
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

	// Filter by topic type. Valid values: Normal, GlobalOrder, PartitionedOrder, Transaction.
	FilterType []*string `json:"FilterType,omitempty" name:"FilterType"`

	// Search by topic name. Fuzzy query is supported.
	FilterName *string `json:"FilterName,omitempty" name:"FilterName"`
}

func NewDescribeRocketMQTopicsRequest 

func NewDescribeRocketMQTopicsRequest() (request *DescribeRocketMQTopicsRequest)

func (*DescribeRocketMQTopicsRequest) FromJsonString 

func (r *DescribeRocketMQTopicsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRocketMQTopicsRequest) ToJsonString 

func (r *DescribeRocketMQTopicsRequest) ToJsonString() string

type DescribeRocketMQTopicsResponse 

type DescribeRocketMQTopicsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Total number of records
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// List of topic information
		Topics []*RocketMQTopic `json:"Topics,omitempty" name:"Topics"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeRocketMQTopicsResponse 

func NewDescribeRocketMQTopicsResponse() (response *DescribeRocketMQTopicsResponse)

func (*DescribeRocketMQTopicsResponse) FromJsonString 

func (r *DescribeRocketMQTopicsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRocketMQTopicsResponse) ToJsonString 

func (r *DescribeRocketMQTopicsResponse) ToJsonString() string

type DescribeRolesRequest 

type DescribeRolesRequest struct {
	*tchttp.BaseRequest

	// Fuzzy query by role name
	RoleName *string `json:"RoleName,omitempty" name:"RoleName"`

	// Offset. If this parameter is left empty, 0 will be used by default.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// Number of results to be returned. If this parameter is left empty, 10 will be used by default. The maximum value is 20.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Cluster ID (required)
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// * RoleName
	// Filter by role name for exact query.
	// Type: String
	// Required: no
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`
}

func NewDescribeRolesRequest 

func NewDescribeRolesRequest() (request *DescribeRolesRequest)

func (*DescribeRolesRequest) FromJsonString 

func (r *DescribeRolesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRolesRequest) ToJsonString 

func (r *DescribeRolesRequest) ToJsonString() string

type DescribeRolesResponse 

type DescribeRolesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of records.
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// Array of roles.
		RoleSets []*Role `json:"RoleSets,omitempty" name:"RoleSets"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeRolesResponse 

func NewDescribeRolesResponse() (response *DescribeRolesResponse)

func (*DescribeRolesResponse) FromJsonString 

func (r *DescribeRolesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeRolesResponse) ToJsonString 

func (r *DescribeRolesResponse) ToJsonString() string

type DescribeSubscriptionsRequest 

type DescribeSubscriptionsRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Topic name.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Offset. If this parameter is left empty, 0 will be used by default.
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Number of results to be returned. If this parameter is left empty, 10 will be used by default. The maximum value is 20.
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Fuzzy match by subscriber name.
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`

	// Data filter.
	Filters []*FilterSubscription `json:"Filters,omitempty" name:"Filters"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDescribeSubscriptionsRequest 

func NewDescribeSubscriptionsRequest() (request *DescribeSubscriptionsRequest)

func (*DescribeSubscriptionsRequest) FromJsonString 

func (r *DescribeSubscriptionsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeSubscriptionsRequest) ToJsonString 

func (r *DescribeSubscriptionsRequest) ToJsonString() string

type DescribeSubscriptionsResponse 

type DescribeSubscriptionsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Array set of subscribers.
		SubscriptionSets []*Subscription `json:"SubscriptionSets,omitempty" name:"SubscriptionSets"`

		// Quantity.
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeSubscriptionsResponse 

func NewDescribeSubscriptionsResponse() (response *DescribeSubscriptionsResponse)

func (*DescribeSubscriptionsResponse) FromJsonString 

func (r *DescribeSubscriptionsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeSubscriptionsResponse) ToJsonString 

func (r *DescribeSubscriptionsResponse) ToJsonString() string

type DescribeTopicsRequest 

type DescribeTopicsRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Fuzzy match by topic name.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Offset. If this parameter is left empty, 0 will be used by default.
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Number of results to be returned. If this parameter is left empty, 10 will be used by default. The maximum value is 20.
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Topic type description:
	// 0: general message;
	// 1: globally sequential message;
	// 2: partitionally sequential message;
	// 3: retry letter queue;
	// 4: dead letter queue;
	// 5: transaction message.
	TopicType *uint64 `json:"TopicType,omitempty" name:"TopicType"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// * TopicName
	// Query by topic name for exact search.
	// Type: String
	// Required: no
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`
}

func NewDescribeTopicsRequest 

func NewDescribeTopicsRequest() (request *DescribeTopicsRequest)

func (*DescribeTopicsRequest) FromJsonString 

func (r *DescribeTopicsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeTopicsRequest) ToJsonString 

func (r *DescribeTopicsRequest) ToJsonString() string

type DescribeTopicsResponse 

type DescribeTopicsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Array set of topics.
		TopicSets []*Topic `json:"TopicSets,omitempty" name:"TopicSets"`

		// Number of topics.
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeTopicsResponse 

func NewDescribeTopicsResponse() (response *DescribeTopicsResponse)

func (*DescribeTopicsResponse) FromJsonString 

func (r *DescribeTopicsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeTopicsResponse) ToJsonString 

func (r *DescribeTopicsResponse) ToJsonString() string

type Environment 

type Environment struct {

	// Namespace name
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Remarks
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// TTL for unconsumed messages in seconds. Maximum value: 1296000 seconds (i.e., 15 days)
	MsgTTL *int64 `json:"MsgTTL,omitempty" name:"MsgTTL"`

	// Creation time
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// Modification time
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// Namespace ID
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

	// Namespace name
	NamespaceName *string `json:"NamespaceName,omitempty" name:"NamespaceName"`

	// Number of topics
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicNum *int64 `json:"TopicNum,omitempty" name:"TopicNum"`

	// Message retention policy
	// Note: this field may return null, indicating that no valid values can be obtained.
	RetentionPolicy *RetentionPolicy `json:"RetentionPolicy,omitempty" name:"RetentionPolicy"`
}

type EnvironmentRole 

type EnvironmentRole struct {

	// Environment (namespace).
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Role name.
	RoleName *string `json:"RoleName,omitempty" name:"RoleName"`

	// Permissions, which is a non-empty string array of `produce` and `consume` at the most.
	Permissions []*string `json:"Permissions,omitempty" name:"Permissions"`

	// Role description.
	RoleDescribe *string `json:"RoleDescribe,omitempty" name:"RoleDescribe"`

	// Creation time.
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// Update time.
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`
}

type Filter 

type Filter struct {

	// Filter parameter name
	Name *string `json:"Name,omitempty" name:"Name"`

	// Value
	Values []*string `json:"Values,omitempty" name:"Values"`
}

type FilterSubscription 

type FilterSubscription struct {

	// Whether to display only subscriptions that include real consumers.
	ConsumerHasCount *bool `json:"ConsumerHasCount,omitempty" name:"ConsumerHasCount"`

	// Whether to display only subscriptions with retained messages.
	ConsumerHasBacklog *bool `json:"ConsumerHasBacklog,omitempty" name:"ConsumerHasBacklog"`

	// Whether to display only subscriptions with messages discarded after expiration.
	ConsumerHasExpired *bool `json:"ConsumerHasExpired,omitempty" name:"ConsumerHasExpired"`

	// Filter by subscription name for exact search.
	SubscriptionNames []*string `json:"SubscriptionNames,omitempty" name:"SubscriptionNames"`
}

type ModifyClusterRequest 

type ModifyClusterRequest struct {
	*tchttp.BaseRequest

	// ID of the Pulsar cluster to be updated.
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Updated cluster name.
	ClusterName *string `json:"ClusterName,omitempty" name:"ClusterName"`

	// Remarks.
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Enables public network access, which can only be `true`.
	PublicAccessEnabled *bool `json:"PublicAccessEnabled,omitempty" name:"PublicAccessEnabled"`
}

func NewModifyClusterRequest 

func NewModifyClusterRequest() (request *ModifyClusterRequest)

func (*ModifyClusterRequest) FromJsonString 

func (r *ModifyClusterRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyClusterRequest) ToJsonString 

func (r *ModifyClusterRequest) ToJsonString() string

type ModifyClusterResponse 

type ModifyClusterResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Pulsar cluster ID
		ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyClusterResponse 

func NewModifyClusterResponse() (response *ModifyClusterResponse)

func (*ModifyClusterResponse) FromJsonString 

func (r *ModifyClusterResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyClusterResponse) ToJsonString 

func (r *ModifyClusterResponse) ToJsonString() string

type ModifyCmqQueueAttributeRequest 

type ModifyCmqQueueAttributeRequest struct {
	*tchttp.BaseRequest

	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`

	// Maximum number of heaped messages. The value range is 1,000,000–10,000,000 during the beta test and can be 1,000,000–1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitempty" name:"MaxMsgHeapNum"`

	// Long polling wait time for message reception. Value range: 0–30 seconds. Default value: 0.
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitempty" name:"PollingWaitSeconds"`

	// Message visibility timeout period. Value range: 1–43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitempty" name:"VisibilityTimeout"`

	// Maximum message length. Value range: 1024–65536 bytes (i.e., 1–64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// Message retention period. Value range: 60–1296000 seconds (i.e., 1 minute–15 days). Default value: 345600 (i.e., 4 days).
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// Maximum message rewindable period. Value range: 0–msgRetentionSeconds (maximum message retention period of the queue). 0 indicates not to enable message rewinding.
	RewindSeconds *uint64 `json:"RewindSeconds,omitempty" name:"RewindSeconds"`

	// First query time
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitempty" name:"FirstQueryInterval"`

	// Maximum number of queries
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitempty" name:"MaxQueryCount"`

	// Dead letter queue name
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitempty" name:"DeadLetterQueueName"`

	// Maximum period in seconds before an unconsumed message expires, which is required if `MaxTimeToLivepolicy` is 1. Value range: 300–43200. This value should be smaller than `MsgRetentionSeconds` (maximum message retention period)
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitempty" name:"MaxTimeToLive"`

	// Maximum number of receipts
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitempty" name:"MaxReceiveCount"`

	// Dead letter queue policy
	Policy *uint64 `json:"Policy,omitempty" name:"Policy"`

	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"Trace,omitempty" name:"Trace"`

	// Whether to enable transaction. 1: yes; 0: no
	Transaction *uint64 `json:"Transaction,omitempty" name:"Transaction"`
}

func NewModifyCmqQueueAttributeRequest 

func NewModifyCmqQueueAttributeRequest() (request *ModifyCmqQueueAttributeRequest)

func (*ModifyCmqQueueAttributeRequest) FromJsonString 

func (r *ModifyCmqQueueAttributeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyCmqQueueAttributeRequest) ToJsonString 

func (r *ModifyCmqQueueAttributeRequest) ToJsonString() string

type ModifyCmqQueueAttributeResponse 

type ModifyCmqQueueAttributeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyCmqQueueAttributeResponse 

func NewModifyCmqQueueAttributeResponse() (response *ModifyCmqQueueAttributeResponse)

func (*ModifyCmqQueueAttributeResponse) FromJsonString 

func (r *ModifyCmqQueueAttributeResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyCmqQueueAttributeResponse) ToJsonString 

func (r *ModifyCmqQueueAttributeResponse) ToJsonString() string

type ModifyCmqSubscriptionAttributeRequest 

type ModifyCmqSubscriptionAttributeRequest struct {
	*tchttp.BaseRequest

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`

	// CMQ push server retry policy in case an error occurs while pushing a message to the endpoint. Valid values:
	// (1) BACKOFF_RETRY: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message.
	// (2) EXPONENTIAL_DECAY_RETRY: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: EXPONENTIAL_DECAY_RETRY.
	NotifyStrategy *string `json:"NotifyStrategy,omitempty" name:"NotifyStrategy"`

	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `HTTP`, both values are acceptable, and the default value is `JSON`.
	NotifyContentFormat *string `json:"NotifyContentFormat,omitempty" name:"NotifyContentFormat"`

	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not configured, no matter whether `MsgTag` is configured, the subscription will receive all messages published to the topic; 2. If the array of `FilterTag` values has a value, only when at least one of the values in the array also exists in the array of `MsgTag` values (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the array of `FilterTag` values has a value, but `MsgTag` is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	FilterTags []*string `json:"FilterTags,omitempty" name:"FilterTags"`

	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` includes up to 15 dots (namely up to 16 segments).
	BindingKey []*string `json:"BindingKey,omitempty" name:"BindingKey"`
}

func NewModifyCmqSubscriptionAttributeRequest 

func NewModifyCmqSubscriptionAttributeRequest() (request *ModifyCmqSubscriptionAttributeRequest)

func (*ModifyCmqSubscriptionAttributeRequest) FromJsonString 

func (r *ModifyCmqSubscriptionAttributeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyCmqSubscriptionAttributeRequest) ToJsonString 

func (r *ModifyCmqSubscriptionAttributeRequest) ToJsonString() string

type ModifyCmqSubscriptionAttributeResponse 

type ModifyCmqSubscriptionAttributeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyCmqSubscriptionAttributeResponse 

func NewModifyCmqSubscriptionAttributeResponse() (response *ModifyCmqSubscriptionAttributeResponse)

func (*ModifyCmqSubscriptionAttributeResponse) FromJsonString 

func (r *ModifyCmqSubscriptionAttributeResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyCmqSubscriptionAttributeResponse) ToJsonString 

func (r *ModifyCmqSubscriptionAttributeResponse) ToJsonString() string

type ModifyCmqTopicAttributeRequest 

type ModifyCmqTopicAttributeRequest struct {
	*tchttp.BaseRequest

	// Topic name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Maximum message length. Value range: 1024–65536 bytes (i.e., 1–64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// Message retention period. Value range: 60–86400 seconds (i.e., 1 minute–1 day). Default value: 86400.
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"Trace,omitempty" name:"Trace"`
}

func NewModifyCmqTopicAttributeRequest 

func NewModifyCmqTopicAttributeRequest() (request *ModifyCmqTopicAttributeRequest)

func (*ModifyCmqTopicAttributeRequest) FromJsonString 

func (r *ModifyCmqTopicAttributeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyCmqTopicAttributeRequest) ToJsonString 

func (r *ModifyCmqTopicAttributeRequest) ToJsonString() string

type ModifyCmqTopicAttributeResponse 

type ModifyCmqTopicAttributeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyCmqTopicAttributeResponse 

func NewModifyCmqTopicAttributeResponse() (response *ModifyCmqTopicAttributeResponse)

func (*ModifyCmqTopicAttributeResponse) FromJsonString 

func (r *ModifyCmqTopicAttributeResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyCmqTopicAttributeResponse) ToJsonString 

func (r *ModifyCmqTopicAttributeResponse) ToJsonString() string

type ModifyEnvironmentAttributesRequest 

type ModifyEnvironmentAttributesRequest struct {
	*tchttp.BaseRequest

	// Namespace name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// TTL for unconsumed messages in seconds. Maximum value: 1296000 seconds.
	MsgTTL *uint64 `json:"MsgTTL,omitempty" name:"MsgTTL"`

	// Remarks (up to 128 characters).
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Message retention policy
	RetentionPolicy *RetentionPolicy `json:"RetentionPolicy,omitempty" name:"RetentionPolicy"`
}

func NewModifyEnvironmentAttributesRequest 

func NewModifyEnvironmentAttributesRequest() (request *ModifyEnvironmentAttributesRequest)

func (*ModifyEnvironmentAttributesRequest) FromJsonString 

func (r *ModifyEnvironmentAttributesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyEnvironmentAttributesRequest) ToJsonString 

func (r *ModifyEnvironmentAttributesRequest) ToJsonString() string

type ModifyEnvironmentAttributesResponse 

type ModifyEnvironmentAttributesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Namespace name.
		EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

		// TTL for unconsumed messages in seconds.
		MsgTTL *uint64 `json:"MsgTTL,omitempty" name:"MsgTTL"`

		// Remarks (up to 128 characters).
		// Note: this field may return null, indicating that no valid values can be obtained.
		Remark *string `json:"Remark,omitempty" name:"Remark"`

		// Namespace ID
		// Note: this field may return null, indicating that no valid values can be obtained.
		NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyEnvironmentAttributesResponse 

func NewModifyEnvironmentAttributesResponse() (response *ModifyEnvironmentAttributesResponse)

func (*ModifyEnvironmentAttributesResponse) FromJsonString 

func (r *ModifyEnvironmentAttributesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyEnvironmentAttributesResponse) ToJsonString 

func (r *ModifyEnvironmentAttributesResponse) ToJsonString() string

type ModifyEnvironmentRoleRequest 

type ModifyEnvironmentRoleRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Role name.
	RoleName *string `json:"RoleName,omitempty" name:"RoleName"`

	// Permissions, which is a non-empty string array of `produce` and `consume` at the most.
	Permissions []*string `json:"Permissions,omitempty" name:"Permissions"`

	// Cluster ID (required)
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewModifyEnvironmentRoleRequest 

func NewModifyEnvironmentRoleRequest() (request *ModifyEnvironmentRoleRequest)

func (*ModifyEnvironmentRoleRequest) FromJsonString 

func (r *ModifyEnvironmentRoleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyEnvironmentRoleRequest) ToJsonString 

func (r *ModifyEnvironmentRoleRequest) ToJsonString() string

type ModifyEnvironmentRoleResponse 

type ModifyEnvironmentRoleResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyEnvironmentRoleResponse 

func NewModifyEnvironmentRoleResponse() (response *ModifyEnvironmentRoleResponse)

func (*ModifyEnvironmentRoleResponse) FromJsonString 

func (r *ModifyEnvironmentRoleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyEnvironmentRoleResponse) ToJsonString 

func (r *ModifyEnvironmentRoleResponse) ToJsonString() string

type ModifyRocketMQClusterRequest 

type ModifyRocketMQClusterRequest struct {
	*tchttp.BaseRequest

	// RocketMQ cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// 3–64 letters, digits, hyphens, and underscores
	ClusterName *string `json:"ClusterName,omitempty" name:"ClusterName"`

	// Remarks (up to 128 characters)
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}

func NewModifyRocketMQClusterRequest 

func NewModifyRocketMQClusterRequest() (request *ModifyRocketMQClusterRequest)

func (*ModifyRocketMQClusterRequest) FromJsonString 

func (r *ModifyRocketMQClusterRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyRocketMQClusterRequest) ToJsonString 

func (r *ModifyRocketMQClusterRequest) ToJsonString() string

type ModifyRocketMQClusterResponse 

type ModifyRocketMQClusterResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyRocketMQClusterResponse 

func NewModifyRocketMQClusterResponse() (response *ModifyRocketMQClusterResponse)

func (*ModifyRocketMQClusterResponse) FromJsonString 

func (r *ModifyRocketMQClusterResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyRocketMQClusterResponse) ToJsonString 

func (r *ModifyRocketMQClusterResponse) ToJsonString() string

type ModifyRocketMQGroupRequest 

type ModifyRocketMQGroupRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

	// Consumer group name
	GroupId *string `json:"GroupId,omitempty" name:"GroupId"`

	// Remarks (up to 128 characters)
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Whether to enable consumption
	ReadEnable *bool `json:"ReadEnable,omitempty" name:"ReadEnable"`

	// Whether to enable broadcast consumption
	BroadcastEnable *bool `json:"BroadcastEnable,omitempty" name:"BroadcastEnable"`
}

func NewModifyRocketMQGroupRequest 

func NewModifyRocketMQGroupRequest() (request *ModifyRocketMQGroupRequest)

func (*ModifyRocketMQGroupRequest) FromJsonString 

func (r *ModifyRocketMQGroupRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyRocketMQGroupRequest) ToJsonString 

func (r *ModifyRocketMQGroupRequest) ToJsonString() string

type ModifyRocketMQGroupResponse 

type ModifyRocketMQGroupResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyRocketMQGroupResponse 

func NewModifyRocketMQGroupResponse() (response *ModifyRocketMQGroupResponse)

func (*ModifyRocketMQGroupResponse) FromJsonString 

func (r *ModifyRocketMQGroupResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyRocketMQGroupResponse) ToJsonString 

func (r *ModifyRocketMQGroupResponse) ToJsonString() string

type ModifyRocketMQNamespaceRequest 

type ModifyRocketMQNamespaceRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace name, which can contain 3–64 letters, digits, hyphens, and underscores
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

	// Retention time of unconsumed messages in milliseconds. Value range: 60 seconds–15 days
	Ttl *uint64 `json:"Ttl,omitempty" name:"Ttl"`

	// Retention time for persisted messages in milliseconds
	RetentionTime *uint64 `json:"RetentionTime,omitempty" name:"RetentionTime"`

	// Remarks (up to 128 characters)
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}

func NewModifyRocketMQNamespaceRequest 

func NewModifyRocketMQNamespaceRequest() (request *ModifyRocketMQNamespaceRequest)

func (*ModifyRocketMQNamespaceRequest) FromJsonString 

func (r *ModifyRocketMQNamespaceRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyRocketMQNamespaceRequest) ToJsonString 

func (r *ModifyRocketMQNamespaceRequest) ToJsonString() string

type ModifyRocketMQNamespaceResponse 

type ModifyRocketMQNamespaceResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyRocketMQNamespaceResponse 

func NewModifyRocketMQNamespaceResponse() (response *ModifyRocketMQNamespaceResponse)

func (*ModifyRocketMQNamespaceResponse) FromJsonString 

func (r *ModifyRocketMQNamespaceResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyRocketMQNamespaceResponse) ToJsonString 

func (r *ModifyRocketMQNamespaceResponse) ToJsonString() string

type ModifyRocketMQTopicRequest 

type ModifyRocketMQTopicRequest struct {
	*tchttp.BaseRequest

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Namespace name
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

	// Topic name
	Topic *string `json:"Topic,omitempty" name:"Topic"`

	// Remarks (up to 128 characters)
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Number of partitions, which is invalid for globally sequential messages and cannot be less than the current number of partitions.
	PartitionNum *int64 `json:"PartitionNum,omitempty" name:"PartitionNum"`
}

func NewModifyRocketMQTopicRequest 

func NewModifyRocketMQTopicRequest() (request *ModifyRocketMQTopicRequest)

func (*ModifyRocketMQTopicRequest) FromJsonString 

func (r *ModifyRocketMQTopicRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyRocketMQTopicRequest) ToJsonString 

func (r *ModifyRocketMQTopicRequest) ToJsonString() string

type ModifyRocketMQTopicResponse 

type ModifyRocketMQTopicResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyRocketMQTopicResponse 

func NewModifyRocketMQTopicResponse() (response *ModifyRocketMQTopicResponse)

func (*ModifyRocketMQTopicResponse) FromJsonString 

func (r *ModifyRocketMQTopicResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyRocketMQTopicResponse) ToJsonString 

func (r *ModifyRocketMQTopicResponse) ToJsonString() string

type ModifyRoleRequest 

type ModifyRoleRequest struct {
	*tchttp.BaseRequest

	// Role name, which can contain up to 32 letters, digits, hyphens, and underscores.
	RoleName *string `json:"RoleName,omitempty" name:"RoleName"`

	// Remarks (up to 128 characters).
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Cluster ID (required)
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewModifyRoleRequest 

func NewModifyRoleRequest() (request *ModifyRoleRequest)

func (*ModifyRoleRequest) FromJsonString 

func (r *ModifyRoleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyRoleRequest) ToJsonString 

func (r *ModifyRoleRequest) ToJsonString() string

type ModifyRoleResponse 

type ModifyRoleResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Role name
		RoleName *string `json:"RoleName,omitempty" name:"RoleName"`

		// Remarks
		Remark *string `json:"Remark,omitempty" name:"Remark"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyRoleResponse 

func NewModifyRoleResponse() (response *ModifyRoleResponse)

func (*ModifyRoleResponse) FromJsonString 

func (r *ModifyRoleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyRoleResponse) ToJsonString 

func (r *ModifyRoleResponse) ToJsonString() string

type ModifyTopicRequest 

type ModifyTopicRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Topic name.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Number of partitions, which must be equal to or greater than the original number of partitions. To maintain the original number of partitions, enter the original number. Modifying the number of partitions will take effect only for non-globally sequential messages. There can be up to 128 partitions.
	Partitions *uint64 `json:"Partitions,omitempty" name:"Partitions"`

	// Remarks (up to 128 characters).
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewModifyTopicRequest 

func NewModifyTopicRequest() (request *ModifyTopicRequest)

func (*ModifyTopicRequest) FromJsonString 

func (r *ModifyTopicRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyTopicRequest) ToJsonString 

func (r *ModifyTopicRequest) ToJsonString() string

type ModifyTopicResponse 

type ModifyTopicResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of partitions
		Partitions *uint64 `json:"Partitions,omitempty" name:"Partitions"`

		// Remarks (up to 128 characters).
		Remark *string `json:"Remark,omitempty" name:"Remark"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyTopicResponse 

func NewModifyTopicResponse() (response *ModifyTopicResponse)

func (*ModifyTopicResponse) FromJsonString 

func (r *ModifyTopicResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyTopicResponse) ToJsonString 

func (r *ModifyTopicResponse) ToJsonString() string

type PartitionsTopic 

type PartitionsTopic struct {

	// Average size of the messages published in the last interval in bytes.
	// Note: this field may return null, indicating that no valid values can be obtained.
	AverageMsgSize *string `json:"AverageMsgSize,omitempty" name:"AverageMsgSize"`

	// Number of consumers.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumerCount *string `json:"ConsumerCount,omitempty" name:"ConsumerCount"`

	// Total number of recorded messages.
	// Note: this field may return null, indicating that no valid values can be obtained.
	LastConfirmedEntry *string `json:"LastConfirmedEntry,omitempty" name:"LastConfirmedEntry"`

	// Time when the last ledger was created.
	// Note: this field may return null, indicating that no valid values can be obtained.
	LastLedgerCreatedTimestamp *string `json:"LastLedgerCreatedTimestamp,omitempty" name:"LastLedgerCreatedTimestamp"`

	// Number of messages published by local and replicated publishers per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRateIn *string `json:"MsgRateIn,omitempty" name:"MsgRateIn"`

	// Sum of the numbers of messages delivered by local and replicated consumers per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRateOut *string `json:"MsgRateOut,omitempty" name:"MsgRateOut"`

	// Number of bytes of messages published by local and replicated publishers per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgThroughputIn *string `json:"MsgThroughputIn,omitempty" name:"MsgThroughputIn"`

	// Number of bytes of messages delivered by local and replicated consumers per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgThroughputOut *string `json:"MsgThroughputOut,omitempty" name:"MsgThroughputOut"`

	// Total number of recorded messages.
	// Note: this field may return null, indicating that no valid values can be obtained.
	NumberOfEntries *string `json:"NumberOfEntries,omitempty" name:"NumberOfEntries"`

	// Subpartition ID.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Partitions *int64 `json:"Partitions,omitempty" name:"Partitions"`

	// Number of producers.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ProducerCount *string `json:"ProducerCount,omitempty" name:"ProducerCount"`

	// Total amount of all stored messages in bytes.
	// Note: this field may return null, indicating that no valid values can be obtained.
	TotalSize *string `json:"TotalSize,omitempty" name:"TotalSize"`

	// Topic type description.
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicType *uint64 `json:"TopicType,omitempty" name:"TopicType"`
}

type PublishCmqMsgRequest 

type PublishCmqMsgRequest struct {
	*tchttp.BaseRequest

	// Topic name
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Message content
	MsgContent *string `json:"MsgContent,omitempty" name:"MsgContent"`

	// Message tag
	MsgTag []*string `json:"MsgTag,omitempty" name:"MsgTag"`
}

func NewPublishCmqMsgRequest 

func NewPublishCmqMsgRequest() (request *PublishCmqMsgRequest)

func (*PublishCmqMsgRequest) FromJsonString 

func (r *PublishCmqMsgRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*PublishCmqMsgRequest) ToJsonString 

func (r *PublishCmqMsgRequest) ToJsonString() string

type PublishCmqMsgResponse 

type PublishCmqMsgResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// `true` indicates that the sending is successful
		Result *bool `json:"Result,omitempty" name:"Result"`

		// Message ID
		MsgId *string `json:"MsgId,omitempty" name:"MsgId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewPublishCmqMsgResponse 

func NewPublishCmqMsgResponse() (response *PublishCmqMsgResponse)

func (*PublishCmqMsgResponse) FromJsonString 

func (r *PublishCmqMsgResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*PublishCmqMsgResponse) ToJsonString 

func (r *PublishCmqMsgResponse) ToJsonString() string

type Publisher 

type Publisher struct {

	// Producer ID.
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	ProducerId *int64 `json:"ProducerId,omitempty" name:"ProducerId"`

	// Producer name.
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	ProducerName *string `json:"ProducerName,omitempty" name:"ProducerName"`

	// Producer address.
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	Address *string `json:"Address,omitempty" name:"Address"`

	// Client version.
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	ClientVersion *string `json:"ClientVersion,omitempty" name:"ClientVersion"`

	// Message production rate (message/sec).
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	MsgRateIn *float64 `json:"MsgRateIn,omitempty" name:"MsgRateIn"`

	// Message production throughput rate (byte/sec).
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	MsgThroughputIn *float64 `json:"MsgThroughputIn,omitempty" name:"MsgThroughputIn"`

	// Average message size in bytes.
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	AverageMsgSize *float64 `json:"AverageMsgSize,omitempty" name:"AverageMsgSize"`

	// Connection time.
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	ConnectedSince *string `json:"ConnectedSince,omitempty" name:"ConnectedSince"`

	// Serial number of the topic partition connected to the producer.
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	Partition *int64 `json:"Partition,omitempty" name:"Partition"`
}

type ReceiveMessageRequest 

type ReceiveMessageRequest struct {
	*tchttp.BaseRequest

	// Name of the topic which receives the message. It is better to be the full path of the topic, such as `tenant/namespace/topic`. If it is not specified, `public/default` will be used by default.
	Topic *string `json:"Topic,omitempty" name:"Topic"`

	// Subscriber name
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`

	// Default value: 1000. Messages received by the consumer will first be stored in the `receiverQueueSize` queue to tune the message receiving rate.
	ReceiverQueueSize *int64 `json:"ReceiverQueueSize,omitempty" name:"ReceiverQueueSize"`

	// Default value: Latest. It is used to determine the position where the consumer initially receives messages. Valid values: Earliest, Latest.
	SubInitialPosition *string `json:"SubInitialPosition,omitempty" name:"SubInitialPosition"`
}

func NewReceiveMessageRequest 

func NewReceiveMessageRequest() (request *ReceiveMessageRequest)

func (*ReceiveMessageRequest) FromJsonString 

func (r *ReceiveMessageRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ReceiveMessageRequest) ToJsonString 

func (r *ReceiveMessageRequest) ToJsonString() string

type ReceiveMessageResponse 

type ReceiveMessageResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Unique primary key used to identify the message
		MessageID *string `json:"MessageID,omitempty" name:"MessageID"`

		// Content of the received message
		MessagePayload *string `json:"MessagePayload,omitempty" name:"MessagePayload"`

		// Provided to the `Ack` API and used to acknowledge messages in the topic
		AckTopic *string `json:"AckTopic,omitempty" name:"AckTopic"`

		// Returned error message. If it is an empty string, no error occurred.
		// Note: this field may return null, indicating that no valid values can be obtained.
		ErrorMsg *string `json:"ErrorMsg,omitempty" name:"ErrorMsg"`

		// Returned subscriber name, which will be used when an acknowledgment consumer is created.
		// Note: this field may return null, indicating that no valid values can be obtained.
		SubName *string `json:"SubName,omitempty" name:"SubName"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewReceiveMessageResponse 

func NewReceiveMessageResponse() (response *ReceiveMessageResponse)

func (*ReceiveMessageResponse) FromJsonString 

func (r *ReceiveMessageResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ReceiveMessageResponse) ToJsonString 

func (r *ReceiveMessageResponse) ToJsonString() string

type ResetMsgSubOffsetByTimestampRequest 

type ResetMsgSubOffsetByTimestampRequest struct {
	*tchttp.BaseRequest

	// Namespace name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Topic name.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Subscriber name.
	Subscription *string `json:"Subscription,omitempty" name:"Subscription"`

	// Timestamp, accurate down to the millisecond.
	ToTimestamp *uint64 `json:"ToTimestamp,omitempty" name:"ToTimestamp"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewResetMsgSubOffsetByTimestampRequest 

func NewResetMsgSubOffsetByTimestampRequest() (request *ResetMsgSubOffsetByTimestampRequest)

func (*ResetMsgSubOffsetByTimestampRequest) FromJsonString 

func (r *ResetMsgSubOffsetByTimestampRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ResetMsgSubOffsetByTimestampRequest) ToJsonString 

func (r *ResetMsgSubOffsetByTimestampRequest) ToJsonString() string

type ResetMsgSubOffsetByTimestampResponse 

type ResetMsgSubOffsetByTimestampResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Result.
		// Note: this field may return null, indicating that no valid values can be obtained.
		Result *bool `json:"Result,omitempty" name:"Result"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewResetMsgSubOffsetByTimestampResponse 

func NewResetMsgSubOffsetByTimestampResponse() (response *ResetMsgSubOffsetByTimestampResponse)

func (*ResetMsgSubOffsetByTimestampResponse) FromJsonString 

func (r *ResetMsgSubOffsetByTimestampResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ResetMsgSubOffsetByTimestampResponse) ToJsonString 

func (r *ResetMsgSubOffsetByTimestampResponse) ToJsonString() string

type RetentionPolicy 

type RetentionPolicy struct {

	// Message retention period
	TimeInMinutes *int64 `json:"TimeInMinutes,omitempty" name:"TimeInMinutes"`

	// Message retention size
	SizeInMB *int64 `json:"SizeInMB,omitempty" name:"SizeInMB"`
}

type RewindCmqQueueRequest 

type RewindCmqQueueRequest struct {
	*tchttp.BaseRequest

	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`

	// After this time is configured, the `(Batch)receiveMessage` API will consume the messages received after this timestamp in the order in which they are produced.
	StartConsumeTime *uint64 `json:"StartConsumeTime,omitempty" name:"StartConsumeTime"`
}

func NewRewindCmqQueueRequest 

func NewRewindCmqQueueRequest() (request *RewindCmqQueueRequest)

func (*RewindCmqQueueRequest) FromJsonString 

func (r *RewindCmqQueueRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*RewindCmqQueueRequest) ToJsonString 

func (r *RewindCmqQueueRequest) ToJsonString() string

type RewindCmqQueueResponse 

type RewindCmqQueueResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewRewindCmqQueueResponse 

func NewRewindCmqQueueResponse() (response *RewindCmqQueueResponse)

func (*RewindCmqQueueResponse) FromJsonString 

func (r *RewindCmqQueueResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*RewindCmqQueueResponse) ToJsonString 

func (r *RewindCmqQueueResponse) ToJsonString() string

type RocketMQClusterConfig 

type RocketMQClusterConfig struct {

	// Maximum TPS per namespace
	MaxTpsPerNamespace *uint64 `json:"MaxTpsPerNamespace,omitempty" name:"MaxTpsPerNamespace"`

	// Maximum number of namespaces
	MaxNamespaceNum *uint64 `json:"MaxNamespaceNum,omitempty" name:"MaxNamespaceNum"`

	// Number of used namespaces
	UsedNamespaceNum *uint64 `json:"UsedNamespaceNum,omitempty" name:"UsedNamespaceNum"`

	// Maximum number of topics
	MaxTopicNum *uint64 `json:"MaxTopicNum,omitempty" name:"MaxTopicNum"`

	// Number of used topics
	UsedTopicNum *uint64 `json:"UsedTopicNum,omitempty" name:"UsedTopicNum"`

	// Maximum number of groups
	MaxGroupNum *uint64 `json:"MaxGroupNum,omitempty" name:"MaxGroupNum"`

	// Number of used groups
	UsedGroupNum *uint64 `json:"UsedGroupNum,omitempty" name:"UsedGroupNum"`

	// Maximum message retention period in milliseconds
	MaxRetentionTime *uint64 `json:"MaxRetentionTime,omitempty" name:"MaxRetentionTime"`

	// Maximum message delay in milliseconds
	MaxLatencyTime *uint64 `json:"MaxLatencyTime,omitempty" name:"MaxLatencyTime"`
}

type RocketMQClusterDetail 

type RocketMQClusterDetail struct {

	// Cluster's basic information
	Info *RocketMQClusterInfo `json:"Info,omitempty" name:"Info"`

	// Cluster configuration information
	Config *RocketMQClusterConfig `json:"Config,omitempty" name:"Config"`

	// Cluster status. 0: creating; 1: normal; 2: terminating; 3: deleted; 4. isolated; 5. creation failed; 6: deletion failed
	// Note: this field may return null, indicating that no valid values can be obtained.
	Status *int64 `json:"Status,omitempty" name:"Status"`
}

type RocketMQClusterInfo 

type RocketMQClusterInfo struct {

	// Cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// Cluster name
	ClusterName *string `json:"ClusterName,omitempty" name:"ClusterName"`

	// Region information
	Region *string `json:"Region,omitempty" name:"Region"`

	// Creation time in milliseconds
	CreateTime *uint64 `json:"CreateTime,omitempty" name:"CreateTime"`

	// Cluster remarks
	// Note: this field may return null, indicating that no valid values can be obtained.
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Public network access address
	PublicEndPoint *string `json:"PublicEndPoint,omitempty" name:"PublicEndPoint"`

	// VPC access address
	VpcEndPoint *string `json:"VpcEndPoint,omitempty" name:"VpcEndPoint"`
}

type RocketMQClusterRecentStats 

type RocketMQClusterRecentStats struct {

	// Number of topics
	TopicNum *uint64 `json:"TopicNum,omitempty" name:"TopicNum"`

	// Number of produced messages
	ProducedMsgNum *uint64 `json:"ProducedMsgNum,omitempty" name:"ProducedMsgNum"`

	// Number of consumed messages
	ConsumedMsgNum *uint64 `json:"ConsumedMsgNum,omitempty" name:"ConsumedMsgNum"`

	// Number of retained messages
	AccumulativeMsgNum *uint64 `json:"AccumulativeMsgNum,omitempty" name:"AccumulativeMsgNum"`
}

type RocketMQGroup 

type RocketMQGroup struct {

	// Consumer group name
	Name *string `json:"Name,omitempty" name:"Name"`

	// Number of online consumers
	ConsumerNum *uint64 `json:"ConsumerNum,omitempty" name:"ConsumerNum"`

	// Consumption TPS
	TPS *uint64 `json:"TPS,omitempty" name:"TPS"`

	// Total number of retained messages
	TotalAccumulative *int64 `json:"TotalAccumulative,omitempty" name:"TotalAccumulative"`

	// 0: cluster consumption mode; 1: broadcast consumption mode; -1: unknown
	ConsumptionMode *int64 `json:"ConsumptionMode,omitempty" name:"ConsumptionMode"`

	// Whether to allow consumption
	ReadEnabled *bool `json:"ReadEnabled,omitempty" name:"ReadEnabled"`

	// Number of partitions in the retry letter topic
	// Note: this field may return null, indicating that no valid values can be obtained.
	RetryPartitionNum *uint64 `json:"RetryPartitionNum,omitempty" name:"RetryPartitionNum"`

	// Creation time in milliseconds
	CreateTime *uint64 `json:"CreateTime,omitempty" name:"CreateTime"`

	// Modification time in milliseconds
	UpdateTime *uint64 `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// Client protocol
	ClientProtocol *string `json:"ClientProtocol,omitempty" name:"ClientProtocol"`

	// Remarks
	// Note: this field may return null, indicating that no valid values can be obtained.
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Consumer type. Enumerated values: ACTIVELY, PASSIVELY
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumerType *string `json:"ConsumerType,omitempty" name:"ConsumerType"`

	// Whether to enable broadcast consumption
	BroadcastEnabled *bool `json:"BroadcastEnabled,omitempty" name:"BroadcastEnabled"`
}

type RocketMQNamespace 

type RocketMQNamespace struct {

	// Namespace name, which can contain 3–64 letters, digits, hyphens, and underscores
	NamespaceId *string `json:"NamespaceId,omitempty" name:"NamespaceId"`

	// Retention period for unconsumed messages in milliseconds. Valid range: 60 seconds–15 days.
	Ttl *uint64 `json:"Ttl,omitempty" name:"Ttl"`

	// Retention period for persisted messages in milliseconds
	RetentionTime *uint64 `json:"RetentionTime,omitempty" name:"RetentionTime"`

	// Remarks
	// Note: this field may return null, indicating that no valid values can be obtained.
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}

type RocketMQTopic 

type RocketMQTopic struct {

	// Topic name
	Name *string `json:"Name,omitempty" name:"Name"`

	// Remarks
	// Note: this field may return null, indicating that no valid values can be obtained.
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Number of read/write partitions
	PartitionNum *uint64 `json:"PartitionNum,omitempty" name:"PartitionNum"`

	// Creation time in milliseconds
	CreateTime *uint64 `json:"CreateTime,omitempty" name:"CreateTime"`

	// Creation time in milliseconds
	UpdateTime *uint64 `json:"UpdateTime,omitempty" name:"UpdateTime"`
}

type Role 

type Role struct {

	// Role name.
	RoleName *string `json:"RoleName,omitempty" name:"RoleName"`

	// Value of the role token.
	Token *string `json:"Token,omitempty" name:"Token"`

	// Remarks.
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Creation time.
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// Update time.
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`
}

type SendBatchMessagesRequest 

type SendBatchMessagesRequest struct {
	*tchttp.BaseRequest

	// Name of the topic to which to send the message. It is better to be the full path of the topic, such as `tenant/namespace/topic`. If it is not specified, `public/default` will be used by default.
	Topic *string `json:"Topic,omitempty" name:"Topic"`

	// Content of the message to be sent
	Payload *string `json:"Payload,omitempty" name:"Payload"`

	// String-Type token, which is optional and will be automatically obtained by the system.
	StringToken *string `json:"StringToken,omitempty" name:"StringToken"`

	// Producer name, which must be globally unique. If it is not configured, the system will automatically generate one.
	ProducerName *string `json:"ProducerName,omitempty" name:"ProducerName"`

	// Message sending timeout period in seconds. Default value: 30s
	SendTimeout *int64 `json:"SendTimeout,omitempty" name:"SendTimeout"`

	// Maximum number of produced messages which can be cached in the memory. Default value: 1000
	MaxPendingMessages *int64 `json:"MaxPendingMessages,omitempty" name:"MaxPendingMessages"`

	// Maximum number of messages in each batch. Default value: 1000 messages/batch
	BatchingMaxMessages *int64 `json:"BatchingMaxMessages,omitempty" name:"BatchingMaxMessages"`

	// Maximum wait time for each batch, after which the batch will be sent no matter whether the specified number or size of messages in the batch is reached. Default value: 10 ms
	BatchingMaxPublishDelay *int64 `json:"BatchingMaxPublishDelay,omitempty" name:"BatchingMaxPublishDelay"`

	// Maximum allowed size of messages in each batch. Default value: 128 KB
	BatchingMaxBytes *int64 `json:"BatchingMaxBytes,omitempty" name:"BatchingMaxBytes"`
}

func NewSendBatchMessagesRequest 

func NewSendBatchMessagesRequest() (request *SendBatchMessagesRequest)

func (*SendBatchMessagesRequest) FromJsonString 

func (r *SendBatchMessagesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*SendBatchMessagesRequest) ToJsonString 

func (r *SendBatchMessagesRequest) ToJsonString() string

type SendBatchMessagesResponse 

type SendBatchMessagesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Unique message ID
		// Note: this field may return null, indicating that no valid values can be obtained.
		MessageId *string `json:"MessageId,omitempty" name:"MessageId"`

		// Error message. If an empty string is returned, no error occurred.
		// Note: this field may return null, indicating that no valid values can be obtained.
		ErrorMsg *string `json:"ErrorMsg,omitempty" name:"ErrorMsg"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewSendBatchMessagesResponse 

func NewSendBatchMessagesResponse() (response *SendBatchMessagesResponse)

func (*SendBatchMessagesResponse) FromJsonString 

func (r *SendBatchMessagesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*SendBatchMessagesResponse) ToJsonString 

func (r *SendBatchMessagesResponse) ToJsonString() string

type SendCmqMsgRequest 

type SendCmqMsgRequest struct {
	*tchttp.BaseRequest

	// Queue name
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`

	// Message content
	MsgContent *string `json:"MsgContent,omitempty" name:"MsgContent"`

	// Delay time
	DelaySeconds *int64 `json:"DelaySeconds,omitempty" name:"DelaySeconds"`
}

func NewSendCmqMsgRequest 

func NewSendCmqMsgRequest() (request *SendCmqMsgRequest)

func (*SendCmqMsgRequest) FromJsonString 

func (r *SendCmqMsgRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*SendCmqMsgRequest) ToJsonString 

func (r *SendCmqMsgRequest) ToJsonString() string

type SendCmqMsgResponse 

type SendCmqMsgResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// `true` indicates that the sending is successful
		Result *bool `json:"Result,omitempty" name:"Result"`

		// Message ID
		MsgId *string `json:"MsgId,omitempty" name:"MsgId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewSendCmqMsgResponse 

func NewSendCmqMsgResponse() (response *SendCmqMsgResponse)

func (*SendCmqMsgResponse) FromJsonString 

func (r *SendCmqMsgResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*SendCmqMsgResponse) ToJsonString 

func (r *SendCmqMsgResponse) ToJsonString() string

type SendMessagesRequest 

type SendMessagesRequest struct {
	*tchttp.BaseRequest

	// Name of the topic to which to send the message. It is better to be the full path of the topic, such as `tenant/namespace/topic`. If it is not specified, `public/default` will be used by default.
	Topic *string `json:"Topic,omitempty" name:"Topic"`

	// Content of the message to be sent
	Payload *string `json:"Payload,omitempty" name:"Payload"`

	// Token used for authentication, which is optional and will be automatically obtained by the system.
	StringToken *string `json:"StringToken,omitempty" name:"StringToken"`

	// Producer name, which must be globally unique. If it is not configured, the system will randomly generate one.
	ProducerName *string `json:"ProducerName,omitempty" name:"ProducerName"`

	// Message sending timeout period, which is 30s by default.
	SendTimeout *int64 `json:"SendTimeout,omitempty" name:"SendTimeout"`

	// Maximum number of produced messages which can be cached in the memory. Default value: 1000
	MaxPendingMessages *int64 `json:"MaxPendingMessages,omitempty" name:"MaxPendingMessages"`
}

func NewSendMessagesRequest 

func NewSendMessagesRequest() (request *SendMessagesRequest)

func (*SendMessagesRequest) FromJsonString 

func (r *SendMessagesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*SendMessagesRequest) ToJsonString 

func (r *SendMessagesRequest) ToJsonString() string

type SendMessagesResponse 

type SendMessagesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// messageID, which must be globally unique and is the metadata information used to identify the message.
		// Note: this field may return null, indicating that no valid values can be obtained.
		MessageId *string `json:"MessageId,omitempty" name:"MessageId"`

		// Returned error message. If an empty string is returned, no error occurred.
		// Note: this field may return null, indicating that no valid values can be obtained.
		ErrorMsg *string `json:"ErrorMsg,omitempty" name:"ErrorMsg"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewSendMessagesResponse 

func NewSendMessagesResponse() (response *SendMessagesResponse)

func (*SendMessagesResponse) FromJsonString 

func (r *SendMessagesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*SendMessagesResponse) ToJsonString 

func (r *SendMessagesResponse) ToJsonString() string

type SendMsgRequest 

type SendMsgRequest struct {
	*tchttp.BaseRequest

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Topic name. If the topic is a partitioned topic, you need to specify the partition; otherwise, messages will be sent to partition 0 by default, such as `my_topic-partition-0`.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Message content, which cannot be empty and can contain up to 5,242,880 bytes.
	MsgContent *string `json:"MsgContent,omitempty" name:"MsgContent"`

	// Pulsar cluster ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewSendMsgRequest 

func NewSendMsgRequest() (request *SendMsgRequest)

func (*SendMsgRequest) FromJsonString 

func (r *SendMsgRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*SendMsgRequest) ToJsonString 

func (r *SendMsgRequest) ToJsonString() string

type SendMsgResponse 

type SendMsgResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewSendMsgResponse 

func NewSendMsgResponse() (response *SendMsgResponse)

func (*SendMsgResponse) FromJsonString 

func (r *SendMsgResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*SendMsgResponse) ToJsonString 

func (r *SendMsgResponse) ToJsonString() string

type Sort 

type Sort struct {

	// Sorting field.
	Name *string `json:"Name,omitempty" name:"Name"`

	// Ascending order: `ASC`; descending order: `DESC`.
	Order *string `json:"Order,omitempty" name:"Order"`
}

type Subscription 

type Subscription struct {

	// Topic name.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// The time when the consumer started connecting.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConnectedSince *string `json:"ConnectedSince,omitempty" name:"ConnectedSince"`

	// Consumer address.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumerAddr *string `json:"ConsumerAddr,omitempty" name:"ConsumerAddr"`

	// Number of consumers.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumerCount *string `json:"ConsumerCount,omitempty" name:"ConsumerCount"`

	// Consumer name.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumerName *string `json:"ConsumerName,omitempty" name:"ConsumerName"`

	// Number of retained messages.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgBacklog *string `json:"MsgBacklog,omitempty" name:"MsgBacklog"`

	// Proportion of messages under this subscription that were discarded but not sent after TTL.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRateExpired *string `json:"MsgRateExpired,omitempty" name:"MsgRateExpired"`

	// Sum of the numbers of messages delivered by the consumer per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRateOut *string `json:"MsgRateOut,omitempty" name:"MsgRateOut"`

	// Number of bytes of messages consumed by the consumer per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgThroughputOut *string `json:"MsgThroughputOut,omitempty" name:"MsgThroughputOut"`

	// Subscription name.
	// Note: this field may return null, indicating that no valid values can be obtained.
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`

	// Set of consumers.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumerSets []*Consumer `json:"ConsumerSets,omitempty" name:"ConsumerSets"`

	// Whether it is online.
	// Note: this field may return null, indicating that no valid values can be obtained.
	IsOnline *bool `json:"IsOnline,omitempty" name:"IsOnline"`

	// Set of consumption progress information.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumersScheduleSets []*ConsumersSchedule `json:"ConsumersScheduleSets,omitempty" name:"ConsumersScheduleSets"`

	// Remarks.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Creation time.
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// Modification time.
	// Note: this field may return null, indicating that no valid values can be obtained.
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`
}

type SubscriptionTopic 

type SubscriptionTopic struct {

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Topic name.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Subscription name.
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`
}

type Tag 

type Tag struct {

	// Value of the tag key
	TagKey *string `json:"TagKey,omitempty" name:"TagKey"`

	// Value of the tag value
	TagValue *string `json:"TagValue,omitempty" name:"TagValue"`
}

type Topic 

type Topic struct {

	// Average size of the messages published in the last interval in bytes.
	// Note: this field may return null, indicating that no valid values can be obtained.
	AverageMsgSize *string `json:"AverageMsgSize,omitempty" name:"AverageMsgSize"`

	// Number of consumers.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumerCount *string `json:"ConsumerCount,omitempty" name:"ConsumerCount"`

	// Total number of recorded messages.
	// Note: this field may return null, indicating that no valid values can be obtained.
	LastConfirmedEntry *string `json:"LastConfirmedEntry,omitempty" name:"LastConfirmedEntry"`

	// Time when the last ledger was created.
	// Note: this field may return null, indicating that no valid values can be obtained.
	LastLedgerCreatedTimestamp *string `json:"LastLedgerCreatedTimestamp,omitempty" name:"LastLedgerCreatedTimestamp"`

	// Number of messages published by local and replicated publishers per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRateIn *string `json:"MsgRateIn,omitempty" name:"MsgRateIn"`

	// Sum of the numbers of messages delivered by local and replicated consumers per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRateOut *string `json:"MsgRateOut,omitempty" name:"MsgRateOut"`

	// Number of bytes of messages published by local and replicated publishers per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgThroughputIn *string `json:"MsgThroughputIn,omitempty" name:"MsgThroughputIn"`

	// Number of bytes of messages delivered by local and replicated consumers per second.
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgThroughputOut *string `json:"MsgThroughputOut,omitempty" name:"MsgThroughputOut"`

	// Total number of recorded messages.
	// Note: this field may return null, indicating that no valid values can be obtained.
	NumberOfEntries *string `json:"NumberOfEntries,omitempty" name:"NumberOfEntries"`

	// Number of partitions ≤ 0: there are no subpartitions in the topic.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Partitions *int64 `json:"Partitions,omitempty" name:"Partitions"`

	// Number of producers.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ProducerCount *string `json:"ProducerCount,omitempty" name:"ProducerCount"`

	// Total amount of all stored messages in bytes.
	// Note: this field may return null, indicating that no valid values can be obtained.
	TotalSize *string `json:"TotalSize,omitempty" name:"TotalSize"`

	// Subpartitions in a partitioned topic.
	// Note: this field may return null, indicating that no valid values can be obtained.
	SubTopicSets []*PartitionsTopic `json:"SubTopicSets,omitempty" name:"SubTopicSets"`

	// Topic type description:
	// 0: general message;
	// 1: globally sequential message;
	// 2: partitionally sequential message;
	// 3: retry letter queue;
	// 4: dead letter queue;
	// 5: transaction message.
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicType *uint64 `json:"TopicType,omitempty" name:"TopicType"`

	// Environment (namespace) name.
	// Note: this field may return null, indicating that no valid values can be obtained.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Topic name.
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Remarks (up to 128 characters).
	// Note: this field may return null, indicating that no valid values can be obtained.
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// Creation time.
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// Modification time.
	// Note: this field may return null, indicating that no valid values can be obtained.
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// Maximum number of producers.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ProducerLimit *string `json:"ProducerLimit,omitempty" name:"ProducerLimit"`

	// Maximum number of consumers.
	// Note: this field may return null, indicating that no valid values can be obtained.
	ConsumerLimit *string `json:"ConsumerLimit,omitempty" name:"ConsumerLimit"`
}

type TopicRecord 

type TopicRecord struct {

	// Environment (namespace) name.
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`

	// Topic name.
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
}

type UnbindCmqDeadLetterRequest 

type UnbindCmqDeadLetterRequest struct {
	*tchttp.BaseRequest

	// Source queue name of dead letter policy. Calling this API will clear the dead letter queue policy of this queue.
	SourceQueueName *string `json:"SourceQueueName,omitempty" name:"SourceQueueName"`
}

func NewUnbindCmqDeadLetterRequest 

func NewUnbindCmqDeadLetterRequest() (request *UnbindCmqDeadLetterRequest)

func (*UnbindCmqDeadLetterRequest) FromJsonString 

func (r *UnbindCmqDeadLetterRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UnbindCmqDeadLetterRequest) ToJsonString 

func (r *UnbindCmqDeadLetterRequest) ToJsonString() string

type UnbindCmqDeadLetterResponse 

type UnbindCmqDeadLetterResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewUnbindCmqDeadLetterResponse 

func NewUnbindCmqDeadLetterResponse() (response *UnbindCmqDeadLetterResponse)

func (*UnbindCmqDeadLetterResponse) FromJsonString 

func (r *UnbindCmqDeadLetterResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UnbindCmqDeadLetterResponse) ToJsonString 

func (r *UnbindCmqDeadLetterResponse) ToJsonString() string

type VpcBindRecord 

type VpcBindRecord struct {

	// Tenant VPC ID
	UniqueVpcId *string `json:"UniqueVpcId,omitempty" name:"UniqueVpcId"`

	// Tenant VPC subnet ID
	UniqueSubnetId *string `json:"UniqueSubnetId,omitempty" name:"UniqueSubnetId"`

	// Route ID
	RouterId *string `json:"RouterId,omitempty" name:"RouterId"`

	// VPC ID
	Ip *string `json:"Ip,omitempty" name:"Ip"`

	// VPC port
	Port *uint64 `json:"Port,omitempty" name:"Port"`

	// Remarks (up to 128 characters)
	// Note: this field may return null, indicating that no valid values can be obtained.
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}

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.