lb monitor operations
This commit is contained in:
Jon Perritt
parent
9077b66045
commit
966c8420d1
|
|
@ -0,0 +1,227 @@
|
|||
package openstack
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"log"
|
||||
"strconv"
|
||||
|
||||
"github.com/hashicorp/terraform/helper/schema"
|
||||
"github.com/rackspace/gophercloud/openstack/networking/v2/extensions/lbaas/monitors"
|
||||
)
|
||||
|
||||
func resourceLBMonitor() *schema.Resource {
|
||||
return &schema.Resource{
|
||||
Create: resourceLBMonitorCreate,
|
||||
Read: resourceLBMonitorRead,
|
||||
Update: resourceLBMonitorUpdate,
|
||||
Delete: resourceLBMonitorDelete,
|
||||
|
||||
Schema: map[string]*schema.Schema{
|
||||
"tenant_id": &schema.Schema{
|
||||
Type: schema.TypeString,
|
||||
Optional: true,
|
||||
ForceNew: true,
|
||||
},
|
||||
|
||||
"type": &schema.Schema{
|
||||
Type: schema.TypeString,
|
||||
Required: true,
|
||||
ForceNew: true,
|
||||
},
|
||||
|
||||
"delay": &schema.Schema{
|
||||
Type: schema.TypeInt,
|
||||
Required: true,
|
||||
ForceNew: false,
|
||||
},
|
||||
|
||||
"timeout": &schema.Schema{
|
||||
Type: schema.TypeInt,
|
||||
Required: true,
|
||||
ForceNew: false,
|
||||
},
|
||||
|
||||
"max_retries": &schema.Schema{
|
||||
Type: schema.TypeInt,
|
||||
Required: true,
|
||||
ForceNew: false,
|
||||
},
|
||||
|
||||
"url_path": &schema.Schema{
|
||||
Type: schema.TypeString,
|
||||
Optional: true,
|
||||
ForceNew: false,
|
||||
},
|
||||
|
||||
"http_method": &schema.Schema{
|
||||
Type: schema.TypeString,
|
||||
Optional: true,
|
||||
ForceNew: false,
|
||||
},
|
||||
|
||||
"expected_codes": &schema.Schema{
|
||||
Type: schema.TypeString,
|
||||
Optional: true,
|
||||
ForceNew: false,
|
||||
},
|
||||
|
||||
"admin_state_up": &schema.Schema{
|
||||
Type: schema.TypeString,
|
||||
Optional: true,
|
||||
ForceNew: false,
|
||||
},
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
func resourceLBMonitorCreate(d *schema.ResourceData, meta interface{}) error {
|
||||
config := meta.(*Config)
|
||||
osClient := config.networkingV2Client
|
||||
|
||||
createOpts := monitors.CreateOpts{
|
||||
TenantID: d.Get("tenant_id").(string),
|
||||
Type: d.Get("type").(string),
|
||||
Delay: d.Get("delay").(int),
|
||||
Timeout: d.Get("timeout").(int),
|
||||
MaxRetries: d.Get("max_retries").(int),
|
||||
URLPath: d.Get("url_path").(string),
|
||||
ExpectedCodes: d.Get("expected_codes").(string),
|
||||
HTTPMethod: d.Get("http_method").(string),
|
||||
}
|
||||
|
||||
asuRaw := d.Get("admin_state_up").(string)
|
||||
if asuRaw != "" {
|
||||
asu, err := strconv.ParseBool(asuRaw)
|
||||
if err != nil {
|
||||
return fmt.Errorf("admin_state_up, if provided, must be either 'true' or 'false'")
|
||||
}
|
||||
createOpts.AdminStateUp = &asu
|
||||
}
|
||||
|
||||
log.Printf("[INFO] Requesting lb monitor creation")
|
||||
m, err := monitors.Create(osClient, createOpts).Extract()
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error creating OpenStack LB Monitor: %s", err)
|
||||
}
|
||||
log.Printf("[INFO] LB Monitor ID: %s", m.ID)
|
||||
|
||||
d.SetId(m.ID)
|
||||
|
||||
return resourceLBMonitorRead(d, meta)
|
||||
}
|
||||
|
||||
func resourceLBMonitorRead(d *schema.ResourceData, meta interface{}) error {
|
||||
config := meta.(*Config)
|
||||
osClient := config.networkingV2Client
|
||||
|
||||
m, err := monitors.Get(osClient, d.Id()).Extract()
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error retrieving OpenStack LB Monitor: %s", err)
|
||||
}
|
||||
|
||||
log.Printf("[DEBUG] Retreived OpenStack LB Monitor %s: %+v", d.Id(), m)
|
||||
|
||||
d.Set("type", m.Type)
|
||||
d.Set("delay", m.Delay)
|
||||
d.Set("timeout", m.Timeout)
|
||||
d.Set("max_retries", m.MaxRetries)
|
||||
|
||||
if _, exists := d.GetOk("tenant_id"); exists {
|
||||
if d.HasChange("tenant_id") {
|
||||
d.Set("tenant_id", m.TenantID)
|
||||
}
|
||||
} else {
|
||||
d.Set("tenant_id", "")
|
||||
}
|
||||
|
||||
if _, exists := d.GetOk("url_path"); exists {
|
||||
if d.HasChange("url_path") {
|
||||
d.Set("url_path", m.URLPath)
|
||||
}
|
||||
} else {
|
||||
d.Set("url_path", "")
|
||||
}
|
||||
|
||||
if _, exists := d.GetOk("http_method"); exists {
|
||||
if d.HasChange("http_method") {
|
||||
d.Set("http_method", m.HTTPMethod)
|
||||
}
|
||||
} else {
|
||||
d.Set("http_method", "")
|
||||
}
|
||||
|
||||
if _, exists := d.GetOk("expected_codes"); exists {
|
||||
if d.HasChange("expected_codes") {
|
||||
d.Set("expected_codes", m.ExpectedCodes)
|
||||
}
|
||||
} else {
|
||||
d.Set("expected_codes", "")
|
||||
}
|
||||
|
||||
if _, exists := d.GetOk("admin_state_up"); exists {
|
||||
if d.HasChange("admin_state_up") {
|
||||
d.Set("admin_state_up", strconv.FormatBool(m.AdminStateUp))
|
||||
}
|
||||
} else {
|
||||
d.Set("admin_state_up", "")
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func resourceLBMonitorUpdate(d *schema.ResourceData, meta interface{}) error {
|
||||
config := meta.(*Config)
|
||||
osClient := config.networkingV2Client
|
||||
|
||||
var updateOpts monitors.UpdateOpts
|
||||
if d.HasChange("delay") {
|
||||
updateOpts.Delay = d.Get("delay").(int)
|
||||
}
|
||||
if d.HasChange("timeout") {
|
||||
updateOpts.Timeout = d.Get("timeout").(int)
|
||||
}
|
||||
if d.HasChange("max_retries") {
|
||||
updateOpts.MaxRetries = d.Get("max_retries").(int)
|
||||
}
|
||||
if d.HasChange("url_path") {
|
||||
updateOpts.URLPath = d.Get("url_path").(string)
|
||||
}
|
||||
if d.HasChange("http_method") {
|
||||
updateOpts.HTTPMethod = d.Get("http_method").(string)
|
||||
}
|
||||
if d.HasChange("expected_codes") {
|
||||
updateOpts.ExpectedCodes = d.Get("expected_codes").(string)
|
||||
}
|
||||
if d.HasChange("admin_state_up") {
|
||||
asuRaw := d.Get("admin_state_up").(string)
|
||||
if asuRaw != "" {
|
||||
asu, err := strconv.ParseBool(asuRaw)
|
||||
if err != nil {
|
||||
return fmt.Errorf("admin_state_up, if provided, must be either 'true' or 'false'")
|
||||
}
|
||||
updateOpts.AdminStateUp = &asu
|
||||
}
|
||||
}
|
||||
|
||||
log.Printf("[DEBUG] Updating OpenStack LB Monitor %s with options: %+v", d.Id(), updateOpts)
|
||||
|
||||
_, err := monitors.Update(osClient, d.Id(), updateOpts).Extract()
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error updating OpenStack LB Monitor: %s", err)
|
||||
}
|
||||
|
||||
return resourceLBMonitorRead(d, meta)
|
||||
}
|
||||
|
||||
func resourceLBMonitorDelete(d *schema.ResourceData, meta interface{}) error {
|
||||
config := meta.(*Config)
|
||||
osClient := config.networkingV2Client
|
||||
|
||||
err := monitors.Delete(osClient, d.Id()).ExtractErr()
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error deleting OpenStack LB Monitor: %s", err)
|
||||
}
|
||||
|
||||
d.SetId("")
|
||||
return nil
|
||||
}
|
||||
|
|
@ -0,0 +1,76 @@
|
|||
---
|
||||
layout: "openstack"
|
||||
page_title: "OpenStack: openstack_lb_monitor"
|
||||
sidebar_current: "docs-openstack-resource-lb-monitor"
|
||||
description: |-
|
||||
Manages a load balancer monitor resource within OpenStack.
|
||||
---
|
||||
|
||||
# openstack\_lb\_monitor
|
||||
|
||||
Manages a load balancer monitor resource within OpenStack.
|
||||
|
||||
## Example Usage
|
||||
|
||||
```
|
||||
resource "openstack_lb_monitor" "monitor_1" {
|
||||
type = "PING"
|
||||
delay = 30
|
||||
timeout = 5
|
||||
max_retries = 3
|
||||
admin_state_up = "true"
|
||||
}
|
||||
```
|
||||
|
||||
## Argument Reference
|
||||
|
||||
The following arguments are supported:
|
||||
|
||||
* `type` - (Required) The type of probe, which is PING, TCP, HTTP, or HTTPS,
|
||||
that is sent by the monitor to verify the member state. Changing this
|
||||
creates a new monitor.
|
||||
|
||||
* `delay` - (Required) The time, in seconds, between sending probes to members.
|
||||
Changing this creates a new monitor.
|
||||
|
||||
* `timeout` - (Required) Maximum number of seconds for a monitor to wait for a
|
||||
ping reply before it times out. The value must be less than the delay value.
|
||||
Changing this updates the timeout of the existing monitor.
|
||||
|
||||
* `max_retries` - (Required) Number of permissible ping failures before changing
|
||||
the member's status to INACTIVE. Must be a number between 1 and 10. Changing
|
||||
this updates the max_retries of the existing monitor.
|
||||
|
||||
* `url_path` - (Optional) Required for HTTP(S) types. URI path that will be
|
||||
accessed if monitor type is HTTP or HTTPS. Changing this updates the
|
||||
url_path of the existing monitor.
|
||||
|
||||
* `http_method` - (Optional) Required for HTTP(S) types. The HTTP method used
|
||||
for requests by the monitor. If this attribute is not specified, it defaults
|
||||
to "GET". Changing this updates the http_method of the existing monitor.
|
||||
|
||||
* `expected_codes` - (Optional) equired for HTTP(S) types. Expected HTTP codes
|
||||
for a passing HTTP(S) monitor. You can either specify a single status like
|
||||
"200", or a range like "200-202". Changing this updates the expected_codes
|
||||
of the existing monitor.
|
||||
|
||||
* `admin_state_up` - (Optional) The administrative state of the monitor.
|
||||
Acceptable values are "true" and "false". Changing this value updates the
|
||||
state of the existing monitor.
|
||||
|
||||
* `tenant_id` - (Optional) The owner of the monitor. Required if admin wants to
|
||||
create a monitor for another tenant. Changing this creates a new monitor.
|
||||
|
||||
## Attributes Reference
|
||||
|
||||
The following attributes are exported:
|
||||
|
||||
* `type` - See Argument Reference above.
|
||||
* `delay` - See Argument Reference above.
|
||||
* `timeout` - See Argument Reference above.
|
||||
* `max_retries` - See Argument Reference above.
|
||||
* `url_path` - See Argument Reference above.
|
||||
* `http_method` - See Argument Reference above.
|
||||
* `expected_codes` - See Argument Reference above.
|
||||
* `admin_state_up` - See Argument Reference above.
|
||||
* `tenant_id` - See Argument Reference above.
|
||||
Loading…
Reference in New Issue