diff --git a/go.mod b/go.mod index 4aa9f27..be4d883 100644 --- a/go.mod +++ b/go.mod @@ -1,12 +1,13 @@ module github.com/grafana/xk6-redis -go 1.19 +go 1.20 require ( - github.com/dop251/goja v0.0.0-20230919151941-fc55792775de + github.com/dop251/goja v0.0.0-20240516125602-ccbae20bcec2 // indirect + github.com/grafana/sobek v0.0.0-20240606091932-2da0e9e5f3e7 github.com/redis/go-redis/v9 v9.0.5 - github.com/stretchr/testify v1.8.4 - go.k6.io/k6 v0.47.0 + github.com/stretchr/testify v1.9.0 + go.k6.io/k6 v0.51.1-0.20240606120708-bd114fdbd683 // To facilitate the integration of the extension in the k6 core codebase // we need to use the same version of the dependencies as k6. @@ -14,38 +15,50 @@ require ( ) require ( - github.com/andybalholm/brotli v1.0.5 // indirect + github.com/andybalholm/brotli v1.1.0 // indirect + github.com/cenkalti/backoff/v4 v4.2.1 // indirect github.com/cespare/xxhash/v2 v2.2.0 // indirect github.com/davecgh/go-spew v1.1.1 // indirect github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect github.com/dlclark/regexp2 v1.9.0 // indirect - github.com/fatih/color v1.15.0 // indirect - github.com/go-sourcemap/sourcemap v2.1.4-0.20211119122758-180fcef48034+incompatible // indirect - github.com/golang/protobuf v1.5.3 // indirect + github.com/evanw/esbuild v0.21.2 // indirect + github.com/fatih/color v1.16.0 // indirect + github.com/go-logr/logr v1.4.1 // indirect + github.com/go-logr/stdr v1.2.2 // indirect + github.com/go-sourcemap/sourcemap v2.1.4+incompatible // indirect github.com/google/pprof v0.0.0-20230728192033-2ba5b33183c6 // indirect - github.com/gorilla/websocket v1.5.0 // indirect + github.com/gorilla/websocket v1.5.1 // indirect + github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0 // indirect github.com/josharian/intern v1.0.0 // indirect - github.com/klauspost/compress v1.16.7 // indirect - github.com/kr/pretty v0.3.1 // indirect + github.com/klauspost/compress v1.17.7 // indirect github.com/mailru/easyjson v0.7.7 // indirect github.com/mattn/go-colorable v0.1.13 // indirect - github.com/mattn/go-isatty v0.0.19 // indirect + github.com/mattn/go-isatty v0.0.20 // indirect github.com/mccutchen/go-httpbin v1.1.2-0.20190116014521-c5cb2f4802fa // indirect github.com/mstoykov/atlas v0.0.0-20220811071828-388f114305dd // indirect + github.com/mstoykov/k6-taskqueue-lib v0.1.0 // indirect github.com/onsi/ginkgo v1.16.5 // indirect github.com/onsi/gomega v1.20.2 // indirect github.com/pmezard/go-difflib v1.0.0 // indirect - github.com/rogpeppe/go-internal v1.10.0 // indirect github.com/serenize/snaker v0.0.0-20201027110005-a7ad2135616e // indirect github.com/sirupsen/logrus v1.9.3 // indirect github.com/spf13/afero v1.1.2 // indirect - golang.org/x/crypto v0.12.0 // indirect - golang.org/x/net v0.14.0 // indirect - golang.org/x/sys v0.11.0 // indirect - golang.org/x/text v0.12.0 // indirect - golang.org/x/time v0.3.0 // indirect - google.golang.org/genproto/googleapis/rpc v0.0.0-20230731193218-e0aa005b6bdf // indirect - google.golang.org/grpc v1.57.0 // indirect - google.golang.org/protobuf v1.31.0 // indirect + go.opentelemetry.io/otel v1.24.0 // indirect + go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.24.0 // indirect + go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.24.0 // indirect + go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.24.0 // indirect + go.opentelemetry.io/otel/metric v1.24.0 // indirect + go.opentelemetry.io/otel/sdk v1.24.0 // indirect + go.opentelemetry.io/otel/trace v1.24.0 // indirect + go.opentelemetry.io/proto/otlp v1.1.0 // indirect + golang.org/x/crypto v0.21.0 // indirect + golang.org/x/net v0.23.0 // indirect + golang.org/x/sys v0.18.0 // indirect + golang.org/x/text v0.14.0 // indirect + golang.org/x/time v0.5.0 // indirect + google.golang.org/genproto/googleapis/api v0.0.0-20240227224415-6ceb2ff114de // indirect + google.golang.org/genproto/googleapis/rpc v0.0.0-20240227224415-6ceb2ff114de // indirect + google.golang.org/grpc v1.63.2 // indirect + google.golang.org/protobuf v1.33.0 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect ) diff --git a/go.sum b/go.sum index 5dc3c21..0c7b133 100644 --- a/go.sum +++ b/go.sum @@ -1,35 +1,34 @@ -github.com/andybalholm/brotli v1.0.5 h1:8uQZIdzKmjc/iuPu7O2ioW48L81FgatrcpfFmiq/cCs= -github.com/andybalholm/brotli v1.0.5/go.mod h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHGRSepvi9Eig= +github.com/andybalholm/brotli v1.1.0 h1:eLKJA0d02Lf0mVpIDgYnqXcUn0GqVmEFny3VuID1U3M= +github.com/andybalholm/brotli v1.1.0/go.mod h1:sms7XGricyQI9K10gOSf56VKKWS4oLer58Q+mhRPtnY= github.com/bsm/ginkgo/v2 v2.7.0 h1:ItPMPH90RbmZJt5GtkcNvIRuGEdwlBItdNVoyzaNQao= github.com/bsm/gomega v1.26.0 h1:LhQm+AFcgV2M0WyKroMASzAzCAJVpAxQXv4SaI9a69Y= +github.com/cenkalti/backoff/v4 v4.2.1 h1:y4OZtCnogmCPw98Zjyt5a6+QwPLGkiQsYW5oUqylYbM= +github.com/cenkalti/backoff/v4 v4.2.1/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyYozVcomhLiZE= github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44= github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= -github.com/chzyer/logex v1.2.0/go.mod h1:9+9sk7u7pGNWYMkh0hdiL++6OeibzJccyQU4p4MedaY= -github.com/chzyer/readline v1.5.0/go.mod h1:x22KAscuvRqlLoK9CsoYsmxoXZMMFVyOl86cAH8qUic= -github.com/chzyer/test v0.0.0-20210722231415-061457976a23/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU= -github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78= github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc= -github.com/dlclark/regexp2 v1.4.1-0.20201116162257-a2a8dda75c91/go.mod h1:2pZnwuY/m+8K6iRw6wQdMtk+rH5tNGR1i55kozfMjCc= -github.com/dlclark/regexp2 v1.7.0/go.mod h1:DHkYz0B9wPfa6wondMfaivmHpzrQ3v9q8cnmRbL6yW8= github.com/dlclark/regexp2 v1.9.0 h1:pTK/l/3qYIKaRXuHnEnIf7Y5NxfRPfpb7dis6/gdlVI= github.com/dlclark/regexp2 v1.9.0/go.mod h1:DHkYz0B9wPfa6wondMfaivmHpzrQ3v9q8cnmRbL6yW8= -github.com/dop251/goja v0.0.0-20211022113120-dc8c55024d06/go.mod h1:R9ET47fwRVRPZnOGvHxxhuZcbrMCuiqOz3Rlrh4KSnk= -github.com/dop251/goja v0.0.0-20230919151941-fc55792775de h1:lA38Xtzr1Wo+iQdkN2E11ziKXJYRxLlzK/e2/fdxoEI= -github.com/dop251/goja v0.0.0-20230919151941-fc55792775de/go.mod h1:QMWlm50DNe14hD7t24KEqZuUdC9sOTy8W6XbCU1mlw4= -github.com/dop251/goja_nodejs v0.0.0-20210225215109-d91c329300e7/go.mod h1:hn7BA7c8pLvoGndExHudxTDKZ84Pyvv+90pbBjbTz0Y= -github.com/dop251/goja_nodejs v0.0.0-20211022123610-8dd9abb0616d/go.mod h1:DngW8aVqWbuLRMHItjPUyqdj+HWPvnQe8V8y1nDpIbM= -github.com/fatih/color v1.15.0 h1:kOqh6YHBtK8aywxGerMG2Eq3H6Qgoqeo13Bk2Mv/nBs= -github.com/fatih/color v1.15.0/go.mod h1:0h5ZqXfHYED7Bhv2ZJamyIOUej9KtShiJESRwBDUSsw= +github.com/dop251/goja v0.0.0-20240516125602-ccbae20bcec2 h1:OFTHt+yJDo/uaIKMGjEKzc3DGhrpQZoqvMUIloZv6ZY= +github.com/dop251/goja v0.0.0-20240516125602-ccbae20bcec2/go.mod h1:o31y53rb/qiIAONF7w3FHJZRqqP3fzHUr1HqanthByw= +github.com/evanw/esbuild v0.21.2 h1:CLplcGi794CfHLVmUbvVfTMKkykm+nyIHU8SU60KUTA= +github.com/evanw/esbuild v0.21.2/go.mod h1:D2vIQZqV/vIf/VRHtViaUtViZmG7o+kKmlBfVQuRi48= +github.com/fatih/color v1.16.0 h1:zmkK9Ngbjj+K0yRhTVONQh1p/HknKYSlNT+vZCzyokM= +github.com/fatih/color v1.16.0/go.mod h1:fL2Sau1YI5c0pdGEVCbKQbLXB6edEj1ZgiY4NijnWvE= github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo= github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ= github.com/fsnotify/fsnotify v1.5.4 h1:jRbGcIw6P2Meqdwuo0H1p6JVLbL5DHKAKlYndzMwVZI= -github.com/go-sourcemap/sourcemap v2.1.3+incompatible/go.mod h1:F8jJfvm2KbVjc5NqelyYJmf/v5J0dwNLS2mL4sNA1Jg= -github.com/go-sourcemap/sourcemap v2.1.4-0.20211119122758-180fcef48034+incompatible h1:bopx7t9jyUNX1ebhr0G4gtQWmUOgwQRI0QsYhdYLgkU= -github.com/go-sourcemap/sourcemap v2.1.4-0.20211119122758-180fcef48034+incompatible/go.mod h1:F8jJfvm2KbVjc5NqelyYJmf/v5J0dwNLS2mL4sNA1Jg= +github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A= +github.com/go-logr/logr v1.4.1 h1:pKouT5E8xu9zeFC39JXRDukb6JFQPXM5p5I91188VAQ= +github.com/go-logr/logr v1.4.1/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY= +github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag= +github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE= +github.com/go-sourcemap/sourcemap v2.1.4+incompatible h1:a+iTbH5auLKxaNwQFg0B+TCYl6lbukKPc7b5x0n1s6Q= +github.com/go-sourcemap/sourcemap v2.1.4+incompatible/go.mod h1:F8jJfvm2KbVjc5NqelyYJmf/v5J0dwNLS2mL4sNA1Jg= github.com/go-task/slim-sprig v0.0.0-20210107165309-348f09dbbbc0/go.mod h1:fyg7847qk6SyHyPtNmDHnmrv/HOrqktSC+C9fM+CJOE= github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8= @@ -38,46 +37,39 @@ github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrU github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w= github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0= github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= -github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= -github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg= -github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= -github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= -github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/google/pprof v0.0.0-20230207041349-798e818bf904/go.mod h1:uglQLonpP8qtYCYyzA+8c/9qtqgA3qsXGYqCPKARAFg= +github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI= github.com/google/pprof v0.0.0-20230728192033-2ba5b33183c6 h1:ZgoomqkdjGbQ3+qQXCkvYMCDvGDNg2k5JJDjjdTB6jY= github.com/google/pprof v0.0.0-20230728192033-2ba5b33183c6/go.mod h1:Jh3hGz2jkYak8qXPD19ryItVnUgpgeqzdkY/D0EaeuA= -github.com/gorilla/websocket v1.5.0 h1:PPwGk2jz7EePpoHN/+ClbZu8SPxiqlu12wZP/3sWmnc= -github.com/gorilla/websocket v1.5.0/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE= +github.com/gorilla/websocket v1.5.1 h1:gmztn0JnHVt9JZquRuzLw3g4wouNVzKL15iLr/zn/QY= +github.com/gorilla/websocket v1.5.1/go.mod h1:x3kM2JMyaluk02fnUJpQuwD2dCS5NDG2ZHL0uE0tcaY= +github.com/grafana/sobek v0.0.0-20240606091932-2da0e9e5f3e7 h1:Ed0df3dkkPsjL0RKagJAv/821vrTBiB6GBk+198pxi4= +github.com/grafana/sobek v0.0.0-20240606091932-2da0e9e5f3e7/go.mod h1:6ZH0b0iOxyigeTh+/IlGoL0Hd3lVXA94xoXf0ldNgCM= +github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0 h1:Wqo399gCIufwto+VfwCSvsnfGpF/w5E9CNxSwbpD6No= +github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0/go.mod h1:qmOFXW2epJhM0qSnUUYpldc7gVz2KMQwJ/QYCDIa7XU= github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU= -github.com/ianlancetaylor/demangle v0.0.0-20220319035150-800ac71e25c2/go.mod h1:aYm2/VgdVmcIU8iMfdMvDMsRAQjcfZSKFby6HOFvi/w= github.com/josharian/intern v1.0.0 h1:vlS4z54oSdjm0bgjRigI+G1HpF+tI+9rE5LLzOg8HmY= github.com/josharian/intern v1.0.0/go.mod h1:5DoeVV0s6jJacbCEi61lwdGj/aVlrQvzHFFd8Hwg//Y= -github.com/klauspost/compress v1.16.7 h1:2mk3MPGNzKyxErAw8YaohYh69+pa4sIQSC0fPGCFR9I= -github.com/klauspost/compress v1.16.7/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE= -github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= -github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI= -github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk= +github.com/klauspost/compress v1.17.7 h1:ehO88t2UGzQK66LMdE8tibEd1ErmzZjNEqWkjLAKQQg= +github.com/klauspost/compress v1.17.7/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw= github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= -github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk= -github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= -github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= -github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= github.com/mailru/easyjson v0.7.7 h1:UGYAvKxe3sBsEDzO8ZeWOSlIQfWFlxbzLZe7hwFURr0= github.com/mailru/easyjson v0.7.7/go.mod h1:xzfreul335JAWq5oZzymOObrkdz5UnU4kGfJJLY9Nlc= github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA= github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg= github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM= -github.com/mattn/go-isatty v0.0.19 h1:JITubQf0MOLdlGRuRq+jtsDlekdYPia9ZFsB8h/APPA= -github.com/mattn/go-isatty v0.0.19/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= +github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY= +github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= github.com/mccutchen/go-httpbin v1.1.2-0.20190116014521-c5cb2f4802fa h1:lx8ZnNPwjkXSzOROz0cg69RlErRXs+L3eDkggASWKLo= github.com/mccutchen/go-httpbin v1.1.2-0.20190116014521-c5cb2f4802fa/go.mod h1:fhpOYavp5g2K74XDl/ao2y4KvhqVtKlkg1e+0UaQv7I= github.com/mstoykov/atlas v0.0.0-20220811071828-388f114305dd h1:AC3N94irbx2kWGA8f/2Ks7EQl2LxKIRQYuT9IJDwgiI= github.com/mstoykov/atlas v0.0.0-20220811071828-388f114305dd/go.mod h1:9vRHVuLCjoFfE3GT06X0spdOAO+Zzo4AMjdIwUHBvAk= -github.com/mstoykov/envconfig v1.4.1-0.20220114105314-765c6d8c76f1 h1:94EkGmhXrVUEal+uLwFUf4fMXPhZpM5tYxuIsxrCCbI= +github.com/mstoykov/envconfig v1.5.0 h1:E2FgWf73BQt0ddgn7aoITkQHmgwAcHup1s//MsS5/f8= +github.com/mstoykov/k6-taskqueue-lib v0.1.0 h1:M3eww1HSOLEN6rIkbNOJHhOVhlqnqkhYj7GTieiMBz4= +github.com/mstoykov/k6-taskqueue-lib v0.1.0/go.mod h1:PXdINulapvmzF545Auw++SCD69942FeNvUztaa9dVe4= github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A= github.com/nxadm/tail v1.4.8 h1:nPr65rt6Y5JFSKQO7qToXr7pePgD6Gwiw05lkbyAQTE= github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+AU= @@ -89,15 +81,11 @@ github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7J github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1ybHNo= github.com/onsi/gomega v1.20.2 h1:8uQq0zMgLEfa0vRrrBgaJF2gyW9Da9BmfGV+OyUzfkY= github.com/onsi/gomega v1.20.2/go.mod h1:iYAIXgPSaDHak0LCMA+AWBpIKBr8WZicMxnE8luStNc= -github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/redis/go-redis/v9 v9.0.5 h1:CuQcn5HIEeK7BgElubPP8CGtE0KakrnbBSTLjathl5o= github.com/redis/go-redis/v9 v9.0.5/go.mod h1:WqMKv5vnQbRuZstUwxQI195wHy+t4PuXDOjzMvcuQHk= -github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc= -github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs= github.com/rogpeppe/go-internal v1.10.0 h1:TMyTOH3F/DB16zRVcYyreMH6GnZZrwQVAoYjRBZyWFQ= -github.com/rogpeppe/go-internal v1.10.0/go.mod h1:UQnix2H7Ngw/k4C5ijL5+65zddjncjaFoBhdsK/akog= github.com/serenize/snaker v0.0.0-20201027110005-a7ad2135616e h1:zWKUYT07mGmVBH+9UgnHXd/ekCK99C8EbDSAt5qsjXE= github.com/serenize/snaker v0.0.0-20201027110005-a7ad2135616e/go.mod h1:Yow6lPLSAXx2ifx470yD/nUe22Dv5vBvxK/UK9UUTVs= github.com/sirupsen/logrus v1.9.3 h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ= @@ -107,33 +95,44 @@ github.com/spf13/afero v1.1.2/go.mod h1:j4pytiNVoe2o6bmDsKpLACNPDBIoEAkihy7loJ1B github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA= github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= -github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk= -github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo= +github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= +github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= -github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY= -go.k6.io/k6 v0.47.0 h1:o5rmxpFbdxzdL0xNqBtaGkHGzEnbnt8ixfBOxEGsHQY= -go.k6.io/k6 v0.47.0/go.mod h1:ulXsmMVRoCZzqV/ZgMeifJ9A484pKadqGT2sfR3eKQg= +go.k6.io/k6 v0.51.1-0.20240606120708-bd114fdbd683 h1:ockJVj41NNWzadyC3fvlSMRXT8QYxEzo13tVvE/WBEw= +go.k6.io/k6 v0.51.1-0.20240606120708-bd114fdbd683/go.mod h1:jKW0vrZjFqum5UGRPw/38ks4bYEywYuEo8vMccp/0Nc= +go.opentelemetry.io/otel v1.24.0 h1:0LAOdjNmQeSTzGBzduGe/rU4tZhMwL5rWgtp9Ku5Jfo= +go.opentelemetry.io/otel v1.24.0/go.mod h1:W7b9Ozg4nkF5tWI5zsXkaKKDjdVjpD4oAt9Qi/MArHo= +go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.24.0 h1:t6wl9SPayj+c7lEIFgm4ooDBZVb01IhLB4InpomhRw8= +go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.24.0/go.mod h1:iSDOcsnSA5INXzZtwaBPrKp/lWu/V14Dd+llD0oI2EA= +go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.24.0 h1:Mw5xcxMwlqoJd97vwPxA8isEaIoxsta9/Q51+TTJLGE= +go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.24.0/go.mod h1:CQNu9bj7o7mC6U7+CA/schKEYakYXWr79ucDHTMGhCM= +go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.24.0 h1:Xw8U6u2f8DK2XAkGRFV7BBLENgnTGX9i4rQRxJf+/vs= +go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.24.0/go.mod h1:6KW1Fm6R/s6Z3PGXwSJN2K4eT6wQB3vXX6CVnYX9NmM= +go.opentelemetry.io/otel/metric v1.24.0 h1:6EhoGWWK28x1fbpA4tYTOWBkPefTDQnb8WSGXlc88kI= +go.opentelemetry.io/otel/metric v1.24.0/go.mod h1:VYhLe1rFfxuTXLgj4CBiyz+9WYBA8pNGJgDcSFRKBco= +go.opentelemetry.io/otel/sdk v1.24.0 h1:YMPPDNymmQN3ZgczicBY3B6sf9n62Dlj9pWD3ucgoDw= +go.opentelemetry.io/otel/sdk v1.24.0/go.mod h1:KVrIYw6tEubO9E96HQpcmpTKDVn9gdv35HoYiQWGDFg= +go.opentelemetry.io/otel/trace v1.24.0 h1:CsKnnL4dUAr/0llH9FKuc698G04IrpWV0MQA/Y1YELI= +go.opentelemetry.io/otel/trace v1.24.0/go.mod h1:HPc3Xr/cOApsBI154IU0OI0HJexz+aw5uPdbs3UCjNU= +go.opentelemetry.io/proto/otlp v1.1.0 h1:2Di21piLrCqJ3U3eXGCTPHE9R8Nh+0uglSnOyxikMeI= +go.opentelemetry.io/proto/otlp v1.1.0/go.mod h1:GpBHCBWiqvVLDqmHZsoMM3C5ySeKTC7ej/RNTae6MdY= +go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= -golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= -golang.org/x/crypto v0.12.0 h1:tFM/ta59kqch6LlvYnPa0yx5a83cL2nHflFhYKvv9Yk= -golang.org/x/crypto v0.12.0/go.mod h1:NF0Gs7EO5K4qLn+Ylc+fih8BSTeIjAP05siRnAh98yw= +golang.org/x/crypto v0.21.0 h1:X31++rzVUdKhX5sWmSOFZxx8UW/ldWx55cbf08iNAMA= +golang.org/x/crypto v0.21.0/go.mod h1:0BP7YvVV9gBbVKyeTG0Gyn+gZm94bibOW5BjDEYAOMs= golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= -golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4= golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20200520004742-59133d7f0dd7/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A= golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= -golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= -golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c= -golang.org/x/net v0.14.0 h1:BONx9s002vGdD9umnlX1Po8vOZmrgH34qlHcD1MfK14= -golang.org/x/net v0.14.0/go.mod h1:PpSgVXXLK0OxS0F31C1/tv6XNguvCrnXIDrFMspZIUI= +golang.org/x/net v0.23.0 h1:7EYJ93RZ9vYSZAIb2x3lnuvqO5zneoD6IvWjuhfxjTs= +golang.org/x/net v0.23.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg= golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= @@ -142,55 +141,42 @@ golang.org/x/sys v0.0.0-20191005200804-aed5e4c7ecf9/go.mod h1:h1NjWce9XRLGQEsW7w golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210112080510-489259a85091/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.0.0-20220310020820-b874c991c1a5/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.11.0 h1:eG7RXZHdqOJ1i+0lgLgCpSXAp6M3LYlAo6osgSi0xOM= -golang.org/x/sys v0.11.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= -golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= +golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4= +golang.org/x/sys v0.18.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= -golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= -golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= -golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ= -golang.org/x/text v0.12.0 h1:k+n5B8goJNdU7hSvEtMUz3d1Q6D/XW4COJSJR6fN0mc= -golang.org/x/text v0.12.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE= -golang.org/x/time v0.3.0 h1:rg5rLMjNzMS1RkNLzCG38eapWhnYLFYXDXj2gOlr8j4= -golang.org/x/time v0.3.0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= +golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ= +golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= +golang.org/x/time v0.5.0 h1:o7cqy6amK/52YcAKIPlM3a+Fpj35zvRj2TP+e1xFSfk= +golang.org/x/time v0.5.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM= golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= golang.org/x/tools v0.0.0-20201224043029-2b0845dc783e/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= -golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -google.golang.org/genproto/googleapis/rpc v0.0.0-20230731193218-e0aa005b6bdf h1:guOdSPaeFgN+jEJwTo1dQ71hdBm+yKSCCKuTRkJzcVo= -google.golang.org/genproto/googleapis/rpc v0.0.0-20230731193218-e0aa005b6bdf/go.mod h1:zBEcrKX2ZOcEkHWxBPAIvYUWOKKMIhYcmNiUIu2ji3I= -google.golang.org/grpc v1.57.0 h1:kfzNeI/klCGD2YPMUlaGNT3pxvYfga7smW3Vth8Zsiw= -google.golang.org/grpc v1.57.0/go.mod h1:Sd+9RMTACXwmub0zcNY2c4arhtrbBYD1AUHI/dt16Mo= +google.golang.org/genproto v0.0.0-20240227224415-6ceb2ff114de h1:F6qOa9AZTYJXOUEr4jDysRDLrm4PHePlge4v4TGAlxY= +google.golang.org/genproto/googleapis/api v0.0.0-20240227224415-6ceb2ff114de h1:jFNzHPIeuzhdRwVhbZdiym9q0ory/xY3sA+v2wPg8I0= +google.golang.org/genproto/googleapis/api v0.0.0-20240227224415-6ceb2ff114de/go.mod h1:5iCWqnniDlqZHrd3neWVTOwvh/v6s3232omMecelax8= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240227224415-6ceb2ff114de h1:cZGRis4/ot9uVm639a+rHCUaG0JJHEsdyzSQTMX+suY= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240227224415-6ceb2ff114de/go.mod h1:H4O17MA/PE9BsGx3w+a+W2VOLLD1Qf7oJneAoU6WktY= +google.golang.org/grpc v1.63.2 h1:MUeiw1B2maTVZthpU5xvASfTh3LDbxHd6IJ6QQVU+xM= +google.golang.org/grpc v1.63.2/go.mod h1:WAX/8DgncnokcFUldAxq7GeB5DXHDbMF+lLvDomNkRA= google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8= google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0= google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM= google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE= google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo= google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= -google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= -google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= -google.golang.org/protobuf v1.31.0 h1:g0LDEJHgrBl9N9r17Ru3sqWhkIx2NB67okBHPwC7hs8= -google.golang.org/protobuf v1.31.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I= +google.golang.org/protobuf v1.33.0 h1:uNO2rsAINq/JlFpSdYEKIZ0uKD/R9cpdv0T+yoGwGmI= +google.golang.org/protobuf v1.33.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= -gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk= -gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q= -gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI= gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys= gopkg.in/guregu/null.v3 v3.3.0 h1:8j3ggqq+NgKt/O7mbFVUFKUMWN+l1AmT5jQmJ6nPh2c= gopkg.in/guregu/null.v3 v3.3.0/go.mod h1:E4tX2Qe3h7QdL+uZ3a0vqvYwKQsRSQKM5V4YltdgH9Y= @@ -200,7 +186,6 @@ gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY= -gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ= gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/redis/client.go b/redis/client.go index ebc1d68..d60878c 100644 --- a/redis/client.go +++ b/redis/client.go @@ -7,7 +7,7 @@ import ( "net" "time" - "github.com/dop251/goja" + "github.com/grafana/sobek" "github.com/redis/go-redis/v9" "go.k6.io/k6/js/common" "go.k6.io/k6/js/modules" @@ -27,7 +27,7 @@ type Client struct { // If the provided value is not a supported type, the promise is rejected with an error. // // The value for `expiration` is interpreted as seconds. -func (c *Client) Set(key string, value interface{}, expiration int) *goja.Promise { +func (c *Client) Set(key string, value interface{}, expiration int) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -58,7 +58,7 @@ func (c *Client) Set(key string, value interface{}, expiration int) *goja.Promis // If the key does not exist, the promise is rejected with an error. // // If the key does not exist, the promise is rejected with an error. -func (c *Client) Get(key string) *goja.Promise { +func (c *Client) Get(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -82,7 +82,7 @@ func (c *Client) Get(key string) *goja.Promise { // GetSet sets the value of key to value and returns the old value stored // // If the provided value is not a supported type, the promise is rejected with an error. -func (c *Client) GetSet(key string, value interface{}) *goja.Promise { +func (c *Client) GetSet(key string, value interface{}) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -109,7 +109,7 @@ func (c *Client) GetSet(key string, value interface{}) *goja.Promise { } // Del removes the specified keys. A key is ignored if it does not exist -func (c *Client) Del(keys ...string) *goja.Promise { +func (c *Client) Del(keys ...string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -133,7 +133,7 @@ func (c *Client) Del(keys ...string) *goja.Promise { // GetDel gets the value of key and deletes the key. // // If the key does not exist, the promise is rejected with an error. -func (c *Client) GetDel(key string) *goja.Promise { +func (c *Client) GetDel(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -157,7 +157,7 @@ func (c *Client) GetDel(key string) *goja.Promise { // Exists returns the number of key arguments that exist. // Note that if the same existing key is mentioned in the argument // multiple times, it will be counted multiple times. -func (c *Client) Exists(keys ...string) *goja.Promise { +func (c *Client) Exists(keys ...string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -182,7 +182,7 @@ func (c *Client) Exists(keys ...string) *goja.Promise { // not exist, it is set to zero before performing the operation. An // error is returned if the key contains a value of the wrong type, or // contains a string that cannot be represented as an integer. -func (c *Client) Incr(key string) *goja.Promise { +func (c *Client) Incr(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -207,7 +207,7 @@ func (c *Client) Incr(key string) *goja.Promise { // not exist, it is set to zero before performing the operation. An // error is returned if the key contains a value of the wrong type, or // contains a string that cannot be represented as an integer. -func (c *Client) IncrBy(key string, increment int64) *goja.Promise { +func (c *Client) IncrBy(key string, increment int64) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -232,7 +232,7 @@ func (c *Client) IncrBy(key string, increment int64) *goja.Promise { // not exist, it is set to zero before performing the operation. An // error is returned if the key contains a value of the wrong type, or // contains a string that cannot be represented as an integer. -func (c *Client) Decr(key string) *goja.Promise { +func (c *Client) Decr(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -257,7 +257,7 @@ func (c *Client) Decr(key string) *goja.Promise { // not exist, it is set to zero before performing the operation. An // error is returned if the key contains a value of the wrong type, or // contains a string that cannot be represented as an integer. -func (c *Client) DecrBy(key string, decrement int64) *goja.Promise { +func (c *Client) DecrBy(key string, decrement int64) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -281,7 +281,7 @@ func (c *Client) DecrBy(key string, decrement int64) *goja.Promise { // RandomKey returns a random key. // // If the database is empty, the promise is rejected with an error. -func (c *Client) RandomKey() *goja.Promise { +func (c *Client) RandomKey() *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -303,7 +303,7 @@ func (c *Client) RandomKey() *goja.Promise { } // Mget returns the values associated with the specified keys. -func (c *Client) Mget(keys ...string) *goja.Promise { +func (c *Client) Mget(keys ...string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -328,7 +328,7 @@ func (c *Client) Mget(keys ...string) *goja.Promise { // be deleted. // Note that calling Expire with a non-positive timeout will result in // the key being deleted rather than expired. -func (c *Client) Expire(key string, seconds int) *goja.Promise { +func (c *Client) Expire(key string, seconds int) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -352,7 +352,7 @@ func (c *Client) Expire(key string, seconds int) *goja.Promise { // Ttl returns the remaining time to live of a key that has a timeout. // //nolint:revive,stylecheck -func (c *Client) Ttl(key string) *goja.Promise { +func (c *Client) Ttl(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -374,7 +374,7 @@ func (c *Client) Ttl(key string) *goja.Promise { } // Persist removes the existing timeout on key. -func (c *Client) Persist(key string) *goja.Promise { +func (c *Client) Persist(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -399,7 +399,7 @@ func (c *Client) Persist(key string) *goja.Promise { // at `key`. If `key` does not exist, it is created as empty list before // performing the push operations. When `key` holds a value that is not // a list, and error is returned. -func (c *Client) Lpush(key string, values ...interface{}) *goja.Promise { +func (c *Client) Lpush(key string, values ...interface{}) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -428,7 +428,7 @@ func (c *Client) Lpush(key string, values ...interface{}) *goja.Promise { // Rpush inserts all the specified values at the tail of the list stored // at `key`. If `key` does not exist, it is created as empty list before // performing the push operations. -func (c *Client) Rpush(key string, values ...interface{}) *goja.Promise { +func (c *Client) Rpush(key string, values ...interface{}) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -457,7 +457,7 @@ func (c *Client) Rpush(key string, values ...interface{}) *goja.Promise { // Lpop removes and returns the first element of the list stored at `key`. // // If the list does not exist, this command rejects the promise with an error. -func (c *Client) Lpop(key string) *goja.Promise { +func (c *Client) Lpop(key string) *sobek.Promise { // TODO: redis supports indicating the amount of values to pop promise, resolve, reject := c.makeHandledPromise() @@ -482,7 +482,7 @@ func (c *Client) Lpop(key string) *goja.Promise { // Rpop removes and returns the last element of the list stored at `key`. // // If the list does not exist, this command rejects the promise with an error. -func (c *Client) Rpop(key string) *goja.Promise { +func (c *Client) Rpop(key string) *sobek.Promise { // TODO: redis supports indicating the amount of values to pop promise, resolve, reject := c.makeHandledPromise() @@ -508,7 +508,7 @@ func (c *Client) Rpop(key string) *goja.Promise { // offsets start and stop are zero-based indexes. These offsets can be // negative numbers, where they indicate offsets starting at the end of // the list. -func (c *Client) Lrange(key string, start, stop int64) *goja.Promise { +func (c *Client) Lrange(key string, start, stop int64) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -534,7 +534,7 @@ func (c *Client) Lrange(key string, start, stop int64) *goja.Promise { // elements starting at the tail of the list. // // If the list does not exist, this command rejects the promise with an error. -func (c *Client) Lindex(key string, index int64) *goja.Promise { +func (c *Client) Lindex(key string, index int64) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -558,7 +558,7 @@ func (c *Client) Lindex(key string, index int64) *goja.Promise { // Lset sets the list element at `index` to `element`. // // If the list does not exist, this command rejects the promise with an error. -func (c *Client) Lset(key string, index int64, element string) *goja.Promise { +func (c *Client) Lset(key string, index int64, element string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -585,7 +585,7 @@ func (c *Client) Lset(key string, index int64, element string) *goja.Promise { // If `count` is zero, all elements matching `value` are removed. // // If the list does not exist, this command rejects the promise with an error. -func (c *Client) Lrem(key string, count int64, value string) *goja.Promise { +func (c *Client) Lrem(key string, count int64, value string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -610,7 +610,7 @@ func (c *Client) Lrem(key string, count int64, value string) *goja.Promise { // does not exist, it is interpreted as an empty list and 0 is returned. // // If the list does not exist, this command rejects the promise with an error. -func (c *Client) Llen(key string) *goja.Promise { +func (c *Client) Llen(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -636,7 +636,7 @@ func (c *Client) Llen(key string) *goja.Promise { // If `field` already exists in the hash, it is overwritten. // // If the hash does not exist, this command rejects the promise with an error. -func (c *Client) Hset(key string, field string, value interface{}) *goja.Promise { +func (c *Client) Hset(key string, field string, value interface{}) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -666,7 +666,7 @@ func (c *Client) Hset(key string, field string, value interface{}) *goja.Promise // only if `field` does not yet exist. If `key` does not exist, a new key // holding a hash is created. If `field` already exists, this operation // has no effect. -func (c *Client) Hsetnx(key, field, value string) *goja.Promise { +func (c *Client) Hsetnx(key, field, value string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -690,7 +690,7 @@ func (c *Client) Hsetnx(key, field, value string) *goja.Promise { // Hget returns the value associated with `field` in the hash stored at `key`. // // If the hash does not exist, this command rejects the promise with an error. -func (c *Client) Hget(key, field string) *goja.Promise { +func (c *Client) Hget(key, field string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -712,7 +712,7 @@ func (c *Client) Hget(key, field string) *goja.Promise { } // Hdel deletes the specified fields from the hash stored at `key`. -func (c *Client) Hdel(key string, fields ...string) *goja.Promise { +func (c *Client) Hdel(key string, fields ...string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -736,7 +736,7 @@ func (c *Client) Hdel(key string, fields ...string) *goja.Promise { // Hgetall returns all fields and values of the hash stored at `key`. // // If the hash does not exist, this command rejects the promise with an error. -func (c *Client) Hgetall(key string) *goja.Promise { +func (c *Client) Hgetall(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -760,7 +760,7 @@ func (c *Client) Hgetall(key string) *goja.Promise { // Hkeys returns all fields of the hash stored at `key`. // // If the hash does not exist, this command rejects the promise with an error. -func (c *Client) Hkeys(key string) *goja.Promise { +func (c *Client) Hkeys(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -784,7 +784,7 @@ func (c *Client) Hkeys(key string) *goja.Promise { // Hvals returns all values of the hash stored at `key`. // // If the hash does not exist, this command rejects the promise with an error. -func (c *Client) Hvals(key string) *goja.Promise { +func (c *Client) Hvals(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -808,7 +808,7 @@ func (c *Client) Hvals(key string) *goja.Promise { // Hlen returns the number of fields in the hash stored at `key`. // // If the hash does not exist, this command rejects the promise with an error. -func (c *Client) Hlen(key string) *goja.Promise { +func (c *Client) Hlen(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -833,7 +833,7 @@ func (c *Client) Hlen(key string) *goja.Promise { // by `increment`. If `key` does not exist, a new key holding a hash is created. // If `field` does not exist the value is set to 0 before the operation is // set to 0 before the operation is performed. -func (c *Client) Hincrby(key, field string, increment int64) *goja.Promise { +func (c *Client) Hincrby(key, field string, increment int64) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -857,7 +857,7 @@ func (c *Client) Hincrby(key, field string, increment int64) *goja.Promise { // Sadd adds the specified members to the set stored at key. // Specified members that are already a member of this set are ignored. // If key does not exist, a new set is created before adding the specified members. -func (c *Client) Sadd(key string, members ...interface{}) *goja.Promise { +func (c *Client) Sadd(key string, members ...interface{}) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -886,7 +886,7 @@ func (c *Client) Sadd(key string, members ...interface{}) *goja.Promise { // Srem removes the specified members from the set stored at key. // Specified members that are not a member of this set are ignored. // If key does not exist, it is treated as an empty set and this command returns 0. -func (c *Client) Srem(key string, members ...interface{}) *goja.Promise { +func (c *Client) Srem(key string, members ...interface{}) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -913,7 +913,7 @@ func (c *Client) Srem(key string, members ...interface{}) *goja.Promise { } // Sismember returns if member is a member of the set stored at key. -func (c *Client) Sismember(key string, member interface{}) *goja.Promise { +func (c *Client) Sismember(key string, member interface{}) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -940,7 +940,7 @@ func (c *Client) Sismember(key string, member interface{}) *goja.Promise { } // Smembers returns all members of the set stored at key. -func (c *Client) Smembers(key string) *goja.Promise { +func (c *Client) Smembers(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -964,7 +964,7 @@ func (c *Client) Smembers(key string) *goja.Promise { // Srandmember returns a random element from the set value stored at key. // // If the set does not exist, the promise is rejected with an error. -func (c *Client) Srandmember(key string) *goja.Promise { +func (c *Client) Srandmember(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -988,7 +988,7 @@ func (c *Client) Srandmember(key string) *goja.Promise { // Spop removes and returns a random element from the set value stored at key. // // If the set does not exist, the promise is rejected with an error. -func (c *Client) Spop(key string) *goja.Promise { +func (c *Client) Spop(key string) *sobek.Promise { promise, resolve, reject := c.makeHandledPromise() if err := c.connect(); err != nil { @@ -1010,7 +1010,7 @@ func (c *Client) Spop(key string) *goja.Promise { } // SendCommand sends a command to the redis server. -func (c *Client) SendCommand(command string, args ...interface{}) *goja.Promise { +func (c *Client) SendCommand(command string, args ...interface{}) *sobek.Promise { var doArgs []interface{} doArgs = append(doArgs, command) doArgs = append(doArgs, args...) @@ -1043,7 +1043,7 @@ func (c *Client) SendCommand(command string, args ...interface{}) *goja.Promise // makeHandledPromise will create a promise and return its resolve and reject methods, // wrapped in such a way that it will block the eventloop from exiting before they are // called even if the promise isn't resolved by the time the current script ends executing. -func (c *Client) makeHandledPromise() (*goja.Promise, func(interface{}), func(interface{})) { +func (c *Client) makeHandledPromise() (*sobek.Promise, func(interface{}), func(interface{})) { runtime := c.vu.Runtime() callback := c.vu.RegisterCallback() p, resolve, reject := runtime.NewPromise() diff --git a/redis/client_test.go b/redis/client_test.go index 469f9f3..bedbb63 100644 --- a/redis/client_test.go +++ b/redis/client_test.go @@ -7,7 +7,7 @@ import ( "strconv" "testing" - "github.com/dop251/goja" + "github.com/grafana/sobek" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" "go.k6.io/k6/js/common" @@ -2556,7 +2556,7 @@ func TestClientIsSupportedType(t *testing.T) { // necessary to test the redis client, in the context // of the execution of a k6 script. type testSetup struct { - rt *goja.Runtime + rt *sobek.Runtime state *lib.State samples chan metrics.SampleContainer ev *eventloop.EventLoop @@ -2570,7 +2570,7 @@ type testSetup struct { func newTestSetup(t testing.TB) testSetup { tb := httpmultibin.NewHTTPMultiBin(t) - rt := goja.New() + rt := sobek.New() rt.SetFieldNameMapper(common.FieldNameMapper{}) samples := make(chan metrics.SampleContainer, 1000) @@ -2624,7 +2624,7 @@ func newTestSetup(t testing.TB) testSetup { // and event loop, ready to execute scripts as if being executed in the // main context of k6. func newInitContextTestSetup(t testing.TB) testSetup { - rt := goja.New() + rt := sobek.New() rt.SetFieldNameMapper(common.FieldNameMapper{}) samples := make(chan metrics.SampleContainer, 1000) diff --git a/redis/module.go b/redis/module.go index 7c44ffb..e821b7b 100644 --- a/redis/module.go +++ b/redis/module.go @@ -4,7 +4,7 @@ package redis import ( "errors" - "github.com/dop251/goja" + "github.com/grafana/sobek" "go.k6.io/k6/js/common" "go.k6.io/k6/js/modules" ) @@ -66,7 +66,7 @@ func (mi *ModuleInstance) Exports() modules.Exports { // Client is initially configured, but in a disconnected state. // The connection is automatically established when using any of the Redis // commands exposed by the Client. -func (mi *ModuleInstance) NewClient(call goja.ConstructorCall) *goja.Object { +func (mi *ModuleInstance) NewClient(call sobek.ConstructorCall) *sobek.Object { rt := mi.vu.Runtime() if len(call.Arguments) != 1 { diff --git a/redis/options.go b/redis/options.go index 983b5f7..7cfdddd 100644 --- a/redis/options.go +++ b/redis/options.go @@ -87,7 +87,7 @@ type sentinelOptions struct { } // newOptionsFromObject validates and instantiates an options struct from its -// map representation as exported from goja.Runtime. +// map representation as exported from sobek.Runtime. func newOptionsFromObject(obj map[string]interface{}) (*redis.UniversalOptions, error) { var options interface{} if cluster, ok := obj["cluster"].(map[string]interface{}); ok {