-
Notifications
You must be signed in to change notification settings - Fork 87
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Implement nxst_policy_edge_high_availability_profile resource
Signed-off-by: Kobi Samoray <[email protected]>
- Loading branch information
Showing
4 changed files
with
569 additions
and
12 deletions.
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
296 changes: 296 additions & 0 deletions
296
nsxt/resource_nsxt_policy_edge_high_availability_profile.go
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,296 @@ | ||
| /* Copyright © 2024 Broadcom, Inc. All Rights Reserved. | ||
| SPDX-License-Identifier: MPL-2.0 */ | ||
|
|
||
| package nsxt | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "log" | ||
| "reflect" | ||
|
|
||
| "github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema" | ||
| "github.com/vmware/vsphere-automation-sdk-go/runtime/protocol/client" | ||
| "github.com/vmware/vsphere-automation-sdk-go/services/nsxt/infra" | ||
| "github.com/vmware/vsphere-automation-sdk-go/services/nsxt/infra/sites/enforcement_points" | ||
| "github.com/vmware/vsphere-automation-sdk-go/services/nsxt/model" | ||
|
|
||
| "github.com/vmware/terraform-provider-nsxt/nsxt/metadata" | ||
| ) | ||
|
|
||
| var policyEdgeHighAvailabilityProfileSchema = map[string]*metadata.ExtendedSchema{ | ||
| "nsx_id": metadata.GetExtendedSchema(getNsxIDSchema()), | ||
| "path": metadata.GetExtendedSchema(getPathSchema()), | ||
| "display_name": metadata.GetExtendedSchema(getDisplayNameSchema()), | ||
| "description": metadata.GetExtendedSchema(getDescriptionSchema()), | ||
| "revision": metadata.GetExtendedSchema(getRevisionSchema()), | ||
| "tag": metadata.GetExtendedSchema(getTagsSchema()), | ||
| "site_path": { | ||
| Schema: schema.Schema{ | ||
| Type: schema.TypeString, | ||
| Description: "Path to the site this Host Transport Node belongs to", | ||
| Optional: true, | ||
| ForceNew: true, | ||
| Default: defaultInfraSitePath, | ||
| ValidateFunc: validatePolicyPath(), | ||
| }, | ||
| Metadata: metadata.Metadata{ | ||
| SchemaType: "string", | ||
| Skip: true, | ||
| }, | ||
| }, | ||
| "enforcement_point": { | ||
| Schema: schema.Schema{ | ||
| Type: schema.TypeString, | ||
| Description: "ID of the enforcement point this Host Transport Node belongs to", | ||
| Optional: true, | ||
| ForceNew: true, | ||
| Default: "default", | ||
| }, | ||
| Metadata: metadata.Metadata{ | ||
| SchemaType: "string", | ||
| Skip: true, | ||
| }, | ||
| }, | ||
| "bfd_probe_interval": { | ||
| Schema: schema.Schema{ | ||
| Type: schema.TypeInt, | ||
| Optional: true, | ||
| Default: 500, | ||
| }, | ||
| Metadata: metadata.Metadata{ | ||
| SchemaType: "int", | ||
| SdkFieldName: "BfdProbeInterval", | ||
| }, | ||
| }, | ||
| "bfd_allowed_hops": { | ||
| Schema: schema.Schema{ | ||
| Type: schema.TypeInt, | ||
| Optional: true, | ||
| Default: 255, | ||
| }, | ||
| Metadata: metadata.Metadata{ | ||
| SchemaType: "int", | ||
| SdkFieldName: "BfdAllowedHops", | ||
| }, | ||
| }, | ||
| "bfd_declare_dead_multiple": { | ||
| Schema: schema.Schema{ | ||
| Type: schema.TypeInt, | ||
| Optional: true, | ||
| Default: 3, | ||
| }, | ||
| Metadata: metadata.Metadata{ | ||
| SchemaType: "int", | ||
| SdkFieldName: "BfdDeclareDeadMultiple", | ||
| }, | ||
| }, | ||
| "standby_relocation_config": { | ||
| Schema: schema.Schema{ | ||
| Type: schema.TypeList, | ||
| MaxItems: 1, | ||
| Elem: &metadata.ExtendedResource{ | ||
| Schema: map[string]*metadata.ExtendedSchema{ | ||
| "standby_relocation_threshold": { | ||
| Schema: schema.Schema{ | ||
| Type: schema.TypeInt, | ||
| Required: true, | ||
| }, | ||
| Metadata: metadata.Metadata{ | ||
| SchemaType: "int", | ||
| SdkFieldName: "StandbyRelocationThreshold", | ||
| }, | ||
| }, | ||
| }, | ||
| }, | ||
| Optional: true, | ||
| }, | ||
| Metadata: metadata.Metadata{ | ||
| SchemaType: "struct", | ||
| SdkFieldName: "StandbyRelocationConfig", | ||
| ReflectType: reflect.TypeOf(model.StandbyRelocationConfig{}), | ||
| }, | ||
| }, | ||
| } | ||
|
|
||
| func resourceNsxtPolicyEdgeHighAvailabilityProfile() *schema.Resource { | ||
| return &schema.Resource{ | ||
| Create: resourceNsxtPolicyEdgeHighAvailabilityProfileCreate, | ||
| Read: resourceNsxtPolicyEdgeHighAvailabilityProfileRead, | ||
| Update: resourceNsxtPolicyEdgeHighAvailabilityProfileUpdate, | ||
| Delete: resourceNsxtPolicyEdgeHighAvailabilityProfileDelete, | ||
| Importer: &schema.ResourceImporter{ | ||
| State: resourceNsxtPolicyEdgeHighAvailabilityProfileImporter, | ||
| }, | ||
| Schema: metadata.GetSchemaFromExtendedSchema(policyEdgeHighAvailabilityProfileSchema), | ||
| } | ||
| } | ||
|
|
||
| func resourceNsxtPolicyEdgeHighAvailabilityProfileExists(siteID, epID, id string, connector client.Connector) (bool, error) { | ||
| // Check site existence first | ||
| siteClient := infra.NewSitesClient(connector) | ||
| _, err := siteClient.Get(siteID) | ||
| if err != nil { | ||
| msg := fmt.Sprintf("failed to read site %s", siteID) | ||
| return false, logAPIError(msg, err) | ||
| } | ||
|
|
||
| client := enforcement_points.NewEdgeClusterHighAvailabilityProfilesClient(connector) | ||
| _, err = client.Get(siteID, epID, id) | ||
| if err == nil { | ||
| return true, nil | ||
| } | ||
|
|
||
| if isNotFoundError(err) { | ||
| return false, nil | ||
| } | ||
|
|
||
| return false, logAPIError("Error retrieving resource", err) | ||
| } | ||
|
|
||
| func resourceNsxtPolicyEdgeHighAvailabilityProfileCreate(d *schema.ResourceData, m interface{}) error { | ||
| id := d.Get("nsx_id").(string) | ||
| if id == "" { | ||
| id = newUUID() | ||
| } | ||
| sitePath := d.Get("site_path").(string) | ||
| siteID := getResourceIDFromResourcePath(sitePath, "sites") | ||
| if siteID == "" { | ||
| return fmt.Errorf("error obtaining Site ID from site path %s", sitePath) | ||
| } | ||
| epID := d.Get("enforcement_point").(string) | ||
| if epID == "" { | ||
| epID = getPolicyEnforcementPoint(m) | ||
| } | ||
|
|
||
| connector := getPolicyConnector(m) | ||
| exists, err := resourceNsxtPolicyEdgeHighAvailabilityProfileExists(siteID, epID, id, connector) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| if exists { | ||
| return fmt.Errorf("resource with ID %s already exists", id) | ||
| } | ||
|
|
||
| displayName := d.Get("display_name").(string) | ||
| description := d.Get("description").(string) | ||
| tags := getPolicyTagsFromSchema(d) | ||
|
|
||
| obj := model.PolicyEdgeHighAvailabilityProfile{ | ||
| DisplayName: &displayName, | ||
| Description: &description, | ||
| Tags: tags, | ||
| } | ||
|
|
||
| elem := reflect.ValueOf(&obj).Elem() | ||
| if err := metadata.SchemaToStruct(elem, d, policyEdgeHighAvailabilityProfileSchema, "", nil); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| log.Printf("[INFO] Creating PolicyEdgeHighAvailabilityProfile with ID %s", id) | ||
|
|
||
| client := enforcement_points.NewEdgeClusterHighAvailabilityProfilesClient(connector) | ||
| err = client.Patch(siteID, epID, id, obj) | ||
| if err != nil { | ||
| return handleCreateError("PolicyEdgeHighAvailabilityProfile", id, err) | ||
| } | ||
| d.SetId(id) | ||
| d.Set("nsx_id", id) | ||
|
|
||
| return resourceNsxtPolicyEdgeHighAvailabilityProfileRead(d, m) | ||
| } | ||
|
|
||
| func resourceNsxtPolicyEdgeHighAvailabilityProfileRead(d *schema.ResourceData, m interface{}) error { | ||
| id, siteID, epID, err := policyIDSiteEPTuple(d, m) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| connector := getPolicyConnector(m) | ||
| client := enforcement_points.NewEdgeClusterHighAvailabilityProfilesClient(connector) | ||
| obj, err := client.Get(siteID, epID, id) | ||
| if err != nil { | ||
| return handleReadError(d, "PolicyEdgeHighAvailabilityProfile", id, err) | ||
| } | ||
|
|
||
| setPolicyTagsInSchema(d, obj.Tags) | ||
| d.Set("nsx_id", id) | ||
| d.Set("display_name", obj.DisplayName) | ||
| d.Set("description", obj.Description) | ||
| d.Set("revision", obj.Revision) | ||
| d.Set("path", obj.Path) | ||
|
|
||
| elem := reflect.ValueOf(&obj).Elem() | ||
| return metadata.StructToSchema(elem, d, policyEdgeHighAvailabilityProfileSchema, "", nil) | ||
| } | ||
|
|
||
| func resourceNsxtPolicyEdgeHighAvailabilityProfileUpdate(d *schema.ResourceData, m interface{}) error { | ||
| id, siteID, epID, err := policyIDSiteEPTuple(d, m) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| description := d.Get("description").(string) | ||
| displayName := d.Get("display_name").(string) | ||
| tags := getPolicyTagsFromSchema(d) | ||
|
|
||
| revision := int64(d.Get("revision").(int)) | ||
|
|
||
| obj := model.PolicyEdgeHighAvailabilityProfile{ | ||
| DisplayName: &displayName, | ||
| Description: &description, | ||
| Tags: tags, | ||
| Revision: &revision, | ||
| } | ||
|
|
||
| elem := reflect.ValueOf(&obj).Elem() | ||
| if err := metadata.SchemaToStruct(elem, d, policyEdgeHighAvailabilityProfileSchema, "", nil); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| connector := getPolicyConnector(m) | ||
| client := enforcement_points.NewEdgeClusterHighAvailabilityProfilesClient(connector) | ||
| _, err = client.Update(siteID, epID, id, obj) | ||
| if err != nil { | ||
| return handleUpdateError("PolicyEdgeHighAvailabilityProfile", id, err) | ||
| } | ||
|
|
||
| return resourceNsxtPolicyEdgeHighAvailabilityProfileRead(d, m) | ||
| } | ||
|
|
||
| func resourceNsxtPolicyEdgeHighAvailabilityProfileDelete(d *schema.ResourceData, m interface{}) error { | ||
| id, siteID, epID, err := policyIDSiteEPTuple(d, m) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| connector := getPolicyConnector(m) | ||
| client := enforcement_points.NewEdgeClusterHighAvailabilityProfilesClient(connector) | ||
| err = client.Delete(siteID, epID, id) | ||
|
|
||
| if err != nil { | ||
| return handleDeleteError("PolicyEdgeHighAvailabilityProfile", id, err) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func resourceNsxtPolicyEdgeHighAvailabilityProfileImporter(d *schema.ResourceData, m interface{}) ([]*schema.ResourceData, error) { | ||
| importID := d.Id() | ||
| rd, err := nsxtPolicyPathResourceImporterHelper(d, m) | ||
| if err != nil { | ||
| return rd, err | ||
| } | ||
|
|
||
| epID, err := getParameterFromPolicyPath("/enforcement-points/", "/edge-cluster-high-availability-profiles/", importID) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| d.Set("enforcement_point", epID) | ||
| sitePath, err := getSitePathFromChildResourcePath(importID) | ||
| if err != nil { | ||
| return rd, err | ||
| } | ||
| d.Set("site_path", sitePath) | ||
|
|
||
| return rd, nil | ||
| } |
Oops, something went wrong.