summaryrefslogtreecommitdiff
path: root/poll.go
diff options
context:
space:
mode:
authorJeff Carr <[email protected]>2024-10-31 15:43:25 -0500
committerJeff Carr <[email protected]>2024-10-31 15:43:25 -0500
commitb28ae96cd4c2801968ed883814b83357b77ed144 (patch)
tree5caa74ff9dd503fde31829b66d54164ddc0dbc42 /poll.go
parentb4ef8b76b1a92ef4da9fc0892c59a00f6f63a130 (diff)
ready for import local domain request to hypervisors
Signed-off-by: Jeff Carr <[email protected]>
Diffstat (limited to 'poll.go')
-rw-r--r--poll.go12
1 files changed, 8 insertions, 4 deletions
diff --git a/poll.go b/poll.go
index 8a0727c..4f225db 100644
--- a/poll.go
+++ b/poll.go
@@ -36,11 +36,15 @@ func (h *HyperT) pollHypervisor() {
if state == "OFF" {
d := me.cluster.FindDropletByName(name)
if d == nil {
- log.Log(WARN, "locally defined:", h.pb.Hostname, fields, "not imported")
- } else {
- log.Log(WARN, "locally defined:", h.pb.Hostname, fields, d.Hostname)
+ log.Log(WARN, "locally defined domain:", h.pb.Hostname, fields)
+ log.Log(WARN, "neeed to add a local droplet protobuf")
+ me.cluster.AddDropletLocal(name, h.pb.Hostname)
+ return
}
- // skip locally defined libvirt vms
+ if d.LocalOnly == "" {
+ log.Log(WARN, "ready to import", d.Hostname, "from", h.pb.Hostname)
+ }
+ log.Log(WARN, "duplicate local droplet", h.pb.Hostname, fields, "need to resolve this")
continue
}
h.lastDroplets[name] = time.Now()