Compare commits
2 Commits
v0.0.1
..
3d7d74ac6b
| Author | SHA1 | Date | |
|---|---|---|---|
| 3d7d74ac6b | |||
| 9bfa63a0d9 |
@@ -0,0 +1,27 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"os"
|
||||||
|
|
||||||
|
"github.com/spf13/cobra"
|
||||||
|
|
||||||
|
"git.jpi.io/amery/jpictl/pkg/zones"
|
||||||
|
)
|
||||||
|
|
||||||
|
// Command
|
||||||
|
var envCmd = &cobra.Command{
|
||||||
|
Use: "env",
|
||||||
|
Short: "generates environment variables for shell scripts",
|
||||||
|
RunE: func(_ *cobra.Command, _ []string) error {
|
||||||
|
m, err := zones.New(cfg.Base, cfg.Domain)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
return m.WriteEnv(os.Stdout)
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
rootCmd.AddCommand(envCmd)
|
||||||
|
}
|
||||||
@@ -0,0 +1,9 @@
|
|||||||
|
// Package zones abstracts the cluster zones
|
||||||
|
package zones
|
||||||
|
|
||||||
|
import "io"
|
||||||
|
|
||||||
|
// WriteEnv generates environment variables for shell scripts
|
||||||
|
func (*Zones) WriteEnv(io.Writer) error {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
@@ -1,9 +1,7 @@
|
|||||||
package zones
|
package zones
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"net/netip"
|
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
|
||||||
"sync"
|
"sync"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -14,8 +12,6 @@ type Machine struct {
|
|||||||
zone *Zone
|
zone *Zone
|
||||||
id int
|
id int
|
||||||
Name string
|
Name string
|
||||||
|
|
||||||
PublicAddresses []netip.Addr
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Machine) String() string {
|
func (m *Machine) String() string {
|
||||||
@@ -42,17 +38,3 @@ func (m *Machine) ID() int {
|
|||||||
|
|
||||||
return m.id
|
return m.id
|
||||||
}
|
}
|
||||||
|
|
||||||
// FullName returns the Name of the machine including domain name
|
|
||||||
func (m *Machine) FullName() string {
|
|
||||||
if domain := m.zone.zones.domain; domain != "" {
|
|
||||||
var s = []string{
|
|
||||||
m.Name,
|
|
||||||
domain,
|
|
||||||
}
|
|
||||||
|
|
||||||
return strings.Join(s, ".")
|
|
||||||
}
|
|
||||||
|
|
||||||
return m.Name
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -1,26 +0,0 @@
|
|||||||
package zones
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"net/netip"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
func (m *Machine) lookupNetIP() ([]netip.Addr, error) {
|
|
||||||
timeout := 2 * time.Second
|
|
||||||
ctx, cancel := context.WithTimeout(context.Background(), timeout)
|
|
||||||
|
|
||||||
defer cancel()
|
|
||||||
|
|
||||||
return m.zone.zones.resolver.LookupNetIP(ctx, "ip", m.FullName())
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *Machine) updatePublicAddresses() error {
|
|
||||||
addrs, err := m.lookupNetIP()
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
m.PublicAddresses = addrs
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
@@ -43,10 +43,6 @@ func (z *Zone) scan() error {
|
|||||||
Name: e.Name(),
|
Name: e.Name(),
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := m.updatePublicAddresses(); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
z.Machines = append(z.Machines, m)
|
z.Machines = append(z.Machines, m)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user