Compare commits

..

No commits in common. "master" and "v0.0.40" have entirely different histories.

11 changed files with 318 additions and 413 deletions

View File

@ -7,23 +7,13 @@ BUILDTIME = $(shell date +%Y.%m.%d_%H%M)
# REDOMOD = $(shell if [ -e go.mod ]; then echo go.mod; else echo no go mod; fi) # REDOMOD = $(shell if [ -e go.mod ]; then echo go.mod; else echo no go mod; fi)
REDOMOD = $(shell if [ -e go.sum ]; then echo go.sum exists; else GO111MODULE= go mod init; GO111MODULE= go mod tidy; fi) REDOMOD = $(shell if [ -e go.sum ]; then echo go.sum exists; else GO111MODULE= go mod init; GO111MODULE= go mod tidy; fi)
all: goimports gocui-debugging all: goimports build
# ./zookeeper ./zookeeper
vet:
@GO111MODULE=off go vet
@echo this go binary package builds okay
nogui: nogui:
./zookeeper --gui nocui ./zookeeper --gui nocui
gocui: build build:
./zookeeper --gui gocui
gocui-debugging: build
./zookeeper --gui gocui --gui-file ~/go/src/go.wit.com/toolkits/gocui/gocui.so >/tmp/forge.log 2>&1
build: goimports vet
GO111MODULE=off go build -v -x \ GO111MODULE=off go build -v -x \
-ldflags "-X main.VERSION=${VERSION} -X main.BUILDTIME=${BUILDTIME} -X gui.GUIVERSION=${VERSION}" -ldflags "-X main.VERSION=${VERSION} -X main.BUILDTIME=${BUILDTIME} -X gui.GUIVERSION=${VERSION}"
@ -51,7 +41,7 @@ redomod:
clean: clean:
rm -f go.* rm -f go.*
rm -f zookeeper rm -f zookeeper
go-mod-clean purge go-mod-clean --purge
# git clone the sources and all the golang dependancies into ~/go/src # git clone the sources and all the golang dependancies into ~/go/src
# if you don't have go-clone, you can get it from http://go.wit.com/ # if you don't have go-clone, you can get it from http://go.wit.com/
@ -64,5 +54,14 @@ http-toogle-ZOOD:
http-list-machines: http-list-machines:
curl --silent http://localhost:8080/list curl --silent http://localhost:8080/list
http-uptime: http-ConfigSave:
curl --silent http://localhost:8080/uptime curl --silent http://localhost:8080/save
http-set-zood-target:
curl --silent "http://localhost:8080/target?package=zood&version=v0.0.8"
http-upgrade-hpdev2.grid.wit.com:
curl --silent "http://localhost:8080/upgrade?hostname=hpdev2.grid.wit.com"
http-upgrade-mirrors.wit.com:
curl --silent "http://localhost:8080/upgrade?hostname=mirrors.wit.com"

View File

