dms

package
v1.70.0 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2024 License: MPL-2.0 Imports: 36 Imported by: 5

Documentation

Overview

Generated by PMS #199

Generated by PMS #205

Generated by PMS #389

Generated by PMS #197

Generated by PMS #204

Generated by PMS #203

Generated by PMS #231

Generated by PMS #259

Generated by PMS #178

Generated by PMS #259

Generated by PMS #379

Generated by PMS #252

Generated by PMS #195

Generated by PMS #188

Generated by PMS #198

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DataSourceDmsKafkaConsumerGroups added in v1.65.1 

func DataSourceDmsKafkaConsumerGroups() *schema.Resource

@API Kafka GET /v2/{project_id}/instances/{instance_id}/groups

func DataSourceDmsKafkaExtendFlavors added in v1.65.2 

func DataSourceDmsKafkaExtendFlavors() *schema.Resource

func DataSourceDmsKafkaInstances added in v1.37.0 

func DataSourceDmsKafkaInstances() *schema.Resource

@API Kafka GET /v2/{project_id}/instances @API Kafka GET /v2/available-zones

func DataSourceDmsKafkaMessageDiagnosisTasks added in v1.70.0 

func DataSourceDmsKafkaMessageDiagnosisTasks() *schema.Resource

func DataSourceDmsKafkaSmartConnectTasks added in v1.60.0 

func DataSourceDmsKafkaSmartConnectTasks() *schema.Resource

@API Kafka GET /v2/{project_id}/connectors/{connector_id}/sink-tasks

func DataSourceDmsKafkaTopics added in v1.65.1 

func DataSourceDmsKafkaTopics() *schema.Resource

func DataSourceDmsKafkaUserClientQuotas added in v1.65.2 

func DataSourceDmsKafkaUserClientQuotas() *schema.Resource

@API Kafka GET /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota

func DataSourceDmsKafkaUsers added in v1.65.2 

func DataSourceDmsKafkaUsers() *schema.Resource

func DataSourceDmsKafkav2SmartConnectTasks added in v1.66.0 

func DataSourceDmsKafkav2SmartConnectTasks() *schema.Resource

func DataSourceDmsMaintainWindow 

func DataSourceDmsMaintainWindow() *schema.Resource

@API DMS GET /v2/instances/maintain-windows

func DataSourceDmsProduct 

func DataSourceDmsProduct() *schema.Resource

@API DMS GET /v2/products

func DataSourceDmsRabbitMQInstances added in v1.61.0 

func DataSourceDmsRabbitMQInstances() *schema.Resource

@API RabbitMQ GET /v2/{project_id}/instances

func DataSourceDmsRabbitmqExchanges added in v1.67.0 

func DataSourceDmsRabbitmqExchanges() *schema.Resource

@API RabbitMQ GET /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/exchanges

func DataSourceDmsRabbitmqExtendFlavors added in v1.65.0 

func DataSourceDmsRabbitmqExtendFlavors() *schema.Resource

func DataSourceDmsRabbitmqPlugins added in v1.61.0 

func DataSourceDmsRabbitmqPlugins() *schema.Resource

@API RabbitMQ GET /v2/{project_id}/instances/{instance_id}/rabbitmq/plugins

func DataSourceDmsRabbitmqQueues added in v1.68.1 

func DataSourceDmsRabbitmqQueues() *schema.Resource

@API RabbitMQ GET /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/queues

func DataSourceDmsRabbitmqUsers added in v1.70.0 

func DataSourceDmsRabbitmqUsers() *schema.Resource

func DataSourceDmsRabbitmqVhosts added in v1.67.0 

func DataSourceDmsRabbitmqVhosts() *schema.Resource

@API RabbitMQ GET /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts

func DataSourceDmsRocketMQBroker added in v1.44.1 

func DataSourceDmsRocketMQBroker() *schema.Resource

@API RocketMQ GET /v2/{project_id}/instances/{instance_id}/brokers

func DataSourceDmsRocketMQConsumerGroups added in v1.58.0 

func DataSourceDmsRocketMQConsumerGroups() *schema.Resource

