portforward

package
v0.6.279 Latest Latest
Warning

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

Go to latest
Published: Mar 29, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DefaultPortForwarder

type DefaultPortForwarder struct {
	genericclioptions.IOStreams
}

func NewDefaultPortForwarder added in v0.2.0

func NewDefaultPortForwarder() *DefaultPortForwarder

func (*DefaultPortForwarder) ForwardPorts

func (f *DefaultPortForwarder) ForwardPorts(method string, url *url.URL, opts PortForwardOptions) error

type PortForwardOptions

type PortForwardOptions struct {
	PortForwarder              PortForwarder
	WorkspaceGroupClientMapper k8s.WorkspaceGroupClientMapper

	K8sClient k8s.K8sClient
	K8sAPIURL string

	Namespace string
	PodName   string

	Address      []string
	Ports        []string
	StopChannel  chan struct{}
	ReadyChannel chan struct{}
}

func NewPortForwardOptions

func NewPortForwardOptions(workspaceGroupClientMapper k8s.WorkspaceGroupClientMapper, portforwarder PortForwarder) *PortForwardOptions

func (PortForwardOptions) RunPortforward

func (o PortForwardOptions) RunPortforward() error

func (*PortForwardOptions) WithPort added in v0.2.0

func (o *PortForwardOptions) WithPort(port string) *PortForwardOptions

TODO with stopchannel

func (*PortForwardOptions) WithWorkspace added in v0.2.0

func (o *PortForwardOptions) WithWorkspace(workspace entity.WorkspaceWithMeta) (*PortForwardOptions, error)

type PortForwarder

type PortForwarder interface {
	ForwardPorts(method string, url *url.URL, opts PortForwardOptions) error
}

Jump to

Keyboard shortcuts

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