implement CheckDiskUsage() for Windows

.github/workflows/go.yml

@@ -29,3 +29,7 @@ jobs:
 
     - name: Goroutine leak detector
       run: go test -c -o tests && for test in $(go test -list . | grep -E "^(Test|Example)"); do ./tests -test.run "^$test\$" &>/dev/null && echo -e "$test passed\n" || echo -e "$test failed\n"; done
+
+    - name: Build for Windows
+      continue-on-error: true
+      run: GOOS=windows GOARCH=amd64 go build -v ./...

internal/pkg/controler/watchers/disk.go

@@ -4,10 +4,8 @@ import (
 	"context"
 	"fmt"
 	"sync"
-	"syscall"
 	"time"
 
-	"github.com/internetarchive/Zeno/internal/pkg/config"
 	"github.com/internetarchive/Zeno/internal/pkg/controler/pause"
 	"github.com/internetarchive/Zeno/internal/pkg/log"
 )
@@ -42,18 +40,6 @@ func checkThreshold(total, free uint64, minSpaceRequired float64) error {
 	return nil
 }
 
-func CheckDiskUsage(path string) error {
-	var stat syscall.Statfs_t
-	if err := syscall.Statfs(path, &stat); err != nil {
-		panic(fmt.Sprintf("Error retrieving disk stats: %v\n", err))
-	}
-
-	total := stat.Blocks * uint64(stat.Bsize)
-	free := stat.Bavail * uint64(stat.Bsize)
-
-	return checkThreshold(total, free, config.Get().MinSpaceRequired)
-}
-
 // WatchDiskSpace watches the disk space and pauses the pipeline if it's low
 func WatchDiskSpace(path string, interval time.Duration) {
 	diskWatcherWg.Add(1)

internal/pkg/controler/watchers/disk_unix.go

@@ -0,0 +1,22 @@
+//go:build !windows
+
+package watchers
+
+import (
+	"fmt"
+	"syscall"
+
+	"github.com/internetarchive/Zeno/internal/pkg/config"
+)
+
+func CheckDiskUsage(path string) error {
+	var stat syscall.Statfs_t
+	if err := syscall.Statfs(path, &stat); err != nil {
+		panic(fmt.Sprintf("Error retrieving disk stats: %v\n", err))
+	}
+
+	total := stat.Blocks * uint64(stat.Bsize)
+	free := stat.Bavail * uint64(stat.Bsize)
+
+	return checkThreshold(total, free, config.Get().MinSpaceRequired)
+}

internal/pkg/controler/watchers/disk_windows.go

@@ -0,0 +1,20 @@
+//go:build windows
+
+package watchers
+
+import (
+	"fmt"
+
+	"github.com/internetarchive/Zeno/internal/pkg/config"
+	"golang.org/x/sys/windows"
+)
+
+func CheckDiskUsage(path string) error {
+	var freeBytesAvailable uint64
+	var totalNumberOfBytes uint64
+	var totalNumberOfFreeBytes uint64
+	if err := windows.GetDiskFreeSpaceEx(windows.StringToUTF16Ptr(path), &freeBytesAvailable, &totalNumberOfBytes, &totalNumberOfFreeBytes); err != nil {
+		panic(fmt.Sprintf("Error retrieving disk stats: %v\n", err))
+	}
+	return checkThreshold(totalNumberOfBytes, freeBytesAvailable, config.Get().MinSpaceRequired)
+}