mirror of
https://github.com/crawlab-team/crawlab.git
synced 2026-01-22 17:31:03 +01:00
38 lines
889 B
Go
38 lines
889 B
Go
package delegate
|
|
|
|
import (
|
|
"github.com/crawlab-team/crawlab/core/constants"
|
|
"github.com/crawlab-team/crawlab/core/interfaces"
|
|
"time"
|
|
)
|
|
|
|
type ModelNodeDelegate struct {
|
|
n interfaces.Node
|
|
interfaces.ModelDelegate
|
|
}
|
|
|
|
func (d *ModelNodeDelegate) UpdateStatus(active bool, activeTs *time.Time, status string) (err error) {
|
|
d.n.SetActive(active)
|
|
if activeTs != nil {
|
|
d.n.SetActiveTs(*activeTs)
|
|
}
|
|
d.n.SetStatus(status)
|
|
return d.Save()
|
|
}
|
|
|
|
func (d *ModelNodeDelegate) UpdateStatusOnline() (err error) {
|
|
now := time.Now()
|
|
return d.UpdateStatus(true, &now, constants.NodeStatusOnline)
|
|
}
|
|
|
|
func (d *ModelNodeDelegate) UpdateStatusOffline() (err error) {
|
|
return d.UpdateStatus(false, nil, constants.NodeStatusOffline)
|
|
}
|
|
|
|
func NewModelNodeDelegate(n interfaces.Node) interfaces.ModelNodeDelegate {
|
|
return &ModelNodeDelegate{
|
|
n: n,
|
|
ModelDelegate: NewModelDelegate(n),
|
|
}
|
|
}
|