concurrentportforwards

package
v0.0.0-...-afd1ef1 Latest Latest
Warning

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

Go to latest
Published: Dec 7, 2021 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Name = "concurrent-portforwards"
)

Variables

This section is empty.

Functions

func PortForwardAPod

func PortForwardAPod(req PortForwardAPodRequest) error

Types

type ConcurrentPortForwards

type ConcurrentPortForwards struct {
	NumberOfConcurrentPortForwards int `yaml:"number_of_concurrent_portforwards"`
	KeepConnectedForSeconds        int `yaml:"keep_connected_for_seconds"`
	StartPort                      int `yaml:"start_port"`
}

func NewConcurrentPortForwards

func NewConcurrentPortForwards() *ConcurrentPortForwards

func (*ConcurrentPortForwards) Cleanup

func (c *ConcurrentPortForwards) Cleanup() error

func (*ConcurrentPortForwards) Run

func (c *ConcurrentPortForwards) Run() error

type PortForwardAPodRequest

type PortForwardAPodRequest struct {
	// RestConfig is the kubernetes config
	RestConfig *rest.Config
	// Pod is the selected pod for this port forwarding
	Pod corev1.Pod
	// LocalPort is the local port that will be selected to expose the PodPort
	LocalPort int
	// PodPort is the target port for the pod
	PodPort int
	// Steams configures where to write or read input from
	Streams genericclioptions.IOStreams
	// StopCh is the channel used to manage the port forward lifecycle
	StopCh <-chan struct{}
	// ReadyCh communicates when the tunnel is ready to receive traffic
	ReadyCh chan struct{}
}

Jump to

Keyboard shortcuts

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