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
}
Click to show internal directories.
Click to hide internal directories.