@ -15,9 +15,8 @@ import (
var argv args var argv args
type args struct { type args struct {
Verbose bool `arg:"--verbose" default:"false" help:"talk more"` Daemon bool `arg:"--daemon" default:"false" help:"run in daemon mode"`
Daemon bool `arg:"--daemon" default:"false" help:"run in daemon mode"` Port int `arg:"--port" default:"8080" help:"port to run on"`
Port int `arg:"--port" default:"8080" help:"port to run on"`
} }
func (args) Version() string { func (args) Version() string {

115
doGui.go
View File

@ -6,6 +6,7 @@ package main
// An app to submit patches for the 30 GO GUI repos // An app to submit patches for the 30 GO GUI repos
import ( import (
"fmt"
"os" "os"
"time" "time"
@ -15,24 +16,10 @@ import (
"go.wit.com/log" "go.wit.com/log"
) )
// refresh the windows & tables the user has open func debug() {
func refresh() { for {
if argv.Verbose { time.Sleep(90 * time.Second)
log.Info("zookeeper scan here") log.Info("TODO: zookeeper scan here. repo count =")
}
if me.zood != nil {
// me.zood.doMachinesUpgradeTable(me.machines)
all := me.machines.All()
for all.Scan() {
m := all.Next()
if me.hostname == m.Hostname {
// this is me! This is the version of zood that should be installed everywhere
v := m.FindVersion("zood")
me.zood.version = v
me.zood.versionL.SetText(v)
}
}
me.zood.refresh()
} }
} }
@ -41,14 +28,22 @@ func doGui() {
me.myGui.InitEmbed(resources) me.myGui.InitEmbed(resources)
me.myGui.Default() me.myGui.Default()
win := gadgets.RawBasicWindow("Zookeeper: (inventory your cluster)") mainWindow := gadgets.RawBasicWindow("Zookeeper: (inventory your cluster)")
win.Make() mainWindow.Make()
win.Show() mainWindow.Show()
win.Custom = func() { mainWindow.Custom = func() {
log.Warn("Main window close") log.Warn("Main window close")
os.Exit(0) os.Exit(0)
} }
drawWindow(mainWindow)
// sits here forever
debug()
}
func drawWindow(win *gadgets.BasicWindow) {
box := win.Box() box := win.Box()
vbox := box.NewVerticalBox("BOX2") vbox := box.NewVerticalBox("BOX2")
@ -56,34 +51,62 @@ func doGui() {
group1 := vbox.NewGroup("Zookeeper Settings") group1 := vbox.NewGroup("Zookeeper Settings")
grid := group1.NewGrid("buildOptions", 0, 0) grid := group1.NewGrid("buildOptions", 0, 0)
grid.NewButton("zood versions", func() { var testWin *genericWindow
// if the window exists, just toggle it open or closed grid.NewButton("machine list", func() {
if me.zood != nil { if testWin != nil {
me.zood.Toggle() testWin.Toggle()
return return
} }
me.zood = makeZoodWin() testWin = makeMachineWindow(me.machines)
}) })
grid.NewButton("Cluster Events", func() { var test2 *genericWindow
log.Info("todo: start a list here!") grid.NewButton("test2", func() {
if test2 != nil {
test2.Toggle()
return
}
test2 = makeMachineWindow(me.machines)
})
}
func findVersion(m *zoopb.Machine, pkgname string) string {
zood := m.Packages.FindByName(pkgname)
if zood == nil {
return "n/a"
}
return zood.Version
}
func makeMachineWindow(pb *zoopb.Machines) *genericWindow {
win := initGenericWindow("Machines registered with Zookeeper", "Buttons of things")
grid := win.group.RawGrid()
grid.NewButton("List", func() {
log.Info("list...")
})
grid.NewButton("more", func() {
log.Info("?")
})
grid.NextRow()
grid.NewButton("smore", func() {
log.Info("smore")
}) })
// sit here forever refreshing the GUI tbox := win.win.Box().Vertical() // a vertical box (like a stack of books)
for { t := pb.NewTable("test 2")
refresh() t.SetParent(tbox)
time.Sleep(90 * time.Second) t.AddHostname()
} t.AddMemory()
} t.AddCpus()
t.AddStringFunc("sMB", func(m *zoopb.Machine) string {
func saveMachineState() { return fmt.Sprintf("%d mb", m.Memory/(1024*1024))
cur := zoopb.NewMachines() })
t.AddStringFunc("zood", func(m *zoopb.Machine) string {
all := me.machines.SortByHostname() return findVersion(m, "zood")
for all.Scan() { })
m := all.Next() t.AddTimeFunc("age", func(m *zoopb.Machine) time.Time {
log.Info("have machine:", m.Hostname) return m.Laststamp.AsTime()
cur.Append(m) })
} t.ShowTable()
cur.ConfigSave() return win
} }

22
exit.go
View File

@ -1,22 +0,0 @@
// Copyright 2017-2025 WIT.COM Inc. All rights reserved.
// Use of this source code is governed by the GPL 3.0
package main
import (
"os"
"go.wit.com/log"
)
func okExit(thing string) {
if thing != "" {
log.Info("zookeeper exit:", thing, "ok")
}
os.Exit(0)
}
func badExit(err error) {
log.Info("zookeeper failed: ", err)
os.Exit(-1)
}

123
http.go
View File

@ -8,8 +8,9 @@ import (
"io/ioutil" "io/ioutil"
"net/http" "net/http"
"strings" "strings"
"time"
"go.wit.com/lib/protobuf/forgepb"
"go.wit.com/lib/protobuf/zoopb"
"go.wit.com/log" "go.wit.com/log"
) )
@ -24,7 +25,9 @@ func okHandler(w http.ResponseWriter, r *http.Request) {
route := cleanURL(r.URL.Path) route := cleanURL(r.URL.Path)
hostname := r.URL.Query().Get("hostname") hostname := r.URL.Query().Get("hostname")
// flag := r.URL.Query().Get("flag") flag := r.URL.Query().Get("flag")
packname := r.URL.Query().Get("package")
version := r.URL.Query().Get("version")
msg, err := ioutil.ReadAll(r.Body) // Read the body as []byte msg, err := ioutil.ReadAll(r.Body) // Read the body as []byte
if err != nil { if err != nil {
@ -39,30 +42,109 @@ func okHandler(w http.ResponseWriter, r *http.Request) {
if route == "/machine" { if route == "/machine" {
handleMachine(r, w, hostname, msg) handleMachine(r, w, hostname, msg)
return return
}
if route == "/uptime" { var m *zoopb.Machine
if me.zood == nil { m = new(zoopb.Machine)
fmt.Fprintf(w, "BAD zood == nil\n") if err := m.Unmarshal(msg); err != nil {
log.Info("zoo host sent unknown machine protobuf len", len(msg))
forgepb.IdentifyProtobuf(msg)
log.Info("error =", err)
return return
} }
var count int log.Log(INFO, "proto.Unmarshal() worked on wire message len", len(msg), "from", m.Hostname)
var bad int b := me.upgrade[m.Hostname]
for m := range me.machines.IterAll() { switch updateMachine(m) {
count += 1 case "upgrade":
if m.FindVersion("zood") != me.zood.version { if b {
if m.SinceLastUpdate() > 10*time.Minute { fmt.Fprintln(w, "apt update")
// skip machines that have not been updated in the last 10 minutes me.upgrade[m.Hostname] = false
log.Info("ignoring old machine", m.Hostname) } else {
continue fmt.Fprintln(w, "upgrade")
} }
bad += 1 default:
fmt.Fprintln(w, "notsure")
}
return
}
if route == "/status" {
var packs *zoopb.Packages
packs = new(zoopb.Packages)
if err := packs.Unmarshal(msg); err != nil {
log.Info("/status proto.Unmarshal() failed on wire message len", len(msg), "from", hostname)
return
}
log.Info("/status Unmarshal worked with msg len", len(msg), "from", hostname)
log.Info("/status hostname", hostname, "has", packs.Len(), "packages installed")
fmt.Fprintln(w, "upgrade")
return
}
// list out the machines and thier version of zood
if route == "/list" {
log.HttpMode(w)
defer log.HttpMode(nil)
loop := me.machines.SortByHostname()
for loop.Scan() {
m := loop.Next()
zood := m.Packages.FindByName("zood")
v := me.targets["zood"] // this is the target version
if zood == nil {
log.Info("machine", m.Hostname, "does not have zood installed")
} else {
log.Info(fmt.Sprintf("zood version %s vs target version %s on machine %s", zood.Version, v, m.Hostname))
} }
} }
if bad == 0 { return
fmt.Fprintf(w, "GOOD machine count=(%d) all machines are version %s\n", count, me.zood.version) }
// save the config file
if route == "/save" {
log.HttpMode(w)
defer log.HttpMode(nil)
if err := me.machines2.ConfigSave(); err == nil {
log.Log(NOW, "ConfigSave() ok")
} else { } else {
fmt.Fprintf(w, "BAD machine count=(%d) upgrade=(%d) to %s\n", count, bad, me.zood.version) log.Log(NOW, "ConfigSave() failed", err)
}
return
}
// flag a package to attempt to upgrade
if route == "/upgrade" {
log.HttpMode(w)
defer log.HttpMode(nil)
me.upgrade[hostname] = true
log.Log(NOW, "setting package ", packname, " to upgrade")
return
}
// set the target version for a package
if route == "/target" {
log.HttpMode(w)
defer log.HttpMode(nil)
// me.targets[packname] = version
log.Log(NOW, "setting package/version to ", packname, " ", version)
return
}
// toggle logging flags
if route == "/flag" {
log.HttpMode(w)
defer log.HttpMode(nil)
log.Info("going to toggle flag:", flag)
switch flag {
case "ZOOD":
if ZOOD.Enabled() {
log.Log(NOW, "toogle ZOOD false")
ZOOD.SetBool(false)
} else {
log.Log(NOW, "toogle ZOOD true")
ZOOD.SetBool(true)
}
default:
log.Info("unknown looging flag:", flag)
} }
return return
} }
@ -80,6 +162,5 @@ func startHTTP() {
err := http.ListenAndServe(p, nil) err := http.ListenAndServe(p, nil)
if err != nil { if err != nil {
log.Println("Error starting server:", err) log.Println("Error starting server:", err)
badExit(err)
} }
} }

View File

@ -4,7 +4,6 @@
package main package main
import ( import (
"fmt"
"net/http" "net/http"
"strings" "strings"
"time" "time"
@ -43,6 +42,7 @@ func handleMachine(r *http.Request, w http.ResponseWriter, hostname string, data
am := new(zoopb.Machine) am := new(zoopb.Machine)
am.Hostname = newm.Hostname am.Hostname = newm.Hostname
am.Memory = newm.Memory am.Memory = newm.Memory
me.machines2.Append(am)
me.machines.Append(newm) me.machines.Append(newm)
log.Info("new machine", am.Hostname, am.Memory) log.Info("new machine", am.Hostname, am.Memory)
return return
@ -53,18 +53,6 @@ func handleMachine(r *http.Request, w http.ResponseWriter, hostname string, data
log.Info("hostname ua changed len =", len(data), ra, hostname, ua) log.Info("hostname ua changed len =", len(data), ra, hostname, ua)
m.UserAgent = ua m.UserAgent = ua
} }
if m.Upgrade {
log.Info(m.Hostname, "was told to upgrade zood")
if m.UpgradeCmd == "" {
fmt.Fprintln(w, "apt update")
} else {
fmt.Fprintln(w, m.UpgradeCmd)
}
m.UpgradeCmd = ""
m.Upgrade = false
} else {
fmt.Fprintln(w, "good")
}
// log.Info("update machine protobuf", hostname) // log.Info("update machine protobuf", hostname)
updateMachine(newm) updateMachine(newm)
} }
@ -79,12 +67,8 @@ func updateMachine(u *zoopb.Machine) string {
if m == nil { if m == nil {
log.Info("adding new machine", u.Hostname) log.Info("adding new machine", u.Hostname)
me.machines.Append(u) me.machines.Append(u)
if me.zood == nil { log.Info("save machines pb file here...")
// do nothing. window has not been opened me.machines2.ConfigSave()
} else {
me.zood.doMachinesUpgradeTable(me.machines)
}
saveMachineState()
return "new" return "new"
} }
// log.Info("updating machine", m.Hostname) // log.Info("updating machine", m.Hostname)
@ -113,9 +97,7 @@ func updateMachine(u *zoopb.Machine) string {
} }
m.Laststamp = timestamppb.New(time.Now()) m.Laststamp = timestamppb.New(time.Now())
if updatePackages(m, u.Packages) { updatePackages(m, u.Packages)
// trigger save pb
}
return "upgrade" return "upgrade"
} }
@ -130,36 +112,20 @@ func updatePackages(m *zoopb.Machine, newp *zoopb.Packages) bool {
for loop.Scan() { for loop.Scan() {
p := loop.Next() p := loop.Next()
if p.Name == "zood" { if p.Name == "zood" {
if updatePackageVersion(m, p) { if pold := m.Packages.FindByName("zood"); pold == nil {
changed = true
}
}
if p.Name == "virtigod" {
if updatePackageVersion(m, p) {
changed = true
}
}
if p.Name == "forge" {
if updatePackageVersion(m, p) {
changed = true changed = true
log.Log(ZOOD, "updatePackages() new package", p.Name, "version", p.Version, "machine", m.Hostname)
m.Packages.Append(p)
} else {
if p.Version == pold.Version {
log.Log(ZOOD, "updatePackages() unchanged", p.Version, "machine", m.Hostname)
} else {
changed = true
log.Log(NOW, "updatePackages() package", p.Name, "version changed", pold.Version, "to", p.Version, "machine", m.Hostname)
pold.Version = p.Version
}
} }
} }
} }
return changed return changed
} }
func updatePackageVersion(m *zoopb.Machine, pnew *zoopb.Package) bool {
pold := m.Packages.FindByName(pnew.Name)
if pold == nil {
log.Log(NOW, "updatePackages() new package", pnew.Name, "version", pnew.Version, "machine", m.Hostname)
m.Packages.Append(pnew)
return true
}
if pold.Version == pnew.Version {
log.Log(ZOOD, "updatePackages() unchanged", pold.Version, "machine", m.Hostname)
return false
}
log.Log(NOW, "updatePackages() package", pnew.Name, "version changed", pold.Version, "to", pnew.Version, "machine", m.Hostname)
pold.Version = pnew.Version
return true
}

