tdmq

package
v1.81.129 Latest Latest
Warning

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

 Go to latest Published: Sep 29, 2024 License: MPL-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NoneTopicType       = -1
	NonePulsarTopicType = -1
)
View Source 
const (
	RabbitMQVipInstanceRunning = 0
	RabbitMQVipInstanceSuccess = 1
)
View Source 
const (
	RocketMqVipInsRunning   = 0
	RocketMqVipInsSuccess   = 1
	RocketMqVipInsIsolating = 2
	RocketMqVipInsDestroy   = 3
	RocketMqVipInsUpdate    = 6
)
View Source 
const (
	AutoRenewFlagTrue = 1
)

Variables

This section is empty.

Functions

This section is empty.

Types

type TdmqService 

type TdmqService struct {
	// contains filtered or unexported fields
}

func NewTdmqService 

func NewTdmqService(client *connectivity.TencentCloudClient) TdmqService

func (*TdmqService) CreateTdmqNamespace 

func (me *TdmqService) CreateTdmqNamespace(ctx context.Context, environName string, msgTtl uint64, clusterId string,
	remark string, retentionPolicy tdmq.RetentionPolicy) (environId string, errRet error)

tdmq namespace

func (*TdmqService) CreateTdmqNamespaceRoleAttachment 

func (me *TdmqService) CreateTdmqNamespaceRoleAttachment(ctx context.Context, environId string,
	roleName string, permissions []*string, clusterId string) (errRet error)

tdmq role

func (*TdmqService) CreateTdmqRole 

func (me *TdmqService) CreateTdmqRole(ctx context.Context, roleName string, clusterId string,
	remark string) (roleId string, errRet error)

tdmq role

func (*TdmqService) CreateTdmqTopic 

func (me *TdmqService) CreateTdmqTopic(ctx context.Context, environId string, topicName string, partitions uint64,
	topicType int64, remark string, clusterId string, pulsarTopicType int64) (errRet error)

tdmq topic

func (*TdmqService) DeleteTdmqInstance 

func (me *TdmqService) DeleteTdmqInstance(ctx context.Context, clusterId string) (errRet error)

func (*TdmqService) DeleteTdmqNamespace 

func (me *TdmqService) DeleteTdmqNamespace(ctx context.Context, environId string, clusterId string) (errRet error)

func (*TdmqService) DeleteTdmqNamespaceRoleAttachment 

func (me *TdmqService) DeleteTdmqNamespaceRoleAttachment(ctx context.Context, environId string,
	roleName string, cluserId string) (errRet error)

func (*TdmqService) DeleteTdmqProfessionalClusterById 

func (me *TdmqService) DeleteTdmqProfessionalClusterById(ctx context.Context, clusterId string) (errRet error)

func (*TdmqService) DeleteTdmqRabbitmqUserById 

func (me *TdmqService) DeleteTdmqRabbitmqUserById(ctx context.Context, instanceId, user string) (errRet error)

func (*TdmqService) DeleteTdmqRabbitmqVipInstanceById 

func (me *TdmqService) DeleteTdmqRabbitmqVipInstanceById(ctx context.Context, instanceId string) (errRet error)

func (*TdmqService) DeleteTdmqRabbitmqVirtualHostById 

func (me *TdmqService) DeleteTdmqRabbitmqVirtualHostById(ctx context.Context, instanceId, virtualHost string) (errRet error)

func (*TdmqService) DeleteTdmqRocketmqVipInstanceById 

func (me *TdmqService) DeleteTdmqRocketmqVipInstanceById(ctx context.Context, clusterId string) (errRet error)

func (*TdmqService) DeleteTdmqRole 

func (me *TdmqService) DeleteTdmqRole(ctx context.Context, roleName string, clusterId string) (errRet error)

func (*TdmqService) DeleteTdmqSubscriptionAttachmentById 

func (me *TdmqService) DeleteTdmqSubscriptionAttachmentById(ctx context.Context, environmentId, Topic, subscriptionName, clusterId string) (errRet error)

func (*TdmqService) DeleteTdmqSubscriptionById added in v1.81.64 

func (me *TdmqService) DeleteTdmqSubscriptionById(ctx context.Context, clusterId, environmentId, topicName, subscriptionName string) (errRet error)

func (*TdmqService) DeleteTdmqTopic 

func (me *TdmqService) DeleteTdmqTopic(ctx context.Context, environId string, topicName string, clusterId string) (errRet error)

func (*TdmqService) DeleteTdmqTopicsAttachmentById 

