Skip to content
This repository was archived by the owner on Aug 31, 2021. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 6 additions & 0 deletions openstack/dms/v1/groups/results.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,12 @@ type Group struct {
AvailableDeadletters int `json:"available_deadletters"`
}

type Groups struct {
QueueId string `json:"queue_id"`
QueueName string `json:"queue_name"`
Details []Group `json:"groups"`
}

// GroupPage may be embedded in a Page
// that contains all of the results from an operation at once.
type GroupPage struct {
Expand Down
19 changes: 17 additions & 2 deletions openstack/dms/v1/instances/requests.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,12 +40,12 @@ type CreateOps struct {
// Uppercase letters
// Digits
// Special characters (`~!@#$%^&*()-_=+\|[{}]:'",<.>/?)
Password string `json:"password" required:"true"`
Password string `json:"password,omitempty"`

// Indicates a username.
// A username consists of 1 to 64 characters
// and supports only letters, digits, and hyphens (-).
AccessUser string `json:"access_user" required:"true"`
AccessUser string `json:"access_user,omitempty"`

// Indicates the ID of a VPC.
VPCID string `json:"vpc_id" required:"true"`
Expand All @@ -70,6 +70,21 @@ type CreateOps struct {
// Indicates the time at which a maintenance time window ends.
// Format: HH:mm:ss
MaintainEnd string `json:"maintain_end,omitempty"`

//This parameter is mandatory when a Kafka instance is created.
//Indicates the maximum number of topics in a Kafka instance.
PartitionNum int `json:"partition_num,omitempty"`

//Indicates whether to enable SSL-encrypted access.
SslEnable bool `json:"ssl_enable"`

//This parameter is mandatory if the engine is kafka.
//Indicates the baseline bandwidth of a Kafka instance, that is,
//the maximum amount of data transferred per unit time. Unit: byte/s.
Specification string `json:"specification,omitempty"`

//Indicates the storage I/O specification. For details on how to select a disk type
StorageSpecCode string `json:"storage_spec_code,omitempty"`
}

// ToInstanceCreateMap is used for type convert
Expand Down
9 changes: 9 additions & 0 deletions openstack/dms/v1/products/results.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ type Detail struct {
SpecCode string `json:"spec_code"`
VMSpecification string `json:"vm_specification"`
ProductInfos []ProductInfo `json:"product_info"`
PartitionNum string `json:"partition_num"`
Bandwidth string `json:"bandwidth"`
IOs []IO `json:"io"`
}

// ProductInfo for dms
Expand All @@ -38,6 +41,12 @@ type ProductInfo struct {
NodeNum string `json:"node_num"`
ProductID string `json:"product_id"`
SpecCode string `json:"spec_code"`
IOs []IO `json:"io"`
}

type IO struct {
IOType string `json:"io_type"`
StorageSpecCode string `json:"storage_spec_code"`
}

// GetResult contains the body of getting detailed
Expand Down