From 1f696887eb27f2eb9b747b238e4f402fac27d18c Mon Sep 17 00:00:00 2001
From: zhukun <2019229048@tju.edu.cn>
Date: Mon, 20 Nov 2023 17:37:19 +0800
Subject: [PATCH] feat(apig_signature): import apig_signature resource, unit
 teset and docs

---
 docs/data-sources/lb_certificate.md           |  46 ++++++
 docs/data-sources/lb_listeners.md             |  72 +++++++++
 docs/resources/elb_logtank.md                 |  50 +++++++
 ...urce_flexibleengine_lb_certificate_test.go | 104 +++++++++++++
 ...source_flexibleengine_lb_listeners_test.go | 139 ++++++++++++++++++
 ...ource_flexibleengine_lb_logtank_v3_test.go | 129 ++++++++++++++++
 flexibleengine/provider.go                    |  16 +-
 7 files changed, 549 insertions(+), 7 deletions(-)
 create mode 100644 docs/data-sources/lb_certificate.md
 create mode 100644 docs/data-sources/lb_listeners.md
 create mode 100644 docs/resources/elb_logtank.md
 create mode 100644 flexibleengine/acceptance/data_source_flexibleengine_lb_certificate_test.go
 create mode 100644 flexibleengine/acceptance/data_source_flexibleengine_lb_listeners_test.go
 create mode 100644 flexibleengine/acceptance/resource_flexibleengine_lb_logtank_v3_test.go