func (me *TdmqService) DeleteTdmqTopicsAttachmentById(ctx context.Context, environmentId, Topic, subscriptionName, clusterId string) (errRet error)

func (*TdmqService) DescribePulsarProInstances 

func (me *TdmqService) DescribePulsarProInstances(ctx context.Context, clusterId string) (professionalCluster *tdmq.PulsarProInstance, errRet error)

func (*TdmqService) DescribeTdmqDeadLetterSourceQueueByFilter 

func (me *TdmqService) DescribeTdmqDeadLetterSourceQueueByFilter(ctx context.Context, param map[string]interface{}) (deadLetterSourceQueue []*tdmq.CmqDeadLetterSource, errRet error)

func (*TdmqService) DescribeTdmqEnvironmentAttributesByFilter 

func (me *TdmqService) DescribeTdmqEnvironmentAttributesByFilter(ctx context.Context, param map[string]interface{}) (environmentAttributes *tdmq.DescribeEnvironmentAttributesResponseParams, errRet error)

func (*TdmqService) DescribeTdmqInstanceById 

func (me *TdmqService) DescribeTdmqInstanceById(ctx context.Context,
	clusterId string) (info *tdmq.Cluster, has bool, errRet error)

func (*TdmqService) DescribeTdmqMessageByFilter 

func (me *TdmqService) DescribeTdmqMessageByFilter(ctx context.Context, param map[string]interface{}) (message *tdmq.DescribeRocketMQMsgResponseParams, errRet error)

func (*TdmqService) DescribeTdmqNamespaceById 

func (me *TdmqService) DescribeTdmqNamespaceById(ctx context.Context,
	environId string, clusterId string) (info *tdmq.Environment, has bool, errRet error)

func (*TdmqService) DescribeTdmqNamespaceRoleAttachment 

func (me *TdmqService) DescribeTdmqNamespaceRoleAttachment(ctx context.Context,
	environId string, roleName string, clusterId string) (info *tdmq.EnvironmentRole, has bool, errRet error)

func (*TdmqService) DescribeTdmqProInstanceDetailByFilter 

func (me *TdmqService) DescribeTdmqProInstanceDetailByFilter(ctx context.Context, param map[string]interface{}) (proInstanceDetail *tdmq.DescribePulsarProInstanceDetailResponseParams, errRet error)

func (*TdmqService) DescribeTdmqProInstancesByFilter 

func (me *TdmqService) DescribeTdmqProInstancesByFilter(ctx context.Context, param map[string]interface{}) (proInstances []*tdmq.PulsarProInstance, errRet error)

func (*TdmqService) DescribeTdmqProfessionalClusterById 

func (me *TdmqService) DescribeTdmqProfessionalClusterById(ctx context.Context, clusterId string) (professionalCluster *tdmq.PulsarProClusterInfo, errRet error)

func (*TdmqService) DescribeTdmqPublisherSummaryByFilter 

func (me *TdmqService) DescribeTdmqPublisherSummaryByFilter(ctx context.Context, param map[string]interface{}) (publisherSummary *tdmq.DescribePublisherSummaryResponseParams, errRet error)

func (*TdmqService) DescribeTdmqPublishersByFilter 

func (me *TdmqService) DescribeTdmqPublishersByFilter(ctx context.Context, param map[string]interface{}) (publishers []*tdmq.Publisher, errRet error)

func (*TdmqService) DescribeTdmqRabbitmqNodeListByFilter 

func (me *TdmqService) DescribeTdmqRabbitmqNodeListByFilter(ctx context.Context, param map[string]interface{}) (rabbitmqNodeList []*tdmq.RabbitMQPrivateNode, errRet error)

func (*TdmqService) DescribeTdmqRabbitmqUserById 

func (me *TdmqService) DescribeTdmqRabbitmqUserById(ctx context.Context, instanceId, user string) (rabbitmqUser *tdmq.RabbitMQUser, errRet error)

func (*TdmqService) DescribeTdmqRabbitmqVipInstanceByFilter 

func (me *TdmqService) DescribeTdmqRabbitmqVipInstanceByFilter(ctx context.Context, param map[string]interface{}) (rabbitmqVipInstance []*tdmq.RabbitMQVipInstance, errRet error)

func (*TdmqService) DescribeTdmqRabbitmqVipInstanceById 

func (me *TdmqService) DescribeTdmqRabbitmqVipInstanceById(ctx context.Context, instanceId string) (rabbitmqVipInstance *tdmq.DescribeRabbitMQVipInstanceResponseParams, errRet error)