@API RocketMQ GET /v2/{project_id}/instances/{instance_id}/groups

func DataSourceDmsRocketMQInstances added in v1.44.1 

func DataSourceDmsRocketMQInstances() *schema.Resource

@API RocketMQ GET /v2/{project_id}/instances @API RocketMQ GET /v2/available-zones

func DataSourceDmsRocketMQTopics added in v1.58.0 

func DataSourceDmsRocketMQTopics() *schema.Resource

@API RocketMQ GET /v2/{project_id}/instances/{instance_id}/topics

func DataSourceDmsRocketMQUsers added in v1.58.0 

func DataSourceDmsRocketMQUsers() *schema.Resource

@API RocketMQ GET /v2/{project_id}/instances/{instance_id}/users

func DataSourceDmsRocketmqExtendFlavors added in v1.65.1 

func DataSourceDmsRocketmqExtendFlavors() *schema.Resource

func DataSourceDmsRocketmqMigrationTasks added in v1.65.1 

func DataSourceDmsRocketmqMigrationTasks() *schema.Resource

func DataSourceDmsRocketmqTopicConsumerGroups added in v1.65.1 

func DataSourceDmsRocketmqTopicConsumerGroups() *schema.Resource

func DataSourceKafkaFlavors added in v1.38.1 

func DataSourceKafkaFlavors() *schema.Resource

@API Kafka GET /v2/{engine}/products

func DataSourceRabbitMQFlavors added in v1.47.0 

func DataSourceRabbitMQFlavors() *schema.Resource

@API RabbitMQ GET /v2/{engine}/products

func DataSourceRocketMQFlavors added in v1.61.0 

func DataSourceRocketMQFlavors() *schema.Resource

@API RocketMQ GET /v2/{engine}/products

func GetKafkaMessageDiagnosisTaskReport added in v1.70.0 

func GetKafkaMessageDiagnosisTaskReport(client *golangsdk.ServiceClient, instanceID, reportID string) (interface{}, error)

func GetRabbitmqExchange added in v1.67.0 

func GetRabbitmqExchange(client *golangsdk.ServiceClient, instanceID, vhost, name string) (interface{}, error)

func GetRabbitmqQueue added in v1.69.0 

func GetRabbitmqQueue(client *golangsdk.ServiceClient, instanceID, vhost, name string) (interface{}, error)

func GetRabbitmqUser added in v1.70.0 

func GetRabbitmqUser(client *golangsdk.ServiceClient, instanceID, accessKey string) (interface{}, error)

func GetRabbitmqVhost added in v1.67.0 

func GetRabbitmqVhost(client *golangsdk.ServiceClient, instanceID, name string) (interface{}, error)

func KafkaInstanceStateRefreshFunc added in v1.44.2 

func KafkaInstanceStateRefreshFunc(client *golangsdk.ServiceClient, instanceID string) resource.StateRefreshFunc

func ResourceDmsKafkaConsumerGroup added in v1.58.0 

func ResourceDmsKafkaConsumerGroup() *schema.Resource

@API Kafka POST /v2/{project_id}/kafka/instances/{instance_id}/group @API Kafka PUT /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group} @API Kafka GET /v2/{project_id}/instances/{instance_id}/groups/{group} @API Kafka POST /v2/{project_id}/instances/{instance_id}/groups/batch-delete

func ResourceDmsKafkaInstance 

func ResourceDmsKafkaInstance() *schema.Resource

