portforward

package
v0.31.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 12, 2024 License: Apache-2.0 Imports: 21 Imported by: 1,016

Documentation

Overview

Package portforward adds support for SSH-like port forwarding from the client's local host to remote containers.

Index

Constants

View Source
const PingPeriod = 10 * time.Second
View Source
const PortForwardProtocolV1Name = "portforward.k8s.io"

PortForwardProtocolV1Name is the subprotocol used for port forwarding. TODO move to API machinery and re-unify with kubelet/server/portfoward

Variables

View Source
var ErrLostConnectionToPod = errors.New("lost connection to pod")

Functions

func NewFallbackDialer added in v0.30.0

func NewFallbackDialer(primary, secondary httpstream.Dialer, shouldFallback func(error) bool) httpstream.Dialer

NewFallbackDialer creates the FallbackDialer with the primary and secondary dialers, as well as the boolean function to determine if the primary dialer failed.

func NewSPDYOverWebsocketDialer added in v0.30.0

func NewSPDYOverWebsocketDialer(url *url.URL, config *restclient.Config) (httpstream.Dialer, error)

NewTunnelingDialer creates and returns the tunnelingDialer structure which implemements the "httpstream.Dialer" interface. The dialer can upgrade a websocket request, creating a websocket connection. This function returns an error if one occurs.

Types

type FallbackDialer added in v0.31.0

type FallbackDialer struct {
	// contains filtered or unexported fields
}

FallbackDialer encapsulates a primary and secondary dialer, including the boolean function to determine if the primary dialer failed. Implements the httpstream.Dialer interface.

func (*FallbackDialer) Dial added in v0.31.0

func (f *FallbackDialer) Dial(protocols ...string) (httpstream.Connection, string, error)

Dial is the single function necessary to implement the "httpstream.Dialer" interface. It takes the protocol version strings to request, returning an the upgraded httstream.Connection and the negotiated protocol version accepted. If the initial primary dialer fails, this function attempts the secondary dialer. Returns an error if one occurs.

type ForwardedPort

type ForwardedPort struct {
	Local  uint16
	Remote uint16
}

ForwardedPort contains a Local:Remote port pairing.

type PortForwarder

type PortForwarder struct {
	Ready chan struct{}
	// contains filtered or unexported fields
}

PortForwarder knows how to listen for local connections and forward them to a remote pod via an upgraded HTTP request.

func New

func New(dialer httpstream.Dialer, ports []string, stopChan <-chan struct{}, readyChan chan struct{}, out, errOut io.Writer) (*PortForwarder, error)

New creates a new PortForwarder with localhost listen addresses.

func NewOnAddresses

func NewOnAddresses(dialer httpstream.Dialer, addresses []string, ports []string, stopChan <-chan struct{}, readyChan chan struct{}, out, errOut io.Writer) (*PortForwarder, error)

NewOnAddresses creates a new PortForwarder with custom listen addresses.

func (*PortForwarder) Close

func (pf *PortForwarder) Close()

Close stops all listeners of PortForwarder.

func (*PortForwarder) ForwardPorts

func (pf *PortForwarder) ForwardPorts() error

ForwardPorts formats and executes a port forwarding request. The connection will remain open until stopChan is closed.

func (*PortForwarder) GetPorts

func (pf *PortForwarder) GetPorts() ([]ForwardedPort, error)

GetPorts will return the ports that were forwarded; this can be used to retrieve the locally-bound port in cases where the input was port 0. This function will signal an error if the Ready channel is nil or if the listeners are not ready yet; this function will succeed after the Ready channel has been closed.

type TunnelingConnection added in v0.30.0

type TunnelingConnection struct {
	// contains filtered or unexported fields
}

TunnelingConnection implements the "httpstream.Connection" interface, wrapping a websocket connection that tunnels SPDY.

func NewTunnelingConnection added in v0.30.0

func NewTunnelingConnection(name string, conn *gwebsocket.Conn) *TunnelingConnection

NewTunnelingConnection wraps the passed gorilla/websockets connection with the TunnelingConnection struct (implementing net.Conn).

func (*TunnelingConnection) Close added in v0.30.0

func (c *TunnelingConnection) Close() error

Close implements "io.Closer" interface, signaling the other tunneled connection endpoint, and closing the tunneled connection only once.

func (*TunnelingConnection) LocalAddr added in v0.30.0

func (c *TunnelingConnection) LocalAddr() net.Addr

LocalAddr implements part of the "net.Conn" interface, returning the local endpoint network address of the tunneled connection.

func (*TunnelingConnection) Read added in v0.30.0

func (c *TunnelingConnection) Read(p []byte) (int, error)

Read implements "io.Reader" interface, reading from the stored connection into the passed buffer "p". Returns the number of bytes read and an error. Can keep track of the "inProgress" messsage from the tunneled connection.

func (*TunnelingConnection) RemoteAddr added in v0.30.0

func (c *TunnelingConnection) RemoteAddr() net.Addr

LocalAddr implements part of the "net.Conn" interface, returning the remote endpoint network address of the tunneled connection.

func (*TunnelingConnection) SetDeadline added in v0.30.0

func (c *TunnelingConnection) SetDeadline(t time.Time) error

SetDeadline sets the *absolute* time in the future for both read and write deadlines. Returns an error if one occurs.

func (*TunnelingConnection) SetReadDeadline added in v0.30.0

func (c *TunnelingConnection) SetReadDeadline(t time.Time) error

SetDeadline sets the *absolute* time in the future for the read deadlines. Returns an error if one occurs.

func (*TunnelingConnection) SetWriteDeadline added in v0.30.0

func (c *TunnelingConnection) SetWriteDeadline(t time.Time) error

SetDeadline sets the *absolute* time in the future for the write deadlines. Returns an error if one occurs.

func (*TunnelingConnection) Write added in v0.30.0

func (c *TunnelingConnection) Write(p []byte) (n int, err error)

Write implements "io.Writer" interface, copying the data in the passed byte array "p" into the stored tunneled connection. Returns the number of bytes written and an error.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL