WIP [dbnode] Refactor posting list operations to be lazily evaluated and zero copy

.buildkite/pipeline.yml

@@ -51,7 +51,7 @@ steps:
         run: app
         workdir: /go/src/github.com/m3db/m3
     <<: *common
-  - name: "Integration (:docker:)"
+  - name: "Integration (:docker:, postings=default) %n"
     command: make clean install-vendor-m3 docker-integration-test
     parallelism: 2
     env:
@@ -61,6 +61,16 @@ steps:
         gopath-checkout#v1.0.1:
           import: github.com/m3db/m3
     <<: *common
+  - name: "Integration (:docker:, postings=read_only)  %n"
+    command: M3DB_READ_ONLY_POSTINGS=true make clean install-vendor-m3 docker-integration-test
+    parallelism: 2
+    env:
+      CGO_ENABLED: 0
+      GIMME_GO_VERSION: 1.13.x
+    plugins:
+        gopath-checkout#v1.0.1:
+          import: github.com/m3db/m3
+    <<: *common
   - name: "Prometheus compatibility (:docker:)"
     command: make clean install-vendor-m3 docker-compatibility-test
     parallelism: 1
@@ -71,17 +81,17 @@ steps:
         gopath-checkout#v1.0.1:
           import: github.com/m3db/m3
     <<: *common
-  - name: "Integration (dbnode Recently Read) %n"
+  - name: "Integration (dbnode cache=LRU postings=default) %n"
     parallelism: 2
-    command: make clean install-vendor-m3 test-ci-integration-dbnode cache_policy=recently_read
+    command: make clean install-vendor-m3 test-ci-integration-dbnode cache_policy=lru m3db_postings_ro=false
     plugins:
       docker-compose#v2.5.1:
         run: app
         workdir: /go/src/github.com/m3db/m3
     <<: *common
-  - name: "Integration (dbnode LRU) %n"
+  - name: "Integration (dbnode cache=LRU postings=read_only) %n"
     parallelism: 2
-    command: make clean install-vendor-m3 test-ci-integration-dbnode cache_policy=lru
+    command: make clean install-vendor-m3 test-ci-integration-dbnode cache_policy=lru m3db_postings_ro=true
     plugins:
       docker-compose#v2.5.1:
         run: app

Makefile

@@ -31,6 +31,7 @@ thrift_rules_dir     := generated/thrift
 vendor_prefix        := vendor
 cache_policy         ?= recently_read
 genny_target         ?= genny-all
+m3db_postings_ro     ?= false # Remove after MigrationReadOnlyPostings done
 
 BUILD                     := $(abspath ./bin)
 VENDOR                    := $(m3_package_path)/$(vendor_prefix)
@@ -256,8 +257,7 @@ SUBDIR_TARGETS := \
 	asset-gen       \
 	genny-gen       \
 	license-gen     \
-	all-gen         \
-	all-gen
+	all-gen         
 
 .PHONY: test-ci-unit
 test-ci-unit: test-base
@@ -359,7 +359,7 @@ test-ci-big-unit-$(SUBDIR):
 .PHONY: test-ci-integration-$(SUBDIR)
 test-ci-integration-$(SUBDIR):
 	@echo "--- test-ci-integration $(SUBDIR)"
-	SRC_ROOT=./src/$(SUBDIR) PANIC_ON_INVARIANT_VIOLATED=true INTEGRATION_TIMEOUT=10m TEST_SERIES_CACHE_POLICY=$(cache_policy) make test-base-ci-integration
+	SRC_ROOT=./src/$(SUBDIR) PANIC_ON_INVARIANT_VIOLATED=true INTEGRATION_TIMEOUT=10m TEST_SERIES_CACHE_POLICY=$(cache_policy) M3DB_READ_ONLY_POSTINGS=$(m3db_postings_ro) make test-base-ci-integration
 	@echo "--- uploading coverage report"
 	$(codecov_push) -f $(coverfile) -F $(SUBDIR)
 

go.mod

