Documentation
¶
Index ¶
- Variables
- func AddServiceHandler(opts *services.NamespaceOpts, obj interface{})
- func Execute(kubeClient *kube.Kube, frpsValues *models.KubeTunnelResourceSpec, ...) *fwdport.HostFileWithLock
- func IsChannelClosed(ch <-chan struct{}) bool
- func UpdateServiceHandler(opts *services.NamespaceOpts, oldObj interface{}, newObj interface{})
- func WaitUntilKubeTunnelIsUp(frpsValues *models.KubeTunnelResourceSpec, done <-chan struct{})
- type LogOutputSplitter
Constants ¶
This section is empty.
Variables ¶
View Source
var Version = "0.0.0"
Functions ¶
func AddServiceHandler ¶
func AddServiceHandler(opts *services.NamespaceOpts, obj interface{})
func Execute ¶
func Execute(kubeClient *kube.Kube, frpsValues *models.KubeTunnelResourceSpec, channel chan error) *fwdport.HostFileWithLock
Execute - This code was copied from kubefwd and modified a bit to support kubetunnel requirements
func IsChannelClosed ¶
func IsChannelClosed(ch <-chan struct{}) bool
func UpdateServiceHandler ¶
func UpdateServiceHandler(opts *services.NamespaceOpts, oldObj interface{}, newObj interface{})
func WaitUntilKubeTunnelIsUp ¶
func WaitUntilKubeTunnelIsUp(frpsValues *models.KubeTunnelResourceSpec, done <-chan struct{})
Types ¶
type LogOutputSplitter ¶
type LogOutputSplitter struct{}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.