package consul import ( "context" "time" consul "github.com/hashicorp/consul/api" "github.com/micro/go-micro/registry" ) // Connect specifies services should be registered as Consul Connect services func Connect() registry.Option { return func(o *registry.Options) { if o.Context == nil { o.Context = context.Background() } o.Context = context.WithValue(o.Context, "consul_connect", true) } } func Config(c *consul.Config) registry.Option { return func(o *registry.Options) { if o.Context == nil { o.Context = context.Background() } o.Context = context.WithValue(o.Context, "consul_config", c) } } // // TCPCheck will tell the service provider to check the service address // and port every `t` interval. It will enabled only if `t` is greater than 0. // See `TCP + Interval` for more information [1]. // // [1] https://www.consul.io/docs/agent/checks.html // func TCPCheck(t time.Duration) registry.Option { return func(o *registry.Options) { if t <= time.Duration(0) { return } if o.Context == nil { o.Context = context.Background() } o.Context = context.WithValue(o.Context, "consul_tcp_check", t) } }