package models
|
|
import (
|
"sync"
|
)
|
|
const (
|
RUNNING_Currupted = 0
|
RUNNING_Stopped = 1
|
RUNNING_Started = 2
|
)
|
|
type BeeNode struct {
|
Id int `gorm:"column:id;primary_key;unique;not null;autoIncrement" json:"id"` // 节点id
|
Address string `gorm:"column:address;not null;default:''" json:"address"` // 程序目录
|
Dir string `gorm:"column:dir;not null;default:''" json:"dir"` // 程序目录
|
ApiPort uint16 `gorm:"column:api_port" json:"apiPort"` // api port number
|
P2PPort uint16 `gorm:"column:p2p_port" json:"p2pPort"` // p2p port number
|
DebugPort uint16 `gorm:"column:debug_port" json:"debugPort"` // debug port number
|
Status uint8 `gorm:"column:status" json:"status"` // status
|
Del uint8 `gorm:"column:del" json:"del"` // del
|
}
|
|
var (
|
m sync.RWMutex
|
)
|
|
func (BeeNode) TableName() string {
|
return "t_node"
|
}
|
|
func (a *BeeNode) FindAll() ([]BeeNode, error) {
|
var rows []BeeNode
|
|
m.RLock()
|
defer m.RUnlock()
|
if err := db.Table(a.TableName()).Find(&rows).Error; err != nil {
|
return nil, err
|
}
|
|
return rows, nil
|
}
|
|
func (a *BeeNode) Save() error {
|
m.Lock()
|
defer m.Unlock()
|
|
return db.Create(a).Error
|
}
|
|
func (a *BeeNode) Update(status uint8) error {
|
m.Lock()
|
defer m.Unlock()
|
|
return db.Model(a).Update("Status", status).Error
|
}
|
