TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-03 23:20:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

实现远程卸载节点功能

Browse Source
This commit is contained in:
刘祥超
2024-05-07 08:39:58 +08:00
parent 6361655beb
commit e1b9c152d4
2 changed files with 138 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
internal/rpc/services/service_node.go
View File

@@ -967,6 +967,31 @@ func (this *NodeService) StopNode(ctx context.Context, req *pb.StopNodeRequest)
return &pb.StopNodeResponse{IsOk: true}, nil
}
// UninstallNode 卸载节点
func (this *NodeService) UninstallNode(ctx context.Context, req *pb.UninstallNodeRequest) (*pb.UninstallNodeResponse, error) {
_, err := this.ValidateAdmin(ctx)
if err != nil {
return nil, err
}
err = installers.SharedNodeQueue().UninstallNode(req.NodeId)
if err != nil {
return &pb.UninstallNodeResponse{
IsOk: false,
Error: err.Error(),
}, nil
}
// 修改为未安装
var tx = this.NullTx()
err = models.SharedNodeDAO.UpdateNodeIsInstalled(tx, req.NodeId, false)
if err != nil {
return nil, err
}
return &pb.UninstallNodeResponse{IsOk: true}, nil
}
// UpdateNodeConnectedAPINodes 更改节点连接的API节点信息
func (this *NodeService) UpdateNodeConnectedAPINodes(ctx context.Context, req *pb.UpdateNodeConnectedAPINodesRequest) (*pb.RPCSuccess, error) {
// 校验节点