summaryrefslogtreecommitdiff
path: root/addDroplet.go
diff options
context:
space:
mode:
authorJeff Carr <[email protected]>2024-10-31 06:46:16 -0500
committerJeff Carr <[email protected]>2024-10-31 06:46:16 -0500
commit2ab607246e19b79b11c19fe6ca17d4015966a0ef (patch)
treeb989a1a9cf7c7389083bbb8c637fe360ece226d7 /addDroplet.go
parent5c3543864db493bdf87375844f9d3b829a31d985 (diff)
change name to virtigolib
Signed-off-by: Jeff Carr <[email protected]>
Diffstat (limited to 'addDroplet.go')
-rw-r--r--addDroplet.go27
1 files changed, 11 insertions, 16 deletions
diff --git a/addDroplet.go b/addDroplet.go
index 04795da..382ee6e 100644
--- a/addDroplet.go
+++ b/addDroplet.go
@@ -1,6 +1,6 @@
// Copyright 2024 WIT.COM Inc Licensed GPL 3.0
-package virtigoxml
+package virtigolib
import (
"encoding/xml"
@@ -27,7 +27,7 @@ func AddDomainDroplet(cluster *pb.Cluster, domcfg *libvirtxml.Domain) (*pb.Dropl
if d == nil {
d = cluster.AddDroplet(domcfg.UUID, domcfg.Name, 2, 2*1024*1024)
d.StartState = pb.DropletState_OFF
- d.CurrentState = pb.DropletState_UNKNOWN
+ d.Current.State = pb.DropletState_UNKNOWN
// if the domcfg doesn't have a uuid, make a new one here
if d.Uuid == "" {
@@ -36,7 +36,7 @@ func AddDomainDroplet(cluster *pb.Cluster, domcfg *libvirtxml.Domain) (*pb.Dropl
}
}
- alle, err = updateDroplet(cluster, d, domcfg)
+ alle, err = updateDroplet(d, domcfg)
if err != nil {
log.Info("updateDroplet() failed for", d.Hostname)
return d, alle, errors.New("update failed for " + domcfg.Name)
@@ -85,7 +85,7 @@ func findDomain(c *pb.Cluster, domcfg *libvirtxml.Domain) (*pb.Droplet, error) {
return found, nil
}
-func updateDroplet(cluster *pb.Cluster, d *pb.Droplet, domcfg *libvirtxml.Domain) ([]*pb.Event, error) {
+func updateDroplet(d *pb.Droplet, domcfg *libvirtxml.Domain) ([]*pb.Event, error) {
var alle []*pb.Event
if d == nil {
@@ -108,10 +108,10 @@ func updateDroplet(cluster *pb.Cluster, d *pb.Droplet, domcfg *libvirtxml.Domain
if (domcfg.OS != nil) && (domcfg.OS.Type != nil) {
// OS Type: &{Arch:x86_64 Machine:pc-i440fx-5.2 Type:hvm}
t := domcfg.OS.Type
- if d.QemuArch != t.Arch {
- e := d.NewChangeEvent("Droplet.QemuArch", d.QemuArch, t.Arch)
+ if d.PreferredArch != t.Arch {
+ e := d.NewChangeEvent("Droplet.QemuArch", d.PreferredArch, t.Arch)
alle = append(alle, e)
- d.QemuArch = t.Arch
+ d.PreferredArch = t.Arch
}
if d.QemuMachine != t.Machine {
e := d.NewChangeEvent("Droplet.QemuMachine", d.QemuMachine, t.Machine)
@@ -156,7 +156,7 @@ func updateDroplet(cluster *pb.Cluster, d *pb.Droplet, domcfg *libvirtxml.Domain
return alle, errors.New("not kvm")
}
- nete, err := updateNetwork(cluster, d, domcfg)
+ nete, err := updateNetwork(d, domcfg)
if err != nil {
log.Info("updateNetwork() failed", err)
return alle, err
@@ -166,7 +166,7 @@ func updateDroplet(cluster *pb.Cluster, d *pb.Droplet, domcfg *libvirtxml.Domain
alle = append(alle, e)
}
- nete, err = updateDisk(cluster, d, domcfg)
+ nete, err = updateDisk(d, domcfg)
if err != nil {
return alle, err
}
@@ -180,11 +180,6 @@ func updateDroplet(cluster *pb.Cluster, d *pb.Droplet, domcfg *libvirtxml.Domain
return alle, nil
}
log.Info("libvirt xml import worked. droplet changed", domcfg.Name)
-
- // append each change event
- for _, e := range alle {
- cluster.E.Events = append(cluster.E.Events, e)
- }
return alle, nil
}
@@ -219,7 +214,7 @@ func updateMemory(d *pb.Droplet, domcfg *libvirtxml.Domain) (*pb.Event, error) {
return e, nil
}
-func updateNetwork(cluster *pb.Cluster, d *pb.Droplet, domcfg *libvirtxml.Domain) ([]*pb.Event, error) {
+func updateNetwork(d *pb.Droplet, domcfg *libvirtxml.Domain) ([]*pb.Event, error) {
var allEvents []*pb.Event
if (d == nil) || (domcfg == nil) {
return nil, errors.New("domcfg == nil")
@@ -343,7 +338,7 @@ func updateNetwork(cluster *pb.Cluster, d *pb.Droplet, domcfg *libvirtxml.Domain
*/
// returns false if something went wrong
-func updateDisk(cluster *pb.Cluster, d *pb.Droplet, domcfg *libvirtxml.Domain) ([]*pb.Event, error) {
+func updateDisk(d *pb.Droplet, domcfg *libvirtxml.Domain) ([]*pb.Event, error) {
var alle []*pb.Event
if (d == nil) || (domcfg == nil) {