diff options
| author | Jeff Carr <[email protected]> | 2024-10-31 06:46:16 -0500 |
|---|---|---|
| committer | Jeff Carr <[email protected]> | 2024-10-31 06:46:16 -0500 |
| commit | 2ab607246e19b79b11c19fe6ca17d4015966a0ef (patch) | |
| tree | b989a1a9cf7c7389083bbb8c637fe360ece226d7 /addDroplet.go | |
| parent | 5c3543864db493bdf87375844f9d3b829a31d985 (diff) | |
change name to virtigolib
Signed-off-by: Jeff Carr <[email protected]>
Diffstat (limited to 'addDroplet.go')
| -rw-r--r-- | addDroplet.go | 27 |
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) { |
