syonad/two
2
0
Fork 0
Code Issues 3 Pull requests 1 Projects Releases 2 Packages Wiki Activity Actions

Compare commits

base: syonad:37e345609e58307487af4e616aa14ca1834680fd
Branches Tags
syonad:main
syonad:feature-15
syonad:intel
syonad:0.1.0rc15
syonad:0.1.0rc14
..
compare: syonad:c1c93f96181a1b88f27549a3635f1c8214fc7205
Branches Tags
syonad:feature-15
syonad:main
syonad:intel
syonad:0.1.0rc15
syonad:0.1.0rc14

No commits in common. "37e345609e58307487af4e616aa14ca1834680fd" and "c1c93f96181a1b88f27549a3635f1c8214fc7205" have entirely different histories.
37e345609e ... c1c93f9618

2 changed files with 15 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

6
cmd/meta_cli/main.go
View file

@ -20,7 +20,6 @@ func main() {
password := flag.String("pass", "", "password user") password := flag.String("pass", "", "password user")
start := flag.Bool("start", false, "start metadata server") start := flag.Bool("start", false, "start metadata server")
stop := flag.Bool("stop", false, "stop metadata server") stop := flag.Bool("stop", false, "stop metadata server")
dryrun := flag.Bool("dryrun", false, "launch in dry node")
flag.Parse() flag.Parse()
@ -31,6 +30,7 @@ func main() {
fmt.Println(err) fmt.Println(err)
return return
} }
fmt.Print(conf)
db := kv.InitDB(kv.Config{ db := kv.InitDB(kv.Config{
Path: conf.Database.Path, Path: conf.Database.Path,
@ -46,13 +46,9 @@ func main() {
Password: *password, Password: *password,
SSHKEY: *ssh_key, SSHKEY: *ssh_key,
}, db) }, db)
if !*dryrun {
service.Start("metadata@" + *vm_name) service.Start("metadata@" + *vm_name)
}
} else if *stop { } else if *stop {
nocloud.UnLoadNoCloudInDB(*vm_name, db) nocloud.UnLoadNoCloudInDB(*vm_name, db)
if !*dryrun {
service.Stop("metadata@" + *vm_name) service.Stop("metadata@" + *vm_name)
} }
}
} }

20
internal/load_db/nocloud/render.go
View file

@ -26,21 +26,25 @@ func renderConfig(path string, cfg Config) (string, error) {
return buf.String(), nil return buf.String(), nil
} }
var DB *badger.DB
func LoadNcCloudInDB(config Config, db *badger.DB) { func LoadNcCloudInDB(config Config, db *badger.DB) {
meta_data, _ := renderConfig("templates/meta-data.tmpl", config) meta_data, _ := renderConfig("templates/meta-data.tmpl", config)
user_data, _ := renderConfig("templates/user-data.tmpl", config) user_data, _ := renderConfig("templates/user-data.tmpl", config)
network_config, _ := renderConfig("templates/network-config.tmpl", config) network_config, _ := renderConfig("templates/network-config.tmpl", config)
vendor_data, _ := renderConfig("templates/vendor-data.tmpl", config) vendor_data, _ := renderConfig("templates/vendor-data.tmpl", config)
kv.AddInDB(db, "metadata/"+config.Name+"/meta-data", meta_data) DB = db
kv.AddInDB(db, "metadata/"+config.Name+"/user-data", user_data)
kv.AddInDB(db, "metadata/"+config.Name+"/network-config", network_config) kv.AddInDB(DB, "metadata/"+config.Name+"/meta-data", meta_data)
kv.AddInDB(db, "metadata/"+config.Name+"/vendor-data", vendor_data) kv.AddInDB(DB, "metadata/"+config.Name+"/user-data", user_data)
kv.AddInDB(db, "metadata/"+config.Name+"/vpc", config.VpcName) kv.AddInDB(DB, "metadata/"+config.Name+"/network-config", network_config)
kv.AddInDB(db, "metadata/"+config.Name+"/bind_ip", config.BindIP) kv.AddInDB(DB, "metadata/"+config.Name+"/vendor-data", vendor_data)
kv.AddInDB(db, "metadata/"+config.Name+"/bind_port", config.BindPort) kv.AddInDB(DB, "metadata/"+config.Name+"/vpc", config.VpcName)
kv.AddInDB(DB, "metadata/"+config.Name+"/bind_ip", config.BindIP)
kv.AddInDB(DB, "metadata/"+config.Name+"/bind_port", config.BindPort)
} }
func UnLoadNoCloudInDB(vm_name string, db *badger.DB) { func UnLoadNoCloudInDB(vm_name string, db *badger.DB) {
kv.DeleteInDB(db, "metadata/"+vm_name) kv.DeleteInDB(DB, "metadata/"+vm_name)
} }