portforward

Documentation

Index

• type DefaultPortForwarder
  • func (f *DefaultPortForwarder) ForwardPorts(method string, url *url.URL, opts PortForwardOptions) error
• type PortForwardOptions
  • func NewPortForwardOptions(portForwardHelpers k8s.K8sClient, workspaceResolver ResourceResolver, ...) *PortForwardOptions
  • func (o *PortForwardOptions) Complete(cmd *cobra.Command, t *terminal.Terminal, args []string) error
  • func (o PortForwardOptions) RunPortforward() error
• type PortForwarder
• type ResourceResolver

Types

type DefaultPortForwarder

type DefaultPortForwarder struct {
	genericclioptions.IOStreams
}

func (*DefaultPortForwarder) ForwardPorts

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

type PortForwardOptions

type PortForwardOptions struct {
	PortForwarder    PortForwarder
	K8sClient        k8s.K8sClient
	ResourceResolver ResourceResolver

	Namespace string
	PodName   string

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

func NewPortForwardOptions

func NewPortForwardOptions(portForwardHelpers k8s.K8sClient, workspaceResolver ResourceResolver, portforwarder PortForwarder) *PortForwardOptions

func (*PortForwardOptions) Complete

func (o *PortForwardOptions) Complete(cmd *cobra.Command, t *terminal.Terminal, args []string) error

func (PortForwardOptions) RunPortforward

func (o PortForwardOptions) RunPortforward() error

type PortForwarder

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

type ResourceResolver

type ResourceResolver interface {
	GetWorkspaceByID(id string) (*brev_api.WorkspaceMetaData, error)
}