f-15: error: add error handle
Signed-off-by: GnomeZworc <nicolas.boufidjeline@g3e.fr>
This commit is contained in:
parent
40b29657ae
commit
825fabb64a
2 changed files with 27 additions and 9 deletions
|
|
@ -35,15 +35,19 @@ func main() {
|
||||||
defer db.Close()
|
defer db.Close()
|
||||||
|
|
||||||
if *start {
|
if *start {
|
||||||
metadata.StartMetadata(metadata.NoCloudConfig{
|
if err := metadata.StartMetadata(metadata.NoCloudConfig{
|
||||||
VpcName: *vpc,
|
VpcName: *vpc,
|
||||||
Name: *vm_name,
|
Name: *vm_name,
|
||||||
BindIP: *bind_ip,
|
BindIP: *bind_ip,
|
||||||
BindPort: *bind_port,
|
BindPort: *bind_port,
|
||||||
Password: *password,
|
Password: *password,
|
||||||
SSHKEY: *ssh_key,
|
SSHKEY: *ssh_key,
|
||||||
}, db, *dryrun)
|
}, db, *dryrun); err != nil {
|
||||||
|
fmt.Println(err)
|
||||||
|
}
|
||||||
} else if *stop {
|
} else if *stop {
|
||||||
metadata.StopMetadata(*vm_name, db, *dryrun)
|
if err := metadata.StopMetadata(*vm_name, db, *dryrun); err != nil {
|
||||||
|
fmt.Println(err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,26 +1,40 @@
|
||||||
package metadata
|
package metadata
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
|
|
||||||
"git.g3e.fr/syonad/two/pkg/systemd"
|
"git.g3e.fr/syonad/two/pkg/systemd"
|
||||||
"github.com/dgraph-io/badger/v4"
|
"github.com/dgraph-io/badger/v4"
|
||||||
)
|
)
|
||||||
|
|
||||||
func StartMetadata(config NoCloudConfig, db *badger.DB, dryrun bool) {
|
func StartMetadata(config NoCloudConfig, db *badger.DB, dryrun bool) error {
|
||||||
service, _ := systemd.New()
|
service, err := systemd.New()
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to connect to systemd: %w", err)
|
||||||
|
}
|
||||||
defer service.Close()
|
defer service.Close()
|
||||||
|
|
||||||
LoadNcCloudInDB(config, db)
|
LoadNcCloudInDB(config, db)
|
||||||
if !dryrun {
|
if !dryrun {
|
||||||
service.Start("metadata@" + config.Name)
|
if err := service.Start("metadata@" + config.Name + ".service"); err != nil {
|
||||||
|
return fmt.Errorf("failed to start metadata@%s: %w", config.Name, err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func StopMetadata(vm_name string, db *badger.DB, dryrun bool) {
|
func StopMetadata(vm_name string, db *badger.DB, dryrun bool) error {
|
||||||
service, _ := systemd.New()
|
service, err := systemd.New()
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("failed to connect to systemd: %w", err)
|
||||||
|
}
|
||||||
defer service.Close()
|
defer service.Close()
|
||||||
|
|
||||||
UnLoadNoCloudInDB(vm_name, db)
|
UnLoadNoCloudInDB(vm_name, db)
|
||||||
if !dryrun {
|
if !dryrun {
|
||||||
service.Stop("metadata@" + vm_name)
|
if err := service.Stop("metadata@" + vm_name + ".service"); err != nil {
|
||||||
|
return fmt.Errorf("failed to stop metadata@%s: %w", vm_name, err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue