Fixes for consul_service resource (#9366)

Added `service_id` in place of `id` for resource.
modified created, read, update to use `service_id`
modified tests to include `service_id`.
modified documentation for consul_service to include new value.

Tests results

CONSUL_HTTP_ADDR=localhost:8500 make testacc TEST=./builtin/providers/consul/

==> Checking that code complies with gofmt requirements...
go generate $(go list ./... | grep -v /terraform/vendor/)
2016/10/14 14:43:05 Generated command/internal_plugin_list.go
TF_ACC=1 go test ./builtin/providers/consul/ -v  -timeout 120m
=== RUN   TestAccDataConsulKeys_basic
--- PASS: TestAccDataConsulKeys_basic (0.05s)
=== RUN   TestAccConsulAgentService_basic
--- PASS: TestAccConsulAgentService_basic (0.05s)
=== RUN   TestAccConsulCatalogEntry_basic
--- PASS: TestAccConsulCatalogEntry_basic (0.06s)
=== RUN   TestAccConsulKeyPrefix_basic
--- PASS: TestAccConsulKeyPrefix_basic (0.19s)
=== RUN   TestConsulKeysMigrateState
--- PASS: TestConsulKeysMigrateState (0.00s)
=== RUN   TestConsulKeysMigrateState_empty
--- PASS: TestConsulKeysMigrateState_empty (0.00s)
=== RUN   TestAccConsulKeys_basic
--- PASS: TestAccConsulKeys_basic (0.13s)
=== RUN   TestAccConsulNode_basic
--- PASS: TestAccConsulNode_basic (0.05s)
=== RUN   TestAccConsulPreparedQuery_basic
--- PASS: TestAccConsulPreparedQuery_basic (0.12s)
=== RUN   TestAccConsulService_basic
--- PASS: TestAccConsulService_basic (0.05s)
=== RUN   TestResourceProvider
--- PASS: TestResourceProvider (0.00s)
=== RUN   TestResourceProvider_impl
--- PASS: TestResourceProvider_impl (0.00s)
=== RUN   TestResourceProvider_Configure
--- PASS: TestResourceProvider_Configure (0.00s)
=== RUN   TestResourceProvider_ConfigureTLS
--- PASS: TestResourceProvider_ConfigureTLS (0.00s)
PASS
ok  	github.com/hashicorp/terraform/builtin/providers/consul	0.708s

Refs: #9352
This commit is contained in:
Daniel Portella 2016-10-26 13:07:00 +01:00 committed by Paul Stack
parent 3ee6f36b59
commit c2370c574e
3 changed files with 35 additions and 16 deletions

View File

@ -22,9 +22,11 @@ func resourceConsulService() *schema.Resource {
ForceNew: true, ForceNew: true,
}, },
"id": &schema.Schema{ "service_id": &schema.Schema{
Type: schema.TypeString, Type: schema.TypeString,
Optional: true,
Computed: true, Computed: true,
ForceNew: true,
}, },
"name": &schema.Schema{ "name": &schema.Schema{
@ -53,7 +55,13 @@ func resourceConsulServiceCreate(d *schema.ResourceData, meta interface{}) error
agent := client.Agent() agent := client.Agent()
name := d.Get("name").(string) name := d.Get("name").(string)
registration := consulapi.AgentServiceRegistration{Name: name} identifier := name
if serviceId, ok := d.GetOk("service_id"); ok {
identifier = serviceId.(string)
}
registration := consulapi.AgentServiceRegistration{Name: name, ID: identifier}
if address, ok := d.GetOk("address"); ok { if address, ok := d.GetOk("address"); ok {
registration.Address = address.(string) registration.Address = address.(string)
@ -79,12 +87,13 @@ func resourceConsulServiceCreate(d *schema.ResourceData, meta interface{}) error
// Update the resource // Update the resource
if serviceMap, err := agent.Services(); err != nil { if serviceMap, err := agent.Services(); err != nil {
return fmt.Errorf("Failed to read services from Consul agent: %v", err) return fmt.Errorf("Failed to read services from Consul agent: %v", err)
} else if service, ok := serviceMap[name]; !ok { } else if service, ok := serviceMap[identifier]; !ok {
return fmt.Errorf("Failed to read service '%s' from Consul agent: %v", name, err) return fmt.Errorf("Failed to read service '%s' from Consul agent: %v", identifier, err)
} else { } else {
d.Set("address", service.Address)
d.Set("id", service.ID)
d.SetId(service.ID) d.SetId(service.ID)
d.Set("address", service.Address)
d.Set("service_id", service.ID)
d.Set("name", service.Service) d.Set("name", service.Service)
d.Set("port", service.Port) d.Set("port", service.Port)
tags := make([]string, 0, len(service.Tags)) tags := make([]string, 0, len(service.Tags))
@ -102,15 +111,21 @@ func resourceConsulServiceRead(d *schema.ResourceData, meta interface{}) error {
agent := client.Agent() agent := client.Agent()
name := d.Get("name").(string) name := d.Get("name").(string)
identifier := name
if serviceId, ok := d.GetOk("service_id"); ok {
identifier = serviceId.(string)
}
if services, err := agent.Services(); err != nil { if services, err := agent.Services(); err != nil {
return fmt.Errorf("Failed to get services from Consul agent: %v", err) return fmt.Errorf("Failed to get services from Consul agent: %v", err)
} else if service, ok := services[name]; !ok { } else if service, ok := services[identifier]; !ok {
return fmt.Errorf("Failed to get service '%s' from Consul agent", name) return fmt.Errorf("Failed to get service '%s' from Consul agent", identifier)
} else { } else {
d.Set("address", service.Address)
d.Set("id", service.ID)
d.SetId(service.ID) d.SetId(service.ID)
d.Set("address", service.Address)
d.Set("service_id", service.ID)
d.Set("name", service.Service) d.Set("name", service.Service)
d.Set("port", service.Port) d.Set("port", service.Port)
tags := make([]string, 0, len(service.Tags)) tags := make([]string, 0, len(service.Tags))
@ -127,7 +142,7 @@ func resourceConsulServiceDelete(d *schema.ResourceData, meta interface{}) error
client := meta.(*consulapi.Client) client := meta.(*consulapi.Client)
catalog := client.Agent() catalog := client.Agent()
id := d.Get("id").(string) id := d.Get("service_id").(string)
if err := catalog.ServiceDeregister(id); err != nil { if err := catalog.ServiceDeregister(id); err != nil {
return fmt.Errorf("Failed to deregister service '%s' from Consul agent: %v", id, err) return fmt.Errorf("Failed to deregister service '%s' from Consul agent: %v", id, err)

View File

@ -21,6 +21,7 @@ func TestAccConsulService_basic(t *testing.T) {
testAccCheckConsulServiceExists(), testAccCheckConsulServiceExists(),
testAccCheckConsulServiceValue("consul_service.app", "address", "www.google.com"), testAccCheckConsulServiceValue("consul_service.app", "address", "www.google.com"),
testAccCheckConsulServiceValue("consul_service.app", "id", "google"), testAccCheckConsulServiceValue("consul_service.app", "id", "google"),
testAccCheckConsulServiceValue("consul_service.app", "service_id", "google"),
testAccCheckConsulServiceValue("consul_service.app", "name", "google"), testAccCheckConsulServiceValue("consul_service.app", "name", "google"),
testAccCheckConsulServiceValue("consul_service.app", "port", "80"), testAccCheckConsulServiceValue("consul_service.app", "port", "80"),
testAccCheckConsulServiceValue("consul_service.app", "tags.#", "2"), testAccCheckConsulServiceValue("consul_service.app", "tags.#", "2"),
@ -83,6 +84,7 @@ func testAccCheckConsulServiceValue(n, attr, val string) resource.TestCheckFunc
const testAccConsulServiceConfig = ` const testAccConsulServiceConfig = `
resource "consul_service" "app" { resource "consul_service" "app" {
address = "www.google.com" address = "www.google.com"
service_id = "google"
name = "google" name = "google"
port = 80 port = 80
tags = ["tag0", "tag1"] tags = ["tag0", "tag1"]

View File

@ -25,14 +25,16 @@ resource "consul_service" "google" {
The following arguments are supported: The following arguments are supported:
* `address` - (Optional) The address of the service. Defaults to the * `service_id` - (Optional, string) The id of the service, defaults to the value of `name` if not supplied.
* `address` - (Optional, string) The address of the service. Defaults to the
address of the agent. address of the agent.
* `name` - (Required) The name of the service. * `name` - (Required, string) The name of the service.
* `port` - (Optional) The port of the service. * `port` - (Optional, int) The port of the service.
* `tags` - (Optional) A list of values that are opaque to Consul, * `tags` - (Optional, set of strings) A list of values that are opaque to Consul,
but can be used to distinguish between services or nodes. but can be used to distinguish between services or nodes.
@ -40,8 +42,8 @@ The following arguments are supported:
The following attributes are exported: The following attributes are exported:
* `service_id` - The id of the service, defaults to the value of `name`.
* `address` - The address of the service. * `address` - The address of the service.
* `id` - The id of the service, defaults to the value of `name`.
* `name` - The name of the service. * `name` - The name of the service.
* `port` - The port of the service. * `port` - The port of the service.
* `tags` - The tags of the service. * `tags` - The tags of the service.