Compare commits
4 Commits
5e4adbfee5
..
v0.7.0
| Author | SHA1 | Date | |
|---|---|---|---|
| 7f5ac151c8 | |||
| 28bcaa2838 | |||
| 3cafb1a4e2 | |||
| 09bec11506 |
@@ -1 +1,2 @@
|
|||||||
.tmp
|
.tmp
|
||||||
|
.version
|
||||||
|
|||||||
+5
-2
@@ -2,6 +2,8 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
_ "embed"
|
||||||
|
|
||||||
"github.com/spf13/cobra"
|
"github.com/spf13/cobra"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -12,8 +14,9 @@ const (
|
|||||||
|
|
||||||
var (
|
var (
|
||||||
rootCmd = &cobra.Command{
|
rootCmd = &cobra.Command{
|
||||||
Use: CmdName,
|
Use: CmdName,
|
||||||
Short: "control tool for jpi.cloud",
|
Short: "control tool for jpi.cloud",
|
||||||
|
Version: version,
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,31 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
_ "embed"
|
||||||
|
|
||||||
|
"fmt"
|
||||||
|
"os"
|
||||||
|
|
||||||
|
"github.com/spf13/cobra"
|
||||||
|
)
|
||||||
|
|
||||||
|
//go:generate sh -c "git describe | tr -d '\r\n' > .version"
|
||||||
|
//go:embed .version
|
||||||
|
var version string
|
||||||
|
|
||||||
|
var versionCmd = &cobra.Command{
|
||||||
|
Use: "version",
|
||||||
|
Short: "Returns jpictl's version",
|
||||||
|
Args: cobra.NoArgs,
|
||||||
|
Run: func(_ *cobra.Command, _ []string) {
|
||||||
|
_, _ = fmt.Fprintf(os.Stdout, "%s\n", version)
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
if version == "" {
|
||||||
|
version = "undetermined"
|
||||||
|
}
|
||||||
|
|
||||||
|
rootCmd.AddCommand(versionCmd)
|
||||||
|
}
|
||||||
@@ -12,10 +12,6 @@ const (
|
|||||||
// ZoneRegionsFileName indicates the file containing
|
// ZoneRegionsFileName indicates the file containing
|
||||||
// region names as references
|
// region names as references
|
||||||
ZoneRegionsFileName = "regions"
|
ZoneRegionsFileName = "regions"
|
||||||
|
|
||||||
// RegionClusterTokenFileName contains the kubernetes
|
|
||||||
// token of the cluster this region represents
|
|
||||||
RegionClusterTokenFileName = "k8s_token"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func (m *Cluster) scan(opts *ScanOptions) error {
|
func (m *Cluster) scan(opts *ScanOptions) error {
|
||||||
@@ -190,8 +186,6 @@ func (z *Zone) scan() error {
|
|||||||
switch {
|
switch {
|
||||||
case name == ZoneRegionsFileName:
|
case name == ZoneRegionsFileName:
|
||||||
err = z.loadRegions()
|
err = z.loadRegions()
|
||||||
case name == RegionClusterTokenFileName:
|
|
||||||
err = z.loadClusterToken()
|
|
||||||
case e.IsDir():
|
case e.IsDir():
|
||||||
err = z.scanSubdirectory(name)
|
err = z.scanSubdirectory(name)
|
||||||
default:
|
default:
|
||||||
@@ -224,28 +218,6 @@ func (z *Zone) loadRegions() error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (z *Zone) loadClusterToken() error {
|
|
||||||
filename := path.Join(z.Name, RegionClusterTokenFileName)
|
|
||||||
lines, err := z.zones.ReadLines(filename)
|
|
||||||
if err == nil {
|
|
||||||
var token string
|
|
||||||
|
|
||||||
for _, s := range lines {
|
|
||||||
if s != "" {
|
|
||||||
token = s
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
err = z.zones.setRegionClusterToken(z.Name, token)
|
|
||||||
if err != nil {
|
|
||||||
err = core.Wrap(err, filename)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
func (z *Zone) scanSubdirectory(name string) error {
|
func (z *Zone) scanSubdirectory(name string) error {
|
||||||
m := &Machine{
|
m := &Machine{
|
||||||
zone: z,
|
zone: z,
|
||||||
|
|||||||
+7
-61
@@ -16,7 +16,6 @@ type Region struct {
|
|||||||
zones []*Zone
|
zones []*Zone
|
||||||
|
|
||||||
Name string
|
Name string
|
||||||
Cluster *string `json:",omitempty" yaml:",omitempty"`
|
|
||||||
Regions []string `json:",omitempty" yaml:",omitempty"`
|
Regions []string `json:",omitempty" yaml:",omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -107,26 +106,6 @@ func (m *Cluster) setRegionZones(name string, zones ...*Zone) {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Cluster) setRegionClusterToken(name string, token string) error {
|
|
||||||
for i := range m.Regions {
|
|
||||||
r := &m.Regions[i]
|
|
||||||
|
|
||||||
if r.Name == name {
|
|
||||||
// found
|
|
||||||
r.Cluster = &token
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// new
|
|
||||||
m.Regions = append(m.Regions, Region{
|
|
||||||
m: m,
|
|
||||||
Name: name,
|
|
||||||
Cluster: &token,
|
|
||||||
})
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *Cluster) appendRegionRegions(name string, subs ...string) {
|
func (m *Cluster) appendRegionRegions(name string, subs ...string) {
|
||||||
for i := range m.Regions {
|
for i := range m.Regions {
|
||||||
r := &m.Regions[i]
|
r := &m.Regions[i]
|
||||||
@@ -212,7 +191,7 @@ func (z *Zone) SyncRegions() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (z *Zone) syncZoneRegions() error {
|
func (z *Zone) syncZoneRegions() error {
|
||||||
name := filepath.Join(z.Name, ZoneRegionsFileName)
|
name := filepath.Join(z.Name, "regions")
|
||||||
|
|
||||||
if len(z.Regions) > 0 {
|
if len(z.Regions) > 0 {
|
||||||
var buf bytes.Buffer
|
var buf bytes.Buffer
|
||||||
@@ -231,25 +210,9 @@ func (z *Zone) syncZoneRegions() error {
|
|||||||
// SyncRegions writes to the file system the regions covered
|
// SyncRegions writes to the file system the regions covered
|
||||||
// by this meta-region
|
// by this meta-region
|
||||||
func (r *Region) SyncRegions() error {
|
func (r *Region) SyncRegions() error {
|
||||||
if err := r.syncRegionsFile(); err != nil {
|
name := filepath.Join(r.Name, "regions")
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return r.syncClusterFile()
|
if len(r.Regions) > 0 {
|
||||||
}
|
|
||||||
|
|
||||||
func (r *Region) mkdir() error {
|
|
||||||
return r.m.MkdirAll(r.Name)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *Region) syncRegionsFile() error {
|
|
||||||
var err error
|
|
||||||
|
|
||||||
name := filepath.Join(r.Name, ZoneRegionsFileName)
|
|
||||||
|
|
||||||
if len(r.Regions) == 0 {
|
|
||||||
err = r.m.RemoveFile(name)
|
|
||||||
} else if err = r.mkdir(); err == nil {
|
|
||||||
var buf bytes.Buffer
|
var buf bytes.Buffer
|
||||||
|
|
||||||
for _, s := range r.Regions {
|
for _, s := range r.Regions {
|
||||||
@@ -257,29 +220,12 @@ func (r *Region) syncRegionsFile() error {
|
|||||||
_, _ = buf.WriteRune('\n')
|
_, _ = buf.WriteRune('\n')
|
||||||
}
|
}
|
||||||
|
|
||||||
err = r.m.WriteStringFile(buf.String(), name)
|
if err := r.m.MkdirAll(r.Name); err != nil {
|
||||||
}
|
return err
|
||||||
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *Region) syncClusterFile() error {
|
|
||||||
var err error
|
|
||||||
|
|
||||||
name := filepath.Join(r.Name, RegionClusterTokenFileName)
|
|
||||||
|
|
||||||
if r.Cluster == nil {
|
|
||||||
err = r.m.RemoveFile(name)
|
|
||||||
} else if err = r.mkdir(); err == nil {
|
|
||||||
var buf bytes.Buffer
|
|
||||||
|
|
||||||
_, _ = buf.WriteString(*r.Cluster)
|
|
||||||
if buf.Len() > 0 {
|
|
||||||
_, _ = buf.WriteRune('\n')
|
|
||||||
}
|
}
|
||||||
|
|
||||||
err = r.m.WriteStringFile(buf.String(), name)
|
return r.m.WriteStringFile(buf.String(), name)
|
||||||
}
|
}
|
||||||
|
|
||||||
return err
|
return r.m.RemoveFile(name)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user