portforward

Documentation

Index

• Constants
• func Dialer(ctx context.Context) func(ctx context.Context, address string) (net.Conn, error)
• func NewResolver(ctx context.Context) resolver.Builder
• func WithRestConfig(ctx context.Context, restConfig *rest.Config) context.Context
• type PodConnection
• type PodDialer
  • func NewPodDialer(ctx context.Context, config *rest.Config, podName, namespace string, ...) (PodDialer, error)

Constants

const (
	K8sPFScheme = "k8spf"
)

const ProtocolV1Name = "portforward.k8s.io"

Functions

func Dialer

func Dialer(ctx context.Context) func(ctx context.Context, address string) (net.Conn, error)

func NewResolver

func NewResolver(ctx context.Context) resolver.Builder

func WithRestConfig

func WithRestConfig(ctx context.Context, restConfig *rest.Config) context.Context

Types

type PodConnection

type PodConnection interface {
	httpstream.Connection
	Dial(ctx context.Context, remotePort uint16) (net.Conn, error)
}

PodConnection represents a port agnostic stream connection to a pod. This connection can then be used when creating a port-specific connection to the connected pod.

type PodDialer

type PodDialer interface {
	Connect(cacheDelete func()) (PodConnection, error)
}

PodDialer can dial a pod to establish a PodConnection.

func NewPodDialer

func NewPodDialer(ctx context.Context, config *rest.Config, podName, namespace string, forceSPDY bool) (PodDialer, error)