Browse Source

cluster: introduce Cluster.WriteStringFile()

Signed-off-by: Alejandro Mery <amery@jpi.io>
pull/36/head
Alejandro Mery 11 months ago
parent
commit
2fd5947f1b
  1. 14
      pkg/cluster/cluster_file.go
  2. 11
      pkg/cluster/machine_file.go

14
pkg/cluster/cluster_file.go

@ -1,6 +1,7 @@
package cluster package cluster
import ( import (
"bytes"
"fmt" "fmt"
"io" "io"
"os" "os"
@ -63,3 +64,16 @@ func (m *Cluster) ReadFile(name string, args ...any) ([]byte, error) {
return fs.ReadFile(m.dir, name) return fs.ReadFile(m.dir, name)
} }
// WriteStringFile writes the given content to a file on the machine's config directory
func (m *Cluster) WriteStringFile(value string, name string, args ...any) error {
f, err := m.CreateTruncFile(name, args...)
if err != nil {
return err
}
defer f.Close()
buf := bytes.NewBufferString(value)
_, err = buf.WriteTo(f)
return err
}

11
pkg/cluster/machine_file.go

@ -1,7 +1,6 @@
package cluster package cluster
import ( import (
"bytes"
"fmt" "fmt"
"io" "io"
"os" "os"
@ -58,15 +57,9 @@ func (m *Machine) ReadFile(name string, args ...any) ([]byte, error) {
// WriteStringFile writes the given content to a file on the machine's config directory // WriteStringFile writes the given content to a file on the machine's config directory
func (m *Machine) WriteStringFile(value string, name string, args ...any) error { func (m *Machine) WriteStringFile(value string, name string, args ...any) error {
f, err := m.CreateTruncFile(name, args...) fullName := m.getFilename(name, args...)
if err != nil {
return err
}
defer f.Close()
buf := bytes.NewBufferString(value) return m.zone.zones.WriteStringFile(value, fullName)
_, err = buf.WriteTo(f)
return err
} }
func (m *Machine) getFilename(name string, args ...any) string { func (m *Machine) getFilename(name string, args ...any) string {

Loading…
Cancel
Save