Method HTTPClient

pkg/httpclient/http.go:83–125

HTTPClient returns a new *http.Client with a default timeout and a configured transport.

(ctx context.Context, opts ...Option)

// HTTPClient returns a new *http.Client with a default timeout and a configured transport.
func (p *provider) HTTPClient(ctx context.Context, opts ...Option) (*http.Client, error) {
	options := &httpClientOptions{}
	for _, opt := range opts {
		opt(options)
	}

	if options.tlsConfig == nil {
		tlsConfig, err := p.tlsConfigProvider.GetTLSClientConfig(ctx, options.tlsConfigOptions...)
		if err != nil {
			return nil, err
		}
		options.tlsConfig = tlsConfig
	}

	transport := http.DefaultTransport.(*http.Transport).Clone()
	transport.TLSClientConfig = options.tlsConfig

	var rt http.RoundTripper = transport
	rt = gzhttp.Transport(rt)
	rt = otelhttp.NewTransport(
		rt,
		otelhttp.WithTracerProvider(tracing.FromContext(ctx)),
		// As pkg/metrics is currently Prometheus based, the OpenTelemetry metrics are unused.
		// TODO: https://github.com/TheThingsNetwork/lorawan-stack/issues/5692.
		otelhttp.WithMeterProvider(noop.MeterProvider{}),
	)
	if options.cache {
		rt = &httpcache.Transport{
			Transport:           rt,
			Cache:               httpcache.NewMemoryCache(),
			MarkCachedResponses: true,
		}
	}
	rt = &roundTripperWithUserAgent{
		RoundTripper: rt,
		UserAgent:    fmt.Sprintf("TheThingsStack/%s (%s/%s)", version.TTN, runtime.GOOS, runtime.GOARCH),
	}

	return &http.Client{
		Timeout:   defaultHTTPClientTimeout,
		Transport: rt,
	}, nil
}

// NewProvider constructs a Provider on top of the provided TLS configuration provider.
func NewProvider(tlsConfigProvider TLSClientConfigurationProvider) Provider {