forwarder

Documentation

Index

• type Forwarder
  • func New(name string, spec config.Forward, stdout io.Writer) (*Forwarder, error)
  • func (fwd *Forwarder) Run(kc *kubeclient.Kubeclient, stop chan struct{}) error
  • func (fwd *Forwarder) String() string

Types

type Forwarder

type Forwarder struct {
	Name string
	config.Forward
	Clients *kubernetes.Clientset
	Io      genericiooptions.IOStreams
	Ready   chan struct{}

	Namespace  string
	BindAddr   string
	BindPort   int32
	RandPort   bool
	TargetPod  string
	TargetPort int32
}

func New

func New(name string, spec config.Forward, stdout io.Writer) (*Forwarder, error)

func (*Forwarder) Run

func (fwd *Forwarder) Run(kc *kubeclient.Kubeclient, stop chan struct{}) error

Run starts the port forwarding and blocks until it is stopped.

func (*Forwarder) String

func (fwd *Forwarder) String() string