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