12
main.go
View File

@ -35,15 +35,21 @@ func main() {
log.DaemonMode(true) log.DaemonMode(true)
} }
me = new(zookeep) me = new(stuff)
me.hostname, _ = os.Hostname() me.hostname, _ = os.Hostname()
me.pollDelay = time.Hour me.pollDelay = 10 * time.Second
me.machines = zoopb.NewMachines() me.machines = zoopb.NewMachines()
me.machines2 = zoopb.NewMachines()
if err := me.machines.ConfigLoad(); err != nil { if err := me.machines.ConfigLoad(); err != nil {
log.Warn("load config failed", err) log.Warn("load config failed", err)
os.Exit(-1) os.Exit(-1)
} }
// me.upgrade = make(map[string]bool) // used to trigger upgrade attempts if err := me.machines2.ConfigLoad(); err != nil {
log.Warn("load config failed", err)
os.Exit(-1)
}
// me.targets = make(map[string]string) // keep track of what versions the machines should be running
me.upgrade = make(map[string]bool) // used to trigger upgrade attempts
go NewWatchdog() go NewWatchdog()

View File

@ -7,26 +7,22 @@ import (
"time" "time"
"go.wit.com/gui" "go.wit.com/gui"
"go.wit.com/lib/gadgets"
"go.wit.com/lib/protobuf/zoopb" "go.wit.com/lib/protobuf/zoopb"
) )
var me *zookeep var me *stuff
// this app's variables // this app's variables
type zookeep struct { type stuff struct {
hostname string // my fqdn dns zookeeper hostname hostname string // my fqdn dns zookeeper hostname
pollDelay time.Duration // how often to report our status pollDelay time.Duration // how often to report our status
dog *time.Ticker // the watchdog timer dog *time.Ticker // the watchdog timer
dogchan chan bool // can kill the watchdog dogchan chan bool // can kill the watchdog
distro string // debian,redhat,gentoo,macos,wincrap distro string // debian,redhat,gentoo,macos,wincrap
packages *zoopb.Packages // installed packages and versions packages *zoopb.Packages // installed packages and versions
machines *zoopb.Machines // every machine that has reported itself to the zookeeper machines *zoopb.Machines // every machine that has reported itself to the zookeeper
targets map[string]string // what versions the machines should be running machines2 *zoopb.Machines // every machine that has reported itself to the zookeeper
upgrade map[string]bool // use this to trigger builds targets map[string]string // what versions the machines should be running
myGui *gui.Node // the gui toolkit handle upgrade map[string]bool // use this to trigger builds
machinesWin *gadgets.GenericWindow // the machines gui window myGui *gui.Node // the gui toolkit handle
machinesBox *gui.Node // the machines gui parent box widget
machinesTB *zoopb.MachinesTable // the machines gui table buffer
zood *stdTableWin // the zood version window
} }

