lb member operations

builtin/providers/openstack/resource_openstack_lb_member.go

@@ -0,0 +1,131 @@
+package openstack
+
+import (
+	"fmt"
+	"log"
+
+	"github.com/hashicorp/terraform/helper/schema"
+	"github.com/rackspace/gophercloud/openstack/networking/v2/extensions/lbaas/members"
+)
+
+func resourceLBMember() *schema.Resource {
+	return &schema.Resource{
+		Create: resourceLBMemberCreate,
+		Read:   resourceLBMemberRead,
+		Update: resourceLBMemberUpdate,
+		Delete: resourceLBMemberDelete,
+
+		Schema: map[string]*schema.Schema{
+			"tenant_id": &schema.Schema{
+				Type:     schema.TypeString,
+				Optional: true,
+				ForceNew: true,
+			},
+
+			"address": &schema.Schema{
+				Type:     schema.TypeString,
+				Required: true,
+				ForceNew: true,
+			},
+
+			"port": &schema.Schema{
+				Type:     schema.TypeInt,
+				Required: true,
+				ForceNew: true,
+			},
+
+			"pool_id": &schema.Schema{
+				Type:     schema.TypeString,
+				Required: true,
+				ForceNew: true,
+			},
+
+			"admin_state_up": &schema.Schema{
+				Type:     schema.TypeBool,
+				Required: true,
+				ForceNew: false,
+			},
+		},
+	}
+}
+
+func resourceLBMemberCreate(d *schema.ResourceData, meta interface{}) error {
+	config := meta.(*Config)
+	osClient := config.networkingV2Client
+
+	createOpts := members.CreateOpts{
+		//TenantID:     d.Get("tenant_id").(string),
+		Address:      d.Get("address").(string),
+		ProtocolPort: d.Get("port").(int),
+		PoolID:       d.Get("pool_id").(string),
+	}
+
+	log.Printf("[INFO] Requesting lb member creation")
+	p, err := members.Create(osClient, createOpts).Extract()
+	if err != nil {
+		return fmt.Errorf("Error creating OpenStack LB member: %s", err)
+	}
+	log.Printf("[INFO] LB Member ID: %s", p.ID)
+
+	d.SetId(p.ID)
+
+	return resourceLBMemberRead(d, meta)
+}
+
+func resourceLBMemberRead(d *schema.ResourceData, meta interface{}) error {
+	config := meta.(*Config)
+	osClient := config.networkingV2Client
+
+	p, err := members.Get(osClient, d.Id()).Extract()
+	if err != nil {
+		return fmt.Errorf("Error retrieving OpenStack LB Member: %s", err)
+	}
+
+	log.Printf("[DEBUG] Retreived OpenStack LB Member %s: %+v", d.Id(), p)
+
+	d.Set("address", p.Address)
+	d.Set("port", p.ProtocolPort)
+	d.Set("pool_id", p.PoolID)
+
+	if _, exists := d.GetOk("tenant_id"); exists {
+		if d.HasChange("tenant_id") {
+			d.Set("tenant_id", p.TenantID)
+		}
+	} else {
+		d.Set("tenant_id", "")
+	}
+
+	return nil
+}
+
+func resourceLBMemberUpdate(d *schema.ResourceData, meta interface{}) error {
+	config := meta.(*Config)
+	osClient := config.networkingV2Client
+
+	var updateOpts members.UpdateOpts
+	if d.HasChange("admin_state_up") {
+		updateOpts.AdminStateUp = d.Get("admin_state_up").(bool)
+	}
+
+	log.Printf("[DEBUG] Updating OpenStack LB Member %s with options: %+v", d.Id(), updateOpts)
+
+	_, err := members.Update(osClient, d.Id(), updateOpts).Extract()
+	if err != nil {
+		return fmt.Errorf("Error updating OpenStack LB Member: %s", err)
+	}
+
+	return resourceLBMemberRead(d, meta)
+}
+
+func resourceLBMemberDelete(d *schema.ResourceData, meta interface{}) error {
+	config := meta.(*Config)
+	osClient := config.networkingV2Client
+
+	err := members.Delete(osClient, d.Id()).ExtractErr()
+	if err != nil {
+		return fmt.Errorf("Error deleting OpenStack LB Member: %s", err)
+	}
+
+	d.SetId("")
+	return nil
+}

website/source/docs/providers/openstack/r/lb_member.html.markdown

@@ -0,0 +1,52 @@
+---
+layout: "openstack"
+page_title: "OpenStack: openstack_lb_member"
+sidebar_current: "docs-openstack-resource-lb-member"
+description: |-
+  Manages a load balancer member resource within OpenStack.
+---
+
+# openstack\_lb\_member
+
+Manages a load balancer member resource within OpenStack.
+
+## Example Usage
+
+```
+resource "openstack_lb_member" "node_1" {
+  address = "196.172.0.1"
+  port = 80
+  pool_id = "$12345"
+  admin_state_up = true
+}
+```
+
+## Argument Reference
+
+The following arguments are supported:
+
+* `address` - (Required) The IP address of the member. Changing this creates a
+    new member.
+
+* `port` - (Required) An integer representing the port on which the member is
+    hosted. Changing this creates a new member.
+
+* `pool_id` - (Required) The pool to which this member will belong. Changing
+    this creates a new member.
+
+* `admin_state_up` - (Optional) The administrative state of the member.
+    Acceptable values are 'true' and 'false'. Changing this value updates the
+    state of the existing member.
+
+* `tenant_id` - (Optional) The owner of the member. Required if admin wants to
+    create a pool member for another tenant. Changing this creates a new member.
+
+## Attributes Reference
+
+The following attributes are exported:
+
+* `address` - See Argument Reference above.
+* `port` - See Argument Reference above.
+* `pool_id` - See Argument Reference above.
+* `admin_state_up` - See Argument Reference above.
+* `tenant_id` - See Argument Reference above.