@@ -18,6 +18,7 @@ require (
 	github.com/cheekybits/genny v1.0.0 // indirect
 	github.com/containerd/continuity v0.0.0-20200413184840-d3ef23f19fbb // indirect
 	github.com/davecgh/go-spew v1.1.1
+	github.com/dgraph-io/ristretto v0.0.3
 	github.com/fortytw2/leaktest v1.2.1-0.20180901000122-b433bbd6d743
 	github.com/fossas/fossa-cli v1.0.30
 	github.com/garethr/kubeval v0.0.0-20180821130434-c44f5193dc94
@@ -55,7 +56,7 @@ require (
 	github.com/m3db/stackadler32 v0.0.0-20180104200216-bfebcd73ef6f
 	github.com/m3db/stackmurmur3/v2 v2.0.2
 	github.com/m3db/tools v0.0.0-20181008195521-c6ded3f34878
-	github.com/m3dbx/pilosa v1.4.1
+	github.com/m3dbx/pilosa v1.4.2-0.20201109081833-6c9df43642fd
 	github.com/m3dbx/vellum v0.0.0-20201119082309-5b47f7a70f69
 	github.com/mauricelam/genny v0.0.0-20180903214747-eb2c5232c885
 	github.com/mjibson/esc v0.1.0

go.sum

@@ -190,8 +190,11 @@ github.com/daviddengcn/go-villa v0.0.0-20160111144444-3f35da8ba982 h1:2Trx4ntMtx
 github.com/daviddengcn/go-villa v0.0.0-20160111144444-3f35da8ba982/go.mod h1:U8xNoHcXfPnZzy9zCxeKRjaJgC1d3613rFHjZVVAqKc=
 github.com/denis-tingajkin/go-header v0.3.1 h1:ymEpSiFjeItCy1FOP+x0M2KdCELdEAHUsNa8F+hHc6w=
 github.com/denis-tingajkin/go-header v0.3.1/go.mod h1:sq/2IxMhaZX+RRcgHfCRx/m0M5na0fBt4/CRe7Lrji0=
+github.com/dgraph-io/ristretto v0.0.3 h1:jh22xisGBjrEVnRZ1DVTpBVQm0Xndu8sMl0CWDzSIBI=
+github.com/dgraph-io/ristretto v0.0.3/go.mod h1:KPxhHT9ZxKefz+PCeOGsrHpl1qZ7i70dGTu2u+Ahh6E=
 github.com/dgrijalva/jwt-go v3.2.0+incompatible h1:7qlOGliEKZXTDg6OTjfoBKDXWrumCAMpl/TFQ4/5kLM=
 github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=
+github.com/dgryski/go-farm v0.0.0-20190423205320-6a90982ecee2/go.mod h1:SqUrOPUnsFjfmXRMNPybcSiG0BgUW2AuFH8PAnS2iTw=
 github.com/dgryski/go-sip13 v0.0.0-20181026042036-e10d5fee7954/go.mod h1:vAd38F8PWV+bWy6jNmig1y/TA+kYO4g3RSRF0IAv0no=
 github.com/dgryski/go-sip13 v0.0.0-20190329191031-25c5027a8c7b/go.mod h1:vAd38F8PWV+bWy6jNmig1y/TA+kYO4g3RSRF0IAv0no=
 github.com/docker/go-connections v0.4.0 h1:El9xVISelRB7BuFusrZozjnkIM5YnzCViNKohAFqRJQ=
@@ -650,8 +653,8 @@ github.com/m3db/thrift v0.0.0-20190820191926-05b5a2227fe4 h1:1x3mMuURd3wqKJ2qVjh
 github.com/m3db/thrift v0.0.0-20190820191926-05b5a2227fe4/go.mod h1:xVfRinGzD3cYDRvMjy6RkIwM+iNL2KHNLZjT0VpVZT8=
 github.com/m3db/tools v0.0.0-20181008195521-c6ded3f34878 h1:kww0LtVVfGrXR7Ofpbi/9bvc2EGYMQC0LCH/gQXoolE=
 github.com/m3db/tools v0.0.0-20181008195521-c6ded3f34878/go.mod h1:TxroQUZzb1wzOsq+4+TfVtT7z89YTz3v2UJAYfLNfLE=
-github.com/m3dbx/pilosa v1.4.1 h1:/Cpp1XAHSd6orpjceXGiKpCoDdYBP5BD/6NoqGG9eVg=
-github.com/m3dbx/pilosa v1.4.1/go.mod h1:Jt0+w9O08sa7qWDeRC58VBjb4OeOTDMOhfvVmyeVCO8=
+github.com/m3dbx/pilosa v1.4.2-0.20201109081833-6c9df43642fd h1:C+RCSMuplTpLH8Fiwb87XIkbYEabVf9itroR9+u4RYo=
+github.com/m3dbx/pilosa v1.4.2-0.20201109081833-6c9df43642fd/go.mod h1:Jt0+w9O08sa7qWDeRC58VBjb4OeOTDMOhfvVmyeVCO8=
 github.com/m3dbx/vellum v0.0.0-20201119082309-5b47f7a70f69 h1:dANuca0xuYlZR7qWdPIIAZKG0YHvsbLTzdenj53yQvc=
 github.com/m3dbx/vellum v0.0.0-20201119082309-5b47f7a70f69/go.mod h1:DOTAUfV4bzK6Nrb0dboT/oCG0DnQuX+/n0jfZPh6xxI=
 github.com/magiconair/properties v1.8.0/go.mod h1:PppfXfuXeibc/6YijjN8zIbojt8czPbwD3XqdrwzmxQ=
@@ -1197,6 +1200,7 @@ golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e h1:vcxGaoTs7kV8m5Np9uUNQin4
 golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20200625203802-6e8e738ad208 h1:qwRHBd0NqMbJxfbotnDhm2ByMI1Shq4Y6oRJo21SGJA=
 golang.org/x/sync v0.0.0-20200625203802-6e8e738ad208/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20210220032951-036812b2e83c h1:5KslGYwFpkhGh+Q16bwMP3cOontH8FOep7tGV86Y7SQ=
 golang.org/x/sys v0.0.0-20200826173525-f9321e4c35a6 h1:DvY3Zkh7KabQE/kfzMvYvKirSiguP9Q/veMtkYyf0o8=
 golang.org/x/sys v0.0.0-20200826173525-f9321e4c35a6/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/text v0.0.0-20160726164857-2910a502d2bf/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=

scripts/docker-integration-tests/aggregator/docker-compose.yml

@@ -12,6 +12,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   m3coordinator01:
     expose:
       - "7202"

scripts/docker-integration-tests/aggregator_legacy/docker-compose.yml

@@ -12,6 +12,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   m3coordinator01:
     expose:
       - "7202"

scripts/docker-integration-tests/carbon/docker-compose.yml

@@ -10,6 +10,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   coordinator01:
     expose:
       - "7201"

scripts/docker-integration-tests/cold_writes_simple/docker-compose.yml

@@ -10,6 +10,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   coordinator01:
     expose:
       - "7201"

scripts/docker-integration-tests/coordinator_config_rules/docker-compose.yml

@@ -10,6 +10,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   coordinator01:
     expose:
       - "7201"

scripts/docker-integration-tests/dedicated_etcd_embedded_coordinator/docker-compose.yml

@@ -12,6 +12,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=dbnode01
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode.yml:/etc/m3dbnode/m3dbnode.yml"
   etcd01:

scripts/docker-integration-tests/multi_cluster_write/docker-compose.yml

@@ -12,6 +12,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_a_m3db_local_1
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-a.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_a_dbnode02:
@@ -26,6 +27,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_a_m3db_local_2
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-a.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_a_coordinator01:
@@ -54,6 +56,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_b_m3db_local_1
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-b.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_b_dbnode02:
@@ -68,6 +71,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_b_m3db_local_2
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-b.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_b_coordinator01:

scripts/docker-integration-tests/prometheus/docker-compose.yml

@@ -10,6 +10,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   coordinator01:
     expose:
       - "7201"

scripts/docker-integration-tests/prometheus/test.sh

@@ -348,8 +348,10 @@ function test_query_restrict_tags {
 
   # First write some hidden metrics.
   echo "Test write with unaggregated metrics type works as expected"
-  TAG_NAME_0="restricted_metrics_type" TAG_VALUE_0="hidden" \
-    TAG_NAME_1="foo_tag" TAG_VALUE_1="foo_tag_value" \
+  TAG_NAME_0="__name__" TAG_VALUE_0="hidden_metric_by_default" \
+    TAG_NAME_1="restricted_metrics_type" TAG_VALUE_1="hidden" \
+    TAG_NAME_2="hidden_label_by_default" TAG_VALUE_2="hidden" \
+    TAG_NAME_3="foo_tag" TAG_VALUE_3="foo_tag_value" \
     prometheus_remote_write \
     some_hidden_metric now 42.42 \
     true "Expected request to succeed" \
@@ -366,6 +368,22 @@ function test_query_restrict_tags {
   echo "Test restrict by tags with coordinator defaults"
   ATTEMPTS=5 TIMEOUT=2 MAX_TIMEOUT=4 retry_with_backoff  \
     '[[ $(curl -s 0.0.0.0:7201/api/v1/query?query=\\{restricted_metrics_type=\"hidden\"\\} | jq -r ".data.result | length") -eq 0 ]]'
+
+  # Check we can see metric in label values endpoint with zero restrictions applied.
+  ATTEMPTS=5 TIMEOUT=2 MAX_TIMEOUT=4 retry_with_backoff  \
+    '[[ $(curl -s -H "M3-Restrict-By-Tags-JSON: {}" 0.0.0.0:7201/api/v1/label/__name__/values | jq ".data | map(select(. == \"hidden_metric_by_default\")) | length") -eq 1 ]]'
+
+  # Now check that without easing restrictions that we can see the label value in question.
+  ATTEMPTS=5 TIMEOUT=2 MAX_TIMEOUT=4 retry_with_backoff  \
+    '[[ $(curl -s 0.0.0.0:7201/api/v1/label/__name__/values | jq ".data | map(select(. == \"hidden_metric_by_default\")) | length") -eq 0 ]]'
+
+  # Check we can see metric in labels endpoint with zero restrictions applied.
+  ATTEMPTS=5 TIMEOUT=2 MAX_TIMEOUT=4 retry_with_backoff  \
+    '[[ $(curl -s -H "M3-Restrict-By-Tags-JSON: {}" 0.0.0.0:7201/api/v1/labels | jq ".data | map(select(. == \"hidden_label_by_default\")) | length") -eq 1 ]]'
+
+  # Now check that without easing restrictions that we can see the label in question.
+  ATTEMPTS=5 TIMEOUT=2 MAX_TIMEOUT=4 retry_with_backoff  \
+    '[[ $(curl -s 0.0.0.0:7201/api/v1/labels | jq ".data | map(select(. == \"hidden_label_by_default\")) | length") -eq 0 ]]'
 }
 
 function test_series {

scripts/docker-integration-tests/prometheus_replication/docker-compose.yml

@@ -10,6 +10,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   coordinator01:
     expose:
       - "7201"
@@ -32,6 +34,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   coordinator02:
     expose:
       - "17201"

scripts/docker-integration-tests/query_fanout/docker-compose.yml

@@ -10,6 +10,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   coordinator-cluster-a:
     expose:
       - "7201"
@@ -34,6 +36,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   coordinator-cluster-b:
     expose:
       - "7201"
@@ -58,6 +62,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   coordinator-cluster-c:
     expose:
       - "7201"

scripts/docker-integration-tests/repair/docker-compose.yml

@@ -12,6 +12,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=m3db_local_1
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode.yml:/etc/m3dbnode/m3dbnode.yml"
   dbnode02:
@@ -26,6 +27,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=m3db_local_2
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode.yml:/etc/m3dbnode/m3dbnode.yml"
   coordinator01:

scripts/docker-integration-tests/repair_and_replication/docker-compose.yml

@@ -12,6 +12,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_a_m3db_local_1
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-a.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_a_dbnode02:
@@ -26,6 +27,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_a_m3db_local_2
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-a.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_a_coordinator01:
@@ -54,6 +56,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_b_m3db_local_1
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-b.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_b_dbnode02:
@@ -68,6 +71,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_b_m3db_local_2
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-b.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_b_coordinator01:

scripts/docker-integration-tests/replication/docker-compose.yml

@@ -12,6 +12,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_a_m3db_local_1
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-a.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_a_dbnode02:
@@ -26,6 +27,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_a_m3db_local_2
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-a.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_a_coordinator01:
@@ -54,6 +56,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_b_m3db_local_1
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-b.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_b_dbnode02:
@@ -68,6 +71,7 @@ services:
     image: "m3dbnode_integration:${REVISION}"
     environment:
       - M3DB_HOST_ID=cluster_b_m3db_local_2
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
     volumes:
       - "./m3dbnode-cluster-b.yml:/etc/m3dbnode/m3dbnode.yml"
   cluster_b_coordinator01:

scripts/docker-integration-tests/simple_v2_batch_apis/docker-compose.yml

@@ -10,6 +10,8 @@ services:
     networks:
       - backend
     image: "m3dbnode_integration:${REVISION}"
+    environment:
+      - M3DB_READ_ONLY_POSTINGS # Remove after MigrationReadOnlyPostings done
   coordinator01:
     expose:
       - "7201"

src/aggregator/client/m3msg_client_test.go

@@ -21,7 +21,8 @@
 package client
 
 import (
-	"testing"
+	"os"
+	"strings"
 
 	"github.com/golang/mock/gomock"
 	"github.com/stretchr/testify/assert"