@API Kafka GET /v2/available-zones @API Kafka POST /v2/{project_id}/instances/{instance_id}/crossvpc/modify @API Kafka POST /v2/{project_id}/instances/{instance_id}/extend @API Kafka DELETE /v2/{project_id}/instances/{instance_id} @API Kafka GET /v2/{project_id}/instances/{instance_id} @API Kafka PUT /v2/{project_id}/instances/{instance_id} @API Kafka POST /v2/{project_id}/instances @API Kafka GET /v2/{project_id}/kafka/{instance_id}/tags @API Kafka POST /v2/{project_id}/kafka/{instance_id}/tags/action @API Kafka POST /v2/{project_id}/instances/{instance_id}/autotopic @API Kafka GET /v2/{project_id}/instances/{instance_id}/tasks @API Kafka GET /v2/{project_id}/instances/{instance_id}/tasks/{task_id} @API Kafka POST /v2/{project_id}/instances/{instance_id}/password @API Kafka PUT /v2/{project_id}/instances/{instance_id}/configs @API Kafka GET /v2/{project_id}/instances/{instance_id}/configs @API Kafka POST /v2/{project_id}/instances/action @API BSS GET /v2/orders/customer-orders/details/{order_id} @API BSS POST /v2/orders/subscriptions/resources/autorenew/{instance_id} @API BSS DELETE /v2/orders/subscriptions/resources/autorenew/{instance_id} @API BSS POST /v2/orders/subscriptions/resources/unsubscribe

func ResourceDmsKafkaMessageDiagnosisTask added in v1.70.0 

func ResourceDmsKafkaMessageDiagnosisTask() *schema.Resource

@API Kafka DELETE /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks @API Kafka POST /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks @API Kafka GET /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis/{report_id} @API Kafka GET /v2/{project_id}/kafka/instances/{instance_id}/diagnosis-check @API Kafka GET /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks

func ResourceDmsKafkaPartitionReassign added in v1.67.0 

func ResourceDmsKafkaPartitionReassign() *schema.Resource

@API Kafka POST /v2/kafka/{project_id}/instances/{instance_id}/reassign @API Kafka GET /v2/{project_id}/instances/{instance_id}/tasks/{task_id}

func ResourceDmsKafkaPermissions added in v1.41.0 

func ResourceDmsKafkaPermissions() *schema.Resource

@API Kafka GET /v1/{project_id}/instances/{instance_id}/topics/{topic_name}/accesspolicy @API Kafka POST /v1/{project_id}/instances/{instance_id}/topics/accesspolicy @API Kafka GET /v2/{project_id}/instances/{instance_id}

func ResourceDmsKafkaSmartConnect added in v1.59.0 

func ResourceDmsKafkaSmartConnect() *schema.Resource

@API Kafka POST /v2/{project_id}/instances/{instance_id}/connector @API Kafka GET /v2/{project_id}/instances/{instance_id} @API Kafka POST /v2/{project_id}/kafka/instances/{instance_id}/delete-connector

func ResourceDmsKafkaSmartConnectTask added in v1.59.1 

func ResourceDmsKafkaSmartConnectTask() *schema.Resource

@API Kafka POST /v2/{project_id}/connectors/{connector_id}/sink-tasks @API Kafka GET /v2/{project_id}/connectors/{connector_id}/sink-tasks @API Kafka DELETE /v2/{project_id}/connectors/{connector_id}/sink-tasks/{task_id}

func ResourceDmsKafkaSmartConnectTaskAction added in v1.66.0 

func ResourceDmsKafkaSmartConnectTaskAction() *schema.Resource

@API Kafka PUT /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/pause @API Kafka PUT /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/resume @API Kafka PUT /v2/{project_id}/kafka/instances/{instance_id}/connector/tasks/{task_id}/restart @API Kafka GET /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}

func ResourceDmsKafkaTopic 

func ResourceDmsKafkaTopic() *schema.Resource

ResourceDmsKafkaTopic implements the resource of "huaweicloud_dms_kafka_topic" @API Kafka POST /v2/{project_id}/instances/{instance_id}/topics/delete @API Kafka GET /v2/{project_id}/instances/{instance_id}/topics @API Kafka POST /v2/{project_id}/instances/{instance_id}/topics @API Kafka PUT /v2/{project_id}/instances/{instance_id}/topics

func ResourceDmsKafkaUser added in v1.41.0 

func ResourceDmsKafkaUser() *schema.Resource

@API Kafka PUT /v2/{engine}/{project_id}/instances/{instance_id}/users/{user_name} @API Kafka GET /v2/{project_id}/instances/{instance_id}/users @API Kafka POST /v2/{project_id}/instances/{instance_id}/users @API Kafka PUT /v2/{project_id}/instances/{instance_id}/users

