Skip to content

Commit

Permalink
Update elasticsearch config during Create iff auto_tune_options exists
Browse files Browse the repository at this point in the history
  • Loading branch information
zhelding committed Dec 2, 2021
1 parent 0fccf89 commit 8b369e6
Showing 1 changed file with 12 additions and 11 deletions.
23 changes: 12 additions & 11 deletions internal/service/elasticsearch/domain.go
Original file line number Diff line number Diff line change
Expand Up @@ -700,23 +700,24 @@ func resourceDomainCreate(d *schema.ResourceData, meta interface{}) error {

log.Printf("[DEBUG] Elasticsearch domain %q created", d.Id())

log.Printf("[DEBUG] Modifying config for Elasticsearch domain %q", d.Id())
if v, ok := d.GetOk("auto_tune_options"); ok && len(v.([]interface{})) > 0 {

inputUpdateDomainConfig := &elasticsearch.UpdateElasticsearchDomainConfigInput{
DomainName: aws.String(d.Get("domain_name").(string)),
}
log.Printf("[DEBUG] Modifying config for Elasticsearch domain %q", d.Id())

inputUpdateDomainConfig := &elasticsearch.UpdateElasticsearchDomainConfigInput{
DomainName: aws.String(d.Get("domain_name").(string)),
}

if v, ok := d.GetOk("auto_tune_options"); ok && len(v.([]interface{})) > 0 {
inputUpdateDomainConfig.AutoTuneOptions = expandAutoTuneOptions(v.([]interface{})[0].(map[string]interface{}))
}

_, err = conn.UpdateElasticsearchDomainConfig(inputUpdateDomainConfig)
_, err = conn.UpdateElasticsearchDomainConfig(inputUpdateDomainConfig)

if err != nil {
return fmt.Errorf("Error modifying config for Elasticsearch domain: %s", err)
}
if err != nil {
return fmt.Errorf("Error modifying config for Elasticsearch domain: %s", err)
}

log.Printf("[DEBUG] Config for Elasticsearch domain %q modified", d.Id())
log.Printf("[DEBUG] Config for Elasticsearch domain %q modified", d.Id())
}

return resourceDomainRead(d, meta)
}
Expand Down

0 comments on commit 8b369e6

Please sign in to comment.