Resource - Neptune: aws_neptune_parameter_group #4724
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,280 @@ | ||
| package aws | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "fmt" | ||
| "log" | ||
| "strings" | ||
| "time" | ||
|
|
||
| "github.com/hashicorp/terraform/helper/hashcode" | ||
| "github.com/hashicorp/terraform/helper/resource" | ||
| "github.com/hashicorp/terraform/helper/schema" | ||
|
|
||
| "github.com/aws/aws-sdk-go/aws" | ||
| "github.com/aws/aws-sdk-go/service/neptune" | ||
| ) | ||
|
|
||
| // We can only modify 20 parameters at a time, so walk them until | ||
| // we've got them all. | ||
| const maxParams = 20 | ||
|
|
||
| func resourceAwsNeptuneParameterGroup() *schema.Resource { | ||
| return &schema.Resource{ | ||
| Create: resourceAwsNeptuneParameterGroupCreate, | ||
| Read: resourceAwsNeptuneParameterGroupRead, | ||
| Update: resourceAwsNeptuneParameterGroupUpdate, | ||
| Delete: resourceAwsNeptuneParameterGroupDelete, | ||
| Importer: &schema.ResourceImporter{ | ||
| State: schema.ImportStatePassthrough, | ||
| }, | ||
| Schema: map[string]*schema.Schema{ | ||
| "name": { | ||
| Type: schema.TypeString, | ||
| ForceNew: true, | ||
| Required: true, | ||
| StateFunc: func(val interface{}) string { | ||
| return strings.ToLower(val.(string)) | ||
| }, | ||
| }, | ||
| "family": { | ||
| Type: schema.TypeString, | ||
| Required: true, | ||
| ForceNew: true, | ||
| }, | ||
| "description": { | ||
| Type: schema.TypeString, | ||
| Optional: true, | ||
| ForceNew: true, | ||
| Default: "Managed by Terraform", | ||
| }, | ||
| "parameter": { | ||
| Type: schema.TypeSet, | ||
| Optional: true, | ||
| Elem: &schema.Resource{ | ||
| Schema: map[string]*schema.Schema{ | ||
| "name": { | ||
| Type: schema.TypeString, | ||
| Required: true, | ||
| }, | ||
| "value": { | ||
| Type: schema.TypeString, | ||
| Required: true, | ||
| }, | ||
| "apply_method": { | ||
|
There was a problem hiding this comment. This argument was not documented originally and will be added post merge. Also adding validation: ValidateFunc: validation.StringInSlice([]string{
neptune.ApplyMethodImmediate,
neptune.ApplyMethodPendingReboot,
}, false), |
||
| Type: schema.TypeString, | ||
| Optional: true, | ||
| Default: "immediate", | ||
|
There was a problem hiding this comment. This seems to be safer to default to |
||
| // this parameter is not actually state, but a | ||
| // meta-parameter describing how the RDS API call | ||
| // to modify the parameter group should be made. | ||
| // Future reads of the resource from AWS don't tell | ||
| // us what we used for apply_method previously, so | ||
| // by squashing state to an empty string we avoid | ||
| // needing to do an update for every future run. | ||
| StateFunc: func(interface{}) string { return "" }, | ||
|
There was a problem hiding this comment. I'm not sure where this |
||
| }, | ||
| }, | ||
| }, | ||
| Set: resourceAwsNeptuneParameterHash, | ||
|
There was a problem hiding this comment. It turns out that this custom |
||
| }, | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| func resourceAwsNeptuneParameterGroupCreate(d *schema.ResourceData, meta interface{}) error { | ||
| conn := meta.(*AWSClient).neptuneconn | ||
|
|
||
| createOpts := neptune.CreateDBParameterGroupInput{ | ||
| DBParameterGroupName: aws.String(d.Get("name").(string)), | ||
| DBParameterGroupFamily: aws.String(d.Get("family").(string)), | ||
| Description: aws.String(d.Get("description").(string)), | ||
| } | ||
|
|
||
| log.Printf("[DEBUG] Create Neptune Parameter Group: %#v", createOpts) | ||
| resp, err := conn.CreateDBParameterGroup(&createOpts) | ||
| if err != nil { | ||
| return fmt.Errorf("Error creating Neptune Parameter Group: %s", err) | ||
| } | ||
|
|
||
| d.Partial(true) | ||
| d.SetPartial("name") | ||
| d.SetPartial("family") | ||
| d.SetPartial("description") | ||
| d.Partial(false) | ||
|
|
||
| d.SetId(*resp.DBParameterGroup.DBParameterGroupName) | ||
| log.Printf("[INFO] Neptune Parameter Group ID: %s", d.Id()) | ||
|
|
||
| return resourceAwsNeptuneParameterGroupUpdate(d, meta) | ||
| } | ||
|
|
||
| func resourceAwsNeptuneParameterGroupRead(d *schema.ResourceData, meta interface{}) error { | ||
| conn := meta.(*AWSClient).neptuneconn | ||
|
|
||
| describeOpts := neptune.DescribeDBParameterGroupsInput{ | ||
| DBParameterGroupName: aws.String(d.Id()), | ||
| } | ||
|
|
||
| describeResp, err := conn.DescribeDBParameterGroups(&describeOpts) | ||
| if err != nil { | ||
| if isAWSErr(err, neptune.ErrCodeDBParameterGroupNotFoundFault, "") { | ||
| log.Printf("[WARN] Neptune Parameter Group (%s) not found, removing from state", d.Id()) | ||
| d.SetId("") | ||
| return nil | ||
| } | ||
| return err | ||
| } | ||
|
|
||
| if describeResp == nil { | ||
| return fmt.Errorf("Unable to get Describe Response for Neptune Parameter Group (%s)", d.Id()) | ||
| } | ||
|
|
||
| if len(describeResp.DBParameterGroups) != 1 || | ||
| *describeResp.DBParameterGroups[0].DBParameterGroupName != d.Id() { | ||
| return fmt.Errorf("Unable to find Parameter Group: %#v", describeResp.DBParameterGroups) | ||
| } | ||
|
|
||
| d.Set("name", describeResp.DBParameterGroups[0].DBParameterGroupName) | ||
| d.Set("family", describeResp.DBParameterGroups[0].DBParameterGroupFamily) | ||
| d.Set("description", describeResp.DBParameterGroups[0].Description) | ||
|
|
||
| // Only include user customized parameters as there's hundreds of system/default ones | ||
| describeParametersOpts := neptune.DescribeDBParametersInput{ | ||
| DBParameterGroupName: aws.String(d.Id()), | ||
| Source: aws.String("user"), | ||
| } | ||
|
|
||
| var parameters []*neptune.Parameter | ||
| err = conn.DescribeDBParametersPages(&describeParametersOpts, | ||
| func(describeParametersResp *neptune.DescribeDBParametersOutput, lastPage bool) bool { | ||
| parameters = append(parameters, describeParametersResp.Parameters...) | ||
| return !lastPage | ||
| }) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| if err := d.Set("parameter", flattenNeptuneParameters(parameters)); err != nil { | ||
| return fmt.Errorf("error setting parameter: %s", err) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func resourceAwsNeptuneParameterGroupUpdate(d *schema.ResourceData, meta interface{}) error { | ||
| conn := meta.(*AWSClient).neptuneconn | ||
|
|
||
| d.Partial(true) | ||
|
|
||
| if d.HasChange("parameter") { | ||
| o, n := d.GetChange("parameter") | ||
| if o == nil { | ||
| o = new(schema.Set) | ||
| } | ||
| if n == nil { | ||
| n = new(schema.Set) | ||
| } | ||
|
|
||
| os := o.(*schema.Set) | ||
| ns := n.(*schema.Set) | ||
|
|
||
| toRemove, err := expandNeptuneParameters(os.Difference(ns).List()) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| log.Printf("[DEBUG] Parameters to remove: %#v", toRemove) | ||
|
|
||
| toAdd, err := expandNeptuneParameters(ns.Difference(os).List()) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| log.Printf("[DEBUG] Parameters to add: %#v", toAdd) | ||
|
|
||
| for len(toRemove) > 0 { | ||
| paramsToModify := make([]*neptune.Parameter, 0) | ||
| if len(toRemove) <= maxParams { | ||
| paramsToModify, toRemove = toRemove[:], nil | ||
| } else { | ||
| paramsToModify, toRemove = toRemove[:maxParams], toRemove[maxParams:] | ||
| } | ||
| resetOpts := neptune.ResetDBParameterGroupInput{ | ||
| DBParameterGroupName: aws.String(d.Get("name").(string)), | ||
| Parameters: paramsToModify, | ||
| } | ||
|
|
||
| log.Printf("[DEBUG] Reset Neptune Parameter Group: %s", resetOpts) | ||
| err := resource.Retry(30*time.Second, func() *resource.RetryError { | ||
| _, err = conn.ResetDBParameterGroup(&resetOpts) | ||
| if err != nil { | ||
| if isAWSErr(err, "InvalidDBParameterGroupState", " has pending changes") { | ||
| return resource.RetryableError(err) | ||
| } | ||
| return resource.NonRetryableError(err) | ||
| } | ||
| return nil | ||
| }) | ||
| if err != nil { | ||
| return fmt.Errorf("Error resetting Neptune Parameter Group: %s", err) | ||
| } | ||
| } | ||
|
|
||
| for len(toAdd) > 0 { | ||
| paramsToModify := make([]*neptune.Parameter, 0) | ||
| if len(toAdd) <= maxParams { | ||
| paramsToModify, toAdd = toAdd[:], nil | ||
| } else { | ||
| paramsToModify, toAdd = toAdd[:maxParams], toAdd[maxParams:] | ||
| } | ||
| modifyOpts := neptune.ModifyDBParameterGroupInput{ | ||
| DBParameterGroupName: aws.String(d.Get("name").(string)), | ||
| Parameters: paramsToModify, | ||
| } | ||
|
|
||
| log.Printf("[DEBUG] Modify Neptune Parameter Group: %s", modifyOpts) | ||
| _, err = conn.ModifyDBParameterGroup(&modifyOpts) | ||
| if err != nil { | ||
| return fmt.Errorf("Error modifying Neptune Parameter Group: %s", err) | ||
| } | ||
| } | ||
|
|
||
| d.SetPartial("parameter") | ||
| } | ||
|
|
||
| d.Partial(false) | ||
|
|
||
| return resourceAwsNeptuneParameterGroupRead(d, meta) | ||
| } | ||
|
|
||
| func resourceAwsNeptuneParameterGroupDelete(d *schema.ResourceData, meta interface{}) error { | ||
| conn := meta.(*AWSClient).neptuneconn | ||
|
|
||
| return resource.Retry(3*time.Minute, func() *resource.RetryError { | ||
| deleteOpts := neptune.DeleteDBParameterGroupInput{ | ||
| DBParameterGroupName: aws.String(d.Id()), | ||
| } | ||
| _, err := conn.DeleteDBParameterGroup(&deleteOpts) | ||
| if err != nil { | ||
| if isAWSErr(err, neptune.ErrCodeDBParameterGroupNotFoundFault, "") { | ||
| return nil | ||
| } | ||
| if isAWSErr(err, neptune.ErrCodeInvalidDBParameterGroupStateFault, "") { | ||
| return resource.RetryableError(err) | ||
| } | ||
| return resource.NonRetryableError(err) | ||
| } | ||
| return nil | ||
| }) | ||
| } | ||
|
|
||
| func resourceAwsNeptuneParameterHash(v interface{}) int { | ||
| var buf bytes.Buffer | ||
| m := v.(map[string]interface{}) | ||
| buf.WriteString(fmt.Sprintf("%s-", m["name"].(string))) | ||
| // Store the value as a lower case string, to match how we store them in flattenParameters | ||
| buf.WriteString(fmt.Sprintf("%s-", strings.ToLower(m["value"].(string)))) | ||
|
|
||
| return hashcode.String(buf.String()) | ||
| } | ||
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This new resource is missing documentation:
website/docs/r/neptune_parameter_group.html.markdownwebsite/aws.erb