func ResourceDmsKafkaUserClientQuota added in v1.60.0 

func ResourceDmsKafkaUserClientQuota() *schema.Resource

@API Kafka POST /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota @API Kafka PUT /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota @API Kafka GET /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota @API Kafka DELETE /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota @API Kafka GET /v2/{project_id}/instances/{instance_id}/tasks/{task_id} @API Kafka GET /v2/{project_id}/instances/{instance_id}

func ResourceDmsKafkav2SmartConnectTask added in v1.66.0 

func ResourceDmsKafkav2SmartConnectTask() *schema.Resource

@API Kafka POST /v2/{project_id}/instances/{instance_id}/connector/tasks @API Kafka GET /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id} @API Kafka DELETE /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}

func ResourceDmsRabbitmqExchange added in v1.67.0 

func ResourceDmsRabbitmqExchange() *schema.Resource

@API RabbitMQ PUT /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/exchanges @API RabbitMQ POST /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/exchanges @API RabbitMQ GET /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/exchanges @API RabbitMQ GET /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/exchanges/{exchange}/binding

func ResourceDmsRabbitmqExchangeAssociate added in v1.69.0 

func ResourceDmsRabbitmqExchangeAssociate() *schema.Resource

func ResourceDmsRabbitmqInstance 

func ResourceDmsRabbitmqInstance() *schema.Resource

@API RabbitMQ POST /v2/{engine}/{project_id}/instances @API RabbitMQ POST /v2/{project_id}/instances @API RabbitMQ POST /v2/{engine}/{project_id}/instances/{instance_id}/extend @API RabbitMQ DELETE /v2/{project_id}/instances/{instance_id} @API RabbitMQ GET /v2/{project_id}/instances/{instance_id} @API RabbitMQ PUT /v2/{project_id}/instances/{instance_id} @API RabbitMQ GET /v2/{project_id}/rabbitmq/{instance_id}/tags @API RabbitMQ POST /v2/{project_id}/rabbitmq/{instance_id}/tags/action @API RabbitMQ GET /v2/available-zones @API RabbitMQ GET /v2/products @API RabbitMQ POST /v2/{project_id}/instances/{instance_id}/password @API BSS POST /v2/orders/suscriptions/resources/query @API BSS GET /v2/orders/customer-orders/details/{order_id} @API BSS POST /v2/orders/subscriptions/resources/unsubscribe

func ResourceDmsRabbitmqPlugin added in v1.61.0 

func ResourceDmsRabbitmqPlugin() *schema.Resource

@API RabbitMQ PUT /v2/{project_id}/instances/{instance_id}/rabbitmq/plugins @API RabbitMQ GET /v2/{project_id}/instances/{instance_id}/rabbitmq/plugins @API RabbitMQ GET /v2/{project_id}/instances/{instance_id} @API RabbitMQ GET /v2/{project_id}/instances/{instance_id}/tasks/{task_id}

func ResourceDmsRabbitmqQueue added in v1.68.1 

func ResourceDmsRabbitmqQueue() *schema.Resource

@API RabbitMQ PUT /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/queues @API RabbitMQ POST /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/queues @API RabbitMQ GET /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/queues/{queue}

func ResourceDmsRabbitmqQueueMessageClear added in v1.69.0 

func ResourceDmsRabbitmqQueueMessageClear() *schema.Resource

@API RabbitMQ DELETE /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/queues/{queue}/contents

func ResourceDmsRabbitmqUser added in v1.70.0 

func ResourceDmsRabbitmqUser() *schema.Resource

@API RabbitMQ PUT /v2/{project_id}/instances/{instance_id}/users/{user_name} @API RabbitMQ POST /v2/{project_id}/instances/{instance_id}/users @API RabbitMQ GET /v2/{project_id}/instances/{instance_id}/users @API RabbitMQ DELETE /v2/{project_id}/instances/{instance_id}/users/{user_name}

func ResourceDmsRabbitmqVhost added in v1.67.0 

func ResourceDmsRabbitmqVhost() *schema.Resource

