concurrentportforwards

Documentation

Index

• Constants
• func PortForwardAPod(req PortForwardAPodRequest) error
• type ConcurrentPortForwards
  • func NewConcurrentPortForwards() *ConcurrentPortForwards
  • func (c *ConcurrentPortForwards) Cleanup() error
  • func (c *ConcurrentPortForwards) Run() error
• type PortForwardAPodRequest

Constants

const (
	Name = "concurrent-portforwards"
)

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{}
}