Documentation ¶
Index ¶
- Constants
- type AcknowledgeMessageRequest
- type AcknowledgeMessageResponse
- type BindCluster
- type ClearCmqQueueRequest
- type ClearCmqQueueResponse
- type ClearCmqSubscriptionFilterTagsRequest
- type ClearCmqSubscriptionFilterTagsResponse
- type Client
- func (c *Client) AcknowledgeMessage(request *AcknowledgeMessageRequest) (response *AcknowledgeMessageResponse, err error)
- func (c *Client) AcknowledgeMessageWithContext(ctx context.Context, request *AcknowledgeMessageRequest) (response *AcknowledgeMessageResponse, err error)
- func (c *Client) ClearCmqQueue(request *ClearCmqQueueRequest) (response *ClearCmqQueueResponse, err error)
- func (c *Client) ClearCmqQueueWithContext(ctx context.Context, request *ClearCmqQueueRequest) (response *ClearCmqQueueResponse, err error)
- func (c *Client) ClearCmqSubscriptionFilterTags(request *ClearCmqSubscriptionFilterTagsRequest) (response *ClearCmqSubscriptionFilterTagsResponse, err error)
- func (c *Client) ClearCmqSubscriptionFilterTagsWithContext(ctx context.Context, request *ClearCmqSubscriptionFilterTagsRequest) (response *ClearCmqSubscriptionFilterTagsResponse, err error)
- func (c *Client) CreateCluster(request *CreateClusterRequest) (response *CreateClusterResponse, err error)
- func (c *Client) CreateClusterWithContext(ctx context.Context, request *CreateClusterRequest) (response *CreateClusterResponse, err error)
- func (c *Client) CreateCmqQueue(request *CreateCmqQueueRequest) (response *CreateCmqQueueResponse, err error)
- func (c *Client) CreateCmqQueueWithContext(ctx context.Context, request *CreateCmqQueueRequest) (response *CreateCmqQueueResponse, err error)
- func (c *Client) CreateCmqSubscribe(request *CreateCmqSubscribeRequest) (response *CreateCmqSubscribeResponse, err error)
- func (c *Client) CreateCmqSubscribeWithContext(ctx context.Context, request *CreateCmqSubscribeRequest) (response *CreateCmqSubscribeResponse, err error)
- func (c *Client) CreateCmqTopic(request *CreateCmqTopicRequest) (response *CreateCmqTopicResponse, err error)
- func (c *Client) CreateCmqTopicWithContext(ctx context.Context, request *CreateCmqTopicRequest) (response *CreateCmqTopicResponse, err error)
- func (c *Client) CreateEnvironment(request *CreateEnvironmentRequest) (response *CreateEnvironmentResponse, err error)
- func (c *Client) CreateEnvironmentRole(request *CreateEnvironmentRoleRequest) (response *CreateEnvironmentRoleResponse, err error)
- func (c *Client) CreateEnvironmentRoleWithContext(ctx context.Context, request *CreateEnvironmentRoleRequest) (response *CreateEnvironmentRoleResponse, err error)
- func (c *Client) CreateEnvironmentWithContext(ctx context.Context, request *CreateEnvironmentRequest) (response *CreateEnvironmentResponse, err error)
- func (c *Client) CreateRocketMQCluster(request *CreateRocketMQClusterRequest) (response *CreateRocketMQClusterResponse, err error)
- func (c *Client) CreateRocketMQClusterWithContext(ctx context.Context, request *CreateRocketMQClusterRequest) (response *CreateRocketMQClusterResponse, err error)
- func (c *Client) CreateRocketMQGroup(request *CreateRocketMQGroupRequest) (response *CreateRocketMQGroupResponse, err error)
- func (c *Client) CreateRocketMQGroupWithContext(ctx context.Context, request *CreateRocketMQGroupRequest) (response *CreateRocketMQGroupResponse, err error)
- func (c *Client) CreateRocketMQNamespace(request *CreateRocketMQNamespaceRequest) (response *CreateRocketMQNamespaceResponse, err error)
- func (c *Client) CreateRocketMQNamespaceWithContext(ctx context.Context, request *CreateRocketMQNamespaceRequest) (response *CreateRocketMQNamespaceResponse, err error)
- func (c *Client) CreateRocketMQTopic(request *CreateRocketMQTopicRequest) (response *CreateRocketMQTopicResponse, err error)
- func (c *Client) CreateRocketMQTopicWithContext(ctx context.Context, request *CreateRocketMQTopicRequest) (response *CreateRocketMQTopicResponse, err error)
- func (c *Client) CreateRole(request *CreateRoleRequest) (response *CreateRoleResponse, err error)
- func (c *Client) CreateRoleWithContext(ctx context.Context, request *CreateRoleRequest) (response *CreateRoleResponse, err error)
- func (c *Client) CreateSubscription(request *CreateSubscriptionRequest) (response *CreateSubscriptionResponse, err error)
- func (c *Client) CreateSubscriptionWithContext(ctx context.Context, request *CreateSubscriptionRequest) (response *CreateSubscriptionResponse, err error)
- func (c *Client) CreateTopic(request *CreateTopicRequest) (response *CreateTopicResponse, err error)
- func (c *Client) CreateTopicWithContext(ctx context.Context, request *CreateTopicRequest) (response *CreateTopicResponse, err error)
- func (c *Client) DeleteCluster(request *DeleteClusterRequest) (response *DeleteClusterResponse, err error)
- func (c *Client) DeleteClusterWithContext(ctx context.Context, request *DeleteClusterRequest) (response *DeleteClusterResponse, err error)
- func (c *Client) DeleteCmqQueue(request *DeleteCmqQueueRequest) (response *DeleteCmqQueueResponse, err error)
- func (c *Client) DeleteCmqQueueWithContext(ctx context.Context, request *DeleteCmqQueueRequest) (response *DeleteCmqQueueResponse, err error)
- func (c *Client) DeleteCmqSubscribe(request *DeleteCmqSubscribeRequest) (response *DeleteCmqSubscribeResponse, err error)
- func (c *Client) DeleteCmqSubscribeWithContext(ctx context.Context, request *DeleteCmqSubscribeRequest) (response *DeleteCmqSubscribeResponse, err error)
- func (c *Client) DeleteCmqTopic(request *DeleteCmqTopicRequest) (response *DeleteCmqTopicResponse, err error)
- func (c *Client) DeleteCmqTopicWithContext(ctx context.Context, request *DeleteCmqTopicRequest) (response *DeleteCmqTopicResponse, err error)
- func (c *Client) DeleteEnvironmentRoles(request *DeleteEnvironmentRolesRequest) (response *DeleteEnvironmentRolesResponse, err error)
- func (c *Client) DeleteEnvironmentRolesWithContext(ctx context.Context, request *DeleteEnvironmentRolesRequest) (response *DeleteEnvironmentRolesResponse, err error)
- func (c *Client) DeleteEnvironments(request *DeleteEnvironmentsRequest) (response *DeleteEnvironmentsResponse, err error)
- func (c *Client) DeleteEnvironmentsWithContext(ctx context.Context, request *DeleteEnvironmentsRequest) (response *DeleteEnvironmentsResponse, err error)
- func (c *Client) DeleteRocketMQCluster(request *DeleteRocketMQClusterRequest) (response *DeleteRocketMQClusterResponse, err error)
- func (c *Client) DeleteRocketMQClusterWithContext(ctx context.Context, request *DeleteRocketMQClusterRequest) (response *DeleteRocketMQClusterResponse, err error)
- func (c *Client) DeleteRocketMQGroup(request *DeleteRocketMQGroupRequest) (response *DeleteRocketMQGroupResponse, err error)
- func (c *Client) DeleteRocketMQGroupWithContext(ctx context.Context, request *DeleteRocketMQGroupRequest) (response *DeleteRocketMQGroupResponse, err error)
- func (c *Client) DeleteRocketMQNamespace(request *DeleteRocketMQNamespaceRequest) (response *DeleteRocketMQNamespaceResponse, err error)
- func (c *Client) DeleteRocketMQNamespaceWithContext(ctx context.Context, request *DeleteRocketMQNamespaceRequest) (response *DeleteRocketMQNamespaceResponse, err error)
- func (c *Client) DeleteRocketMQTopic(request *DeleteRocketMQTopicRequest) (response *DeleteRocketMQTopicResponse, err error)
- func (c *Client) DeleteRocketMQTopicWithContext(ctx context.Context, request *DeleteRocketMQTopicRequest) (response *DeleteRocketMQTopicResponse, err error)
- func (c *Client) DeleteRoles(request *DeleteRolesRequest) (response *DeleteRolesResponse, err error)
- func (c *Client) DeleteRolesWithContext(ctx context.Context, request *DeleteRolesRequest) (response *DeleteRolesResponse, err error)
- func (c *Client) DeleteSubscriptions(request *DeleteSubscriptionsRequest) (response *DeleteSubscriptionsResponse, err error)
- func (c *Client) DeleteSubscriptionsWithContext(ctx context.Context, request *DeleteSubscriptionsRequest) (response *DeleteSubscriptionsResponse, err error)
- func (c *Client) DeleteTopics(request *DeleteTopicsRequest) (response *DeleteTopicsResponse, err error)
- func (c *Client) DeleteTopicsWithContext(ctx context.Context, request *DeleteTopicsRequest) (response *DeleteTopicsResponse, err error)
- func (c *Client) DescribeBindClusters(request *DescribeBindClustersRequest) (response *DescribeBindClustersResponse, err error)
- func (c *Client) DescribeBindClustersWithContext(ctx context.Context, request *DescribeBindClustersRequest) (response *DescribeBindClustersResponse, err error)
- func (c *Client) DescribeBindVpcs(request *DescribeBindVpcsRequest) (response *DescribeBindVpcsResponse, err error)
- func (c *Client) DescribeBindVpcsWithContext(ctx context.Context, request *DescribeBindVpcsRequest) (response *DescribeBindVpcsResponse, err error)
- func (c *Client) DescribeClusterDetail(request *DescribeClusterDetailRequest) (response *DescribeClusterDetailResponse, err error)
- func (c *Client) DescribeClusterDetailWithContext(ctx context.Context, request *DescribeClusterDetailRequest) (response *DescribeClusterDetailResponse, err error)
- func (c *Client) DescribeClusters(request *DescribeClustersRequest) (response *DescribeClustersResponse, err error)
- func (c *Client) DescribeClustersWithContext(ctx context.Context, request *DescribeClustersRequest) (response *DescribeClustersResponse, err error)
- func (c *Client) DescribeCmqDeadLetterSourceQueues(request *DescribeCmqDeadLetterSourceQueuesRequest) (response *DescribeCmqDeadLetterSourceQueuesResponse, err error)
- func (c *Client) DescribeCmqDeadLetterSourceQueuesWithContext(ctx context.Context, request *DescribeCmqDeadLetterSourceQueuesRequest) (response *DescribeCmqDeadLetterSourceQueuesResponse, err error)
- func (c *Client) DescribeCmqQueueDetail(request *DescribeCmqQueueDetailRequest) (response *DescribeCmqQueueDetailResponse, err error)
- func (c *Client) DescribeCmqQueueDetailWithContext(ctx context.Context, request *DescribeCmqQueueDetailRequest) (response *DescribeCmqQueueDetailResponse, err error)
- func (c *Client) DescribeCmqQueues(request *DescribeCmqQueuesRequest) (response *DescribeCmqQueuesResponse, err error)
- func (c *Client) DescribeCmqQueuesWithContext(ctx context.Context, request *DescribeCmqQueuesRequest) (response *DescribeCmqQueuesResponse, err error)
- func (c *Client) DescribeCmqSubscriptionDetail(request *DescribeCmqSubscriptionDetailRequest) (response *DescribeCmqSubscriptionDetailResponse, err error)
- func (c *Client) DescribeCmqSubscriptionDetailWithContext(ctx context.Context, request *DescribeCmqSubscriptionDetailRequest) (response *DescribeCmqSubscriptionDetailResponse, err error)
- func (c *Client) DescribeCmqTopicDetail(request *DescribeCmqTopicDetailRequest) (response *DescribeCmqTopicDetailResponse, err error)
- func (c *Client) DescribeCmqTopicDetailWithContext(ctx context.Context, request *DescribeCmqTopicDetailRequest) (response *DescribeCmqTopicDetailResponse, err error)
- func (c *Client) DescribeCmqTopics(request *DescribeCmqTopicsRequest) (response *DescribeCmqTopicsResponse, err error)
- func (c *Client) DescribeCmqTopicsWithContext(ctx context.Context, request *DescribeCmqTopicsRequest) (response *DescribeCmqTopicsResponse, err error)
- func (c *Client) DescribeEnvironmentAttributes(request *DescribeEnvironmentAttributesRequest) (response *DescribeEnvironmentAttributesResponse, err error)
- func (c *Client) DescribeEnvironmentAttributesWithContext(ctx context.Context, request *DescribeEnvironmentAttributesRequest) (response *DescribeEnvironmentAttributesResponse, err error)
- func (c *Client) DescribeEnvironmentRoles(request *DescribeEnvironmentRolesRequest) (response *DescribeEnvironmentRolesResponse, err error)
- func (c *Client) DescribeEnvironmentRolesWithContext(ctx context.Context, request *DescribeEnvironmentRolesRequest) (response *DescribeEnvironmentRolesResponse, err error)
- func (c *Client) DescribeEnvironments(request *DescribeEnvironmentsRequest) (response *DescribeEnvironmentsResponse, err error)
- func (c *Client) DescribeEnvironmentsWithContext(ctx context.Context, request *DescribeEnvironmentsRequest) (response *DescribeEnvironmentsResponse, err error)
- func (c *Client) DescribePublisherSummary(request *DescribePublisherSummaryRequest) (response *DescribePublisherSummaryResponse, err error)
- func (c *Client) DescribePublisherSummaryWithContext(ctx context.Context, request *DescribePublisherSummaryRequest) (response *DescribePublisherSummaryResponse, err error)
- func (c *Client) DescribePublishers(request *DescribePublishersRequest) (response *DescribePublishersResponse, err error)
- func (c *Client) DescribePublishersWithContext(ctx context.Context, request *DescribePublishersRequest) (response *DescribePublishersResponse, err error)
- func (c *Client) DescribeRocketMQCluster(request *DescribeRocketMQClusterRequest) (response *DescribeRocketMQClusterResponse, err error)
- func (c *Client) DescribeRocketMQClusterWithContext(ctx context.Context, request *DescribeRocketMQClusterRequest) (response *DescribeRocketMQClusterResponse, err error)
- func (c *Client) DescribeRocketMQClusters(request *DescribeRocketMQClustersRequest) (response *DescribeRocketMQClustersResponse, err error)
- func (c *Client) DescribeRocketMQClustersWithContext(ctx context.Context, request *DescribeRocketMQClustersRequest) (response *DescribeRocketMQClustersResponse, err error)
- func (c *Client) DescribeRocketMQGroups(request *DescribeRocketMQGroupsRequest) (response *DescribeRocketMQGroupsResponse, err error)
- func (c *Client) DescribeRocketMQGroupsWithContext(ctx context.Context, request *DescribeRocketMQGroupsRequest) (response *DescribeRocketMQGroupsResponse, err error)
- func (c *Client) DescribeRocketMQNamespaces(request *DescribeRocketMQNamespacesRequest) (response *DescribeRocketMQNamespacesResponse, err error)
- func (c *Client) DescribeRocketMQNamespacesWithContext(ctx context.Context, request *DescribeRocketMQNamespacesRequest) (response *DescribeRocketMQNamespacesResponse, err error)
- func (c *Client) DescribeRocketMQTopics(request *DescribeRocketMQTopicsRequest) (response *DescribeRocketMQTopicsResponse, err error)
- func (c *Client) DescribeRocketMQTopicsWithContext(ctx context.Context, request *DescribeRocketMQTopicsRequest) (response *DescribeRocketMQTopicsResponse, err error)
- func (c *Client) DescribeRoles(request *DescribeRolesRequest) (response *DescribeRolesResponse, err error)
- func (c *Client) DescribeRolesWithContext(ctx context.Context, request *DescribeRolesRequest) (response *DescribeRolesResponse, err error)
- func (c *Client) DescribeSubscriptions(request *DescribeSubscriptionsRequest) (response *DescribeSubscriptionsResponse, err error)
- func (c *Client) DescribeSubscriptionsWithContext(ctx context.Context, request *DescribeSubscriptionsRequest) (response *DescribeSubscriptionsResponse, err error)
- func (c *Client) DescribeTopics(request *DescribeTopicsRequest) (response *DescribeTopicsResponse, err error)
- func (c *Client) DescribeTopicsWithContext(ctx context.Context, request *DescribeTopicsRequest) (response *DescribeTopicsResponse, err error)
- func (c *Client) ModifyCluster(request *ModifyClusterRequest) (response *ModifyClusterResponse, err error)
- func (c *Client) ModifyClusterWithContext(ctx context.Context, request *ModifyClusterRequest) (response *ModifyClusterResponse, err error)
- func (c *Client) ModifyCmqQueueAttribute(request *ModifyCmqQueueAttributeRequest) (response *ModifyCmqQueueAttributeResponse, err error)
- func (c *Client) ModifyCmqQueueAttributeWithContext(ctx context.Context, request *ModifyCmqQueueAttributeRequest) (response *ModifyCmqQueueAttributeResponse, err error)
- func (c *Client) ModifyCmqSubscriptionAttribute(request *ModifyCmqSubscriptionAttributeRequest) (response *ModifyCmqSubscriptionAttributeResponse, err error)
- func (c *Client) ModifyCmqSubscriptionAttributeWithContext(ctx context.Context, request *ModifyCmqSubscriptionAttributeRequest) (response *ModifyCmqSubscriptionAttributeResponse, err error)
- func (c *Client) ModifyCmqTopicAttribute(request *ModifyCmqTopicAttributeRequest) (response *ModifyCmqTopicAttributeResponse, err error)
- func (c *Client) ModifyCmqTopicAttributeWithContext(ctx context.Context, request *ModifyCmqTopicAttributeRequest) (response *ModifyCmqTopicAttributeResponse, err error)
- func (c *Client) ModifyEnvironmentAttributes(request *ModifyEnvironmentAttributesRequest) (response *ModifyEnvironmentAttributesResponse, err error)
- func (c *Client) ModifyEnvironmentAttributesWithContext(ctx context.Context, request *ModifyEnvironmentAttributesRequest) (response *ModifyEnvironmentAttributesResponse, err error)
- func (c *Client) ModifyEnvironmentRole(request *ModifyEnvironmentRoleRequest) (response *ModifyEnvironmentRoleResponse, err error)
- func (c *Client) ModifyEnvironmentRoleWithContext(ctx context.Context, request *ModifyEnvironmentRoleRequest) (response *ModifyEnvironmentRoleResponse, err error)
- func (c *Client) ModifyRocketMQCluster(request *ModifyRocketMQClusterRequest) (response *ModifyRocketMQClusterResponse, err error)
- func (c *Client) ModifyRocketMQClusterWithContext(ctx context.Context, request *ModifyRocketMQClusterRequest) (response *ModifyRocketMQClusterResponse, err error)
- func (c *Client) ModifyRocketMQGroup(request *ModifyRocketMQGroupRequest) (response *ModifyRocketMQGroupResponse, err error)
- func (c *Client) ModifyRocketMQGroupWithContext(ctx context.Context, request *ModifyRocketMQGroupRequest) (response *ModifyRocketMQGroupResponse, err error)
- func (c *Client) ModifyRocketMQNamespace(request *ModifyRocketMQNamespaceRequest) (response *ModifyRocketMQNamespaceResponse, err error)
- func (c *Client) ModifyRocketMQNamespaceWithContext(ctx context.Context, request *ModifyRocketMQNamespaceRequest) (response *ModifyRocketMQNamespaceResponse, err error)
- func (c *Client) ModifyRocketMQTopic(request *ModifyRocketMQTopicRequest) (response *ModifyRocketMQTopicResponse, err error)
- func (c *Client) ModifyRocketMQTopicWithContext(ctx context.Context, request *ModifyRocketMQTopicRequest) (response *ModifyRocketMQTopicResponse, err error)
- func (c *Client) ModifyRole(request *ModifyRoleRequest) (response *ModifyRoleResponse, err error)
- func (c *Client) ModifyRoleWithContext(ctx context.Context, request *ModifyRoleRequest) (response *ModifyRoleResponse, err error)
- func (c *Client) ModifyTopic(request *ModifyTopicRequest) (response *ModifyTopicResponse, err error)
- func (c *Client) ModifyTopicWithContext(ctx context.Context, request *ModifyTopicRequest) (response *ModifyTopicResponse, err error)
- func (c *Client) PublishCmqMsg(request *PublishCmqMsgRequest) (response *PublishCmqMsgResponse, err error)
- func (c *Client) PublishCmqMsgWithContext(ctx context.Context, request *PublishCmqMsgRequest) (response *PublishCmqMsgResponse, err error)
- func (c *Client) ReceiveMessage(request *ReceiveMessageRequest) (response *ReceiveMessageResponse, err error)
- func (c *Client) ReceiveMessageWithContext(ctx context.Context, request *ReceiveMessageRequest) (response *ReceiveMessageResponse, err error)
- func (c *Client) ResetMsgSubOffsetByTimestamp(request *ResetMsgSubOffsetByTimestampRequest) (response *ResetMsgSubOffsetByTimestampResponse, err error)
- func (c *Client) ResetMsgSubOffsetByTimestampWithContext(ctx context.Context, request *ResetMsgSubOffsetByTimestampRequest) (response *ResetMsgSubOffsetByTimestampResponse, err error)
- func (c *Client) RewindCmqQueue(request *RewindCmqQueueRequest) (response *RewindCmqQueueResponse, err error)
- func (c *Client) RewindCmqQueueWithContext(ctx context.Context, request *RewindCmqQueueRequest) (response *RewindCmqQueueResponse, err error)
- func (c *Client) SendBatchMessages(request *SendBatchMessagesRequest) (response *SendBatchMessagesResponse, err error)
- func (c *Client) SendBatchMessagesWithContext(ctx context.Context, request *SendBatchMessagesRequest) (response *SendBatchMessagesResponse, err error)
- func (c *Client) SendCmqMsg(request *SendCmqMsgRequest) (response *SendCmqMsgResponse, err error)
- func (c *Client) SendCmqMsgWithContext(ctx context.Context, request *SendCmqMsgRequest) (response *SendCmqMsgResponse, err error)
- func (c *Client) SendMessages(request *SendMessagesRequest) (response *SendMessagesResponse, err error)
- func (c *Client) SendMessagesWithContext(ctx context.Context, request *SendMessagesRequest) (response *SendMessagesResponse, err error)
- func (c *Client) SendMsg(request *SendMsgRequest) (response *SendMsgResponse, err error)
- func (c *Client) SendMsgWithContext(ctx context.Context, request *SendMsgRequest) (response *SendMsgResponse, err error)
- func (c *Client) UnbindCmqDeadLetter(request *UnbindCmqDeadLetterRequest) (response *UnbindCmqDeadLetterResponse, err error)
- func (c *Client) UnbindCmqDeadLetterWithContext(ctx context.Context, request *UnbindCmqDeadLetterRequest) (response *UnbindCmqDeadLetterResponse, err error)
- type Cluster
- type CmqDeadLetterPolicy
- type CmqDeadLetterSource
- type CmqQueue
- type CmqSubscription
- type CmqTopic
- type CmqTransactionPolicy
- type Consumer
- type ConsumersSchedule
- type CreateClusterRequest
- type CreateClusterResponse
- type CreateCmqQueueRequest
- type CreateCmqQueueResponse
- type CreateCmqSubscribeRequest
- type CreateCmqSubscribeResponse
- type CreateCmqTopicRequest
- type CreateCmqTopicResponse
- type CreateEnvironmentRequest
- type CreateEnvironmentResponse
- type CreateEnvironmentRoleRequest
- type CreateEnvironmentRoleResponse
- type CreateRocketMQClusterRequest
- type CreateRocketMQClusterResponse
- type CreateRocketMQGroupRequest
- type CreateRocketMQGroupResponse
- type CreateRocketMQNamespaceRequest
- type CreateRocketMQNamespaceResponse
- type CreateRocketMQTopicRequest
- type CreateRocketMQTopicResponse
- type CreateRoleRequest
- type CreateRoleResponse
- type CreateSubscriptionRequest
- type CreateSubscriptionResponse
- type CreateTopicRequest
- type CreateTopicResponse
- type DeleteClusterRequest
- type DeleteClusterResponse
- type DeleteCmqQueueRequest
- type DeleteCmqQueueResponse
- type DeleteCmqSubscribeRequest
- type DeleteCmqSubscribeResponse
- type DeleteCmqTopicRequest
- type DeleteCmqTopicResponse
- type DeleteEnvironmentRolesRequest
- type DeleteEnvironmentRolesResponse
- type DeleteEnvironmentsRequest
- type DeleteEnvironmentsResponse
- type DeleteRocketMQClusterRequest
- type DeleteRocketMQClusterResponse
- type DeleteRocketMQGroupRequest
- type DeleteRocketMQGroupResponse
- type DeleteRocketMQNamespaceRequest
- type DeleteRocketMQNamespaceResponse
- type DeleteRocketMQTopicRequest
- type DeleteRocketMQTopicResponse
- type DeleteRolesRequest
- type DeleteRolesResponse
- type DeleteSubscriptionsRequest
- type DeleteSubscriptionsResponse
- type DeleteTopicsRequest
- type DeleteTopicsResponse
- type DescribeBindClustersRequest
- type DescribeBindClustersResponse
- type DescribeBindVpcsRequest
- type DescribeBindVpcsResponse
- type DescribeClusterDetailRequest
- type DescribeClusterDetailResponse
- type DescribeClustersRequest
- type DescribeClustersResponse
- type DescribeCmqDeadLetterSourceQueuesRequest
- type DescribeCmqDeadLetterSourceQueuesResponse
- type DescribeCmqQueueDetailRequest
- type DescribeCmqQueueDetailResponse
- type DescribeCmqQueuesRequest
- type DescribeCmqQueuesResponse
- type DescribeCmqSubscriptionDetailRequest
- type DescribeCmqSubscriptionDetailResponse
- type DescribeCmqTopicDetailRequest
- type DescribeCmqTopicDetailResponse
- type DescribeCmqTopicsRequest
- type DescribeCmqTopicsResponse
- type DescribeEnvironmentAttributesRequest
- type DescribeEnvironmentAttributesResponse
- type DescribeEnvironmentRolesRequest
- type DescribeEnvironmentRolesResponse
- type DescribeEnvironmentsRequest
- type DescribeEnvironmentsResponse
- type DescribePublisherSummaryRequest
- type DescribePublisherSummaryResponse
- type DescribePublishersRequest
- type DescribePublishersResponse
- type DescribeRocketMQClusterRequest
- type DescribeRocketMQClusterResponse
- type DescribeRocketMQClustersRequest
- type DescribeRocketMQClustersResponse
- type DescribeRocketMQGroupsRequest
- type DescribeRocketMQGroupsResponse
- type DescribeRocketMQNamespacesRequest
- type DescribeRocketMQNamespacesResponse
- type DescribeRocketMQTopicsRequest
- type DescribeRocketMQTopicsResponse
- type DescribeRolesRequest
- type DescribeRolesResponse
- type DescribeSubscriptionsRequest
- type DescribeSubscriptionsResponse
- type DescribeTopicsRequest
- type DescribeTopicsResponse
- type Environment
- type EnvironmentRole
- type Filter
- type FilterSubscription
- type ModifyClusterRequest
- type ModifyClusterResponse
- type ModifyCmqQueueAttributeRequest
- type ModifyCmqQueueAttributeResponse
- type ModifyCmqSubscriptionAttributeRequest
- type ModifyCmqSubscriptionAttributeResponse
- type ModifyCmqTopicAttributeRequest
- type ModifyCmqTopicAttributeResponse
- type ModifyEnvironmentAttributesRequest
- type ModifyEnvironmentAttributesResponse
- type ModifyEnvironmentRoleRequest
- type ModifyEnvironmentRoleResponse
- type ModifyRocketMQClusterRequest
- type ModifyRocketMQClusterResponse
- type ModifyRocketMQGroupRequest
- type ModifyRocketMQGroupResponse
- type ModifyRocketMQNamespaceRequest
- type ModifyRocketMQNamespaceResponse
- type ModifyRocketMQTopicRequest
- type ModifyRocketMQTopicResponse
- type ModifyRoleRequest
- type ModifyRoleResponse
- type ModifyTopicRequest
- type ModifyTopicResponse
- type PartitionsTopic
- type PublishCmqMsgRequest
- type PublishCmqMsgResponse
- type Publisher
- type ReceiveMessageRequest
- type ReceiveMessageResponse
- type ResetMsgSubOffsetByTimestampRequest
- type ResetMsgSubOffsetByTimestampResponse
- type RetentionPolicy
- type RewindCmqQueueRequest
- type RewindCmqQueueResponse
- type RocketMQClusterConfig
- type RocketMQClusterDetail
- type RocketMQClusterInfo
- type RocketMQClusterRecentStats
- type RocketMQGroup
- type RocketMQNamespace
- type RocketMQTopic
- type Role
- type SendBatchMessagesRequest
- type SendBatchMessagesResponse
- type SendCmqMsgRequest
- type SendCmqMsgResponse
- type SendMessagesRequest
- type SendMessagesResponse
- type SendMsgRequest
- type SendMsgResponse
- type Sort
- type Subscription
- type SubscriptionTopic
- type Tag
- type Topic
- type TopicRecord
- type UnbindCmqDeadLetterRequest
- type UnbindCmqDeadLetterResponse
- type VpcBindRecord
Constants ¶
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" )
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 ¶
func NewClient ¶
func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)
func NewClientWithSecretId ¶
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 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 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 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 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 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"` }