Function NewClient

api/logcache/log_cache_client.go:109–155

NewClient returns back a configured Log Cache Client.

(logCacheEndpoint string, config command.Config, ui command.UI, k8sConfigGetter v7action.KubernetesConfigGetter)

// NewClient returns back a configured Log Cache Client.
func NewClient(logCacheEndpoint string, config command.Config, ui command.UI, k8sConfigGetter v7action.KubernetesConfigGetter) (*logcache.Client, error) {
	var tr http.RoundTripper = &http.Transport{
		Proxy:           http.ProxyFromEnvironment,
		TLSClientConfig: util.NewTLSConfig(nil, config.SkipSSLValidation()),
		DialContext: (&net.Dialer{
			KeepAlive: 30 * time.Second,
			Timeout:   config.DialTimeout(),
		}).DialContext,
	}

	if config.IsCFOnK8s() {
		var err error
		tr, err = shared.WrapForCFOnK8sAuth(config, k8sConfigGetter, tr)
		if err != nil {
			return nil, err
		}
	}

	var client logcache.HTTPClient // nolint
	client = &userAgentHTTPClient{
		c:         &http.Client{Transport: tr},
		userAgent: fmt.Sprintf("%s/%s (%s; %s %s)", config.BinaryName(), config.BinaryVersion(), runtime.Version(), runtime.GOARCH, runtime.GOOS),
	}

	verbose, location := config.Verbose()
	if verbose && ui != nil {
		printer := DebugPrinter{}
		printer.addOutput(ui.RequestLoggerTerminalDisplay())
		if location != nil {
			printer.addOutput(ui.RequestLoggerFileWriter(location))
		}

		client = &httpDebugClient{printer: printer, c: client}
	}

	if !config.IsCFOnK8s() {
		client = &tokenHTTPClient{
			c:           client,
			accessToken: config.AccessToken,
		}
	}

	return logcache.NewClient(
		logCacheEndpoint,
		logcache.WithHTTPClient(client),
	), nil
}

func headersString(header http.Header) string {
	var result string