update workflows, CHANGELOG

Signed-off-by: Valery Piashchynski <[email protected]>

9 files changed, 377 insertions, 118 deletions

diff --git a/.github/workflows/release.yml b/.github/workflows/release.yml
index 8f77f64b..30faad75 100644
--- a/.github/workflows/release.yml
+++ b/.github/workflows/release.yml
@@ -22,22 +22,31 @@ jobs:
             compiler: gcc
             archiver: tar
             arch: amd64
+            tags: ''
+            # -----
           - os: linux
             compiler: gcc
             archiver: tar
             arch: arm64
+            tags: ''
+            # -----
           - os: darwin
             compiler: gcc
             archiver: tar
             arch: arm64
+            tags: ''
+            # -----
           - os: freebsd
             compiler: gcc
             archiver: tar
             arch: amd64
+            tags: ''
+            # -----
           - os: ''
             compiler: musl-gcc # more info: <https://musl.libc.org/>
             archiver: zip
             arch: amd64
+            tags: -tags musl
     steps:
       - name: Set up Go
         uses: actions/setup-go@v3
@@ -81,13 +90,13 @@ jobs:
           CC: ${{ matrix.compiler }}
           GPG_SIGNING_KEY: ${{ secrets.GPG_SIGNING_KEY }}
           GPG_PASS: ${{secrets.GPG_PASS}}
-          CGO_ENABLED: 0
+          CGO_ENABLED: 1
           LDFLAGS: >-
             -s
             -X github.com/roadrunner-server/roadrunner/v2/internal/meta.version=${{ steps.values.outputs.version }}
             -X github.com/roadrunner-server/roadrunner/v2/internal/meta.buildTime=${{ steps.values.outputs.timestamp }}
         run: |
-          go build -trimpath -ldflags "$LDFLAGS" -o "./${{ steps.values.outputs.binary-name }}" ./cmd/rr
+          go build ${{ matrix.tags }} -trimpath -ldflags "$LDFLAGS" -o "./${{ steps.values.outputs.binary-name }}" ./cmd/rr
           stat "./${{ steps.values.outputs.binary-name }}"
           gpg --detach-sign --armor "./${{ steps.values.outputs.binary-name }}"
 
diff --git a/.github/workflows/release_dep.yml b/.github/workflows/release_dep.yml
index f11547c3..fd92eb96 100644
--- a/.github/workflows/release_dep.yml
+++ b/.github/workflows/release_dep.yml
@@ -53,7 +53,7 @@ jobs:
           CC: ${{ matrix.compiler }}
           GPG_SIGNING_KEY: ${{ secrets.GPG_SIGNING_KEY }}
           GPG_PASS: ${{secrets.GPG_PASS}}
-          CGO_ENABLED: 0
+          CGO_ENABLED: 1
           LDFLAGS: >-
             -s
             -X github.com/roadrunner-server/roadrunner/v2/internal/meta.version=${{ steps.values.outputs.version }}
diff --git a/.github/workflows/release_grpc.yml b/.github/workflows/release_grpc.yml
index 9964b6f6..19e64bde 100644
--- a/.github/workflows/release_grpc.yml
+++ b/.github/workflows/release_grpc.yml
@@ -22,26 +22,31 @@ jobs:
             compiler: gcc
             archiver: tar
             arch: amd64
+            tags: ''
             #----------
           - os: linux
             compiler: gcc
             archiver: tar
             arch: arm64
+            tags: ''
             #----------
           - os: freebsd
             compiler: gcc
             archiver: tar
             arch: amd64
+            tags: ''
             #----------
           - os: darwin
             compiler: gcc
             archiver: tar
             arch: arm64
+            tags: ''
             #----------
           - os: ''
             compiler: musl-gcc # more info: <https://musl.libc.org/>
             archiver: zip
             arch: amd64
+            tags: -tags musl
     steps:
       - name: Set up Go
         uses: actions/setup-go@v3
@@ -85,11 +90,11 @@ jobs:
           GOOS: ${{ matrix.os }}
           GOARCH: ${{ matrix.arch }}
           CC: ${{ matrix.compiler }}
-          CGO_ENABLED: 0
+          CGO_ENABLED: 1
           LDFLAGS: >-
             -s
         run: |
-          go build -trimpath -ldflags "$LDFLAGS" -o "./${{ steps.values.outputs.binary-name }}" protoc_plugins/protoc-gen-php-grpc/main.go
+          go build ${{ matrix.tags }} -trimpath -ldflags "$LDFLAGS" -o "./${{ steps.values.outputs.binary-name }}" protoc_plugins/protoc-gen-php-grpc/main.go
           stat "./${{ steps.values.outputs.binary-name }}"
           gpg --detach-sign --armor "./${{ steps.values.outputs.binary-name }}"
 
diff --git a/.github/workflows/tests.yml b/.github/workflows/tests.yml
index 8ac3a953..6eb3b215 100644
--- a/.github/workflows/tests.yml
+++ b/.github/workflows/tests.yml
@@ -119,7 +119,7 @@ jobs:
         env:
           GOOS: ${{ matrix.os }}
           GOARCH: amd64
-          CGO_ENABLED: 0
+          CGO_ENABLED: 1
           LDFLAGS: -s
             -X github.com/roadrunner-server/roadrunner/v2/internal/meta.version=${{ steps.values.outputs.version }}
             -X github.com/roadrunner-server/roadrunner/v2/internal/meta.buildTime=${{ steps.values.outputs.timestamp }}
diff --git a/CHANGELOG.md b/CHANGELOG.md
index e3147816..10377f15 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,6 +1,77 @@
 # CHANGELOG
 
-## v2.11.0 (28.07.2022)
+## v2.11.0-beta.2 (28.07.2022)
+
+## 👀 New:
+
+- ✏️ **[BETA]: Kafka driver**: New kafka driver for the Jobs plugin.
+
+Some info:
+- RR uses confluentic kafka driver from the `librdkafka` developers
+- Go (CGO) driver: https://github.com/confluentinc/confluent-kafka-go/
+- Original kafka C driver: https://github.com/edenhill/librdkafka
+
+Configuration:
+```yaml
+jobs:
+    num_pollers: 10
+    pool:
+        num_workers: 2
+
+    pipelines:
+        test-1:
+            driver: kafka
+            config:
+                priority: 1
+                topics:
+                    - test-1
+                number_of_partitions: 2
+                create_topics_on_start: true
+
+                topics_config:
+                    compression:type: snappy
+
+                consumer_config:
+                    bootstrap:servers: 127.0.0.1:9092
+                    group:id: default-1
+                    enable:partition:eof: true
+                    auto:offset:reset: earliest
+
+                producer_config:
+                    bootstrap:servers: 127.0.0.1:9092
+
+        test-2:
+            driver: kafka
+            config:
+                priority: 2
+                topics:
+                    - test-2
+                number_of_partitions: 2
+                create_topics_on_start: true
+
+                topics_config:
+                    compression:type: snappy
+
+                consumer_config:
+                    bootstrap:servers: 127.0.0.1:9092
+                    group:id: default-2
+                    enable:partition:eof: true
+                    auto:offset:reset: earliest
+
+                producer_config:
+                    bootstrap:servers: 127.0.0.1:9092
+
+    consume: [ "test-1", "test-2" ]
+```
+
+## 🩹 Fixes:
+
+- ✏️ **gRPC Plugin**: Fix issue when some proto files might not be added automatically to use a reflection server.
+- 🐛 **SDK**: Use `pool.allocate_timeout` for the sockets/tcp relays instead of silently used of `relay_timeout`.
+
+---
+
+## v2.11.0-beta.1 (18.07.2022)
 
 ## 👀 New:
 
@@ -25,6 +96,7 @@ grpc:
     - "second.proto"
 ```
 
+---
 
 ## v2.10.7 (14.07.2022)
 
diff --git a/container/plugins.go b/container/plugins.go
index 3ee8cdc7..8f382c61 100644
--- a/container/plugins.go
+++ b/container/plugins.go
@@ -1,3 +1,5 @@
+//go:build !windows
+
 package container
 
 import (
@@ -13,6 +15,7 @@ import (
 	httpPlugin "github.com/roadrunner-server/http/v2"
 	"github.com/roadrunner-server/informer/v2"
 	"github.com/roadrunner-server/jobs/v2"
+	"github.com/roadrunner-server/kafka/v2"
 	"github.com/roadrunner-server/logger/v2"
 	"github.com/roadrunner-server/memory/v2"
 	"github.com/roadrunner-server/metrics/v2"
@@ -67,6 +70,7 @@ func Plugins() []interface{} { //nolint:funlen
 		&sqs.Plugin{},
 		&nats.Plugin{},
 		&beanstalk.Plugin{},
+		&kafka.Plugin{},
 		// =========
 
 		// http server plugin with middleware
diff --git a/container/plugins_windows.go b/container/plugins_windows.go
new file mode 100644
index 00000000..f7af327f
--- /dev/null
+++ b/container/plugins_windows.go
@@ -0,0 +1,114 @@
+//go:build windows
+
+package container
+
+import (
+	"github.com/roadrunner-server/amqp/v2"
+	"github.com/roadrunner-server/beanstalk/v2"
+	"github.com/roadrunner-server/boltdb/v2"
+	"github.com/roadrunner-server/broadcast/v2"
+	"github.com/roadrunner-server/cache/v2"
+	"github.com/roadrunner-server/fileserver/v2"
+	grpcPlugin "github.com/roadrunner-server/grpc/v2"
+	"github.com/roadrunner-server/gzip/v2"
+	"github.com/roadrunner-server/headers/v2"
+	httpPlugin "github.com/roadrunner-server/http/v2"
+	"github.com/roadrunner-server/informer/v2"
+	"github.com/roadrunner-server/jobs/v2"
+	"github.com/roadrunner-server/logger/v2"
+	"github.com/roadrunner-server/memory/v2"
+	"github.com/roadrunner-server/metrics/v2"
+	"github.com/roadrunner-server/nats/v2"
+	newrelic "github.com/roadrunner-server/new_relic/v2"
+	rrOtel "github.com/roadrunner-server/otel/v2"
+	"github.com/roadrunner-server/prometheus/v2"
+	proxyIP "github.com/roadrunner-server/proxy_ip_parser/v2"
+	"github.com/roadrunner-server/redis/v2"
+	"github.com/roadrunner-server/reload/v2"
+	"github.com/roadrunner-server/resetter/v2"
+	rpcPlugin "github.com/roadrunner-server/rpc/v2"
+	"github.com/roadrunner-server/send/v2"
+	"github.com/roadrunner-server/server/v2"
+	"github.com/roadrunner-server/service/v2"
+	"github.com/roadrunner-server/sqs/v2"
+	"github.com/roadrunner-server/static/v2"
+	"github.com/roadrunner-server/status/v2"
+	"github.com/roadrunner-server/websockets/v2"
+
+	"github.com/roadrunner-server/kv/v2"
+	"github.com/roadrunner-server/memcached/v2"
+	"github.com/roadrunner-server/tcp/v2"
+	rrt "github.com/temporalio/roadrunner-temporal"
+)
+
+// Plugins returns active plugins for the endure container. Feel free to add or remove any plugins.
+func Plugins() []interface{} { //nolint:funlen
+	return []interface{}{
+		// bundled
+		// informer plugin (./rr workers, ./rr workers -i)
+		&informer.Plugin{},
+		// resetter plugin (./rr reset)
+		&resetter.Plugin{},
+
+		// logger plugin
+		&logger.Plugin{},
+		// metrics plugin
+		&metrics.Plugin{},
+		// reload plugin
+		&reload.Plugin{},
+		// rpc plugin (workers, reset)
+		&rpcPlugin.Plugin{},
+		// server plugin (NewWorker, NewWorkerPool)
+		&server.Plugin{},
+		// service plugin
+		&service.Plugin{},
+
+		// ========= JOBS bundle
+		&jobs.Plugin{},
+		&amqp.Plugin{},
+		&sqs.Plugin{},
+		&nats.Plugin{},
+		&beanstalk.Plugin{},
+		// =========
+
+		// http server plugin with middleware
+		&httpPlugin.Plugin{},
+		&newrelic.Plugin{},
+		&static.Plugin{},
+		&headers.Plugin{},
+		&status.Plugin{},
+		&gzip.Plugin{},
+		&prometheus.Plugin{},
+		&cache.Plugin{},
+		&send.Plugin{},
+		&proxyIP.Plugin{},
+		&fileserver.Plugin{},
+		&rrOtel.Plugin{},
+		// ===================
+
+		&grpcPlugin.Plugin{},
+		// kv + ws + jobs plugin
+		&memory.Plugin{},
+		// KV + Jobs
+		&boltdb.Plugin{},
+
+		// broadcast via memory or redis
+		// used in conjunction with Websockets, memory and redis plugins
+		&broadcast.Plugin{},
+		// ======== websockets broadcast bundle
+		&websockets.Plugin{},
+		&redis.Plugin{},
+		// =========
+
+		// ============== KV
+		&kv.Plugin{},
+		&memcached.Plugin{},
+		// ==============
+
+		// raw TCP connections handling
+		&tcp.Plugin{},
+
+		// temporal plugins
+		&rrt.Plugin{},
+	}
+}
diff --git a/go.mod b/go.mod
index be0354b6..b84178f5 100644
--- a/go.mod
+++ b/go.mod
@@ -8,45 +8,46 @@ require (
 	github.com/fatih/color v1.13.0
 	github.com/joho/godotenv v1.4.0
 	github.com/olekukonko/tablewriter v0.0.5
-	github.com/roadrunner-server/amqp/v2 v2.17.8
+	github.com/roadrunner-server/amqp/v2 v2.17.9
 	github.com/roadrunner-server/api/v2 v2.20.0
-	github.com/roadrunner-server/beanstalk/v2 v2.16.5
-	github.com/roadrunner-server/boltdb/v2 v2.16.7
-	github.com/roadrunner-server/broadcast/v2 v2.12.9
-	github.com/roadrunner-server/cache/v2 v2.15.8
-	github.com/roadrunner-server/config/v2 v2.14.8
+	github.com/roadrunner-server/beanstalk/v2 v2.16.6
+	github.com/roadrunner-server/boltdb/v2 v2.16.8
+	github.com/roadrunner-server/broadcast/v2 v2.12.10
+	github.com/roadrunner-server/cache/v2 v2.15.9
+	github.com/roadrunner-server/config/v2 v2.14.9
 	github.com/roadrunner-server/endure v1.3.1
 	github.com/roadrunner-server/errors v1.1.2
-	github.com/roadrunner-server/fileserver/v2 v2.13.8
+	github.com/roadrunner-server/fileserver/v2 v2.13.9
 	github.com/roadrunner-server/goridge/v3 v3.4.5
-	github.com/roadrunner-server/grpc/v2 v2.19.1
-	github.com/roadrunner-server/gzip/v2 v2.12.5
-	github.com/roadrunner-server/headers/v2 v2.12.6
-	github.com/roadrunner-server/http/v2 v2.20.1
-	github.com/roadrunner-server/informer/v2 v2.11.9
-	github.com/roadrunner-server/jobs/v2 v2.16.0
-	github.com/roadrunner-server/kv/v2 v2.12.10
-	github.com/roadrunner-server/logger/v2 v2.13.8
-	github.com/roadrunner-server/memcached/v2 v2.12.6
-	github.com/roadrunner-server/memory/v2 v2.15.5
-	github.com/roadrunner-server/metrics/v2 v2.13.8
-	github.com/roadrunner-server/nats/v2 v2.16.4
-	github.com/roadrunner-server/new_relic/v2 v2.14.9
+	github.com/roadrunner-server/grpc/v2 v2.19.2
+	github.com/roadrunner-server/gzip/v2 v2.12.6
+	github.com/roadrunner-server/headers/v2 v2.12.7
+	github.com/roadrunner-server/http/v2 v2.20.2
+	github.com/roadrunner-server/informer/v2 v2.11.10
+	github.com/roadrunner-server/jobs/v2 v2.16.1
+	github.com/roadrunner-server/kafka/v2 v2.0.0-beta.2
+	github.com/roadrunner-server/kv/v2 v2.12.11
+	github.com/roadrunner-server/logger/v2 v2.13.9
+	github.com/roadrunner-server/memcached/v2 v2.12.7
+	github.com/roadrunner-server/memory/v2 v2.15.6
+	github.com/roadrunner-server/metrics/v2 v2.13.9
+	github.com/roadrunner-server/nats/v2 v2.16.5
+	github.com/roadrunner-server/new_relic/v2 v2.14.10
 	github.com/roadrunner-server/otel/v2 v2.3.0
-	github.com/roadrunner-server/prometheus/v2 v2.13.8
+	github.com/roadrunner-server/prometheus/v2 v2.13.9
 	github.com/roadrunner-server/proxy_ip_parser/v2 v2.4.0
-	github.com/roadrunner-server/redis/v2 v2.15.6
-	github.com/roadrunner-server/reload/v2 v2.12.9
-	github.com/roadrunner-server/resetter/v2 v2.11.9
-	github.com/roadrunner-server/rpc/v2 v2.13.7
-	github.com/roadrunner-server/send/v2 v2.12.5
-	github.com/roadrunner-server/server/v2 v2.14.8
-	github.com/roadrunner-server/service/v2 v2.15.2
-	github.com/roadrunner-server/sqs/v2 v2.17.5
-	github.com/roadrunner-server/static/v2 v2.13.6
-	github.com/roadrunner-server/status/v2 v2.13.9
-	github.com/roadrunner-server/tcp/v2 v2.13.9
-	github.com/roadrunner-server/websockets/v2 v2.14.8
+	github.com/roadrunner-server/redis/v2 v2.15.7
+	github.com/roadrunner-server/reload/v2 v2.12.10
+	github.com/roadrunner-server/resetter/v2 v2.11.10
+	github.com/roadrunner-server/rpc/v2 v2.13.8
+	github.com/roadrunner-server/send/v2 v2.12.6
+	github.com/roadrunner-server/server/v2 v2.14.9
+	github.com/roadrunner-server/service/v2 v2.15.3
+	github.com/roadrunner-server/sqs/v2 v2.17.6
+	github.com/roadrunner-server/static/v2 v2.13.7
+	github.com/roadrunner-server/status/v2 v2.13.10
+	github.com/roadrunner-server/tcp/v2 v2.13.10
+	github.com/roadrunner-server/websockets/v2 v2.14.9
 	github.com/spf13/cobra v1.5.0
 	github.com/spf13/viper v1.12.0
 	github.com/stretchr/testify v1.8.0
@@ -73,6 +74,7 @@ require (
 	github.com/caddyserver/certmagic v0.16.1 // indirect
 	github.com/cenkalti/backoff/v4 v4.1.3 // indirect
 	github.com/cespare/xxhash/v2 v2.1.2 // indirect
+	github.com/confluentinc/confluent-kafka-go v1.9.1 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
 	github.com/emicklei/proto v1.11.0 // indirect
@@ -125,10 +127,10 @@ require (
 	github.com/prometheus/client_golang v1.12.2 // indirect
 	github.com/prometheus/client_model v0.2.0 // indirect
 	github.com/prometheus/common v0.37.0 // indirect
-	github.com/prometheus/procfs v0.7.3 // indirect
+	github.com/prometheus/procfs v0.8.0 // indirect
 	github.com/rabbitmq/amqp091-go v1.4.0 // indirect
 	github.com/rivo/uniseg v0.2.0 // indirect
-	github.com/roadrunner-server/sdk/v2 v2.18.0 // indirect
+	github.com/roadrunner-server/sdk/v2 v2.18.1 // indirect
 	github.com/roadrunner-server/tcplisten v1.1.2 // indirect
 	github.com/robfig/cron v1.2.0 // indirect
 	github.com/shirou/gopsutil v3.21.11+incompatible // indirect
@@ -172,13 +174,13 @@ require (
 	go.uber.org/zap v1.21.0 // indirect
 	golang.org/x/crypto v0.0.0-20220722155217-630584e8d5aa // indirect
 	golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4 //indirect
-	golang.org/x/net v0.0.0-20220722155237-a158d28d115b // indirect
+	golang.org/x/net v0.0.0-20220725212005-46097bf591d3 // indirect
 	golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4 // indirect
 	golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f // indirect
 	golang.org/x/text v0.3.7 // indirect
 	golang.org/x/time v0.0.0-20220722155302-e5dcc9cfc0b9 // indirect
 	golang.org/x/tools v0.1.11 // indirect
-	google.golang.org/genproto v0.0.0-20220722212130-b98a9ff5e252 // indirect
+	google.golang.org/genproto v0.0.0-20220725144611-272f38e5d71b // indirect
 	google.golang.org/grpc v1.48.0 // indirect
 	google.golang.org/protobuf v1.28.0 // indirect
 	gopkg.in/ini.v1 v1.66.6 // indirect
diff --git a/go.sum b/go.sum
index f57bd4a2..815a1f7d 100644
--- a/go.sum
+++ b/go.sum
@@ -42,6 +42,9 @@ github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym
 github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
 github.com/Shopify/sarama v1.30.0/go.mod h1:zujlQQx1kzHsh4jfV1USnptCQrHAEZ2Hk8fTKCulPVs=
 github.com/Shopify/toxiproxy/v2 v2.1.6-0.20210914104332-15ea381dcdae/go.mod h1:/cvHQkZ1fst0EmZnA5dFtiQdWCNCFYzb+uE2vqVgvx0=
+github.com/actgardner/gogen-avro/v10 v10.1.0/go.mod h1:o+ybmVjEa27AAr35FRqU98DJu1fXES56uXniYFv4yDA=
+github.com/actgardner/gogen-avro/v10 v10.2.1/go.mod h1:QUhjeHPchheYmMDni/Nx7VB0RsT/ee8YIgGY/xpEQgQ=
+github.com/actgardner/gogen-avro/v9 v9.1.0/go.mod h1:nyTj6wPqDJoxM3qdnjcLv+EnMDSDFqE0qDpva2QRmKc=
 github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
 github.com/alecthomas/template v0.0.0-20190718012654-fb15b899a751/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
 github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
@@ -109,6 +112,8 @@ github.com/cncf/xds/go v0.0.0-20210805033703-aa0b78936158/go.mod h1:eXthEFrGJvWH
 github.com/cncf/xds/go v0.0.0-20210922020428-25de7278fc84/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs=
 github.com/cncf/xds/go v0.0.0-20211001041855-01bcc9b48dfe/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs=
 github.com/cncf/xds/go v0.0.0-20211011173535-cb28da3451f1/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs=
+github.com/confluentinc/confluent-kafka-go v1.9.1 h1:L3aW6KvTyrq/+BOMnDm9xJylhAEoAgqhoaJbMPe3GQI=
+github.com/confluentinc/confluent-kafka-go v1.9.1/go.mod h1:ptXNqsuDfYbAE/LBW6pnwWZElUoWxHoV8E43DCrliyo=
 github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=
 github.com/cpuguy83/go-md2man/v2 v2.0.2/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=
 github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
@@ -129,6 +134,7 @@ github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.m
 github.com/envoyproxy/go-control-plane v0.9.4/go.mod h1:6rpuAdCZL397s3pYoYcLgu1mIlRU8Am5FuJP05cCM98=
 github.com/envoyproxy/go-control-plane v0.9.7/go.mod h1:cwu0lG7PUMfa9snN8LXBig5ynNVH9qI8YYLbd1fK2po=
 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.20210217033140-668b12f5399d/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/go-control-plane v0.10.2-0.20220325020618-49ff273808a1/go.mod h1:KJwIaB5Mv44NWtYuAOFCVOjcI94vtpEz2JU/D2v6IjE=
@@ -140,7 +146,11 @@ github.com/fatih/color v1.13.0/go.mod h1:kLAiJbzzSOZDVNGyDpeOxJ47H46qBXwg5ILebYF
 github.com/felixge/httpsnoop v1.0.3 h1:s/nj+GCswXYzN5v2DpNMuMQYe+0DDwt5WVCU6CWBdXk=
 github.com/felixge/httpsnoop v1.0.3/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=
 github.com/fortytw2/leaktest v1.3.0/go.mod h1:jDsjWgpAGjm2CA7WthBh/CdZYEPF31XHquHwclZch5g=
+github.com/frankban/quicktest v1.2.2/go.mod h1:Qh/WofXFeiAFII1aEBu529AtJo6Zg2VHscnEsbBnJ20=
+github.com/frankban/quicktest v1.7.2/go.mod h1:jaStnuzAqU1AJdCO0l53JDCJrVDKcS03DbaAcR7Ks/o=
+github.com/frankban/quicktest v1.10.0/go.mod h1:ui7WezCLWMWxVWr1GETZY3smRy0G4KWq9vcPtJmFl7Y=
 github.com/frankban/quicktest v1.11.3/go.mod h1:wRf/ReqHper53s+kmmSZizM8NamnL3IM0I9ntUbOk+k=
+github.com/frankban/quicktest v1.14.0/go.mod h1:NeW+ay9A/U67EYXNFA1nPE8e/tnQv/09mUdL/ijj8og=
 github.com/frankban/quicktest v1.14.3 h1:FJKSZTDHjyhriyC81FLQ0LY93eSai0ZyR/ZIkd3ZUKE=
 github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
 github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ=
@@ -221,10 +231,13 @@ github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw
 github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
 github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw=
 github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
+github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
+github.com/golang/snappy v0.0.3/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
 github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
 github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
 github.com/google/btree v1.0.0/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
 github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
+github.com/google/go-cmp v0.2.1-0.20190312032427-6f77996f0c42/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
 github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
 github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
 github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
@@ -251,6 +264,7 @@ github.com/google/pprof v0.0.0-20200708004538-1a94d8640e99/go.mod h1:ZgVRPoUq/hf
 github.com/google/pprof v0.0.0-20201023163331-3e6fc7fc9c4c/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
 github.com/google/pprof v0.0.0-20201203190320-1bf35d6f28c2/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
 github.com/google/pprof v0.0.0-20201218002935-b9804c9f04c2/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
+github.com/google/pprof v0.0.0-20211008130755-947d60d73cc0/go.mod h1:KgnwoLYCZ8IQu3XUZ8Nc/bM9CCZFOyjUNOSygVozoDg=
 github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
 github.com/google/uuid v1.0.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
@@ -268,6 +282,7 @@ github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFb
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.7.0/go.mod h1:hgWBS7lorOAVIJEQMi4ZsPv9hVvWI6+ch50m39Pf2Ks=
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.11.0 h1:Ghn7copILfeIg0y8sTGRppI1bd8I4l2VN3cob0Xeqwg=
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.11.0/go.mod h1:dnjr4snxnhRSn5GWqJUva2AoMbeaxyAcepvc0Tg8lXk=
+github.com/hamba/avro v1.5.6/go.mod h1:3vNT0RLXXpFm2Tb/5KC71ZRJlOroggq1Rcitb6k4Fr8=
 github.com/hashicorp/go-uuid v1.0.2/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
 github.com/hashicorp/go-version v1.6.0 h1:feTTfFNnjP967rlCxM/I9g701jU+RN74YKx2mOkIeek=
 github.com/hashicorp/go-version v1.6.0/go.mod h1:fltr4n8CU8Ke44wwGCBoEymUuxUHl09ZGVZPK5anwXA=
@@ -275,17 +290,26 @@ github.com/hashicorp/golang-lru v0.5.0/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ
 github.com/hashicorp/golang-lru v0.5.1/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
 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/heetch/avro v0.3.1/go.mod h1:4xn38Oz/+hiEUTpbVfGVLfvOg0yKLlRP7Q9+gJJILgA=
 github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
+github.com/iancoleman/orderedmap v0.0.0-20190318233801-ac98e3ecb4b0/go.mod h1:N0Wam8K1arqPXNWjMo21EXnBPOPp36vB07FNRdD2geA=
 github.com/ianlancetaylor/demangle v0.0.0-20181102032728-5e5cf60278f6/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
 github.com/ianlancetaylor/demangle v0.0.0-20200824232613-28f6c0f3b639/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
+github.com/ianlancetaylor/demangle v0.0.0-20210905161508-09a460cdf81d/go.mod h1:aYm2/VgdVmcIU8iMfdMvDMsRAQjcfZSKFby6HOFvi/w=
 github.com/inconshreveable/mousetrap v1.0.0 h1:Z8tu5sraLXCXIcARxBp/8cbvlwVa7Z1NHg9XEKhtSvM=
 github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=
+github.com/invopop/jsonschema v0.4.0/go.mod h1:O9uiLokuu0+MGFlyiaqtWxwqJm41/+8Nj0lD7A36YH0=
 github.com/jcmturner/aescts/v2 v2.0.0/go.mod h1:AiaICIRyfYg35RUkr8yESTqvSy7csK90qZ5xfvvsoNs=
 github.com/jcmturner/dnsutils/v2 v2.0.0/go.mod h1:b0TnjGOvI/n42bZa+hmXL+kFJZsFT7G4t3HTlQ184QM=
 github.com/jcmturner/gofork v1.0.0/go.mod h1:MK8+TM0La+2rjBD4jE12Kj1pCCxK7d2LK/UM3ncEo0o=
 github.com/jcmturner/goidentity/v6 v6.0.1/go.mod h1:X1YW3bgtvwAXju7V3LCIMpY0Gbxyjn/mY9zx4tFonSg=
 github.com/jcmturner/gokrb5/v8 v8.4.2/go.mod h1:sb+Xq/fTY5yktf/VxLsE3wlfPqQjp0aWNYyvBVK62bc=
 github.com/jcmturner/rpc/v2 v2.0.3/go.mod h1:VUJYCIDm3PVOEHw8sgt091/20OJjskO/YJki3ELg/Hc=
+github.com/jhump/gopoet v0.0.0-20190322174617-17282ff210b3/go.mod h1:me9yfT6IJSlOL3FCfrg+L6yzUEZ+5jW6WHt4Sk+UPUI=
+github.com/jhump/gopoet v0.1.0/go.mod h1:me9yfT6IJSlOL3FCfrg+L6yzUEZ+5jW6WHt4Sk+UPUI=
+github.com/jhump/goprotoc v0.5.0/go.mod h1:VrbvcYrQOrTi3i0Vf+m+oqQWk9l72mjkJCYo7UvLHRQ=
+github.com/jhump/protoreflect v1.11.0/go.mod h1:U7aMIjN0NWq9swDP7xDdoMfRHb35uiuTd3Z9nFXJf5E=
+github.com/jhump/protoreflect v1.12.0/go.mod h1:JytZfP5d0r8pVNLZvai7U/MCuTWITgrI4tTg7puQFKI=
 github.com/jmespath/go-jmespath v0.4.0/go.mod h1:T8mJZnbsbmF+m6zOOFylbeCJqk5+pHWvzYPziyZiYoo=
 github.com/jmespath/go-jmespath/internal/testify v1.5.1/go.mod h1:L3OGu8Wl2/fWfCI6z80xFu9LTZmf1ZRjMHUOPmWr69U=
 github.com/joho/godotenv v1.4.0 h1:3l4+N6zfMWnkbPEXKng2o2/MR5mSwTrBih4ZEkkz1lg=
@@ -297,6 +321,7 @@ github.com/json-iterator/go v1.1.11/go.mod h1:KdQUCv79m/52Kvf8AW2vK1V8akMuk1QjK/
 github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
 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/juju/qthttptest v0.1.1/go.mod h1:aTlAv8TYaflIiTDIQYzxnl1QdPjAg8Q8qJMErpKy6A4=
 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/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=
@@ -312,14 +337,20 @@ github.com/konsorten/go-windows-terminal-sequences v1.0.3/go.mod h1:T0+1ngSBFLxv
 github.com/kr/fs v0.1.0/go.mod h1:FFnZGqtBN9Gxj7eW1uZ42v5BccTP0vu6NEaFoC2HwRg=
 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.0/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
 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/libdns/libdns v0.2.1 h1:Wu59T7wSHRgtA0cfxC+n1c/e+O3upJGWytknkmFEDis=
 github.com/libdns/libdns v0.2.1/go.mod h1:yQCXzk1lEZmmCPa857bnk4TsOiqYasqpyOEeSObbb40=
+github.com/linkedin/goavro v2.1.0+incompatible/go.mod h1:bBCwI2eGYpUI/4820s67MElg9tdeLbINjLjiM2xZFYM=
+github.com/linkedin/goavro/v2 v2.10.0/go.mod h1:UgQUb2N/pmueQYH9bfqFioWxzYCZXSfF8Jw03O5sjqA=
+github.com/linkedin/goavro/v2 v2.10.1/go.mod h1:UgQUb2N/pmueQYH9bfqFioWxzYCZXSfF8Jw03O5sjqA=
+github.com/linkedin/goavro/v2 v2.11.1/go.mod h1:UgQUb2N/pmueQYH9bfqFioWxzYCZXSfF8Jw03O5sjqA=
 github.com/magiconair/properties v1.8.6 h1:5ibWZ6iY0NctNGWo87LalDlEZ6R41TqbbDamhfG/Qzo=
 github.com/magiconair/properties v1.8.6/go.mod h1:y3VJvCyxH9uVvJTWEGAELF3aiYNyPKd5NZ3oSwXrF60=
 github.com/mattn/go-colorable v0.1.9/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc=
@@ -360,6 +391,7 @@ github.com/nats-io/nuid v1.0.1/go.mod h1:19wcPz3Ph3q0Jbyiqsd0kePYG7A95tJPxeL+1OS
 github.com/newrelic/go-agent/v3 v3.17.0 h1:FLhxjckKKoJWB2rR14oNm+mYZLpktfEy+JKRSF5WgXw=
 github.com/newrelic/go-agent/v3 v3.17.0/go.mod h1:BFJOlbZWRlPTXKYIC1TTTtQKTnYntEJaU0VU507hDc0=
 github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno=
+github.com/nrwiersma/avro-benchmarks v0.0.0-20210913175520-21aec48c8f76/go.mod h1:iKyFMidsk/sVYONJRE372sJuX/QTRPacU7imPqqsu7g=
 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=
@@ -384,6 +416,7 @@ github.com/pelletier/go-toml v1.9.5/go.mod h1:u1nR/EPcESfeI/szUZKdtJ0xRNbUoANCko
 github.com/pelletier/go-toml/v2 v2.0.2 h1:+jQXlF3scKIcSEKkdHzXhCTDLPFi5r1wnK6yPS+49Gw=
 github.com/pelletier/go-toml/v2 v2.0.2/go.mod h1:MovirKjgVRESsAvNZlAjtFwV867yGuwRkXbG66OzopI=
 github.com/pierrec/lz4 v2.6.1+incompatible/go.mod h1:pdkljMzZIN41W+lC3N2tnIh5sFi+IEE17M5jbnwPHcY=
+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/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
@@ -413,103 +446,110 @@ github.com/prometheus/procfs v0.0.0-20181005140218-185b4288413d/go.mod h1:c3At6R
 github.com/prometheus/procfs v0.0.2/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
 github.com/prometheus/procfs v0.1.3/go.mod h1:lV6e/gmhEcM9IjHGsFOCxxuZ+z1YqCvr4OA4YeYWdaU=
 github.com/prometheus/procfs v0.6.0/go.mod h1:cz+aTbrPOrUb4q7XlbU9ygM+/jj0fzG6c1xBZuNvfVA=
-github.com/prometheus/procfs v0.7.3 h1:4jVXhlkAyzOScmCkXBTOLRLTz8EeU+eyjrwB/EPq0VU=
 github.com/prometheus/procfs v0.7.3/go.mod h1:cz+aTbrPOrUb4q7XlbU9ygM+/jj0fzG6c1xBZuNvfVA=
+github.com/prometheus/procfs v0.8.0 h1:ODq8ZFEaYeCaZOJlZZdJA2AbQR98dSHSM1KW/You5mo=
+github.com/prometheus/procfs v0.8.0/go.mod h1:z7EfXMXOkbkqb9IINtpCn86r/to3BnA0uaxHdg830/4=
 github.com/rabbitmq/amqp091-go v1.1.0/go.mod h1:ogQDLSOACsLPsIq0NpbtiifNZi2YOz0VTJ0kHRghqbM=
 github.com/rabbitmq/amqp091-go v1.4.0 h1:T2G+J9W9OY4p64Di23J6yH7tOkMocgnESvYeBjuG9cY=
 github.com/rabbitmq/amqp091-go v1.4.0/go.mod h1:JsV0ofX5f1nwOGafb8L5rBItt9GyhfQfcJj+oyz0dGg=
 github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475/go.mod h1:bCqnVzQkZxMG4s8nGwiZ5l3QUCyqpo9Y+/ZMZ9VjZe4=
 github.com/rivo/uniseg v0.2.0 h1:S1pD9weZBuJdFmowNwbpi7BJ8TNftyUImj/0WQi72jY=
 github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
-github.com/roadrunner-server/amqp/v2 v2.17.8 h1:seUoiyGnAnELH/icTbr/d3lpKsllaTYcn0wf9A4PiRo=
-github.com/roadrunner-server/amqp/v2 v2.17.8/go.mod h1:1a7qfC54kh7JN/EEkbuAh8MOgFurO5ZRdBfoMHuj/Vw=
+github.com/roadrunner-server/amqp/v2 v2.17.9 h1:0Gu0la6p4ijG6FVirtzF3vKQSknWYolxRW6yy1MZvyE=
+github.com/roadrunner-server/amqp/v2 v2.17.9/go.mod h1:4Cr6WKV/U0A87Cuw5y8EZK+S5+vsJp6Rl4KHgXjAvfg=
 github.com/roadrunner-server/api/v2 v2.20.0 h1:VyWesy/EQGVcTk35KufUgUWSPwGprbC/N92Wb9t9NnM=
 github.com/roadrunner-server/api/v2 v2.20.0/go.mod h1:9AvCOEhbNyfPuCCsrpL84TFb0k56BPmYQ6tUBNLS58c=
-github.com/roadrunner-server/beanstalk/v2 v2.16.5 h1:vqqWA37IpO+dw1ExJB8xPmw1RfrSxteCG+iIeets/jQ=
-github.com/roadrunner-server/beanstalk/v2 v2.16.5/go.mod h1:KY2ZS6AnyWkhbnQ3bhrZBO0F3DkwBseNMpDE0UrTIfo=
-github.com/roadrunner-server/boltdb/v2 v2.16.7 h1:SnPXcO3+JnD2rZomL6nAtx/N3wj/hl6klD8waGQNJsA=
-github.com/roadrunner-server/boltdb/v2 v2.16.7/go.mod h1:/pwmknU0NlPQoKMM6vYid2YCSTMf/Kt4g09tIyYj4Oo=
-github.com/roadrunner-server/broadcast/v2 v2.12.9 h1:uP9uvy2LHpOQUAaYHZaEsNGNk44HP1bGrPT3CVHjdFk=
-github.com/roadrunner-server/broadcast/v2 v2.12.9/go.mod h1:u37xELeolq70JUcwzZ6lZKot1vdNzRV1d04g3jYuX+E=
-github.com/roadrunner-server/cache/v2 v2.15.8 h1:rntifH6S1Np4eOaKst5UIMHfp7V5VuZ1ezbWMK/pBDg=
-github.com/roadrunner-server/cache/v2 v2.15.8/go.mod h1:4IYMHzaU7gTcWRt0oCdximzZ+nrEvrHaSArgzp+d4bk=
-github.com/roadrunner-server/config/v2 v2.14.8 h1:2tDBVyPoHmACObXfWbC93hi4Gyg7WeTVacIIUefzOdU=
-github.com/roadrunner-server/config/v2 v2.14.8/go.mod h1:SFhNbLgY4Z+H4Co9+QvcK9y6lc3thK30jzzq1r8nR4M=
+github.com/roadrunner-server/beanstalk/v2 v2.16.6 h1:eHa3oALMbB9wlFkE2dy924WzUOWWxvF2e+vXyYEPwdI=
+github.com/roadrunner-server/beanstalk/v2 v2.16.6/go.mod h1:Vyf2+nurqTIZU+eFE44STA19M/VOdnxRxPe2ddKQUYU=
+github.com/roadrunner-server/boltdb/v2 v2.16.8 h1:WXsRxSvTal6cf2tVEHohwv2xg4F+YG8JFz12MD2KHrs=
+github.com/roadrunner-server/boltdb/v2 v2.16.8/go.mod h1:eSV991pPcHMHVMzRkWhGLMdDUHn7sAEuQ4sLn1uDOqU=
+github.com/roadrunner-server/broadcast/v2 v2.12.10 h1:a/4W+yTYYw3DaGWgsVRmmfvFDSvGTUaLeaW5kt8IrrA=
+github.com/roadrunner-server/broadcast/v2 v2.12.10/go.mod h1:m9nvqWgukZuytYV517pEBdQh18oAuEeLKOuPNSHXQGU=
+github.com/roadrunner-server/cache/v2 v2.15.9 h1:82sB5tOLhg7TaIIqnBHbzyYoub6jjF6pCmgIdGZRmeI=
+github.com/roadrunner-server/cache/v2 v2.15.9/go.mod h1:frsY3a8F9WNF5XmevHmq+W/Kxeky21wBhgmMt4k63Bg=
+github.com/roadrunner-server/config/v2 v2.14.9 h1:q+VDRCpo4wdqHNhdqkrYgh+XABNLsiM/SpRVkcgiu+U=
+github.com/roadrunner-server/config/v2 v2.14.9/go.mod h1:pqLokhzQME9djs8ZOQtIA80AmCaaq8sO8ieUru0NIUc=
 github.com/roadrunner-server/endure v1.3.1 h1:7YvXUOz+sHBv6i+Qx3V0rnGn/1poFLK11bOt8MHBfHc=
 github.com/roadrunner-server/endure v1.3.1/go.mod h1:uWaoO9yxGbryvbSG8ThSW1KKNnYwsoR53MQQEFUlK4s=
 github.com/roadrunner-server/errors v1.1.2 h1:+LPw9Akgg+8LAGM4wASMWLAoBIbyP+mhNfR+FBS2Slw=
 github.com/roadrunner-server/errors v1.1.2/go.mod h1:jVSh32nFtRMzKItYUM9W2CTLLpXAM8HseL2lUENPYtU=
-github.com/roadrunner-server/fileserver/v2 v2.13.8 h1:3x8/tBvWEY6N9W24QtffVLRg/mMw1dX/XuPwcl1fyts=
-github.com/roadrunner-server/fileserver/v2 v2.13.8/go.mod h1:ZmuEuOGIM6pyDFNnHOwWAWdO/mfGt00rmQqdMK0LMdA=
+github.com/roadrunner-server/fileserver/v2 v2.13.9 h1:h++tKKdLA3yIJfvPkpW3Ryki/9/jjEQTWEONb7nlMBk=
+github.com/roadrunner-server/fileserver/v2 v2.13.9/go.mod h1:IG/Ooh3pQlOFteWpwvg3+CUGT0NsKMZ9YpjAfRRLCgg=
 github.com/roadrunner-server/goridge/v3 v3.4.5 h1:g7K9kOmyAOQQ9TusDYksgyKBsKQrQVNc0CT1HKhaphg=
 github.com/roadrunner-server/goridge/v3 v3.4.5/go.mod h1:zGbUad2YyaaW9Vt9dqLBDcyrA45KlYoRh8jB7TUsStM=
-github.com/roadrunner-server/grpc/v2 v2.19.1 h1:VcU/+aA1N/Se9+qR3emQc4hu3Ba7bYFHD/pmdBQZQSE=
-github.com/roadrunner-server/grpc/v2 v2.19.1/go.mod h1:R5rBIrlMzKNEaeJ2gKJFAC2uyEX0Huucgz+HnFpZmq8=
-github.com/roadrunner-server/gzip/v2 v2.12.5 h1:TygneHz97KiOxfDJPRyfRWfLy0ac4g6IAi/8ZAuLrQk=
-github.com/roadrunner-server/gzip/v2 v2.12.5/go.mod h1:IQB9oGsH27uchzYaks5LYPo/Fre1P3KVzNbgEO8H8To=
-github.com/roadrunner-server/headers/v2 v2.12.6 h1:vNtCt12pQAwn36GlaAWouvN08TuFCOEWK/nBla8F6dE=
-github.com/roadrunner-server/headers/v2 v2.12.6/go.mod h1:QaF6Nd6brnMEiD32GOsKdt03Lcx7qvDkU2ZLKTC7iMg=
-github.com/roadrunner-server/http/v2 v2.20.1 h1:b2LlsMaZ1x/c5lhg8BwgmJNGye7O+T0iMjLUa9YoBNQ=
-github.com/roadrunner-server/http/v2 v2.20.1/go.mod h1:pSLX2lF/x07UP6iQwpj0dgVuM2WuwXB4xkxELc19jSw=
-github.com/roadrunner-server/informer/v2 v2.11.9 h1:WrDHLsKtDKXD+/eVONX5qKRWM8AAralF89TQSTmMyn0=
-github.com/roadrunner-server/informer/v2 v2.11.9/go.mod h1:y9Ue2XcRpaOzR5vr+SOgZJnz1HTRfgh9nlHd+83wu30=
-github.com/roadrunner-server/jobs/v2 v2.16.0 h1:SzmfAkSHxALAa+3azD9KHGVSpuZDOEdb1BZH3dqGP2E=
-github.com/roadrunner-server/jobs/v2 v2.16.0/go.mod h1:pGMg7sMeOmC9jhRkUWtvYL3QKe6AlbVidcvIZTjQTCo=
-github.com/roadrunner-server/kv/v2 v2.12.10 h1:q3UpmfI1FcaO4VlaV/A3CXT1t+Jexe5iOhPZGJzyFR0=
-github.com/roadrunner-server/kv/v2 v2.12.10/go.mod h1:/Jk2XS2g2Y5LXYehMqpLEYnXJBT04C0cB8mKVgJM+2E=
-github.com/roadrunner-server/logger/v2 v2.13.8 h1:DunFVWAHdjjXPo2aal4oDW4nbRFThth+gxwhTowAKVQ=
-github.com/roadrunner-server/logger/v2 v2.13.8/go.mod h1:NskRXaAGPPAhJcP68jRal5/CNV0HMd/T0+Zn5sqKX7A=
-github.com/roadrunner-server/memcached/v2 v2.12.6 h1:4O10Fnmq53Ymh5j+8n2SBSmrp3PeTND7PBKDDHlIXSw=
-github.com/roadrunner-server/memcached/v2 v2.12.6/go.mod h1:Bq54aE+sOmyJ++/8lh1J4JUA+tkglHtLw9oj7GzcApM=
-github.com/roadrunner-server/memory/v2 v2.15.5 h1:Qha8+7DigFHk3UcMTdoVgkipGEjMhn3uzGSCYntKrJ4=
-github.com/roadrunner-server/memory/v2 v2.15.5/go.mod h1:NUg8tSmQSgvMQIkaTiKgmmb8OG5hibg0oRUm7KMVlP8=
-github.com/roadrunner-server/metrics/v2 v2.13.8 h1:rYt87noRBgJHIanJ1uJUr3iMBgwG7dpIUUSb3gD7sMk=
-github.com/roadrunner-server/metrics/v2 v2.13.8/go.mod h1:4+o48WAF4/A2Lvh3ign5sT+NmHa0KBjO2eQhs7nDISs=
-github.com/roadrunner-server/nats/v2 v2.16.4 h1:xWfyN8XsIoqxqbDFm9qYX64CvO2EMWiKbeKmStUUSVY=
-github.com/roadrunner-server/nats/v2 v2.16.4/go.mod h1:1Mbqwc9Ybt8mdjJWsJ4lfxZweCcHZ3uXG0fMUuRnNEM=
-github.com/roadrunner-server/new_relic/v2 v2.14.9 h1:fUdj1WDjYo1zN2vjx+ezPYwVHST7pJb/6wSWlLJgwZ8=
-github.com/roadrunner-server/new_relic/v2 v2.14.9/go.mod h1:3OM5TfmftCzyuymqRhjw63Wzoc1meIR1b5rozD7G/tU=
+github.com/roadrunner-server/grpc/v2 v2.19.2 h1:b0Nu4nODwo8W6yyuVRiZyDBnSFJY72BHkrMLyHoth5g=
+github.com/roadrunner-server/grpc/v2 v2.19.2/go.mod h1:KuMR9HciW7NlPDu9wtRxxAftof5jLLePUefge/2tX6Y=
+github.com/roadrunner-server/gzip/v2 v2.12.6 h1:R+6m7kJY/KrJcevV5ou8DE+bRAK8ja7vtPUCICueTUw=
+github.com/roadrunner-server/gzip/v2 v2.12.6/go.mod h1:SCkpLbWRuqUBvi64CElhpt6rCuDDd009BP/6B0Ef39E=
+github.com/roadrunner-server/headers/v2 v2.12.7 h1:O0HPCC4VJ5YQQUwfRSt/54Mv+fV+npr+IDF42T1R18Y=
+github.com/roadrunner-server/headers/v2 v2.12.7/go.mod h1:0hJxdTZrUjqbYnvns1WdXbFl28qZYwIYauN1FxSod24=
+github.com/roadrunner-server/http/v2 v2.20.2 h1:Fvuhz7BxfDIky3wBs/vsUp0yE2KBgsoPj3PQzuZTFWc=
+github.com/roadrunner-server/http/v2 v2.20.2/go.mod h1:OmhlZ/sw/JcyR2bdb4J2OiNrSs8VwGWnCXXs6sNOhYM=
+github.com/roadrunner-server/informer/v2 v2.11.10 h1:wW8Q/tR48faUu48wVdM0NcMqoeAf0CUZqD71SOl/fE4=
+github.com/roadrunner-server/informer/v2 v2.11.10/go.mod h1:vTqXNaKFGNdubC3bunvT749At+yHzB/u81ww/UwiMQo=
+github.com/roadrunner-server/jobs/v2 v2.16.1 h1:TCyRS4WAXrELtaywWrQ2nOb4IKK89JK4qJzfqkVmg1w=
+github.com/roadrunner-server/jobs/v2 v2.16.1/go.mod h1:8OPYPZbwt7O5p/7nYQ9FQZq61M23RQn9snTO80fbJ3E=
+github.com/roadrunner-server/kafka/v2 v2.0.0-beta.2 h1:t5Qo0H2oQahaLCWxd/t4ZFZzLdcXVPG2sSIrWTtI7RU=
+github.com/roadrunner-server/kafka/v2 v2.0.0-beta.2/go.mod h1:01IYl4f8z0lCkmmEgSypRwkfMdLndryY7iZGMwaN3JA=
+github.com/roadrunner-server/kv/v2 v2.12.11 h1:pnQJKl40CjbtQFs+NOA2p6z4mOGRXiVagnS6xZzro4c=
+github.com/roadrunner-server/kv/v2 v2.12.11/go.mod h1:IU9lvKDK+3w6RzLHutQetGcYXSBPVczoVNncw3cu53o=
+github.com/roadrunner-server/logger/v2 v2.13.9 h1:b7SyMMc/SWFjmvpWVqU09VmFTF6ubbPU27LbBixV7YE=
+github.com/roadrunner-server/logger/v2 v2.13.9/go.mod h1:45M2g0uuHyRTcecbGR34Wzsk2RNNo+LnySCS60U/1lA=
+github.com/roadrunner-server/memcached/v2 v2.12.7 h1:FImKL0I/XFQji90gv7QCHrzUBdYivYaNHc//gMC7aDA=
+github.com/roadrunner-server/memcached/v2 v2.12.7/go.mod h1:iQUvBvNH6XxIceWEPKQeO7DhMTWZ7ChIn1ePNKipoIg=
+github.com/roadrunner-server/memory/v2 v2.15.6 h1:9DTEVepCdOcWe3Q1pBxJEwOK6NVFsQqljkcB76BPXlE=
+github.com/roadrunner-server/memory/v2 v2.15.6/go.mod h1:Gy7rZTf81B6pHg5duQf69q+O+mk2SquQ2ovwkFaq+OY=
+github.com/roadrunner-server/metrics/v2 v2.13.9 h1:hoqlRsCneygHlw8CY8o4iCgndB0UCOdk/6egR+Mc2Bo=
+github.com/roadrunner-server/metrics/v2 v2.13.9/go.mod h1:HcGAHxu5rBRDkQS0zcbEnUQ/DPcjXHM9ritqNPVa6Rc=
+github.com/roadrunner-server/nats/v2 v2.16.5 h1:3+64P/oGJwIH8q+4wyV/o5SFkoI72Iym0a/46DPoGtw=
+github.com/roadrunner-server/nats/v2 v2.16.5/go.mod h1:P4siDhOPXnDI22fulzWiEbdmWCvp8nOH82tz7LGm26U=
+github.com/roadrunner-server/new_relic/v2 v2.14.10 h1:Pg3q9zR2VRNz2HiOfAnqczgkIooFf3QWCL7PR7AFOFE=
+github.com/roadrunner-server/new_relic/v2 v2.14.10/go.mod h1:liy0/Dzb+UuYbxM/W8EhazadN8yCwaAGv0N5nz7YBsA=
 github.com/roadrunner-server/otel/v2 v2.3.0 h1:/S4c4J13smMVHrKvWMVlDDcJnktbI8pQ6AhyAsl/rFU=
 github.com/roadrunner-server/otel/v2 v2.3.0/go.mod h1:iLrejpHB+PD1NG+y4o+giSNOtXdJWmLOuAnLwVaRYFo=
-github.com/roadrunner-server/prometheus/v2 v2.13.8 h1:rVPAEXW19EU3LvRsm1udTav/+pEyRiPmLi2tuLGfJ/0=
-github.com/roadrunner-server/prometheus/v2 v2.13.8/go.mod h1:SV3WX36OpyJvSUeGuGcukXHrene9HEssdou+d0Mn0RE=
+github.com/roadrunner-server/prometheus/v2 v2.13.9 h1:qOL9sTvuceTtsokOVsUa0UT+IflFTgDoTEWYMGWo9Sc=
+github.com/roadrunner-server/prometheus/v2 v2.13.9/go.mod h1:TwlH5VeSSXzro+C41BD6GfoTyb7QA0vosrz7tUFSLAA=
 github.com/roadrunner-server/proxy_ip_parser/v2 v2.4.0 h1:DA2fItCrwzNBXN7zl2dB+pQMvXoSM9raH1Q8nELkhuI=
 github.com/roadrunner-server/proxy_ip_parser/v2 v2.4.0/go.mod h1:mZHMsfUIkNXQRN8X98POxa/qYB6Zrb4HZmBTAWdxusg=
-github.com/roadrunner-server/redis/v2 v2.15.6 h1:Rm+uufk16c+yqnSQSP8gCk1fTfKmTThLSSqBpCQ6CWU=
-github.com/roadrunner-server/redis/v2 v2.15.6/go.mod h1:3Pa1TKKh+DW/aunn2jzRH/7OFm+2a7TcZ1Wt4eMBgUk=
-github.com/roadrunner-server/reload/v2 v2.12.9 h1:k6j7L1eXwfEP09F9Bs8guCTAwzX+yki4ClPzNAHQKXs=
-github.com/roadrunner-server/reload/v2 v2.12.9/go.mod h1:kjXqB4uqyw9zCrqAqPfY4773uH/noPN9AC1OSb0qb5c=
-github.com/roadrunner-server/resetter/v2 v2.11.9 h1:Ugw6qY/M9tqQWs9hIVI48NujPC3lRV6zSKF1eUOXJRA=
-github.com/roadrunner-server/resetter/v2 v2.11.9/go.mod h1:GHDyAJMjHz5l6Cqdk0yc6GDi91F0W11t83mrGNltjE4=
-github.com/roadrunner-server/rpc/v2 v2.13.7 h1:P6oZpBK/au3uam0fuHndTuQYdJUiK6NTic6OVr5JNZI=
-github.com/roadrunner-server/rpc/v2 v2.13.7/go.mod h1:FPh3NeZYoNu/9xd7WvyzxiSi/5DJ1WIVmCwYh7qK0fA=
-github.com/roadrunner-server/sdk/v2 v2.18.0 h1:cPu3o8Z13NKFND3ybk6J4HAnSq4qYLkFT1T5CDd42Hs=
-github.com/roadrunner-server/sdk/v2 v2.18.0/go.mod h1:u4QeEEr/Aa7ZamQw1duZSmsl3LMeuMIQKzdENqWEKLI=
-github.com/roadrunner-server/send/v2 v2.12.5 h1:JDxGo929xkGZfAZ4EAQU3VaXGoYHM6JHoXWnNB0KdTU=
-github.com/roadrunner-server/send/v2 v2.12.5/go.mod h1:FdqdTeHVpH7U+8TPQtxGr+QWCoE3uMwqdRqGweD7wYs=
-github.com/roadrunner-server/server/v2 v2.14.8 h1:5ezs+kytvDp6VleYNBKRntNIoy5fVItQ90fQz3rB6/o=
-github.com/roadrunner-server/server/v2 v2.14.8/go.mod h1:iS55gagD/x6bxs8d0bD9f0fuIykllo1cYHnzMaqSfqY=
-github.com/roadrunner-server/service/v2 v2.15.2 h1:XX/xXy0AbysR6PrLx6mv5ijtVBn+FH41ifhWDL/8LxU=
-github.com/roadrunner-server/service/v2 v2.15.2/go.mod h1:rU50K6q0qEDjI2U3zZ9Tv0Yl83eZbc/PAU/kyXMv3O4=
-github.com/roadrunner-server/sqs/v2 v2.17.5 h1:yyy3xGBzI0DVN3/rYxF+RcDKWLgBRe80nNwTsv3gukU=
-github.com/roadrunner-server/sqs/v2 v2.17.5/go.mod h1:hvZQS7+kfU7/Q65qw17F3wwdH0TL/xGyafPc2FMSUEo=
-github.com/roadrunner-server/static/v2 v2.13.6 h1:SOIONB0yDF79kWxTdvHnO8lJ6HZkoZ1NoDbL6AjHPHw=
-github.com/roadrunner-server/static/v2 v2.13.6/go.mod h1:An4Qd0sAU4z0pkDN67iCBUcR086H6oLijrQMbOpWTBo=
-github.com/roadrunner-server/status/v2 v2.13.9 h1:sRGnSK4wqaV4B9hAzUygnu5N9yfgbQLoxA8qg1JGjb0=
-github.com/roadrunner-server/status/v2 v2.13.9/go.mod h1:5mLzp8tYzesPTbYcn6SI+AC1CaQiefvVxfpydX6zTL8=
-github.com/roadrunner-server/tcp/v2 v2.13.9 h1:IiPjfq7CdvVmHD1Gq/PmOYtwRqNX9fzLK4sugca6KEM=
-github.com/roadrunner-server/tcp/v2 v2.13.9/go.mod h1:86o0hf9eQ+XO9xV8XPCZbpkB/VIh5qmrgWTFvDCgv8k=
+github.com/roadrunner-server/redis/v2 v2.15.7 h1:Tf1PhAirGrgFcdXTUzgL0g0wGrtCC6+3kEsMk9ftj38=
+github.com/roadrunner-server/redis/v2 v2.15.7/go.mod h1:y8vfuGxt2uDSR85N+O67fUr0DlWgNAvC8M7MBRj3t9A=
+github.com/roadrunner-server/reload/v2 v2.12.10 h1:sx2URL9RK7KHtAyGgAtMFSt/vBofVSsoa6VBwrDkz1Y=
+github.com/roadrunner-server/reload/v2 v2.12.10/go.mod h1:DDK9rUFI+MV1e5/Gf6nDE/s7CzpoVxNpJUUmTQ6Mx1g=
+github.com/roadrunner-server/resetter/v2 v2.11.10 h1:J44xKQNv00ziVa7wx62PmeaM8Q6JX769elrBCabOKxk=
+github.com/roadrunner-server/resetter/v2 v2.11.10/go.mod h1:l8aunFo/IcSOmevSAl2QeCOy0LoW+oBDZL2eVuQMbNY=
+github.com/roadrunner-server/rpc/v2 v2.13.8 h1:aYLF98Ds/u24ERbH5GJfBwcbBfJ+E34iEzmY/n/CA7k=
+github.com/roadrunner-server/rpc/v2 v2.13.8/go.mod h1:NWOmR/xi7aWz7zLzfgAcnptzxpLCFWNSsEDZAduN7nA=
+github.com/roadrunner-server/sdk/v2 v2.18.1 h1:8jlUxQbiK9wTW/oDQZQ4b1b4p9pAMY7puaIyN/lmv70=
+github.com/roadrunner-server/sdk/v2 v2.18.1/go.mod h1:3W/iPjObht/J9D4CtkhHj6VRHlg4+KiT/IeuUrdqZ1g=
+github.com/roadrunner-server/send/v2 v2.12.6 h1:DQ49fW+uum3I84Nm6Xod5VRa018FWwB5MeSkQiHxO5U=
+github.com/roadrunner-server/send/v2 v2.12.6/go.mod h1:hhmZ1NhYjQhVfHsTVGVagUKmwMM2SvBJOpC6blOiUrw=
+github.com/roadrunner-server/server/v2 v2.14.9 h1:kq5lDZyBpGsPm2xcX0Y+SQOajuh4fSYiIJaXBhB6tnw=
+github.com/roadrunner-server/server/v2 v2.14.9/go.mod h1:ysH9JsFNSmFZmgcicYgXQzYsbCjJHAPeO8PkQdHk9G4=
+github.com/roadrunner-server/service/v2 v2.15.3 h1:vpSEhavr0txaHKvUrRHCuIEOd1wrYwb09lrzOHoRaWs=
+github.com/roadrunner-server/service/v2 v2.15.3/go.mod h1:Zfhjm8wA/Ya3xxeKm+Mhq4Aq4uUURbJUuxVYZQuj2kY=
+github.com/roadrunner-server/sqs/v2 v2.17.6 h1:IGN98XYNpL3uZuR+YpiBz8x2lYWxKgHoDfl3oh6aJoQ=
+github.com/roadrunner-server/sqs/v2 v2.17.6/go.mod h1:IG6oSjeYZR+bH6Zpcz0VM7REypYH1TY9KnDT63DQk3g=
+github.com/roadrunner-server/static/v2 v2.13.7 h1:qxn5qlk+ySupUxz/YApGXf/GQLHypT1VMW9O4Oy/8WY=
+github.com/roadrunner-server/static/v2 v2.13.7/go.mod h1:OMgw7LfoKl6TOO2QKjYhAIxvUTZSGr7PIp3Ofi6iQVE=
+github.com/roadrunner-server/status/v2 v2.13.10 h1:NpSMlVs6zLF8OrLS3hOIBfDnr/4sgiLwWs3hl+NXbmI=
+github.com/roadrunner-server/status/v2 v2.13.10/go.mod h1:juDD1HbLCnEP9QlznY8FN6AzB/9Mrezxd9YPGgrTwwo=
+github.com/roadrunner-server/tcp/v2 v2.13.10 h1:ZgukVptcxAc1eEhwhAVIAphDvQsE88/SD34yjHHlCNE=
+github.com/roadrunner-server/tcp/v2 v2.13.10/go.mod h1:L0ZiK9xElIHwPWtdZwfcVeUIUUxGy2GURA+ZQUCy+1M=
 github.com/roadrunner-server/tcplisten v1.1.2 h1:GBjKlSEbA67UB2y83rFWsQKqMQGyalhTN9Q9HCIMBC0=
 github.com/roadrunner-server/tcplisten v1.1.2/go.mod h1:wN2/X46Vo60sC9L5Bf/eC8kL+X3//7KIFmANEXZaLsg=
-github.com/roadrunner-server/websockets/v2 v2.14.8 h1:nEPRlrpRz7YC7uk4gL5dlOZj+HPu9NXJzWTXvZiFZeE=
-github.com/roadrunner-server/websockets/v2 v2.14.8/go.mod h1:e6+eaXj4L7LhDCJecrCXu8Aq8reH1RyzVgKEVwdMrDE=
+github.com/roadrunner-server/websockets/v2 v2.14.9 h1:ZUxrzIbcm1rFKGGTn8jBRJGeWjLPDPMR19uj7XdK79A=
+github.com/roadrunner-server/websockets/v2 v2.14.9/go.mod h1:RHl8YGN+iVZZHpLhwy+V70rctvN/cKtCc08+Xtzl69M=
 github.com/robfig/cron v1.2.0 h1:ZjScXvvxeQ63Dbyxy76Fj3AT3Ut0aKsyd2/tl3DTMuQ=
 github.com/robfig/cron v1.2.0/go.mod h1:JGuDeoQd7Z6yL4zQhZ3OPEVHB7fL6Ka6skscFHfmt2k=
+github.com/rogpeppe/clock v0.0.0-20190514195947-2896927a307a/go.mod h1:4r5QyqhjIWCcK8DO4KMclc5Iknq5qVBAlbYYzAbUScQ=
 github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
 github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
-github.com/rogpeppe/go-internal v1.6.1 h1:/FiVV8dS/e+YqF2JvO3yXRFbBLTIuSDkuC7aBOAvL+k=
+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/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
 github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
+github.com/santhosh-tekuri/jsonschema/v5 v5.0.0/go.mod h1:FKdcjfQW6rpZSnxxUvEA5H/cDPdvJ/SZJQLWWXWGrZ0=
 github.com/shirou/gopsutil v3.21.11+incompatible h1:+1+c1VGhc88SSonWP6foOcLhvnKlUeu/erjjvaPEYiI=
 github.com/shirou/gopsutil v3.21.11+incompatible/go.mod h1:5b4v6he4MtMOwMlS0TUMTu2PcXUg8+E1lC7eC3UO/RA=
 github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc=
@@ -537,6 +577,7 @@ github.com/stretchr/objx v0.4.0 h1:M2gUjqZET1qApGOWNSnZ49BAIMX4F/1plDv3+l31EJ4=
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
+github.com/stretchr/testify v1.3.1-0.20190311161405-34c6fa2dc709/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 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=
@@ -719,6 +760,7 @@ golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLL
 golang.org/x/net v0.0.0-20200301022130-244492dfa37a/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/net v0.0.0-20200324143707-d3edc9973b7e/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
 golang.org/x/net v0.0.0-20200501053045-e0ff5e5a1de5/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
+golang.org/x/net v0.0.0-20200505041828-1ed23360d12c/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
 golang.org/x/net v0.0.0-20200506145744-7e3656a0809f/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
 golang.org/x/net v0.0.0-20200513185701-a91f0712d120/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
 golang.org/x/net v0.0.0-20200520004742-59133d7f0dd7/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
@@ -743,8 +785,8 @@ golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd/go.mod h1:CfG3xpIq0wQ8r1q4Su
 golang.org/x/net v0.0.0-20220225172249-27dd8689420f/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
 golang.org/x/net v0.0.0-20220531201128-c960675eff93/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
 golang.org/x/net v0.0.0-20220630215102-69896b714898/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
-golang.org/x/net v0.0.0-20220722155237-a158d28d115b h1:PxfKdU9lEEDYjdIzOtC4qFWgkU2rGHdKlKowJSMN9h0=
-golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
+golang.org/x/net v0.0.0-20220725212005-46097bf591d3 h1:2yWTtPWWRcISTw3/o+s/Y4UOMnQL71DWyToOANFusCg=
+golang.org/x/net v0.0.0-20220725212005-46097bf591d3/go.mod h1:AaygXjzTFtRAg2ttMY5RMuhpJ3cNnI0XpyFJD1iQRSM=
 golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
 golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
 golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
@@ -830,6 +872,7 @@ golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBc
 golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20210910150752-751e447fb3d0/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-20211007075335-d3039528d8ac/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20211019181941-9d821ace8654/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=
@@ -893,6 +936,7 @@ golang.org/x/tools v0.0.0-20200304193943-95d2e580d8eb/go.mod h1:o4KQGtdN14AW+yjs
 golang.org/x/tools v0.0.0-20200312045724-11d5b4c81c7d/go.mod h1:o4KQGtdN14AW+yjsvvwRTJJuXz8XRtIHtEnmAXLyFUw=
 golang.org/x/tools v0.0.0-20200331025713-a30bf2db82d4/go.mod h1:Sl4aGygMT6LrqrWclx+PTx3U+LnKx/seiNR+3G19Ar8=
 golang.org/x/tools v0.0.0-20200501065659-ab2804fb9c9d/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
+golang.org/x/tools v0.0.0-20200505023115-26f46d2f7ef8/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
 golang.org/x/tools v0.0.0-20200512131952-2bc93b1c0c88/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
 golang.org/x/tools v0.0.0-20200515010526-7d3b6ebf133d/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
 golang.org/x/tools v0.0.0-20200618134242-20370b0cb4b2/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
@@ -986,9 +1030,10 @@ google.golang.org/genproto v0.0.0-20210108203827-ffc7fda8c3d7/go.mod h1:FWY/as6D
 google.golang.org/genproto v0.0.0-20210226172003-ab064af71705/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
 google.golang.org/genproto v0.0.0-20210909211513-a8c4777a87af/go.mod h1:eFjDcFEctNawg4eG61bRv87N7iHBWyVhJu7u1kqDUXY=
 google.golang.org/genproto v0.0.0-20211118181313-81c1377c94b1/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc=
+google.golang.org/genproto v0.0.0-20220503193339-ba3ae3f07e29/go.mod h1:RAyBrSAP7Fh3Nc84ghnVLDPuV51xc9agzmm4Ph6i0Q4=
 google.golang.org/genproto v0.0.0-20220602131408-e326c6e8e9c8/go.mod h1:yKyY4AMRwFiC8yMMNaMi+RkCnjZJt9LoWuvhXjMs+To=
-google.golang.org/genproto v0.0.0-20220722212130-b98a9ff5e252 h1:G5AjFxR+ibe9Taamo0TdW+iylfBYK10DSkHYdx7PZ9w=
-google.golang.org/genproto v0.0.0-20220722212130-b98a9ff5e252/go.mod h1:GkXuJDJ6aQ7lnJcRF+SJVgFdQhypqgl3LB1C9vabdRE=
+google.golang.org/genproto v0.0.0-20220725144611-272f38e5d71b h1:SfSkJugek6xm7lWywqth4r2iTrYLpD8lOj1nMIIhMNM=
+google.golang.org/genproto v0.0.0-20220725144611-272f38e5d71b/go.mod h1:iHe1svFLAZg9VWz891+QbRMwUv9O/1Ww+/mngYeThbc=
 google.golang.org/grpc v1.12.0/go.mod h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw=
 google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
 google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38=
@@ -1008,10 +1053,12 @@ google.golang.org/grpc v1.33.2/go.mod h1:JMHMWHQWaTccqQQlmk3MJZS+GWXOdAesneDmEnv
 google.golang.org/grpc v1.34.0/go.mod h1:WotjhfgOW/POjDeRt8vscBtXq+2VjORFy659qA51WJ8=
 google.golang.org/grpc v1.35.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU=
 google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU=
+google.golang.org/grpc v1.38.0/go.mod h1:NREThFqKR1f3iQ6oBuvc5LadQuXVGo9rkm5ZGrQdJfM=
 google.golang.org/grpc v1.39.0/go.mod h1:PImNr+rS9TWYb2O4/emRugxiyHZ5JyHW5F+RPnDzfrE=
 google.golang.org/grpc v1.40.0/go.mod h1:ogyxbiOoUXAkP+4+xa6PZSE9DZgIHtSpzjDTB9KAK34=
 google.golang.org/grpc v1.41.0/go.mod h1:U3l9uK9J0sini8mHphKoXyaqDA/8VyGnDee1zzIUK6k=
 google.golang.org/grpc v1.42.0/go.mod h1:k+4IHHFw41K8+bbowsex27ge2rCb65oeWqe4jJ590SU=
+google.golang.org/grpc v1.46.0/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk=
 google.golang.org/grpc v1.46.2/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk=
 google.golang.org/grpc v1.47.0/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk=
 google.golang.org/grpc v1.48.0 h1:rQOsyJ/8+ufEDJd/Gdsz7HG220Mh9HAhFHRGnIjda0w=
@@ -1032,18 +1079,23 @@ google.golang.org/protobuf v1.27.1/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQ
 google.golang.org/protobuf v1.28.0 h1:w43yiav+6bVFTBQFZX0r7ipe9JQ1QsbMgHwbBziscLw=
 google.golang.org/protobuf v1.28.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
 gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw=
+gopkg.in/avro.v0 v0.0.0-20171217001914-a730b5802183/go.mod h1:FvqrFXt+jCsyQibeRv4xxEJBL5iG2DDW5aeJwzDiq4A=
 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-20190902080502-41f04d3bba15/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.v1 v1.0.0/go.mod h1:CxwszS/Xz1C49Ucd2i6Zil5UToP1EmyrFhKaMVbg1mk=
 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/httprequest.v1 v1.2.1/go.mod h1:x2Otw96yda5+8+6ZeWwHIJTFkEHWP/qP8pJOzqEtWPM=
 gopkg.in/ini.v1 v1.66.6 h1:LATuAqN/shcYAOkv3wl2L4rkaKqkcgTBQjOyYDvcPKI=
 gopkg.in/ini.v1 v1.66.6/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
+gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22/go.mod h1:yeKp02qBN3iKW1OzL3MGk2IdtZzaj7SFntXj72NppTA=
 gopkg.in/natefinch/lumberjack.v2 v2.0.0 h1:1Lc07Kr7qY4U2YPouBjpCLxpiyxIVoxqXgkXLknAOE8=
 gopkg.in/natefinch/lumberjack.v2 v2.0.0/go.mod h1:l0ndWWf7gzL7RNwBG7wST/UCcT4T24xpD6X8LsfU/+k=
+gopkg.in/retry.v1 v1.0.3/go.mod h1:FJkXmWiMaAo7xB+xhvDF59zhfjDWyzmyAxiT4dB688g=
 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/validator.v2 v2.0.0-20200605151824-2b28d334fa05/go.mod h1:o4V0GXN9/CAmCsvJ0oXYZvrZOe7syiDZSN1GWGZTGzc=
@@ -1052,6 +1104,7 @@ 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.5/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.2.7/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=