proxy

Documentation

Index

• func ConnectCluster(ctx context.Context, cluster *clusterapis.Cluster, proxyPath string, ...) (http.Handler, error)
• func GetTLSConfigForCluster(ctx context.Context, cluster *clusterapis.Cluster, ...) (*tls.Config, error)
• func ImpersonateToken(clusterName string, secret *corev1.Secret) (string, error)
• func Location(cluster *clusterapis.Cluster, tlsConfig *tls.Config) (*url.URL, http.RoundTripper, error)
• func NewThrottledUpgradeAwareProxyHandler(location *url.URL, transport http.RoundTripper, ...) *proxy.UpgradeAwareHandler
• func ParseProxyHeaders(proxyHeaders map[string]string) http.Header
• func SkipGroup(group string) bool
• type SecretGetterFunc
• type UpgradeAwareHandler
  • func NewUpgradeAwareHandler(location *url.URL, transport http.RoundTripper, ...) *UpgradeAwareHandler
  • func (h *UpgradeAwareHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type UpgradeDialer
  • func NewUpgradeDialerWithConfig(cfg UpgradeDialerWithConfig) *UpgradeDialer
  • func (u *UpgradeDialer) Dial(req *http.Request) (net.Conn, error)
  • func (u *UpgradeDialer) TLSClientConfig() *tls.Config
• type UpgradeDialerWithConfig

Functions

func ConnectCluster

func ConnectCluster(ctx context.Context, cluster *clusterapis.Cluster, proxyPath string, secretGetter SecretGetterFunc, responder registryrest.Responder) (http.Handler, error)

ConnectCluster returns a handler for proxy cluster.

func GetTLSConfigForCluster

func GetTLSConfigForCluster(ctx context.Context, cluster *clusterapis.Cluster, secretGetter SecretGetterFunc) (*tls.Config, error)

GetTLSConfigForCluster returns a tls config for the cluster.

func ImpersonateToken

func ImpersonateToken(clusterName string, secret *corev1.Secret) (string, error)

ImpersonateToken returns the impersonate token of the cluster.

func Location

func Location(cluster *clusterapis.Cluster, tlsConfig *tls.Config) (*url.URL, http.RoundTripper, error)

Location returns a URL to which one can send traffic for the specified cluster.

func NewThrottledUpgradeAwareProxyHandler

func NewThrottledUpgradeAwareProxyHandler(location *url.URL, transport http.RoundTripper, wrapTransport, upgradeRequired bool, responder registryrest.Responder) *proxy.UpgradeAwareHandler

NewThrottledUpgradeAwareProxyHandler creates a new proxy handler with a default flush interval. Responder is required for returning errors to the caller.

func ParseProxyHeaders

func ParseProxyHeaders(proxyHeaders map[string]string) http.Header

ParseProxyHeaders parses the proxy headers.

func SkipGroup

func SkipGroup(group string) bool

SkipGroup tells whether the input group can be skipped during impersonate.

Types

type SecretGetterFunc

type SecretGetterFunc func(context.Context, string, string) (*corev1.Secret, error)

SecretGetterFunc is a function to get secret.

type UpgradeAwareHandler

type UpgradeAwareHandler struct {
	proxyutil.UpgradeAwareHandler

	UpgradeDialer *UpgradeDialer
}

UpgradeAwareHandler is an interface for dialing a backend for an upgrade request

func NewUpgradeAwareHandler

func NewUpgradeAwareHandler(location *url.URL, transport http.RoundTripper, wrapTransport, upgradeRequired bool, responder proxyutil.ErrorResponder) *UpgradeAwareHandler

NewUpgradeAwareHandler creates a new proxy handler with a default flush interval. Responder is required for returning errors to the caller.

func (*UpgradeAwareHandler) ServeHTTP

func (h *UpgradeAwareHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

ServeHTTP handles the proxy request

type UpgradeDialer

type UpgradeDialer struct {

	// Dialer is the dialer used to connect.  Used if non-nil.
	Dialer *net.Dialer
	// contains filtered or unexported fields
}

UpgradeDialer knows how to upgrade an HTTP request to one that supports multiplexed streams. After Dial() is invoked, Conn will be usable.

func NewUpgradeDialerWithConfig

func NewUpgradeDialerWithConfig(cfg UpgradeDialerWithConfig) *UpgradeDialer

NewUpgradeDialerWithConfig creates a new UpgradeRoundTripper with the specified configuration.

func (*UpgradeDialer) Dial

func (u *UpgradeDialer) Dial(req *http.Request) (net.Conn, error)

Dial implements k8s.io/apimachinery/pkg/util/net.Dialer.

func (*UpgradeDialer) TLSClientConfig

func (u *UpgradeDialer) TLSClientConfig() *tls.Config

TLSClientConfig implements pkg/util/net.TLSClientConfigHolder for proper TLS checking during proxying with a roundtripper.

type UpgradeDialerWithConfig

type UpgradeDialerWithConfig struct {
	// TLS configuration used by the round tripper.
	TLS *tls.Config
	// Header holds the HTTP request headers for dialing. Optional.
	Header http.Header
	// Proxier is a proxy function invoked on each request. Optional.
	Proxier func(*http.Request) (*url.URL, error)
	// PingPeriod is a period for sending Pings on the connection.
	// Optional.
	PingPeriod time.Duration
}

UpgradeDialerWithConfig is a set of options for an UpgradeDialer.