Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| d036abd816 |
@@ -48,12 +48,3 @@ func (m *Cluster) ReadFile(name string, args ...any) ([]byte, error) {
|
|||||||
|
|
||||||
return fs.ReadFile(m.dir, name)
|
return fs.ReadFile(m.dir, name)
|
||||||
}
|
}
|
||||||
|
|
||||||
// MkdirAll creates directories relative to the cluster's config directory
|
|
||||||
func (m *Cluster) MkdirAll(name string, args ...any) error {
|
|
||||||
if len(args) > 0 {
|
|
||||||
name = fmt.Sprintf(name, args...)
|
|
||||||
}
|
|
||||||
|
|
||||||
return fs.MkdirAll(m.dir, name, 0755)
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -76,13 +76,6 @@ func (m *Machine) WriteStringFile(value string, name string, args ...any) error
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// MkdirAll creates directories relative to the machine's config directory
|
|
||||||
func (m *Machine) MkdirAll(name string, args ...any) error {
|
|
||||||
fullName := m.getFilename(name, args...)
|
|
||||||
|
|
||||||
return m.zone.zones.MkdirAll(fullName)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *Machine) getFilename(name string, args ...any) string {
|
func (m *Machine) getFilename(name string, args ...any) string {
|
||||||
if len(args) > 0 {
|
if len(args) > 0 {
|
||||||
name = fmt.Sprintf(name, args...)
|
name = fmt.Sprintf(name, args...)
|
||||||
@@ -96,3 +89,11 @@ func (m *Machine) getFilename(name string, args ...any) string {
|
|||||||
|
|
||||||
return filepath.Join(s...)
|
return filepath.Join(s...)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// MkdirAll creates the directory representing this [Machine]
|
||||||
|
func (m *Machine) MkdirAll() error {
|
||||||
|
base := m.zone.zones.dir
|
||||||
|
fullName := m.getFilename(".")
|
||||||
|
|
||||||
|
return fs.MkdirAll(base, fullName, 0755)
|
||||||
|
}
|
||||||
|
|||||||
+9
-5
@@ -1,9 +1,13 @@
|
|||||||
package cluster
|
package cluster
|
||||||
|
|
||||||
|
import (
|
||||||
|
"github.com/hack-pad/hackpadfs"
|
||||||
|
)
|
||||||
|
|
||||||
// SyncAll updates all config files
|
// SyncAll updates all config files
|
||||||
func (m *Cluster) SyncAll() error {
|
func (m *Cluster) SyncAll() error {
|
||||||
for _, fn := range []func() error{
|
for _, fn := range []func() error{
|
||||||
m.SyncMkdirAll,
|
m.MkdirAll,
|
||||||
m.SyncAllWireguard,
|
m.SyncAllWireguard,
|
||||||
m.SyncAllCeph,
|
m.SyncAllCeph,
|
||||||
m.WriteHosts,
|
m.WriteHosts,
|
||||||
@@ -16,13 +20,13 @@ func (m *Cluster) SyncAll() error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// SyncMkdirAll creates the directories needed to store files
|
// MkdirAll creates the directories needed to store files
|
||||||
// required to represent the cluster.
|
// required to represent the cluster.
|
||||||
func (m *Cluster) SyncMkdirAll() error {
|
func (m *Cluster) MkdirAll() error {
|
||||||
err := m.MkdirAll(".")
|
err := hackpadfs.MkdirAll(m.dir, ".", 0755)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
m.ForEachMachine(func(p *Machine) bool {
|
m.ForEachMachine(func(p *Machine) bool {
|
||||||
err = p.MkdirAll(".")
|
err = p.MkdirAll()
|
||||||
return err != nil
|
return err != nil
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user