@API RabbitMQ PUT /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts @API RabbitMQ POST /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts @API RabbitMQ GET /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts

func ResourceDmsRocketMQConsumerGroup added in v1.44.0 

func ResourceDmsRocketMQConsumerGroup() *schema.Resource

@API RocketMQ POST /v2/{project_id}/instances/{instance_id}/groups @API RocketMQ DELETE /v2/{project_id}/instances/{instance_id}/groups/{group} @API RocketMQ GET /v2/{project_id}/instances/{instance_id}/groups/{group} @API RocketMQ PUT /v2/{project_id}/instances/{instance_id}/groups/{group}

func ResourceDmsRocketMQInstance added in v1.43.0 

func ResourceDmsRocketMQInstance() *schema.Resource

@API RocketMQ POST /v2/{engine}/{project_id}/instances @API RocketMQ PUT /v2/{project_id}/instances/{instance_id} @API RocketMQ GET /v2/{project_id}/instances/{instance_id} @API RocketMQ DELETE /v2/{project_id}/instances/{instance_id} @API RocketMQ POST /v2/{project_id}/rocketmq/{instance_id}/tags/action @API RocketMQ GET /v2/{project_id}/rocketmq/{instance_id}/tags @API RocketMQ POST /v2/{project_id}/instances/{instance_id}/crossvpc/modify @API RocketMQ GET /v2/{project_id}/instances/{instance_id}/tasks @API RocketMQ POST /v2/{engine}/{project_id}/instances/{instance_id}/extend @API RocketMQ PUT /v2/{project_id}/rocketmq/instances/{instance_id}/configs @API RocketMQ GET /v2/{project_id}/rocketmq/instances/{instance_id}/configs @API EIP GET /v1/{project_id}/publicips @API BSS GET /v2/orders/customer-orders/details/{order_id} @API BSS POST /v2/orders/subscriptions/resources/autorenew/{instance_id} @API BSS DELETE /v2/orders/subscriptions/resources/autorenew/{instance_id} @API BSS POST /v2/orders/subscriptions/resources/unsubscribe

func ResourceDmsRocketMQTopic added in v1.44.0 

func ResourceDmsRocketMQTopic() *schema.Resource

@API RocketMQ POST /v2/{project_id}/instances/{instance_id}/topics @API RocketMQ DELETE /v2/{project_id}/instances/{instance_id}/topics/{topic} @API RocketMQ GET /v2/{project_id}/instances/{instance_id}/topics/{topic} @API RocketMQ PUT /v2/{project_id}/instances/{instance_id}/topics/{topic}

func ResourceDmsRocketMQUser added in v1.44.1 

func ResourceDmsRocketMQUser() *schema.Resource

@API RocketMQ POST /v2/{project_id}/instances/{instance_id}/users @API RocketMQ DELETE /v2/{project_id}/instances/{instance_id}/users/{user_name} @API RocketMQ GET /v2/{project_id}/instances/{instance_id}/users/{user_name} @API RocketMQ PUT /v2/{project_id}/instances/{instance_id}/users/{user_name}

func ResourceDmsRocketmqMigrationTask added in v1.62.0 

func ResourceDmsRocketmqMigrationTask() *schema.Resource

@API RocketMQ POST /v2/{project_id}/instances/{instance_id}/metadata @API RocketMQ GET /v2/{project_id}/instances/{instance_id}/metadata @API RocketMQ DELETE /v2/{project_id}/instances/{instance_id}/metadata

Types

type ChargingMode added in v1.38.1 

type ChargingMode string
var (
	ChargingModePrePaid  ChargingMode = "prePaid"
	ChargingModePostPaid ChargingMode = "postPaid"

	ChargingModesMap map[string]ChargingMode = map[string]ChargingMode{
		"hourly":  ChargingModePrePaid,
		"monthly": ChargingModePostPaid,
	}
)

type KafkaExtendFlavorsDSWrapper added in v1.65.2 

type KafkaExtendFlavorsDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*KafkaExtendFlavorsDSWrapper) ShowEngineInstanceExtendProductInfo added in v1.65.2 

