daemon_server

Documentation

Index

• 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
• type ConfigSaveResp
• type PortForwardManager
  • 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

Functions

func GetTopController

func GetTopController(refs []v1.OwnerReference, client *clientgoutils.ClientGoUtils) *v1.OwnerReference

func HandleCheckClusterStatus

func HandleCheckClusterStatus(cmd *command.CheckClusterStatusCommand) (*daemon_common.CheckClusterStatus, error)

func ParseErrToForwardPort

func ParseErrToForwardPort(errStr string) (*clientgoutils.ForwardPort, error)

func Process

func Process(conn net.Conn, fun func(conn net.Conn) (interface{}, error)) error

func ProcessStream

func ProcessStream(conn net.Conn, fun func(conn net.Conn) (io.ReadCloser, error)) error

func StartDaemon

func StartDaemon(isSudoUser bool, v string, c string) error

Types

type ConfigSaveParams

type ConfigSaveParams struct {
	Application string
	Kubeconfig  string
	Name        string // svcName
	Namespace   string
	Type        string // svcType
	Config      string // config content
}

type ConfigSaveResp

type ConfigSaveResp struct {
	Success bool
	Message string
}

type PortForwardManager

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

func NewPortForwardManager

func NewPortForwardManager() *PortForwardManager

func (*PortForwardManager) ListAllRunningPFGoRoutineProfile

func (p *PortForwardManager) ListAllRunningPFGoRoutineProfile() []*daemon_common.PortForwardProfile

ListAllRunningPortForwardGoRoutineProfile

func (*PortForwardManager) RecoverAllPortForward

func (p *PortForwardManager) RecoverAllPortForward()

func (*PortForwardManager) RecoverPortForwardForApplication

func (p *PortForwardManager) RecoverPortForwardForApplication(ns, appName, nid string) error

func (*PortForwardManager) StartPortForwardGoRoutine

func (p *PortForwardManager) StartPortForwardGoRoutine(startCmd *command.PortForwardCommand, saveToDB bool) error

StartPortForwardGoRoutine Start a port-forward If saveToDB is true, record it to leveldb

func (*PortForwardManager) StopPortForwardGoRoutine

func (p *PortForwardManager) StopPortForwardGoRoutine(cmd *command.PortForwardCommand) error