Versions in this module Expand all Collapse all v1 v1.0.1 Nov 9, 2023 v1.0.0 Nov 9, 2023 Changes in this version + func GetTopController(refs []v1.OwnerReference, client *clientgoutils.ClientGoUtils) *v1.OwnerReference + func HandleCheckClusterStatus(cmd *command.CheckClusterStatusCommand) (*daemon_common.CheckClusterStatus, error) + func ParseErrToForwardPort(errStr string) (*clientgoutils.ForwardPort, error) + func Process(conn net.Conn, fun func(conn net.Conn) (interface{}, error)) error + func ProcessStream(conn net.Conn, fun func(conn net.Conn) (io.ReadCloser, error)) error + func StartDaemon(isSudoUser bool, v string, c string) error + type ConfigSaveParams struct + Application string + Config string + Kubeconfig string + Name string + Namespace string + Type string + type ConfigSaveResp struct + Message string + Success bool + type PortForwardManager struct + func NewPortForwardManager() *PortForwardManager + func (p *PortForwardManager) ListAllRunningPFGoRoutineProfile() []*daemon_common.PortForwardProfile + func (p *PortForwardManager) RecoverAllPortForward() + func (p *PortForwardManager) RecoverPortForwardForApplication(ns, appName, nid string) error + func (p *PortForwardManager) StartPortForwardGoRoutine(startCmd *command.PortForwardCommand, saveToDB bool) error + func (p *PortForwardManager) StopPortForwardGoRoutine(cmd *command.PortForwardCommand) error