func (w *KafkaExtendFlavorsDSWrapper) ShowEngineInstanceExtendProductInfo() (*gjson.Result, error)

@API Kafka GET /v2/{engine}/{project_id}/instances/{instance_id}/extend

type KafkaMessageDiagnosisTasksDSWrapper added in v1.70.0 

type KafkaMessageDiagnosisTasksDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*KafkaMessageDiagnosisTasksDSWrapper) ListMessageDiagnosisReports added in v1.70.0 

func (w *KafkaMessageDiagnosisTasksDSWrapper) ListMessageDiagnosisReports() (*gjson.Result, error)

@API Kafka GET /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks

type KafkaTopicsDSWrapper added in v1.65.1 

type KafkaTopicsDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*KafkaTopicsDSWrapper) ListInstanceTopics added in v1.65.1 

func (w *KafkaTopicsDSWrapper) ListInstanceTopics() (*gjson.Result, error)

@API Kafka GET /v2/{project_id}/instances/{instance_id}/topics

type KafkaUsersDSWrapper added in v1.65.2 

type KafkaUsersDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*KafkaUsersDSWrapper) ShowInstanceUsers added in v1.65.2 

func (w *KafkaUsersDSWrapper) ShowInstanceUsers() (*gjson.Result, error)

@API Kafka GET /v2/{project_id}/instances/{instance_id}/users

type Kafkav2SmartConnectTasksDSWrapper added in v1.66.0 

type Kafkav2SmartConnectTasksDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*Kafkav2SmartConnectTasksDSWrapper) ListConnectorTasks added in v1.66.0 

func (w *Kafkav2SmartConnectTasksDSWrapper) ListConnectorTasks() (*gjson.Result, error)

@API Kafka GET /v2/{project_id}/instances/{instance_id}/connector/tasks

type RabbitmqExtendFlavorsDSWrapper added in v1.65.0 

type RabbitmqExtendFlavorsDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*RabbitmqExtendFlavorsDSWrapper) ShowEngineInstanceExtendProductInfo added in v1.65.0 

func (w *RabbitmqExtendFlavorsDSWrapper) ShowEngineInstanceExtendProductInfo() (*gjson.Result, error)

@API RabbitMQ GET /v2/{engine}/{project_id}/instances/{instance_id}/extend

type RabbitmqUsersDSWrapper added in v1.70.0 

type RabbitmqUsersDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*RabbitmqUsersDSWrapper) ListUser added in v1.70.0 

func (w *RabbitmqUsersDSWrapper) ListUser() (*gjson.Result, error)

@API RabbitMQ GET /v2/{project_id}/instances/{instance_id}/users

type RocketmqExtendFlavorsDSWrapper added in v1.65.1 

type RocketmqExtendFlavorsDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*RocketmqExtendFlavorsDSWrapper) ShowEngineInstanceExtendProductInfo added in v1.65.1 

func (w *RocketmqExtendFlavorsDSWrapper) ShowEngineInstanceExtendProductInfo() (*gjson.Result, error)

@API RocketMQ GET /v2/{engine}/{project_id}/instances/{instance_id}/extend

type RocketmqMigrationTasksDSWrapper added in v1.65.1 

type RocketmqMigrationTasksDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*RocketmqMigrationTasksDSWrapper) ListRocketMqMigrationTask added in v1.65.1 

func (w *RocketmqMigrationTasksDSWrapper) ListRocketMqMigrationTask() (*gjson.Result, error)

@API RocketMQ GET /v2/{project_id}/instances/{instance_id}/metadata

type RocketmqTopicConsumerGroupsDSWrapper added in v1.65.1 

type RocketmqTopicConsumerGroupsDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*RocketmqTopicConsumerGroupsDSWrapper) ListConsumerGroupOfTopic added in v1.65.1 

func (w *RocketmqTopicConsumerGroupsDSWrapper) ListConsumerGroupOfTopic() (*gjson.Result, error)

@API RocketMQ GET /v2/{project_id}/instances/{instance_id}/topics/{topic}/groups

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.