util

Documentation

Index

• Constants
• func GenerateServiceURL(cluster, namespace, service string) string
• func GetKonnectivityTLSConfig(restConfig *rest.Config, proxyConfig *proxyv1alpha1.ManagedProxyConfiguration) (*tls.Config, error)
• func IsServiceResolverLegal(mpsr *proxyv1alpha1.ManagedProxyServiceResolver) bool
• type LocalProxyServer
  • func NewRoundRobinLocalProxy(restConfig *rest.Config, readiness *atomic.Value, ...) LocalProxyServer
  • func NewRoundRobinLocalProxyWithReqId(restConfig *rest.Config, readiness *atomic.Value, ...) LocalProxyServer

Constants

const PortForwardProtocolV1Name = "portforward.k8s.io"

PortForwardProtocolV1Name is the subprotocol used for port forwarding.

Functions

func GenerateServiceURL

func GenerateServiceURL(cluster, namespace, service string) string

func GetKonnectivityTLSConfig

func GetKonnectivityTLSConfig(restConfig *rest.Config, proxyConfig *proxyv1alpha1.ManagedProxyConfiguration) (*tls.Config, error)

func IsServiceResolverLegal

func IsServiceResolverLegal(mpsr *proxyv1alpha1.ManagedProxyServiceResolver) bool

Types

type LocalProxyServer

type LocalProxyServer interface {
	Listen(ctx context.Context) (func(), error)
}

func NewRoundRobinLocalProxy

func NewRoundRobinLocalProxy(
	restConfig *rest.Config,
	readiness *atomic.Value,
	podNamespace,
	podSelector string,
	targetPort int32) LocalProxyServer

func NewRoundRobinLocalProxyWithReqId

func NewRoundRobinLocalProxyWithReqId(
	restConfig *rest.Config,
	readiness *atomic.Value,
	podNamespace,
	podSelector string,
	targetPort int32,
	reqId int) LocalProxyServer