proxy

Documentation

Index

• func ConnectCluster(ctx context.Context, cluster *clusterapis.Cluster, proxyPath string, ...) (http.Handler, error)
• func Location(cluster *clusterapis.Cluster) (*url.URL, http.RoundTripper, error)
• func NewThrottledUpgradeAwareProxyHandler(location *url.URL, transport http.RoundTripper, ...) *proxy.UpgradeAwareHandler

Functions

func ConnectCluster

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

ConnectCluster returns a handler for proxy cluster.

func Location

func Location(cluster *clusterapis.Cluster) (*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 rest.Responder) *proxy.UpgradeAwareHandler

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