frpc

Documentation

Index

• func ChangeHostToKubeTunnel(hostFile *fwdport.HostFileWithLock, kubeTunnelServerDns string)
• func Execute(common models.Common, servicePair []ServicePair) (cancelChan *notify.CancellationChannel, err error)
• type Manager
  • func NewManager(common models.Common, servicePair []ServicePair, ...) *Manager
  • func (m *Manager) RunFRPc()
  • func (m *Manager) WaitForLocalPortToBecomeAvailable()
  • func (m *Manager) WaitForLocalPortToBecomeUnavailableAndCancel(channel *notify.CancellationChannel)
• type ServicePair

Functions

func ChangeHostToKubeTunnel

func ChangeHostToKubeTunnel(hostFile *fwdport.HostFileWithLock, kubeTunnelServerDns string)

func Execute

func Execute(common models.Common, servicePair []ServicePair) (cancelChan *notify.CancellationChannel, err error)

Execute - This code was copied from frpc and modified a bit to support kubetunnel requirements

Types

type Manager

type Manager struct {
	Common      models.Common
	ServicePair []ServicePair
}

func NewManager

func NewManager(common models.Common, servicePair []ServicePair, hostFile *fwdport.HostFileWithLock) *Manager

func (*Manager) RunFRPc

func (m *Manager) RunFRPc()

func (*Manager) WaitForLocalPortToBecomeAvailable

func (m *Manager) WaitForLocalPortToBecomeAvailable()

func (*Manager) WaitForLocalPortToBecomeUnavailableAndCancel

func (m *Manager) WaitForLocalPortToBecomeUnavailableAndCancel(channel *notify.CancellationChannel)

type ServicePair

type ServicePair struct {
	Name    string
	Service models.Service
}