Skip to content

Commit 194efd2

Browse files
committed
add
1 parent 4e1c64e commit 194efd2

File tree

2 files changed

+35
-25
lines changed

2 files changed

+35
-25
lines changed

tencentcloud/services/tmp/resource_tc_monitor_tmp_exporter_integration.go

Lines changed: 2 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ func resourceTencentCloudMonitorTmpExporterIntegrationCreate(d *schema.ResourceD
146146
logId, request.GetAction(), request.ToJsonString(), result.ToJsonString())
147147
}
148148

149-
if result == nil || result.Response == nil || response.Response.Names == nil {
149+
if result == nil || result.Response == nil || result.Response.Names == nil {
150150
return resource.NonRetryableError(fmt.Errorf("Create monitor tmpExporterIntegration failed, Response is nil."))
151151
}
152152

@@ -167,34 +167,11 @@ func resourceTencentCloudMonitorTmpExporterIntegrationCreate(d *schema.ResourceD
167167

168168
d.SetId(strings.Join([]string{tmpExporterIntegrationId, instanceId, strconv.Itoa(kubeType), clusterId, kind}, tccommon.FILED_SP))
169169

170-
// wait
171-
err = resource.Retry(8*tccommon.ReadRetryTimeout, func() *resource.RetryError {
172-
results, errRet := meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseMonitorClient().DescribePrometheusInstanceInitStatus(initStatus)
173-
if errRet != nil {
174-
return tccommon.RetryError(errRet, tccommon.InternalError)
175-
}
176-
177-
if results == nil || results.Response == nil || results.Response.Status == nil {
178-
return resource.NonRetryableError(fmt.Errorf("prometheusInstanceInit status is nil, operate failed"))
179-
}
180-
181-
status := results.Response.Status
182-
if *status == "running" {
183-
return nil
184-
}
185-
186-
return resource.RetryableError(fmt.Errorf("prometheusInstanceInit status is %s", *status))
187-
})
188-
189-
if err != nil {
190-
return err
191-
}
192-
193170
return resourceTencentCloudMonitorTmpExporterIntegrationRead(d, meta)
194171
}
195172

196173
func resourceTencentCloudMonitorTmpExporterIntegrationRead(d *schema.ResourceData, meta interface{}) error {
197-
defer tccommon.LogElapsed("resource.tencentcloud_monitor_tmpExporterIntegration.read")()
174+
defer tccommon.LogElapsed("resource.tencentcloud_monitor_tmp_exporter_integration.read")()
198175
defer tccommon.InconsistentCheck(d, meta)()
199176

200177
logId := tccommon.GetLogId(tccommon.ContextNil)

tencentcloud/services/tmp/resource_tc_monitor_tmp_instance.go

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -128,6 +128,10 @@ func resourceTencentCloudMonitorTmpInstanceCreate(d *schema.ResourceData, meta i
128128
logId, request.GetAction(), request.ToJsonString(), result.ToJsonString())
129129
}
130130

131+
if result == nil || result.Response == nil {
132+
return resource.NonRetryableError(fmt.Errorf("Create monitor tmpInstance failed, Response is nil."))
133+
}
134+
131135
response = result
132136
return nil
133137
})
@@ -137,6 +141,10 @@ func resourceTencentCloudMonitorTmpInstanceCreate(d *schema.ResourceData, meta i
137141
return err
138142
}
139143

144+
if response.Response.InstanceId == nil {
145+
return fmt.Errorf("InstanceId is nil.")
146+
}
147+
140148
tmpInstanceId := *response.Response.InstanceId
141149
service := svcmonitor.NewMonitorService(meta.(tccommon.ProviderMeta).GetAPIV3Conn())
142150
ctx := context.WithValue(context.TODO(), tccommon.LogIdKey, logId)
@@ -162,6 +170,31 @@ func resourceTencentCloudMonitorTmpInstanceCreate(d *schema.ResourceData, meta i
162170
return err
163171
}
164172

173+
// wait
174+
initStatus := monitor.NewDescribePrometheusInstanceInitStatusRequest()
175+
initStatus.InstanceId = &tmpInstanceId
176+
err = resource.Retry(8*tccommon.ReadRetryTimeout, func() *resource.RetryError {
177+
result, errRet := meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseMonitorClient().DescribePrometheusInstanceInitStatus(initStatus)
178+
if errRet != nil {
179+
return tccommon.RetryError(errRet, tccommon.InternalError)
180+
}
181+
182+
if result == nil || result.Response == nil || result.Response.Status == nil {
183+
return resource.NonRetryableError(fmt.Errorf("prometheusInstanceInit status is nil, operate failed"))
184+
}
185+
186+
status := result.Response.Status
187+
if *status == "running" {
188+
return nil
189+
}
190+
191+
return resource.RetryableError(fmt.Errorf("prometheusInstanceInit status is %s", *status))
192+
})
193+
194+
if err != nil {
195+
return err
196+
}
197+
165198
if tags := helper.GetTags(d, "tags"); len(tags) > 0 {
166199
tagService := svctag.NewTagService(meta.(tccommon.ProviderMeta).GetAPIV3Conn())
167200
region := meta.(tccommon.ProviderMeta).GetAPIV3Conn().Region

0 commit comments

Comments
 (0)