Include service.Attrs as Consul Meta for the service

consul/consul.go

@@ -4,9 +4,10 @@ import (
  "fmt"
  "log"
  "net/url"
- "strings"
- "strconv"
  "os"
+ "strconv"
+ "strings"
+
  "github.com/gliderlabs/registrator/bridge"
  consulapi "github.com/hashicorp/consul/api"
  "github.com/hashicorp/go-cleanhttp"
@@ -34,16 +35,16 @@ func (f *Factory) New(uri *url.URL) bridge.RegistryAdapter {
  if uri.Scheme == "consul-unix" {
  config.Address = strings.TrimPrefix(uri.String(), "consul-")
  } else if uri.Scheme == "consul-tls" {
-  tlsConfigDesc := &consulapi.TLSConfig {
-  Address: uri.Host,
-  CAFile: os.Getenv("CONSUL_CACERT"),
-   CertFile: os.Getenv("CONSUL_TLSCERT"),
-   KeyFile: os.Getenv("CONSUL_TLSKEY"),
-  InsecureSkipVerify: false,
+  tlsConfigDesc := &consulapi.TLSConfig{
+ Address:  uri.Host,
+ CAFile:  os.Getenv("CONSUL_CACERT"),
+ CertFile:  os.Getenv("CONSUL_TLSCERT"),
+ KeyFile:  os.Getenv("CONSUL_TLSKEY"),
+ InsecureSkipVerify: false,
  }
  tlsConfig, err := consulapi.SetupTLSConfig(tlsConfigDesc)
  if err != nil {
-  log.Fatal("Cannot set up Consul TLSConfig", err)
+  log.Fatal("Cannot set up Consul TLSConfig", err)
  }
  config.Scheme = "https"
  transport := cleanhttp.DefaultPooledTransport()
@@ -84,6 +85,7 @@ func (r *ConsulAdapter) Register(service *bridge.Service) error {
  registration.Tags = service.Tags
  registration.Address = service.IP
  registration.Check = r.buildCheck(service)
+ registration.Meta = service.Attrs
  return r.client.Agent().ServiceRegister(registration)
 }