func (*TdmqService) DescribeTdmqRabbitmqVirtualHostById 

func (me *TdmqService) DescribeTdmqRabbitmqVirtualHostById(ctx context.Context, instanceId, virtualHost string) (rabbitmqVirtualHost *tdmq.RabbitMQVirtualHostInfo, errRet error)

func (*TdmqService) DescribeTdmqRabbitmqVirtualHostListByFilter 

func (me *TdmqService) DescribeTdmqRabbitmqVirtualHostListByFilter(ctx context.Context, param map[string]interface{}) (rabbitmqVirtualHostList []*tdmq.RabbitMQPrivateVirtualHost, errRet error)

func (*TdmqService) DescribeTdmqRocketmqVipInstanceById 

func (me *TdmqService) DescribeTdmqRocketmqVipInstanceById(ctx context.Context, clusterId string) (rocketmqVipInstanceDetail *tdmq.DescribeRocketMQVipInstanceDetailResponseParams, errRet error)

func (*TdmqService) DescribeTdmqRocketmqVipInstancesByFilter 

func (me *TdmqService) DescribeTdmqRocketmqVipInstancesByFilter(ctx context.Context, clusterId string) (rocketmqVipInstances *tdmq.RocketMQVipInstance, errRet error)

func (*TdmqService) DescribeTdmqRoleById 

func (me *TdmqService) DescribeTdmqRoleById(ctx context.Context,
	roleName string, clusterId string) (info *tdmq.Role, has bool, errRet error)

func (*TdmqService) DescribeTdmqSubscriptionAttachmentById 

func (me *TdmqService) DescribeTdmqSubscriptionAttachmentById(ctx context.Context, environmentId, Topic, subscriptionName, clusterId string) (subscriptionAttachment *tdmq.Subscription, errRet error)

func (*TdmqService) DescribeTdmqSubscriptionById added in v1.81.64 

func (me *TdmqService) DescribeTdmqSubscriptionById(ctx context.Context, clusterId, environmentId, topicName, subscriptionName string) (subscriptionAttachment *tdmq.Subscription, errRet error)

func (*TdmqService) DescribeTdmqTopicById 

func (me *TdmqService) DescribeTdmqTopicById(ctx context.Context,
	environId string, topicName string, clusterId string) (info *tdmq.Topic, has bool, errRet error)

func (*TdmqService) DescribeTdmqVipInstanceByFilter 

func (me *TdmqService) DescribeTdmqVipInstanceByFilter(ctx context.Context, param map[string]interface{}) (vipInstance *tdmq.DescribeRocketMQVipInstanceDetailResponseParams, errRet error)

func (*TdmqService) GetTdmqTopicsAttachmentById 

func (me *TdmqService) GetTdmqTopicsAttachmentById(ctx context.Context, environmentId, Topic, subscriptionName, clusterId string) (has bool, errRet error)

func (*TdmqService) ModifyTdmqInstanceAttribute 

func (me *TdmqService) ModifyTdmqInstanceAttribute(ctx context.Context, clusterId, clusterName string,
	remark string) (errRet error)

func (*TdmqService) ModifyTdmqNamespaceAttribute 

func (me *TdmqService) ModifyTdmqNamespaceAttribute(ctx context.Context, environId string, msgTtl uint64,
	remark string, clusterId string, retentionPolicy *tdmq.RetentionPolicy) (errRet error)

func (*TdmqService) ModifyTdmqNamespaceRoleAttachment 

func (me *TdmqService) ModifyTdmqNamespaceRoleAttachment(ctx context.Context,
	environId string, roleName string, permissions []*string, clusterId string) (errRet error)

func (*TdmqService) ModifyTdmqRoleAttribute 

func (me *TdmqService) ModifyTdmqRoleAttribute(ctx context.Context, roleName string, clusterId string,
	remark string) (errRet error)

func (*TdmqService) ModifyTdmqTopicAttribute 

func (me *TdmqService) ModifyTdmqTopicAttribute(ctx context.Context, environId string, topicName string,
	partitions uint64, remark string, clusterId string) (errRet error)

func (*TdmqService) TdmqProfessionalClusterStateRefreshFunc 

func (me *TdmqService) TdmqProfessionalClusterStateRefreshFunc(clusterId string, failStates []string) resource.StateRefreshFunc

Source Files

View all Source files

Jump to

Keyboard shortcuts

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