Switched peer logging over

Signed-off-by: Jimmy Moore <[email protected]>

cmd/drafter-peer/devices.go

@@ -0,0 +1,167 @@
+package main
+
+import (
+	"encoding/json"
+	"path/filepath"
+	"time"
+
+	"github.com/loopholelabs/drafter/pkg/packager"
+)
+
+type CompositeDevices struct {
+	Name string `json:"name"`
+
+	Base    string `json:"base"`
+	Overlay string `json:"overlay"`
+	State   string `json:"state"`
+
+	BlockSize uint32 `json:"blockSize"`
+
+	Expiry time.Duration `json:"expiry"`
+
+	MaxDirtyBlocks int `json:"maxDirtyBlocks"`
+	MinCycles      int `json:"minCycles"`
+	MaxCycles      int `json:"maxCycles"`
+
+	CycleThrottle time.Duration `json:"cycleThrottle"`
+
+	MakeMigratable bool `json:"makeMigratable"`
+	Shared         bool `json:"shared"`
+}
+
+func decodeDevices(data string) ([]CompositeDevices, error) {
+	var devices []CompositeDevices
+	err := json.Unmarshal([]byte(data), &devices)
+	return devices, err
+}
+func getDefaultDevices() string {
+	defaultDevices, err := json.Marshal([]CompositeDevices{
+		{
+			Name: packager.StateName,
+
+			Base:    filepath.Join("out", "package", "state.bin"),
+			Overlay: filepath.Join("out", "overlay", "state.bin"),
+			State:   filepath.Join("out", "state", "state.bin"),
+
+			BlockSize: 1024 * 64,
+
+			Expiry: time.Second,
+
+			MaxDirtyBlocks: 200,
+			MinCycles:      5,
+			MaxCycles:      20,
+
+			CycleThrottle: time.Millisecond * 500,
+
+			MakeMigratable: true,
+			Shared:         false,
+		},
+		{
+			Name: packager.MemoryName,
+
+			Base:    filepath.Join("out", "package", "memory.bin"),
+			Overlay: filepath.Join("out", "overlay", "memory.bin"),
+			State:   filepath.Join("out", "state", "memory.bin"),
+
+			BlockSize: 1024 * 64,
+
+			Expiry: time.Second,
+
+			MaxDirtyBlocks: 200,
+			MinCycles:      5,
+			MaxCycles:      20,
+
+			CycleThrottle: time.Millisecond * 500,
+
+			MakeMigratable: true,
+			Shared:         false,
+		},
+
+		{
+			Name: packager.KernelName,
+
+			Base:    filepath.Join("out", "package", "vmlinux"),
+			Overlay: filepath.Join("out", "overlay", "vmlinux"),
+			State:   filepath.Join("out", "state", "vmlinux"),
+
+			BlockSize: 1024 * 64,
+
+			Expiry: time.Second,
+
+			MaxDirtyBlocks: 200,
+			MinCycles:      5,
+			MaxCycles:      20,
+
+			CycleThrottle: time.Millisecond * 500,
+
+			MakeMigratable: true,
+			Shared:         false,
+		},
+		{
+			Name: packager.DiskName,
+
+			Base:    filepath.Join("out", "package", "rootfs.ext4"),
+			Overlay: filepath.Join("out", "overlay", "rootfs.ext4"),
+			State:   filepath.Join("out", "state", "rootfs.ext4"),
+
+			BlockSize: 1024 * 64,
+
+			Expiry: time.Second,
+
+			MaxDirtyBlocks: 200,
+			MinCycles:      5,
+			MaxCycles:      20,
+
+			CycleThrottle: time.Millisecond * 500,
+
+			MakeMigratable: true,
+			Shared:         false,
+		},
+
+		{
+			Name: packager.ConfigName,
+
+			Base:    filepath.Join("out", "package", "config.json"),
+			Overlay: filepath.Join("out", "overlay", "config.json"),
+			State:   filepath.Join("out", "state", "config.json"),
+
+			BlockSize: 1024 * 64,
+
+			Expiry: time.Second,
+
+			MaxDirtyBlocks: 200,
+			MinCycles:      5,
+			MaxCycles:      20,
+
+			CycleThrottle: time.Millisecond * 500,
+
+			MakeMigratable: true,
+			Shared:         false,
+		},
+
+		{
+			Name: "oci",
+
+			Base:    filepath.Join("out", "package", "oci.ext4"),
+			Overlay: filepath.Join("out", "overlay", "oci.ext4"),
+			State:   filepath.Join("out", "state", "oci.ext4"),
+
+			BlockSize: 1024 * 64,
+
+			Expiry: time.Second,
+
+			MaxDirtyBlocks: 200,
+			MinCycles:      5,
+			MaxCycles:      20,
+
+			CycleThrottle: time.Millisecond * 500,
+
+			MakeMigratable: true,
+			Shared:         false,
+		},
+	})
+	if err != nil {
+		panic(err)
+	}
+	return string(defaultDevices)
+}