server

Nov 15, 2023

Changes in this version

type AgentServer

+ func (s *AgentServer) GetWatcherFilterItem(appName, filterContent string) (appInfo AppInfo, err error)

Nov 3, 2023

Changes in this version

type AgentServer

+ func (s *AgentServer) CloseWatcher(uuid string)

Mar 21, 2023

Changes in this version

+ var AGENT_CREATE_ERR = errors.New("create agent faile")

+ func StartGRPCServer(grpcPort int, s *AgentServer)

+ type AgentServer struct

+ CloserFunDo func(appName, appUuid string) error

+ DoWorkChan chan Work

+ RegisterFunDo func(appName, appUuid, secret string) error

+ func NewServer() *AgentServer

+ func (s *AgentServer) ConnectAfterDo(req *pubproto.WorkDetail)

+ func (s *AgentServer) DoWork(stream pubproto.PubConnect_DoWorkServer) error

+ func (s *AgentServer) GetWatcherItem(appName string) (appInfo AppInfo, err error)

+ func (s *AgentServer) GetWatcherList() (appList []AppInfo)

+ func (s *AgentServer) GetWorkResult(uuid string) (Work, error)

+ func (s *AgentServer) Register(c context.Context, req *pubproto.RegReq) (*pubproto.RegResp, error)

+ func (s *AgentServer) SendWork(priKey, appName, appUuid, name, params string) (actionUuid string)

+ type AppInfo struct

+ Name string

+ UUID string

+ type Work struct

+ AppName string

+ AppUuid string

+ Name string

+ Params string

+ PriKey string

+ RequestTime int64

+ ResponseTime int64

+ Results string

+ Status string

+ Uuid string