chore(kafka): add new creation api and support the port_protocol parameter (#741)

Author: wuzhuanhong

openstack/dms/v2/kafka/instances/requests.go

@@ -150,6 +150,9 @@ type CreateOps struct {
 
 	// Indicates the parameter related to the yearly/monthly billing mode.
 	BssParam BssParam `json:"bss_param,omitempty"`
+
+	// The access mode of the Kafka instance.
+	PortProtocol *PortProtocol `json:"port_protocol,omitempty"`
 }
 
 type BssParam struct {
@@ -169,6 +172,39 @@ type BssParam struct {
 	IsAutoPay *bool `json:"is_auto_pay,omitempty"`
 }
 
+type PortProtocol struct {
+	// Whether to enable private plaintext access. Default to `false`.
+	// + true: Enable private plaintext access. Connection address: ip:9092, access protocol: PLAINTEXT.
+	// + false: Disable private plaintext access.
+	PrivatePlainEnable *bool `json:"private_plain_enable,omitempty"`
+
+	// Whether to enable private ciphertext access mode with the SASL_SSL security protocol. Default to `false`.
+	// `private_sasl_ssl_enable` and `private_sasl_plaintext_enable` cannot be set to `true` at the same time.
+	PrivateSaslSslEnable *bool `json:"private_sasl_ssl_enable,omitempty"`
+
+	// Whether to enable private SASL plaintext access. Default to `false`.
+	// Connection address: ip:9093, access protocol: SASL_PLAINTEXT.
+	// `private_sasl_plaintext_enable` and `private_sasl_ssl_enable` cannot be set to `true` at the same time.
+	PrivateSaslPlaintextEnable *bool `json:"private_sasl_plaintext_enable,omitempty"`
+
+	// Whether to enable public plaintext access. Default to `false`.
+	// Before enabling public plaintext access, you must enable public network access.
+	// Connection address: ip:9094, access protocol: PLAINTEXT.
+	PublicPlainEnable *bool `json:"public_plain_enable,omitempty"`
+
+	// Whether to enable public SASL SSL access. Default to `false`.
+	// Connection address: ip:9095, access protocol: SASL_SSL.
+	// `public_sasl_ssl_enable` and `public_sasl_plaintext_enable` cannot be set to `true` at the same time.
+	// When this parameter is set to `true`, the instance must be enabled for public network access.
+	PublicSaslSslEnable *bool `json:"public_sasl_ssl_enable,omitempty"`
+
+	// Whether to enable public SASL plaintext access. Default to `false`.
+	// Connection address: ip:9095, access protocol: SASL_PLAINTEXT.
+	// `public_sasl_plaintext_enable` and `public_sasl_ssl_enable` cannot be set to `true` at the same time.
+	// When this parameter is set to `true`, the instance must be enabled for public network access.
+	PublicSaslPlaintextEnable *bool `json:"public_sasl_plaintext_enable,omitempty"`
+}
+
 // ToInstanceCreateMap is used for type convert
 func (ops CreateOps) ToInstanceCreateMap() (map[string]interface{}, error) {
 	return golangsdk.BuildRequestBody(ops, "")
@@ -189,6 +225,20 @@ func Create(client *golangsdk.ServiceClient, ops CreateOpsBuilder) (r CreateResu
 	return
 }
 
+func CreateWithEngine(client *golangsdk.ServiceClient, ops CreateOpsBuilder, engine string) (r CreateResult) {
+	b, err := ops.ToInstanceCreateMap()
+	if err != nil {
+		r.Err = err
+		return
+	}
+
+	_, r.Err = client.Post(createURLWithEngine(engine, client), b, &r.Body, &golangsdk.RequestOpts{
+		OkCodes: []int{200},
+	})
+
+	return
+}
+
 // Delete an instance by id
 func Delete(client *golangsdk.ServiceClient, id string) (r DeleteResult) {
 	_, r.Err = client.Delete(deleteURL(client, id), &golangsdk.RequestOpts{

openstack/dms/v2/kafka/instances/urls.go

@@ -10,6 +10,10 @@ func createURL(client *golangsdk.ServiceClient) string {
 	return client.ServiceURL(client.ProjectID, resourcePath)
 }
 
+func createURLWithEngine(engine string, client *golangsdk.ServiceClient) string {
+	return client.ServiceURL(engine, client.ProjectID, resourcePath)
+}
+
 // deleteURL will build the url of deletion
 func deleteURL(client *golangsdk.ServiceClient, id string) string {
 	return client.ServiceURL(client.ProjectID, resourcePath, id)