fwdport

Documentation

Index

• type HostFileWithLock
• type HostsParams
• type OperatorInterface
• type PortForwardOpts
  • func (pfo *PortForwardOpts) AddHosts()
  • func (pfo *PortForwardOpts) BuildTheHostsParams()
  • func (pfo *PortForwardOpts) ListenUntilPodDeleted(signalsChan chan struct{}, pod *v1.Pod)
  • func (pfo *PortForwardOpts) PortForward() error
  • func (pfo *PortForwardOpts) Stop()
  • func (pfo *PortForwardOpts) WaitForPodRunning(signalsChan chan struct{}) (*v1.Pod, error)

Types

type HostFileWithLock

type HostFileWithLock struct {
	Hosts *txeh.Hosts
	sync.Mutex
}

type HostsParams

type HostsParams struct {
	// contains filtered or unexported fields
}

type OperatorInterface

type OperatorInterface interface {
	ForwardService(svcName string, svcNamespace string)
	UnForwardService(svcName string, svcNamespace string)
}

type PortForwardOpts

type PortForwardOpts struct {
	Out               *fwdpub.Publisher
	Config            *restclient.Config
	ClientSet         *kubernetes.Clientset
	RESTClient        *restclient.RESTClient
	ServiceOperator   OperatorInterface
	Context           string
	Namespace         string
	Service           string
	NativeServiceName string
	PodName           string
	PodPort           string
	LocalIp           net.IP
	LocalPort         string
	Hostfile          *HostFileWithLock
	ExitOnFail        bool
	ShortName         bool
	Remote            bool
	Domain            string
	HostsParams       *HostsParams
	ManualStopChan    chan struct{}
}

func (*PortForwardOpts) AddHosts

func (pfo *PortForwardOpts) AddHosts()

this method to add hosts obj in /etc/hosts

func (*PortForwardOpts) BuildTheHostsParams

func (pfo *PortForwardOpts) BuildTheHostsParams()

this method to build the HostsParams

func (*PortForwardOpts) ListenUntilPodDeleted

func (pfo *PortForwardOpts) ListenUntilPodDeleted(signalsChan chan struct{}, pod *v1.Pod)

listen for pod is deleted

func (*PortForwardOpts) PortForward

func (pfo *PortForwardOpts) PortForward() error

func (*PortForwardOpts) Stop

func (pfo *PortForwardOpts) Stop()

this method to stop PortForward for the pfo

func (*PortForwardOpts) WaitForPodRunning

func (pfo *PortForwardOpts) WaitForPodRunning(signalsChan chan struct{}) (*v1.Pod, error)

Waiting for the pod running