+
:trollface: 哪吒监控 一站式轻监控轻运维系统。支持系统状态、HTTP(SSL 证书变更、即将到期、到期)、TCP、Ping 监控报警，计划任务和在线终端。
@@ -48,7 +48,7 @@ _\* 使用 WatchTower 可以自动更新面板，Windows 终端可以使用 nssm - `--disable-auto-update` 禁止 **自动更新** Agent（安全特性） - `--disable-force-update` 禁止 **强制更新** Agent（安全特性） - `--disable-command-execute` 禁止在 Agent 机器上执行定时任务、打开在线终端（安全特性） -- `--tls` 启用SSL/TLS加密（使用 nginx 反向代理 Agent 的 grpc 连接，并且 nginx 开启 SSL/TLS 时，需要启用该项配置） +- `--tls` 启用 SSL/TLS 加密（使用 nginx 反向代理 Agent 的 grpc 连接，并且 nginx 开启 SSL/TLS 时，需要启用该项配置） ## 功能说明 @@ -371,9 +371,9 @@ Agent 端配置 开启 Cloudflare CDN（可选） 根据 Cloudflare gRPC 的要求：gRPC 服务必须侦听 443 端口 且必须支持 TLS 和 HTTP/2。 -所以如果需要开启CDN，必须在配置 Nginx 或者 Caddy 反向代理 gRPC 时使用 443 端口，并配置证书（Caddy 会自动申请并配置证书）。 +所以如果需要开启 CDN，必须在配置 Nginx 或者 Caddy 反向代理 gRPC 时使用 443 端口，并配置证书（Caddy 会自动申请并配置证书）。 -- 登录 Cloudflare，选择使用的域名。打开 `网络` 选项将 `gRPC` 开关打开，打开 `DNS` 选项，找到 Nginx 或 Caddy 反代 gRPC 配置的域名的解析记录，打开橙色云启用CDN。 +- 登录 Cloudflare，选择使用的域名。打开 `网络` 选项将 `gRPC` 开关打开，打开 `DNS` 选项，找到 Nginx 或 Caddy 反代 gRPC 配置的域名的解析记录，打开橙色云启用 CDN。 diff --git a/cmd/dashboard/controller/member_api.go b/cmd/dashboard/controller/member_api.go index 331f7e2..854de73 100644 --- a/cmd/dashboard/controller/member_api.go +++ b/cmd/dashboard/controller/member_api.go @@ -331,7 +331,7 @@ func (ma *memberAPI) manualTrigger(c *gin.Context) { return } - dao.ManualTrigger(&cr) + dao.ManualTrigger(cr) c.JSON(http.StatusOK, model.Response{ Code: http.StatusOK, diff --git a/service/dao/dao.go b/service/dao/dao.go index 9b0e84d..ae482bd 100644 --- a/service/dao/dao.go +++ b/service/dao/dao.go @@ -13,7 +13,7 @@ import ( pb "github.com/naiba/nezha/proto" ) -var Version = "v0.12.0" // ！！记得修改 README 中的 badge 版本！！ +var Version = "v0.12.1" // ！！记得修改 README 中的 badge 版本！！ var ( Conf *model.Config @@ -53,20 +53,8 @@ var CronLock sync.RWMutex var Crons map[uint64]*model.Cron var Cron *cron.Cron -func ManualTrigger(c *model.Cron) { - ServerLock.RLock() - defer ServerLock.RUnlock() - for j := 0; j < len(c.Servers); j++ { - if ServerList[c.Servers[j]].TaskStream != nil { - ServerList[c.Servers[j]].TaskStream.Send(&pb.Task{ - Id: c.ID, - Data: c.Command, - Type: model.TaskTypeCommand, - }) - } else { - SendNotification(fmt.Sprintf("[任务失败] %s，服务器 %s 离线，无法执行。", c.Name, ServerList[c.Servers[j]].Name), false) - } - } +func ManualTrigger(c model.Cron) { + CronTrigger(c)() } func CronTrigger(cr model.Cron) func() {