Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 8d1b9c4f04 | |||
| 60d3a5f650 | |||
| 67e27b7f01 | |||
| 03dfc73f63 | |||
| 41e2b75964 | |||
| 6e7f24f491 | |||
| 54b302c6d5 | |||
| fb331b6586 | |||
| f62a47003d | |||
| 5abaed9047 |
@@ -0,0 +1,75 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"context"
|
||||
"os"
|
||||
|
||||
"github.com/spf13/cobra"
|
||||
|
||||
"git.jpi.io/amery/jpictl/pkg/cluster"
|
||||
"git.jpi.io/amery/jpictl/pkg/dns"
|
||||
)
|
||||
|
||||
func newDNSManager(m *cluster.Cluster) (*dns.Manager, error) {
|
||||
domain := m.Domain
|
||||
if m.Name != "" {
|
||||
domain = m.Name + "." + domain
|
||||
}
|
||||
|
||||
mgr, err := dns.NewManager(dns.WithDomain(domain), dns.WithLogger(log))
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
m.ForEachZone(func(z *cluster.Zone) bool {
|
||||
z.ForEachMachine(func(p *cluster.Machine) bool {
|
||||
err = mgr.AddHost(context.TODO(), z.Name, p.ID, true, p.PublicAddresses...)
|
||||
return err != nil
|
||||
})
|
||||
|
||||
return err != nil
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
for _, r := range m.Regions {
|
||||
err := mgr.AddRegion(context.TODO(), r.Name, r.Zones()...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
}
|
||||
|
||||
return mgr, nil
|
||||
}
|
||||
|
||||
// Command
|
||||
var dnsCmd = &cobra.Command{
|
||||
Use: "dns",
|
||||
}
|
||||
|
||||
var dnsWriteCmd = &cobra.Command{
|
||||
Use: "write",
|
||||
PreRun: setVerbosity,
|
||||
RunE: func(_ *cobra.Command, _ []string) error {
|
||||
m, err := cfg.LoadZones(true)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
mgr, err := newDNSManager(m)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
_, err = mgr.WriteTo(os.Stdout)
|
||||
return err
|
||||
},
|
||||
}
|
||||
|
||||
func init() {
|
||||
rootCmd.AddCommand(dnsCmd)
|
||||
|
||||
dnsCmd.AddCommand(dnsWriteCmd)
|
||||
}
|
||||
Reference in New Issue
Block a user