portforward

Documentation

Index

• type DefaultPortForwarder
  • func NewDefaultPortForwarder() *DefaultPortForwarder
  • func (f *DefaultPortForwarder) ForwardPorts(method string, url *url.URL, opts PortForwardOptions) error
• type PortForwardOptions
  • func NewPortForwardOptions(workspaceGroupClientMapper k8s.WorkspaceGroupClientMapper, ...) *PortForwardOptions
  • func (o PortForwardOptions) RunPortforward() error
  • func (o *PortForwardOptions) WithPort(port string) *PortForwardOptions
  • func (o *PortForwardOptions) WithWorkspace(workspace entity.WorkspaceWithMeta) (*PortForwardOptions, error)
• type PortForwarder

Types

type DefaultPortForwarder

type DefaultPortForwarder struct {
	genericclioptions.IOStreams
}

func NewDefaultPortForwarder

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

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

TODO with stopchannel

func (*PortForwardOptions) WithWorkspace

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

type PortForwarder

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