mirror of
https://github.com/hanzoai/s3.git
synced 2026-10-30 14:59:09 +00:00
zeekay
ca324e043d
Kill MinIO; migrate object storage to SeaweedFS, rebranded Hanzo S3.
- module github.com/hanzoai/s3 (all 1920 imports rewritten); seaweedfs/{raft,goexif,go-fuse,cockroachdb-parser} kept as deps
- binary weed -> s3; display brand SeaweedFS -> Hanzo S3 (Server/version/admin); wire identifiers unchanged for S3 compat
- Dockerfile builds s3 (CGO_ENABLED=0, ldflags) -> ghcr.io/hanzoai/s3 via shared CI
- MinIO preserved in git history (prior main)
39 lines
1.1 KiB
Go
39 lines
1.1 KiB
Go
package framework
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/hanzoai/s3/test/volume_server/matrix"
|
|
)
|
|
|
|
func TestRustVolumeArgsIncludeReadMode(t *testing.T) {
|
|
profile := matrix.P1()
|
|
profile.ReadMode = "redirect"
|
|
profile.ConcurrentUploadLimitMB = 7
|
|
profile.ConcurrentDownloadLimitMB = 9
|
|
profile.InflightUploadTimeout = 3 * time.Second
|
|
profile.InflightDownloadTimeout = 4 * time.Second
|
|
|
|
args := rustVolumeArgs(profile, "/tmp/config", 9333, 18080, 28080, 38080, "/tmp/data")
|
|
|
|
assertArgPair(t, args, "--readMode", "redirect")
|
|
assertArgPair(t, args, "--concurrentUploadLimitMB", "7")
|
|
assertArgPair(t, args, "--concurrentDownloadLimitMB", "9")
|
|
assertArgPair(t, args, "--inflightUploadDataTimeout", "3s")
|
|
assertArgPair(t, args, "--inflightDownloadDataTimeout", "4s")
|
|
}
|
|
|
|
func assertArgPair(t *testing.T, args []string, flag string, want string) {
|
|
t.Helper()
|
|
for i := 0; i+1 < len(args); i += 2 {
|
|
if args[i] == flag {
|
|
if args[i+1] != want {
|
|
t.Fatalf("%s value mismatch: got %q want %q", flag, args[i+1], want)
|
|
}
|
|
return
|
|
}
|
|
}
|
|
t.Fatalf("missing %s in args: %v", flag, args)
|
|
}
|