Function newHTTPWrapperServiceClient

cluster/util/service_client.go:26–57

(isHTTPS, secure bool, baseURL string)

}

func newHTTPWrapperServiceClient(isHTTPS, secure bool, baseURL string) *httpWrapperServiceClient {
	netDialer := &net.Dialer{}

	// By default, block both things
	netDial := func(_ context.Context, network, addr string) (net.Conn, error) {
		return nil, fmt.Errorf("%w: cannot connect to %v:%v TLS must be used", errServiceClient, network, addr)
	}
	dialTLS := func(_ context.Context, network string, addr string) (net.Conn, error) {
		return nil, fmt.Errorf("%w: cannot connect to %v:%v TLS is not supported", errServiceClient, network, addr)
	}

	// Unblock one of the dial methods
	if isHTTPS {
		tlsDialer := tls.Dialer{
			NetDialer: netDialer,
			Config: &tls.Config{
				InsecureSkipVerify: !secure, // nolint:gosec
			},
		}
		dialTLS = tlsDialer.DialContext
	} else {
		netDial = netDialer.DialContext
	}

	transport := &http.Transport{
		DialContext:     netDial,
		DialTLSContext:  dialTLS,
		MaxIdleConns:    2,
		MaxConnsPerHost: 2,
	}
	return newHTTPWrapperServiceClientWithTransport(transport, baseURL)
}

func newHTTPWrapperServiceClientWithTransport(transport http.RoundTripper, baseURL string) *httpWrapperServiceClient {
	return &httpWrapperServiceClient{