[#1065]: feat(streams): http response streams

2 files changed, 136 insertions, 97 deletions

diff --git a/go.mod b/go.mod
index 5ff8dc78..651c51a1 100644
--- a/go.mod
+++ b/go.mod
@@ -9,43 +9,43 @@ require (
 	github.com/joho/godotenv v1.4.0
 	github.com/mattn/go-runewidth v0.0.13
 	github.com/olekukonko/tablewriter v0.0.5
-	github.com/roadrunner-server/amqp/v2 v2.10.2
+	github.com/roadrunner-server/amqp/v2 v2.11.0
 	github.com/roadrunner-server/api/v2 v2.14.0
-	github.com/roadrunner-server/beanstalk/v2 v2.10.2
-	github.com/roadrunner-server/boltdb/v2 v2.10.1
-	github.com/roadrunner-server/broadcast/v2 v2.10.2
-	github.com/roadrunner-server/cache/v2 v2.10.2
-	github.com/roadrunner-server/config/v2 v2.10.3
+	github.com/roadrunner-server/beanstalk/v2 v2.11.0
+	github.com/roadrunner-server/boltdb/v2 v2.11.0
+	github.com/roadrunner-server/broadcast/v2 v2.11.0
+	github.com/roadrunner-server/cache/v2 v2.11.0
+	github.com/roadrunner-server/config/v2 v2.11.0
 	github.com/roadrunner-server/endure v1.2.2
 	github.com/roadrunner-server/errors v1.1.2
-	github.com/roadrunner-server/fileserver/v2 v2.10.2
+	github.com/roadrunner-server/fileserver/v2 v2.11.0
 	github.com/roadrunner-server/goridge/v3 v3.4.0
-	github.com/roadrunner-server/grpc/v2 v2.11.3
-	github.com/roadrunner-server/gzip/v2 v2.9.0
-	github.com/roadrunner-server/headers/v2 v2.10.2
-	github.com/roadrunner-server/http/v2 v2.12.3
-	github.com/roadrunner-server/informer/v2 v2.10.2
-	github.com/roadrunner-server/jobs/v2 v2.10.2
-	github.com/roadrunner-server/kv/v2 v2.10.1
-	github.com/roadrunner-server/logger/v2 v2.10.2
-	github.com/roadrunner-server/memcached/v2 v2.10.1
-	github.com/roadrunner-server/memory/v2 v2.10.1
-	github.com/roadrunner-server/metrics/v2 v2.10.2
-	github.com/roadrunner-server/nats/v2 v2.10.3
-	github.com/roadrunner-server/new_relic/v2 v2.11.3
-	github.com/roadrunner-server/prometheus/v2 v2.10.0
-	github.com/roadrunner-server/redis/v2 v2.11.1
-	github.com/roadrunner-server/reload/v2 v2.10.2
-	github.com/roadrunner-server/resetter/v2 v2.10.2
-	github.com/roadrunner-server/rpc/v2 v2.10.2
-	github.com/roadrunner-server/send/v2 v2.9.0
-	github.com/roadrunner-server/server/v2 v2.11.2
-	github.com/roadrunner-server/service/v2 v2.10.3
-	github.com/roadrunner-server/sqs/v2 v2.11.2
-	github.com/roadrunner-server/static/v2 v2.10.2
-	github.com/roadrunner-server/status/v2 v2.10.2
-	github.com/roadrunner-server/tcp/v2 v2.10.2
-	github.com/roadrunner-server/websockets/v2 v2.10.2
+	github.com/roadrunner-server/grpc/v2 v2.12.0
+	github.com/roadrunner-server/gzip/v2 v2.10.0
+	github.com/roadrunner-server/headers/v2 v2.11.0
+	github.com/roadrunner-server/http/v2 v2.13.0
+	github.com/roadrunner-server/informer/v2 v2.11.0
+	github.com/roadrunner-server/jobs/v2 v2.11.0
+	github.com/roadrunner-server/kv/v2 v2.11.0
+	github.com/roadrunner-server/logger/v2 v2.11.0
+	github.com/roadrunner-server/memcached/v2 v2.11.0
+	github.com/roadrunner-server/memory/v2 v2.11.0
+	github.com/roadrunner-server/metrics/v2 v2.11.0
+	github.com/roadrunner-server/nats/v2 v2.11.0
+	github.com/roadrunner-server/new_relic/v2 v2.12.0
+	github.com/roadrunner-server/prometheus/v2 v2.11.0
+	github.com/roadrunner-server/redis/v2 v2.12.0
+	github.com/roadrunner-server/reload/v2 v2.11.0
+	github.com/roadrunner-server/resetter/v2 v2.11.0
+	github.com/roadrunner-server/rpc/v2 v2.11.0
+	github.com/roadrunner-server/send/v2 v2.10.0
+	github.com/roadrunner-server/server/v2 v2.12.0
+	github.com/roadrunner-server/service/v2 v2.11.0
+	github.com/roadrunner-server/sqs/v2 v2.12.0
+	github.com/roadrunner-server/static/v2 v2.11.0
+	github.com/roadrunner-server/status/v2 v2.11.0
+	github.com/roadrunner-server/tcp/v2 v2.11.0
+	github.com/roadrunner-server/websockets/v2 v2.11.0
 	github.com/spf13/cobra v1.4.0
 	github.com/spf13/viper v1.10.1
 	github.com/stretchr/testify v1.7.1
@@ -57,17 +57,17 @@ require (
 	github.com/VividCortex/ewma v1.2.0 // indirect
 	github.com/acarl005/stripansi v0.0.0-20180116102854-5a71ef0e047d // indirect
 	github.com/andybalholm/brotli v1.0.4 // indirect
-	github.com/aws/aws-sdk-go-v2 v1.15.0 // indirect
-	github.com/aws/aws-sdk-go-v2/config v1.15.0 // indirect
-	github.com/aws/aws-sdk-go-v2/credentials v1.10.0 // indirect
-	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.0 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.6 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.0 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/ini v1.3.7 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.0 // indirect
+	github.com/aws/aws-sdk-go-v2 v1.16.0 // indirect
+	github.com/aws/aws-sdk-go-v2/config v1.15.1 // indirect
+	github.com/aws/aws-sdk-go-v2/credentials v1.11.0 // indirect
+	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.1 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.7 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.1 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/ini v1.3.8 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.1 // indirect
 	github.com/aws/aws-sdk-go-v2/service/sqs v1.18.0 // indirect
-	github.com/aws/aws-sdk-go-v2/service/sso v1.11.0 // indirect
-	github.com/aws/aws-sdk-go-v2/service/sts v1.16.0 // indirect
+	github.com/aws/aws-sdk-go-v2/service/sso v1.11.1 // indirect
+	github.com/aws/aws-sdk-go-v2/service/sts v1.16.1 // indirect
 	github.com/aws/smithy-go v1.11.1 // indirect
 	github.com/beanstalkd/go-beanstalk v0.1.0 // indirect
 	github.com/beorn7/perks v1.0.1 // indirect
@@ -123,7 +123,7 @@ require (
 	github.com/prometheus/procfs v0.7.3 // indirect
 	github.com/rabbitmq/amqp091-go v1.3.0 // indirect
 	github.com/rivo/uniseg v0.2.0 // indirect
-	github.com/roadrunner-server/sdk/v2 v2.11.1 // indirect
+	github.com/roadrunner-server/sdk/v2 v2.12.0 // 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
@@ -159,7 +159,7 @@ require (
 	golang.org/x/time v0.0.0-20220224211638-0e9765cccd65 // indirect
 	golang.org/x/tools v0.1.10 // indirect
 	golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 // indirect
-	google.golang.org/genproto v0.0.0-20220322021311-435b647f9ef2 // indirect
+	google.golang.org/genproto v0.0.0-20220323144105-ec3c684e5b14 // indirect
 	google.golang.org/grpc v1.45.0 // indirect
 	google.golang.org/protobuf v1.28.0 // indirect
 	gopkg.in/ini.v1 v1.66.4 // indirect
diff --git a/go.sum b/go.sum
index b9a408da..d25430e6 100644
--- a/go.sum
+++ b/go.sum
@@ -55,26 +55,46 @@ github.com/andybalholm/brotli v1.0.4/go.mod h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHG
 github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY=
 github.com/aws/aws-sdk-go-v2 v1.15.0 h1:f9kWLNfyCzCB43eupDAk3/XgJ2EpgktiySD6leqs0js=
 github.com/aws/aws-sdk-go-v2 v1.15.0/go.mod h1:lJYcuZZEHWNIb6ugJjbQY1fykdoobWbOS7kJYb4APoI=
+github.com/aws/aws-sdk-go-v2 v1.16.0 h1:cBAYjiiexRAg9v2z9vb6IdxAa7ef4KCtjW7w7e3GxGo=
+github.com/aws/aws-sdk-go-v2 v1.16.0/go.mod h1:lJYcuZZEHWNIb6ugJjbQY1fykdoobWbOS7kJYb4APoI=
 github.com/aws/aws-sdk-go-v2/config v1.15.0 h1:cibCYF2c2uq0lsbu0Ggbg8RuGeiHCmXwUlTMS77CiK4=
 github.com/aws/aws-sdk-go-v2/config v1.15.0/go.mod h1:NccaLq2Z9doMmeQXHQRrt2rm+2FbkrcPvfdbCaQn5hY=
+github.com/aws/aws-sdk-go-v2/config v1.15.1 h1:hTIZFepYESYyowQUBo47lu69WSxsYqGUILY9Nu8+7pY=
+github.com/aws/aws-sdk-go-v2/config v1.15.1/go.mod h1:MZHGbuW2WnqIOQQBKu2ZkhTjuutZSTnn56TDq4QyydE=
 github.com/aws/aws-sdk-go-v2/credentials v1.10.0 h1:M/FFpf2w31F7xqJqJLgiM0mFpLOtBvwZggORr6QCpo8=
 github.com/aws/aws-sdk-go-v2/credentials v1.10.0/go.mod h1:HWJMr4ut5X+Lt/7epc7I6Llg5QIcoFHKAeIzw32t6EE=
+github.com/aws/aws-sdk-go-v2/credentials v1.11.0 h1:gc4Uhs80s60nmLon5Z4JXWinX2BkAGT0YROoUT8h8U4=
+github.com/aws/aws-sdk-go-v2/credentials v1.11.0/go.mod h1:EdV1ZFgtZ4XM5RDHWcRWK8H+xW5duNVBqWj2oLu7tRo=
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.0 h1:gUlb+I7NwDtqJUIRcFYDiheYa97PdVHG/5Iz+SwdoHE=
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.0/go.mod h1:prX26x9rmLwkEE1VVCelQOQgRN9sOVIssgowIJ270SE=
+github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.1 h1:F9Je1nq5YXfMOv6451NHvMf6U0iTWeMnsG0MMIQoUmk=
+github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.1/go.mod h1:Yph0XsTbQ5GGZ2+mO1a03P/SO9fdX3t1nejIp2tq79g=
 github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.6 h1:xiGjGVQsem2cxoIX61uRGy+Jux2s9C/kKbTrWLdrU54=
 github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.6/go.mod h1:SSPEdf9spsFgJyhjrXvawfpyzrXHBCUe+2eQ1CjC1Ak=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.7 h1:KUErSJgdqmqAPBWAp6Zx9CjL0YXfytXJeXcsWnuCM1c=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.7/go.mod h1:oB9nZcxH1cGq7NPGurVJwxrO2vmJ9mmEBayCwcAlmT8=
 github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.0 h1:bt3zw79tm209glISdMRCIVRCwvSDXxgAxh5KWe2qHkY=
 github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.0/go.mod h1:viTrxhAuejD+LszDahzAE2x40YjYWhMqzHxv2ZiWaME=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.1 h1:feVfa9eJonhJiss7g51ikjNB2DrUzbNZNvPL8pw/54k=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.1/go.mod h1:K4vz7lRYCyLYpYAMCLObODahFgARdD3YVa0MvQte9Co=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.3.7 h1:QOMEP8jnO8sm0SX/4G7dbaIq2eEP2wcWEsF0jzrXLJc=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.3.7/go.mod h1:P5sjYYf2nc5dE6cZIzEMsVtq6XeLD7c4rM+kQJPrByA=
+github.com/aws/aws-sdk-go-v2/internal/ini v1.3.8 h1:adr3PfiggFtqgFofAMUFCtdvwzpf3QxPES4ezK4M3iI=
+github.com/aws/aws-sdk-go-v2/internal/ini v1.3.8/go.mod h1:wLbQYt36AJqaRZUQiCNXzbtkNigyPfKHrotHuIDiCy8=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.0 h1:YQ3fTXACo7xeAqg0NiqcCmBOXJruUfh+4+O2qxF2EjQ=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.0/go.mod h1:R31ot6BgESRCIoxwfKtIHzZMo/vsZn2un81g9BJ4nmo=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.1 h1:B/SPX7J+Y0Yrcjv60Nhbh1gC2uBN47SfN8JYre6Mp4M=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.1/go.mod h1:2Hhr9Eh1gJzDatwACX/ozAZ/ljq5vzvPRu5cdu25tzc=
 github.com/aws/aws-sdk-go-v2/service/sqs v1.18.0 h1:nKaxCMASO9YbaLROWQqwpUiv82oWks6hHHbTmWiRx00=
 github.com/aws/aws-sdk-go-v2/service/sqs v1.18.0/go.mod h1:sXyfsQ0VN6V8HxkMIvH+eFuy9tVEgCSp+ZkT3trHRTQ=
 github.com/aws/aws-sdk-go-v2/service/sso v1.11.0 h1:gZLEXLH6NiU8Y52nRhK1jA+9oz7LZzBK242fi/ziXa4=
 github.com/aws/aws-sdk-go-v2/service/sso v1.11.0/go.mod h1:d1WcT0OjggjQCAdOkph8ijkr5sUwk1IH/VenOn7W1PU=
+github.com/aws/aws-sdk-go-v2/service/sso v1.11.1 h1:DyHctRsJIAWIvom1Itb4T84D2jwpIu+KIi3d0SFaswg=
+github.com/aws/aws-sdk-go-v2/service/sso v1.11.1/go.mod h1:CvFTucADIx7U/M44vjLs/ZttpQHdpxwK+62+dUGhDeY=
 github.com/aws/aws-sdk-go-v2/service/sts v1.16.0 h1:0+X/rJ2+DTBKWbUsn7WtF0JvNk/fRf928vkFsXkbbZs=
 github.com/aws/aws-sdk-go-v2/service/sts v1.16.0/go.mod h1:+8k4H2ASUZZXmjx/s3DFLo9tGBb44lkz3XcgfypJY7s=
+github.com/aws/aws-sdk-go-v2/service/sts v1.16.1 h1:xsOtPAvHqhvQvBza5ohaUcfq1LceH2lZKMUGZJKiZiM=
+github.com/aws/aws-sdk-go-v2/service/sts v1.16.1/go.mod h1:Aq2/Qggh2oemSfyHH+EO4UBbgWG6zFCXLHYI4ILTY7w=
 github.com/aws/smithy-go v1.11.1 h1:IQ+lPZVkSM3FRtyaDox41R8YS6iwPMYIreejOgPW49g=
 github.com/aws/smithy-go v1.11.1/go.mod h1:3xHYmszWVx2c0kIwQeEVf9uSm4fYZt67FBJnwub1bgM=
 github.com/beanstalkd/go-beanstalk v0.1.0 h1:IiNwYbAoVBDs5xEOmleGoX+DRD3Moz99EpATbl8672w=
@@ -95,6 +115,7 @@ github.com/caddyserver/certmagic v0.15.4/go.mod h1:qhkAOthf72ufAcp3Y5jF2RaGE96oi
 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 h1:a6HrQnmkObjyL+Gs60czilIUGqrzKutQD6XZog3p+ko=
 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/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE=
@@ -368,84 +389,102 @@ github.com/rabbitmq/amqp091-go v1.3.0 h1:A/QuHiNw7LMCJsxx9iZn5lrIz6OrhIn7Dfk5/1Y
 github.com/rabbitmq/amqp091-go v1.3.0/go.mod h1:ogQDLSOACsLPsIq0NpbtiifNZi2YOz0VTJ0kHRghqbM=
 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.10.2 h1:0qs+Vub/VKaauSpFXkwYZBV/6P7WzrpmcZp8qINVpXA=
-github.com/roadrunner-server/amqp/v2 v2.10.2/go.mod h1:owqcWJTIYWkdomIaumljZY16+2zjPaatdLiNkXB8NTo=
+github.com/roadrunner-server/amqp/v2 v2.11.0 h1:udoukzmwh01dF+6Pyun26hLQomdvIkaDwhVIqd0txX0=
+github.com/roadrunner-server/amqp/v2 v2.11.0/go.mod h1:RLa/US0KnELbU90Cy4WQbQeLslyJKUmBhO2pGzgEeiM=
 github.com/roadrunner-server/api/v2 v2.14.0 h1:U7CrMXv5h8qlO9vvqdvPDK0g+zMLwcERUAPcoLy6tYs=
 github.com/roadrunner-server/api/v2 v2.14.0/go.mod h1:COjb3T7DYHydaKIfino/N8gVa8op1jGAXFF+qKHMnk0=
-github.com/roadrunner-server/beanstalk/v2 v2.10.2 h1:xrY1NAwaj7nO7JMBjEE5L2RK8dFm6Nv265y3pnZSZRc=
-github.com/roadrunner-server/beanstalk/v2 v2.10.2/go.mod h1:J46qGODQ0X1UtKeV9jAOHx47u8ZfEqy5FbEm+cQyDnA=
-github.com/roadrunner-server/boltdb/v2 v2.10.1 h1:aYmDhQzUR+A7vsjUg6H9Nsp/F3mSOMR1Zi0kQ1U+3IA=
-github.com/roadrunner-server/boltdb/v2 v2.10.1/go.mod h1:dU6qnA4Ys1B/ZQflqSni2ojfFbNORlqVppSK85Z2zpY=
+github.com/roadrunner-server/beanstalk/v2 v2.11.0 h1:SajbQuDccuv0/vsYh5efqx/8yiygvz3n6ZfpvQcCu+E=
+github.com/roadrunner-server/beanstalk/v2 v2.11.0/go.mod h1:bEoduavbkU7Wn/mm6DpzJfRlLBd03buDRd7CX5QEXXI=
+github.com/roadrunner-server/boltdb/v2 v2.11.0 h1:9cSBWnGx4HFKRFr7dqJZ2p29ujcw5Fr4nqkZezqMSDo=
+github.com/roadrunner-server/boltdb/v2 v2.11.0/go.mod h1:NJ3dwg88rcABvHXE49tz3cxdodqo+aq1xygciRQDPog=
 github.com/roadrunner-server/broadcast/v2 v2.10.2 h1:YLZKWTw1jyEeqVkT+B1QQDon18bcfrgwYSfpTujlroQ=
 github.com/roadrunner-server/broadcast/v2 v2.10.2/go.mod h1:P8vc9w2pUOmOBA2MpiwRyYRKjAQpCWCThjoIQgB2QrA=
+github.com/roadrunner-server/broadcast/v2 v2.11.0 h1:oUMAvAX+k+y5HESGYcc/rkJblWcEor2KXuXqf+AVJOs=
+github.com/roadrunner-server/broadcast/v2 v2.11.0/go.mod h1:YW/91Lsmf/DZ/OhxJmorNhdDQBNPU+C6hXPRXb2wuP8=
 github.com/roadrunner-server/cache/v2 v2.10.2 h1:8nEM3iYAZuB0Z59SS5qpQPliCFDrgZprXqvOZuL4aAY=
 github.com/roadrunner-server/cache/v2 v2.10.2/go.mod h1:aHoE8HefFGlM3HMYA0SR8GhAbO/jWy5spXu0ITQPDs0=
-github.com/roadrunner-server/config/v2 v2.10.3 h1:Yx+mS/CB2p0Ej0v5hayCcOpSj+8dAa00d8m2tefQO1k=
-github.com/roadrunner-server/config/v2 v2.10.3/go.mod h1:9dWbxvQeUjgbuYCxQ/56V9qw3iCNYI/vbVQ8T63XPHk=
+github.com/roadrunner-server/cache/v2 v2.11.0 h1:ndqovXOPe0kJ8YN6NZVjj2SXR1WPbhFFhGSk8I0x5Ss=
+github.com/roadrunner-server/cache/v2 v2.11.0/go.mod h1:uQxhqa2sk5ugcPoACjCdDnJLZzmnEUTWm1EItVnk1bw=
+github.com/roadrunner-server/config/v2 v2.11.0 h1:hXcPCXgLAV/2fQbn8UuGej5znd6ET9qX+Gt+vhMAKCI=
+github.com/roadrunner-server/config/v2 v2.11.0/go.mod h1:0nGg8I34VVZOFyCwQtBLDqSZK72Pksm1TC5QObaviG0=
 github.com/roadrunner-server/endure v1.2.2 h1:MuNT8jjg75OczvMdj1h8KUBWKaQbpUrN2ymkTOA+QpQ=
 github.com/roadrunner-server/endure v1.2.2/go.mod h1:MzEmu0galbhgNGMeVcb5u7PqHz2uvpeyFzKlC82O25E=
 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.10.2 h1:bgJf3llCztWebBIhIh5lSd9j49c2F9T5CIuYPukB9k4=
-github.com/roadrunner-server/fileserver/v2 v2.10.2/go.mod h1:fvSTvAGG42keR/4+Mip0MfZHwyJLYgWPhJwo1jC7K0Q=
+github.com/roadrunner-server/fileserver/v2 v2.11.0 h1:ec8460pCL6paYaPk6XwBy6UHz7yjzWuCukRsjq2WRMw=
+github.com/roadrunner-server/fileserver/v2 v2.11.0/go.mod h1:+EBrCH8nM0YA4yOMFcY4vRzSZ0h2gVwp7pigoA+56pw=
 github.com/roadrunner-server/goridge/v3 v3.4.0 h1:6sIm8Dk+ykDzDkOB27vStAdriYuEymi8OSiro7y4Wbc=
 github.com/roadrunner-server/goridge/v3 v3.4.0/go.mod h1:i7Y1z7dr48E6KZ+bEBS7lBRh4t9eWSUCsEOivEPpS5s=
-github.com/roadrunner-server/grpc/v2 v2.11.3 h1:b7EZw0Wv6KFWRz5xtTY3kFFCTxsh1lKfWIL5kiu9Dp0=
-github.com/roadrunner-server/grpc/v2 v2.11.3/go.mod h1:uTtj/njonr6DTownKAphXrKHq0j23gy8RLwSXeh0zl8=
+github.com/roadrunner-server/grpc/v2 v2.12.0 h1:pTxz61W19uv0Axbv1ocsTaUy31hJW2RUUxnd6hGVWaw=
+github.com/roadrunner-server/grpc/v2 v2.12.0/go.mod h1:0TQeSchKK4uzMoAMDmAkZ3VOksF7qqmJQyRglggBJZo=
 github.com/roadrunner-server/gzip/v2 v2.9.0 h1:56dXirrCKRot2e8KKmCk3gBoksMZPedmeZpBm+Pu9so=
 github.com/roadrunner-server/gzip/v2 v2.9.0/go.mod h1:FNJqsJBydoAjJ/elgcpPXXI3ET5xKJDhsBsudYPqe/s=
-github.com/roadrunner-server/headers/v2 v2.10.2 h1:rjgd/XJUIlVXOY2UGUYWyqGnXNZ+E574SefVbD9ChaA=
-github.com/roadrunner-server/headers/v2 v2.10.2/go.mod h1:WdEXU2SYftztfZC9042qZ0hCsQKy1cRw91GOIWRq5/Y=
-github.com/roadrunner-server/http/v2 v2.12.3 h1:Ou5pWQqROqCl2eCmXU115qPWySN3zsT7BOUwUmEIQVk=
-github.com/roadrunner-server/http/v2 v2.12.3/go.mod h1:oh/GcV/c9yiR7Hey+byL+p/SWKxtCqRaUROssjirSr0=
+github.com/roadrunner-server/gzip/v2 v2.10.0 h1:/2dpoNU5SJBsrOBIk5dBHaIEk57NQ0X97zdbbFS5xOE=
+github.com/roadrunner-server/gzip/v2 v2.10.0/go.mod h1:+ZK6ae1O41kNJcsIGh6Vcu91caWcGq6cscWx/zugo60=
+github.com/roadrunner-server/headers/v2 v2.11.0 h1:NYjgGMjQgLTscVJTDe77zAz9gmb5/An6Y9HUUnlUIvQ=
+github.com/roadrunner-server/headers/v2 v2.11.0/go.mod h1:C+QmP9csKz4nFUsRFaRbPTKwHK2cR6UhYb8TIuIGDHk=
+github.com/roadrunner-server/http/v2 v2.13.0 h1:x42ZetLFS3xhDHAflRnqNHDiNPi76EkahWRe+Mr4hWI=
+github.com/roadrunner-server/http/v2 v2.13.0/go.mod h1:YL7yn5wiQ1riiqQUTFpsSr0m/WxIAWXQ5CsZOaLifz0=
 github.com/roadrunner-server/informer/v2 v2.10.2 h1:SB45xK6j1bPUIo1jZ6/+Zw5au+mD4ura7XCEDdLz3Ro=
 github.com/roadrunner-server/informer/v2 v2.10.2/go.mod h1:cFstEhIQaIsYkmJVHL4Mww7RbVnk17bxpBJCE93HF/0=
-github.com/roadrunner-server/jobs/v2 v2.10.2 h1:xwVrPWU9JIG/nznFzso0YUwBpIwixKehNEDp9wD2Pso=
-github.com/roadrunner-server/jobs/v2 v2.10.2/go.mod h1:lsBf500TsaZKQsll8CQ/Z2lpm6pVUZVrAWPbye99Zss=
+github.com/roadrunner-server/informer/v2 v2.11.0 h1:Ouo81SDmKD4UdN53GKmQOk0sGBa9Ml3cu9SxXEguAas=
+github.com/roadrunner-server/informer/v2 v2.11.0/go.mod h1:B7MvUyep+UB0e0Zq5S0Dn7vzHO2DxmHVgC1aDrnLcAY=
+github.com/roadrunner-server/jobs/v2 v2.11.0 h1:jSYRdw6xluUnyPguh+qw8DMVRIsQ4BFKtsKyhJwuctE=
+github.com/roadrunner-server/jobs/v2 v2.11.0/go.mod h1:hgWEqO1hoHt5DWe83sDrg5xmFIG+497RgSiUaddXkO8=
 github.com/roadrunner-server/kv/v2 v2.10.1 h1:G7KFLLOtb5gOQu1frB949R+r4ZN+U+pzyKZJVpc0DXo=
 github.com/roadrunner-server/kv/v2 v2.10.1/go.mod h1:7hZnknPy6EDYrwQzcJMgmeOc04H+5s0rVFPyp+eMtmE=
-github.com/roadrunner-server/logger/v2 v2.10.2 h1:Zalw8FEf7Q+khXm2hNENNlpVqhhLJTnkdbWrgUG6owA=
-github.com/roadrunner-server/logger/v2 v2.10.2/go.mod h1:Q6Epg/LsEmhQqZLDxUZHQitf78wVKwe/9t1nq8diA3k=
-github.com/roadrunner-server/memcached/v2 v2.10.1 h1:S5x3NLMLlAR46IBUw2MjdxoXiBZMwe1RuSibC7tSMe8=
-github.com/roadrunner-server/memcached/v2 v2.10.1/go.mod h1:Qs4rxMICeYI6t24sZHRWvV6mf8T3H6Km+nYM27Ea7zA=
-github.com/roadrunner-server/memory/v2 v2.10.1 h1:kVJ9S9OtEWnXbWsqPEdnu7RWCLlZihF5bNwQx78jzn8=
-github.com/roadrunner-server/memory/v2 v2.10.1/go.mod h1:TciZQ5UcUCwr0AYxsyX6NPDBNMja7o+kd6j+F1g+HQ4=
-github.com/roadrunner-server/metrics/v2 v2.10.2 h1:5938BOCXkJ2lM/IfZYAMm3NkUHEz/U0Uu6sQk1wf3C0=
-github.com/roadrunner-server/metrics/v2 v2.10.2/go.mod h1:iCheqtmxg/axLLKapgSQVQ6kvwb7a2kgGq52DXrO8f4=
-github.com/roadrunner-server/nats/v2 v2.10.3 h1:iUHmdqk8dT2nMsisPBSWQ9wdzZKmVCsb/5dgRkPhzzQ=
-github.com/roadrunner-server/nats/v2 v2.10.3/go.mod h1:xvojJjLelBIEI3p9o8qwIfEPmK3XdKugHQhOsDYDKck=
-github.com/roadrunner-server/new_relic/v2 v2.11.3 h1:Bsw5Lp4uObKmCKWza2MDpPAx6QCEdknFKcZKJPCaRM8=
-github.com/roadrunner-server/new_relic/v2 v2.11.3/go.mod h1:CPO8kmQP9iANQh4XcA1gKrveKe6NHSK6AW421goAIu0=
-github.com/roadrunner-server/prometheus/v2 v2.10.0 h1:uRBQmJ7P3bFPc15FAm93bFga0zTmouowWisRsfHdbPM=
-github.com/roadrunner-server/prometheus/v2 v2.10.0/go.mod h1:5FqA4IEBzu9EppIF3Rqj7OyJqUY6EIkpFPv54wvDQdc=
+github.com/roadrunner-server/kv/v2 v2.11.0 h1:Z3Et0x19gJjnDF01uhYnmTvibZwHvovJF7FX3TvQoOU=
+github.com/roadrunner-server/kv/v2 v2.11.0/go.mod h1:yh3F2Ilmp2/gjmyJIXqcIKu0JtAIS5N+rfVeozQEHsA=
+github.com/roadrunner-server/logger/v2 v2.11.0 h1:kNzRERGsNLUIfCR5uDXfbpFHMtt07Fr0gsMGDl2vPfM=
+github.com/roadrunner-server/logger/v2 v2.11.0/go.mod h1:Zsl9Fe7XW0nJtqfr65jESL6LEQwj53IL429lL/W91dY=
+github.com/roadrunner-server/memcached/v2 v2.11.0 h1:JsW61GNc9kdUNmvgz8RHPAXwNBGLDMH3cSf7Agcj/BM=
+github.com/roadrunner-server/memcached/v2 v2.11.0/go.mod h1:+R8oHmg6kNy9lOMMXxWm6rQlSmz0VlxGVRJhgRDUTTU=
+github.com/roadrunner-server/memory/v2 v2.11.0 h1:IyAFDgIR8bT49JRTRZYBJ8t2Cy+7nPp3k/xyPDduWRk=
+github.com/roadrunner-server/memory/v2 v2.11.0/go.mod h1:LpeLGwShsRfyaTGWUSswY1aqIw/aqd3cAASt1Bvz+ok=
+github.com/roadrunner-server/metrics/v2 v2.11.0 h1:GO8gHGM9T5nGf7EcGTRRHYWmuT90KdXdt1B687b4DCU=
+github.com/roadrunner-server/metrics/v2 v2.11.0/go.mod h1:ePXdEbkrA7n8M4OJMBgCoZPg/lJ5+STwSuTosUFdVsI=
+github.com/roadrunner-server/nats/v2 v2.11.0 h1:qN/40K6bzx1pN4gSO5F5zOY7OGSh/afaa+mkPJujTWE=
+github.com/roadrunner-server/nats/v2 v2.11.0/go.mod h1:O7BDxt28e3WrMenT7Q6YTE0pedP9htzNm/GsajgYxKM=
+github.com/roadrunner-server/new_relic/v2 v2.12.0 h1:xdv/JdeG4pAKgdSDjmPvMvBUK1FpSK5Ijw3tuKoHv/8=
+github.com/roadrunner-server/new_relic/v2 v2.12.0/go.mod h1:TUAoNI6oWZ85lk1x7mDmMUyhBtQqrMSGtNDpRfJDpGY=
+github.com/roadrunner-server/prometheus/v2 v2.11.0 h1:EpdxBJYnOvNzjAFtYr2nrlAO/cFCkPamAD8F3KE9TAc=
+github.com/roadrunner-server/prometheus/v2 v2.11.0/go.mod h1:v8HHyJtcvgUiG/h/Polk0WLDeUtg4Gtr6S7sjtvU63g=
 github.com/roadrunner-server/redis/v2 v2.11.1 h1:BEPAdxSfI7ZY6QIbh+KktFd5REBPWR+5rB2s94M6T50=
 github.com/roadrunner-server/redis/v2 v2.11.1/go.mod h1:xZLKatufJTbEJ3wrhyszuTt6SS1X+F58I02R8M5haec=
-github.com/roadrunner-server/reload/v2 v2.10.2 h1:/i4Ai7ffy8fVgzoiMKNHrX4oL6sMYZz65ovr/TKb6cY=
-github.com/roadrunner-server/reload/v2 v2.10.2/go.mod h1:pJSMktMex6sivzx2ZeT+VPyHjSvLy1qcZHGpUHSpxNo=
-github.com/roadrunner-server/resetter/v2 v2.10.2 h1:CGUNcsL8F7d56nvk/pBKEk60YWdvk7D1oiNdSXWdWgQ=
-github.com/roadrunner-server/resetter/v2 v2.10.2/go.mod h1:aXzfVXvZaQcGA4vtzNKzARHl/VOmGpZyiaaCggdS3CE=
+github.com/roadrunner-server/redis/v2 v2.12.0 h1:EfG8mvRSo4Gz230L4ta5aWmGFpOUBuxIGFWBI5VaxUY=
+github.com/roadrunner-server/redis/v2 v2.12.0/go.mod h1:Fkl12l+VztYYi0mobK/ghQkuxL7269wkjOEPS3RZKXc=
+github.com/roadrunner-server/reload/v2 v2.11.0 h1:6OEkjbZrgwjs+xvDX7BjyGP9LuggzWypOehC2cnLu6o=
+github.com/roadrunner-server/reload/v2 v2.11.0/go.mod h1:Baqn+56b5Je51vMwLN6VFneYL2dYZykVoOmrA2xE4j8=
+github.com/roadrunner-server/resetter/v2 v2.11.0 h1:EQGv7wHVOe/BtBzYOUlHdcmOY1XyTk6+5Tpzx56lEOw=
+github.com/roadrunner-server/resetter/v2 v2.11.0/go.mod h1:9G3EZA1pSij6NO+PeCqbLunE/ke6kSybR5P59Iv6dyc=
 github.com/roadrunner-server/rpc/v2 v2.10.2 h1:oGOn78nIGcL5nUfdSc9fqZacwPtlw6j1XJj/UFKvDMs=
 github.com/roadrunner-server/rpc/v2 v2.10.2/go.mod h1:wDjEOpWHinwM76wWMQUYYLJKLKmrLsVtN+4YJ/MyS5Q=
-github.com/roadrunner-server/sdk/v2 v2.11.1 h1:r5/ztyfEtsfymAjVynsgv5IZi5hJPrgUFA1hH4YoDVY=
-github.com/roadrunner-server/sdk/v2 v2.11.1/go.mod h1:mzKZdxTKLD4Hr0+JK7izkESchUOew+olTAFfi5zexqc=
+github.com/roadrunner-server/rpc/v2 v2.11.0 h1:chnnNivD+zceu0y5+LxZpQWOD6JKYdI595neboKK3To=
+github.com/roadrunner-server/rpc/v2 v2.11.0/go.mod h1:KZJbTdB3LK5WIGzJ0Bq0QkG1RK8wfSioatheoneCdFQ=
+github.com/roadrunner-server/sdk/v2 v2.12.0 h1:O2uN0ufBQ/ftpoXYW9k/w9JZW8+01JvSQXpqsZ69xPo=
+github.com/roadrunner-server/sdk/v2 v2.12.0/go.mod h1:SPBLc4g9i9qpQ71dXTeaRXpfNgKjtCSwEk/dc1bXg+s=
 github.com/roadrunner-server/send/v2 v2.9.0 h1:59tTVt2j6KDc+KlQKqzqqXq0Z2u3ctQWwAaXig5wPqE=
 github.com/roadrunner-server/send/v2 v2.9.0/go.mod h1:p3xJamvF47VPdeX2kBPQjKPSbUWCSA+tHN9dIIcGanU=
-github.com/roadrunner-server/server/v2 v2.11.2 h1:gtwOvQtWOQYLpzzpQnkviXnMhOUOfFgoJLe3I3gYdZI=
-github.com/roadrunner-server/server/v2 v2.11.2/go.mod h1:JY1lsVFqGHMDbzucEF4IrxrvK+KRoh6FtFRjVQzSMjU=
+github.com/roadrunner-server/send/v2 v2.10.0 h1:FRNo8aMzrE4Zu0IwdUPsp1Rh6CuTULBRUHvbbtfADME=
+github.com/roadrunner-server/send/v2 v2.10.0/go.mod h1:48Pe+O+4vmirHBNGfd1/l7SZoPQ2EonSLBhOi9Nathw=
+github.com/roadrunner-server/server/v2 v2.12.0 h1:Qd9XEviH4ScxTX2i/Vl/8nMChwSSeSnBnaXjSly1J7o=
+github.com/roadrunner-server/server/v2 v2.12.0/go.mod h1:Yi9KiGLzmk/4+tw0q77th/mdEolhZg/77hTFjrp4CTI=
 github.com/roadrunner-server/service/v2 v2.10.3 h1:Ua8HYLYltmdVFqGPHPRznxMJd7/6XNeCyXrTUTF5kcc=
 github.com/roadrunner-server/service/v2 v2.10.3/go.mod h1:rBY7GWPstXAWScgEY9ApSWNqCp1XunAxDvv/D8nZ87I=
-github.com/roadrunner-server/sqs/v2 v2.11.2 h1:B4rUB6y0uWPBNeUHKzm0h44nQmy7sNUJRseXHERwRJg=
-github.com/roadrunner-server/sqs/v2 v2.11.2/go.mod h1:oSRsoXl1aKDmzEnseKJoMjWzpYQB0LX7oTt+Klb+iqE=
-github.com/roadrunner-server/static/v2 v2.10.2 h1:d16g1ha9Z3GYJttOOfJeiLTY7Md027d/RJYv6/sI9jI=
-github.com/roadrunner-server/static/v2 v2.10.2/go.mod h1:t15U1u2I8qEaZTTcbepmsz6VuK+sZI6xXpadoVkrINY=
-github.com/roadrunner-server/status/v2 v2.10.2 h1:/YeEY/BeLQl0MabSHjDJdAQrQ+EhnZI89kY7yjFEMJM=
-github.com/roadrunner-server/status/v2 v2.10.2/go.mod h1:N4wD+tgqsQuBZwd1qLl87BJb9keOzUBsFTi1y7W0ow4=
-github.com/roadrunner-server/tcp/v2 v2.10.2 h1:C1bEEYeV0rnjxb9LYcRq3ai/cSO6TZQBPeeT2+3zFGo=
-github.com/roadrunner-server/tcp/v2 v2.10.2/go.mod h1:lgYGtw79fj1FBikydBlKQvdVDa9UHYDbYS4wWDUnmb0=
+github.com/roadrunner-server/service/v2 v2.11.0 h1:v9LvDi21+BbtmIj/w8vYV24lVNBqFq565EzjlExjVZ8=
+github.com/roadrunner-server/service/v2 v2.11.0/go.mod h1:2LRAmbd95YoxdHIsHJjYchcQL9LICM0WWS9kOotAQD8=
+github.com/roadrunner-server/sqs/v2 v2.12.0 h1:HaZwYv3+3dS0AqiqvYE48jupvmYWkQ1iaQUOWq8EsYQ=
+github.com/roadrunner-server/sqs/v2 v2.12.0/go.mod h1:2eO7Rf8GFiiuPud52EJJSbFA0wPYhZ6b0cxX6qxGZX4=
+github.com/roadrunner-server/static/v2 v2.11.0 h1:XmyoyPrkTeEoQYSJfFkWRiRiq5SSZo2EDSS0C3hTDc4=
+github.com/roadrunner-server/static/v2 v2.11.0/go.mod h1:/0WKU8uxbIn+mEsR+R6pDcciW7+WYrtHD5+c5plH4hE=
+github.com/roadrunner-server/status/v2 v2.11.0 h1:IgI7Ea++NQ3sgwjjU8USZPcgtLYqvdlQYBbgNTnbAHM=
+github.com/roadrunner-server/status/v2 v2.11.0/go.mod h1:ekYw7soYlGootnv4B0aiLNEDLqAViJZLPJh/gAUcYu4=
+github.com/roadrunner-server/tcp/v2 v2.11.0 h1:pOqriY1Bx6ptdoT7Shu7OTnL+7jC1mvWq+F0/Fw+q1s=
+github.com/roadrunner-server/tcp/v2 v2.11.0/go.mod h1:krlYXDLdR+OFUT6+Uvrn1+x59oR2r3FbiEnWRhlW7VY=
 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.10.2 h1:vYFmoPMljRzMfG7BC4rWAZIxM93QguQd49NJPKEfhSU=
-github.com/roadrunner-server/websockets/v2 v2.10.2/go.mod h1:UGv9EsJhb8U34JvljPVEbtZoUE91OWV/SfXzhSJ9fog=
+github.com/roadrunner-server/websockets/v2 v2.11.0 h1:HBEmnQPsxQ0CXKEVCfUwk+Pf8Xhb2AgJEDqG0G2pn28=
+github.com/roadrunner-server/websockets/v2 v2.11.0/go.mod h1:wwSxQ7+8U9aw2Onw3mAmVZPxTiiyjD5y1oWY6NyZAlc=
 github.com/robfig/cron v1.2.0 h1:ZjScXvvxeQ63Dbyxy76Fj3AT3Ut0aKsyd2/tl3DTMuQ=
 github.com/robfig/cron v1.2.0/go.mod h1:JGuDeoQd7Z6yL4zQhZ3OPEVHB7fL6Ka6skscFHfmt2k=
 github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
@@ -870,8 +909,8 @@ 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-20220222213610-43724f9ea8cf/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI=
-google.golang.org/genproto v0.0.0-20220322021311-435b647f9ef2 h1:3n0D2NdPGm0g0wrVJzXJWW5CBOoqgGBkDX9cRMJHZAY=
-google.golang.org/genproto v0.0.0-20220322021311-435b647f9ef2/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E=
+google.golang.org/genproto v0.0.0-20220323144105-ec3c684e5b14 h1:17TOyVD+9MLIDtDJW9PdtMuVT7gNLEkN+G/xFYjZmr8=
+google.golang.org/genproto v0.0.0-20220323144105-ec3c684e5b14/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E=
 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=