diff --git a/docs/data-sources/lb_certificate.md b/docs/data-sources/lb_certificate.md
new file mode 100644
index 00000000..0fd1ab16
--- /dev/null
+++ b/docs/data-sources/lb_certificate.md
@@ -0,0 +1,46 @@
+---
+subcategory: "Elastic Load Balance (ELB)"
+---
+
+# flexibleengine_lb_certificate
+
+Use this data source to get the certificates in FlexibleEngine Elastic Load Balance (ELB).
+
+## Example Usage
+
+```hcl
+variable "certificate_name" {}
+
+data "flexibleengine_lb_certificate" "test" {
+  name = var.certificate_name
+  type = "server"
+}
+```
+
+## Argument Reference
+
+The following arguments are supported:
+
+* `region` - (Optional, String) The region in which to obtain the ELB certificate. If omitted, the provider-level region
+  will be used.
+
+* `type` - (Optional, String) Specifies the certificate type. The default value is `server`. The value can be one of the
+  following:
+  + `server`: indicates the server certificate.
+  + `client`: indicates the CA certificate.
+
+* `name` - (Required, String) The name of certificate. The value is case sensitive and does not supports fuzzy matching.
+
+  -> **NOTE:** The certificate name is not unique. Only returns the last created one when matched multiple certificates.
+
+## Attribute Reference
+
+In addition to all arguments above, the following attributes are exported:
+
+* `id` - The certificate ID in UUID format.
+
+* `domain` - The domain of the Certificate. This parameter is valid only when `type` is "server".
+
+* `description` - Human-readable description for the Certificate.
+
+* `expiration` - Indicates the time when the certificate expires.
diff --git a/docs/data-sources/lb_listeners.md b/docs/data-sources/lb_listeners.md
new file mode 100644
index 00000000..fbdc48ab
--- /dev/null
+++ b/docs/data-sources/lb_listeners.md
@@ -0,0 +1,72 @@
+---
+subcategory: "Elastic Load Balance (ELB)"
+---
+
+# flexibleengine_lb_listeners
+
+Use this data source to query the list of ELB listeners.
+
+## Example Usage
+
+```hcl
+variable "protocol" {}
+
+data "flexibleengine_lb_listeners" "test" {
+  protocol  = var.protocol
+}
+```
+
+## Argument Reference
+
+The following arguments are supported:
+
+* `region` - (Optional, String) Specifies the region in which to query the data source.
+  If omitted, the provider-level region will be used.
+
+* `name` - (Optional, String) The listener name.
+
+* `protocol` - (Optional, String) The listener protocol.  
+  The valid values are **TCP**, **UDP**, **HTTP** and **TERMINATED_HTTPS**.
+
+* `protocol_port` - (Optional, String) The front-end listening port of the listener.  
+  The valid value is range from `1` to `65535`.
+
+## Attribute Reference
+
+In addition to all arguments above, the following attributes are exported:
+
+* `id` - The resource ID.
+
+* `listeners` - Listener list.
+The [listeners](#listeners_listeners) structure is documented below.
+
+<a name="listeners_listeners"></a>
+The `listeners` block supports:
+
+* `id` - The ELB listener ID.
+
+* `name` - The listener name.
+
+* `protocol` - The listener protocol.
+
+* `protocol_port` - The front-end listening port of the listener.
+
+* `default_pool_id` - The ID of the default pool with which the ELB listener is associated.
+
+* `description` - The description of the ELB listener.
+
+* `connection_limit` - The maximum number of connections allowed for the listener.
+
+* `http2_enable` - Whether the ELB listener uses HTTP/2.
+
+* `default_tls_container_ref` - The ID of the server certificate used by the listener.
+
+* `sni_container_refs` - List of the SNI certificate (server certificates with a domain name) IDs used by the listener.
+
+* `loadbalancers` - Listener list.
+The [loadbalancers](#listeners_loadbalancers) structure is documented below.
+
+<a name="listeners_loadbalancers"></a>
+The `loadbalancers` block supports:
+
+* `id` - The ELB loadbalancer ID.
diff --git a/docs/resources/elb_logtank.md b/docs/resources/elb_logtank.md
new file mode 100644
index 00000000..f67f4d68
--- /dev/null
+++ b/docs/resources/elb_logtank.md
@@ -0,0 +1,50 @@
+---
+subcategory: "Dedicated Load Balance (Dedicated ELB)"
+---
+
+# flexibleengine_elb_logtank
+
+Manage an ELB logtank resource within FlexibleEngine.
+
+## Example Usage
+
+```hcl
+variable "loadbalancer_id" {}
+variable "group_id" {}
+variable "topic_id" {}
+
+resource "flexibleengine_elb_logtank" "test" {
+  loadbalancer_id = var.loadbalancer_id
+  log_group_id    = var.group_id
+  log_topic_id    = var.topic_id
+}
+```
+
+## Argument Reference
+
+The following arguments are supported:
+
+* `region` - (Optional, String, ForceNew) The region in which to create the logtank resource.
+  If omitted, the provider-level region will be used. Changing this creates a new logtank.
+
+* `loadbalancer_id` - (Required, String, ForceNew) Specifies the ID of a loadbalancer. Changing this
+  creates a new logtank.
+
+* `log_group_id` - (Required, String) Specifies the ID of a log group. It is provided by other service.
+
+* `log_topic_id` - (Required, String) Specifies the ID of the subscribe topic.
+
+## Attribute Reference
+
+In addition to all arguments above, the following attributes are exported:
+
+* `id` - The logtank ID.
+
+## Import
+
+ELB logtank can be imported using the logtank ID, e.g.
+
+```bash
+$ terraform import flexibleengine_elb_logtank.test
+2f148a75-acd3-4ce7-8f63-d5c9fadab3a0
+```
diff --git a/flexibleengine/acceptance/data_source_flexibleengine_lb_certificate_test.go b/flexibleengine/acceptance/data_source_flexibleengine_lb_certificate_test.go
new file mode 100644
index 00000000..8df150a8
--- /dev/null
+++ b/flexibleengine/acceptance/data_source_flexibleengine_lb_certificate_test.go
@@ -0,0 +1,104 @@
+package acceptance
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/acctest"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/huaweicloud/terraform-provider-huaweicloud/huaweicloud/services/acceptance"
+)
+
+func TestAccDataSourceLBCertificateV2_basic(t *testing.T) {
+	name := fmt.Sprintf("cert-%s", acctest.RandString(6))
+	dataSourceName := "data.flexibleengine_lb_certificate_v2.cert_1"
+	dc := acceptance.InitDataSourceCheck(dataSourceName)
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:          func() { testAccPreCheck(t) },
+		ProviderFactories: TestAccProviderFactories,
+		Steps: []resource.TestStep{
+			{
+				Config: testAccLBCertificateSourceV2_conf(name),
+				Check: resource.ComposeTestCheckFunc(
+					dc.CheckResourceExists(),
+					resource.TestCheckResourceAttr(dataSourceName, "name", name),
+					resource.TestCheckResourceAttr(dataSourceName, "type", "server"),
+					resource.TestCheckResourceAttrSet(dataSourceName, "domain"),
+					resource.TestCheckResourceAttrSet(dataSourceName, "description"),
+				),
+			},
+		},
+	})
+}
+
+func testAccLBCertificateSourceV2_conf(name string) string {
+	return fmt.Sprintf(`
+data "flexibleengine_lb_certificate_v2" "cert_1" {
+  name = flexibleengine_elb_certificate.certificate_1.name
+
+  depends_on = [flexibleengine_elb_certificate.certificate_1]
+}
+
+resource "flexibleengine_elb_certificate" "certificate_1" {
+  name        = "%s"
+  description = "terraform test certificate"
+  domain      = "www.elb.com"
+  type        = "server"
+  private_key = <<EOT
+-----BEGIN RSA PRIVATE KEY-----
+MIIEowIBAAKCAQEAwZ5UJULAjWr7p6FVwGRQRjFN2s8tZ/6LC3X82fajpVsYqF1x
+qEuUDndDXVD09E4u83MS6HO6a3bIVQDp6/klnYldiE6Vp8HH5BSKaCWKVg8lGWg1
+UM9wZFnlryi14KgmpIFmcu9nA8yV/6MZAe6RSDmb3iyNBmiZ8aZhGw2pI1YwR+15
+MVqFFGB+7ExkziROi7L8CFCyCezK2/oOOvQsH1dzQ8z1JXWdg8/9Zx7Ktvgwu5PQ
+M3cJtSHX6iBPOkMU8Z8TugLlTqQXKZOEgwajwvQ5mf2DPkVgM08XAgaLJcLigwD5
+13koAdtJd5v+9irw+5LAuO3JclqwTvwy7u/YwwIDAQABAoIBACU9S5fjD9/jTMXA
+DRs08A+gGgZUxLn0xk+NAPX3LyB1tfdkCaFB8BccLzO6h3KZuwQOBPv6jkdvEDbx
+Nwyw3eA/9GJsIvKiHc0rejdvyPymaw9I8MA7NbXHaJrY7KpqDQyk6sx+aUTcy5jg
+iMXLWdwXYHhJ/1HVOo603oZyiS6HZeYU089NDUcX+1SJi3e5Ke0gPVXEqCq1O11/
+rh24bMxnwZo4PKBWdcMBN5Zf/4ij9vrZE+fFzW7vGBO48A5lvZxWU2U5t/OZQRtN
+1uLOHmMFa0FIF2aWbTVfwdUWAFsvAOkHj9VV8BXOUwKOUuEktdkfAlvrxmsFrO/H
+yDeYYPkCgYEA/S55CBbR0sMXpSZ56uRn8JHApZJhgkgvYr+FqDlJq/e92nAzf01P
+RoEBUajwrnf1ycevN/SDfbtWzq2XJGqhWdJmtpO16b7KBsC6BdRcH6dnOYh31jgA
+vABMIP3wzI4zSVTyxRE8LDuboytF1mSCeV5tHYPQTZNwrplDnLQhywcCgYEAw8Yc
+Uk/eiFr3hfH/ZohMfV5p82Qp7DNIGRzw8YtVG/3+vNXrAXW1VhugNhQY6L+zLtJC
+aKn84ooup0m3YCg0hvINqJuvzfsuzQgtjTXyaE0cEwsjUusOmiuj09vVx/3U7siK
+Hdjd2ICPCvQ6Q8tdi8jV320gMs05AtaBkZdsiWUCgYEAtLw4Kk4f+xTKDFsrLUNf
+75wcqhWVBiwBp7yQ7UX4EYsJPKZcHMRTk0EEcAbpyaJZE3I44vjp5ReXIHNLMfPs
+uvI34J4Rfot0LN3n7cFrAi2+wpNo+MOBwrNzpRmijGP2uKKrq4JiMjFbKV/6utGF
+Up7VxfwS904JYpqGaZctiIECgYA1A6nZtF0riY6ry/uAdXpZHL8ONNqRZtWoT0kD
+79otSVu5ISiRbaGcXsDExC52oKrSDAgFtbqQUiEOFg09UcXfoR6HwRkba2CiDwve
+yHQLQI5Qrdxz8Mk0gIrNrSM4FAmcW9vi9z4kCbQyoC5C+4gqeUlJRpDIkQBWP2Y4
+2ct/bQKBgHv8qCsQTZphOxc31BJPa2xVhuv18cEU3XLUrVfUZ/1f43JhLp7gynS2
+ep++LKUi9D0VGXY8bqvfJjbECoCeu85vl8NpCXwe/LoVoIn+7KaVIZMwqoGMfgNl
+nEqm7HWkNxHhf8A6En/IjleuddS1sf9e/x+TJN1Xhnt9W6pe7Fk1
+-----END RSA PRIVATE KEY-----
+EOT
+
+  certificate = <<EOT
+-----BEGIN CERTIFICATE-----
+MIIDpTCCAo2gAwIBAgIJAKdmmOBYnFvoMA0GCSqGSIb3DQEBCwUAMGkxCzAJBgNV
+BAYTAnh4MQswCQYDVQQIDAJ4eDELMAkGA1UEBwwCeHgxCzAJBgNVBAoMAnh4MQsw
+CQYDVQQLDAJ4eDELMAkGA1UEAwwCeHgxGTAXBgkqhkiG9w0BCQEWCnh4QDE2My5j
+b20wHhcNMTcxMjA0MDM0MjQ5WhcNMjAxMjAzMDM0MjQ5WjBpMQswCQYDVQQGEwJ4
+eDELMAkGA1UECAwCeHgxCzAJBgNVBAcMAnh4MQswCQYDVQQKDAJ4eDELMAkGA1UE
+CwwCeHgxCzAJBgNVBAMMAnh4MRkwFwYJKoZIhvcNAQkBFgp4eEAxNjMuY29tMIIB
+IjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAwZ5UJULAjWr7p6FVwGRQRjFN
+2s8tZ/6LC3X82fajpVsYqF1xqEuUDndDXVD09E4u83MS6HO6a3bIVQDp6/klnYld
+iE6Vp8HH5BSKaCWKVg8lGWg1UM9wZFnlryi14KgmpIFmcu9nA8yV/6MZAe6RSDmb
+3iyNBmiZ8aZhGw2pI1YwR+15MVqFFGB+7ExkziROi7L8CFCyCezK2/oOOvQsH1dz
+Q8z1JXWdg8/9Zx7Ktvgwu5PQM3cJtSHX6iBPOkMU8Z8TugLlTqQXKZOEgwajwvQ5
+mf2DPkVgM08XAgaLJcLigwD513koAdtJd5v+9irw+5LAuO3JclqwTvwy7u/YwwID
+AQABo1AwTjAdBgNVHQ4EFgQUo5A2tIu+bcUfvGTD7wmEkhXKFjcwHwYDVR0jBBgw
+FoAUo5A2tIu+bcUfvGTD7wmEkhXKFjcwDAYDVR0TBAUwAwEB/zANBgkqhkiG9w0B
+AQsFAAOCAQEAWJ2rS6Mvlqk3GfEpboezx2J3X7l1z8Sxoqg6ntwB+rezvK3mc9H0
+83qcVeUcoH+0A0lSHyFN4FvRQL6X1hEheHarYwJK4agb231vb5erasuGO463eYEG
+r4SfTuOm7SyiV2xxbaBKrXJtpBp4WLL/s+LF+nklKjaOxkmxUX0sM4CTA7uFJypY
+c8Tdr8lDDNqoUtMD8BrUCJi+7lmMXRcC3Qi3oZJW76ja+kZA5mKVFPd1ATih8TbA
+i34R7EQDtFeiSvBdeKRsPp8c0KT8H1B4lXNkkCQs2WX5p4lm99+ZtLD4glw8x6Ic
+i1YhgnQbn5E0hz55OLu5jvOkKQjPCW+8Kg==
+-----END CERTIFICATE-----
+EOT
+}
+`, name)
+}
diff --git a/flexibleengine/acceptance/data_source_flexibleengine_lb_listeners_test.go b/flexibleengine/acceptance/data_source_flexibleengine_lb_listeners_test.go
new file mode 100644
index 00000000..637c244e
--- /dev/null
+++ b/flexibleengine/acceptance/data_source_flexibleengine_lb_listeners_test.go
@@ -0,0 +1,139 @@
+package acceptance
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+
+	"github.com/huaweicloud/terraform-provider-huaweicloud/huaweicloud/services/acceptance"
+)
+
+func TestAccDatasourceListeners_basic(t *testing.T) {
+	var (
+		rName            = acceptance.RandomAccResourceNameWithDash()
+		dcByName         = acceptance.InitDataSourceCheck("data.flexibleengine_lb_listeners.by_name")
+		dcByProtocol     = acceptance.InitDataSourceCheck("data.flexibleengine_lb_listeners.by_protocol")
+		dcByProtocolPort = acceptance.InitDataSourceCheck("data.flexibleengine_lb_listeners.by_protocol_port")
+	)
+
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:          func() { testAccPreCheck(t) },
+		ProviderFactories: TestAccProviderFactories,
+		Steps: []resource.TestStep{
+			{
+				Config: testAccDatasourceListeners_basic(rName),
+				Check: resource.ComposeTestCheckFunc(
+					dcByName.CheckResourceExists(),
+					resource.TestCheckOutput("name_query_result_validation", "true"),
+					resource.TestCheckResourceAttrSet("data.flexibleengine_lb_listeners.by_name",
+						"listeners.0.name"),
+					resource.TestCheckResourceAttrSet("data.flexibleengine_lb_listeners.by_name",
+						"listeners.0.protocol"),
+					resource.TestCheckResourceAttrSet("data.flexibleengine_lb_listeners.by_name",
+						"listeners.0.protocol_port"),
+					resource.TestCheckResourceAttrSet("data.flexibleengine_lb_listeners.by_name",
+						"listeners.0.connection_limit"),
+					resource.TestCheckResourceAttrSet("data.flexibleengine_lb_listeners.by_name",
+						"listeners.0.http2_enable"),
+					resource.TestCheckResourceAttr("data.flexibleengine_lb_listeners.by_name",
+						"listeners.0.loadbalancers.#", "1"),
+					dcByProtocol.CheckResourceExists(),
+					resource.TestCheckOutput("protocol_query_result_validation", "true"),
+					dcByProtocolPort.CheckResourceExists(),
+					resource.TestCheckOutput("protocol_port_query_result_validation", "true"),
+				),
+			},
+		},
+	})
+}
+
+func testAccDatasourceListeners_base(rName string) string {
+	rCidr := acceptance.RandomCidr()
+	return fmt.Sprintf(`
+variable "listener_configuration" {
+  type = list(object({
+    protocol_port = number
+    protocol      = string
+  }))
+  default = [
+    {protocol_port = 306, protocol = "TCP"},
+    {protocol_port = 406, protocol = "UDP"},
+    {protocol_port = 506, protocol = "HTTP"},
+  ]
+}
+
+resource "flexibleengine_vpc_v1" "test" {
+  name = "%[1]s"
+  cidr = "%[2]s"
+}
+
+resource "flexibleengine_vpc_subnet_v1" "test" {
+  vpc_id = flexibleengine_vpc_v1.test.id
+
+  name       = "%[1]s"
+  cidr       = cidrsubnet(flexibleengine_vpc_v1.test.cidr, 4, 1)
+  gateway_ip = cidrhost(cidrsubnet(flexibleengine_vpc_v1.test.cidr, 4, 1), 1)
+}
+
+resource "flexibleengine_lb_loadbalancer_v2" "test" {
+  name          = "%[1]s"
+  vip_subnet_id = flexibleengine_vpc_subnet_v1.test.ipv4_subnet_id
+}
+
+resource "flexibleengine_lb_listener_v2" "test" {
+  count = length(var.listener_configuration)
+
+  loadbalancer_id = flexibleengine_lb_loadbalancer_v2.test.id
+
+  name          = "%[1]s-${count.index}"
+  protocol      = var.listener_configuration[count.index]["protocol"]
+  protocol_port = var.listener_configuration[count.index]["protocol_port"]
+}
+`, rName, rCidr)
+}
+
+func testAccDatasourceListeners_basic(rName string) string {
+	return fmt.Sprintf(`
+%s
+
+data "flexibleengine_lb_listeners" "by_name" {
+  depends_on = [flexibleengine_lb_listener_v2.test]
+
+  name = flexibleengine_lb_listener_v2.test[0].name
+}
+
+data "flexibleengine_lb_listeners" "by_protocol" {
+  depends_on = [flexibleengine_lb_listener_v2.test]
+
+  protocol = flexibleengine_lb_listener_v2.test[1].protocol
+}
+
+data "flexibleengine_lb_listeners" "by_protocol_port" {
+  depends_on = [flexibleengine_lb_listener_v2.test]
+
+  protocol_port = flexibleengine_lb_listener_v2.test[2].protocol_port
+}
+
+output "name_query_result_validation" {
+  value = contains(data.flexibleengine_lb_listeners.by_name.listeners[*].id,
+  flexibleengine_lb_listener_v2.test[0].id) && !contains(data.flexibleengine_lb_listeners.by_name.listeners[*].id,
+  flexibleengine_lb_listener_v2.test[1].id) && !contains(data.flexibleengine_lb_listeners.by_name.listeners[*].id,
+  flexibleengine_lb_listener_v2.test[2].id)
+}
+
+output "protocol_query_result_validation" {
+  value = contains(data.flexibleengine_lb_listeners.by_protocol.listeners[*].id,
+  flexibleengine_lb_listener_v2.test[1].id) && !contains(data.flexibleengine_lb_listeners.by_protocol.listeners[*].id,
+  flexibleengine_lb_listener_v2.test[0].id) && !contains(data.flexibleengine_lb_listeners.by_protocol.listeners[*].id,
+  flexibleengine_lb_listener_v2.test[2].id)
+}
+
+output "protocol_port_query_result_validation" {
+  value = contains(data.flexibleengine_lb_listeners.by_protocol_port.listeners[*].id,
+  flexibleengine_lb_listener_v2.test[2].id) && !contains(data.flexibleengine_lb_listeners.by_protocol_port.listeners[*].id,
+  flexibleengine_lb_listener_v2.test[0].id) && !contains(data.flexibleengine_lb_listeners.by_protocol_port.listeners[*].id,
+  flexibleengine_lb_listener_v2.test[1].id)
+}
+`, testAccDatasourceListeners_base(rName))
+}
diff --git a/flexibleengine/acceptance/resource_flexibleengine_lb_logtank_v3_test.go b/flexibleengine/acceptance/resource_flexibleengine_lb_logtank_v3_test.go
new file mode 100644
index 00000000..c7e4991c
--- /dev/null
+++ b/flexibleengine/acceptance/resource_flexibleengine_lb_logtank_v3_test.go
@@ -0,0 +1,129 @@
+package acceptance
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/terraform"
+
+	"github.com/chnsz/golangsdk/openstack/elb/v3/logtanks"
+
+	"github.com/huaweicloud/terraform-provider-huaweicloud/huaweicloud/config"
+	"github.com/huaweicloud/terraform-provider-huaweicloud/huaweicloud/services/acceptance"
+)
+
+func getELBLogTankResourceFunc(c *config.Config, state *terraform.ResourceState) (interface{}, error) {
+	client, err := c.ElbV3Client(OS_REGION_NAME)
+	if err != nil {
+		return nil, fmt.Errorf("error creating ELB client: %s", err)
+	}
+	return logtanks.Get(client, state.Primary.ID).Extract()
+}
+
+func TestAccElbLogTank_basic(t *testing.T) {
+	var logTanks logtanks.LogTank
+	rName := acceptance.RandomAccResourceNameWithDash()
+	resourceName := "flexibleengine_lb_logtank_v3.test"
+
+	rc := acceptance.InitResourceCheck(
+		resourceName,
+		&logTanks,
+		getELBLogTankResourceFunc,
+	)
+
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:          func() { testAccPreCheck(t) },
+		ProviderFactories: TestAccProviderFactories,
+		CheckDestroy:      rc.CheckResourceDestroy(),
+		Steps: []resource.TestStep{
+			{
+				Config: testAccElbLogTankConfig_basic(rName),
+				Check: resource.ComposeTestCheckFunc(
+					rc.CheckResourceExists(),
+					resource.TestCheckResourceAttrPair(resourceName, "log_group_id",
+						"flexibleengine_lts_group.test", "id"),
+					resource.TestCheckResourceAttrPair(resourceName, "log_topic_id",
+						"flexibleengine_lts_topic.test", "id"),
+				),
+			},
+			{
+				Config: testAccElbLogTankConfig_update(rName),
+				Check: resource.ComposeTestCheckFunc(
+					rc.CheckResourceExists(),
+					resource.TestCheckResourceAttrPair(resourceName, "log_group_id",
+						"flexibleengine_lts_group.test_update", "id"),
+					resource.TestCheckResourceAttrPair(resourceName, "log_topic_id",
+						"flexibleengine_lts_topic.test_update", "id"),
+				),
+			},
+			{
+				ResourceName:      resourceName,
+				ImportState:       true,
+				ImportStateVerify: true,
+			},
+		},
+	})
+}
+
+func testAccElbLogTankConfig_base(rName, updateName string) string {
+	return fmt.Sprintf(`
+data "flexibleengine_availability_zones" "test" {}
+
+resource "flexibleengine_vpc_v1" "test" {
+  name = "%[1]s"
+  cidr = "192.168.0.0/16"
+}
+
+resource "flexibleengine_vpc_subnet_v1" "test" {
+  name        = "%[1]s"
+  cidr        = "192.168.0.0/24"
+  gateway_ip  = "192.168.0.1"
+  vpc_id      = flexibleengine_vpc_v1.test.id
+  ipv6_enable = true
+}
+
+resource "flexibleengine_lb_loadbalancer_v3" "test" {
+  name            = "%[1]s"
+  ipv4_subnet_id  = flexibleengine_vpc_subnet_v1.test.ipv4_subnet_id
+  ipv6_network_id = flexibleengine_vpc_subnet_v1.test.id
+
+  availability_zone = [
+    data.flexibleengine_availability_zones.test.names[0]
+  ]
+}
+
+resource "flexibleengine_lts_group" "%[2]s" {
+  group_name  = "%[2]s"
+}
+
+resource "flexibleengine_lts_topic" "%[2]s" {
+  group_id   = flexibleengine_lts_group.%[2]s.id
+  topic_name = "%[1]s"
+}
+`, rName, updateName)
+}
+
+func testAccElbLogTankConfig_basic(rName string) string {
+	return fmt.Sprintf(`
+%s
+
+resource "flexibleengine_lb_logtank_v3" "test" {
+  loadbalancer_id = flexibleengine_lb_loadbalancer_v3.test.id
+  log_group_id    = flexibleengine_lts_group.test.id
+  log_topic_id    = flexibleengine_lts_topic.test.id
+}
+`, testAccElbLogTankConfig_base(rName, "test"))
+}
+
+func testAccElbLogTankConfig_update(rName string) string {
+	return fmt.Sprintf(`
+%s
+
+resource "flexibleengine_lb_logtank_v3" "test" {
+  loadbalancer_id = flexibleengine_lb_loadbalancer_v3.test.id
+  log_group_id    = flexibleengine_lts_group.test_update.id
+  log_topic_id    = flexibleengine_lts_topic.test_update.id
+}
+`, testAccElbLogTankConfig_base(rName, "test_update"))
+}
diff --git a/flexibleengine/provider.go b/flexibleengine/provider.go
index 92d9261d..85114c43 100644
--- a/flexibleengine/provider.go
+++ b/flexibleengine/provider.go
@@ -305,6 +305,8 @@ func Provider() *schema.Provider {
 			"flexibleengine_dws_flavors": dws.DataSourceDwsFlavors(),
 
 			"flexibleengine_elb_certificate":  elb.DataSourceELBCertificateV3(),
+			"flexibleengine_lb_listeners":     lb.DataSourceListeners(),
+			"flexibleengine_lb_certificate":   lb.DataSourceLBCertificateV2(),
 			"flexibleengine_fgs_dependencies": fgs.DataSourceFunctionGraphDependencies(),
 
 			"flexibleengine_gaussdb_cassandra_flavors":   gaussdb.DataSourceCassandraFlavors(),
@@ -550,11 +552,10 @@ func Provider() *schema.Provider {
 			"flexibleengine_waf_dedicated_certificate": ResourceWafDedicatedCertificateV1(),
 			"flexibleengine_waf_dedicated_domain":      ResourceWafDedicatedDomainV1(),
 
-			"flexibleengine_lb_loadbalancer_v3": elb.ResourceLoadBalancerV3(),
-			"flexibleengine_lb_listener_v3":     elb.ResourceListenerV3(),
-			"flexibleengine_elb_certificate":    elb.ResourceCertificateV3(),
-			"flexibleengine_elb_ipgroup":        elb.ResourceIpGroupV3(),
-
+			"flexibleengine_lb_loadbalancer_v3":        elb.ResourceLoadBalancerV3(),
+			"flexibleengine_lb_listener_v3":            elb.ResourceListenerV3(),
+			"flexibleengine_elb_certificate":           elb.ResourceCertificateV3(),
+			"flexibleengine_elb_ipgroup":               elb.ResourceIpGroupV3(),
 			"flexibleengine_modelarts_dataset":         modelarts.ResourceDataset(),
 			"flexibleengine_modelarts_dataset_version": modelarts.ResourceDatasetVersion(),
 			"flexibleengine_smn_message_template":      smn.ResourceSmnMessageTemplate(),
@@ -567,8 +568,9 @@ func Provider() *schema.Provider {
 			"flexibleengine_lb_pool_v3":          elb.ResourcePoolV3(),                // v1.35.0
 			"flexibleengine_lb_monitor_v3":       elb.ResourceMonitorV3(),             // v1.35.0
 			"flexibleengine_lb_member_v3":        elb.ResourceMemberV3(),              // v1.35.0
-			"flexibleengine_smn_topic_v2":        smn.ResourceTopic(),                 // v1.39.0
-			"flexibleengine_smn_subscription_v2": smn.ResourceSubscription(),          // v1.39.0
+			"flexibleengine_lb_logtank_v3":       elb.ResourceLogTank(),
+			"flexibleengine_smn_topic_v2":        smn.ResourceTopic(),        // v1.39.0
+			"flexibleengine_smn_subscription_v2": smn.ResourceSubscription(), // v1.39.0
 			"flexibleengine_sfs_turbo":           sfs.ResourceSFSTurbo(),
 
 			// Deprecated resource