|
|
|
@ -3,6 +3,7 @@ package cluster
|
|
|
|
|
// SyncAll updates all config files
|
|
|
|
|
func (m *Cluster) SyncAll() error { |
|
|
|
|
for _, fn := range []func() error{ |
|
|
|
|
m.SyncMkdirAll, |
|
|
|
|
m.SyncAllWireguard, |
|
|
|
|
m.SyncAllCeph, |
|
|
|
|
m.WriteHosts, |
|
|
|
@ -15,6 +16,20 @@ func (m *Cluster) SyncAll() error {
|
|
|
|
|
return nil |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// SyncMkdirAll creates the directories needed to store files
|
|
|
|
|
// required to represent the cluster.
|
|
|
|
|
func (m *Cluster) SyncMkdirAll() error { |
|
|
|
|
err := m.MkdirAll(".") |
|
|
|
|
if err == nil { |
|
|
|
|
m.ForEachMachine(func(p *Machine) bool { |
|
|
|
|
err = p.MkdirAll(".") |
|
|
|
|
return err != nil |
|
|
|
|
}) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
return err |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// SyncAllWireguard updates all wireguard config files
|
|
|
|
|
func (m *Cluster) SyncAllWireguard() error { |
|
|
|
|
var err error |
|
|
|
|