View File

@ -55,7 +55,7 @@ func NewWatchdog() {
// log.Info("know about machine", m.Hostname, "zood version", zood.Version) // log.Info("know about machine", m.Hostname, "zood version", zood.Version)
} }
} }
log.Info("hour watchdog:", counter, "machines. Current time:", t) log.Info("zookeeper has", counter, "machines. Current time:", t)
// h.pollHypervisor() // h.pollHypervisor()
// h.Scan() // h.Scan()

92
windowGeneric.go Normal file
View File

@ -0,0 +1,92 @@
// Copyright 2017-2025 WIT.COM Inc. All rights reserved.
// Use of this source code is governed by the GPL 3.0
package main
import (
"go.wit.com/lib/gadgets"
"go.wit.com/log"
"go.wit.com/gui"
)
type genericWindow struct {
win *gadgets.BasicWindow // the window widget itself
box *gui.Node // the top box of the repolist window
group *gui.Node // the default group
}
func (r *genericWindow) Hidden() bool {
if r == nil {
return true
}
if r.win == nil {
return true
}
return r.win.Hidden()
}
func (r *genericWindow) Toggle() {
if r.Hidden() {
r.Show()
} else {
r.Hide()
}
}
func (r *genericWindow) Show() {
if r == nil {
return
}
if r.win == nil {
return
}
r.win.Show()
}
func (r *genericWindow) Hide() {
if r == nil {
return
}
if r.win == nil {
return
}
r.win.Hide()
}
func (r *genericWindow) Disable() {
if r == nil {
return
}
if r.box == nil {
return
}
r.box.Disable()
}
func (r *genericWindow) Enable() {
if r == nil {
return
}
if r.box == nil {
return
}
r.box.Enable()
}
func initGenericWindow(title string, grouptxt string) *genericWindow {
gw := new(genericWindow)
gw.win = gadgets.RawBasicWindow(title)
gw.win.Make()
gw.box = gw.win.Box().Vertical() // a vertical box (like a stack of books)
gw.win.Custom = func() {
log.Warn("Found Window close. setting hidden=true")
// sets the hidden flag to false so Toggle() works
gw.win.Hide()
}
gw.group = gw.box.NewGroup(grouptxt)
gw.Show()
return gw
}

