Support minio warp

This commit is contained in:
Quentin 2022-09-23 23:20:10 +02:00
parent 60df0fb95d
commit 0dc16e5e80
Signed by untrusted user: quentin
GPG key ID: E9602264D639FF68
3 changed files with 29 additions and 4 deletions

View file

@ -1,12 +1,17 @@
import os import os
from os.path import exists from os.path import exists
from pathlib import Path from pathlib import Path
from fragments import shared, garage, flavor from fragments import shared, garage, flavor, minio
warp_bin = Path(os.path.dirname(__file__)) / "../../benchmarks/warp/warp" warp_bin = Path(os.path.dirname(__file__)) / "../../benchmarks/warp/warp"
bench = flavor.warp["warp-fast"] bench = flavor.warp["warp-fast"]
def on_garage(params="mixed"): def common(port, ak, sk):
out = Path(shared.storage_path) / "warp.csv"
shared.log(f"launching warp {warp_bin}") shared.log(f"launching warp {warp_bin}")
shared.exec(f"{warp_bin} {params} --host={os.environ['IP']}:3900 --access-key={garage.key.access_key_id} --secret-key={garage.key.secret_access_key}") shared.exec(f"{warp_bin} {bench} --host=[{os.environ['IP']}]:{port} --analyze.out={out} --access-key={ak} --secret-key={sk}")
shared.log(f"execution done") shared.log(f"execution done")
def on_garage(): common(3900, garage.key.access_key_id, garage.key.secret_access_key)
def on_minio(): common(9000, minio.access_key, minio.secret_key)

View file

@ -10,7 +10,7 @@ for fl in sys.argv[1:]:
if shared.id() == 1: if shared.id() == 1:
garage.deploy_coord() garage.deploy_coord()
warp.on_garage(params=warp.bench) warp.on_garage()
garage.delete_key() garage.delete_key()
garage.destroy() garage.destroy()
else: else:

20
scenarios/minio-warp Executable file
View file

@ -0,0 +1,20 @@
#!/usr/bin/env python3
from fragments import minio, warp, shared, flavor
import sys
for fl in sys.argv[1:]:
if fl in flavor.minio:
minio.version = flavor.minio[fl]
if fl in flavor.warp:
warp.bench = flavor.warp[fl]
if shared.id() == 1:
minio.deploy_coord()
warp.on_minio()
minio.delete_sync_bucket()
minio.destroy()
else:
minio.deploy_follow()
minio.sync_on_bucket_down()
minio.destroy()
shared.log("bye")