Add docs for the `consul_catalog_services` data source.
This commit is contained in:
parent
b7c9dedf4e
commit
9d06a47069
|
@ -11,10 +11,13 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
catalogServicesDatacenter = "datacenter"
|
// Datasource predicates
|
||||||
catalogServicesNames = "names"
|
|
||||||
|
|
||||||
catalogServicesServiceName = "name"
|
catalogServicesServiceName = "name"
|
||||||
|
|
||||||
|
// Out parameters
|
||||||
|
catalogServicesDatacenter = "datacenter"
|
||||||
|
catalogServicesNames = "names"
|
||||||
|
catalogServicesServices = "services"
|
||||||
catalogServicesServiceTags = "tags"
|
catalogServicesServiceTags = "tags"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -34,17 +37,19 @@ func dataSourceConsulCatalogServices() *schema.Resource {
|
||||||
|
|
||||||
// Out parameters
|
// Out parameters
|
||||||
catalogServicesNames: &schema.Schema{
|
catalogServicesNames: &schema.Schema{
|
||||||
|
Type: schema.TypeList,
|
||||||
|
Computed: true,
|
||||||
|
Elem: &schema.Schema{Type: schema.TypeString},
|
||||||
|
},
|
||||||
|
catalogServicesServices: &schema.Schema{
|
||||||
Computed: true,
|
Computed: true,
|
||||||
Type: schema.TypeMap,
|
Type: schema.TypeMap,
|
||||||
Elem: &schema.Resource{
|
Elem: &schema.Resource{
|
||||||
Schema: map[string]*schema.Schema{
|
Schema: map[string]*schema.Schema{
|
||||||
catalogServiceServiceTags: &schema.Schema{
|
catalogServiceServiceTags: &schema.Schema{
|
||||||
// FIXME(sean@): Tags is currently a space separated list of tags.
|
Type: schema.TypeList,
|
||||||
// The ideal structure should be map[string][]string instead.
|
|
||||||
// When this is supported in the future this should be changed to
|
|
||||||
// be a TypeList instead.
|
|
||||||
Type: schema.TypeString,
|
|
||||||
Computed: true,
|
Computed: true,
|
||||||
|
Elem: &schema.Schema{Type: schema.TypeString},
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
@ -67,7 +72,7 @@ func dataSourceConsulCatalogServicesRead(d *schema.ResourceData, meta interface{
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
m := make(map[string]interface{}, len(services))
|
catalogServices := make(map[string]interface{}, len(services))
|
||||||
for name, tags := range services {
|
for name, tags := range services {
|
||||||
tagList := make([]string, 0, len(tags))
|
tagList := make([]string, 0, len(tags))
|
||||||
for _, tag := range tags {
|
for _, tag := range tags {
|
||||||
|
@ -75,16 +80,25 @@ func dataSourceConsulCatalogServicesRead(d *schema.ResourceData, meta interface{
|
||||||
}
|
}
|
||||||
|
|
||||||
sort.Strings(tagList)
|
sort.Strings(tagList)
|
||||||
m[name] = strings.Join(tagList, " ")
|
catalogServices[name] = strings.Join(tagList, " ")
|
||||||
|
}
|
||||||
|
|
||||||
|
serviceNames := make([]interface{}, 0, len(services))
|
||||||
|
for k := range catalogServices {
|
||||||
|
serviceNames = append(serviceNames, k)
|
||||||
}
|
}
|
||||||
|
|
||||||
const idKeyFmt = "catalog-services-%s"
|
const idKeyFmt = "catalog-services-%s"
|
||||||
d.SetId(fmt.Sprintf(idKeyFmt, queryOpts.Datacenter))
|
d.SetId(fmt.Sprintf(idKeyFmt, queryOpts.Datacenter))
|
||||||
|
|
||||||
d.Set(catalogServicesDatacenter, queryOpts.Datacenter)
|
d.Set(catalogServicesDatacenter, queryOpts.Datacenter)
|
||||||
if err := d.Set(catalogServicesNames, m); err != nil {
|
if err := d.Set(catalogServicesServices, catalogServices); err != nil {
|
||||||
return errwrap.Wrapf("Unable to store services: {{err}}", err)
|
return errwrap.Wrapf("Unable to store services: {{err}}", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if err := d.Set(catalogServicesNames, serviceNames); err != nil {
|
||||||
|
return errwrap.Wrapf("Unable to store service names: {{err}}", err)
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -15,8 +15,8 @@ func TestAccDataConsulCatalogServices_basic(t *testing.T) {
|
||||||
Config: testAccDataConsulCatalogServicesConfig,
|
Config: testAccDataConsulCatalogServicesConfig,
|
||||||
Check: resource.ComposeTestCheckFunc(
|
Check: resource.ComposeTestCheckFunc(
|
||||||
testAccCheckDataSourceValue("data.consul_catalog_services.read", "datacenter", "dc1"),
|
testAccCheckDataSourceValue("data.consul_catalog_services.read", "datacenter", "dc1"),
|
||||||
testAccCheckDataSourceValue("data.consul_catalog_services.read", "names.%", "1"),
|
testAccCheckDataSourceValue("data.consul_catalog_services.read", "services.%", "1"),
|
||||||
testAccCheckDataSourceValue("data.consul_catalog_services.read", "names.consul", ""),
|
testAccCheckDataSourceValue("data.consul_catalog_services.read", "services.consul", ""),
|
||||||
),
|
),
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
|
|
@ -0,0 +1,80 @@
|
||||||
|
---
|
||||||
|
layout: "consul"
|
||||||
|
page_title: "Consul: consul_catalog_services"
|
||||||
|
sidebar_current: "docs-consul-data-source-catalog-services"
|
||||||
|
description: |-
|
||||||
|
Provides a list of services in a given Consul datacenter.
|
||||||
|
---
|
||||||
|
|
||||||
|
# consul\_catalog\_services
|
||||||
|
|
||||||
|
The `consul_catalog_services` data source returns a list of Consul services that
|
||||||
|
have been registered with the Consul cluster in a given datacenter. By
|
||||||
|
specifying a different datacenter in the `query_options` it is possible to
|
||||||
|
retrieve a list of services from a different WAN-attached Consul datacenter.
|
||||||
|
|
||||||
|
This data source is different from the `consul_catalog_service` (singular) data
|
||||||
|
source, which provides a detailed response about a specific Consul service.
|
||||||
|
|
||||||
|
## Example Usage
|
||||||
|
|
||||||
|
```
|
||||||
|
data "consul_catalog_services" "read-dc1" {
|
||||||
|
query_options {
|
||||||
|
# Optional parameter
|
||||||
|
datacenter = "dc1"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
# Set the description to a whitespace delimited list of the services
|
||||||
|
resource "example_resource" "app" {
|
||||||
|
description = "${join(" ", data.consul_catalog_services.names)}"
|
||||||
|
...
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
## Argument Reference
|
||||||
|
|
||||||
|
The following arguments are supported:
|
||||||
|
|
||||||
|
* `datacenter` - (Optional) The Consul datacenter to query. Defaults to the
|
||||||
|
same value found in `query_options` parameter specified below, or if that is
|
||||||
|
empty, the `datacenter` value found in the Consul agent that this provider is
|
||||||
|
configured to talk to.
|
||||||
|
|
||||||
|
* `query_options` - (Optional) See below.
|
||||||
|
|
||||||
|
The `query_options` block supports the following:
|
||||||
|
|
||||||
|
* `allow_stale` - (Optional) When `true`, the default, allow responses from
|
||||||
|
Consul servers that are followers.
|
||||||
|
|
||||||
|
* `require_consistent` - (Optional) When `true` force the client to perform a
|
||||||
|
read on at least quorum servers and verify the result is the same. Defaults
|
||||||
|
to `false`.
|
||||||
|
|
||||||
|
* `token` - (Optional) Specify the Consul ACL token to use when performing the
|
||||||
|
request. This defaults to the same API token configured by the `consul`
|
||||||
|
provider but may be overriden if necessary.
|
||||||
|
|
||||||
|
* `wait_index` - (Optional) Index number used to enable blocking quereis.
|
||||||
|
|
||||||
|
* `wait_time` - (Optional) Max time the client should wait for a blocking query
|
||||||
|
to return.
|
||||||
|
|
||||||
|
## Attributes Reference
|
||||||
|
|
||||||
|
The following attributes are exported:
|
||||||
|
|
||||||
|
* `datacenter` - The datacenter the keys are being read from to.
|
||||||
|
* `names` - A list of the Consul services found. This will always contain the
|
||||||
|
list of services found.
|
||||||
|
* `services.<service>` - For each name given, the corresponding attribute is a
|
||||||
|
Terraform map of services and their tags. The value is an alphanumerically
|
||||||
|
sorted, whitespace delimited set of tags associated with the service. As
|
||||||
|
shown in the example above, to create a list of the available servies, wrap
|
||||||
|
the `names` attribute in a call to `keys()`.
|
||||||
|
* `tags` - A map of the tags found for each service. If more than one service
|
||||||
|
shares the same tag, unique service names will be joined by whitespace (this
|
||||||
|
is the inverse of `services` and can be used to lookup the services that match
|
||||||
|
a single tag).
|
|
@ -13,10 +13,13 @@
|
||||||
<li<%= sidebar_current(/^docs-consul-data-source/) %>>
|
<li<%= sidebar_current(/^docs-consul-data-source/) %>>
|
||||||
<a href="#">Data Sources</a>
|
<a href="#">Data Sources</a>
|
||||||
<ul class="nav nav-visible">
|
<ul class="nav nav-visible">
|
||||||
<li<%= sidebar_current("docs-consul-data-source-keys") %>>
|
<li<%= sidebar_current("docs-consul-data-source-catalog-services") %>>
|
||||||
<a href="/docs/providers/consul/d/keys.html">consul_keys</a>
|
<a href="/docs/providers/consul/d/services.html">consul_catalog_services</a>
|
||||||
</li>
|
</li>
|
||||||
</ul>
|
<li<%= sidebar_current("docs-consul-data-source-keys") %>>
|
||||||
|
<a href="/docs/providers/consul/d/keys.html">consul_keys</a>
|
||||||
|
</li>
|
||||||
|
</ul>
|
||||||
</li>
|
</li>
|
||||||
|
|
||||||
<li<%= sidebar_current(/^docs-consul-resource/) %>>
|
<li<%= sidebar_current(/^docs-consul-resource/) %>>
|
||||||
|
|
Loading…
Reference in New Issue