floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

remove "src"

This commit is contained in:
liugq 2023-06-05 11:39:11 +08:00
parent 9b47a1c57e
commit 567a204fe2
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
modules/agent/state/state.go
View File

@ -9,6 +9,7 @@ import (
"fmt" "fmt"
"github.com/buger/jsonparser" "github.com/buger/jsonparser"
log "github.com/cihub/seelog" log "github.com/cihub/seelog"
"gopkg.in/yaml.v2"
"infini.sh/console/modules/agent/client" "infini.sh/console/modules/agent/client"
"infini.sh/console/modules/agent/common" "infini.sh/console/modules/agent/common"
"infini.sh/console/modules/agent/model" "infini.sh/console/modules/agent/model"
@ -20,7 +21,6 @@ import (
"infini.sh/framework/modules/elastic" "infini.sh/framework/modules/elastic"
"runtime" "runtime"
"runtime/debug" "runtime/debug"
"src/gopkg.in/yaml.v2"
"sync" "sync"
"time" "time"
) )
@ -102,8 +102,6 @@ func (sm *StateManager) checkAgentStatus() {
// status change to online // status change to online
sm.agentIds[agentID] = model.StatusOnline sm.agentIds[agentID] = model.StatusOnline
log.Infof("status of agent [%s] changed to online", agentID) log.Infof("status of agent [%s] changed to online", agentID)
//set timestamp equals 0 to create pipeline
sm.timestamps[agentID] = 0
continue continue
}else{ }else{
// already offline // already offline