[#164] *.js: Fix formatting

Signed-off-by: Alexander Chuprov <a.chuprov@yadro.com>

.forgejo/workflows/tests.yml

@@ -20,6 +20,27 @@ jobs:
       - name: Run linters
         run: make lint
 
+  clang-format:
+    name: Check clang-format
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v3
+
+      - name: Install deps
+        run: |
+         apt update
+         apt install -y clang-format          
+
+      - name: Run clang-format
+        run: make clang
+
+      - name: Print diff
+        run: git diff HEAD
+
+      - name: Check that nothing has changed
+        run: git diff-index --exit-code HEAD
+
   tests:
     name: Tests
     runs-on: ubuntu-latest

.pre-commit-config.yaml

@@ -0,0 +1,64 @@
+ci:
+  autofix_prs: false
+
+repos:
+  - repo: https://github.com/pre-commit/pre-commit-hooks
+    rev: v4.5.0
+    hooks:
+      - id: check-added-large-files
+      - id: check-case-conflict
+      - id: check-executables-have-shebangs
+      - id: check-shebang-scripts-are-executable
+      - id: check-merge-conflict
+      - id: check-json
+      - id: check-xml
+      - id: check-yaml
+      - id: trailing-whitespace
+        args: [--markdown-linebreak-ext=md]
+      - id: end-of-file-fixer
+        exclude: "(.key|.svg)$"
+
+  - repo: https://github.com/shellcheck-py/shellcheck-py
+    rev: v0.9.0.6
+    hooks:
+      - id: shellcheck
+
+  - repo: local
+    hooks:
+      - id: make-lint
+        name: Run Make Lint
+        entry: make lint
+        language: system
+        pass_filenames: false
+
+  - repo: local
+    hooks:
+      - id: make-clang
+        name: Run Make clang
+        entry: make clang
+        language: system
+        pass_filenames: false
+
+  - repo: local
+    hooks:
+      - id: go-unit-tests
+        name: go unit tests
+        entry: make test GOFLAGS=''
+        pass_filenames: false
+        types: [go]
+        language: system
+
+  - repo: local
+    hooks:
+      - id: gofumpt
+        name: gofumpt
+        entry: make fumpt
+        pass_filenames: false
+        types: [go]
+        language: system
+
+  - repo: https://github.com/TekWizely/pre-commit-golang
+    rev: v1.0.0-rc.1
+    hooks:
+      - id: go-staticcheck-repo-mod
+      - id: go-mod-tidy

CONTRIBUTING.md

@@ -27,7 +27,8 @@ Start by forking the `xk6-frostfs` repository, make changes in a branch and then
 send a pull request. We encourage pull requests to discuss code changes. Here
 are the steps in details:
 
-### Set up your GitHub Repository
+### Set up your repository
+
 Fork [xk6-frostfs upstream](https://git.frostfs.info/TrueCloudLab/xk6-frostfs/fork) source
 repository to your own personal repository. Copy the URL of your fork (you will
 need it for the `git clone` command below).
@@ -89,7 +90,7 @@ $ git push origin feature/123-something_awesome
 ```
 
 ### Create a Pull Request
-Pull requests can be created via GitHub. Refer to [this
+Pull requests can be created via git.frostfs.info. Refer to [this
 document](https://help.github.com/articles/creating-a-pull-request/) for
 detailed steps on how to create a pull request. After a Pull Request gets peer
 reviewed and approved, it will be merged.

Makefile

@@ -66,6 +66,8 @@ cover:
 format:
 	@echo "⇒ Processing gofmt check"
 	@gofmt -s -w ./
+	@echo "⇒ Processing clang-format"
+	@clang-format -i **/*.js
 
 # Run linters
 lint:

examples/local.js

@@ -1,24 +1,26 @@
 import local from 'k6/x/frostfs/local';
-import { uuidv4 } from '../scenarios/libs/k6-utils-1.4.0.js';
+
+import {uuidv4} from '../scenarios/libs/k6-utils-1.4.0.js';
 
 const payload = open('../go.sum', 'b');
-const local_cli = local.connect("/path/to/config.yaml", "/path/to/config/dir", "", false)
+const local_cli =
+    local.connect("/path/to/config.yaml", "/path/to/config/dir", "", false)
 
 export const options = {
-    stages: [
+  stages : [
-        {duration: '30s', target: 10},
+    {duration : '30s', target : 10},
-    ],
+  ],
 };
 
-export default function () {
+export default function() {
-    let headers = {
+  let headers = {
-        'unique_header': uuidv4()
+    'unique_header' : uuidv4()
-    }
+  } const container_id = '6BVPPXQewRJ6J5EYmAPLczXxNocS7ikyF7amS2esWQnb';
-    const container_id = '6BVPPXQewRJ6J5EYmAPLczXxNocS7ikyF7amS2esWQnb';
+  let resp = local_cli.put(container_id, headers, payload)
-    let resp = local_cli.put(container_id, headers, payload)
+  if (resp.success) {
-    if (resp.success) {
+    local_cli.get(container_id, resp.object_id)
-        local_cli.get(container_id, resp.object_id)
+  }
-    } else {
+  else {
-        console.log(resp.error)
+    console.log(resp.error)
-    }
+  }
 }

examples/native.js

@@ -1,40 +1,43 @@
+import {fail} from "k6";
 import native from 'k6/x/frostfs/native';
-import { fail } from "k6";
+
-import { uuidv4 } from '../scenarios/libs/k6-utils-1.4.0.js';
+import {uuidv4} from '../scenarios/libs/k6-utils-1.4.0.js';
 
 const payload = open('../go.sum', 'b');
-const frostfs_cli = native.connect("s01.frostfs.devenv:8080", "1dd37fba80fec4e6a6f13fd708d8dcb3b29def768017052f6c930fa1c5d90bbb", 0, 0, false, 0)
+const frostfs_cli = native.connect(
+    "s01.frostfs.devenv:8080",
+    "1dd37fba80fec4e6a6f13fd708d8dcb3b29def768017052f6c930fa1c5d90bbb", 0, 0,
+    false, 0)
 
 export const options = {
-    stages: [
+  stages : [
-        { duration: '30s', target: 10 },
+    {duration : '30s', target : 10},
-    ],
+  ],
 };
 
 export function setup() {
-    const params = {
+  const params = {
-        acl: 'public-read-write',
+    acl : 'public-read-write',
-        placement_policy: 'REP 3',
+    placement_policy : 'REP 3',
-        name: 'container-name',
+    name : 'container-name',
-        name_global_scope: 'false'
+    name_global_scope : 'false'
-    }
+  }
 
-    const res = frostfs_cli.putContainer(params)
+  const res = frostfs_cli.putContainer(params)
-    if (!res.success) {
+  if (!res.success) {
-        fail(res.error)
+    fail(res.error)
-    }
+  }
-    console.info("created container", res.container_id)
+  console.info("created container", res.container_id)
-    return { container_id: res.container_id }
+  return { container_id: res.container_id }
 }
 
-export default function (data) {
+export default function(data) {
-    let headers = {
+  let headers = {'unique_header' : uuidv4()} let resp =
-        'unique_header': uuidv4()
+      frostfs_cli.put(data.container_id, headers, payload)
-    }
+  if (resp.success) {
-    let resp = frostfs_cli.put(data.container_id, headers, payload)
+    frostfs_cli.get(data.container_id, resp.object_id)
-    if (resp.success) {
+  }
-        frostfs_cli.get(data.container_id, resp.object_id)
+  else {
-    } else {
+    console.log(resp.error)
-        console.log(resp.error)
+  }
-    }
 }

examples/native_onsite.js

@@ -1,25 +1,25 @@
 import native from 'k6/x/frostfs/native';
-import { uuidv4 } from '../scenarios/libs/k6-utils-1.4.0.js';
+
+import {uuidv4} from '../scenarios/libs/k6-utils-1.4.0.js';
 
 const payload = open('../go.sum', 'b');
 const container = "AjSxSNNXbJUDPqqKYm1VbFVDGCakbpUNH8aGjPmGAH3B"
-const frostfs_cli = native.connect("s01.frostfs.devenv:8080", "", 0, 0, false, 0)
+const frostfs_cli =
+    native.connect("s01.frostfs.devenv:8080", "", 0, 0, false, 0)
 const frostfs_obj = frostfs_cli.onsite(container, payload)
 
 export const options = {
-    stages: [
+  stages : [
-        { duration: '30s', target: 10 },
+    {duration : '30s', target : 10},
-    ],
+  ],
 };
 
-export default function () {
+export default function() {
-    let headers = {
+  let headers = {'unique_header' : uuidv4()} let resp = frostfs_obj.put(headers)
-        'unique_header': uuidv4()
+  if (resp.success) {
-    }
+    frostfs_cli.get(container, resp.object_id)
-    let resp = frostfs_obj.put(headers)
+  }
-    if (resp.success) {
+  else {
-        frostfs_cli.get(container, resp.object_id)
+    console.log(resp.error)
-    } else {
+  }
-        console.log(resp.error)
-    }
 }

examples/s3.js

@@ -1,33 +1,35 @@
+import {fail} from 'k6'
 import s3 from 'k6/x/frostfs/s3';
-import { fail } from 'k6'
+
-import { uuidv4 } from '../scenarios/libs/k6-utils-1.4.0.js';
+import {uuidv4} from '../scenarios/libs/k6-utils-1.4.0.js';
 
 const payload = open('../go.sum', 'b');
 const bucket = "cats"
-const s3_cli = s3.connect("https://s3.frostfs.devenv:8080", {'no_verify_ssl': 'true'})
+const s3_cli =
+    s3.connect("https://s3.frostfs.devenv:8080", {'no_verify_ssl' : 'true'})
 
 export const options = {
-    stages: [
+  stages : [
-        {duration: '30s', target: 10},
+    {duration : '30s', target : 10},
-    ],
+  ],
 };
 
 export function setup() {
-    const params = {
+  const params = {
-        acl: 'private',
+    acl : 'private',
-        lock_enabled: 'true',
+    lock_enabled : 'true',
-        location_constraint: 'ru'
+    location_constraint : 'ru'
-    }
+  }
 
-    const res = s3_cli.createBucket(bucket, params)
+  const res = s3_cli.createBucket(bucket, params)
-    if (!res.success) {
+  if (!res.success) {
-        fail(res.error)
+    fail(res.error)
-    }
+  }
 }
 
-export default function () {
+export default function() {
-    const key = uuidv4();
+  const key = uuidv4();
-    if (s3_cli.put(bucket, key, payload).success) {
+  if (s3_cli.put(bucket, key, payload).success) {
-        s3_cli.get(bucket, key)
+    s3_cli.get(bucket, key)
-    }
+  }
 }

examples/s3local.js

@@ -1,15 +1,17 @@
 import s3local from 'k6/x/frostfs/s3local';
-import { uuidv4 } from '../scenarios/libs/k6-utils-1.4.0.js';
+
+import {uuidv4} from '../scenarios/libs/k6-utils-1.4.0.js';
 
 const bucket = "testbucket"
 const payload = open('../go.sum', 'b');
-const s3local_cli = s3local.connect("path/to/storage/config.yml", "path/to/storage/config/dir", {}, {
+const s3local_cli = s3local.connect(
-    'testbucket': 'GBQDDUM1hdodXmiRHV57EUkFWJzuntsG8BG15wFSwam6',
+    "path/to/storage/config.yml", "path/to/storage/config/dir", {}, {
-});
+      'testbucket' : 'GBQDDUM1hdodXmiRHV57EUkFWJzuntsG8BG15wFSwam6',
+    });
 
-export default function () {
+export default function() {
-    const key = uuidv4();
+  const key = uuidv4();
-    if (s3local_cli.put(bucket, key, payload).success) {
+  if (s3local_cli.put(bucket, key, payload).success) {
-        s3local_cli.get(bucket, key)
+    s3local_cli.get(bucket, key)
-    }
+  }
 }

internal/s3/client.go

@@ -142,6 +142,70 @@ func (c *Client) Get(bucket, key string) GetResponse {
 	return GetResponse{Success: true}
 }
 
+// DeleteObjectVersion deletes object version with specified versionID.
+// If version argument is empty, deletes all versions and delete-markers of specified object.
+func (c *Client) DeleteObjectVersion(bucket, key, version string) DeleteResponse {
+	var toDelete []types.ObjectIdentifier
+
+	if version != "" {
+		toDelete = append(toDelete, types.ObjectIdentifier{
+			Key:       aws.String(key),
+			VersionId: aws.String(version),
+		})
+	} else {
+		versions, err := c.cli.ListObjectVersions(c.vu.Context(), &s3.ListObjectVersionsInput{
+			Bucket: aws.String(bucket),
+			Prefix: aws.String(key),
+		})
+		if err != nil {
+			stats.Report(c.vu, objDeleteFails, 1)
+			return DeleteResponse{Success: false, Error: err.Error()}
+		}
+		toDelete = filterObjectVersions(versions, key)
+	}
+	if len(toDelete) == 0 {
+		return c.Delete(bucket, key)
+	} else {
+		_, err := c.cli.DeleteObjects(c.vu.Context(), &s3.DeleteObjectsInput{
+			Bucket: aws.String(bucket),
+			Delete: &types.Delete{
+				Objects: toDelete,
+				Quiet:   true,
+			},
+		})
+		if err != nil {
+			stats.Report(c.vu, objDeleteFails, 1)
+			return DeleteResponse{Success: false, Error: err.Error()}
+		}
+	}
+
+	return DeleteResponse{Success: true}
+}
+
+func filterObjectVersions(versions *s3.ListObjectVersionsOutput, key string) []types.ObjectIdentifier {
+	var result []types.ObjectIdentifier
+
+	for _, v := range versions.Versions {
+		if *v.Key == key {
+			result = append(result, types.ObjectIdentifier{
+				Key:       v.Key,
+				VersionId: v.VersionId,
+			})
+		}
+	}
+
+	for _, marker := range versions.DeleteMarkers {
+		if *marker.Key == key {
+			result = append(result, types.ObjectIdentifier{
+				Key:       marker.Key,
+				VersionId: marker.VersionId,
+			})
+		}
+	}
+
+	return result
+}
+
 func get(
 	c *s3.Client,
 	bucket string,
@@ -215,6 +279,26 @@ func (c *Client) CreateBucket(bucket string, params map[string]string) CreateBuc
 		return CreateBucketResponse{Success: false, Error: err.Error()}
 	}
 
+	var versioning bool
+	if strVersioned, ok := params["versioning"]; ok {
+		if versioning, err = strconv.ParseBool(strVersioned); err != nil {
+			stats.Report(c.vu, createBucketFails, 1)
+			return CreateBucketResponse{Success: false, Error: err.Error()}
+		}
+	}
+	if versioning {
+		_, err = c.cli.PutBucketVersioning(context.TODO(), &s3.PutBucketVersioningInput{
+			Bucket: aws.String(bucket),
+			VersioningConfiguration: &types.VersioningConfiguration{
+				Status: types.BucketVersioningStatusEnabled,
+			},
+		})
+		if err != nil {
+			stats.Report(c.vu, createBucketFails, 1)
+			return CreateBucketResponse{Success: false, Error: err.Error()}
+		}
+	}
+
 	stats.Report(c.vu, createBucketSuccess, 1)
 	stats.Report(c.vu, createBucketDuration, metrics.D(time.Since(start)))
 	return CreateBucketResponse{Success: true}

scenarios/grpc.js

@@ -1,25 +1,25 @@
-import { sleep } from 'k6';
+import {sleep} from 'k6';
-import { SharedArray } from 'k6/data';
+import {SharedArray} from 'k6/data';
 import exec from 'k6/execution';
 import logging from 'k6/x/frostfs/logging';
 import native from 'k6/x/frostfs/native';
 import registry from 'k6/x/frostfs/registry';
 import stats from 'k6/x/frostfs/stats';
 
-import { newGenerator } from './libs/datagen.js';
+import {newGenerator} from './libs/datagen.js';
-import { parseEnv } from './libs/env-parser.js';
+import {parseEnv} from './libs/env-parser.js';
-import { textSummary } from './libs/k6-summary-0.0.2.js';
+import {textSummary} from './libs/k6-summary-0.0.2.js';
-import { uuidv4 } from './libs/k6-utils-1.4.0.js';
+import {uuidv4} from './libs/k6-utils-1.4.0.js';
 
 parseEnv();
 
 const obj_list = new SharedArray(
-  'obj_list',
+    'obj_list',
-  function () { return JSON.parse(open(__ENV.PREGEN_JSON)).objects; });
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).objects; });
 
 const container_list = new SharedArray(
-  'container_list',
+    'container_list',
-  function () { return JSON.parse(open(__ENV.PREGEN_JSON)).containers; });
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).containers; });
 
 const read_size = JSON.parse(open(__ENV.PREGEN_JSON)).obj_size;
 const summary_json = __ENV.SUMMARY_JSON || '/tmp/summary.json';
@@ -27,17 +27,18 @@ const summary_json = __ENV.SUMMARY_JSON || '/tmp/summary.json';
 // Select random gRPC endpoint for current VU
 const grpc_endpoints = __ENV.GRPC_ENDPOINTS.split(',');
 const grpc_endpoint =
-  grpc_endpoints[Math.floor(Math.random() * grpc_endpoints.length)];
+    grpc_endpoints[Math.floor(Math.random() * grpc_endpoints.length)];
 const grpc_client = native.connect(
-  grpc_endpoint, '', __ENV.DIAL_TIMEOUT ? parseInt(__ENV.DIAL_TIMEOUT) : 5,
+    grpc_endpoint, '', __ENV.DIAL_TIMEOUT ? parseInt(__ENV.DIAL_TIMEOUT) : 5,
-  __ENV.STREAM_TIMEOUT ? parseInt(__ENV.STREAM_TIMEOUT) : 60,
+    __ENV.STREAM_TIMEOUT ? parseInt(__ENV.STREAM_TIMEOUT) : 60,
-  __ENV.PREPARE_LOCALLY ? __ENV.PREPARE_LOCALLY.toLowerCase() === 'true' : false,
+    __ENV.PREPARE_LOCALLY ? __ENV.PREPARE_LOCALLY.toLowerCase() === 'true'
-  1024 * parseInt(__ENV.MAX_OBJECT_SIZE || '0'));
+                          : false,
+    1024 * parseInt(__ENV.MAX_OBJECT_SIZE || '0'));
 const log = logging.new().withField('endpoint', grpc_endpoint);
 
 const registry_enabled = !!__ENV.REGISTRY_FILE;
 const obj_registry =
-  registry_enabled ? registry.open(__ENV.REGISTRY_FILE) : undefined;
+    registry_enabled ? registry.open(__ENV.REGISTRY_FILE) : undefined;
 
 const duration = __ENV.DURATION;
 
@@ -49,11 +50,11 @@ const read_age = __ENV.READ_AGE ? parseInt(__ENV.READ_AGE) : 10;
 let obj_to_read_selector = undefined;
 if (registry_enabled) {
   obj_to_read_selector = registry.getLoopedSelector(
-    __ENV.REGISTRY_FILE, 'obj_to_read',
+      __ENV.REGISTRY_FILE, 'obj_to_read',
-    __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
+      __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-    status: 'created',
+        status : 'created',
-    age: read_age,
+        age : read_age,
-  })
+      })
 }
 
 const scenarios = {};
@@ -63,11 +64,11 @@ const write_grpc_chunk_size = 1024 * parseInt(__ENV.GRPC_CHUNK_SIZE || '0')
 const generator = newGenerator(write_vu_count > 0);
 if (write_vu_count > 0) {
   scenarios.write = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: write_vu_count,
+    vus : write_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_write',
+    exec : 'obj_write',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
@@ -78,24 +79,24 @@ if (registry_enabled && delete_age) {
   obj_to_delete_exit_on_null = write_vu_count == 0;
 
   let constructor = obj_to_delete_exit_on_null ? registry.getOneshotSelector
-    : registry.getSelector;
+                                               : registry.getSelector;
 
   obj_to_delete_selector =
-    constructor(__ENV.REGISTRY_FILE, 'obj_to_delete',
+      constructor(__ENV.REGISTRY_FILE, 'obj_to_delete',
-      __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
+                  __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-      status: 'created',
+                    status : 'created',
-      age: delete_age,
+                    age : delete_age,
-    });
+                  });
 }
 
 const read_vu_count = parseInt(__ENV.READERS || '0');
 if (read_vu_count > 0) {
   scenarios.read = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: read_vu_count,
+    vus : read_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_read',
+    exec : 'obj_read',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
@@ -103,21 +104,21 @@ const delete_vu_count = parseInt(__ENV.DELETERS || '0');
 if (delete_vu_count > 0) {
   if (!obj_to_delete_selector) {
     throw new Error(
-      'Positive DELETE worker number without a proper object selector');
+        'Positive DELETE worker number without a proper object selector');
   }
 
   scenarios.delete = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: delete_vu_count,
+    vus : delete_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_delete',
+    exec : 'obj_delete',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
 export const options = {
   scenarios,
-  setupTimeout: '5s',
+  setupTimeout : '5s',
 };
 
 export function setup() {
@@ -133,7 +134,7 @@ export function setup() {
 
   const start_timestamp = Date.now()
   console.log(
-    `Load started at:               ${Date(start_timestamp).toString()}`)
+      `Load started at:               ${Date(start_timestamp).toString()}`)
 }
 
 export function teardown(data) {
@@ -142,13 +143,13 @@ export function teardown(data) {
   }
   const end_timestamp = Date.now()
   console.log(
-    `Load finished at:              ${Date(end_timestamp).toString()}`)
+      `Load finished at:              ${Date(end_timestamp).toString()}`)
 }
 
 export function handleSummary(data) {
   return {
-    'stdout': textSummary(data, { indent: ' ', enableColors: false }),
+    'stdout' : textSummary(data, {indent : ' ', enableColors : false}),
-    [summary_json]: JSON.stringify(data),
+    [summary_json] : JSON.stringify(data),
   };
 }
 
@@ -157,13 +158,13 @@ export function obj_write() {
     sleep(__ENV.SLEEP_WRITE);
   }
 
-  const headers = { unique_header: uuidv4() };
+  const headers = {unique_header : uuidv4()};
   const container =
-    container_list[Math.floor(Math.random() * container_list.length)];
+      container_list[Math.floor(Math.random() * container_list.length)];
 
   const payload = generator.genPayload();
   const resp =
-    grpc_client.put(container, headers, payload, write_grpc_chunk_size);
+      grpc_client.put(container, headers, payload, write_grpc_chunk_size);
   if (!resp.success) {
     log.withField('cid', container).error(resp.error);
     return;
@@ -186,7 +187,7 @@ export function obj_read() {
     }
     const resp = grpc_client.get(obj.c_id, obj.o_id)
     if (!resp.success) {
-      log.withFields({ cid: obj.c_id, oid: obj.o_id }).error(resp.error);
+      log.withFields({cid : obj.c_id, oid : obj.o_id}).error(resp.error);
     }
     return
   }
@@ -194,7 +195,7 @@ export function obj_read() {
   const obj = obj_list[Math.floor(Math.random() * obj_list.length)];
   const resp = grpc_client.get(obj.container, obj.object)
   if (!resp.success) {
-    log.withFields({ cid: obj.container, oid: obj.object }).error(resp.error);
+    log.withFields({cid : obj.container, oid : obj.object}).error(resp.error);
   }
 }
 
@@ -214,7 +215,7 @@ export function obj_delete() {
   const resp = grpc_client.delete(obj.c_id, obj.o_id);
   if (!resp.success) {
     // Log errors except (2052 - object already deleted)
-    log.withFields({ cid: obj.c_id, oid: obj.o_id }).error(resp.error);
+    log.withFields({cid : obj.c_id, oid : obj.o_id}).error(resp.error);
     return;
   }
 

scenarios/grpc_car.js

@@ -1,24 +1,24 @@
-import { sleep } from 'k6';
+import {sleep} from 'k6';
-import { SharedArray } from 'k6/data';
+import {SharedArray} from 'k6/data';
 import logging from 'k6/x/frostfs/logging';
 import native from 'k6/x/frostfs/native';
 import registry from 'k6/x/frostfs/registry';
 import stats from 'k6/x/frostfs/stats';
 
-import { newGenerator } from './libs/datagen.js';
+import {newGenerator} from './libs/datagen.js';
-import { parseEnv } from './libs/env-parser.js';
+import {parseEnv} from './libs/env-parser.js';
-import { textSummary } from './libs/k6-summary-0.0.2.js';
+import {textSummary} from './libs/k6-summary-0.0.2.js';
-import { uuidv4 } from './libs/k6-utils-1.4.0.js';
+import {uuidv4} from './libs/k6-utils-1.4.0.js';
 
 parseEnv();
 
-const obj_list = new SharedArray('obj_list', function () {
+const obj_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).objects;
+    'obj_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).objects; });
 
-const container_list = new SharedArray('container_list', function () {
+const container_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).containers;
+    'container_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).containers; });
 
 const read_size = JSON.parse(open(__ENV.PREGEN_JSON)).obj_size;
 const summary_json = __ENV.SUMMARY_JSON || '/tmp/summary.json';
@@ -26,17 +26,18 @@ const summary_json = __ENV.SUMMARY_JSON || '/tmp/summary.json';
 // Select random gRPC endpoint for current VU
 const grpc_endpoints = __ENV.GRPC_ENDPOINTS.split(',');
 const grpc_endpoint =
-  grpc_endpoints[Math.floor(Math.random() * grpc_endpoints.length)];
+    grpc_endpoints[Math.floor(Math.random() * grpc_endpoints.length)];
 const grpc_client = native.connect(
-  grpc_endpoint, '', __ENV.DIAL_TIMEOUT ? parseInt(__ENV.DIAL_TIMEOUT) : 5,
+    grpc_endpoint, '', __ENV.DIAL_TIMEOUT ? parseInt(__ENV.DIAL_TIMEOUT) : 5,
-  __ENV.STREAM_TIMEOUT ? parseInt(__ENV.STREAM_TIMEOUT) : 60,
+    __ENV.STREAM_TIMEOUT ? parseInt(__ENV.STREAM_TIMEOUT) : 60,
-  __ENV.PREPARE_LOCALLY ? __ENV.PREPARE_LOCALLY.toLowerCase() === 'true' : false,
+    __ENV.PREPARE_LOCALLY ? __ENV.PREPARE_LOCALLY.toLowerCase() === 'true'
-  1024 * parseInt(__ENV.MAX_OBJECT_SIZE || '0'));
+                          : false,
+    1024 * parseInt(__ENV.MAX_OBJECT_SIZE || '0'));
 const log = logging.new().withField('endpoint', grpc_endpoint);
 
 const registry_enabled = !!__ENV.REGISTRY_FILE;
 const obj_registry =
-  registry_enabled ? registry.open(__ENV.REGISTRY_FILE) : undefined;
+    registry_enabled ? registry.open(__ENV.REGISTRY_FILE) : undefined;
 
 const duration = __ENV.DURATION;
 
@@ -48,22 +49,22 @@ const delete_age = __ENV.DELETE_AGE ? parseInt(__ENV.DELETE_AGE) : undefined;
 let obj_to_delete_selector = undefined;
 if (registry_enabled && delete_age) {
   obj_to_delete_selector = registry.getSelector(
-    __ENV.REGISTRY_FILE, 'obj_to_delete',
+      __ENV.REGISTRY_FILE, 'obj_to_delete',
-    __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
+      __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-    status: 'created',
+        status : 'created',
-    age: delete_age,
+        age : delete_age,
-  });
+      });
 }
 
 const read_age = __ENV.READ_AGE ? parseInt(__ENV.READ_AGE) : 10;
 let obj_to_read_selector = undefined;
 if (registry_enabled) {
   obj_to_read_selector = registry.getLoopedSelector(
-    __ENV.REGISTRY_FILE, 'obj_to_read',
+      __ENV.REGISTRY_FILE, 'obj_to_read',
-    __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
+      __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-    status: 'created',
+        status : 'created',
-    age: read_age,
+        age : read_age,
-  })
+      })
 }
 
 const scenarios = {};
@@ -76,14 +77,14 @@ const write_grpc_chunk_size = 1024 * parseInt(__ENV.GRPC_CHUNK_SIZE || '0')
 const generator = newGenerator(write_rate > 0);
 if (write_rate > 0) {
   scenarios.write = {
-    executor: 'constant-arrival-rate',
+    executor : 'constant-arrival-rate',
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    preAllocatedVUs: pre_alloc_write_vus,
+    preAllocatedVUs : pre_alloc_write_vus,
-    maxVUs: max_write_vus,
+    maxVUs : max_write_vus,
-    rate: write_rate,
+    rate : write_rate,
-    timeUnit: time_unit,
+    timeUnit : time_unit,
-    exec: 'obj_write',
+    exec : 'obj_write',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
@@ -92,14 +93,14 @@ const max_read_vus = parseInt(__ENV.MAX_READERS || pre_alloc_read_vus);
 const read_rate = parseInt(__ENV.READ_RATE || '0');
 if (read_rate > 0) {
   scenarios.read = {
-    executor: 'constant-arrival-rate',
+    executor : 'constant-arrival-rate',
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    preAllocatedVUs: pre_alloc_write_vus,
+    preAllocatedVUs : pre_alloc_write_vus,
-    maxVUs: max_read_vus,
+    maxVUs : max_read_vus,
-    rate: read_rate,
+    rate : read_rate,
-    timeUnit: time_unit,
+    timeUnit : time_unit,
-    exec: 'obj_read',
+    exec : 'obj_read',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
@@ -109,29 +110,29 @@ const delete_rate = parseInt(__ENV.DELETE_RATE || '0');
 if (delete_rate > 0) {
   if (!obj_to_delete_selector) {
     throw new Error(
-      'Positive DELETE worker number without a proper object selector');
+        'Positive DELETE worker number without a proper object selector');
   }
 
   scenarios.delete = {
-    executor: 'constant-arrival-rate',
+    executor : 'constant-arrival-rate',
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    preAllocatedVUs: pre_alloc_delete_vus,
+    preAllocatedVUs : pre_alloc_delete_vus,
-    maxVUs: max_delete_vus,
+    maxVUs : max_delete_vus,
-    rate: delete_rate,
+    rate : delete_rate,
-    timeUnit: time_unit,
+    timeUnit : time_unit,
-    exec: 'obj_delete',
+    exec : 'obj_delete',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
 export const options = {
   scenarios,
-  setupTimeout: '5s',
+  setupTimeout : '5s',
 };
 
 export function setup() {
   const total_pre_allocated_vu_count =
-    pre_alloc_write_vus + pre_alloc_read_vus + pre_alloc_delete_vus;
+      pre_alloc_write_vus + pre_alloc_read_vus + pre_alloc_delete_vus;
   const total_max_vu_count = max_read_vus + max_write_vus + max_delete_vus
 
   console.log(`Pregenerated containers:       ${container_list.length}`);
@@ -152,7 +153,7 @@ export function setup() {
 
   const start_timestamp = Date.now()
   console.log(
-    `Load started at:               ${Date(start_timestamp).toString()}`)
+      `Load started at:               ${Date(start_timestamp).toString()}`)
 }
 
 export function teardown(data) {
@@ -161,13 +162,13 @@ export function teardown(data) {
   }
   const end_timestamp = Date.now()
   console.log(
-    `Load finished at:              ${Date(end_timestamp).toString()}`)
+      `Load finished at:              ${Date(end_timestamp).toString()}`)
 }
 
 export function handleSummary(data) {
   return {
-    'stdout': textSummary(data, { indent: ' ', enableColors: false }),
+    'stdout' : textSummary(data, {indent : ' ', enableColors : false}),
-    [summary_json]: JSON.stringify(data),
+    [summary_json] : JSON.stringify(data),
   };
 }
 
@@ -176,13 +177,13 @@ export function obj_write() {
     sleep(__ENV.SLEEP_WRITE);
   }
 
-  const headers = { unique_header: uuidv4() };
+  const headers = {unique_header : uuidv4()};
   const container =
-    container_list[Math.floor(Math.random() * container_list.length)];
+      container_list[Math.floor(Math.random() * container_list.length)];
 
   const payload = generator.genPayload();
   const resp =
-    grpc_client.put(container, headers, payload, write_grpc_chunk_size);
+      grpc_client.put(container, headers, payload, write_grpc_chunk_size);
   if (!resp.success) {
     log.withField('cid', container).error(resp.error);
     return;
@@ -205,7 +206,7 @@ export function obj_read() {
     }
     const resp = grpc_client.get(obj.c_id, obj.o_id)
     if (!resp.success) {
-      log.withFields({ cid: obj.c_id, oid: obj.o_id }).error(resp.error);
+      log.withFields({cid : obj.c_id, oid : obj.o_id}).error(resp.error);
     }
     return
   }
@@ -213,7 +214,7 @@ export function obj_read() {
   const obj = obj_list[Math.floor(Math.random() * obj_list.length)];
   const resp = grpc_client.get(obj.container, obj.object)
   if (!resp.success) {
-    log.withFields({ cid: obj.container, oid: obj.object }).error(resp.error);
+    log.withFields({cid : obj.container, oid : obj.object}).error(resp.error);
   }
 }
 
@@ -230,7 +231,7 @@ export function obj_delete() {
   const resp = grpc_client.delete(obj.c_id, obj.o_id);
   if (!resp.success) {
     // Log errors except (2052 - object already deleted)
-    log.withFields({ cid: obj.c_id, oid: obj.o_id }).error(resp.error);
+    log.withFields({cid : obj.c_id, oid : obj.o_id}).error(resp.error);
     return;
   }
 

scenarios/http.js

@@ -12,13 +12,13 @@ import {uuidv4} from './libs/k6-utils-1.4.0.js';
 
 parseEnv();
 
-const obj_list = new SharedArray('obj_list', function() {
+const obj_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).objects;
+    'obj_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).objects; });
 
-const container_list = new SharedArray('container_list', function() {
+const container_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).containers;
+    'container_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).containers; });
 
 const read_size = JSON.parse(open(__ENV.PREGEN_JSON)).obj_size;
 const summary_json = __ENV.SUMMARY_JSON || '/tmp/summary.json';
@@ -45,28 +45,28 @@ const write_vu_count = parseInt(__ENV.WRITERS || '0');
 const generator = newGenerator(write_vu_count > 0);
 if (write_vu_count > 0) {
   scenarios.write = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: write_vu_count,
+    vus : write_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_write',
+    exec : 'obj_write',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   }
 }
 
 const read_vu_count = parseInt(__ENV.READERS || '0');
 if (read_vu_count > 0) {
   scenarios.read = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: read_vu_count,
+    vus : read_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_read',
+    exec : 'obj_read',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   }
 }
 
 export const options = {
   scenarios,
-  setupTimeout: '5s',
+  setupTimeout : '5s',
 };
 
 export function setup() {
@@ -95,8 +95,8 @@ export function teardown(data) {
 
 export function handleSummary(data) {
   return {
-    'stdout': textSummary(data, {indent: ' ', enableColors: false}),
+    'stdout' : textSummary(data, {indent : ' ', enableColors : false}),
-    [summary_json]: JSON.stringify(data),
+    [summary_json] : JSON.stringify(data),
   };
 }
 
@@ -110,16 +110,16 @@ export function obj_write() {
 
   const payload = generator.genPayload();
   const data = {
-    field: uuidv4(),
+    field : uuidv4(),
     // Because we use `file` wrapping and it is not straightforward to use
     // streams here,
     // `-e STREAMING=1` has no effect for this scenario.
-    file: http.file(payload.bytes(), 'random.data'),
+    file : http.file(payload.bytes(), 'random.data'),
   };
 
   const resp = http.post(`http://${http_endpoint}/upload/${container}`, data);
   if (resp.status != 200) {
-    log.withFields({status: resp.status, cid: container}).error(resp.error);
+    log.withFields({status : resp.status, cid : container}).error(resp.error);
     return;
   }
   const object_id = JSON.parse(resp.body).object_id;
@@ -137,7 +137,8 @@ export function obj_read() {
   const resp =
       http.get(`http://${http_endpoint}/get/${obj.container}/${obj.object}`);
   if (resp.status != 200) {
-    log.withFields({status: resp.status, cid: obj.container, oid: obj.object})
+    log.withFields(
+           {status : resp.status, cid : obj.container, oid : obj.object})
         .error(resp.error);
   }
 }

scenarios/local.js

@@ -12,13 +12,13 @@ import {uuidv4} from './libs/k6-utils-1.4.0.js';
 
 parseEnv();
 
-const obj_list = new SharedArray('obj_list', function() {
+const obj_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).objects;
+    'obj_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).objects; });
 
-const container_list = new SharedArray('container_list', function() {
+const container_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).containers;
+    'container_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).containers; });
 
 const read_size = JSON.parse(open(__ENV.PREGEN_JSON)).obj_size;
 const summary_json = __ENV.SUMMARY_JSON || '/tmp/summary.json';
@@ -31,7 +31,7 @@ const max_total_size_gb =
 const local_client =
     local.connect(config_file, config_dir, '', debug_logger, max_total_size_gb);
 const log = logging.new().withFields(
-    {'config_file': config_file, 'config_dir': config_dir});
+    {'config_file' : config_file, 'config_dir' : config_dir});
 
 const registry_enabled = !!__ENV.REGISTRY_FILE;
 const obj_registry =
@@ -49,8 +49,8 @@ if (registry_enabled && delete_age) {
   obj_to_delete_selector = registry.getSelector(
       __ENV.REGISTRY_FILE, 'obj_to_delete',
       __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-        status: 'created',
+        status : 'created',
-        age: delete_age,
+        age : delete_age,
       });
 }
 
@@ -60,22 +60,22 @@ const write_vu_count = parseInt(__ENV.WRITERS || '0');
 const generator = newGenerator(write_vu_count > 0);
 if (write_vu_count > 0) {
   scenarios.write = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: write_vu_count,
+    vus : write_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_write',
+    exec : 'obj_write',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
 const read_vu_count = parseInt(__ENV.READERS || '0');
 if (read_vu_count > 0) {
   scenarios.read = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: read_vu_count,
+    vus : read_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_read',
+    exec : 'obj_read',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
@@ -87,17 +87,17 @@ if (delete_vu_count > 0) {
   }
 
   scenarios.delete = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: delete_vu_count,
+    vus : delete_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_delete',
+    exec : 'obj_delete',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
 export const options = {
   scenarios,
-  setupTimeout: '5s',
+  setupTimeout : '5s',
 };
 
 export function setup() {
@@ -127,13 +127,13 @@ export function teardown(data) {
 
 export function handleSummary(data) {
   return {
-    'stdout': textSummary(data, {indent: ' ', enableColors: false}),
+    'stdout' : textSummary(data, {indent : ' ', enableColors : false}),
-    [summary_json]: JSON.stringify(data),
+    [summary_json] : JSON.stringify(data),
   };
 }
 
 export function obj_write() {
-  const headers = {unique_header: uuidv4()};
+  const headers = {unique_header : uuidv4()};
   const container =
       container_list[Math.floor(Math.random() * container_list.length)];
 
@@ -156,7 +156,7 @@ export function obj_read() {
   const obj = obj_list[Math.floor(Math.random() * obj_list.length)];
   const resp = local_client.get(obj.container, obj.object)
   if (!resp.success) {
-    log.withFields({cid: obj.container, oid: obj.object}).error(resp.error);
+    log.withFields({cid : obj.container, oid : obj.object}).error(resp.error);
   }
 }
 
@@ -169,7 +169,7 @@ export function obj_delete() {
   const resp = local_client.delete(obj.c_id, obj.o_id);
   if (!resp.success) {
     // Log errors except (2052 - object already deleted)
-    log.withFields({cid: obj.c_id, oid: obj.o_id}).error(resp.error);
+    log.withFields({cid : obj.c_id, oid : obj.o_id}).error(resp.error);
     return;
   }
 

scenarios/preset/helpers/aws_cli.py

@@ -15,7 +15,7 @@ def create_bucket(endpoint, versioning, location, acl, no_verify_ssl):
     cmd_line = f"aws {no_verify_ssl_str} s3api create-bucket --bucket {bucket_name} " \
                f"--endpoint {endpoint} {configuration} {acl} "
     cmd_line_ver = f"aws {no_verify_ssl_str} s3api put-bucket-versioning --bucket {bucket_name} " \
-                   f"--versioning-configuration Status=Enabled --endpoint {endpoint} {acl} "
+                   f"--versioning-configuration Status=Enabled --endpoint {endpoint}"
 
     output, success = execute_cmd(cmd_line)
 
@@ -25,7 +25,7 @@ def create_bucket(endpoint, versioning, location, acl, no_verify_ssl):
             f"Error: {output}", endpoint)
         return False
 
-    if versioning == "True":
+    if versioning:
         output, success = execute_cmd(cmd_line_ver)
         if not success:
             log(f"{cmd_line_ver}\n"

scenarios/preset/preset_s3.py

@@ -13,6 +13,7 @@ from helpers.aws_cli import create_bucket, upload_object
 
 ERROR_WRONG_CONTAINERS_COUNT = 1
 ERROR_WRONG_OBJECTS_COUNT = 2
+ERROR_WRONG_PERCENTAGE = 3
 MAX_WORKERS = 50
 DEFAULT_LOCATION = ""
 
@@ -26,7 +27,8 @@ parser.add_argument('--endpoint', help='S3 Gateways addresses separated by comma
 parser.add_argument('--update', help='True/False, False by default. Save existed buckets from target file (--out). '
                                      'New buckets will not be created.')
 parser.add_argument('--location', help=f'AWS location constraint. Default is "{DEFAULT_LOCATION}"', action="append")
-parser.add_argument('--versioning', help='True/False, False by default.')
+parser.add_argument('--versioning', help='True/False, False by default. Alias of --buckets_versioned=100')
+parser.add_argument('--buckets_versioned', help='Percent of versioned buckets. Default is 0', default=0)
 parser.add_argument('--ignore-errors', help='Ignore preset errors', action='store_true')
 parser.add_argument('--no-verify-ssl', help='Ignore SSL verifications', action='store_true')
 parser.add_argument('--workers', help='Count of workers in preset. Max = 50, Default = 50', default=50)
@@ -62,8 +64,17 @@ def main():
         print(f"Create buckets: {buckets_count}")
 
         with ProcessPoolExecutor(max_workers=min(MAX_WORKERS, workers)) as executor:
-            buckets_runs = [executor.submit(create_bucket, endpoint, args.versioning, location, args.acl, no_verify_ssl) 
+            if not 0 <= int(args.buckets_versioned) <= 100:
-                            for _, endpoint, location in 
+                print(f"Percent of versioned buckets must be between 0 and 100: got {args.buckets_versioned}")
+                if not ignore_errors:
+                    sys.exit(ERROR_WRONG_PERCENTAGE)
+            if args.versioning == "True":
+                versioning_per_bucket = [True] * buckets_count
+            else:
+                num_versioned_buckets = int((int(args.buckets_versioned) / 100) * buckets_count)
+                versioning_per_bucket = [True] * num_versioned_buckets + [False] * (buckets_count -  num_versioned_buckets)
+            buckets_runs = [executor.submit(create_bucket, endpoint, versioning_per_bucket[i], location, args.acl, no_verify_ssl)
+                            for i, endpoint, location in
                             zip(range(buckets_count), cycle(endpoints), cycle(args.location))]
 
         for run in buckets_runs:

scenarios/run_scenarios.md

@@ -125,7 +125,7 @@ The tests will use all pre-created buckets for PUT operations and all pre-create
 $ ./scenarios/preset/preset_s3.py --size 1024 --buckets 1 --out s3_1024kb.json --endpoint host1:8084 --preload_obj 500 --location load-1-4
 ```
   * '--location' - specify the name of container policy (from policy.json file). It's important to run 'aws configure' each time when the policy file has been changed to pick up the latest policies.
-
+  * '--buckets_versioned' - specify the percentage of versioned buckets from the total number of created buckets. Default is 0
 3. Execute scenario with options:
 
 ```shell

scenarios/s3.js

@@ -6,10 +6,10 @@ import registry from 'k6/x/frostfs/registry';
 import s3 from 'k6/x/frostfs/s3';
 import stats from 'k6/x/frostfs/stats';
 
-import {generateS3Key} from './libs/keygen.js';
+import {newGenerator} from './libs/datagen.js';
 import {parseEnv} from './libs/env-parser.js';
 import {textSummary} from './libs/k6-summary-0.0.2.js';
-import {newGenerator} from './libs/datagen.js';
+import {generateS3Key} from './libs/keygen.js';
 
 parseEnv();
 
@@ -133,7 +133,7 @@ export function setup() {
   console.log(
       `Load started at:               ${Date(start_timestamp).toString()}`)
 
-  if (delete_vu_count > 0){
+  if (delete_vu_count > 0) {
     obj_to_delete_selector.sync.add(delete_vu_count)
   }
 }

scenarios/s3_car.js

@@ -5,20 +5,20 @@ import registry from 'k6/x/frostfs/registry';
 import s3 from 'k6/x/frostfs/s3';
 import stats from 'k6/x/frostfs/stats';
 
-import {generateS3Key} from './libs/keygen.js';
 import {newGenerator} from './libs/datagen.js';
 import {parseEnv} from './libs/env-parser.js';
 import {textSummary} from './libs/k6-summary-0.0.2.js';
+import {generateS3Key} from './libs/keygen.js';
 
 parseEnv();
 
-const obj_list = new SharedArray('obj_list', function() {
+const obj_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).objects;
+    'obj_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).objects; });
 
-const bucket_list = new SharedArray('bucket_list', function() {
+const bucket_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).buckets;
+    'bucket_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).buckets; });
 
 const read_size = JSON.parse(open(__ENV.PREGEN_JSON)).obj_size;
 const summary_json = __ENV.SUMMARY_JSON || '/tmp/summary.json';
@@ -29,7 +29,7 @@ const s3_endpoint =
     s3_endpoints[Math.floor(Math.random() * s3_endpoints.length)];
 const no_verify_ssl = __ENV.NO_VERIFY_SSL || 'true';
 const connection_args = {
-  no_verify_ssl: no_verify_ssl
+  no_verify_ssl : no_verify_ssl
 };
 const s3_client = s3.connect(s3_endpoint, connection_args);
 const log = logging.new().withField('endpoint', s3_endpoint);
@@ -50,8 +50,8 @@ if (registry_enabled && delete_age) {
   obj_to_delete_selector = registry.getSelector(
       __ENV.REGISTRY_FILE, 'obj_to_delete',
       __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-        status: 'created',
+        status : 'created',
-        age: delete_age,
+        age : delete_age,
       });
 }
 
@@ -61,8 +61,8 @@ if (registry_enabled) {
   obj_to_read_selector = registry.getLoopedSelector(
       __ENV.REGISTRY_FILE, 'obj_to_read',
       __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-        status: 'created',
+        status : 'created',
-        age: read_age,
+        age : read_age,
       })
 }
 
@@ -75,35 +75,33 @@ const write_rate = parseInt(__ENV.WRITE_RATE || '0');
 const generator = newGenerator(write_rate > 0);
 if (write_rate > 0) {
   scenarios.write = {
-    executor: 'constant-arrival-rate',
+    executor : 'constant-arrival-rate',
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    preAllocatedVUs: pre_alloc_write_vus,
+    preAllocatedVUs : pre_alloc_write_vus,
-    maxVUs: max_write_vus,
+    maxVUs : max_write_vus,
-    rate: write_rate,
+    rate : write_rate,
-    timeUnit: time_unit,
+    timeUnit : time_unit,
-    exec: 'obj_write',
+    exec : 'obj_write',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
-
 const pre_alloc_read_vus = parseInt(__ENV.PRE_ALLOC_READERS || '0');
 const max_read_vus = parseInt(__ENV.MAX_READERS || pre_alloc_read_vus);
 const read_rate = parseInt(__ENV.READ_RATE || '0');
 if (read_rate > 0) {
   scenarios.read = {
-    executor: 'constant-arrival-rate',
+    executor : 'constant-arrival-rate',
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    preAllocatedVUs: pre_alloc_write_vus,
+    preAllocatedVUs : pre_alloc_write_vus,
-    maxVUs: max_read_vus,
+    maxVUs : max_read_vus,
-    rate: read_rate,
+    rate : read_rate,
-    timeUnit: time_unit,
+    timeUnit : time_unit,
-    exec: 'obj_read',
+    exec : 'obj_read',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
-
 const pre_alloc_delete_vus = parseInt(__ENV.PRE_ALLOC_DELETERS || '0');
 const max_delete_vus = parseInt(__ENV.MAX_DELETERS || pre_alloc_write_vus);
 const delete_rate = parseInt(__ENV.DELETE_RATE || '0');
@@ -114,20 +112,20 @@ if (delete_rate > 0) {
   }
 
   scenarios.delete = {
-    executor: 'constant-arrival-rate',
+    executor : 'constant-arrival-rate',
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    preAllocatedVUs: pre_alloc_delete_vus,
+    preAllocatedVUs : pre_alloc_delete_vus,
-    maxVUs: max_delete_vus,
+    maxVUs : max_delete_vus,
-    rate: delete_rate,
+    rate : delete_rate,
-    timeUnit: time_unit,
+    timeUnit : time_unit,
-    exec: 'obj_delete',
+    exec : 'obj_delete',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
 export const options = {
   scenarios,
-  setupTimeout: '5s',
+  setupTimeout : '5s',
 };
 
 export function setup() {
@@ -167,8 +165,8 @@ export function teardown(data) {
 
 export function handleSummary(data) {
   return {
-    'stdout': textSummary(data, {indent: ' ', enableColors: false}),
+    'stdout' : textSummary(data, {indent : ' ', enableColors : false}),
-    [summary_json]: JSON.stringify(data),
+    [summary_json] : JSON.stringify(data),
   };
 }
 
@@ -183,7 +181,7 @@ export function obj_write() {
   const payload = generator.genPayload();
   const resp = s3_client.put(bucket, key, payload);
   if (!resp.success) {
-    log.withFields({bucket: bucket, key: key}).error(resp.error);
+    log.withFields({bucket : bucket, key : key}).error(resp.error);
     return;
   }
 
@@ -204,7 +202,7 @@ export function obj_read() {
     }
     const resp = s3_client.get(obj.s3_bucket, obj.s3_key)
     if (!resp.success) {
-      log.withFields({bucket: obj.s3_bucket, key: obj.s3_key})
+      log.withFields({bucket : obj.s3_bucket, key : obj.s3_key})
           .error(resp.error);
     }
     return
@@ -214,7 +212,7 @@ export function obj_read() {
 
   const resp = s3_client.get(obj.bucket, obj.object);
   if (!resp.success) {
-    log.withFields({bucket: obj.bucket, key: obj.object}).error(resp.error);
+    log.withFields({bucket : obj.bucket, key : obj.object}).error(resp.error);
   }
 }
 
@@ -230,7 +228,7 @@ export function obj_delete() {
 
   const resp = s3_client.delete(obj.s3_bucket, obj.s3_key);
   if (!resp.success) {
-    log.withFields({bucket: obj.s3_bucket, key: obj.s3_key, op: 'DELETE'})
+    log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'DELETE'})
         .error(resp.error);
     return;
   }

scenarios/s3_dar.js

@@ -6,10 +6,10 @@ import registry from 'k6/x/frostfs/registry';
 import s3 from 'k6/x/frostfs/s3';
 import stats from 'k6/x/frostfs/stats';
 
-import {generateS3Key} from './libs/keygen.js';
 import {newGenerator} from './libs/datagen.js';
 import {parseEnv} from './libs/env-parser.js';
 import {textSummary} from './libs/k6-summary-0.0.2.js';
+import {generateS3Key} from './libs/keygen.js';
 
 parseEnv();
 
@@ -27,7 +27,7 @@ const summary_json = __ENV.SUMMARY_JSON || '/tmp/summary.json';
 const no_verify_ssl = __ENV.NO_VERIFY_SSL || 'true';
 
 const connection_args = {
-    no_verify_ssl : no_verify_ssl
+  no_verify_ssl : no_verify_ssl
 }
 // Select random S3 endpoint for current VU
 const s3_endpoints = __ENV.S3_ENDPOINTS.split(',');
@@ -43,18 +43,18 @@ const obj_registry =
 const duration = __ENV.DURATION;
 
 if (!!__ENV.METRIC_TAGS) {
-    stats.setTags(__ENV.METRIC_TAGS)
+  stats.setTags(__ENV.METRIC_TAGS)
 }
 
 const read_age = __ENV.READ_AGE ? parseInt(__ENV.READ_AGE) : 10;
 let obj_to_read_selector = undefined;
 if (registry_enabled) {
-    obj_to_read_selector = registry.getSelector(
+  obj_to_read_selector = registry.getSelector(
-        __ENV.REGISTRY_FILE, 'obj_to_read',
+      __ENV.REGISTRY_FILE, 'obj_to_read',
-        __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
+      __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-            status : 'created',
+        status : 'created',
-            age : read_age,
+        age : read_age,
-        })
+      })
 }
 
 const scenarios = {};
@@ -62,172 +62,176 @@ const scenarios = {};
 const write_vu_count = parseInt(__ENV.WRITERS || '0');
 const generator = newGenerator(write_vu_count > 0);
 if (write_vu_count > 0) {
-    scenarios.write = {
+  scenarios.write = {
-        executor : 'constant-vus',
+    executor : 'constant-vus',
-        vus : write_vu_count,
+    vus : write_vu_count,
-        duration : `${duration}s`,
+    duration : `${duration}s`,
-        exec : 'obj_write',
+    exec : 'obj_write',
-        gracefulStop : '5s',
+    gracefulStop : '5s',
-    };
+  };
 }
 
 const read_vu_count = parseInt(__ENV.READERS || '0');
 if (read_vu_count > 0) {
-    scenarios.read = {
+  scenarios.read = {
-        executor : 'constant-vus',
+    executor : 'constant-vus',
-        vus : read_vu_count,
+    vus : read_vu_count,
-        duration : `${duration}s`,
+    duration : `${duration}s`,
-        exec : 'obj_read',
+    exec : 'obj_read',
-        gracefulStop : '5s',
+    gracefulStop : '5s',
-    };
+  };
 }
 
 const delete_age = __ENV.DELETE_AGE ? parseInt(__ENV.DELETE_AGE) : undefined;
 let obj_to_delete_selector = undefined;
 let obj_to_delete_exit_on_null = undefined;
 
-if (registry_enabled ) {
+if (registry_enabled) {
-    obj_to_delete_exit_on_null = (write_vu_count == 0) && (read_vu_count == 0)
+  obj_to_delete_exit_on_null = (write_vu_count == 0) && (read_vu_count == 0)
 
-    let constructor = obj_to_delete_exit_on_null ? registry.getOneshotSelector
+  let constructor = obj_to_delete_exit_on_null ? registry.getOneshotSelector
-        : registry.getSelector;
+                                               : registry.getSelector;
 
-    obj_to_delete_selector =
+  obj_to_delete_selector =
-        constructor(__ENV.REGISTRY_FILE, 'obj_to_delete',
+      constructor(__ENV.REGISTRY_FILE, 'obj_to_delete',
-            __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
+                  __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-                status : 'read',
+                    status : 'read',
-                age : delete_age,
+                    age : delete_age,
-            });
+                  });
 }
 
-
-
 const delete_vu_count = parseInt(__ENV.DELETERS || '0');
 if (delete_vu_count > 0) {
-    if (!obj_to_delete_selector) {
+  if (!obj_to_delete_selector) {
-        throw 'Positive DELETE worker number without a proper object selector';
+    throw 'Positive DELETE worker number without a proper object selector';
-    }
+  }
 
-    scenarios.delete = {
+  scenarios.delete = {
-        executor : 'constant-vus',
+    executor : 'constant-vus',
-        vus : delete_vu_count,
+    vus : delete_vu_count,
-        duration : `${duration}s`,
+    duration : `${duration}s`,
-        exec : 'obj_delete',
+    exec : 'obj_delete',
-        gracefulStop : '5s',
+    gracefulStop : '5s',
-    };
+  };
 }
 
 export const options = {
-    scenarios,
+  scenarios,
-    setupTimeout : '5s',
+  setupTimeout : '5s',
 };
 
 export function setup() {
-    const total_vu_count = write_vu_count + read_vu_count + delete_vu_count;
+  const total_vu_count = write_vu_count + read_vu_count + delete_vu_count;
 
-    console.log(`Pregenerated buckets:          ${bucket_list.length}`);
+  console.log(`Pregenerated buckets:          ${bucket_list.length}`);
-    console.log(`Pregenerated read object size: ${read_size}`);
+  console.log(`Pregenerated read object size: ${read_size}`);
-    console.log(`Pregenerated total objects:    ${obj_list.length}`);
+  console.log(`Pregenerated total objects:    ${obj_list.length}`);
-    console.log(`Reading VUs:                   ${read_vu_count}`);
+  console.log(`Reading VUs:                   ${read_vu_count}`);
-    console.log(`Writing VUs:                   ${write_vu_count}`);
+  console.log(`Writing VUs:                   ${write_vu_count}`);
-    console.log(`Deleting VUs:                  ${delete_vu_count}`);
+  console.log(`Deleting VUs:                  ${delete_vu_count}`);
-    console.log(`Total VUs:                     ${total_vu_count}`);
+  console.log(`Total VUs:                     ${total_vu_count}`);
 
-    const start_timestamp = Date.now()
+  const start_timestamp = Date.now()
-    console.log(
+  console.log(
-        `Load started at:               ${Date(start_timestamp).toString()}`)
+      `Load started at:               ${Date(start_timestamp).toString()}`)
 }
 
 export function teardown(data) {
-    if (obj_registry) {
+  if (obj_registry) {
-        obj_registry.close();
+    obj_registry.close();
-    }
+  }
-    const end_timestamp = Date.now()
+  const end_timestamp = Date.now()
-    console.log(
+  console.log(
-        `Load finished at:              ${Date(end_timestamp).toString()}`)
+      `Load finished at:              ${Date(end_timestamp).toString()}`)
 }
 
 export function handleSummary(data) {
-    return {
+  return {
-        'stdout' : textSummary(data, {indent : ' ', enableColors : false}),
+    'stdout' : textSummary(data, {indent : ' ', enableColors : false}),
-        [summary_json] : JSON.stringify(data),
+    [summary_json] : JSON.stringify(data),
-    };
+  };
 }
 
 export function obj_write() {
-    if (__ENV.SLEEP_WRITE) {
+  if (__ENV.SLEEP_WRITE) {
-        sleep(__ENV.SLEEP_WRITE);
+    sleep(__ENV.SLEEP_WRITE);
-    }
+  }
 
-    const key = generateS3Key();
+  const key = generateS3Key();
-    const bucket = bucket_list[Math.floor(Math.random() * bucket_list.length)];
+  const bucket = bucket_list[Math.floor(Math.random() * bucket_list.length)];
 
-    const payload = generator.genPayload();
+  const payload = generator.genPayload();
-    const resp = s3_client.put(bucket, key, payload);
+  const resp = s3_client.put(bucket, key, payload);
-    if (!resp.success) {
+  if (!resp.success) {
-        log.withFields({bucket : bucket, key : key}).error(resp.error);
+    log.withFields({bucket : bucket, key : key}).error(resp.error);
-        return;
+    return;
-    }
+  }
 
-    if (obj_registry) {
+  if (obj_registry) {
-        obj_registry.addObject('', '', bucket, key, payload.hash());
+    obj_registry.addObject('', '', bucket, key, payload.hash());
-    }
+  }
 }
 
 export function obj_read() {
-    if (__ENV.SLEEP_READ) {
+  if (__ENV.SLEEP_READ) {
-        sleep(__ENV.SLEEP_READ);
+    sleep(__ENV.SLEEP_READ);
+  }
+
+  if (obj_to_read_selector) {
+    const obj = obj_to_read_selector.nextObject();
+    if (!obj) {
+      return;
     }
-
+    const resp = s3_client.get(obj.s3_bucket, obj.s3_key)
-    if (obj_to_read_selector) {
-        const obj = obj_to_read_selector.nextObject();
-        if (!obj  ) {
-            return;
-        }
-        const resp = s3_client.get(obj.s3_bucket, obj.s3_key)
-        if (!resp.success) {
-            log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, status: obj.status, op: `READ`})
-                .error(resp.error);
-        } else {
-            obj_registry.setObjectStatus(obj.id, obj.status, 'read');
-        }
-
-        return
-    }
-
-    const obj = obj_list[Math.floor(Math.random() * obj_list.length)];
-
-    const resp = s3_client.get(obj.bucket, obj.object);
     if (!resp.success) {
-        log.withFields({bucket : obj.bucket, key : obj.object}).error(resp.error);
+      log.withFields({
-    } else {
+           bucket : obj.s3_bucket,
-        obj_registry.setObjectStatus(obj.id, obj.status, 'read');
+           key : obj.s3_key,
+           status : obj.status,
+           op : `READ`
+         })
+          .error(resp.error);
     }
+    else {
+      obj_registry.setObjectStatus(obj.id, obj.status, 'read');
+    }
+
+    return
+  }
+
+  const obj = obj_list[Math.floor(Math.random() * obj_list.length)];
+
+  const resp = s3_client.get(obj.bucket, obj.object);
+  if (!resp.success) {
+    log.withFields({bucket : obj.bucket, key : obj.object}).error(resp.error);
+  } else {
+    obj_registry.setObjectStatus(obj.id, obj.status, 'read');
+  }
 }
 
 export function obj_delete() {
-    if (__ENV.SLEEP_DELETE) {
+  if (__ENV.SLEEP_DELETE) {
-        sleep(__ENV.SLEEP_DELETE);
+    sleep(__ENV.SLEEP_DELETE);
-    }
+  }
 
-    const obj = obj_to_delete_selector.nextObject();
+  const obj = obj_to_delete_selector.nextObject();
-    delete_object(obj)
+  delete_object(obj)
 }
 
 export function delete_object(obj) {
-    if (!obj) {
+  if (!obj) {
-        if (obj_to_delete_exit_on_null) {
+    if (obj_to_delete_exit_on_null) {
-            exec.test.abort("No more objects to select");
+      exec.test.abort("No more objects to select");
-        }
-        return;
     }
+    return;
+  }
 
-    const resp = s3_client.delete(obj.s3_bucket, obj.s3_key);
+  const resp = s3_client.delete(obj.s3_bucket, obj.s3_key);
-    if (!resp.success) {
+  if (!resp.success) {
-        log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'DELETE'})
+    log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'DELETE'})
-            .error(resp.error);
+        .error(resp.error);
-        return;
+    return;
-    }
+  }
 
-    obj_registry.deleteObject(obj.id);
+  obj_registry.deleteObject(obj.id);
 }

scenarios/s3_multipart.js

@@ -5,16 +5,16 @@ import registry from 'k6/x/frostfs/registry';
 import s3 from 'k6/x/frostfs/s3';
 import stats from 'k6/x/frostfs/stats';
 
-import {generateS3Key} from './libs/keygen.js';
 import {newGenerator} from './libs/datagen.js';
 import {parseEnv} from './libs/env-parser.js';
 import {textSummary} from './libs/k6-summary-0.0.2.js';
+import {generateS3Key} from './libs/keygen.js';
 
 parseEnv();
 
-const bucket_list = new SharedArray('bucket_list', function() {
+const bucket_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).buckets;
+    'bucket_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).buckets; });
 
 const summary_json = __ENV.SUMMARY_JSON || '/tmp/summary.json';
 
@@ -24,7 +24,7 @@ const s3_endpoint =
     s3_endpoints[Math.floor(Math.random() * s3_endpoints.length)];
 const no_verify_ssl = __ENV.NO_VERIFY_SSL || 'true';
 const connection_args = {
-  no_verify_ssl: no_verify_ssl
+  no_verify_ssl : no_verify_ssl
 };
 const s3_client = s3.connect(s3_endpoint, connection_args);
 const log = logging.new().withField('endpoint', s3_endpoint);
@@ -55,17 +55,17 @@ const generator =
     newGenerator(write_vu_count > 0 || write_multipart_vu_count > 0);
 if (write_vu_count > 0) {
   scenarios.write_multipart = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: write_vu_count,
+    vus : write_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_write_multipart',
+    exec : 'obj_write_multipart',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
 export const options = {
   scenarios,
-  setupTimeout: '5s',
+  setupTimeout : '5s',
 };
 
 export function setup() {
@@ -85,8 +85,8 @@ export function teardown(data) {
 
 export function handleSummary(data) {
   return {
-    'stdout': textSummary(data, {indent: ' ', enableColors: false}),
+    'stdout' : textSummary(data, {indent : ' ', enableColors : false}),
-    [summary_json]: JSON.stringify(data),
+    [summary_json] : JSON.stringify(data),
   };
 }
 
@@ -105,11 +105,10 @@ export function obj_write_multipart() {
   const bucket = bucket_list[Math.floor(Math.random() * bucket_list.length)];
 
   const payload = generator.genPayload();
-  const resp = s3_client.multipart(
+  const resp = s3_client.multipart(bucket, key, write_multipart_part_size,
-      bucket, key, write_multipart_part_size, write_multipart_vu_count,
+                                   write_multipart_vu_count, payload);
-      payload);
   if (!resp.success) {
-    log.withFields({bucket: bucket, key: key}).error(resp.error);
+    log.withFields({bucket : bucket, key : key}).error(resp.error);
     return;
   }
 

scenarios/s3local.js

@@ -5,25 +5,25 @@ import registry from 'k6/x/frostfs/registry';
 import s3local from 'k6/x/frostfs/s3local';
 import stats from 'k6/x/frostfs/stats';
 
-import {generateS3Key} from './libs/keygen.js';
 import {newGenerator} from './libs/datagen.js';
 import {parseEnv} from './libs/env-parser.js';
 import {textSummary} from './libs/k6-summary-0.0.2.js';
 import {uuidv4} from './libs/k6-utils-1.4.0.js';
+import {generateS3Key} from './libs/keygen.js';
 
 parseEnv();
 
-const obj_list = new SharedArray('obj_list', function() {
+const obj_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).objects;
+    'obj_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).objects; });
 
-const container_list = new SharedArray('container_list', function() {
+const container_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).containers;
+    'container_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).containers; });
 
-const bucket_list = new SharedArray('bucket_list', function() {
+const bucket_list = new SharedArray(
-  return JSON.parse(open(__ENV.PREGEN_JSON)).buckets;
+    'bucket_list',
-});
+    function() { return JSON.parse(open(__ENV.PREGEN_JSON)).buckets; });
 
 function bucket_mapping() {
   if (container_list.length != bucket_list.length) {
@@ -43,13 +43,12 @@ const config_file = __ENV.CONFIG_FILE;
 const config_dir = __ENV.CONFIG_DIR;
 const max_total_size_gb =
     __ENV.MAX_TOTAL_SIZE_GB ? parseInt(__ENV.MAX_TOTAL_SIZE_GB) : 0;
-const s3_client = s3local.connect(
+const s3_client = s3local.connect(config_file, config_dir, {
-    config_file, config_dir, {
+  'debug_logger' : __ENV.DEBUG_LOGGER || 'false',
-      'debug_logger': __ENV.DEBUG_LOGGER || 'false',
+},
-    },
+                                  bucket_mapping(), max_total_size_gb);
-    bucket_mapping(), max_total_size_gb);
 const log = logging.new().withFields(
-    {'config_file': config_file, 'config_dir': config_dir});
+    {'config_file' : config_file, 'config_dir' : config_dir});
 
 if (!!__ENV.METRIC_TAGS) {
   stats.setTags(__ENV.METRIC_TAGS)
@@ -64,7 +63,7 @@ if (registry_enabled) {
   obj_to_read_selector = registry.getLoopedSelector(
       __ENV.REGISTRY_FILE, 'obj_to_read',
       __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-        status: 'created',
+        status : 'created',
       })
 }
 
@@ -76,28 +75,28 @@ const write_vu_count = parseInt(__ENV.WRITERS || '0');
 const generator = newGenerator(write_vu_count > 0);
 if (write_vu_count > 0) {
   scenarios.write = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: write_vu_count,
+    vus : write_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_write',
+    exec : 'obj_write',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
 const read_vu_count = parseInt(__ENV.READERS || '0');
 if (read_vu_count > 0) {
   scenarios.read = {
-    executor: 'constant-vus',
+    executor : 'constant-vus',
-    vus: read_vu_count,
+    vus : read_vu_count,
-    duration: `${duration}s`,
+    duration : `${duration}s`,
-    exec: 'obj_read',
+    exec : 'obj_read',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   };
 }
 
 export const options = {
   scenarios,
-  setupTimeout: '5s',
+  setupTimeout : '5s',
 };
 
 export function setup() {
@@ -126,8 +125,8 @@ export function teardown(data) {
 
 export function handleSummary(data) {
   return {
-    'stdout': textSummary(data, {indent: ' ', enableColors: false}),
+    'stdout' : textSummary(data, {indent : ' ', enableColors : false}),
-    [summary_json]: JSON.stringify(data),
+    [summary_json] : JSON.stringify(data),
   };
 }
 
@@ -141,7 +140,7 @@ export function obj_write() {
     if (resp.abort) {
       exec.test.abort(resp.error);
     }
-    log.withFields({bucket: bucket, key: key}).error(resp.error);
+    log.withFields({bucket : bucket, key : key}).error(resp.error);
     return;
   }
 
@@ -158,7 +157,7 @@ export function obj_read() {
     }
     const resp = s3_client.get(obj.s3_bucket, obj.s3_key)
     if (!resp.success) {
-      log.withFields({bucket: obj.s3_bucket, key: obj.s3_key})
+      log.withFields({bucket : obj.s3_bucket, key : obj.s3_key})
           .error(resp.error);
     }
     return
@@ -168,6 +167,6 @@ export function obj_read() {
 
   const resp = s3_client.get(obj.bucket, obj.object);
   if (!resp.success) {
-    log.withFields({bucket: obj.bucket, key: obj.object}).error(resp.error);
+    log.withFields({bucket : obj.bucket, key : obj.object}).error(resp.error);
   }
 }

scenarios/verify.js

@@ -1,13 +1,13 @@
-import { sleep } from 'k6';
+import {sleep} from 'k6';
-import { Counter } from 'k6/metrics';
+import {Counter} from 'k6/metrics';
 import logging from 'k6/x/frostfs/logging';
 import native from 'k6/x/frostfs/native';
 import registry from 'k6/x/frostfs/registry';
 import s3 from 'k6/x/frostfs/s3';
 import stats from 'k6/x/frostfs/stats';
 
-import { parseEnv } from './libs/env-parser.js';
+import {parseEnv} from './libs/env-parser.js';
-import { textSummary } from './libs/k6-summary-0.0.2.js';
+import {textSummary} from './libs/k6-summary-0.0.2.js';
 
 parseEnv();
 
@@ -23,9 +23,9 @@ const summary_json = __ENV.SUMMARY_JSON || '/tmp/summary.json';
 // This allows to run this scenario multiple times and collect overall
 // statistics in the final run.
 const obj_counters = {
-  verified: new Counter('verified_obj'),
+  verified : new Counter('verified_obj'),
-  skipped: new Counter('skipped_obj'),
+  skipped : new Counter('skipped_obj'),
-  invalid: new Counter('invalid_obj'),
+  invalid : new Counter('invalid_obj'),
 };
 
 let log = logging.new();
@@ -39,23 +39,24 @@ let grpc_client = undefined;
 if (__ENV.GRPC_ENDPOINTS) {
   const grpcEndpoints = __ENV.GRPC_ENDPOINTS.split(',');
   const grpcEndpoint =
-    grpcEndpoints[Math.floor(Math.random() * grpcEndpoints.length)];
+      grpcEndpoints[Math.floor(Math.random() * grpcEndpoints.length)];
   log = log.withField('endpoint', grpcEndpoint);
   grpc_client = native.connect(
-    grpcEndpoint, '', __ENV.DIAL_TIMEOUT ? parseInt(__ENV.DIAL_TIMEOUT) : 0,
+      grpcEndpoint, '', __ENV.DIAL_TIMEOUT ? parseInt(__ENV.DIAL_TIMEOUT) : 0,
-    __ENV.STREAM_TIMEOUT ? parseInt(__ENV.STREAM_TIMEOUT) : 0,
+      __ENV.STREAM_TIMEOUT ? parseInt(__ENV.STREAM_TIMEOUT) : 0,
-    __ENV.PREPARE_LOCALLY ? __ENV.PREPARE_LOCALLY.toLowerCase() === 'true' : false,
+      __ENV.PREPARE_LOCALLY ? __ENV.PREPARE_LOCALLY.toLowerCase() === 'true'
-    1024 * parseInt(__ENV.MAX_OBJECT_SIZE || '0'));
+                            : false,
+      1024 * parseInt(__ENV.MAX_OBJECT_SIZE || '0'));
 }
 
 // Connect to random S3 endpoint
 let s3_client = undefined;
 if (__ENV.S3_ENDPOINTS) {
   const no_verify_ssl = __ENV.NO_VERIFY_SSL || 'true';
-  const connection_args = { no_verify_ssl: no_verify_ssl };
+  const connection_args = {no_verify_ssl : no_verify_ssl};
   const s3_endpoints = __ENV.S3_ENDPOINTS.split(',');
   const s3_endpoint =
-    s3_endpoints[Math.floor(Math.random() * s3_endpoints.length)];
+      s3_endpoints[Math.floor(Math.random() * s3_endpoints.length)];
   log = log.withField('endpoint', s3_endpoint);
   s3_client = s3.connect(s3_endpoint, connection_args);
 }
@@ -64,10 +65,10 @@ if (__ENV.S3_ENDPOINTS) {
 // execute as many iterations as there are objects. Each object will have 3
 // retries to be verified
 const obj_to_verify_selector = registry.getSelector(
-  __ENV.REGISTRY_FILE, 'obj_to_verify',
+    __ENV.REGISTRY_FILE, 'obj_to_verify',
-  __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
+    __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {
-  status: 'created',
+      status : 'created',
-});
+    });
 const obj_to_verify_count = obj_to_verify_selector.count();
 // Execute at least one iteration (executor shared-iterations can't run 0
 // iterations)
@@ -77,35 +78,35 @@ const iterations = Math.max(1, obj_to_verify_count);
 const vus = Math.min(__ENV.CLIENTS, iterations);
 
 const scenarios = {
-  verify: {
+  verify : {
-    executor: 'shared-iterations',
+    executor : 'shared-iterations',
     vus,
     iterations,
-    maxDuration: `${time_limit}s`,
+    maxDuration : `${time_limit}s`,
-    exec: 'obj_verify',
+    exec : 'obj_verify',
-    gracefulStop: '5s',
+    gracefulStop : '5s',
   }
 };
 
 export const options = {
   scenarios,
-  setupTimeout: '5s',
+  setupTimeout : '5s',
 };
 
 export function setup() {
   // Populate counters with initial values
   for (const [status, counter] of Object.entries(obj_counters)) {
     const obj_selector = registry.getSelector(
-      __ENV.REGISTRY_FILE, status,
+        __ENV.REGISTRY_FILE, status,
-      __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, { status });
+        __ENV.SELECTION_SIZE ? parseInt(__ENV.SELECTION_SIZE) : 0, {status});
     counter.add(obj_selector.count());
   }
 }
 
 export function handleSummary(data) {
   return {
-    'stdout': textSummary(data, { indent: ' ', enableColors: false }),
+    'stdout' : textSummary(data, {indent : ' ', enableColors : false}),
-    [summary_json]: JSON.stringify(data),
+    [summary_json] : JSON.stringify(data),
   };
 }
 
@@ -137,19 +138,19 @@ function verify_object_with_retries(obj, attempts) {
     // ReferenceError: Cannot access a variable before initialization.
     let lg = log;
     if (obj.c_id && obj.o_id) {
-      lg = lg.withFields({ cid: obj.c_id, oid: obj.o_id });
+      lg = lg.withFields({cid : obj.c_id, oid : obj.o_id});
       result = grpc_client.verifyHash(obj.c_id, obj.o_id, obj.payload_hash);
     } else if (obj.s3_bucket && obj.s3_key) {
-      lg = lg.withFields({ bucket: obj.s3_bucket, key: obj.s3_key });
+      lg = lg.withFields({bucket : obj.s3_bucket, key : obj.s3_key});
       result =
-        s3_client.verifyHash(obj.s3_bucket, obj.s3_key, obj.payload_hash);
+          s3_client.verifyHash(obj.s3_bucket, obj.s3_key, obj.payload_hash);
     } else {
       lg.withFields({
-        cid: obj.c_id,
+          cid : obj.c_id,
-        oid: obj.o_id,
+          oid : obj.o_id,
-        bucket: obj.s3_bucket,
+          bucket : obj.s3_bucket,
-        key: obj.s3_key
+          key : obj.s3_key
-      }).warn(`Object cannot be verified with supported protocols`);
+        }).warn(`Object cannot be verified with supported protocols`);
       return 'skipped';
     }