f-21: code: add default interface
Signed-off-by: GnomeZworc <nicolas.boufidjeline@g3e.fr>
This commit is contained in:
parent
8a68d3818f
commit
7dd795f4aa
3 changed files with 7 additions and 3 deletions
|
|
@ -1,7 +1,9 @@
|
||||||
database:
|
database:
|
||||||
path: "/var/lib/two/data/"
|
path: "/var/lib/two/data/"
|
||||||
|
|
||||||
|
default_interface: br-000000
|
||||||
|
|
||||||
interfaces:
|
interfaces:
|
||||||
vms: br-000000
|
vms: br-000000
|
||||||
internet: br-000000
|
internet: br-000000
|
||||||
admin: br-000000
|
admin: br-000000
|
||||||
|
|
|
||||||
|
|
@ -20,7 +20,8 @@ type Config struct {
|
||||||
Count int `mapstructure:"count"`
|
Count int `mapstructure:"count"`
|
||||||
BufferSize int `mapstructure:"buffer_size"`
|
BufferSize int `mapstructure:"buffer_size"`
|
||||||
} `mapstructure:"worker"`
|
} `mapstructure:"worker"`
|
||||||
Interfaces map[string]string `mapstructure:"interfaces"`
|
DefaultInterface string `mapstructure:"default_interface"`
|
||||||
|
Interfaces map[string]string `mapstructure:"interfaces"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func LoadConfig(path string) (*Config, error) {
|
func LoadConfig(path string) (*Config, error) {
|
||||||
|
|
@ -35,6 +36,7 @@ func LoadConfig(path string) (*Config, error) {
|
||||||
v.SetDefault("prometheus.port", 9090)
|
v.SetDefault("prometheus.port", 9090)
|
||||||
v.SetDefault("worker.count", 4)
|
v.SetDefault("worker.count", 4)
|
||||||
v.SetDefault("worker.buffer_size", 100)
|
v.SetDefault("worker.buffer_size", 100)
|
||||||
|
v.SetDefault("default_interface", "br-000000")
|
||||||
|
|
||||||
v.ReadInConfig()
|
v.ReadInConfig()
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -23,7 +23,7 @@ type CreateSubnetCommand struct {
|
||||||
func (c CreateSubnetCommand) Execute(db *badger.DB, cfg *configuration.Config) error {
|
func (c CreateSubnetCommand) Execute(db *badger.DB, cfg *configuration.Config) error {
|
||||||
localIface, ok := cfg.Interfaces[c.IfaceType]
|
localIface, ok := cfg.Interfaces[c.IfaceType]
|
||||||
if !ok {
|
if !ok {
|
||||||
return fmt.Errorf("unknown iface_type %q: not found in config", c.IfaceType)
|
localIface = cfg.DefaultInterface
|
||||||
}
|
}
|
||||||
kv.AddInDB(db, "subnet/"+c.Name+"/state", "creating")
|
kv.AddInDB(db, "subnet/"+c.Name+"/state", "creating")
|
||||||
kv.AddInDB(db, "subnet/"+c.Name+"/vpc", c.VPC)
|
kv.AddInDB(db, "subnet/"+c.Name+"/vpc", c.VPC)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue