diff --git a/.helm/templates/deployment-api.yaml b/.helm/templates/deployment-api.yaml index 85fc278..687df34 100644 --- a/.helm/templates/deployment-api.yaml +++ b/.helm/templates/deployment-api.yaml @@ -12,6 +12,8 @@ spec: role: api template: metadata: + annotations: + sidecar.opentelemetry.io/inject: "true" labels: {{- include "jiraclick.selectorLabels" . | nindent 8 }} role: api @@ -36,10 +38,18 @@ spec: {{ include "jiraclick.common_env" . | nindent 12 }} - name: HTTPHANDLER_PORT value: "8080" + - name: METRICS_PORT + value: "9090" + envFrom: + - configMapRef: + name: opentelemetry-config ports: - name: http-handler containerPort: 8080 protocol: TCP + - name: http-metrics + containerPort: 9090 + protocol: TCP livenessProbe: httpGet: path: /health-check diff --git a/.helm/templates/deployment-worker.yaml b/.helm/templates/deployment-worker.yaml index 43e4017..f41337d 100644 --- a/.helm/templates/deployment-worker.yaml +++ b/.helm/templates/deployment-worker.yaml @@ -12,6 +12,8 @@ spec: role: worker template: metadata: + annotations: + sidecar.opentelemetry.io/inject: "true" labels: {{- include "jiraclick.selectorLabels" . | nindent 8 }} role: worker @@ -34,6 +36,15 @@ spec: - worker env: {{ include "jiraclick.common_env" . | nindent 12 }} + - name: METRICS_PORT + value: "9090" + envFrom: + - configMapRef: + name: opentelemetry-config + ports: + - name: http-metrics + containerPort: 9090 + protocol: TCP resources: {{- toYaml .Values.resources | nindent 12 }} {{- with .Values.nodeSelector }} diff --git a/.helm/templates/service.yaml b/.helm/templates/service.yaml index 1899f47..e3d1785 100644 --- a/.helm/templates/service.yaml +++ b/.helm/templates/service.yaml @@ -11,6 +11,10 @@ spec: targetPort: http-handler protocol: TCP name: http-handler + - port: 9090 + targetPort: http-metrics + protocol: TCP + name: http-metrics selector: {{- include "jiraclick.selectorLabels" . | nindent 4 }} role: api diff --git a/Dockerfile b/Dockerfile index 08b154c..935d03f 100644 --- a/Dockerfile +++ b/Dockerfile @@ -1,6 +1,6 @@ -FROM golang:1.14 AS builder +FROM golang:1.17 AS builder -ARG GOPROXY=direct +ARG GOPROXY=https://proxy.golang.org,direct ENV GOPROXY ${GOPROXY} ARG GOPRIVATE diff --git a/cmd/httphandler.go b/cmd/httphandler.go index fa25f2a..dd758c2 100644 --- a/cmd/httphandler.go +++ b/cmd/httphandler.go @@ -1,10 +1,11 @@ package cmd import ( - "github.com/astreter/amqpwrapper" + "github.com/astreter/amqpwrapper/v2" "github.com/gin-gonic/gin" "github.com/sirupsen/logrus" "github.com/spf13/cobra" + "go.opentelemetry.io/contrib/instrumentation/github.com/gin-gonic/gin/otelgin" "x-qdo/jiraclick/pkg/contract" "x-qdo/jiraclick/pkg/config" @@ -42,6 +43,7 @@ func NewHTTPHandlerCmd( "message": "ok", }) }) + router.Use(otelgin.Middleware(config.ServiceName)) router.POST("webhooks/clickup", clickUpHandler.TaskEvent) diff --git a/cmd/worker.go b/cmd/worker.go index 6cac105..2b66f99 100644 --- a/cmd/worker.go +++ b/cmd/worker.go @@ -1,7 +1,7 @@ package cmd import ( - "github.com/astreter/amqpwrapper" + "github.com/astreter/amqpwrapper/v2" "github.com/spf13/cobra" "x-qdo/jiraclick/pkg/consumer" diff --git a/context/context.go b/context/context.go index d68a461..02bbd30 100644 --- a/context/context.go +++ b/context/context.go @@ -2,7 +2,8 @@ package context import ( "context" - "github.com/astreter/amqpwrapper" + "github.com/astreter/amqpwrapper/v2" + "github.com/x-qdo/otelwrapper" "sync" "x-qdo/jiraclick/pkg/contract" @@ -41,14 +42,26 @@ func NewContext() (*Context, error) { ctx.WaitGroup = new(sync.WaitGroup) - amqpProvider, err := amqpwrapper.NewRabbitChannel(ctx.Ctx, ctx.CancelF, ctx.WaitGroup, &amqpwrapper.Config{ - URL: cfg.RabbitMQ.URL, - Debug: cfg.Debug, + tp, err := otelwrapper.InitTracerProvider(config.ServiceName, "default") + if err != nil { + return nil, err + } + go otelwrapper.ShutdownWaiting(tp, ctx.Ctx, ctx.WaitGroup) + + amqpProvider, err := amqpwrapper.NewRabbitChannel(ctx.Ctx, ctx.WaitGroup, &amqpwrapper.Config{ + URL: cfg.RabbitMQ.URL, + Debug: cfg.Debug, + ConfirmSends: true, }) if err != nil { panic(err) } + go func() { + <-amqpProvider.Cancel() + ctx.CancelF() + }() + db, err := provider.NewPostgres(cfg) if err != nil { panic(err) diff --git a/go.mod b/go.mod index 4f5aa11..71b1c01 100644 --- a/go.mod +++ b/go.mod @@ -3,28 +3,37 @@ module x-qdo/jiraclick go 1.16 require ( - github.com/andygrunwald/go-jira v1.13.0 + github.com/andygrunwald/go-jira v1.14.0 github.com/araddon/dateparse v0.0.0-20201001162425-8aadafed4dc4 - github.com/astreter/amqpwrapper v1.2.3 + github.com/astreter/amqpwrapper/v2 v2.0.2 github.com/gin-gonic/gin v1.7.7 - github.com/go-pg/migrations/v8 v8.0.1 // indirect - github.com/go-pg/pg/v10 v10.7.4 - github.com/go-playground/validator/v10 v10.9.0 // indirect - github.com/golang/protobuf v1.5.2 // indirect - github.com/google/uuid v1.2.0 // indirect + github.com/go-logr/stdr v1.2.2 // indirect + github.com/go-pg/migrations/v8 v8.1.0 + github.com/go-pg/pg/extra/pgotel/v10 v10.10.6 + github.com/go-pg/pg/v10 v10.10.6 + github.com/go-playground/validator/v10 v10.10.0 // indirect + github.com/golang-jwt/jwt v3.2.2+incompatible // indirect + github.com/google/go-querystring v1.1.0 // indirect github.com/json-iterator/go v1.1.12 // indirect github.com/mattn/go-isatty v0.0.14 // indirect github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect - github.com/pkg/errors v0.8.1 - github.com/rabbitmq/amqp091-go v1.2.0 + github.com/pkg/errors v0.9.1 + github.com/rabbitmq/amqp091-go v1.3.0 github.com/sirupsen/logrus v1.8.1 github.com/spf13/cobra v1.0.0 github.com/spf13/viper v1.4.0 - github.com/trivago/tgo v1.0.1 + github.com/trivago/tgo v1.0.7 github.com/ugorji/go v1.2.6 // indirect - golang.org/x/crypto v0.0.0-20211215153901-e495a2d5b3d3 // indirect - golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e // indirect - golang.org/x/text v0.3.7 // indirect - google.golang.org/protobuf v1.27.1 // indirect + github.com/vmihailenco/msgpack/v5 v5.3.5 // indirect + github.com/x-qdo/otelwrapper v1.0.1 + go.opentelemetry.io/contrib/instrumentation/github.com/gin-gonic/gin/otelgin v0.28.0 + go.opentelemetry.io/otel v1.3.0 + go.opentelemetry.io/otel/trace v1.3.0 + go.opentelemetry.io/proto/otlp v0.12.0 // indirect + golang.org/x/crypto v0.0.0-20220210151621-f4118a5b28e2 // indirect + golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd // indirect + golang.org/x/sys v0.0.0-20220209214540-3681064d5158 // indirect + google.golang.org/genproto v0.0.0-20220204002441-d6cc3cc0770e // indirect + google.golang.org/grpc v1.44.0 // indirect gopkg.in/yaml.v2 v2.4.0 // indirect ) diff --git a/go.sum b/go.sum index 3e06f28..547bd24 100644 --- a/go.sum +++ b/go.sum @@ -1,26 +1,35 @@ cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw= -dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU= +cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw= +github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ= github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= -github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo= +github.com/Insly/goutils v1.0.0 h1:TTIJ5uyRVJF95uutWAbX+RwQaeIvTGDRLQQwD5Feo7Y= +github.com/Insly/goutils v1.0.0/go.mod h1:oiF31/Qjp5CXpYAwQn50fU43a6ZxJm0uH2WKgpPRoq4= github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU= github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc= github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0= -github.com/andygrunwald/go-jira v1.13.0 h1:vvIImGgX32bHfoiyUwkNo+/YrPnRczNarvhLOncP6dE= -github.com/andygrunwald/go-jira v1.13.0/go.mod h1:jYi4kFDbRPZTJdJOVJO4mpMMIwdB+rcZwSO58DzPd2I= +github.com/andygrunwald/go-jira v1.14.0 h1:7GT/3qhar2dGJ0kq8w0d63liNyHOnxZsUZ9Pe4+AKBI= +github.com/andygrunwald/go-jira v1.14.0/go.mod h1:KMo2f4DgMZA1C9FdImuLc04x4WQhn5derQpnsuBFgqE= +github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY= github.com/araddon/dateparse v0.0.0-20201001162425-8aadafed4dc4 h1:OkS1BqB3CzLtGRznRyvriSY8jeaVk2CrDn2ZiRQgMUI= github.com/araddon/dateparse v0.0.0-20201001162425-8aadafed4dc4/go.mod h1:hMAUZFIkk4B1FouGxqlogyMyU6BwY/UiVmmbbzz9Up8= github.com/armon/consul-api v0.0.0-20180202201655-eb2c6b5be1b6/go.mod h1:grANhF5doyWs3UAsr3K4I6qtAmlQcZDesFNEHPZAzj8= -github.com/astreter/amqpwrapper v0.1.5 h1:h1IdvBeiEHTNYqeOfHFIGIB41oZ5zafs5yBIGMfvP/M= -github.com/astreter/amqpwrapper v0.1.5/go.mod h1:VNGJVSn/MMDTPHIg5PXV1zM9/mslMIKBSKWHL2X2wFw= -github.com/astreter/amqpwrapper v1.0.1 h1:S/WIU74VQ5eYD8ih2KyWqjOD4g1npVKZcHz4nH7q6hA= -github.com/astreter/amqpwrapper v1.0.1/go.mod h1:wbhmzxLHfY2T8nMvx02y0UzGaheEvrnI022YBz1mEqo= -github.com/astreter/amqpwrapper v1.2.3 h1:FZnmbmrz0ZWmtCgAUlsxueKfXO30lzYuZZen2Wj/wW8= -github.com/astreter/amqpwrapper v1.2.3/go.mod h1:fl8AabP4uQlTdWgQIyorn4+ejE/Y3KHupVeBVrCQ1Ig= +github.com/astreter/amqpwrapper/v2 v2.0.2 h1:Aj++Euk6zuHZwlpRtfP77foE+hay90qD0j169FkePsY= +github.com/astreter/amqpwrapper/v2 v2.0.2/go.mod h1:hz6oyWW181H/lwaPSQZGq0KlJEGfB5u9rjaH+BFGt18= github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q= github.com/beorn7/perks v1.0.0/go.mod h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+CedLV8= +github.com/cenkalti/backoff/v4 v4.1.2 h1:6Yo7N8UP2K6LWZnW94DLVSSrbobcWdVzAYOisuDPIFo= +github.com/cenkalti/backoff/v4 v4.1.2/go.mod h1:scbssz8iZGpm3xbr14ovlUdkxfGXNInqkPWOWmG2CLw= github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU= github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc= +github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw= +github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc= +github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk= +github.com/cncf/udpa/go v0.0.0-20210930031921-04548b0d99d4/go.mod h1:6pvJx4me5XPnfI9Z40ddWsdw2W/uZgQLFXToKeRcDiI= +github.com/cncf/xds/go v0.0.0-20210312221358-fbca930ec8ed/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= +github.com/cncf/xds/go v0.0.0-20210805033703-aa0b78936158/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= +github.com/cncf/xds/go v0.0.0-20210922020428-25de7278fc84/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= +github.com/cncf/xds/go v0.0.0-20211011173535-cb28da3451f1/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/coreos/bbolt v1.3.2/go.mod h1:iRUV2dpdMOn7Bo10OQBFzIJO9kkE559Wcmn+qkEiiKk= github.com/coreos/etcd v3.3.10+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc32PjwdhPthX9715RE= github.com/coreos/go-semver v0.2.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk= @@ -29,64 +38,69 @@ github.com/coreos/pkg v0.0.0-20180928190104-399ea9e2e55f/go.mod h1:E3G3o1h8I7cfc github.com/cpuguy83/go-md2man/v2 v2.0.0/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU= 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/dgrijalva/jwt-go v3.2.0+incompatible h1:7qlOGliEKZXTDg6OTjfoBKDXWrumCAMpl/TFQ4/5kLM= github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ= github.com/dgryski/go-sip13 v0.0.0-20181026042036-e10d5fee7954/go.mod h1:vAd38F8PWV+bWy6jNmig1y/TA+kYO4g3RSRF0IAv0no= +github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= +github.com/envoyproxy/go-control-plane v0.9.4/go.mod h1:6rpuAdCZL397s3pYoYcLgu1mIlRU8Am5FuJP05cCM98= +github.com/envoyproxy/go-control-plane v0.9.9-0.20201210154907-fd9021fe5dad/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk= +github.com/envoyproxy/go-control-plane v0.9.9-0.20210512163311-63b5d3c536b0/go.mod h1:hliV/p42l8fGbc6Y9bQ70uLwIvmJyVE5k4iMKlh8wCQ= +github.com/envoyproxy/go-control-plane v0.9.10-0.20210907150352-cf90f659a021/go.mod h1:AFq3mo9L8Lqqiid3OhADV3RfLJnjiw63cSpi+fDTRC0= github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c= -github.com/fatih/structs v1.0.0 h1:BrX964Rv5uQ3wwS+KRUAJCBBw5PQmgJfJ6v4yly5QwU= -github.com/fatih/structs v1.0.0/go.mod h1:9NiDSp5zOcgEDl+j00MP/WkGVPOlPRLejGD8Ga6PJ7M= -github.com/fsnotify/fsnotify v1.4.7 h1:IXs+QLmnXW2CcXuY+8Mzv/fWEsPGWxqefPtCP5CnV9I= +github.com/fatih/structs v1.1.0 h1:Q7juDM0QtcnhCpeyLGQKyg4TOIghuNXrkL32pHAUMxo= +github.com/fatih/structs v1.1.0/go.mod h1:9NiDSp5zOcgEDl+j00MP/WkGVPOlPRLejGD8Ga6PJ7M= github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo= github.com/fsnotify/fsnotify v1.4.9 h1:hsms1Qyu0jgnwNXIxa+/V/PDsU6CfLf6CNO8H7IWoS4= github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ= github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04= 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.6.3 h1:ahKqKTFpO5KTPHxWZjEdPScmYaGtLo8Y4DMHoEsnp14= -github.com/gin-gonic/gin v1.6.3/go.mod h1:75u5sXoLsGZoRN5Sgbi1eraJ4GU3++wFwWzhwvtwp4M= github.com/gin-gonic/gin v1.7.7 h1:3DoBmSbJbZAWqXJC3SLjAPfutPJJRN1U5pALB7EeTTs= github.com/gin-gonic/gin v1.7.7/go.mod h1:axIBovoeJpVj8S3BwE0uPMTeReE4+AfFtqpqaZ1qq1U= -github.com/go-gl/glfw/v3.3/glfw v0.0.0-20200222043503-6f7a984d4dc4/go.mod h1:tQ2UAYgL5IevRw8kRxooKSPJfGvJ9fJQFa0TUsXzTg8= github.com/go-kit/kit v0.8.0/go.mod h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2as= github.com/go-logfmt/logfmt v0.3.0/go.mod h1:Qt1PoO58o5twSAckw1HlFXLmHsOX5/0LbT9GBnD5lWE= github.com/go-logfmt/logfmt v0.4.0/go.mod h1:3RMwSq7FuexP4Kalkev3ejPJsZTpXXBr9+V4qmtdjCk= -github.com/go-pg/migrations v1.0.2 h1:3vtMENDO0wt8ciFNyOWKWMT0pJz7J9S4B0H3cMMB++g= -github.com/go-pg/migrations v6.7.3+incompatible h1:mKayeWTNGhYA9P9wzZNSDoumJRhfB4fEmfAlxNTVwtA= -github.com/go-pg/migrations/v8 v8.0.1 h1:I3BOQGuWcft6Vro6MFOWee9go1YApmSRD91eDWT19vQ= -github.com/go-pg/migrations/v8 v8.0.1/go.mod h1:P+p8sfswdIZgyjB7hCrGGhjE4exeWVxhs76LpIS5cHc= -github.com/go-pg/pg v8.0.7+incompatible h1:ty/sXL1OZLo+47KK9N8llRcmbA9tZasqbQ/OO4ld53g= -github.com/go-pg/pg/v10 v10.0.0-beta.11/go.mod h1:8mcMTXR1lDg1AhKVxDnTurPDZeBPDy3CaINv+Ox+TqQ= -github.com/go-pg/pg/v10 v10.7.4 h1:mlEZibLDMH20k5BK0iXp4KOpLytSjnknBw3rPEuJb4c= -github.com/go-pg/pg/v10 v10.7.4/go.mod h1:lKGGb3/k9tK5NBMPTcEuFJf9MQJOZIk6qrDOknygYVo= +github.com/go-logr/logr v1.2.0/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A= +github.com/go-logr/logr v1.2.1/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A= +github.com/go-logr/logr v1.2.2 h1:ahHml/yUpnlb96Rp8HCvtYVPY8ZYpxq3g7UYchIYwbs= +github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A= +github.com/go-logr/stdr v1.2.0/go.mod h1:YkVgnZu1ZjjL7xTxrfm/LLZBfkhTqSR1ydtm6jTKKwI= +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-pg/migrations/v8 v8.1.0 h1:bc1wQwFoWRKvLdluXCRFRkeaw9xDU4qJ63uCAagh66w= +github.com/go-pg/migrations/v8 v8.1.0/go.mod h1:o+CN1u572XHphEHZyK6tqyg2GDkRvL2bIoLNyGIewus= +github.com/go-pg/pg/extra/pgotel/v10 v10.10.6 h1:ngw4cAa/b9ixeDcx4DnD5TbIHZt1mm5Ebx4ErFby1X0= +github.com/go-pg/pg/extra/pgotel/v10 v10.10.6/go.mod h1:NjsSrEJ8CGl1n+J9KUXspdk5JNwV/GtUteYBEb4yP+4= +github.com/go-pg/pg/v10 v10.4.0/go.mod h1:BfgPoQnD2wXNd986RYEHzikqv9iE875PrFaZ9vXvtNM= +github.com/go-pg/pg/v10 v10.10.6 h1:1vNtPZ4Z9dWUw/TjJwOfFUbF5nEq1IkR6yG8Mq/Iwso= +github.com/go-pg/pg/v10 v10.10.6/go.mod h1:GLmFXufrElQHf5uzM3BQlcfwV3nsgnHue5uzjQ6Nqxg= github.com/go-pg/zerochecker v0.2.0 h1:pp7f72c3DobMWOb2ErtZsnrPaSvHd2W4o9//8HtF4mU= github.com/go-pg/zerochecker v0.2.0/go.mod h1:NJZ4wKL0NmTtz0GKCoJ8kym6Xn/EQzXRl2OnAe7MmDo= +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/locales v0.13.0 h1:HyWk6mgj5qFqCT5fjGBuRArbVDfE4hi8+e8ceBS/t7Q= 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/universal-translator v0.17.0 h1:icxd5fm+REJzpZx7ZfpaD876Lmtgy7VtROAbHHXk8no= 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/validator/v10 v10.2.0 h1:KgJ0snyC2R9VXYN2rneOtQcw5aHQB1Vv0sFl1UcHBOY= -github.com/go-playground/validator/v10 v10.2.0/go.mod h1:uOYAAleCW8F/7oMFd6aG0GOhaH6EGOAJShg8Id5JGkI= -github.com/go-playground/validator/v10 v10.4.1 h1:pH2c5ADXtd66mxoE0Zm9SUhxE20r7aM3F26W0hOn+GE= github.com/go-playground/validator/v10 v10.4.1/go.mod h1:nlOn6nFhuKACm19sB/8EGNn9GlaMV7XkbRSipzJ0Ii4= -github.com/go-playground/validator/v10 v10.9.0 h1:NgTtmN58D0m8+UuxtYmGztBJB7VnPgjj221I1QHci2A= -github.com/go-playground/validator/v10 v10.9.0/go.mod h1:74x4gJWsvQexRdW8Pn3dXSGrTK4nAUsbPlLADvpJkos= +github.com/go-playground/validator/v10 v10.10.0 h1:I7mrTYv78z8k8VXa/qJlOlEXn/nBh+BF8dHX5nt/dr0= +github.com/go-playground/validator/v10 v10.10.0/go.mod h1:74x4gJWsvQexRdW8Pn3dXSGrTK4nAUsbPlLADvpJkos= github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY= github.com/gogo/protobuf v1.1.1/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ= github.com/gogo/protobuf v1.2.1/go.mod h1:hp+jE20tsWTFYpLwKvXlhS1hjn+gTNwPg2I6zVXpSg4= +github.com/golang-jwt/jwt v3.2.1+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I= +github.com/golang-jwt/jwt v3.2.2+incompatible h1:IfV12K8xAKAnZqdXVzCZ+TOjboZ2keLg81eXfW3O+oY= +github.com/golang-jwt/jwt v3.2.2+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I= github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q= github.com/golang/groupcache v0.0.0-20190129154638-5b532d6fd5ef/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc= github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A= github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= -github.com/golang/protobuf v1.3.3 h1:gyjaxf+svBWX08ZjK86iN9geUJF0H6gp2IRKX6Nf6/I= github.com/golang/protobuf v1.3.3/go.mod h1:vzj43D7+SQXF/4pzW/hwtAqwc6iTitCiVSaWz5lYuqw= github.com/golang/protobuf v1.3.4/go.mod h1:vzj43D7+SQXF/4pzW/hwtAqwc6iTitCiVSaWz5lYuqw= github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8= @@ -96,7 +110,6 @@ github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:W github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0= github.com/golang/protobuf v1.4.1/go.mod h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8= github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= -github.com/golang/protobuf v1.4.3 h1:JjCZWpVbqXDqFVmTfYWEVTMIYrL/NPdPSCHPJ0T/raM= github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw= @@ -107,18 +120,21 @@ github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMyw 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.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= -github.com/google/go-cmp v0.5.1/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= -github.com/google/go-cmp v0.5.4/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/google/go-cmp v0.5.2/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-querystring v0.0.0-20170111101155-53e6ce116135 h1:zLTLjkaOFEFIOxY5BWLFLwh+cL8vOBW4XJ2aqLE/Tf0= +github.com/google/go-cmp v0.5.6 h1:BKbKCqvP6I+rmFHt06ZmyQtvB8xAkWdhFyr0ZUNZcxQ= +github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-querystring v0.0.0-20170111101155-53e6ce116135/go.mod h1:odCYkC5MyYFN7vkCjXpyrEuKhc/BUO6wN/zVPAxq5ck= +github.com/google/go-querystring v1.1.0 h1:AnCroh3fv4ZBgVIf1Iwtovgjaw/GiKJo8M8yD/fhyJ8= +github.com/google/go-querystring v1.1.0/go.mod h1:Kcdr2DB4koayq7X8pmAG4sNG59So17icRSOU623lUBU= github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= -github.com/google/uuid v1.2.0 h1:qJYtXnJRWmpe7m/3XlyhrsLrEURqHRM2kxzoxXqyUDs= -github.com/google/uuid v1.2.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= github.com/gorilla/websocket v1.4.0/go.mod h1:E7qHFY5m1UJ88s3WnNqhKjPHQ0heANvMoAMk2YaljkQ= github.com/grpc-ecosystem/go-grpc-middleware v1.0.0/go.mod h1:FiyG127CGDf3tlThmgyCl78X/SZQqEOJBCDaAfeWzPs= github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0/go.mod h1:8NvIoxWQoOIhqOTXgfV/d3M/q6VIi02HzZEHgUlZvzk= github.com/grpc-ecosystem/grpc-gateway v1.9.0/go.mod h1:vNeuVxBJEsws4ogUvrchl83t/GYV9WGTSLVdBhOQFDY= +github.com/grpc-ecosystem/grpc-gateway v1.16.0 h1:gmcG1KaJ57LophUzW0Hy8NmPhnMZb4M0+kPpLofRdBo= +github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw= github.com/hashicorp/hcl v1.0.0 h1:0Anlzjpi4vEasTeNFn2mLJgTSwt0+6sfsiTG8qcWGx4= github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ= github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU= @@ -127,7 +143,6 @@ github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANyt github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E= github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc= github.com/jonboulle/clockwork v0.1.0/go.mod h1:Ii8DK3G1RaLaWxj9trq07+26W01tbo22gdxWY5EU2bo= -github.com/json-iterator/go v1.1.9 h1:9yzud/Ht36ygwatGx56VwCZtlI/2AD15T1X2sjSuGns= github.com/json-iterator/go v1.1.9/go.mod h1:KdQUCv79m/52Kvf8AW2vK1V8akMuk1QjK/uOdHXbAo4= github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM= github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo= @@ -138,17 +153,17 @@ github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxv github.com/kr/logfmt v0.0.0-20140226030751-b84e30acd515/go.mod h1:+0opPa2QZZtGFBFZlji/RkVcI2GknAs/DXo4wKdlNEc= 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 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0= github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk= 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/leodido/go-urn v1.2.0 h1:hpXL4XnriNwQ/ABnpepYM/1vCLWNDfUNts8dX3xTG6Y= 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/magiconair/properties v1.8.0 h1:LLgXmsheXeRoUOBOjtwPQCWIYqM/LU1ayDtDePerRcY= github.com/magiconair/properties v1.8.0/go.mod h1:PppfXfuXeibc/6YijjN8zIbojt8czPbwD3XqdrwzmxQ= -github.com/mattn/go-isatty v0.0.12 h1:wuysRhFDzyxgEmMf5xjvJ2M9dZoWAXNNr5LSBS7uHXY= github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU= github.com/mattn/go-isatty v0.0.14 h1:yVuAays6BHfxijgZPzw+3Zlu5yQgKGP2/hcQbHb7S9Y= github.com/mattn/go-isatty v0.0.14/go.mod h1:7GGIvUiUoEMVVmxf/4nioHXj79iQHKdU27kJ6hsGG94= @@ -157,31 +172,32 @@ github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5 github.com/mitchellh/go-homedir v1.1.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0= github.com/mitchellh/mapstructure v1.1.2 h1:fmNYVwqnSfB9mZU6OS2O6GsXM+wcskZDuKQzvN1EDeE= github.com/mitchellh/mapstructure v1.1.2/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y= -github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 h1:ZqeYNhU3OHLH3mGKHDcjJRFFRrJa6eAM5H+CtDdOsPc= github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= -github.com/modern-go/reflect2 v0.0.0-20180701023420-4b7aa43c6742 h1:Esafd1046DLDQ0W1YjYsBW+p8U2u7vzgW2SQVmlNazg= github.com/modern-go/reflect2 v0.0.0-20180701023420-4b7aa43c6742/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0= github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M= github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk= github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U= github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno= +github.com/nxadm/tail v1.4.4 h1:DQuhQpB1tVlglWS2hLQ5OV6B5r8aGxSrPc5Qo6uTN78= github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A= github.com/oklog/ulid v1.3.1/go.mod h1:CirwcVhetQ6Lv90oh/F+FBtV6XMibvdAFo93nm5qn4U= github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE= github.com/onsi/ginkgo v1.12.1/go.mod h1:zj2OWP4+oCPe1qIXoGWkgMRwljMUYCdkwsT2108oapk= -github.com/onsi/ginkgo v1.14.0/go.mod h1:iSB4RoI2tjJc9BBv4NKIKWKya62Rps+oPG/Lv9klQyY= +github.com/onsi/ginkgo v1.14.2 h1:8mVmC9kjFFmA8H4pKMUhcblgifdkOIXPvbhN1T36q1M= github.com/onsi/ginkgo v1.14.2/go.mod h1:iSB4RoI2tjJc9BBv4NKIKWKya62Rps+oPG/Lv9klQyY= github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7JYyY= github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1ybHNo= +github.com/onsi/gomega v1.10.3 h1:gph6h/qe9GSUw1NhH1gp+qb+h8rXD8Cy60Z32Qw3ELA= github.com/onsi/gomega v1.10.3/go.mod h1:V9xEwhxec5O8UDM77eCW8vLymOMltsqPVYWrpDsH8xc= github.com/pelletier/go-toml v1.2.0 h1:T5zMGML61Wp+FlcbWjRDT7yAxhJNAiPPLOFECq181zc= github.com/pelletier/go-toml v1.2.0/go.mod h1:5z9KED0ma1S8pY6P1sdut58dfprrGBbd/94hg7ilaic= github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA= github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= -github.com/pkg/errors v0.8.1 h1:iURUrRGxPUNPdy5/HRSm+Yj6okJ6UtLINN0Q9M4+h3I= -github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= +github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4= +github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= +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/prometheus/client_golang v0.9.1/go.mod h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw= github.com/prometheus/client_golang v0.9.3/go.mod h1:/TN21ttK/J9q6uSwhBd54HahCDft0ttaMvbicHlPoso= @@ -193,21 +209,17 @@ github.com/prometheus/common v0.4.0/go.mod h1:TNfzLD0ON7rHzMJeJkieUDPYmFC7Snx/y8 github.com/prometheus/procfs v0.0.0-20181005140218-185b4288413d/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk= github.com/prometheus/procfs v0.0.0-20190507164030-5867b95ac084/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA= github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40TwIPHuXU= -github.com/rabbitmq/amqp091-go v1.2.0 h1:1pHBxAsQh54R9eX/xo679fUEAfv3loMqi0pvRFOj2nk= -github.com/rabbitmq/amqp091-go v1.2.0/go.mod h1:ogQDLSOACsLPsIq0NpbtiifNZi2YOz0VTJ0kHRghqbM= +github.com/rabbitmq/amqp091-go v1.3.0 h1:A/QuHiNw7LMCJsxx9iZn5lrIz6OrhIn7Dfk5/1YatWM= +github.com/rabbitmq/amqp091-go v1.3.0/go.mod h1:ogQDLSOACsLPsIq0NpbtiifNZi2YOz0VTJ0kHRghqbM= github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg= +github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ= github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc= +github.com/rogpeppe/go-internal v1.8.0 h1:FCbCCtXNOY3UtUuHUYaghJg4y7Fd14rXifAYUAtL9R8= github.com/rogpeppe/go-internal v1.8.0/go.mod h1:WmiCO8CzOY8rg0OYDC4/i/2WRWAB6poM+XZ2dLUbcbE= -github.com/rs/xid v1.2.1/go.mod h1:+uKXf+4Djp6Md1KODXJxgGQPKngRmWyn10oCKFzNHOQ= -github.com/rs/zerolog v1.20.0 h1:38k9hgtUBdxFwE34yS8rTHmHBa4eN16E4DJlv177LNs= -github.com/rs/zerolog v1.20.0/go.mod h1:IzD0RJ65iWH0w97OQQebJEvTZYvsCUm9WVLWBQrJRjo= github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM= github.com/scylladb/termtables v0.0.0-20191203121021-c4c0b6d42ff4/go.mod h1:C1a7PQSMz9NShzorzCiG2fk9+xuCgLkPeCvMHYR2OWg= -github.com/segmentio/encoding v0.1.15/go.mod h1:RWhr02uzMB9gQC1x+MfYxedtmBibb9cZ6Vv9VxRSSbw= github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc= github.com/sirupsen/logrus v1.2.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo= -github.com/sirupsen/logrus v1.7.0 h1:ShrD1U9pZB12TX0cVy0DtePoCH97K8EtX+mg7ZARUtM= -github.com/sirupsen/logrus v1.7.0/go.mod h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0= github.com/sirupsen/logrus v1.8.1 h1:dJKuHgqk1NNQlqoA6BTlM1Wf9DOH3NBjQyu0h9+AZZE= github.com/sirupsen/logrus v1.8.1/go.mod h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0= github.com/soheilhy/cmux v0.1.4/go.mod h1:IM3LyeVVIOuxMH7sFAkER9+bJ4dT7Ms6E4xg4kGIyLM= @@ -224,8 +236,6 @@ github.com/spf13/pflag v1.0.3 h1:zPAT6CGy6wXeQ7NtTnaTerfKOsV6V6F8agHXFiazDkg= github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4= github.com/spf13/viper v1.4.0 h1:yXHLWeravcrgGyFSyCgdYpXQ9dR9c/WED3pg1RhxqEU= github.com/spf13/viper v1.4.0/go.mod h1:PTJ7Z/lr49W6bUbkmS1V3by4uWynFiR9p7+dSq/yZzE= -github.com/streadway/amqp v1.0.0 h1:kuuDrUJFZL1QYL9hUNuCxNObNzB0bV/ZG5jV3RWAQgo= -github.com/streadway/amqp v1.0.0/go.mod h1:AZpEONHx3DKn8O/DFsRAY58/XVQiIPMTMB1SddzLXVw= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs= @@ -233,20 +243,17 @@ github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UV github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4= github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA= github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY= github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= -github.com/swaggo/files v0.0.0-20190704085106-630677cd5c14 h1:PyYN9JH5jY9j6av01SpfRMb+1DWg/i3MbGOKPxJ2wjM= -github.com/swaggo/files v0.0.0-20190704085106-630677cd5c14/go.mod h1:gxQT6pBGRuIGunNf/+tSOB5OHvguWi8Tbt82WOkf35E= github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U= github.com/tmthrgd/go-hex v0.0.0-20190904060850-447a3041c3bc h1:9lRDQMhESg+zvGYmW5DyG0UqvY96Bu5QYsTLvCHdrgo= github.com/tmthrgd/go-hex v0.0.0-20190904060850-447a3041c3bc/go.mod h1:bciPuU6GHm1iF1pBvUfxfsH0Wmnc2VbpgvbI9ZWuIRs= -github.com/trivago/tgo v1.0.1 h1:bxatjJIXNIpV18bucU4Uk/LaoxvxuOlp/oowRHyncLQ= -github.com/trivago/tgo v1.0.1/go.mod h1:w4dpD+3tzNIIiIfkWWa85w5/B77tlvdZckQ+6PkFnhc= +github.com/trivago/tgo v1.0.7 h1:uaWH/XIy9aWYWpjm2CU3RpcqZXmX2ysQ9/Go+d9gyrM= +github.com/trivago/tgo v1.0.7/go.mod h1:w4dpD+3tzNIIiIfkWWa85w5/B77tlvdZckQ+6PkFnhc= github.com/ugorji/go v1.1.4/go.mod h1:uQMGLiO92mf5W77hV/PUCpI3pbzQx3CRekS0kk+RGrc= -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 v1.2.6 h1:tGiWC9HENWE2tqYycIqFTNorMmFRVhNwCpDOpWqnk8E= github.com/ugorji/go v1.2.6/go.mod h1:anCg0y61KIhDlPZmnH+so+RQbysYVyDko0IMgJv0Nn0= -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.6 h1:7kbGefxLoDBuYXOms4yD7223OpNMMPNPZxXk5TvFcyQ= github.com/ugorji/go/codec v1.2.6/go.mod h1:V6TCNZ4PHqoHGFZuSG1W8nrCzzdgA2DozYxWFFpvxTw= @@ -254,64 +261,87 @@ github.com/vmihailenco/bufpool v0.1.11 h1:gOq2WmBrq0i2yW5QJ16ykccQ4wH9UyEsgLm6cz github.com/vmihailenco/bufpool v0.1.11/go.mod h1:AFf/MOy3l2CFTKbxwt0mp2MwnqjNEs5H/UxrkA5jxTQ= github.com/vmihailenco/msgpack/v4 v4.3.11/go.mod h1:gborTTJjAo/GWTqqRjrLCn9pgNN+NXzzngzBKDPIqw4= github.com/vmihailenco/msgpack/v5 v5.0.0-beta.1/go.mod h1:xlngVLeyQ/Qi05oQxhQ+oTuqa03RjMwMfk/7/TCs+QI= -github.com/vmihailenco/msgpack/v5 v5.1.4 h1:6K44/cU6dMNGkVTGGuu7ef2NdSRFMhAFGGLfE3cqtHM= -github.com/vmihailenco/msgpack/v5 v5.1.4/go.mod h1:C5gboKD0TJPqWDTVTtrQNfRbiBwHZGo8UTqP/9/XvLI= +github.com/vmihailenco/msgpack/v5 v5.3.4/go.mod h1:7xyJ9e+0+9SaZT0Wt1RGleJXzli6Q/V5KbhBonMG9jc= +github.com/vmihailenco/msgpack/v5 v5.3.5 h1:5gO0H1iULLWGhs2H5tbAHIZTV8/cYafcFOr9znI5mJU= +github.com/vmihailenco/msgpack/v5 v5.3.5/go.mod h1:7xyJ9e+0+9SaZT0Wt1RGleJXzli6Q/V5KbhBonMG9jc= github.com/vmihailenco/tagparser v0.1.1/go.mod h1:OeAg3pn3UbLjkWt+rN9oFYB6u/cQgqMEUPoW2WPyhdI= github.com/vmihailenco/tagparser v0.1.2 h1:gnjoVuB/kljJ5wICEEOpx98oXMWPLj22G67Vbd1qPqc= github.com/vmihailenco/tagparser v0.1.2/go.mod h1:OeAg3pn3UbLjkWt+rN9oFYB6u/cQgqMEUPoW2WPyhdI= +github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g= +github.com/vmihailenco/tagparser/v2 v2.0.0/go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds= +github.com/x-qdo/otelwrapper v1.0.1 h1:sUJlVEUa3qMcir+qYX/gQ0BbyKf99pUagt2mOw+LVSU= +github.com/x-qdo/otelwrapper v1.0.1/go.mod h1:bvxs+u4BxDR5nMkfH8TEbh6TekdT5rb+jSf+VxQjtq4= github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2/go.mod h1:UETIi67q53MR2AWcXfiuqkDkRtnGDLqkBTpCHuJHxtU= github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77/go.mod h1:aYKd//L2LvnjZzWKhF00oedf4jCCReLcmhLdhm1A27Q= go.etcd.io/bbolt v1.3.2/go.mod h1:IbVyRI1SCnLcuJnV2u8VeU0CEYM7e686BmAb1XKL+uU= -go.opentelemetry.io/otel v0.11.0/go.mod h1:G8UCk+KooF2HLkgo8RHX9epABH/aRGYET7gQOqBVdB0= -go.opentelemetry.io/otel v0.16.0 h1:uIWEbdeb4vpKPGITLsRVUS44L5oDbDUCZxn8lkxhmgw= -go.opentelemetry.io/otel v0.16.0/go.mod h1:e4GKElweB8W2gWUqbghw0B8t5MCTccc9212eNHnOHwA= +go.opentelemetry.io/contrib/instrumentation/github.com/gin-gonic/gin/otelgin v0.28.0 h1:e6uFYVURwheCC4GwkG4XCsWHoNQ8nPpYXCZctcg3mnw= +go.opentelemetry.io/contrib/instrumentation/github.com/gin-gonic/gin/otelgin v0.28.0/go.mod h1:f56Jk2pg43YRxWz9OMsVOFWh2HEPzHAjdfmC2pNG90M= +go.opentelemetry.io/contrib/propagators/b3 v1.2.0 h1:+zQjl3DBSOle9GEhHuhqzDUKtYcVSfbHSNv24hsoOJ0= +go.opentelemetry.io/contrib/propagators/b3 v1.2.0/go.mod h1:kO8hNKCfa1YmQJ0lM7pzfJGvbXEipn/S7afbOfaw2Kc= +go.opentelemetry.io/otel v0.13.0/go.mod h1:dlSNewoRYikTkotEnxdmuBHgzT+k/idJSfDv/FxEnOY= +go.opentelemetry.io/otel v1.0.0/go.mod h1:AjRVh9A5/5DE7S+mZtTR6t8vpKKryam+0lREnfmS4cg= +go.opentelemetry.io/otel v1.2.0/go.mod h1:aT17Fk0Z1Nor9e0uisf98LrntPGMnk4frBO9+dkf69I= +go.opentelemetry.io/otel v1.3.0 h1:APxLf0eiBwLl+SOXiJJCVYzA1OOJNyAoV8C5RNRyy7Y= +go.opentelemetry.io/otel v1.3.0/go.mod h1:PWIKzi6JCp7sM0k9yZ43VX+T345uNbAkDKwHVjb2PTs= +go.opentelemetry.io/otel/exporters/otlp/internal/retry v1.3.0 h1:R/OBkMoGgfy2fLhs2QhkCI1w4HLEQX92GCcJB6SSdNk= +go.opentelemetry.io/otel/exporters/otlp/internal/retry v1.3.0/go.mod h1:VpP4/RMn8bv8gNo9uK7/IMY4mtWLELsS+JIP0inH0h4= +go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.3.0 h1:giGm8w67Ja7amYNfYMdme7xSp2pIxThWopw8+QP51Yk= +go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.3.0/go.mod h1:hO1KLR7jcKaDDKDkvI9dP/FIhpmna5lkqPUQdEjFAM8= +go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.3.0 h1:Ydage/P0fRrSPpZeCVxzjqGcI6iVmG2xb43+IR8cjqM= +go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.3.0/go.mod h1:QNX1aly8ehqqX1LEa6YniTU7VY9I6R3X/oPxhGdTceE= +go.opentelemetry.io/otel/sdk v1.3.0 h1:3278edCoH89MEJ0Ky8WQXVmDQv3FX4ZJ3Pp+9fJreAI= +go.opentelemetry.io/otel/sdk v1.3.0/go.mod h1:rIo4suHNhQwBIPg9axF8V9CA72Wz2mKF1teNrup8yzs= +go.opentelemetry.io/otel/trace v1.0.0/go.mod h1:PXTWqayeFUlJV1YDNhsJYB184+IvAH814St6o6ajzIs= +go.opentelemetry.io/otel/trace v1.2.0/go.mod h1:N5FLswTubnxKxOJHM7XZC074qpeEdLy3CgAVsdMucK0= +go.opentelemetry.io/otel/trace v1.3.0 h1:doy8Hzb1RJ+I3yFhtDmwNc7tIyw1tNMOIsyPzp1NOGY= +go.opentelemetry.io/otel/trace v1.3.0/go.mod h1:c/VDhno8888bvQYmbYLqe41/Ldmr/KKunbvWM4/fEjk= +go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI= +go.opentelemetry.io/proto/otlp v0.11.0/go.mod h1:QpEjXPrNQzrFDZgoTo49dgHR9RYRSrg3NAKnUGl9YpQ= +go.opentelemetry.io/proto/otlp v0.12.0 h1:CMJ/3Wp7iOWES+CYLfnBv+DVmPbB+kmy9PJ92XvlR6c= +go.opentelemetry.io/proto/otlp v0.12.0/go.mod h1:TsIjwGWIx5VFYv9KGVlOpxoBl5Dy+63SUguV7GGvlSQ= go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE= 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/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4= golang.org/x/crypto v0.0.0-20180910181607-0e37d006457b/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= -golang.org/x/crypto v0.0.0-20190426145343-a29dc8fdc734/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= -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-20200820211705-5c72a883971a/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= -golang.org/x/crypto v0.0.0-20201221181555-eec23a3978ad h1:DN0cp81fZ3njFcrLCytUHRSUkqBjfTo4Tx9RJTWs0EY= -golang.org/x/crypto v0.0.0-20201221181555-eec23a3978ad/go.mod h1:jdWPYTVW3xRLrWPugEBEK3UY2ZEsg3UU495nc5E+M+I= +golang.org/x/crypto v0.0.0-20201012173705-84dcc777aaee/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= +golang.org/x/crypto v0.0.0-20201016220609-9e8e0b390897/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= golang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= -golang.org/x/crypto v0.0.0-20211215153901-e495a2d5b3d3 h1:0es+/5331RGQPcXlMfP+WrnIIS6dNnNRe0WB02W0F4M= -golang.org/x/crypto v0.0.0-20211215153901-e495a2d5b3d3/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4= +golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= +golang.org/x/crypto v0.0.0-20220131195533-30dcbda58838 h1:71vQrMauZZhcTVK6KdYM+rklehEEwb3E+ZhaE5jrPrE= +golang.org/x/crypto v0.0.0-20220131195533-30dcbda58838/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4= +golang.org/x/crypto v0.0.0-20220210151621-f4118a5b28e2 h1:XdAboW3BNMv9ocSCOk/u1MFioZGzCNkiJZ19v9Oe3Ig= +golang.org/x/crypto v0.0.0-20220210151621-f4118a5b28e2/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4= golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA= -golang.org/x/exp v0.0.0-20190306152737-a1d7652674e8/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA= -golang.org/x/exp v0.0.0-20200821190819-94841d0725da/go.mod h1:3jZMyOhIsHpP37uCMkUooju7aAi5cS1Q23tOzKc+0MU= -golang.org/x/exp v0.0.0-20200901203048-c4f52b2c50aa/go.mod h1:3jZMyOhIsHpP37uCMkUooju7aAi5cS1Q23tOzKc+0MU= -golang.org/x/image v0.0.0-20190227222117-0694c2d4d067/go.mod h1:kZ7UVZpmo3dzQBMxlp+ypCbDeSB+sBbTgSJuh5dn5js= -golang.org/x/image v0.0.0-20190802002840-cff245a6509b/go.mod h1:FeLwcggjj3mMvU+oOTbSwawSJRM1uh48EjtB4UJZlP0= golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE= golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU= golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc= -golang.org/x/mobile v0.0.0-20190719004257-d2bd2a29d028/go.mod h1:E/iHnbuqvinMTCcRqshq8CkpyQDoeVncDDYHnLhea+o= -golang.org/x/mod v0.1.1-0.20191105210325-c90efee705ee/go.mod h1:QqPTAvyqsEbceGzBzNggFXnrqF1CaUcvgkdR5Ot7KZg= -golang.org/x/mod v0.1.1-0.20191107180719-034126e5016b/go.mod h1:QqPTAvyqsEbceGzBzNggFXnrqF1CaUcvgkdR5Ot7KZg= golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20181114220301-adae6a3d119a/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20181220203305-927f97764cc3/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= +golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= golang.org/x/net v0.0.0-20190522155817-f3200d17e092/go.mod h1:HSz+uSET+XFnRR8LxR5pz3Of3rY3CfYBVs4xY44aLks= golang.org/x/net v0.0.0-20190603091049-60506f45cf65/go.mod h1:HSz+uSET+XFnRR8LxR5pz3Of3rY3CfYBVs4xY44aLks= -golang.org/x/net v0.0.0-20190620200207-3b0461eec859 h1:R/3boaszxrf1GEUWTVDzSKVwLmSJpwZ1yqXm8j0v2QI= -golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20200301022130-244492dfa37a/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-20200822124328-c89045814202/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= golang.org/x/net v0.0.0-20201006153459-a7d1128ccaa0/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= -golang.org/x/net v0.0.0-20201110031124-69a78807bb2b/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= +golang.org/x/net v0.0.0-20201010224723-4f7140c49acb/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= +golang.org/x/net v0.0.0-20201016165138-7b1cca2348c0/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-20210405180319-a5a99cb37ef4/go.mod h1:p54w0d4576C0XHj96bSt6lcn1PtDYWL6XObtHCRCNQM= golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= +golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd h1:O7DYs+zxREGLKzKoMQrtrEacpb0ZVXA5rIwylE2Xchk= +golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= +golang.org/x/oauth2 v0.0.0-20200107190931-bf48bf16ab8d/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= @@ -322,42 +352,39 @@ golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5h golang.org/x/sys v0.0.0-20181107165924-66b7b1311ac8/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20181116152217-5ac8a444bdc5/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-20190312061237-fead79001313/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20190904154756-749cb33beabd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20191001151750-bb3f8db39f24/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20191005200804-aed5e4c7ecf9/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20191026070338-33540a1f6037 h1:YyJpGZS1sBuBCzLAR1VEpK193GlqGZbnPFnPV/5Rsb4= golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20200116001909-b77594299b42 h1:vEOn+mP2zCOVzKckCZy6YsCtDblrpj/w7B9nxGNELpg= golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200519105757-fe76b779f299/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20200824131525-c12d262b63d8/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20200831180312-196b9ba8737a/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20201015000850-e3ed0017c211/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20201017003518-b09fb700fbb7/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20210113181707-4bcb84eeeb78 h1:nVuTkr9L6Bq62qpUqKo/RnZCFfzDBL0bYo6w9OJUqZY= -golang.org/x/sys v0.0.0-20210113181707-4bcb84eeeb78/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20210124154548-22da62e12c0c h1:VwygUrnw9jn88c4u8GD3rZQbqrP/tgas88tPUbBxQrk= -golang.org/x/sys v0.0.0-20210124154548-22da62e12c0c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20210326220804-49726bf1d181 h1:64ChN/hjER/taL4YJuA+gpLfIMT+/NFherRZixbxOhg= -golang.org/x/sys v0.0.0-20210326220804-49726bf1d181/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210423185535-09eb48e85fd7/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/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-20211216021012-1d35b9e2eb4e h1:fLOSk5Q00efkSvAm+4xcoXD+RRmLmmulPn5I3Y9F2EM= +golang.org/x/sys v0.0.0-20210923061019-b8560ed6a9b7/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/term v0.0.0-20201117132131-f5c789dd3221/go.mod h1:Nr5EML6q2oocZ2LXRh80K7BxOlk5/8JxuGnuhpl+muw= +golang.org/x/sys v0.0.0-20220114195835-da31bd327af9/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220204135822-1c1b9b1eba6a h1:ppl5mZgokTT8uPkmYOyEUmPTr3ypaKkg5eFOGrAmxxE= +golang.org/x/sys v0.0.0-20220204135822-1c1b9b1eba6a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220209214540-3681064d5158 h1:rm+CHSpPEEW2IsXUib1ThaHIjuBVZjxNgSKmBLFfD4c= +golang.org/x/sys v0.0.0-20220209214540-3681064d5158/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-20210220032956-6a3ed077a48d/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= +golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= -golang.org/x/text v0.3.2 h1:tW2bmiBqwgJj/UpqtC8EpXEZVYOwU0yG4iWbprSVAcs= golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk= -golang.org/x/text v0.3.3 h1:cokOdA+Jmi5PJGXLlLllQSgYigAEfHXJAERHVMaCc2k= golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= -golang.org/x/text v0.3.6 h1:aRYxNxv6iGQlyVaZmk6ZgYEDa+Jg18DxebPSrd6bg1M= +golang.org/x/text v0.3.5/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.7 h1:olpwvP2KacW1ZWvsR7uQhoyTYvKAupfQrRGBFM352Gk= golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= @@ -368,23 +395,31 @@ golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGm golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY= golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs= golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q= -golang.org/x/tools v0.0.0-20190828213141-aed303cbaa74/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= -golang.org/x/tools v0.0.0-20200207183749-b753a1ba74fa/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28= -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 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE= +golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM= google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4= google.golang.org/appengine v1.6.5/go.mod h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc= -google.golang.org/appengine v1.6.6/go.mod h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc= google.golang.org/appengine v1.6.7/go.mod h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc= google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc= google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc= +google.golang.org/genproto v0.0.0-20200513103714-09dca8ec2884/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c= google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo= +google.golang.org/genproto v0.0.0-20220204002441-d6cc3cc0770e h1:hXl9hnyOkeznztYpYxVPAVZfPzcbO6Q0C+nLXodza8k= +google.golang.org/genproto v0.0.0-20220204002441-d6cc3cc0770e/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.21.0/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM= google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg= +google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY= google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk= +google.golang.org/grpc v1.33.1/go.mod h1:fr5YgcSWrqhRRxogOsw7RzIpsmvOZ6IcH4kBYTpR3n0= +google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU= +google.golang.org/grpc v1.40.0/go.mod h1:ogyxbiOoUXAkP+4+xa6PZSE9DZgIHtSpzjDTB9KAK34= +google.golang.org/grpc v1.42.0/go.mod h1:k+4IHHFw41K8+bbowsex27ge2rCb65oeWqe4jJ590SU= +google.golang.org/grpc v1.43.0/go.mod h1:k+4IHHFw41K8+bbowsex27ge2rCb65oeWqe4jJ590SU= +google.golang.org/grpc v1.44.0 h1:weqSxi/TMs1SqFRMHCtBgXRs8k3X39QIDEZ0pRcttUg= +google.golang.org/grpc v1.44.0/go.mod h1:k+4IHHFw41K8+bbowsex27ge2rCb65oeWqe4jJ590SU= 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= @@ -393,7 +428,6 @@ google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzi google.golang.org/protobuf v1.22.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= -google.golang.org/protobuf v1.25.0 h1:Ejskq+SyPohKW+1uil0JJMtmHCgJPJ/qWTxr8qp+R4c= google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c= 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= @@ -403,22 +437,24 @@ gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLks 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-20200227125254-8fa46927fb4f/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/resty.v1 v1.12.0/go.mod h1:mDo4pnntr5jdWRML875a/NmxYqAlA73dVijT2AXvQQo= +gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ= gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw= gopkg.in/yaml.v2 v2.0.0-20170812160011-eb3733d160e7/go.mod h1:JAlM8MvJe8wmxCU4Bli9HhUf9+ttbYbLASfIpnQbh74= gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= +gopkg.in/yaml.v2 v2.2.3/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= -gopkg.in/yaml.v2 v2.2.8 h1:obN1ZagJSUGI0Ek/LBmuj4SNLPfIny3KsKFopxRdj10= gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= -gopkg.in/yaml.v2 v2.3.0 h1:clyUAQHOM3G0M3f5vQj7LuJrETvjVot3Z5el9nffUtU= 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.0-20210107192922-496545a6307b h1:h8qDotaEPuJATrMmW04NCwg7v22aHH28wwpauUhK9Oo= gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= diff --git a/pkg/config/config.go b/pkg/config/config.go index 1adaca7..e9758e8 100644 --- a/pkg/config/config.go +++ b/pkg/config/config.go @@ -7,6 +7,18 @@ import ( "github.com/spf13/viper" ) +const ServiceName = "jiraclick" + +var envBindings = []string{ + "debug", + "rabbitmq.url", + "httphandler.port", + "metrics.port", + "postgres.url", + "postgres.insecure", + "otel.exporter.endpoint", +} + type Config struct { Debug bool `yaml:"debug"` RabbitMQ struct { @@ -24,22 +36,18 @@ type Config struct { URL string `yaml:"url"` Insecure bool `yaml:"insecure"` } `yaml:"postgres"` + Metrics struct { + Port string `yaml:"port"` + } `yaml:"metrics"` + OTel struct { + Exporter struct { + Endpoint string `yaml:"endpoint"` + } `yaml:"exporter"` + } `yaml:"otel"` } func NewConfig() (*Config, error) { - if err := viper.BindEnv("debug"); err != nil { - return nil, err - } - if err := viper.BindEnv("rabbitmq.url"); err != nil { - return nil, err - } - if err := viper.BindEnv("httphandler.port"); err != nil { - return nil, err - } - if err := viper.BindEnv("postgres.url"); err != nil { - return nil, err - } - if err := viper.BindEnv("postgres.insecure"); err != nil { + if err := bindEnvs(envBindings); err != nil { return nil, err } viper.SetEnvKeyReplacer(strings.NewReplacer(".", "_")) @@ -51,3 +59,13 @@ func NewConfig() (*Config, error) { return c, nil } + +func bindEnvs(envKeys []string) error { + for _, envKey := range envKeys { + if err := viper.BindEnv(envKey); err != nil { + return fmt.Errorf("error binding '%s': %w", envKey, err) + } + } + + return nil +} diff --git a/pkg/consumer/actions.go b/pkg/consumer/actions.go index 3d6d25f..9f9ba8d 100644 --- a/pkg/consumer/actions.go +++ b/pkg/consumer/actions.go @@ -1,7 +1,7 @@ package consumer import ( - "github.com/astreter/amqpwrapper" + "github.com/astreter/amqpwrapper/v2" "x-qdo/jiraclick/pkg/contract" "x-qdo/jiraclick/pkg/provider/clickup" "x-qdo/jiraclick/pkg/provider/jira" diff --git a/pkg/consumer/task-create-clickup.go b/pkg/consumer/task-create-clickup.go index 293d700..42d5158 100644 --- a/pkg/consumer/task-create-clickup.go +++ b/pkg/consumer/task-create-clickup.go @@ -1,8 +1,10 @@ package consumer import ( + "context" "encoding/json" "github.com/araddon/dateparse" + "go.opentelemetry.io/otel" "github.com/pkg/errors" amqp "github.com/rabbitmq/amqp091-go" @@ -25,45 +27,63 @@ func NewTaskCreateClickupAction(clickup *clickup.ConnectorPool, p *publisher.Eve }, nil } -func (a *TaskCreateClickupAction) ProcessAction(delivery amqp.Delivery) error { +func (a *TaskCreateClickupAction) ProcessAction(ctx context.Context, delivery amqp.Delivery) error { var ( input inputBody task *clickup.Task payload model.TaskPayload ) + ctx, span := otel.Tracer("clickup action").Start(ctx, "ProcessAction") + defer span.End() + err := json.Unmarshal(delivery.Body, &input) if err != nil { - return errors.Wrap(err, "Can't unmarshall task body") + err = errors.Wrap(err, "Can't unmarshall task body") + span.RecordError(err) + return err } err = json.Unmarshal([]byte(input.Data.Payload), &payload) if err != nil { - return errors.Wrap(err, "Can't unmarshall task body") + err = errors.Wrap(err, "Can't unmarshall task body") + span.RecordError(err) + return err } - request := a.generateTaskRequest(&payload) - task, err = a.client.GetInstance(payload.SlackChannel).CreateTask(request) + request := a.generateTaskRequest(ctx, &payload) + span.AddEvent("Request payload generated") + task, err = a.client.GetInstance(payload.SlackChannel).CreateTask(ctx, request) if err != nil { - return errors.Wrap(err, "Can't create a task in ClickUp") + err = errors.Wrap(err, "Can't create a task in ClickUp") + span.RecordError(err) + return err } + span.AddEvent("task created") + payload.ClickupID = task.ID payload.Details["clickup_url"] = task.URL - err = a.publisher.ClickUpTaskCreated(payload) + err = a.publisher.ClickUpTaskCreated(ctx, payload) if err != nil { + span.RecordError(err) return err } + span.AddEvent("result sent to BRP") + return nil } -func (a *TaskCreateClickupAction) generateTaskRequest(payload *model.TaskPayload) *clickup.PutClickUpTaskRequest { +func (a *TaskCreateClickupAction) generateTaskRequest(ctx context.Context, payload *model.TaskPayload) *clickup.PutClickUpTaskRequest { request := new(clickup.PutClickUpTaskRequest) + ctx, span := otel.Tracer("clickup action").Start(ctx, "generateTaskRequest") + defer span.End() + request.Name = payload.Title request.NotifyAll = false - request.Status = a.client.GetInstance(payload.SlackChannel).GetInitialTaskStatus() + request.Status = a.client.GetInstance(payload.SlackChannel).GetInitialTaskStatus(ctx) request.Description = payload.Description + "\n" + payload.AC request.AddCustomField(clickup.RequestedBy, payload.SlackReporter) request.AddCustomField(clickup.SlackLink, payload.Details["slack"]) diff --git a/pkg/consumer/task-create-jira.go b/pkg/consumer/task-create-jira.go index f99b485..e73c32d 100644 --- a/pkg/consumer/task-create-jira.go +++ b/pkg/consumer/task-create-jira.go @@ -1,11 +1,12 @@ package consumer import ( + "context" "encoding/json" - "github.com/pkg/errors" amqp "github.com/rabbitmq/amqp091-go" "github.com/trivago/tgo/tcontainer" + "go.opentelemetry.io/otel" "x-qdo/jiraclick/pkg/contract" "x-qdo/jiraclick/pkg/model" @@ -25,36 +26,51 @@ func NewTaskCreateJiraAction(jira *jira.ConnectorPool, p *publisher.EventPublish }, nil } -func (a *TaskCreateJiraAction) ProcessAction(delivery amqp.Delivery) error { +func (a *TaskCreateJiraAction) ProcessAction(ctx context.Context, delivery amqp.Delivery) error { var ( input inputBody payload model.TaskPayload ) + ctx, span := otel.Tracer("jira action").Start(ctx, "ProcessAction") + defer span.End() + err := json.Unmarshal(delivery.Body, &input) if err != nil { - return errors.Wrap(err, "Can't unmarshall task body") + err = errors.Wrap(err, "Can't unmarshall task body") + span.RecordError(err) + return err } err = json.Unmarshal([]byte(input.Data.Payload), &payload) if err != nil { - return errors.Wrap(err, "Can't unmarshall task body") + err = errors.Wrap(err, "Can't unmarshall task body") + span.RecordError(err) + return err } task := a.generateTaskRequest(payload) + span.AddEvent("Request payload generated") - response, err := a.client.GetInstance(payload.SlackChannel).CreateIssue(task) + response, err := a.client.GetInstance(payload.SlackChannel).CreateIssue(ctx, task) if err != nil { - return errors.Wrap(err, "Can't create task in Jira") + err = errors.Wrap(err, "Can't create task in Jira") + span.RecordError(err) + return err } + span.AddEvent("issue created") + payload.JiraID = response.ID payload.Details["jira_url"] = response.URL - err = a.publisher.JiraTaskCreated(payload) + err = a.publisher.JiraTaskCreated(ctx, payload) if err != nil { + span.RecordError(err) return err } + span.AddEvent("result sent to BRP") + return nil } diff --git a/pkg/consumer/task-update-clickup.go b/pkg/consumer/task-update-clickup.go index 6e04266..f5a7562 100644 --- a/pkg/consumer/task-update-clickup.go +++ b/pkg/consumer/task-update-clickup.go @@ -1,7 +1,9 @@ package consumer import ( + "context" "encoding/json" + "go.opentelemetry.io/otel" "github.com/pkg/errors" amqp "github.com/rabbitmq/amqp091-go" @@ -24,36 +26,42 @@ func NewTaskUpdateClickupAction(clickup *clickup.ConnectorPool, p *publisher.Eve }, nil } -func (a *TaskUpdateClickupAction) ProcessAction(delivery amqp.Delivery) error { +func (a *TaskUpdateClickupAction) ProcessAction(ctx context.Context, delivery amqp.Delivery) error { var ( input inputBody payload model.TaskPayload ) + ctx, span := otel.Tracer("clickup action").Start(ctx, "ProcessAction") + defer span.End() + err := json.Unmarshal(delivery.Body, &input) if err != nil { - return errors.Wrap(err, "Can't unmarshall task body") + err = errors.Wrap(err, "Can't unmarshall task body") + span.RecordError(err) + return err } err = json.Unmarshal([]byte(input.Data.Payload), &payload) if err != nil { - return errors.Wrap(err, "Can't unmarshall task body") - } - - request, err := a.generateTaskRequest(payload) - if err != nil { - return errors.Wrap(err, "Can't create task request") + err = errors.Wrap(err, "Can't unmarshall task body") + span.RecordError(err) + return err } - err = a.client.GetInstance(payload.SlackChannel).UpdateTask(payload.ClickupID, request) + request := a.generateTaskRequest(payload) + span.AddEvent("Request payload generated") + err = a.client.GetInstance(payload.SlackChannel).UpdateTask(ctx, payload.ClickupID, request) if err != nil { - return errors.Wrap(err, "Can't update a task in ClickUp") + err = errors.Wrap(err, "Can't update a task in ClickUp") + span.RecordError(err) + return err } return nil } -func (a *TaskUpdateClickupAction) generateTaskRequest(payload model.TaskPayload) (*clickup.PutClickUpTaskRequest, error) { +func (a *TaskUpdateClickupAction) generateTaskRequest(payload model.TaskPayload) *clickup.PutClickUpTaskRequest { request := new(clickup.PutClickUpTaskRequest) request.Name = payload.Title @@ -62,5 +70,5 @@ func (a *TaskUpdateClickupAction) generateTaskRequest(payload model.TaskPayload) request.AddCustomField(clickup.SlackLink, payload.Details["slack"]) request.AddCustomField(clickup.JiraLink, payload.Details["clickup_url"]) - return request, nil + return request } diff --git a/pkg/contract/action.go b/pkg/contract/action.go index 45e126f..3cfc47c 100644 --- a/pkg/contract/action.go +++ b/pkg/contract/action.go @@ -1,9 +1,10 @@ package contract import ( + "context" amqp "github.com/rabbitmq/amqp091-go" ) type Action interface { - ProcessAction(delivery amqp.Delivery) error + ProcessAction(ctx context.Context, delivery amqp.Delivery) error } diff --git a/pkg/handler/clickup.go b/pkg/handler/clickup.go index 5c43ef5..358969f 100644 --- a/pkg/handler/clickup.go +++ b/pkg/handler/clickup.go @@ -2,7 +2,11 @@ package handler import ( "bytes" - "github.com/astreter/amqpwrapper" + "context" + "github.com/astreter/amqpwrapper/v2" + "go.opentelemetry.io/otel" + "go.opentelemetry.io/otel/attribute" + "go.opentelemetry.io/otel/trace" "net/http" "strconv" "x-qdo/jiraclick/pkg/contract" @@ -46,36 +50,48 @@ func NewClickUpWebhooksHandler( } func (h *clickUpWebhooks) TaskEvent(ctx *gin.Context) { + spanCtx, span := otel.Tracer("http handler").Start(ctx.Request.Context(), "TaskEvent") + defer span.End() + buf := new(bytes.Buffer) if _, err := buf.ReadFrom(ctx.Request.Body); err != nil { - h.logger.Error(errors.Wrap(err, "ClickUp webhook: body can't be read")) + err = errors.Wrap(err, "ClickUp webhook: body can't be read") + span.RecordError(err) + h.logger.Error(err) ctx.Status(http.StatusInternalServerError) return } body := buf.String() - accessed, tenant := h.checkWebhookSecret(ctx, body) + accessed, tenant := h.checkWebhookSecret(spanCtx, ctx.Request.Header.Get("X-Signature"), body) if !accessed { - h.logger.Error("ClickUp webhook: signature is not valid") + err := errors.New("ClickUp webhook: signature is not valid") + span.RecordError(err) + h.logger.Error(err) ctx.Status(http.StatusForbidden) return } h.logger.Debug("Clickup Raw Event: ", body) - event, err := clickup.ParseEvent(body) + event, err := clickup.ParseEvent(spanCtx, body) h.logger.Debug("Clickup Parsed Event: ", event) if err != nil { - h.logger.Error(errors.Wrap(err, "ClickUp webhook: body can't be parsed")) + err = errors.Wrap(err, "ClickUp webhook: body can't be parsed") + span.RecordError(err) + h.logger.Error(err) ctx.Status(http.StatusInternalServerError) return } else if event == nil { - h.logger.Debug("ClickUp webhook: webhook is without changes data") + msg := "ClickUp webhook: webhook is without changes data" + span.AddEvent(msg) + h.logger.Debug(msg) ctx.Status(http.StatusOK) return } - err = h.doAction(event, tenant) + err = h.doAction(spanCtx, event, tenant) if err != nil { + span.RecordError(err) h.logger.Error(err) ctx.Status(http.StatusInternalServerError) return @@ -84,27 +100,38 @@ func (h *clickUpWebhooks) TaskEvent(ctx *gin.Context) { ctx.Status(http.StatusOK) } -func (h *clickUpWebhooks) doAction(event *clickup.WebhookEvent, tenant string) error { +func (h *clickUpWebhooks) doAction(ctx context.Context, event *clickup.WebhookEvent, tenant string) error { var changes model.TaskChanges + span := trace.SpanFromContext(ctx) - task, err := h.clickup.GetInstance(tenant).GetTask(event.TaskID) + task, err := h.clickup.GetInstance(tenant).GetTask(ctx, event.TaskID) if err != nil { - return errors.Wrap(err, "ClickUp webhook: can't get task") + err = errors.Wrap(err, "ClickUp webhook: can't get task") + span.RecordError(err) + return err } + span.AddEvent("task retrieved from Clickup") if event.Type == clickup.TaskUpdated && !isEventActual(task.DateUpdated, event.Changes[0].Date) { + span.AddEvent("task doesn't have `taskUpdated` status or update is not actual") return nil } slackChannel := task.GetSlackChannel() if slackChannel == "" { - return errors.Wrap(err, "ClickUp webhook: slackChannel is not defined") + err = errors.Wrap(err, "ClickUp webhook: slackChannel is not defined") + span.RecordError(err) + return err } + span.AddEvent("slackChannel retrieved from task") changes = generateTaskChangesByEvent(event, task) - err = h.publisher.ClickUpTaskUpdated(changes, slackChannel) + span.AddEvent("changes are defined") + err = h.publisher.ClickUpTaskUpdated(ctx, changes, slackChannel) if err != nil { - return errors.Wrap(err, "ClickUp webhook: can't trigger changes event") + err = errors.Wrap(err, "ClickUp webhook: can't trigger changes event") + span.RecordError(err) + return err } return nil @@ -151,15 +178,19 @@ func isEventActual(taskDate, eventDate string) bool { return taskTimestamp <= eventTimestamp } -func (h *clickUpWebhooks) checkWebhookSecret(ctx *gin.Context, body string) (bool, string) { +func (h *clickUpWebhooks) checkWebhookSecret(ctx context.Context, signature, body string) (bool, string) { + span := trace.SpanFromContext(ctx) clickUpAccounts, err := h.db.GetClickUpAccounts(ctx) if err != nil { + span.RecordError(err) panic(err) } for tenant, acc := range clickUpAccounts { - if clickup.CheckSignature(ctx.Request.Header.Get("X-Signature"), body, acc.WebhookSecret) { + if clickup.CheckSignature(ctx, signature, body, acc.WebhookSecret) { + span.AddEvent("signature checked", trace.WithAttributes(attribute.Bool("valid", true))) return true, tenant } } + span.AddEvent("signature checked", trace.WithAttributes(attribute.Bool("valid", false))) return false, "" } diff --git a/pkg/provider/clickup/client.go b/pkg/provider/clickup/client.go index 246b8b2..c1eb1c6 100644 --- a/pkg/provider/clickup/client.go +++ b/pkg/provider/clickup/client.go @@ -2,9 +2,11 @@ package clickup import ( "bytes" + "context" "encoding/json" "fmt" - "github.com/sirupsen/logrus" + "go.opentelemetry.io/otel" + "go.opentelemetry.io/otel/attribute" "net/http" "net/http/httputil" ) @@ -20,11 +22,11 @@ type APIClient struct { } type ClientInterface interface { - CreateTask(request *PutClickUpTaskRequest) (*Task, error) - UpdateTask(taskID string, request *PutClickUpTaskRequest) error - SetCustomField(taskID, customFieldID string, value interface{}) error - GetTask(taskID string) (*Task, error) - GetInitialTaskStatus() string + CreateTask(ctx context.Context, request *PutClickUpTaskRequest) (*Task, error) + UpdateTask(ctx context.Context, taskID string, request *PutClickUpTaskRequest) error + SetCustomField(ctx context.Context, taskID, customFieldID string, value interface{}) error + GetTask(ctx context.Context, taskID string) (*Task, error) + GetInitialTaskStatus(ctx context.Context) string } type PutClickUpTaskRequest struct { @@ -41,16 +43,23 @@ func (t *PutClickUpTaskRequest) AddCustomField(id CustomFieldKey, value interfac t.CustomFields = append(t.CustomFields, CustomField{ID: id, Value: value}) } -func (c *APIClient) CreateTask(request *PutClickUpTaskRequest) (*Task, error) { +func (c *APIClient) CreateTask(ctx context.Context, request *PutClickUpTaskRequest) (*Task, error) { var task Task + ctx, span := otel.Tracer("clickup provider").Start(ctx, "CreateTask") + defer span.End() + body, err := json.Marshal(request) if err != nil { + span.RecordError(err) return nil, err } - logrus.Debug("Sending POST request to Clickup: ", c.options.host+"/list/"+c.options.listID+"/task/") - logrus.Debug(string(body)) + span.SetAttributes( + attribute.String("url", c.options.host+"/list/"+c.options.listID+"/task/"), + attribute.String("request body", string(body)), + ) req, err := http.NewRequest("POST", c.options.host+"/list/"+c.options.listID+"/task/", bytes.NewBuffer(body)) if err != nil { + span.RecordError(err) return nil, err } req.Header.Add("Authorization", c.options.token) @@ -58,30 +67,42 @@ func (c *APIClient) CreateTask(request *PutClickUpTaskRequest) (*Task, error) { r, err := c.httpClient.Do(req) if err != nil { + span.RecordError(err) return nil, err } + span.AddEvent("POST request sent to ClickUp") if r.StatusCode != http.StatusOK { - return nil, formatHttpError(r) + err = formatHttpError(r) + span.RecordError(err) + return nil, err } defer r.Body.Close() err = json.NewDecoder(r.Body).Decode(&task) if err != nil { + span.RecordError(err) return nil, err } return &task, nil } -func (c *APIClient) UpdateTask(taskID string, request *PutClickUpTaskRequest) error { +func (c *APIClient) UpdateTask(ctx context.Context, taskID string, request *PutClickUpTaskRequest) error { + ctx, span := otel.Tracer("clickup provider").Start(ctx, "UpdateTask") + defer span.End() + body, err := json.Marshal(request) if err != nil { + span.RecordError(err) return err } - logrus.Debug("Sending PUT request to Clickup: ", c.options.host+"/task/"+taskID) - logrus.Debug(string(body)) + span.SetAttributes( + attribute.String("url", c.options.host+"/task/"+taskID), + attribute.String("request body", string(body)), + ) req, err := http.NewRequest("PUT", c.options.host+"/task/"+taskID, bytes.NewBuffer(body)) if err != nil { + span.RecordError(err) return err } req.Header.Add("Authorization", c.options.token) @@ -89,18 +110,24 @@ func (c *APIClient) UpdateTask(taskID string, request *PutClickUpTaskRequest) er r, err := c.httpClient.Do(req) if err != nil { + span.RecordError(err) return err } + span.AddEvent("POST request sent to ClickUp") + if r.StatusCode != http.StatusOK { - return formatHttpError(r) + err = formatHttpError(r) + span.RecordError(err) + return err } defer r.Body.Close() var customField CustomField for _, customField = range request.CustomFields { - err = c.SetCustomField(taskID, string(customField.ID), customField.Value) + err = c.SetCustomField(ctx, taskID, string(customField.ID), customField.Value) if err != nil { + span.RecordError(err) return err } } @@ -108,20 +135,28 @@ func (c *APIClient) UpdateTask(taskID string, request *PutClickUpTaskRequest) er return nil } -func (c *APIClient) SetCustomField(taskID, customFieldID string, value interface{}) error { +func (c *APIClient) SetCustomField(ctx context.Context, taskID, customFieldID string, value interface{}) error { var request struct { Value interface{} `json:"value"` } + + ctx, span := otel.Tracer("clickup provider").Start(ctx, "SetCustomField") + defer span.End() + request.Value = value body, err := json.Marshal(request) if err != nil { + span.RecordError(err) return err } - logrus.Debug("Sending POST request to Clickup: ", c.options.host+"/task/"+taskID+"/field/"+customFieldID) - logrus.Debug(string(body)) + span.SetAttributes( + attribute.String("url", c.options.host+"/task/"+taskID+"/field/"+customFieldID), + attribute.String("request body", string(body)), + ) req, err := http.NewRequest("POST", c.options.host+"/task/"+taskID+"/field/"+customFieldID, bytes.NewBuffer(body)) if err != nil { + span.RecordError(err) return err } req.Header.Add("Authorization", c.options.token) @@ -129,22 +164,33 @@ func (c *APIClient) SetCustomField(taskID, customFieldID string, value interface r, err := c.httpClient.Do(req) if err != nil { + span.RecordError(err) return err } + span.AddEvent("POST request sent to ClickUp") + if r.StatusCode != http.StatusOK { - return formatHttpError(r) + err = formatHttpError(r) + span.RecordError(err) + return err } defer r.Body.Close() return nil } -func (c *APIClient) GetTask(taskID string) (*Task, error) { +func (c *APIClient) GetTask(ctx context.Context, taskID string) (*Task, error) { var task Task - logrus.Debug("Sending GET request to Clickup: ", c.options.host+"/task/"+taskID) + ctx, span := otel.Tracer("clickup provider").Start(ctx, "GetTask") + defer span.End() + span.SetAttributes( + attribute.String("url", c.options.host+"/task/"+taskID), + ) + req, err := http.NewRequest("GET", c.options.host+"/task/"+taskID, nil) if err != nil { + span.RecordError(err) return nil, err } req.Header.Add("Authorization", c.options.token) @@ -152,22 +198,30 @@ func (c *APIClient) GetTask(taskID string) (*Task, error) { r, err := c.httpClient.Do(req) if err != nil { + span.RecordError(err) return nil, err } + span.AddEvent("GET request sent to ClickUp") + if r.StatusCode != http.StatusOK { return nil, formatHttpError(r) } defer r.Body.Close() err = json.NewDecoder(r.Body).Decode(&task) if err != nil { + span.RecordError(err) return nil, err } + span.AddEvent("task received") + return &task, nil } -func (c *APIClient) GetInitialTaskStatus() string { +func (c *APIClient) GetInitialTaskStatus(ctx context.Context) string { + ctx, span := otel.Tracer("clickup provider").Start(ctx, "GetInitialTaskStatus") + defer span.End() return c.options.initialTaskStatus } diff --git a/pkg/provider/clickup/webhook.go b/pkg/provider/clickup/webhook.go index f9be770..b90e2df 100644 --- a/pkg/provider/clickup/webhook.go +++ b/pkg/provider/clickup/webhook.go @@ -1,10 +1,12 @@ package clickup import ( + "context" "crypto/hmac" "crypto/sha256" "encoding/hex" "encoding/json" + "go.opentelemetry.io/otel" ) type EventType string @@ -42,12 +44,16 @@ type HistoryItem struct { After interface{} `json:"after"` } -func CheckSignature(signature, body, secret string) bool { +func CheckSignature(ctx context.Context, signature, body, secret string) bool { + ctx, span := otel.Tracer("clickup provider").Start(ctx, "CheckSignature") + defer span.End() + s := []byte(secret) m := []byte(body) hash := hmac.New(sha256.New, s) if _, err := hash.Write(m); err != nil { + span.RecordError(err) return false } @@ -57,9 +63,12 @@ func CheckSignature(signature, body, secret string) bool { return result == signature } -func ParseEvent(body string) (*WebhookEvent, error) { +func ParseEvent(ctx context.Context, body string) (*WebhookEvent, error) { + ctx, span := otel.Tracer("clickup provider").Start(ctx, "ParseEvent") + defer span.End() e := new(WebhookEvent) if err := json.Unmarshal([]byte(body), e); err != nil { + span.RecordError(err) return nil, err } if len(e.Changes) == 0 { diff --git a/pkg/provider/jira/client.go b/pkg/provider/jira/client.go index 425d0d0..6235361 100644 --- a/pkg/provider/jira/client.go +++ b/pkg/provider/jira/client.go @@ -2,19 +2,23 @@ package jira import ( "bytes" + "context" + "encoding/json" "fmt" - "github.com/andygrunwald/go-jira" "github.com/pkg/errors" "github.com/trivago/tgo/tcontainer" + "go.opentelemetry.io/otel" + "go.opentelemetry.io/otel/attribute" + "go.opentelemetry.io/otel/trace" ) const LinkToJiraTask = "%s/browse/%s" type ClientInterface interface { - CreateIssue(task *Task) (*PutJiraTaskResponse, error) - UpdateIssue() error - FindUserByEmail(email string) *jira.User + CreateIssue(ctx context.Context, task *Task) (*PutJiraTaskResponse, error) + UpdateIssue(ctx context.Context) error + FindUserByEmail(ctx context.Context, email string) *jira.User } type jiraClient struct { @@ -37,12 +41,22 @@ type PutJiraTaskResponse struct { URL string `json:"url"` } -func (c *jiraClient) CreateIssue(task *Task) (*PutJiraTaskResponse, error) { +func (c *jiraClient) CreateIssue(ctx context.Context, task *Task) (*PutJiraTaskResponse, error) { var response PutJiraTaskResponse + ctx, span := otel.Tracer("jira client").Start(ctx, "CreateIssue") + defer span.End() + + t, err := json.Marshal(task) + if err != nil { + span.RecordError(err) + } else { + span.SetAttributes(attribute.Key("task").String(string(t))) + } + i := jira.Issue{ Fields: &jira.IssueFields{ - Reporter: c.FindUserByEmail(task.Reporter), + Reporter: c.FindUserByEmail(ctx, task.Reporter), Description: task.Description, Type: jira.IssueType{ Name: task.Type, @@ -55,10 +69,12 @@ func (c *jiraClient) CreateIssue(task *Task) (*PutJiraTaskResponse, error) { }, } - issue, r, err := c.client.Issue.Create(&i) + issue, r, err := c.client.Issue.CreateWithContext(ctx, &i) if err != nil { + span.RecordError(err) buf := new(bytes.Buffer) if _, e := buf.ReadFrom(r.Response.Body); e != nil { + span.RecordError(e) return nil, e } return nil, errors.Wrap(err, buf.String()) @@ -67,19 +83,43 @@ func (c *jiraClient) CreateIssue(task *Task) (*PutJiraTaskResponse, error) { response.ID = issue.ID response.URL = fmt.Sprintf(LinkToJiraTask, c.baseURL, issue.Key) + span.AddEvent("issue has been created", trace.WithAttributes( + attribute.Key("issue id").String(issue.ID), + attribute.Key("issue url").String(response.URL), + )) return &response, nil } -func (c *jiraClient) UpdateIssue() error { +func (c *jiraClient) UpdateIssue(ctx context.Context) error { + ctx, span := otel.Tracer("jira client").Start(ctx, "UpdateIssue") + defer span.End() return nil } -func (c *jiraClient) FindUserByEmail(email string) *jira.User { - users, _, err := c.client.User.Find(email) +func (c *jiraClient) FindUserByEmail(ctx context.Context, email string) *jira.User { + ctx, span := otel.Tracer("jira client").Start(ctx, "FindUserByEmail") + defer span.End() + span.SetAttributes(attribute.Key("email").String(email)) + + users, _, err := c.client.User.FindWithContext(ctx, email) if err != nil { + span.RecordError(err) return nil - } else if len(users) > 1 { + } + + usersStr := make([]string, 0) + for _, u := range users { + usersStr = append(usersStr, u.Name) + } + span.AddEvent("following users has been found", trace.WithAttributes( + attribute.Key("users").StringSlice(usersStr), + )) + + if len(users) > 1 { + span.AddEvent("user selected", trace.WithAttributes( + attribute.Key("user").String(users[0].Name), + )) return &users[0] } diff --git a/pkg/provider/postgres.go b/pkg/provider/postgres.go index 2b3dd51..6155905 100644 --- a/pkg/provider/postgres.go +++ b/pkg/provider/postgres.go @@ -5,6 +5,7 @@ import ( "crypto/tls" "encoding/json" "fmt" + "github.com/go-pg/pg/extra/pgotel/v10" "github.com/go-pg/pg/v10" "github.com/go-pg/pg/v10/orm" "x-qdo/jiraclick/pkg/config" @@ -33,6 +34,7 @@ func NewPostgres(cfg *config.Config) (*postgresDB, error) { } db := pg.Connect(opt) + db.AddQueryHook(pgotel.NewTracingHook()) if err := db.Ping(context.Background()); err != nil { return nil, fmt.Errorf("failed to ping Postgres: %s", err.Error()) @@ -82,7 +84,7 @@ func (db *postgresDB) getConnection(ctx context.Context) orm.DB { return tx } - return db.conn + return db.conn.WithContext(ctx) } func (db *postgresDB) Close() error { diff --git a/pkg/publisher/event.go b/pkg/publisher/event.go index 905d491..8e245d1 100644 --- a/pkg/publisher/event.go +++ b/pkg/publisher/event.go @@ -1,8 +1,9 @@ package publisher import ( + "context" "fmt" - "github.com/astreter/amqpwrapper" + "github.com/astreter/amqpwrapper/v2" "github.com/pkg/errors" @@ -24,27 +25,27 @@ func NewEventPublisher(queueProvider *amqpwrapper.RabbitChannel) (*EventPublishe }, nil } -func (p *EventPublisher) ClickUpTaskCreated(payload model.TaskPayload) error { +func (p *EventPublisher) ClickUpTaskCreated(ctx context.Context, payload model.TaskPayload) error { routingKey := fmt.Sprintf(string(contract.TaskCreatedClickUpEvent), payload.SlackChannel) - if err := p.queueProvider.Publish(payload, contract.BRPEventsExchange, routingKey); err != nil { + if err := p.queueProvider.Publish(ctx, payload, contract.BRPEventsExchange, routingKey); err != nil { return errors.Wrap(err, fmt.Sprintf("failed to send a %s to events queue", routingKey)) } return nil } -func (p *EventPublisher) JiraTaskCreated(payload model.TaskPayload) error { +func (p *EventPublisher) JiraTaskCreated(ctx context.Context, payload model.TaskPayload) error { routingKey := fmt.Sprintf(string(contract.TaskCreatedJiraEvent), payload.SlackChannel) - if err := p.queueProvider.Publish(payload, contract.BRPEventsExchange, routingKey); err != nil { + if err := p.queueProvider.Publish(ctx, payload, contract.BRPEventsExchange, routingKey); err != nil { return errors.Wrap(err, fmt.Sprintf("failed to send a %s to events queue", routingKey)) } return nil } -func (p *EventPublisher) ClickUpTaskUpdated(payload model.TaskChanges, slackChannel string) error { +func (p *EventPublisher) ClickUpTaskUpdated(ctx context.Context, payload model.TaskChanges, slackChannel string) error { routingKey := fmt.Sprintf(string(contract.TaskUpdatedClickUpEvent), slackChannel) - if err := p.queueProvider.Publish(payload, contract.BRPEventsExchange, routingKey); err != nil { + if err := p.queueProvider.Publish(ctx, payload, contract.BRPEventsExchange, routingKey); err != nil { return errors.Wrap(err, fmt.Sprintf("failed to send a %s to events queue", routingKey)) }