@@ -34,12 +34,12 @@ func dataSourceTencentCloudNatGateways() *schema.Resource {
3434 "name" : {
3535 Type : schema .TypeString ,
3636 Optional : true ,
37- Description : "Name of the nat gateway." ,
37+ Description : "Name of the NAT gateway." ,
3838 },
3939 "id" : {
4040 Type : schema .TypeString ,
4141 Optional : true ,
42- Description : "ID of the nat gateway." ,
42+ Description : "ID of the NAT gateway." ,
4343 },
4444 "result_output_file" : {
4545 Type : schema .TypeString ,
@@ -51,13 +51,13 @@ func dataSourceTencentCloudNatGateways() *schema.Resource {
5151 "nats" : {
5252 Type : schema .TypeList ,
5353 Computed : true ,
54- Description : "Information list of the dedicated tunnels ." ,
54+ Description : "Information list of the dedicated nats ." ,
5555 Elem : & schema.Resource {
5656 Schema : map [string ]* schema.Schema {
5757 "id" : {
5858 Type : schema .TypeString ,
5959 Computed : true ,
60- Description : "ID of the nat gateway." ,
60+ Description : "ID of the NAT gateway." ,
6161 },
6262 "vpc_id" : {
6363 Type : schema .TypeString ,
@@ -67,22 +67,22 @@ func dataSourceTencentCloudNatGateways() *schema.Resource {
6767 "name" : {
6868 Type : schema .TypeString ,
6969 Computed : true ,
70- Description : "Name of the nat gateway." ,
70+ Description : "Name of the NAT gateway." ,
7171 },
7272 "state" : {
7373 Type : schema .TypeInt ,
7474 Computed : true ,
75- Description : "State of the nat gateway." ,
75+ Description : "State of the NAT gateway." ,
7676 },
7777 "max_concurrent" : {
7878 Type : schema .TypeInt ,
7979 Computed : true ,
80- Description : "The upper limit of concurrent connection of nat gateway, the available values include: 1000000,3000000,10000000. Default is 1000000." ,
80+ Description : "The upper limit of concurrent connection of NAT gateway, the available values include: 1000000,3000000,10000000. Default is 1000000." ,
8181 },
8282 "bandwidth" : {
8383 Type : schema .TypeInt ,
8484 Computed : true ,
85- Description : "The maximum public network output bandwidth of nat gateway (unit: Mbps), the available values include: 20,50,100,200,500,1000,2000,5000. Default is 100." ,
85+ Description : "The maximum public network output bandwidth of NAT gateway (unit: Mbps), the available values include: 20,50,100,200,500,1000,2000,5000. Default is 100." ,
8686 },
8787 "assigned_eip_set" : {
8888 Type : schema .TypeList ,
@@ -93,7 +93,7 @@ func dataSourceTencentCloudNatGateways() *schema.Resource {
9393 "create_time" : {
9494 Type : schema .TypeString ,
9595 Computed : true ,
96- Description : "Create time of the nat gateway." ,
96+ Description : "Create time of the NAT gateway." ,
9797 },
9898 },
9999 },
@@ -126,24 +126,38 @@ func dataSourceTencentCloudNatGatewaysRead(d *schema.ResourceData, meta interfac
126126 }
127127 request .Filters = append (request .Filters , filter )
128128 }
129- var response * vpc.DescribeNatGatewaysResponse
130- err := resource .Retry (readRetryTimeout , func () * resource.RetryError {
131- result , e := meta .(* TencentCloudClient ).apiV3Conn .UseVpcClient ().DescribeNatGateways (request )
132- if e != nil {
133- log .Printf ("[CRITAL]%s api[%s] fail, request body [%s], reason[%s]\n " ,
134- logId , request .GetAction (), request .ToJsonString (), e .Error ())
135- return retryError (e )
129+ offset := uint64 (0 )
130+ request .Offset = & offset
131+ result := make ([]* vpc.NatGateway , 0 )
132+ limit := uint64 (NAT_DESCRIBE_LIMIT )
133+ for {
134+ var response * vpc.DescribeNatGatewaysResponse
135+ err := resource .Retry (readRetryTimeout , func () * resource.RetryError {
136+ result , e := meta .(* TencentCloudClient ).apiV3Conn .UseVpcClient ().DescribeNatGateways (request )
137+ if e != nil {
138+ log .Printf ("[CRITAL]%s api[%s] fail, request body [%s], reason[%s]\n " ,
139+ logId , request .GetAction (), request .ToJsonString (), e .Error ())
140+ return retryError (e )
141+ }
142+ response = result
143+ return nil
144+ })
145+ if err != nil {
146+ log .Printf ("[CRITAL]%s read NAT gateway failed, reason:%s\n " , logId , err .Error ())
147+ return err
148+ } else {
149+ result = append (result , response .Response .NatGatewaySet ... )
150+ if len (response .Response .NatGatewaySet ) < NAT_DESCRIBE_LIMIT {
151+ break
152+ } else {
153+ offset = offset + limit
154+ request .Offset = & offset
155+ }
136156 }
137- response = result
138- return nil
139- })
140- if err != nil {
141- log .Printf ("[CRITAL]%s read nat gateway failed, reason:%s\n " , logId , err .Error ())
142- return err
143157 }
144- ids := make ([]string , 0 , len (response . Response . NatGatewaySet ))
145- natList := make ([]map [string ]interface {}, 0 , len (response . Response . NatGatewaySet ))
146- for _ , nat := range response . Response . NatGatewaySet {
158+ ids := make ([]string , 0 , len (result ))
159+ natList := make ([]map [string ]interface {}, 0 , len (result ))
160+ for _ , nat := range result {
147161 mapping := map [string ]interface {}{
148162 "id" : * nat .NatGatewayId ,
149163 "vpc_id" : * nat .VpcId ,
@@ -159,7 +173,7 @@ func dataSourceTencentCloudNatGatewaysRead(d *schema.ResourceData, meta interfac
159173 }
160174 d .SetId (dataResourceIdsHash (ids ))
161175 if e := d .Set ("nats" , natList ); e != nil {
162- log .Printf ("[CRITAL]%s provider set clb list fail, reason:%s\n " , logId , e .Error ())
176+ log .Printf ("[CRITAL]%s provider set NAT list fail, reason:%s\n " , logId , e .Error ())
163177 return e
164178 }
165179
0 commit comments