dms

package
v1.64.1 Latest Latest
Warning

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

 Go to latest Published: May 6, 2024 License: MPL-2.0 Imports: 33 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	InstanceTypeSingle  InstanceType = "single"
	InstanceTypeCluster InstanceType = "cluster"

	ChargingModePrePaid  ChargingMode = "prePaid"
	ChargingModePostPaid ChargingMode = "postPaid"

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

Functions

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 DataSourceDmsKafkaSmartConnectTasks added in v1.60.0 

func DataSourceDmsKafkaSmartConnectTasks() *schema.Resource

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

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 DataSourceDmsRabbitmqPlugins added in v1.61.0 

func DataSourceDmsRabbitmqPlugins() *schema.Resource

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

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 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 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 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 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 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 @API Kafka GET /v2/{project_id}/instances/{instance_id}

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

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

type InstanceType added in v1.38.1 

type InstanceType string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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