action

Documentation

Index

• Variables
• func GetDaemonLogPath() string
• func InitFactory(kubeconfigBytes string, ns string) cmdutil.Factory
• func InitFactoryByPath(kubeconfig string, ns string) cmdutil.Factory
• type Server
  • func (svr *Server) Clone(req *rpc.CloneRequest, resp rpc.Daemon_CloneServer) error
  • func (svr *Server) ConfigAdd(ctx context.Context, req *rpc.ConfigAddRequest) (*rpc.ConfigAddResponse, error)
  • func (svr *Server) ConfigRemove(ctx context.Context, req *rpc.ConfigRemoveRequest) (*rpc.ConfigRemoveResponse, error)
  • func (svr *Server) Connect(req *rpc.ConnectRequest, resp rpc.Daemon_ConnectServer) (e error)
  • func (svr *Server) ConnectFork(req *rpc.ConnectRequest, resp rpc.Daemon_ConnectForkServer) error
  • func (svr *Server) Disconnect(req *rpc.DisconnectRequest, resp rpc.Daemon_DisconnectServer) error
  • func (svr *Server) Get(ctx context.Context, req *rpc.GetRequest) (*rpc.GetResponse, error)
  • func (svr *Server) Leave(req *rpc.LeaveRequest, resp rpc.Daemon_LeaveServer) error
  • func (svr *Server) List(ctx context.Context, req *rpc.ListRequest) (*rpc.ListResponse, error)
  • func (svr *Server) Logs(req *rpc.LogRequest, resp rpc.Daemon_LogsServer) error
  • func (svr *Server) Proxy(req *rpc.ConnectRequest, resp rpc.Daemon_ProxyServer) error
  • func (svr *Server) Quit(req *rpc.QuitRequest, resp rpc.Daemon_QuitServer) error
  • func (svr *Server) Remove(req *rpc.RemoveRequest, resp rpc.Daemon_RemoveServer) error
  • func (svr *Server) Reset(req *rpc.ResetRequest, resp rpc.Daemon_ResetServer) error
  • func (svr *Server) SshStart(ctx context.Context, req *rpc.SshStartRequest) (*rpc.SshStartResponse, error)
  • func (svr *Server) SshStop(ctx context.Context, req *rpc.SshStopRequest) (*rpc.SshStopResponse, error)
  • func (svr *Server) Status(ctx context.Context, request *rpc.StatusRequest) (*rpc.StatusResponse, error)
  • func (svr *Server) Stop(req *rpc.QuitRequest, resp rpc.Daemon_QuitServer) error
  • func (svr *Server) Upgrade(ctx context.Context, req *rpc.UpgradeRequest) (*rpc.UpgradeResponse, error)
  • func (svr *Server) Version(ctx context.Context, req *rpc.VersionRequest) (*rpc.VersionResponse, error)

Variables

var CancelFunc = make(map[string]context.CancelFunc)

var DefaultServerIP = (&net.IPNet{IP: config.DockerRouterIP, Mask: net.CIDRMask(bits, bits)}).String()

Functions

func GetDaemonLogPath

func GetDaemonLogPath() string

func InitFactory

func InitFactory(kubeconfigBytes string, ns string) cmdutil.Factory

func InitFactoryByPath

func InitFactoryByPath(kubeconfig string, ns string) cmdutil.Factory

Types

type Server

type Server struct {
	rpc.UnimplementedDaemonServer

	Cancel    func()
	GetClient func(isSudo bool) rpc.DaemonClient
	IsSudo    bool
	LogFile   *lumberjack.Logger
	Lock      sync.Mutex
	// contains filtered or unexported fields
}

func (*Server) Clone

func (svr *Server) Clone(req *rpc.CloneRequest, resp rpc.Daemon_CloneServer) error

func (*Server) ConfigAdd

func (svr *Server) ConfigAdd(ctx context.Context, req *rpc.ConfigAddRequest) (*rpc.ConfigAddResponse, error)

func (*Server) ConfigRemove

func (svr *Server) ConfigRemove(ctx context.Context, req *rpc.ConfigRemoveRequest) (*rpc.ConfigRemoveResponse, error)

func (*Server) Connect

func (svr *Server) Connect(req *rpc.ConnectRequest, resp rpc.Daemon_ConnectServer) (e error)

func (*Server) ConnectFork

func (svr *Server) ConnectFork(req *rpc.ConnectRequest, resp rpc.Daemon_ConnectForkServer) error

func (*Server) Disconnect

func (svr *Server) Disconnect(req *rpc.DisconnectRequest, resp rpc.Daemon_DisconnectServer) error

func (*Server) Get

func (svr *Server) Get(ctx context.Context, req *rpc.GetRequest) (*rpc.GetResponse, error)

func (*Server) Leave

func (svr *Server) Leave(req *rpc.LeaveRequest, resp rpc.Daemon_LeaveServer) error

func (*Server) List

func (svr *Server) List(ctx context.Context, req *rpc.ListRequest) (*rpc.ListResponse, error)

func (*Server) Logs

func (svr *Server) Logs(req *rpc.LogRequest, resp rpc.Daemon_LogsServer) error

func (*Server) Proxy

func (svr *Server) Proxy(req *rpc.ConnectRequest, resp rpc.Daemon_ProxyServer) error

Proxy

1. if not connect to cluster 1.1 connect to cluster 1.2 proxy workloads
2. if already connect to cluster 2.1 disconnect from cluster 2.2 same as step 1

func (*Server) Quit

func (svr *Server) Quit(req *rpc.QuitRequest, resp rpc.Daemon_QuitServer) error

func (*Server) Remove

func (svr *Server) Remove(req *rpc.RemoveRequest, resp rpc.Daemon_RemoveServer) error

func (*Server) Reset

func (svr *Server) Reset(req *rpc.ResetRequest, resp rpc.Daemon_ResetServer) error

func (*Server) SshStart

func (svr *Server) SshStart(ctx context.Context, req *rpc.SshStartRequest) (*rpc.SshStartResponse, error)

func (*Server) SshStop

func (svr *Server) SshStop(ctx context.Context, req *rpc.SshStopRequest) (*rpc.SshStopResponse, error)

func (*Server) Status

func (svr *Server) Status(ctx context.Context, request *rpc.StatusRequest) (*rpc.StatusResponse, error)

func (*Server) Stop

func (svr *Server) Stop(req *rpc.QuitRequest, resp rpc.Daemon_QuitServer) error

func (*Server) Upgrade

func (svr *Server) Upgrade(ctx context.Context, req *rpc.UpgradeRequest) (*rpc.UpgradeResponse, error)

func (*Server) Version

func (svr *Server) Version(ctx context.Context, req *rpc.VersionRequest) (*rpc.VersionResponse, error)