Update agent information in place when a heartbeat is received

This commit is contained in:
Zack Mullaly 2018-11-19 15:27:58 -05:00
Родитель 262f2c4c8c
Коммит 12392b0205
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 1486642516ED3535
1 изменённых файлов: 6 добавлений и 2 удалений

Просмотреть файл

@ -26,9 +26,13 @@ func (persist PersistHeartbeatPostgres) PersistHeartbeat(heartbeat Heartbeat) er
fmt.Printf("POST /heartbeat got heartbeat %v\n", heartbeat)
agent := heartbeat.ToMigAgent()
err := persist.db.InsertAgent(agent, nil)
//err := persist.db.InsertAgent(agent, nil)
agent, err := persist.db.AgentByQueueAndPID(agent.QueueLoc, agent.PID)
if err != nil {
return err
}
return err
return persist.db.UpdateAgentHeartbeat(agent)
}
// _dontrun invokes a goroutine that updates the agent table when a heartbeat