kubernetes/test/e2e/framework/pod/dial.go

// NewTransport creates a transport which uses the port forward dialer.
// URLs must use <namespace>.<pod>:<port> as host.
func NewTransport(client kubernetes.Interface, restConfig *rest.Config) *http.Transport { … }

// NewDialer creates a dialer that supports connecting to container ports.
func NewDialer(client kubernetes.Interface, restConfig *rest.Config) *Dialer { … }

type Dialer …

// DialContainerPort connects to a certain container port in a pod.
func (d *Dialer) DialContainerPort(ctx context.Context, addr Addr) (conn net.Conn, finalErr error) { … }

type Addr …

var _ …

func (a Addr) Network() string { … }

func (a Addr) String() string { … }

// ParseAddr expects a <namespace>.<pod>:<port number> as produced
// by Addr.String.
func ParseAddr(addr string) (*Addr, error) { … }

var addrRegex …

type stream …

var _ …

func (s *stream) Close() error { … }

func (s *stream) LocalAddr() net.Addr { … }

func (s *stream) RemoteAddr() net.Addr { … }

func (s *stream) SetDeadline(t time.Time) error { … }

func (s *stream) SetReadDeadline(t time.Time) error { … }

func (s *stream) SetWriteDeadline(t time.Time) error { … }

type LocalAddr …

var _ …

func (l LocalAddr) Network() string { … }

func (l LocalAddr) String() string  { … }