View File

@ -1,235 +0,0 @@
// Copyright 2017-2025 WIT.COM Inc. All rights reserved.
// Use of this source code is governed by the GPL 3.0
package main
import (
"fmt"
"sync"
"time"
"go.wit.com/gui"
"go.wit.com/lib/gadgets"
"go.wit.com/lib/protobuf/zoopb"
"go.wit.com/log"
)
type stdTableWin struct {
sync.Mutex
win *gadgets.GenericWindow // the machines gui window
box *gui.Node // the machines gui parent box widget
TB *zoopb.MachinesTable // the machines gui table buffer
version string // the current zood version
versionL *gui.Node // label widget to display the current zood version
outOfDate *gui.Node // checkbox to only show out of date droplets
showAll *gui.Node // show everything in the zoo
update bool // if the window should be updated
}
func (w *stdTableWin) Toggle() {
if w == nil {
return
}
if w.win == nil {
return
}
w.win.Toggle()
}
func makeZoodWin() *stdTableWin {
stdw := new(stdTableWin)
stdw.win = gadgets.NewGenericWindow("zood daemon versions", "todo: add global controls here")
stdw.win.Custom = func() {
log.Info("test delete window here")
}
grid := stdw.win.Group.RawGrid()
grid.NewButton("save machines.pb", func() {
saveMachineState()
})
grid.NewButton("show active", func() {
stdw.doMachinesUpgradeTable(me.machines)
})
grid.NewButton("refresh", func() {
stdw.refresh()
})
stdw.versionL = grid.NewLabel("scan")
stdw.outOfDate = grid.NewCheckbox("out of date")
stdw.showAll = grid.NewCheckbox("all")
grid.NewButton("show out of date", func() {
found := zoopb.NewMachines()
all := me.machines.All()
for all.Scan() {
m := all.Next()
if m.FindVersion("zood") != me.zood.version {
found.Append(m)
}
}
stdw.doMachinesUpgradeTable(found)
})
// make a box at the bottom of the window for the protobuf table
stdw.box = stdw.win.Bottom.Box().SetProgName("TBOX")
stdw.doMachinesUpgradeTable(me.machines)
return stdw
}
func (stdw *stdTableWin) refresh() {
if stdw.outOfDate.Checked() {
log.Info("refresh() showing out of date zoo")
found := zoopb.NewMachines()
all := me.machines.All()
for all.Scan() {
m := all.Next()
if !stdw.showAll.Checked() {
// skip non-active zoo members
mtime := m.Laststamp.AsTime()
if time.Since(mtime) > 10*time.Hour {
continue
}
}
if m.FindVersion("zood") != me.zood.version {
found.Append(m)
}
}
stdw.doMachinesUpgradeTable(found)
return
}
if stdw.showAll.Checked() {
log.Info("refresh() showing everything in zoo")
stdw.doMachinesUpgradeTable(me.machines)
return
}
log.Info("refresh() only show active zoo")
found := zoopb.NewMachines()
all := me.machines.All()
for all.Scan() {
m := all.Next()
mtime := m.Laststamp.AsTime()
// now := time.Now()
if time.Since(mtime) > 10*time.Hour {
continue
}
found.Append(m)
}
stdw.doMachinesUpgradeTable(found)
}
func (zood *stdTableWin) doMachinesUpgradeTable(pb *zoopb.Machines) {
zood.Lock()
defer zood.Unlock()
if zood.TB != nil {
zood.TB.Delete()
zood.TB = nil
}
/*
found := zoopb.NewMachines()
all := pb.SortByHostname()
for all.Scan() {
m := all.Next()
found.Append(m)
}
*/
// display the protobuf
zood.TB = AddMachinesPB(zood.box, pb)
f := func(m *zoopb.Machine) {
log.Info("Triggering machine", m.Hostname, "to upgrade zood")
m.Upgrade = true
}
zood.TB.Custom(f)
log.Info("table has uuid", zood.TB.GetUuid())
}
func AddMachinesPB(tbox *gui.Node, pb *zoopb.Machines) *zoopb.MachinesTable {
t := pb.NewTable("MachinesPB")
t.NewUuid()
t.SetParent(tbox)
upbut := t.AddButtonFunc("upgrade", func(m *zoopb.Machine) string {
if me.zood != nil {
mver := m.FindVersion("zood")
if mver == me.zood.version {
return ""
} else {
// log.Info("machine mismatch", m.Hostname, mver, me.zood.version)
}
}
// log.Info("machine =", m.Hostname)
return "now"
})
upbut.Custom = func(m *zoopb.Machine) {
log.Info("Triggering machine", m.Hostname, "to upgrade zood")
m.Upgrade = true
}
t.AddHostname()
t.AddMemory()
t.AddCpus()
t.AddStringFunc("sMB", func(m *zoopb.Machine) string {
if m.Memory/(1024*1024) > 10000 {
return fmt.Sprintf("%4d G", m.Memory/(1024*1024*1024))
}
return fmt.Sprintf("%4d M", m.Memory/(1024*1024))
})
t.AddStringFunc("zood", func(m *zoopb.Machine) string {
return m.FindVersion("zood")
})
virtbut := t.AddButtonFunc("virtigod", func(m *zoopb.Machine) string {
ver := m.FindVersion("virtigod")
if ver == "n/a" {
return ""
}
return ver
})
virtbut.Custom = func(m *zoopb.Machine) {
log.Info("Triggering machine", m.Hostname, "to upgrade virtigod")
m.Upgrade = true
m.UpgradeCmd = "apt install virtigod"
}
forgebut := t.AddButtonFunc("forge", func(m *zoopb.Machine) string {
ver := m.FindVersion("forge")
if ver == "n/a" {
return ""
}
return ver
})
forgebut.Custom = func(m *zoopb.Machine) {
log.Info("Triggering machine", m.Hostname, "to upgrade forge")
m.Upgrade = true
m.UpgradeCmd = "apt install forge"
}
delf := func(m *zoopb.Machine) string {
return "delete"
}
delbut := t.AddButtonFunc("delete", delf)
delbut.Custom = func(m *zoopb.Machine) {
log.Info("Need to delete the protobuf record here", m.Hostname)
}
/*
// show if the machine needs to be upgraded
t.AddStringFunc("triggered?", func(m *zoopb.Machine) string {
if m.Upgrade {
return "yes"
}
return ""
})
*/
t.AddTimeFunc("age", func(m *zoopb.Machine) time.Time {
return m.Laststamp.AsTime()
})
t.ShowTable()
return t
}