From 0764534edba7af85b8ae1ba13ad5428a154856b1 Mon Sep 17 00:00:00 2001 From: "renovate[bot]" <29139614+renovate[bot]@users.noreply.github.com> Date: Mon, 22 Jan 2024 14:54:34 +0500 Subject: [PATCH] fix(deps): update module github.com/influxdata/influxdb-client-go/v2 to v2.13.0 (#4737) * fix(deps): update module github.com/influxdata/influxdb-client-go/v2 to v2.13.0 * go mod tidy * add new APIClient method to mock * go mod tdiy * go mod tidy again * remove mocks * update mockery and regenerate --------- Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com> Co-authored-by: jliempt <> Co-authored-by: Gulom Alimov Co-authored-by: Googlom <36107508+Googlom@users.noreply.github.com> --- .mockery.yaml | 15 + go.mod | 20 +- go.sum | 73 +- pkg/influx/mocks/Client.go | 1036 ++++++++++++++++++++++++++ pkg/influx/mocks/WriteAPIBlocking.go | 237 ++++++ pkg/influx/mocks/client.go | 300 -------- pkg/influx/mocks/writeAPIBlocking.go | 57 -- 7 files changed, 1337 insertions(+), 401 deletions(-) create mode 100644 .mockery.yaml create mode 100644 pkg/influx/mocks/Client.go create mode 100644 pkg/influx/mocks/WriteAPIBlocking.go delete mode 100644 pkg/influx/mocks/client.go delete mode 100644 pkg/influx/mocks/writeAPIBlocking.go diff --git a/.mockery.yaml b/.mockery.yaml new file mode 100644 index 0000000000..74691b1cb9 --- /dev/null +++ b/.mockery.yaml @@ -0,0 +1,15 @@ +quiet: false +mockname: "{{.InterfaceName}}" +filename: "{{.InterfaceName}}.go" +outpkg: mocks +packages: + github.com/influxdata/influxdb-client-go/v2: + config: + dir: pkg/influx/mocks + interfaces: + Client: + github.com/influxdata/influxdb-client-go/v2/api: + config: + dir: pkg/influx/mocks + interfaces: + WriteAPIBlocking: diff --git a/go.mod b/go.mod index de34143181..255bd90699 100644 --- a/go.mod +++ b/go.mod @@ -9,7 +9,7 @@ replace golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d => golang.org/x/c require ( cloud.google.com/go/storage v1.29.0 github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v0.4.1 - github.com/BurntSushi/toml v1.2.1 + github.com/BurntSushi/toml v1.3.2 github.com/Jeffail/gabs/v2 v2.6.1 github.com/Masterminds/sprig v2.22.0+incompatible github.com/antchfx/htmlquery v1.2.4 @@ -27,9 +27,9 @@ require ( github.com/go-git/go-git/v5 v5.10.1 github.com/go-openapi/runtime v0.24.1 github.com/go-openapi/strfmt v0.21.3 - github.com/go-playground/locales v0.14.0 - github.com/go-playground/universal-translator v0.18.0 - github.com/go-playground/validator/v10 v10.11.0 + github.com/go-playground/locales v0.14.1 + github.com/go-playground/universal-translator v0.18.1 + github.com/go-playground/validator/v10 v10.14.1 github.com/google/go-cmp v0.6.0 github.com/google/go-containerregistry v0.13.0 github.com/google/go-github/v45 v45.2.0 @@ -39,7 +39,7 @@ require ( github.com/hashicorp/vault/api v1.9.2 github.com/iancoleman/orderedmap v0.2.0 github.com/imdario/mergo v0.3.15 - github.com/influxdata/influxdb-client-go/v2 v2.5.1 + github.com/influxdata/influxdb-client-go/v2 v2.13.0 github.com/jarcoal/httpmock v1.0.8 github.com/magiconair/properties v1.8.6 github.com/magicsong/sonargo v0.0.1 @@ -60,7 +60,7 @@ require ( golang.org/x/oauth2 v0.15.0 golang.org/x/text v0.14.0 google.golang.org/api v0.126.0 - gopkg.in/ini.v1 v1.66.6 + gopkg.in/ini.v1 v1.67.0 gopkg.in/yaml.v2 v2.4.0 helm.sh/helm/v3 v3.10.3 mvdan.cc/xurls/v2 v2.4.0 @@ -71,6 +71,7 @@ require ( cloud.google.com/go/compute/metadata v0.2.3 // indirect dario.cat/mergo v1.0.0 // indirect github.com/AdaLogics/go-fuzz-headers v0.0.0-20230106234847-43070de90fa1 // indirect + github.com/apapsch/go-jsonmerge/v2 v2.0.0 // indirect github.com/aws/aws-sdk-go-v2/internal/v4a v1.0.23 // indirect github.com/aws/aws-sdk-go-v2/service/ssooidc v1.14.6 // indirect github.com/axiomhq/hyperloglog v0.0.0-20220105174342-98591331716a // indirect @@ -79,6 +80,7 @@ require ( github.com/cyphar/filepath-securejoin v0.2.4 // indirect github.com/dgryski/go-metro v0.0.0-20180109044635-280f6062b5bc // indirect github.com/duosecurity/duo_api_golang v0.0.0-20190308151101-6c680f768e74 // indirect + github.com/gabriel-vasile/mimetype v1.4.2 // indirect github.com/go-jose/go-jose/v3 v3.0.1 // indirect github.com/go-logr/stdr v1.2.2 // indirect github.com/go-ozzo/ozzo-validation v3.6.0+incompatible // indirect @@ -99,6 +101,7 @@ require ( github.com/lufia/plan9stats v0.0.0-20211012122336-39d0f177ccd0 // indirect github.com/moby/patternmatcher v0.5.0 // indirect github.com/moby/sys/sequential v0.5.0 // indirect + github.com/oapi-codegen/runtime v1.0.0 // indirect github.com/okta/okta-sdk-golang/v2 v2.12.1 // indirect github.com/oracle/oci-go-sdk/v60 v60.0.0 // indirect github.com/pires/go-proxyproto v0.6.1 // indirect @@ -179,7 +182,6 @@ require ( github.com/containerd/containerd v1.7.0 // indirect github.com/containerd/stargz-snapshotter/estargz v0.12.1 // indirect github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect - github.com/deepmap/oapi-codegen v1.8.2 // indirect github.com/denverdino/aliyungo v0.0.0-20190125010748-a747050bb1ba // indirect github.com/digitalocean/godo v1.7.5 // indirect github.com/dimchansky/utfbom v1.1.1 // indirect @@ -268,8 +270,8 @@ require ( github.com/joyent/triton-go v1.7.1-0.20200416154420-6801d15b779f // indirect github.com/json-iterator/go v1.1.12 // indirect github.com/kevinburke/ssh_config v1.2.0 // indirect - github.com/klauspost/compress v1.16.5 // indirect - github.com/leodido/go-urn v1.2.1 // indirect + github.com/klauspost/compress v1.16.7 // indirect + github.com/leodido/go-urn v1.2.4 // indirect github.com/liggitt/tabwriter v0.0.0-20181228230101-89fcab3d43de // indirect github.com/linode/linodego v0.7.1 // indirect github.com/magicsong/color-glog v0.0.1 // indirect diff --git a/go.sum b/go.sum index ace0b2afc1..1a5741f748 100644 --- a/go.sum +++ b/go.sum @@ -128,8 +128,8 @@ github.com/Azure/go-ntlmssp v0.0.0-20221128193559-754e69321358 h1:mFRzDkZVAjdal+ github.com/AzureAD/microsoft-authentication-library-for-go v1.0.0 h1:OBhqkivkhkMqLPymWEppkm7vgPQY2XsHoEkaMQ0AdZY= github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= github.com/BurntSushi/toml v0.4.1/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ= -github.com/BurntSushi/toml v1.2.1 h1:9F2/+DoOYIOksmaJFPw1tGFy1eDnIJXg+UHjuD8lTak= -github.com/BurntSushi/toml v1.2.1/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ= +github.com/BurntSushi/toml v1.3.2 h1:o7IhLm0Msx3BaB+n3Ag7L8EVlByGnpq14C4YWiu/gL8= +github.com/BurntSushi/toml v1.3.2/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ= github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo= github.com/CloudyKit/fastprinter v0.0.0-20200109182630-33d98a066a53/go.mod h1:+3IMCy2vIlbG1XG/0ggNQv0SvxCAIpPM5b1nCz56Xno= github.com/CloudyKit/jet/v3 v3.0.0/go.mod h1:HKQPgSJmdK8hdoAbKUUWajkHyHo4RaU5rMdUywE7VMo= @@ -186,6 +186,7 @@ github.com/PuerkitoBio/purell v1.1.0/go.mod h1:c11w/QuzBsJSee3cPx9rAFu61PvFxuPbt github.com/PuerkitoBio/purell v1.1.1/go.mod h1:c11w/QuzBsJSee3cPx9rAFu61PvFxuPbtSwDGJws/X0= github.com/PuerkitoBio/urlesc v0.0.0-20160726150825-5bd2802263f2/go.mod h1:uGdkoq3SwY9Y+13GIhn11/XLaGBb4BfwItxLd5jeuXE= github.com/PuerkitoBio/urlesc v0.0.0-20170810143723-de5bf2ad4578/go.mod h1:uGdkoq3SwY9Y+13GIhn11/XLaGBb4BfwItxLd5jeuXE= +github.com/RaveNoX/go-jsoncommentstrip v1.0.0/go.mod h1:78ihd09MekBnJnxpICcwzCMzGrKSKYe4AqU6PDYYpjk= github.com/SAP/go-hdb v0.14.1 h1:hkw4ozGZ/i4eak7ZuGkY5e0hxiXFdNUBNhr4AvZVNFE= github.com/Shopify/goreferrer v0.0.0-20181106222321-ec9c9a553398/go.mod h1:a1uqRtAwp2Xwc6WNPJEufxJ7fx3npB4UV/JOLmbu5I0= github.com/Shopify/logrus-bugsnag v0.0.0-20171204204709-577dee27f20d h1:UrqY+r/OJnIp5u0s1SbQ8dVfLCZJsnvazdBP5hS4iRs= @@ -210,6 +211,8 @@ github.com/antchfx/xpath v1.2.0 h1:mbwv7co+x0RwgeGAOHdrKy89GvHaGvxxBtPK0uF9Zr8= github.com/antchfx/xpath v1.2.0/go.mod h1:i54GszH55fYfBmoZXapTHN8T8tkcHfRgLyVwwqzXNcs= github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY= github.com/apache/arrow/go/arrow v0.0.0-20211112161151-bc219186db40 h1:q4dksr6ICHXqG5hm0ZW5IHyeEJXoIJSOZeBLmWPNeIQ= +github.com/apapsch/go-jsonmerge/v2 v2.0.0 h1:axGnT1gRIfimI7gJifB699GoE/oq+F2MU7Dml6nw9rQ= +github.com/apapsch/go-jsonmerge/v2 v2.0.0/go.mod h1:lvDnEdqiQrp0O42VQGgmlKpxL1AP2+08jFMw88y4klk= github.com/apex/log v1.9.0 h1:FHtw/xuaM8AgmvDDTI9fiwoAL25Sq2cxojnZICUU8l0= github.com/apex/log v1.9.0/go.mod h1:m82fZlWIuiWzWP04XCTXmnX0xRkYYbCdYn8jbJeLBEA= github.com/apex/logs v1.0.0/go.mod h1:XzxuLZ5myVHDy9SAmYpamKKRNApGj54PfYLcFrXqDwo= @@ -289,6 +292,7 @@ github.com/bitly/go-simplejson v0.5.0/go.mod h1:cXHtHw4XUPsvGaxgjIAn8PhEWG9NfngE github.com/bketelsen/crypt v0.0.3-0.20200106085610-5cbc8cc4026c/go.mod h1:MKsuJmJgSg28kpZDP6UIiPt0e0Oz0kqKNGyRaWEPv84= github.com/blang/semver v3.1.0+incompatible/go.mod h1:kRBLl5iJ+tD4TcOOxsy/0fnwebNt5EWlYSAyrTnjyyk= github.com/blang/semver v3.5.1+incompatible/go.mod h1:kRBLl5iJ+tD4TcOOxsy/0fnwebNt5EWlYSAyrTnjyyk= +github.com/bmatcuk/doublestar v1.1.1/go.mod h1:UD6OnuiIn0yFxxA2le/rnRU1G4RaI4UvFv1sNto9p6w= github.com/bmatcuk/doublestar v1.3.4 h1:gPypJ5xD31uhX6Tf54sDPUOBXTqKH4c9aPY66CyQrS0= github.com/bmatcuk/doublestar v1.3.4/go.mod h1:wiQtGV+rzVYxB7WIlirSN++5HPtPlXEo9MEoZQC/PmE= github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869/go.mod h1:Ekp36dRnpXw/yCqJaO+ZrUyxD+3VXMFFr56k5XYrpB4= @@ -314,6 +318,7 @@ github.com/buildpacks/imgutil v0.0.0-20211001201950-cf7ae41c3771/go.mod h1:ZfCbs github.com/buildpacks/lifecycle v0.13.0 h1:Hxc8tCvB5UVeEGVZuOWIeKcJy8XgO6fKnLkYyj1WKOE= github.com/buildpacks/lifecycle v0.13.0/go.mod h1:s+uQ+driaV0+ffaT4UDIVCWoP/7kTUVsplU+L1Qd4e0= github.com/bwesterb/go-ristretto v1.2.3/go.mod h1:fUIoIZaG73pV5biE2Blr2xEzDoMj7NFEuV9ekS419A0= +github.com/bytedance/sonic v1.10.0-rc3 h1:uNSnscRapXTwUgTyOF0GVljYD08p9X/Lbr9MweSV3V0= github.com/cenkalti/backoff v2.2.1+incompatible h1:tNowT99t7UNflLxfYYSlKYsBpXdEet03Pg2g16Swow4= github.com/cenkalti/backoff v2.2.1+incompatible/go.mod h1:90ReRw6GdpyfrHakVjL/QHaoyV4aDUVVkXQJJJ3NXXM= github.com/cenkalti/backoff/v3 v3.2.2 h1:cfUAAO3yvKMYKPrvhDuHSwQnhZNk/RMHKdZqKTxfm6M= @@ -328,6 +333,8 @@ github.com/cespare/xxhash/v2 v2.1.2/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XL 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/checkpoint-restore/go-criu/v4 v4.1.0/go.mod h1:xUQBLp4RLc5zJtWY++yjOoMoB5lihDt7fai+75m+rGw= +github.com/chenzhuoyu/base64x v0.0.0-20230717121745-296ad89f973d h1:77cEq6EriyTZ0g/qfRdp61a3Uu/AWrgIq2s0ClJV1g0= +github.com/chenzhuoyu/iasm v0.9.0 h1:9fhXjVzq5hUy2gkhhgHl95zG2cEAhw9OSGs8toWWAwo= github.com/chrismalek/oktasdk-go v0.0.0-20181212195951-3430665dfaa0 h1:CWU8piLyqoi9qXEUwzOh5KFKGgmSU5ZhktJyYcq6ryQ= github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI= github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI= @@ -470,7 +477,6 @@ github.com/creack/pty v1.1.7/go.mod h1:lj5s0c3V2DBrqTV7llrYr5NG6My20zk30Fl46Y7Do github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E= github.com/creack/pty v1.1.11/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E= github.com/creack/pty v1.1.18 h1:n56/Zwd5o6whRC5PMGretI4IdRLlmBXYNjScPaBgsbY= -github.com/cyberdelia/templates v0.0.0-20141128023046-ca7fffd4298c/go.mod h1:GyV+0YP4qX0UQ7r2MoYZ+AvYDp12OF5yg4q8rGnyNh4= github.com/cyphar/filepath-securejoin v0.2.2/go.mod h1:FpkQEhXnPnOthhzymB7CGsFk2G9VLXONKD9G7QGMM+4= github.com/cyphar/filepath-securejoin v0.2.4 h1:Ugdm7cg7i6ZK6x3xDF1oEu1nfkyfH53EtKeQYTC3kyg= github.com/cyphar/filepath-securejoin v0.2.4/go.mod h1:aPGpWjXOXUn2NCNjFvBE6aRxGGx79pTxQpKOJNYHHl4= @@ -484,8 +490,6 @@ github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSs github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM= github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/deepmap/oapi-codegen v1.8.2 h1:SegyeYGcdi0jLLrpbCMoJxnUUn8GBXHsvr4rbzjuhfU= -github.com/deepmap/oapi-codegen v1.8.2/go.mod h1:YLgSKSDv/bZQB7N4ws6luhozi3cEdRktEqrX88CvjIw= github.com/denisenkom/go-mssqldb v0.12.2 h1:1OcPn5GBIobjWNd+8yjfHNIaFX14B1pWI3F9HZy5KXw= github.com/denverdino/aliyungo v0.0.0-20170926055100-d3308649c661/go.mod h1:dV8lFg6daOBZbT6/BDGIz6Y3WFGn8juu6G+CQ6LHtl0= github.com/denverdino/aliyungo v0.0.0-20190125010748-a747050bb1ba h1:p6poVbjHDkKa+wtC8frBMwQtT3BmqGYBjzMwJ63tuR4= @@ -589,11 +593,11 @@ github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4 github.com/fsnotify/fsnotify v1.6.0 h1:n+5WquG0fcWoWp6xPWfHdbskMCQaFnG6PfBrh1Ky4HY= github.com/fullsailor/pkcs7 v0.0.0-20190404230743-d7302db945fa/go.mod h1:KnogPXtdwXqoenmZCw6S+25EAm2MkxbG0deNDu4cbSA= github.com/gabriel-vasile/mimetype v1.4.2 h1:w5qFW6JKBz9Y393Y4q372O9A7cUSequkh1Q7OhCmWKU= +github.com/gabriel-vasile/mimetype v1.4.2/go.mod h1:zApsH/mKG4w07erKIaJPFiX0Tsq9BFQgN3qGY5GnNgA= github.com/gammazero/deque v0.2.1 h1:qSdsbG6pgp6nL7A0+K/B7s12mcCY/5l5SIUpMOl+dC0= github.com/gammazero/workerpool v1.1.3 h1:WixN4xzukFoN0XSeXF6puqEqFTl2mECI9S6W44HWy9Q= github.com/garyburd/redigo v0.0.0-20150301180006-535138d7bcd7/go.mod h1:NR3MbYisc3/PwhQ00EMzDiPmrwpPxAn5GI05/YaO1SY= github.com/gavv/httpexpect v2.0.0+incompatible/go.mod h1:x+9tiU1YnrOvnB725RkpoLv1M62hOWzwo5OXotisrKc= -github.com/getkin/kin-openapi v0.61.0/go.mod h1:7Yn5whZr5kJi6t+kShccXS8ae1APpYTW6yheSwk8Yi4= github.com/getsentry/sentry-go v0.11.0 h1:qro8uttJGvNAMr5CLcFI9CHR0aDzXl0Vs3Pmw/oTPg8= github.com/getsentry/sentry-go v0.11.0/go.mod h1:KBQIxiZAetw62Cj8Ri964vAEWVdgfaUCn30Q3bCvANo= github.com/ghodss/yaml v0.0.0-20150909031657-73d445a93680/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04= @@ -604,14 +608,13 @@ github.com/gin-contrib/sse v0.0.0-20190301062529-5545eab6dad3/go.mod h1:VJ0WA2NB github.com/gin-contrib/sse v0.1.0 h1:Y/yl/+YNO8GZSjAhjMsSuLt29uWRFHdHYUb5lYOV9qE= github.com/gin-contrib/sse v0.1.0/go.mod h1:RHrZQHXnP2xjPF+u1gW/2HnVO7nvIa9PG3Gm+fLHvGI= github.com/gin-gonic/gin v1.4.0/go.mod h1:OW2EZn3DO8Ln9oIKOvM++LBO+5UPHJJDH72/q/3rZdM= -github.com/gin-gonic/gin v1.6.3 h1:ahKqKTFpO5KTPHxWZjEdPScmYaGtLo8Y4DMHoEsnp14= github.com/gin-gonic/gin v1.6.3/go.mod h1:75u5sXoLsGZoRN5Sgbi1eraJ4GU3++wFwWzhwvtwp4M= +github.com/gin-gonic/gin v1.9.1 h1:4idEAncQnU5cB7BeOkPtxjfCSye0AAm1R0RVIqJ+Jmg= github.com/gliderlabs/ssh v0.3.5 h1:OcaySEmAQJgyYcArR+gGGTHCyE7nvhEMTlYY+Dp8CpY= github.com/globalsign/mgo v0.0.0-20180905125535-1ca0a4f7cbcb/go.mod h1:xkRDCp4j0OGD1HRkm4kmhM+pmpv3AKq5SU7GMg4oO/Q= github.com/globalsign/mgo v0.0.0-20181015135952-eeefdecb41b8/go.mod h1:xkRDCp4j0OGD1HRkm4kmhM+pmpv3AKq5SU7GMg4oO/Q= github.com/go-asn1-ber/asn1-ber v1.5.4 h1:vXT6d/FNDiELJnLb6hGNa309LMsrCoYFvpwHDF0+Y1A= github.com/go-check/check v0.0.0-20180628173108-788fd7840127/go.mod h1:9ES+weclKsC9YodN5RgxqK/VD9HM9JsCSh7rNhMZE98= -github.com/go-chi/chi/v5 v5.0.0/go.mod h1:BBug9lr0cqtdAhsu6R4AAdvufI0/XBzAQSsUqJpoZOs= github.com/go-errors/errors v1.0.1/go.mod h1:f4zRHt4oKfwPJE5k8C9vpYG+aDHdBFUsgrm6/TyX73Q= github.com/go-errors/errors v1.4.2 h1:J6MZopCL4uSllY1OfXM374weqZFFItUbrImctkmUxIA= github.com/go-errors/errors v1.4.2/go.mod h1:sIVyrIiJhuEF+Pj9Ebtd6P/rEYROXFi3BopGUQ5a5Og= @@ -734,17 +737,17 @@ github.com/go-openapi/validate v0.22.0 h1:b0QecH6VslW/TxtpKgzpO1SNG7GU2FsaqKdP1E github.com/go-openapi/validate v0.22.0/go.mod h1:rjnrwK57VJ7A8xqfpAOEKRH8yQSGUriMu5/zuPSQ1hg= github.com/go-ozzo/ozzo-validation v3.6.0+incompatible h1:msy24VGS42fKO9K1vLz82/GeYW1cILu7Nuuj1N3BBkE= github.com/go-ozzo/ozzo-validation v3.6.0+incompatible/go.mod h1:gsEKFIVnabGBt6mXmxK0MoFy+cZoTJY6mu5Ll3LVLBU= -github.com/go-playground/assert/v2 v2.0.1 h1:MsBgLAaY856+nPRTKrp3/OZK38U/wa0CcBYNjji3q3A= github.com/go-playground/assert/v2 v2.0.1/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4= +github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s= github.com/go-playground/locales v0.13.0/go.mod h1:taPMhCMXrRLJO55olJkUXHZBHCxTMfnGwq/HNwmWNS8= -github.com/go-playground/locales v0.14.0 h1:u50s323jtVGugKlcYeyzC0etD1HifMjqmJqb8WugfUU= -github.com/go-playground/locales v0.14.0/go.mod h1:sawfccIbzZTqEDETgFXqTho0QybSa7l++s0DH+LDiLs= +github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA= +github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY= github.com/go-playground/universal-translator v0.17.0/go.mod h1:UkSxE5sNxxRwHyU+Scu5vgOQjsIJAF8j9muTVoKLVtA= -github.com/go-playground/universal-translator v0.18.0 h1:82dyy6p4OuJq4/CByFNOn/jYrnRPArHwAcmLoJZxyho= -github.com/go-playground/universal-translator v0.18.0/go.mod h1:UvRDBj+xPUEGrFYl+lu/H90nyDXpg0fqeB/AQUGNTVA= +github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY= +github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY= github.com/go-playground/validator/v10 v10.2.0/go.mod h1:uOYAAleCW8F/7oMFd6aG0GOhaH6EGOAJShg8Id5JGkI= -github.com/go-playground/validator/v10 v10.11.0 h1:0W+xRM511GY47Yy3bZUbJVitCNg2BOGlCyvTqsp/xIw= -github.com/go-playground/validator/v10 v10.11.0/go.mod h1:i+3WkQ1FvaUjjxh1kSvIA4dMGDBiPU55YFDl0WbKdWU= +github.com/go-playground/validator/v10 v10.14.1 h1:9c50NUPC30zyuKprjL3vNZ0m5oG+jU0zvx4AqHGnv4k= +github.com/go-playground/validator/v10 v10.14.1/go.mod h1:9iXMNT7sEkjXb0I+enO7QXmzG6QCsPWY4zveKFVRSyU= github.com/go-redis/redis v6.15.9+incompatible h1:K0pv1D7EQUjfyoMql+r/jZqCLizCGKFlFgcHWWmHQjg= github.com/go-redis/redis v6.15.9+incompatible/go.mod h1:NAIEuMOZ/fxfXJIrKDQDz8wamY7mA7PouImQ2Jvg6kA= github.com/go-sql-driver/mysql v1.5.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg= @@ -788,6 +791,7 @@ github.com/gobwas/pool v0.2.0 h1:QEmUOlnSjWtnpRGHF3SauEiOsy82Cup83Vf2LcMlnc8= github.com/gobwas/pool v0.2.0/go.mod h1:q8bcK0KcYlCgd9e7WYLm9LpyS+YeLd8JVDW6WezmKEw= github.com/gobwas/ws v1.0.2 h1:CoAavW/wd/kulfZmSIBt6p24n4j7tHgNVCjsfHVNUbo= github.com/gobwas/ws v1.0.2/go.mod h1:szmBTxLgaFppYjEmNtny/v3w89xOydFnnZMcgRRu/EM= +github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU= github.com/gocql/gocql v1.0.0 h1:UnbTERpP72VZ/viKE1Q1gPtmLvyTZTvuAstvSRydw/c= github.com/godbus/dbus v0.0.0-20151105175453-c7fdd8b5cd55/go.mod h1:/YcGZj5zSblfDWMMoOzV4fas9FZnQYTkDnsGvmh2Grw= github.com/godbus/dbus v0.0.0-20180201030542-885f9cc04c9c/go.mod h1:/YcGZj5zSblfDWMMoOzV4fas9FZnQYTkDnsGvmh2Grw= @@ -852,7 +856,6 @@ github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEW github.com/golang/snappy v0.0.3/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q= github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM= github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q= -github.com/golangci/lint-1 v0.0.0-20181222135242-d2cdd8c08219/go.mod h1:/X8TswGSh1pIozq4ZwCfxS0WA5JGXguxk94ar/4c87Y= github.com/gomodule/redigo v1.7.1-0.20190724094224-574c33c3df38/go.mod h1:B4C85qUVwatsJoIUNIfCRsp7qO0iAmpGFZ4EELWSbC4= github.com/gomodule/redigo v1.8.2 h1:H5XSIre1MB5NbPYFp+i1NBbb5qN1W8Y8YAQoAYbkm8k= github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ= @@ -1154,8 +1157,8 @@ github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANyt github.com/inconshreveable/mousetrap v1.0.1 h1:U3uMjPSQEBMNp1lFxmllqCPM6P5u/Xq7Pgzkat/bFNc= github.com/inconshreveable/mousetrap v1.0.1/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw= github.com/influxdata/influxdb v1.7.6/go.mod h1:qZna6X/4elxqT3yI9iZYdZrWWdeFOOprn86kgg4+IzY= -github.com/influxdata/influxdb-client-go/v2 v2.5.1 h1:ytMbX2YeupSsec1Exp3zALTjvfhXkvxcyV6nOXkjG3s= -github.com/influxdata/influxdb-client-go/v2 v2.5.1/go.mod h1:Y/0W1+TZir7ypoQZYd2IrnVOKB3Tq6oegAQeSVN/+EU= +github.com/influxdata/influxdb-client-go/v2 v2.13.0 h1:ioBbLmR5NMbAjP4UVA5r9b5xGjpABD7j65pI8kFphDM= +github.com/influxdata/influxdb-client-go/v2 v2.13.0/go.mod h1:k+spCbt9hcvqvUiz0sr5D8LolXHqAAOfPw9v/RIRHl4= github.com/influxdata/influxdb1-client v0.0.0-20200827194710-b269163b24ab h1:HqW4xhhynfjrtEiiSGcQUd6vrK23iMam1FO8rI7mwig= github.com/influxdata/line-protocol v0.0.0-20200327222509-2487e7298839 h1:W9WBk7wlPfJLvMCdtV4zPulc4uCPrlywQOmbFOhgQNU= github.com/influxdata/line-protocol v0.0.0-20200327222509-2487e7298839/go.mod h1:xaLFMmpvUxqXtVkUJfg9QmT88cDaCJ3ZKgdZ78oO8Qo= @@ -1224,6 +1227,7 @@ github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHm github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod h1:6v2b51hI/fHJwM22ozAgKL4VKDeJcHhJFhtBdhmNjmU= github.com/jstemmer/go-junit-report v0.9.1/go.mod h1:Brl9GWCQeLvo8nXZwPNNblvFj/XSXhF0NWZEnDohbsk= github.com/jtolds/gls v4.20.0+incompatible/go.mod h1:QJZ7F/aHp+rZTRtaJ1ow/lLfFfVYBRgL+9YlvaHOwJU= +github.com/juju/gnuflag v0.0.0-20171113085948-2ce1bb71843d/go.mod h1:2PavIy+JPciBPrBUjwbNvtwB6RQlve+hkpll6QSNmOE= github.com/julienschmidt/httprouter v1.2.0/go.mod h1:SYymIcj16QtmaHHD7aYtjjsJG7VTCxuUUipMqKk8s4w= github.com/julienschmidt/httprouter v1.3.0/go.mod h1:JR6WtHb+2LUe8TCKY3cZOxFyyO8IZAc4RVcycCCAKdM= github.com/k0kubun/colorstring v0.0.0-20150214042306-9440f1994b88/go.mod h1:3w7q1U84EfirKl04SVQ/s7nPm1ZPhiXd34z40TNz36k= @@ -1251,9 +1255,11 @@ github.com/klauspost/compress v1.12.3/go.mod h1:8dP1Hq4DHOhN9w426knH3Rhby4rFm6D8 github.com/klauspost/compress v1.13.0/go.mod h1:8dP1Hq4DHOhN9w426knH3Rhby4rFm6D8eO+e+Dq5Gzg= github.com/klauspost/compress v1.13.6/go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk= github.com/klauspost/compress v1.15.11/go.mod h1:QPwzmACJjUTFsnSHH934V6woptycfrDDJnH7hvFVbGM= -github.com/klauspost/compress v1.16.5 h1:IFV2oUNUzZaz+XyusxpLzpzS8Pt5rh0Z16For/djlyI= -github.com/klauspost/compress v1.16.5/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE= +github.com/klauspost/compress v1.16.7 h1:2mk3MPGNzKyxErAw8YaohYh69+pa4sIQSC0fPGCFR9I= +github.com/klauspost/compress v1.16.7/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE= +github.com/klauspost/cpuid v1.2.1 h1:vJi+O/nMdFt0vqm8NZBI6wzALWdA2X+egi0ogNyrC/w= github.com/klauspost/cpuid v1.2.1/go.mod h1:Pj4uuM528wm8OyEC2QMXAi2YiTZ96dNQPGgoMS4s3ek= +github.com/klauspost/cpuid/v2 v2.2.5 h1:0E5MSMDEoAulmXNFquVs//DdoomxaoTY1kUhbc/qbZg= github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ= github.com/konsorten/go-windows-terminal-sequences v1.0.2/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ= github.com/konsorten/go-windows-terminal-sequences v1.0.3/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ= @@ -1271,11 +1277,10 @@ github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc= github.com/labstack/echo/v4 v4.1.11/go.mod h1:i541M3Fj6f76NZtHSj7TXnyM8n2gaodfvfxNnFqi74g= -github.com/labstack/echo/v4 v4.2.1/go.mod h1:AA49e0DZ8kk5jTOOCKNuPR6oTnBS0dYiM4FW1e6jwpg= github.com/labstack/gommon v0.3.0/go.mod h1:MULnywXg0yavhxWKc+lOruYdAhDwPK9wf0OL7NoOu+k= github.com/leodido/go-urn v1.2.0/go.mod h1:+8+nEpDfqqsY+g338gtMEUOtuK+4dEMhiQEgxpxOKII= -github.com/leodido/go-urn v1.2.1 h1:BqpAaACuzVSgi/VLzGZIobT2z4v53pjosyNd9Yv6n/w= -github.com/leodido/go-urn v1.2.1/go.mod h1:zt4jvISO2HfUBqxjfIshjdMTYS56ZS/qv49ictyFfxY= +github.com/leodido/go-urn v1.2.4 h1:XlAE/cm/ms7TE/VMVoduSpNBoyc2dOxHs5MZSwAN63Q= +github.com/leodido/go-urn v1.2.4/go.mod h1:7ZrI8mTSeBSHl/UaRyKQW1qZeMgak41ANeCNaVckg+4= github.com/lib/pq v1.1.1/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo= github.com/liggitt/tabwriter v0.0.0-20181228230101-89fcab3d43de h1:9TO3cAIGXtEhnIaL+V+BEER86oLrvS+kWobKpbJuye0= github.com/liggitt/tabwriter v0.0.0-20181228230101-89fcab3d43de/go.mod h1:zAbeS9B/r2mtpb6U+EI2rYA5OAXxsYw6wTamcNW+zcE= @@ -1303,12 +1308,10 @@ github.com/mailru/easyjson v0.7.7/go.mod h1:xzfreul335JAWq5oZzymOObrkdz5UnU4kGfJ github.com/markbates/oncer v0.0.0-20181203154359-bf2de49a0be2/go.mod h1:Ld9puTsIW75CHf65OeIOkyKbteujpZVXDpWK6YGZbxE= github.com/markbates/safe v1.0.1/go.mod h1:nAqgmRi7cY2nqMc92/bSEeQA+R4OheNU2T1kNSCBdG0= github.com/marstr/guid v1.1.0/go.mod h1:74gB1z2wpxxInTG6yaqA7KrtM0NZ+RbrcqDvYHefzho= -github.com/matryer/moq v0.0.0-20190312154309-6cfb0558e1bd/go.mod h1:9ELz6aaclSIGnZBoaSLZ3NAl1VTufbOrXBPvtcy6WiQ= github.com/mattn/go-colorable v0.0.9/go.mod h1:9vuHe8Xs5qXnSaW/c/ABM9alt+Vo+STaOChaDxuIBZU= github.com/mattn/go-colorable v0.1.1/go.mod h1:FuOcm+DKB9mbwrcAfNl7/TZVBZ6rcnceauSikq3lYCQ= github.com/mattn/go-colorable v0.1.2/go.mod h1:U0ppj6V5qS13XJ6of8GYAs25YV2eR4EVcfRqFIhoBtE= github.com/mattn/go-colorable v0.1.4/go.mod h1:U0ppj6V5qS13XJ6of8GYAs25YV2eR4EVcfRqFIhoBtE= -github.com/mattn/go-colorable v0.1.7/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc= github.com/mattn/go-colorable v0.1.8/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc= github.com/mattn/go-colorable v0.1.9/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc= github.com/mattn/go-colorable v0.1.12/go.mod h1:u5H1YNBxpqRaxsYJYSkiCWKzEfiAb1Gb520KVy5xxl4= @@ -1434,6 +1437,8 @@ github.com/nishanths/predeclared v0.0.0-20200524104333-86fad755b4d3/go.mod h1:nt 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= +github.com/oapi-codegen/runtime v1.0.0 h1:P4rqFX5fMFWqRzY9M/3YF9+aPSPPB06IzP2P7oOxrWo= +github.com/oapi-codegen/runtime v1.0.0/go.mod h1:LmCUMQuPB4M/nLXilQXhHw+BLZdDb18B34OO356yJ/A= github.com/oklog/run v1.1.0 h1:GEenZ1cK0+q0+wsJew9qUg/DyD8k3JzYsZAi5gYi2mA= github.com/oklog/run v1.1.0/go.mod h1:sVPdnTZT1zYwAJeCMu2Th4T21pA3FPOQRfWjQlk7DVU= github.com/oklog/ulid v1.3.1 h1:EGfNDEx6MqHz8B3uNV6QAib1UR2Lm97sHi3ocA6ESJ4= @@ -1508,6 +1513,8 @@ github.com/pborman/uuid v1.2.0/go.mod h1:X/NO0urCmaxf9VXbdlT7C2Yzkj2IKimNn4k+gtP github.com/pelletier/go-toml v1.2.0/go.mod h1:5z9KED0ma1S8pY6P1sdut58dfprrGBbd/94hg7ilaic= github.com/pelletier/go-toml v1.7.0/go.mod h1:vwGMzjaWMwyfHwgIBhI2YUM4fB6nL6lVAvS1LBMMhTE= github.com/pelletier/go-toml v1.8.1/go.mod h1:T2/BmBdy8dvIRq1a/8aqjN41wvWlN4lrapLU/GW4pbc= +github.com/pelletier/go-toml v1.9.5 h1:4yBQzkHv+7BHq2PQUZF3Mx0IYxG7LsP222s7Agd3ve8= +github.com/pelletier/go-toml/v2 v2.0.9 h1:uH2qQXheeefCCkuBBSLi7jCiSmj3VRh2+Goq2N7Xxu0= github.com/peterbourgon/diskv v2.0.1+incompatible h1:UBdAOUP5p4RWqPBg048CAvpKN+vxiaj6gdUUzhl4XmI= github.com/peterbourgon/diskv v2.0.1+incompatible/go.mod h1:uqqh8zWWbv1HBMNONnaR/tNboyR3/BZd58JJSHlUSCU= github.com/petermattis/goid v0.0.0-20180202154549-b0b1615b78e5 h1:q2e307iGHPdTGp0hoxKjt1H5pDo6utceo3dQVK3I5XQ= @@ -1606,7 +1613,6 @@ github.com/rogpeppe/go-internal v1.2.2/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFR github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4= github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc= github.com/rogpeppe/go-internal v1.6.2/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc= -github.com/rogpeppe/go-internal v1.8.0/go.mod h1:WmiCO8CzOY8rg0OYDC4/i/2WRWAB6poM+XZ2dLUbcbE= github.com/rogpeppe/go-internal v1.8.1/go.mod h1:JeRgkft04UBgHMgCIwADu4Pn6Mtm5d4nPKWu0nJ5d+o= github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs= github.com/rogpeppe/go-internal v1.11.0 h1:cWPaGQEPrBb5/AsnsZesgZZ9yb1OQ+GOISoDNXVBh4M= @@ -1689,6 +1695,7 @@ github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An github.com/spf13/viper v1.3.2/go.mod h1:ZiWeW+zYFKm7srdB9IoDzzZXaJaI5eL9QjNiN/DMA2s= github.com/spf13/viper v1.4.0/go.mod h1:PTJ7Z/lr49W6bUbkmS1V3by4uWynFiR9p7+dSq/yZzE= github.com/spf13/viper v1.7.0/go.mod h1:8WkrPz2fc9jxqZNCJI/76HCieCp4Q8HaLFoCha5qpdg= +github.com/spkg/bom v0.0.0-20160624110644-59b7046e48ad/go.mod h1:qLr4V1qq6nMqFKkMo8ZTx3f+BZEkzsRUY10Xsm2mwU0= github.com/stefanberger/go-pkcs11uri v0.0.0-20201008174630-78d3cae3a980/go.mod h1:AO3tvPzVZ/ayst6UlUKUv6rcPQInYe3IknH3jYhAKu8= github.com/stoewer/go-strcase v1.2.0/go.mod h1:IBiWB2sKIp3wVVQ3Y035++gc+knqhUQag1KpM8ahLw8= github.com/stretchr/objx v0.0.0-20180129172003-8a3f7159479f/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= @@ -1741,6 +1748,7 @@ github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5/go.mod h1 github.com/tv42/httpunix v0.0.0-20150427012821-b75d8614f926/go.mod h1:9ESjWnEqriFuLhtthL60Sar/7RFoluCcXsuvEwTV5KM= github.com/tv42/httpunix v0.0.0-20191220191345-2ba4b9c3382c h1:u6SKchux2yDvFQnDHS3lPnIRmfVJ5Sxy3ao2SIdysLQ= github.com/tv42/httpunix v0.0.0-20191220191345-2ba4b9c3382c/go.mod h1:hzIxponao9Kjc7aWznkXaL4U4TWaDSs8zcsY4Ka08nM= +github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI= github.com/uber/jaeger-client-go v2.30.0+incompatible h1:D6wyKGCecFaSRUpo8lCVbaOOb6ThwMmTEbhRwtKR97o= github.com/uber/jaeger-client-go v2.30.0+incompatible/go.mod h1:WVhlPFC8FDjOFMMWRy2pZqQJSXxYSwNYOkTr/Z6d3Kk= github.com/uber/jaeger-lib v2.4.1+incompatible h1:td4jdvLcExb4cBISKIpHuGoVXh+dVKhn2Um6rjCsSsg= @@ -1749,8 +1757,8 @@ github.com/ugorji/go v1.1.4/go.mod h1:uQMGLiO92mf5W77hV/PUCpI3pbzQx3CRekS0kk+RGr github.com/ugorji/go v1.1.7 h1:/68gy2h+1mWMrwZFeD1kQialdSzAb432dtpeJ42ovdo= github.com/ugorji/go v1.1.7/go.mod h1:kZn38zHttfInRq0xu/PH0az30d+z6vm202qpg1oXVMw= github.com/ugorji/go/codec v0.0.0-20181204163529-d75b2dcb6bc8/go.mod h1:VFNgLljTbGfSG7qAOspJ7OScBnGdDN/yBr0sguwnwf0= -github.com/ugorji/go/codec v1.1.7 h1:2SvQaVZ1ouYrrKKwoSk2pzd4A9evlKJb9oTL+OaLUSs= github.com/ugorji/go/codec v1.1.7/go.mod h1:Ax+UKWsSmolVDwsd+7N3ZtXu+yMGCf907BLYF3GoBXY= +github.com/ugorji/go/codec v1.2.11 h1:BMaWp1Bb6fHwEtbplGBGJ498wD+LKlNSl25MjdZY4dU= github.com/urfave/cli v0.0.0-20171014202726-7bc6a0acffa5/go.mod h1:70zkFmudgCuE/ngEzBv17Jvp/497gISqfk5gWijbERA= github.com/urfave/cli v1.20.0/go.mod h1:70zkFmudgCuE/ngEzBv17Jvp/497gISqfk5gWijbERA= github.com/urfave/cli v1.22.1/go.mod h1:Gos4lmkARVdJ6EkW0WaNv/tZAAMe9V7XWyB60NtXRu0= @@ -1760,7 +1768,6 @@ github.com/urfave/negroni v1.0.0/go.mod h1:Meg73S6kFm/4PpbYdq35yYWoCZ9mS/YSx+lKn github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc= github.com/valyala/fasthttp v1.6.0/go.mod h1:FstJa9V+Pj9vQ7OJie2qMHdwemEDaDiSdBnvPM1Su9w= github.com/valyala/fasttemplate v1.0.1/go.mod h1:UQGH1tvbgY+Nz5t2n7tXsz52dQxojPUpymEIMZ47gx8= -github.com/valyala/fasttemplate v1.2.1/go.mod h1:KHLXt3tVN2HBp8eijSv/kGJopbvo7S+qRAEEKiv+SiQ= github.com/valyala/tcplisten v0.0.0-20161114210144-ceec8f93295a/go.mod h1:v3UYOV9WzVtRmSR+PDvWpU/qWl4Wa5LApYYX4ZtKbio= github.com/vbatts/tar-split v0.11.2 h1:Via6XqJr0hceW4wff3QRzD5gAk/tatMw/4ZA7cTlIME= github.com/vbatts/tar-split v0.11.2/go.mod h1:vV3ZuO2yWSVsz+pfFzDG/upWH1JhjOiEaWq6kXyQ3VI= @@ -1863,6 +1870,7 @@ go.uber.org/goleak v1.1.10/go.mod h1:8a7PlsEVH3e/a/GLqe5IIrQx6GzcnRmZEufDUTk4A7A go.uber.org/goleak v1.2.1 h1:NBol2c7O1ZokfZ0LEU9K6Whx/KnwvepVetCUhtKja4A= go.uber.org/multierr v1.1.0/go.mod h1:wR5kodmAFQ0UK8QlbwjlSNy0Z68gJhDJUG5sjR94q/0= go.uber.org/zap v1.10.0/go.mod h1:vwi/ZaCAaUcBkycHslxD9B2zi4UTXhF60s6SWpuDF0Q= +golang.org/x/arch v0.4.0 h1:A8WCeEWhLwPBKNbFi5Wv5UTCBx5zzubnXDlMOFAzFMc= golang.org/x/crypto v0.0.0-20171113213409-9f005a07e0d3/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4= golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4= golang.org/x/crypto v0.0.0-20181009213950-7c1a557ab941/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4= @@ -1888,7 +1896,6 @@ golang.org/x/crypto v0.0.0-20200728195943-123391ffb6de/go.mod h1:LzIPMQfyMNhhGPh golang.org/x/crypto v0.0.0-20200820211705-5c72a883971a/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= golang.org/x/crypto v0.0.0-20201002170205-7f63de1d35b0/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= golang.org/x/crypto v0.0.0-20201216223049-8b5274cf687f/go.mod h1:jdWPYTVW3xRLrWPugEBEK3UY2ZEsg3UU495nc5E+M+I= -golang.org/x/crypto v0.0.0-20201221181555-eec23a3978ad/go.mod h1:jdWPYTVW3xRLrWPugEBEK3UY2ZEsg3UU495nc5E+M+I= golang.org/x/crypto v0.0.0-20210322153248-0c34fe9e7dc2/go.mod h1:T9bdIzuCu7OtxOm1hfPfRQxPLYneinmdGuTeoZ9dtd4= golang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= @@ -2117,7 +2124,6 @@ golang.org/x/sys v0.0.0-20200625212154-ddb9806d33ae/go.mod h1:h1NjWce9XRLGQEsW7w golang.org/x/sys v0.0.0-20200728102440-3e129f6d46b1/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200803210538-64077c9b5642/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200817155316-9781c653f443/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20200826173525-f9321e4c35a6/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200831180312-196b9ba8737a/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200905004654-be1d3432aa8f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200909081042-eff7692f9009/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= @@ -2151,7 +2157,6 @@ golang.org/x/sys v0.0.0-20210608053332-aa57babbf139/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210616094352-59db8d763f22/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.0.0-20210806184541-e5e7981a1069/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210927094055-39ccf1dd6fa6/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220114195835-da31bd327af9/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= @@ -2199,8 +2204,6 @@ golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxb golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20200630173020-3af7569d3a1e/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= -golang.org/x/time v0.0.0-20201208040808-7e3f01d25324/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= -golang.org/x/time v0.0.0-20210220033141-f8bda1e9f3ba/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= 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/tools v0.0.0-20180221164845-07fd8470d635/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= @@ -2440,8 +2443,8 @@ gopkg.in/inf.v0 v0.9.1/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw= gopkg.in/ini.v1 v1.51.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k= gopkg.in/ini.v1 v1.51.1/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k= gopkg.in/ini.v1 v1.66.2/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k= -gopkg.in/ini.v1 v1.66.6 h1:LATuAqN/shcYAOkv3wl2L4rkaKqkcgTBQjOyYDvcPKI= -gopkg.in/ini.v1 v1.66.6/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k= +gopkg.in/ini.v1 v1.67.0 h1:Dgnx+6+nfE+IfzjUEISNeydPJh9AXNNsWbGP9KzCsOA= +gopkg.in/ini.v1 v1.67.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k= gopkg.in/jcmturner/goidentity.v3 v3.0.0 h1:1duIyWiTaYvVx3YX2CYtpJbUFd7/UuPYCfgXtQ3VTbI= gopkg.in/mgo.v2 v2.0.0-20180705113604-9856a29383ce/go.mod h1:yeKp02qBN3iKW1OzL3MGk2IdtZzaj7SFntXj72NppTA= gopkg.in/natefinch/lumberjack.v2 v2.0.0/go.mod h1:l0ndWWf7gzL7RNwBG7wST/UCcT4T24xpD6X8LsfU/+k= diff --git a/pkg/influx/mocks/Client.go b/pkg/influx/mocks/Client.go new file mode 100644 index 0000000000..ad616fdefd --- /dev/null +++ b/pkg/influx/mocks/Client.go @@ -0,0 +1,1036 @@ +// Code generated by mockery v2.40.1. DO NOT EDIT. + +package mocks + +import ( + context "context" + + api "github.com/influxdata/influxdb-client-go/v2/api" + + domain "github.com/influxdata/influxdb-client-go/v2/domain" + + http "github.com/influxdata/influxdb-client-go/v2/api/http" + + influxdb2 "github.com/influxdata/influxdb-client-go/v2" + + mock "github.com/stretchr/testify/mock" +) + +// Client is an autogenerated mock type for the Client type +type Client struct { + mock.Mock +} + +type Client_Expecter struct { + mock *mock.Mock +} + +func (_m *Client) EXPECT() *Client_Expecter { + return &Client_Expecter{mock: &_m.Mock} +} + +// APIClient provides a mock function with given fields: +func (_m *Client) APIClient() *domain.Client { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for APIClient") + } + + var r0 *domain.Client + if rf, ok := ret.Get(0).(func() *domain.Client); ok { + r0 = rf() + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(*domain.Client) + } + } + + return r0 +} + +// Client_APIClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'APIClient' +type Client_APIClient_Call struct { + *mock.Call +} + +// APIClient is a helper method to define mock.On call +func (_e *Client_Expecter) APIClient() *Client_APIClient_Call { + return &Client_APIClient_Call{Call: _e.mock.On("APIClient")} +} + +func (_c *Client_APIClient_Call) Run(run func()) *Client_APIClient_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_APIClient_Call) Return(_a0 *domain.Client) *Client_APIClient_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_APIClient_Call) RunAndReturn(run func() *domain.Client) *Client_APIClient_Call { + _c.Call.Return(run) + return _c +} + +// AuthorizationsAPI provides a mock function with given fields: +func (_m *Client) AuthorizationsAPI() api.AuthorizationsAPI { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for AuthorizationsAPI") + } + + var r0 api.AuthorizationsAPI + if rf, ok := ret.Get(0).(func() api.AuthorizationsAPI); ok { + r0 = rf() + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(api.AuthorizationsAPI) + } + } + + return r0 +} + +// Client_AuthorizationsAPI_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AuthorizationsAPI' +type Client_AuthorizationsAPI_Call struct { + *mock.Call +} + +// AuthorizationsAPI is a helper method to define mock.On call +func (_e *Client_Expecter) AuthorizationsAPI() *Client_AuthorizationsAPI_Call { + return &Client_AuthorizationsAPI_Call{Call: _e.mock.On("AuthorizationsAPI")} +} + +func (_c *Client_AuthorizationsAPI_Call) Run(run func()) *Client_AuthorizationsAPI_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_AuthorizationsAPI_Call) Return(_a0 api.AuthorizationsAPI) *Client_AuthorizationsAPI_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_AuthorizationsAPI_Call) RunAndReturn(run func() api.AuthorizationsAPI) *Client_AuthorizationsAPI_Call { + _c.Call.Return(run) + return _c +} + +// BucketsAPI provides a mock function with given fields: +func (_m *Client) BucketsAPI() api.BucketsAPI { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for BucketsAPI") + } + + var r0 api.BucketsAPI + if rf, ok := ret.Get(0).(func() api.BucketsAPI); ok { + r0 = rf() + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(api.BucketsAPI) + } + } + + return r0 +} + +// Client_BucketsAPI_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BucketsAPI' +type Client_BucketsAPI_Call struct { + *mock.Call +} + +// BucketsAPI is a helper method to define mock.On call +func (_e *Client_Expecter) BucketsAPI() *Client_BucketsAPI_Call { + return &Client_BucketsAPI_Call{Call: _e.mock.On("BucketsAPI")} +} + +func (_c *Client_BucketsAPI_Call) Run(run func()) *Client_BucketsAPI_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_BucketsAPI_Call) Return(_a0 api.BucketsAPI) *Client_BucketsAPI_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_BucketsAPI_Call) RunAndReturn(run func() api.BucketsAPI) *Client_BucketsAPI_Call { + _c.Call.Return(run) + return _c +} + +// Close provides a mock function with given fields: +func (_m *Client) Close() { + _m.Called() +} + +// Client_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close' +type Client_Close_Call struct { + *mock.Call +} + +// Close is a helper method to define mock.On call +func (_e *Client_Expecter) Close() *Client_Close_Call { + return &Client_Close_Call{Call: _e.mock.On("Close")} +} + +func (_c *Client_Close_Call) Run(run func()) *Client_Close_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_Close_Call) Return() *Client_Close_Call { + _c.Call.Return() + return _c +} + +func (_c *Client_Close_Call) RunAndReturn(run func()) *Client_Close_Call { + _c.Call.Return(run) + return _c +} + +// DeleteAPI provides a mock function with given fields: +func (_m *Client) DeleteAPI() api.DeleteAPI { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for DeleteAPI") + } + + var r0 api.DeleteAPI + if rf, ok := ret.Get(0).(func() api.DeleteAPI); ok { + r0 = rf() + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(api.DeleteAPI) + } + } + + return r0 +} + +// Client_DeleteAPI_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteAPI' +type Client_DeleteAPI_Call struct { + *mock.Call +} + +// DeleteAPI is a helper method to define mock.On call +func (_e *Client_Expecter) DeleteAPI() *Client_DeleteAPI_Call { + return &Client_DeleteAPI_Call{Call: _e.mock.On("DeleteAPI")} +} + +func (_c *Client_DeleteAPI_Call) Run(run func()) *Client_DeleteAPI_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_DeleteAPI_Call) Return(_a0 api.DeleteAPI) *Client_DeleteAPI_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_DeleteAPI_Call) RunAndReturn(run func() api.DeleteAPI) *Client_DeleteAPI_Call { + _c.Call.Return(run) + return _c +} + +// HTTPService provides a mock function with given fields: +func (_m *Client) HTTPService() http.Service { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for HTTPService") + } + + var r0 http.Service + if rf, ok := ret.Get(0).(func() http.Service); ok { + r0 = rf() + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(http.Service) + } + } + + return r0 +} + +// Client_HTTPService_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HTTPService' +type Client_HTTPService_Call struct { + *mock.Call +} + +// HTTPService is a helper method to define mock.On call +func (_e *Client_Expecter) HTTPService() *Client_HTTPService_Call { + return &Client_HTTPService_Call{Call: _e.mock.On("HTTPService")} +} + +func (_c *Client_HTTPService_Call) Run(run func()) *Client_HTTPService_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_HTTPService_Call) Return(_a0 http.Service) *Client_HTTPService_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_HTTPService_Call) RunAndReturn(run func() http.Service) *Client_HTTPService_Call { + _c.Call.Return(run) + return _c +} + +// Health provides a mock function with given fields: ctx +func (_m *Client) Health(ctx context.Context) (*domain.HealthCheck, error) { + ret := _m.Called(ctx) + + if len(ret) == 0 { + panic("no return value specified for Health") + } + + var r0 *domain.HealthCheck + var r1 error + if rf, ok := ret.Get(0).(func(context.Context) (*domain.HealthCheck, error)); ok { + return rf(ctx) + } + if rf, ok := ret.Get(0).(func(context.Context) *domain.HealthCheck); ok { + r0 = rf(ctx) + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(*domain.HealthCheck) + } + } + + if rf, ok := ret.Get(1).(func(context.Context) error); ok { + r1 = rf(ctx) + } else { + r1 = ret.Error(1) + } + + return r0, r1 +} + +// Client_Health_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Health' +type Client_Health_Call struct { + *mock.Call +} + +// Health is a helper method to define mock.On call +// - ctx context.Context +func (_e *Client_Expecter) Health(ctx interface{}) *Client_Health_Call { + return &Client_Health_Call{Call: _e.mock.On("Health", ctx)} +} + +func (_c *Client_Health_Call) Run(run func(ctx context.Context)) *Client_Health_Call { + _c.Call.Run(func(args mock.Arguments) { + run(args[0].(context.Context)) + }) + return _c +} + +func (_c *Client_Health_Call) Return(_a0 *domain.HealthCheck, _a1 error) *Client_Health_Call { + _c.Call.Return(_a0, _a1) + return _c +} + +func (_c *Client_Health_Call) RunAndReturn(run func(context.Context) (*domain.HealthCheck, error)) *Client_Health_Call { + _c.Call.Return(run) + return _c +} + +// LabelsAPI provides a mock function with given fields: +func (_m *Client) LabelsAPI() api.LabelsAPI { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for LabelsAPI") + } + + var r0 api.LabelsAPI + if rf, ok := ret.Get(0).(func() api.LabelsAPI); ok { + r0 = rf() + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(api.LabelsAPI) + } + } + + return r0 +} + +// Client_LabelsAPI_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LabelsAPI' +type Client_LabelsAPI_Call struct { + *mock.Call +} + +// LabelsAPI is a helper method to define mock.On call +func (_e *Client_Expecter) LabelsAPI() *Client_LabelsAPI_Call { + return &Client_LabelsAPI_Call{Call: _e.mock.On("LabelsAPI")} +} + +func (_c *Client_LabelsAPI_Call) Run(run func()) *Client_LabelsAPI_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_LabelsAPI_Call) Return(_a0 api.LabelsAPI) *Client_LabelsAPI_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_LabelsAPI_Call) RunAndReturn(run func() api.LabelsAPI) *Client_LabelsAPI_Call { + _c.Call.Return(run) + return _c +} + +// Options provides a mock function with given fields: +func (_m *Client) Options() *influxdb2.Options { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for Options") + } + + var r0 *influxdb2.Options + if rf, ok := ret.Get(0).(func() *influxdb2.Options); ok { + r0 = rf() + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(*influxdb2.Options) + } + } + + return r0 +} + +// Client_Options_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Options' +type Client_Options_Call struct { + *mock.Call +} + +// Options is a helper method to define mock.On call +func (_e *Client_Expecter) Options() *Client_Options_Call { + return &Client_Options_Call{Call: _e.mock.On("Options")} +} + +func (_c *Client_Options_Call) Run(run func()) *Client_Options_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_Options_Call) Return(_a0 *influxdb2.Options) *Client_Options_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_Options_Call) RunAndReturn(run func() *influxdb2.Options) *Client_Options_Call { + _c.Call.Return(run) + return _c +} + +// OrganizationsAPI provides a mock function with given fields: +func (_m *Client) OrganizationsAPI() api.OrganizationsAPI { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for OrganizationsAPI") + } + + var r0 api.OrganizationsAPI + if rf, ok := ret.Get(0).(func() api.OrganizationsAPI); ok { + r0 = rf() + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(api.OrganizationsAPI) + } + } + + return r0 +} + +// Client_OrganizationsAPI_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OrganizationsAPI' +type Client_OrganizationsAPI_Call struct { + *mock.Call +} + +// OrganizationsAPI is a helper method to define mock.On call +func (_e *Client_Expecter) OrganizationsAPI() *Client_OrganizationsAPI_Call { + return &Client_OrganizationsAPI_Call{Call: _e.mock.On("OrganizationsAPI")} +} + +func (_c *Client_OrganizationsAPI_Call) Run(run func()) *Client_OrganizationsAPI_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_OrganizationsAPI_Call) Return(_a0 api.OrganizationsAPI) *Client_OrganizationsAPI_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_OrganizationsAPI_Call) RunAndReturn(run func() api.OrganizationsAPI) *Client_OrganizationsAPI_Call { + _c.Call.Return(run) + return _c +} + +// Ping provides a mock function with given fields: ctx +func (_m *Client) Ping(ctx context.Context) (bool, error) { + ret := _m.Called(ctx) + + if len(ret) == 0 { + panic("no return value specified for Ping") + } + + var r0 bool + var r1 error + if rf, ok := ret.Get(0).(func(context.Context) (bool, error)); ok { + return rf(ctx) + } + if rf, ok := ret.Get(0).(func(context.Context) bool); ok { + r0 = rf(ctx) + } else { + r0 = ret.Get(0).(bool) + } + + if rf, ok := ret.Get(1).(func(context.Context) error); ok { + r1 = rf(ctx) + } else { + r1 = ret.Error(1) + } + + return r0, r1 +} + +// Client_Ping_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ping' +type Client_Ping_Call struct { + *mock.Call +} + +// Ping is a helper method to define mock.On call +// - ctx context.Context +func (_e *Client_Expecter) Ping(ctx interface{}) *Client_Ping_Call { + return &Client_Ping_Call{Call: _e.mock.On("Ping", ctx)} +} + +func (_c *Client_Ping_Call) Run(run func(ctx context.Context)) *Client_Ping_Call { + _c.Call.Run(func(args mock.Arguments) { + run(args[0].(context.Context)) + }) + return _c +} + +func (_c *Client_Ping_Call) Return(_a0 bool, _a1 error) *Client_Ping_Call { + _c.Call.Return(_a0, _a1) + return _c +} + +func (_c *Client_Ping_Call) RunAndReturn(run func(context.Context) (bool, error)) *Client_Ping_Call { + _c.Call.Return(run) + return _c +} + +// QueryAPI provides a mock function with given fields: org +func (_m *Client) QueryAPI(org string) api.QueryAPI { + ret := _m.Called(org) + + if len(ret) == 0 { + panic("no return value specified for QueryAPI") + } + + var r0 api.QueryAPI + if rf, ok := ret.Get(0).(func(string) api.QueryAPI); ok { + r0 = rf(org) + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(api.QueryAPI) + } + } + + return r0 +} + +// Client_QueryAPI_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QueryAPI' +type Client_QueryAPI_Call struct { + *mock.Call +} + +// QueryAPI is a helper method to define mock.On call +// - org string +func (_e *Client_Expecter) QueryAPI(org interface{}) *Client_QueryAPI_Call { + return &Client_QueryAPI_Call{Call: _e.mock.On("QueryAPI", org)} +} + +func (_c *Client_QueryAPI_Call) Run(run func(org string)) *Client_QueryAPI_Call { + _c.Call.Run(func(args mock.Arguments) { + run(args[0].(string)) + }) + return _c +} + +func (_c *Client_QueryAPI_Call) Return(_a0 api.QueryAPI) *Client_QueryAPI_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_QueryAPI_Call) RunAndReturn(run func(string) api.QueryAPI) *Client_QueryAPI_Call { + _c.Call.Return(run) + return _c +} + +// Ready provides a mock function with given fields: ctx +func (_m *Client) Ready(ctx context.Context) (*domain.Ready, error) { + ret := _m.Called(ctx) + + if len(ret) == 0 { + panic("no return value specified for Ready") + } + + var r0 *domain.Ready + var r1 error + if rf, ok := ret.Get(0).(func(context.Context) (*domain.Ready, error)); ok { + return rf(ctx) + } + if rf, ok := ret.Get(0).(func(context.Context) *domain.Ready); ok { + r0 = rf(ctx) + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(*domain.Ready) + } + } + + if rf, ok := ret.Get(1).(func(context.Context) error); ok { + r1 = rf(ctx) + } else { + r1 = ret.Error(1) + } + + return r0, r1 +} + +// Client_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready' +type Client_Ready_Call struct { + *mock.Call +} + +// Ready is a helper method to define mock.On call +// - ctx context.Context +func (_e *Client_Expecter) Ready(ctx interface{}) *Client_Ready_Call { + return &Client_Ready_Call{Call: _e.mock.On("Ready", ctx)} +} + +func (_c *Client_Ready_Call) Run(run func(ctx context.Context)) *Client_Ready_Call { + _c.Call.Run(func(args mock.Arguments) { + run(args[0].(context.Context)) + }) + return _c +} + +func (_c *Client_Ready_Call) Return(_a0 *domain.Ready, _a1 error) *Client_Ready_Call { + _c.Call.Return(_a0, _a1) + return _c +} + +func (_c *Client_Ready_Call) RunAndReturn(run func(context.Context) (*domain.Ready, error)) *Client_Ready_Call { + _c.Call.Return(run) + return _c +} + +// ServerURL provides a mock function with given fields: +func (_m *Client) ServerURL() string { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for ServerURL") + } + + var r0 string + if rf, ok := ret.Get(0).(func() string); ok { + r0 = rf() + } else { + r0 = ret.Get(0).(string) + } + + return r0 +} + +// Client_ServerURL_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ServerURL' +type Client_ServerURL_Call struct { + *mock.Call +} + +// ServerURL is a helper method to define mock.On call +func (_e *Client_Expecter) ServerURL() *Client_ServerURL_Call { + return &Client_ServerURL_Call{Call: _e.mock.On("ServerURL")} +} + +func (_c *Client_ServerURL_Call) Run(run func()) *Client_ServerURL_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_ServerURL_Call) Return(_a0 string) *Client_ServerURL_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_ServerURL_Call) RunAndReturn(run func() string) *Client_ServerURL_Call { + _c.Call.Return(run) + return _c +} + +// Setup provides a mock function with given fields: ctx, username, password, org, bucket, retentionPeriodHours +func (_m *Client) Setup(ctx context.Context, username string, password string, org string, bucket string, retentionPeriodHours int) (*domain.OnboardingResponse, error) { + ret := _m.Called(ctx, username, password, org, bucket, retentionPeriodHours) + + if len(ret) == 0 { + panic("no return value specified for Setup") + } + + var r0 *domain.OnboardingResponse + var r1 error + if rf, ok := ret.Get(0).(func(context.Context, string, string, string, string, int) (*domain.OnboardingResponse, error)); ok { + return rf(ctx, username, password, org, bucket, retentionPeriodHours) + } + if rf, ok := ret.Get(0).(func(context.Context, string, string, string, string, int) *domain.OnboardingResponse); ok { + r0 = rf(ctx, username, password, org, bucket, retentionPeriodHours) + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(*domain.OnboardingResponse) + } + } + + if rf, ok := ret.Get(1).(func(context.Context, string, string, string, string, int) error); ok { + r1 = rf(ctx, username, password, org, bucket, retentionPeriodHours) + } else { + r1 = ret.Error(1) + } + + return r0, r1 +} + +// Client_Setup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Setup' +type Client_Setup_Call struct { + *mock.Call +} + +// Setup is a helper method to define mock.On call +// - ctx context.Context +// - username string +// - password string +// - org string +// - bucket string +// - retentionPeriodHours int +func (_e *Client_Expecter) Setup(ctx interface{}, username interface{}, password interface{}, org interface{}, bucket interface{}, retentionPeriodHours interface{}) *Client_Setup_Call { + return &Client_Setup_Call{Call: _e.mock.On("Setup", ctx, username, password, org, bucket, retentionPeriodHours)} +} + +func (_c *Client_Setup_Call) Run(run func(ctx context.Context, username string, password string, org string, bucket string, retentionPeriodHours int)) *Client_Setup_Call { + _c.Call.Run(func(args mock.Arguments) { + run(args[0].(context.Context), args[1].(string), args[2].(string), args[3].(string), args[4].(string), args[5].(int)) + }) + return _c +} + +func (_c *Client_Setup_Call) Return(_a0 *domain.OnboardingResponse, _a1 error) *Client_Setup_Call { + _c.Call.Return(_a0, _a1) + return _c +} + +func (_c *Client_Setup_Call) RunAndReturn(run func(context.Context, string, string, string, string, int) (*domain.OnboardingResponse, error)) *Client_Setup_Call { + _c.Call.Return(run) + return _c +} + +// SetupWithToken provides a mock function with given fields: ctx, username, password, org, bucket, retentionPeriodHours, token +func (_m *Client) SetupWithToken(ctx context.Context, username string, password string, org string, bucket string, retentionPeriodHours int, token string) (*domain.OnboardingResponse, error) { + ret := _m.Called(ctx, username, password, org, bucket, retentionPeriodHours, token) + + if len(ret) == 0 { + panic("no return value specified for SetupWithToken") + } + + var r0 *domain.OnboardingResponse + var r1 error + if rf, ok := ret.Get(0).(func(context.Context, string, string, string, string, int, string) (*domain.OnboardingResponse, error)); ok { + return rf(ctx, username, password, org, bucket, retentionPeriodHours, token) + } + if rf, ok := ret.Get(0).(func(context.Context, string, string, string, string, int, string) *domain.OnboardingResponse); ok { + r0 = rf(ctx, username, password, org, bucket, retentionPeriodHours, token) + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(*domain.OnboardingResponse) + } + } + + if rf, ok := ret.Get(1).(func(context.Context, string, string, string, string, int, string) error); ok { + r1 = rf(ctx, username, password, org, bucket, retentionPeriodHours, token) + } else { + r1 = ret.Error(1) + } + + return r0, r1 +} + +// Client_SetupWithToken_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetupWithToken' +type Client_SetupWithToken_Call struct { + *mock.Call +} + +// SetupWithToken is a helper method to define mock.On call +// - ctx context.Context +// - username string +// - password string +// - org string +// - bucket string +// - retentionPeriodHours int +// - token string +func (_e *Client_Expecter) SetupWithToken(ctx interface{}, username interface{}, password interface{}, org interface{}, bucket interface{}, retentionPeriodHours interface{}, token interface{}) *Client_SetupWithToken_Call { + return &Client_SetupWithToken_Call{Call: _e.mock.On("SetupWithToken", ctx, username, password, org, bucket, retentionPeriodHours, token)} +} + +func (_c *Client_SetupWithToken_Call) Run(run func(ctx context.Context, username string, password string, org string, bucket string, retentionPeriodHours int, token string)) *Client_SetupWithToken_Call { + _c.Call.Run(func(args mock.Arguments) { + run(args[0].(context.Context), args[1].(string), args[2].(string), args[3].(string), args[4].(string), args[5].(int), args[6].(string)) + }) + return _c +} + +func (_c *Client_SetupWithToken_Call) Return(_a0 *domain.OnboardingResponse, _a1 error) *Client_SetupWithToken_Call { + _c.Call.Return(_a0, _a1) + return _c +} + +func (_c *Client_SetupWithToken_Call) RunAndReturn(run func(context.Context, string, string, string, string, int, string) (*domain.OnboardingResponse, error)) *Client_SetupWithToken_Call { + _c.Call.Return(run) + return _c +} + +// TasksAPI provides a mock function with given fields: +func (_m *Client) TasksAPI() api.TasksAPI { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for TasksAPI") + } + + var r0 api.TasksAPI + if rf, ok := ret.Get(0).(func() api.TasksAPI); ok { + r0 = rf() + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(api.TasksAPI) + } + } + + return r0 +} + +// Client_TasksAPI_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TasksAPI' +type Client_TasksAPI_Call struct { + *mock.Call +} + +// TasksAPI is a helper method to define mock.On call +func (_e *Client_Expecter) TasksAPI() *Client_TasksAPI_Call { + return &Client_TasksAPI_Call{Call: _e.mock.On("TasksAPI")} +} + +func (_c *Client_TasksAPI_Call) Run(run func()) *Client_TasksAPI_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_TasksAPI_Call) Return(_a0 api.TasksAPI) *Client_TasksAPI_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_TasksAPI_Call) RunAndReturn(run func() api.TasksAPI) *Client_TasksAPI_Call { + _c.Call.Return(run) + return _c +} + +// UsersAPI provides a mock function with given fields: +func (_m *Client) UsersAPI() api.UsersAPI { + ret := _m.Called() + + if len(ret) == 0 { + panic("no return value specified for UsersAPI") + } + + var r0 api.UsersAPI + if rf, ok := ret.Get(0).(func() api.UsersAPI); ok { + r0 = rf() + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(api.UsersAPI) + } + } + + return r0 +} + +// Client_UsersAPI_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UsersAPI' +type Client_UsersAPI_Call struct { + *mock.Call +} + +// UsersAPI is a helper method to define mock.On call +func (_e *Client_Expecter) UsersAPI() *Client_UsersAPI_Call { + return &Client_UsersAPI_Call{Call: _e.mock.On("UsersAPI")} +} + +func (_c *Client_UsersAPI_Call) Run(run func()) *Client_UsersAPI_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *Client_UsersAPI_Call) Return(_a0 api.UsersAPI) *Client_UsersAPI_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_UsersAPI_Call) RunAndReturn(run func() api.UsersAPI) *Client_UsersAPI_Call { + _c.Call.Return(run) + return _c +} + +// WriteAPI provides a mock function with given fields: org, bucket +func (_m *Client) WriteAPI(org string, bucket string) api.WriteAPI { + ret := _m.Called(org, bucket) + + if len(ret) == 0 { + panic("no return value specified for WriteAPI") + } + + var r0 api.WriteAPI + if rf, ok := ret.Get(0).(func(string, string) api.WriteAPI); ok { + r0 = rf(org, bucket) + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(api.WriteAPI) + } + } + + return r0 +} + +// Client_WriteAPI_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WriteAPI' +type Client_WriteAPI_Call struct { + *mock.Call +} + +// WriteAPI is a helper method to define mock.On call +// - org string +// - bucket string +func (_e *Client_Expecter) WriteAPI(org interface{}, bucket interface{}) *Client_WriteAPI_Call { + return &Client_WriteAPI_Call{Call: _e.mock.On("WriteAPI", org, bucket)} +} + +func (_c *Client_WriteAPI_Call) Run(run func(org string, bucket string)) *Client_WriteAPI_Call { + _c.Call.Run(func(args mock.Arguments) { + run(args[0].(string), args[1].(string)) + }) + return _c +} + +func (_c *Client_WriteAPI_Call) Return(_a0 api.WriteAPI) *Client_WriteAPI_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_WriteAPI_Call) RunAndReturn(run func(string, string) api.WriteAPI) *Client_WriteAPI_Call { + _c.Call.Return(run) + return _c +} + +// WriteAPIBlocking provides a mock function with given fields: org, bucket +func (_m *Client) WriteAPIBlocking(org string, bucket string) api.WriteAPIBlocking { + ret := _m.Called(org, bucket) + + if len(ret) == 0 { + panic("no return value specified for WriteAPIBlocking") + } + + var r0 api.WriteAPIBlocking + if rf, ok := ret.Get(0).(func(string, string) api.WriteAPIBlocking); ok { + r0 = rf(org, bucket) + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(api.WriteAPIBlocking) + } + } + + return r0 +} + +// Client_WriteAPIBlocking_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WriteAPIBlocking' +type Client_WriteAPIBlocking_Call struct { + *mock.Call +} + +// WriteAPIBlocking is a helper method to define mock.On call +// - org string +// - bucket string +func (_e *Client_Expecter) WriteAPIBlocking(org interface{}, bucket interface{}) *Client_WriteAPIBlocking_Call { + return &Client_WriteAPIBlocking_Call{Call: _e.mock.On("WriteAPIBlocking", org, bucket)} +} + +func (_c *Client_WriteAPIBlocking_Call) Run(run func(org string, bucket string)) *Client_WriteAPIBlocking_Call { + _c.Call.Run(func(args mock.Arguments) { + run(args[0].(string), args[1].(string)) + }) + return _c +} + +func (_c *Client_WriteAPIBlocking_Call) Return(_a0 api.WriteAPIBlocking) *Client_WriteAPIBlocking_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *Client_WriteAPIBlocking_Call) RunAndReturn(run func(string, string) api.WriteAPIBlocking) *Client_WriteAPIBlocking_Call { + _c.Call.Return(run) + return _c +} + +// NewClient creates a new instance of Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. +// The first argument is typically a *testing.T value. +func NewClient(t interface { + mock.TestingT + Cleanup(func()) +}) *Client { + mock := &Client{} + mock.Mock.Test(t) + + t.Cleanup(func() { mock.AssertExpectations(t) }) + + return mock +} diff --git a/pkg/influx/mocks/WriteAPIBlocking.go b/pkg/influx/mocks/WriteAPIBlocking.go new file mode 100644 index 0000000000..bf2549831f --- /dev/null +++ b/pkg/influx/mocks/WriteAPIBlocking.go @@ -0,0 +1,237 @@ +// Code generated by mockery v2.40.1. DO NOT EDIT. + +package mocks + +import ( + context "context" + + write "github.com/influxdata/influxdb-client-go/v2/api/write" + mock "github.com/stretchr/testify/mock" +) + +// WriteAPIBlocking is an autogenerated mock type for the WriteAPIBlocking type +type WriteAPIBlocking struct { + mock.Mock +} + +type WriteAPIBlocking_Expecter struct { + mock *mock.Mock +} + +func (_m *WriteAPIBlocking) EXPECT() *WriteAPIBlocking_Expecter { + return &WriteAPIBlocking_Expecter{mock: &_m.Mock} +} + +// EnableBatching provides a mock function with given fields: +func (_m *WriteAPIBlocking) EnableBatching() { + _m.Called() +} + +// WriteAPIBlocking_EnableBatching_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnableBatching' +type WriteAPIBlocking_EnableBatching_Call struct { + *mock.Call +} + +// EnableBatching is a helper method to define mock.On call +func (_e *WriteAPIBlocking_Expecter) EnableBatching() *WriteAPIBlocking_EnableBatching_Call { + return &WriteAPIBlocking_EnableBatching_Call{Call: _e.mock.On("EnableBatching")} +} + +func (_c *WriteAPIBlocking_EnableBatching_Call) Run(run func()) *WriteAPIBlocking_EnableBatching_Call { + _c.Call.Run(func(args mock.Arguments) { + run() + }) + return _c +} + +func (_c *WriteAPIBlocking_EnableBatching_Call) Return() *WriteAPIBlocking_EnableBatching_Call { + _c.Call.Return() + return _c +} + +func (_c *WriteAPIBlocking_EnableBatching_Call) RunAndReturn(run func()) *WriteAPIBlocking_EnableBatching_Call { + _c.Call.Return(run) + return _c +} + +// Flush provides a mock function with given fields: ctx +func (_m *WriteAPIBlocking) Flush(ctx context.Context) error { + ret := _m.Called(ctx) + + if len(ret) == 0 { + panic("no return value specified for Flush") + } + + var r0 error + if rf, ok := ret.Get(0).(func(context.Context) error); ok { + r0 = rf(ctx) + } else { + r0 = ret.Error(0) + } + + return r0 +} + +// WriteAPIBlocking_Flush_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Flush' +type WriteAPIBlocking_Flush_Call struct { + *mock.Call +} + +// Flush is a helper method to define mock.On call +// - ctx context.Context +func (_e *WriteAPIBlocking_Expecter) Flush(ctx interface{}) *WriteAPIBlocking_Flush_Call { + return &WriteAPIBlocking_Flush_Call{Call: _e.mock.On("Flush", ctx)} +} + +func (_c *WriteAPIBlocking_Flush_Call) Run(run func(ctx context.Context)) *WriteAPIBlocking_Flush_Call { + _c.Call.Run(func(args mock.Arguments) { + run(args[0].(context.Context)) + }) + return _c +} + +func (_c *WriteAPIBlocking_Flush_Call) Return(_a0 error) *WriteAPIBlocking_Flush_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *WriteAPIBlocking_Flush_Call) RunAndReturn(run func(context.Context) error) *WriteAPIBlocking_Flush_Call { + _c.Call.Return(run) + return _c +} + +// WritePoint provides a mock function with given fields: ctx, point +func (_m *WriteAPIBlocking) WritePoint(ctx context.Context, point ...*write.Point) error { + _va := make([]interface{}, len(point)) + for _i := range point { + _va[_i] = point[_i] + } + var _ca []interface{} + _ca = append(_ca, ctx) + _ca = append(_ca, _va...) + ret := _m.Called(_ca...) + + if len(ret) == 0 { + panic("no return value specified for WritePoint") + } + + var r0 error + if rf, ok := ret.Get(0).(func(context.Context, ...*write.Point) error); ok { + r0 = rf(ctx, point...) + } else { + r0 = ret.Error(0) + } + + return r0 +} + +// WriteAPIBlocking_WritePoint_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WritePoint' +type WriteAPIBlocking_WritePoint_Call struct { + *mock.Call +} + +// WritePoint is a helper method to define mock.On call +// - ctx context.Context +// - point ...*write.Point +func (_e *WriteAPIBlocking_Expecter) WritePoint(ctx interface{}, point ...interface{}) *WriteAPIBlocking_WritePoint_Call { + return &WriteAPIBlocking_WritePoint_Call{Call: _e.mock.On("WritePoint", + append([]interface{}{ctx}, point...)...)} +} + +func (_c *WriteAPIBlocking_WritePoint_Call) Run(run func(ctx context.Context, point ...*write.Point)) *WriteAPIBlocking_WritePoint_Call { + _c.Call.Run(func(args mock.Arguments) { + variadicArgs := make([]*write.Point, len(args)-1) + for i, a := range args[1:] { + if a != nil { + variadicArgs[i] = a.(*write.Point) + } + } + run(args[0].(context.Context), variadicArgs...) + }) + return _c +} + +func (_c *WriteAPIBlocking_WritePoint_Call) Return(_a0 error) *WriteAPIBlocking_WritePoint_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *WriteAPIBlocking_WritePoint_Call) RunAndReturn(run func(context.Context, ...*write.Point) error) *WriteAPIBlocking_WritePoint_Call { + _c.Call.Return(run) + return _c +} + +// WriteRecord provides a mock function with given fields: ctx, line +func (_m *WriteAPIBlocking) WriteRecord(ctx context.Context, line ...string) error { + _va := make([]interface{}, len(line)) + for _i := range line { + _va[_i] = line[_i] + } + var _ca []interface{} + _ca = append(_ca, ctx) + _ca = append(_ca, _va...) + ret := _m.Called(_ca...) + + if len(ret) == 0 { + panic("no return value specified for WriteRecord") + } + + var r0 error + if rf, ok := ret.Get(0).(func(context.Context, ...string) error); ok { + r0 = rf(ctx, line...) + } else { + r0 = ret.Error(0) + } + + return r0 +} + +// WriteAPIBlocking_WriteRecord_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WriteRecord' +type WriteAPIBlocking_WriteRecord_Call struct { + *mock.Call +} + +// WriteRecord is a helper method to define mock.On call +// - ctx context.Context +// - line ...string +func (_e *WriteAPIBlocking_Expecter) WriteRecord(ctx interface{}, line ...interface{}) *WriteAPIBlocking_WriteRecord_Call { + return &WriteAPIBlocking_WriteRecord_Call{Call: _e.mock.On("WriteRecord", + append([]interface{}{ctx}, line...)...)} +} + +func (_c *WriteAPIBlocking_WriteRecord_Call) Run(run func(ctx context.Context, line ...string)) *WriteAPIBlocking_WriteRecord_Call { + _c.Call.Run(func(args mock.Arguments) { + variadicArgs := make([]string, len(args)-1) + for i, a := range args[1:] { + if a != nil { + variadicArgs[i] = a.(string) + } + } + run(args[0].(context.Context), variadicArgs...) + }) + return _c +} + +func (_c *WriteAPIBlocking_WriteRecord_Call) Return(_a0 error) *WriteAPIBlocking_WriteRecord_Call { + _c.Call.Return(_a0) + return _c +} + +func (_c *WriteAPIBlocking_WriteRecord_Call) RunAndReturn(run func(context.Context, ...string) error) *WriteAPIBlocking_WriteRecord_Call { + _c.Call.Return(run) + return _c +} + +// NewWriteAPIBlocking creates a new instance of WriteAPIBlocking. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. +// The first argument is typically a *testing.T value. +func NewWriteAPIBlocking(t interface { + mock.TestingT + Cleanup(func()) +}) *WriteAPIBlocking { + mock := &WriteAPIBlocking{} + mock.Mock.Test(t) + + t.Cleanup(func() { mock.AssertExpectations(t) }) + + return mock +} diff --git a/pkg/influx/mocks/client.go b/pkg/influx/mocks/client.go deleted file mode 100644 index 969e2cbaf4..0000000000 --- a/pkg/influx/mocks/client.go +++ /dev/null @@ -1,300 +0,0 @@ -// Code generated by mockery v2.7.4. DO NOT EDIT. - -package mocks - -import ( - context "context" - - api "github.com/influxdata/influxdb-client-go/v2/api" - - domain "github.com/influxdata/influxdb-client-go/v2/domain" - - http "github.com/influxdata/influxdb-client-go/v2/api/http" - - influxdb2 "github.com/influxdata/influxdb-client-go/v2" - - mock "github.com/stretchr/testify/mock" -) - -// Client is an autogenerated mock type for the Client type -type Client struct { - mock.Mock -} - -// AuthorizationsAPI provides a mock function with given fields: -func (_m *Client) AuthorizationsAPI() api.AuthorizationsAPI { - ret := _m.Called() - - var r0 api.AuthorizationsAPI - if rf, ok := ret.Get(0).(func() api.AuthorizationsAPI); ok { - r0 = rf() - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(api.AuthorizationsAPI) - } - } - - return r0 -} - -// BucketsAPI provides a mock function with given fields: -func (_m *Client) BucketsAPI() api.BucketsAPI { - ret := _m.Called() - - var r0 api.BucketsAPI - if rf, ok := ret.Get(0).(func() api.BucketsAPI); ok { - r0 = rf() - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(api.BucketsAPI) - } - } - - return r0 -} - -// Close provides a mock function with given fields: -func (_m *Client) Close() { - _m.Called() -} - -// DeleteAPI provides a mock function with given fields: -func (_m *Client) DeleteAPI() api.DeleteAPI { - ret := _m.Called() - - var r0 api.DeleteAPI - if rf, ok := ret.Get(0).(func() api.DeleteAPI); ok { - r0 = rf() - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(api.DeleteAPI) - } - } - - return r0 -} - -// HTTPService provides a mock function with given fields: -func (_m *Client) HTTPService() http.Service { - ret := _m.Called() - - var r0 http.Service - if rf, ok := ret.Get(0).(func() http.Service); ok { - r0 = rf() - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(http.Service) - } - } - - return r0 -} - -// Health provides a mock function with given fields: ctx -func (_m *Client) Health(ctx context.Context) (*domain.HealthCheck, error) { - ret := _m.Called(ctx) - - var r0 *domain.HealthCheck - if rf, ok := ret.Get(0).(func(context.Context) *domain.HealthCheck); ok { - r0 = rf(ctx) - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(*domain.HealthCheck) - } - } - - var r1 error - if rf, ok := ret.Get(1).(func(context.Context) error); ok { - r1 = rf(ctx) - } else { - r1 = ret.Error(1) - } - - return r0, r1 -} - -// LabelsAPI provides a mock function with given fields: -func (_m *Client) LabelsAPI() api.LabelsAPI { - ret := _m.Called() - - var r0 api.LabelsAPI - if rf, ok := ret.Get(0).(func() api.LabelsAPI); ok { - r0 = rf() - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(api.LabelsAPI) - } - } - - return r0 -} - -// Options provides a mock function with given fields: -func (_m *Client) Options() *influxdb2.Options { - ret := _m.Called() - - var r0 *influxdb2.Options - if rf, ok := ret.Get(0).(func() *influxdb2.Options); ok { - r0 = rf() - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(*influxdb2.Options) - } - } - - return r0 -} - -// OrganizationsAPI provides a mock function with given fields: -func (_m *Client) OrganizationsAPI() api.OrganizationsAPI { - ret := _m.Called() - - var r0 api.OrganizationsAPI - if rf, ok := ret.Get(0).(func() api.OrganizationsAPI); ok { - r0 = rf() - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(api.OrganizationsAPI) - } - } - - return r0 -} - -// QueryAPI provides a mock function with given fields: org -func (_m *Client) QueryAPI(org string) api.QueryAPI { - ret := _m.Called(org) - - var r0 api.QueryAPI - if rf, ok := ret.Get(0).(func(string) api.QueryAPI); ok { - r0 = rf(org) - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(api.QueryAPI) - } - } - - return r0 -} - -// Ready provides a mock function with given fields: ctx -func (_m *Client) Ready(ctx context.Context) (bool, error) { - ret := _m.Called(ctx) - - var r0 bool - if rf, ok := ret.Get(0).(func(context.Context) bool); ok { - r0 = rf(ctx) - } else { - r0 = ret.Get(0).(bool) - } - - var r1 error - if rf, ok := ret.Get(1).(func(context.Context) error); ok { - r1 = rf(ctx) - } else { - r1 = ret.Error(1) - } - - return r0, r1 -} - -// ServerURL provides a mock function with given fields: -func (_m *Client) ServerURL() string { - ret := _m.Called() - - var r0 string - if rf, ok := ret.Get(0).(func() string); ok { - r0 = rf() - } else { - r0 = ret.Get(0).(string) - } - - return r0 -} - -// Setup provides a mock function with given fields: ctx, username, password, org, bucket, retentionPeriodHours -func (_m *Client) Setup(ctx context.Context, username string, password string, org string, bucket string, retentionPeriodHours int) (*domain.OnboardingResponse, error) { - ret := _m.Called(ctx, username, password, org, bucket, retentionPeriodHours) - - var r0 *domain.OnboardingResponse - if rf, ok := ret.Get(0).(func(context.Context, string, string, string, string, int) *domain.OnboardingResponse); ok { - r0 = rf(ctx, username, password, org, bucket, retentionPeriodHours) - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(*domain.OnboardingResponse) - } - } - - var r1 error - if rf, ok := ret.Get(1).(func(context.Context, string, string, string, string, int) error); ok { - r1 = rf(ctx, username, password, org, bucket, retentionPeriodHours) - } else { - r1 = ret.Error(1) - } - - return r0, r1 -} - -// TasksAPI provides a mock function with given fields: -func (_m *Client) TasksAPI() api.TasksAPI { - ret := _m.Called() - - var r0 api.TasksAPI - if rf, ok := ret.Get(0).(func() api.TasksAPI); ok { - r0 = rf() - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(api.TasksAPI) - } - } - - return r0 -} - -// UsersAPI provides a mock function with given fields: -func (_m *Client) UsersAPI() api.UsersAPI { - ret := _m.Called() - - var r0 api.UsersAPI - if rf, ok := ret.Get(0).(func() api.UsersAPI); ok { - r0 = rf() - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(api.UsersAPI) - } - } - - return r0 -} - -// WriteAPI provides a mock function with given fields: org, bucket -func (_m *Client) WriteAPI(org string, bucket string) api.WriteAPI { - ret := _m.Called(org, bucket) - - var r0 api.WriteAPI - if rf, ok := ret.Get(0).(func(string, string) api.WriteAPI); ok { - r0 = rf(org, bucket) - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(api.WriteAPI) - } - } - - return r0 -} - -// WriteAPIBlocking provides a mock function with given fields: org, bucket -func (_m *Client) WriteAPIBlocking(org string, bucket string) api.WriteAPIBlocking { - ret := _m.Called(org, bucket) - - var r0 api.WriteAPIBlocking - if rf, ok := ret.Get(0).(func(string, string) api.WriteAPIBlocking); ok { - r0 = rf(org, bucket) - } else { - if ret.Get(0) != nil { - r0 = ret.Get(0).(api.WriteAPIBlocking) - } - } - - return r0 -} diff --git a/pkg/influx/mocks/writeAPIBlocking.go b/pkg/influx/mocks/writeAPIBlocking.go deleted file mode 100644 index d95c53f816..0000000000 --- a/pkg/influx/mocks/writeAPIBlocking.go +++ /dev/null @@ -1,57 +0,0 @@ -// Code generated by mockery v2.7.4. DO NOT EDIT. - -package mocks - -import ( - context "context" - - write "github.com/influxdata/influxdb-client-go/v2/api/write" - mock "github.com/stretchr/testify/mock" -) - -// WriteAPIBlocking is an autogenerated mock type for the WriteAPIBlocking type -type WriteAPIBlocking struct { - mock.Mock -} - -// WritePoint provides a mock function with given fields: ctx, point -func (_m *WriteAPIBlocking) WritePoint(ctx context.Context, point ...*write.Point) error { - _va := make([]interface{}, len(point)) - for _i := range point { - _va[_i] = point[_i] - } - var _ca []interface{} - _ca = append(_ca, ctx) - _ca = append(_ca, _va...) - ret := _m.Called(_ca...) - - var r0 error - if rf, ok := ret.Get(0).(func(context.Context, ...*write.Point) error); ok { - r0 = rf(ctx, point...) - } else { - r0 = ret.Error(0) - } - - return r0 -} - -// WriteRecord provides a mock function with given fields: ctx, line -func (_m *WriteAPIBlocking) WriteRecord(ctx context.Context, line ...string) error { - _va := make([]interface{}, len(line)) - for _i := range line { - _va[_i] = line[_i] - } - var _ca []interface{} - _ca = append(_ca, ctx) - _ca = append(_ca, _va...) - ret := _m.Called(_ca...) - - var r0 error - if rf, ok := ret.Get(0).(func(context.Context, ...string) error); ok { - r0 = rf(ctx, line...) - } else { - r0 = ret.Error(0) - } - - return r0 -}