Function NewClient

kv/consul/client.go:86–110

NewClient returns a new Client.

(cfg Config, codec codec.Codec, logger log.Logger, registerer prometheus.Registerer)

// NewClient returns a new Client.
func NewClient(cfg Config, codec codec.Codec, logger log.Logger, registerer prometheus.Registerer) (*Client, error) {
	client, err := consul.NewClient(&consul.Config{
		Address: cfg.Host,
		Token:   cfg.ACLToken.String(),
		Scheme:  "http",
		HttpClient: &http.Client{
			Transport: cleanhttp.DefaultPooledTransport(),
			// See https://blog.cloudflare.com/the-complete-guide-to-golang-net-http-timeouts/
			Timeout: cfg.HTTPClientTimeout,
		},
	})
	if err != nil {
		return nil, err
	}
	consulMetrics := newConsulMetrics(registerer)

	c := &Client{
		kv:            consulInstrumentation{client.KV(), consulMetrics},
		codec:         codec,
		cfg:           cfg,
		logger:        logger,
		consulMetrics: consulMetrics,
	}
	return c, nil
}

// Put is mostly here for testing.
func (c *Client) Put(ctx context.Context, key string, value interface{}) error {