summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2022-12-01 12:49:48 +0100
committerGitHub <[email protected]>2022-12-01 12:49:48 +0100
commitef1f3159ac2a16ddf0119afcd61df07a51cc8b33 (patch)
treea138af0c4b96d9d5fb37d9581c8f6375929bdc72
parent6e61b988c8e328543f5708421e7196878b3f96f2 (diff)
parent79ec1832e5bc08663fe6853afefb8660b1d2e0ce (diff)
[#1385]: release: `v2.12.1`v2.12.1-rc.1v2.12.1
-rw-r--r--.rr.yaml20
-rw-r--r--CHANGELOG.md17
-rw-r--r--go.mod80
-rw-r--r--go.sum160
-rw-r--r--schemas/config/2.0.schema.json10
5 files changed, 159 insertions, 128 deletions
diff --git a/.rr.yaml b/.rr.yaml
index daa2ec42..7832789b 100644
--- a/.rr.yaml
+++ b/.rr.yaml
@@ -1239,7 +1239,7 @@ jobs:
# If the job has priority set to 0, it will inherit the pipeline's priority. Default: 10.
priority: 10
- # Number of job to prefetch from the driver.
+ # Number of job to prefetch from the driver until ACK/NACK.
#
# Default: 100_000.
prefetch: 10000
@@ -1303,6 +1303,21 @@ jobs:
# Default: false
durable: false
+ # Durable exchange (rabbitmq option: https://www.rabbitmq.com/tutorials/amqp-concepts.html#exchanges)
+ #
+ # Default: true
+ exchange_durable: false
+
+ # Auto-delete (exchange is deleted when last queue is unbound from it): https://www.rabbitmq.com/tutorials/amqp-concepts.html#exchanges
+ #
+ # Default: false
+ exchange_auto_deleted: false
+
+ # Auto-delete (queue that has had at least one consumer is deleted when last consumer unsubscribes) (rabbitmq option: https://www.rabbitmq.com/queues.html#properties)
+ #
+ # Default: false
+ queue_auto_deleted: false
+
# Delete queue when stopping the pipeline
#
# Default: false
@@ -1397,8 +1412,7 @@ jobs:
# If the job has priority set to 0, it will inherit the pipeline's priority. Default: 10.
priority: 10
- # Number of jobs to prefetch from the SQS. Amazon SQS never returns more messages than this value
- # (however, fewer messages might be returned). Valid values: 1 to 10.
+ # Number of jobs to prefetch from the SQS until ACK/NACK.
#
# Default: 10
prefetch: 10
diff --git a/CHANGELOG.md b/CHANGELOG.md
index add316c4..dae057a3 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,22 @@
# CHANGELOG
+## v2.12.1 (01.12.2022)
+
+###### tags: `roadrunner` `v2.12.1`
+
+## <center> 🚀 v2.12.1 🚀 </center>
+## <center>👀 New: </center>
+
+- ✏ **RR:** Automatically set the `GOMAXPROCS` to match the container CPU quota.
+- ✏ **AMQP plugin:** implement `Status` to check the AMQP connection [PR](https://github.com/roadrunner-server/amqp/pull/33).
+- ✏ **SQS plugin:** `prefetch` option now works as expected. RR will not consume new JOBS when reaches `prefetch` limit, until already accepted messages are not ACK/NACK-ed.
+- ✏ **JOBS(memory) plugin:** `prefetch` option now works as expected (see SQS). You can now emulate FIFO in memory by setting the `prefetch` option to 1.
+
+### <center>🩹 Fixes:</center>
+
+- **gRPC plugin**: server options are applied only when TLS is set. [Discussion](https://github.com/roadrunner-server/roadrunner/discussions/1384).
+- **AMQP plugin**: fix a few typos in the configuration.
+
## v2.12.0 (24.11.2022)
# ⚠️ `websocket` and `broadcast` plugins were replaced by the new `centrifuge` plugin.
diff --git a/go.mod b/go.mod
index b850a3bd..2744c101 100644
--- a/go.mod
+++ b/go.mod
@@ -9,48 +9,48 @@ 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/v3 v3.0.2
- github.com/roadrunner-server/app-logger/v3 v3.0.1
- github.com/roadrunner-server/beanstalk/v3 v3.0.2
- github.com/roadrunner-server/boltdb/v3 v3.0.2
- github.com/roadrunner-server/centrifuge/v3 v3.0.2
- github.com/roadrunner-server/config/v3 v3.0.2
- github.com/roadrunner-server/endure v1.4.5
+ github.com/roadrunner-server/amqp/v3 v3.0.4
+ github.com/roadrunner-server/app-logger/v3 v3.0.2
+ github.com/roadrunner-server/beanstalk/v3 v3.0.4
+ github.com/roadrunner-server/boltdb/v3 v3.0.4
+ github.com/roadrunner-server/centrifuge/v3 v3.0.4
+ github.com/roadrunner-server/config/v3 v3.0.4
+ github.com/roadrunner-server/endure v1.4.6
github.com/roadrunner-server/errors v1.2.0
- github.com/roadrunner-server/fileserver/v3 v3.0.2
+ github.com/roadrunner-server/fileserver/v3 v3.0.4
github.com/roadrunner-server/goridge/v3 v3.6.2
- github.com/roadrunner-server/grpc/v3 v3.0.2
- github.com/roadrunner-server/gzip/v3 v3.0.2
- github.com/roadrunner-server/headers/v3 v3.0.2
- github.com/roadrunner-server/http/v3 v3.0.3
- github.com/roadrunner-server/informer/v3 v3.0.2
- github.com/roadrunner-server/jobs/v3 v3.0.2
- github.com/roadrunner-server/kafka/v3 v3.0.2
- github.com/roadrunner-server/kv/v3 v3.0.2
- github.com/roadrunner-server/logger/v3 v3.0.1
- github.com/roadrunner-server/memcached/v3 v3.0.2
- github.com/roadrunner-server/memory/v3 v3.1.0
- github.com/roadrunner-server/metrics/v3 v3.1.0
- github.com/roadrunner-server/nats/v3 v3.0.2
- github.com/roadrunner-server/otel/v3 v3.0.2
- github.com/roadrunner-server/prometheus/v3 v3.0.2
- github.com/roadrunner-server/proxy_ip_parser/v3 v3.0.2
- github.com/roadrunner-server/redis/v3 v3.0.2
- github.com/roadrunner-server/reload/v3 v3.0.1
- github.com/roadrunner-server/resetter/v3 v3.0.1
- github.com/roadrunner-server/rpc/v3 v3.0.2
- github.com/roadrunner-server/sdk/v3 v3.0.0
- github.com/roadrunner-server/send/v3 v3.0.2
- github.com/roadrunner-server/server/v3 v3.0.2
- github.com/roadrunner-server/service/v3 v3.0.2
- github.com/roadrunner-server/sqs/v3 v3.1.0
- github.com/roadrunner-server/static/v3 v3.0.2
- github.com/roadrunner-server/status/v3 v3.0.2
- github.com/roadrunner-server/tcp/v3 v3.0.2
+ github.com/roadrunner-server/grpc/v3 v3.0.5
+ github.com/roadrunner-server/gzip/v3 v3.0.4
+ github.com/roadrunner-server/headers/v3 v3.0.4
+ github.com/roadrunner-server/http/v3 v3.0.5
+ github.com/roadrunner-server/informer/v3 v3.0.4
+ github.com/roadrunner-server/jobs/v3 v3.0.4
+ github.com/roadrunner-server/kafka/v3 v3.0.4
+ github.com/roadrunner-server/kv/v3 v3.0.4
+ github.com/roadrunner-server/logger/v3 v3.0.2
+ github.com/roadrunner-server/memcached/v3 v3.0.4
+ github.com/roadrunner-server/memory/v3 v3.1.3
+ github.com/roadrunner-server/metrics/v3 v3.1.1
+ github.com/roadrunner-server/nats/v3 v3.0.4
+ github.com/roadrunner-server/otel/v3 v3.0.4
+ github.com/roadrunner-server/prometheus/v3 v3.0.4
+ github.com/roadrunner-server/proxy_ip_parser/v3 v3.0.4
+ github.com/roadrunner-server/redis/v3 v3.0.4
+ github.com/roadrunner-server/reload/v3 v3.0.2
+ github.com/roadrunner-server/resetter/v3 v3.0.2
+ github.com/roadrunner-server/rpc/v3 v3.0.4
+ github.com/roadrunner-server/sdk/v3 v3.0.1
+ github.com/roadrunner-server/send/v3 v3.0.4
+ github.com/roadrunner-server/server/v3 v3.0.4
+ github.com/roadrunner-server/service/v3 v3.0.4
+ github.com/roadrunner-server/sqs/v3 v3.1.3
+ github.com/roadrunner-server/static/v3 v3.0.4
+ github.com/roadrunner-server/status/v3 v3.0.4
+ github.com/roadrunner-server/tcp/v3 v3.0.4
github.com/spf13/cobra v1.6.1
github.com/spf13/viper v1.14.0
github.com/stretchr/testify v1.8.1
- github.com/temporalio/roadrunner-temporal/v2 v2.0.0
+ github.com/temporalio/roadrunner-temporal/v2 v2.0.1
go.buf.build/protocolbuffers/go/roadrunner-server/api v1.3.27
go.uber.org/automaxprocs v1.5.1
)
@@ -175,7 +175,7 @@ require (
github.com/rabbitmq/amqp091-go v1.5.0 // indirect
github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475 // indirect
github.com/rivo/uniseg v0.4.3 // indirect
- github.com/roadrunner-server/tcplisten v1.2.0 // indirect
+ github.com/roadrunner-server/tcplisten v1.2.1 // indirect
github.com/robfig/cron v1.2.0 // indirect
github.com/sean-/seed v0.0.0-20170313163322-e2103e2c3529 // indirect
github.com/segmentio/asm v1.2.0 // indirect
@@ -227,7 +227,7 @@ require (
go.temporal.io/server v1.18.5 // indirect
go.uber.org/atomic v1.10.0 // indirect
go.uber.org/multierr v1.8.0 // indirect
- go.uber.org/zap v1.23.0 // indirect
+ go.uber.org/zap v1.24.0 // indirect
golang.org/x/crypto v0.3.0 // indirect
golang.org/x/mod v0.7.0 // indirect
golang.org/x/net v0.2.0 // indirect
@@ -237,7 +237,7 @@ require (
golang.org/x/time v0.2.0 // indirect
golang.org/x/tools v0.3.0 // indirect
google.golang.org/appengine v1.6.7 // indirect
- google.golang.org/genproto v0.0.0-20221118155620-16455021b5e6 // indirect
+ google.golang.org/genproto v0.0.0-20221130183247-a2ec334bae6f // indirect
google.golang.org/grpc v1.51.0 // indirect
google.golang.org/protobuf v1.28.1 // indirect
gopkg.in/ini.v1 v1.67.0 // indirect
diff --git a/go.sum b/go.sum
index 30af0a13..1e076ac9 100644
--- a/go.sum
+++ b/go.sum
@@ -813,84 +813,84 @@ github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475/go.mod h1:bCqn
github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
github.com/rivo/uniseg v0.4.3 h1:utMvzDsuh3suAEnhH0RdHmoPbU648o6CvXxTx4SBMOw=
github.com/rivo/uniseg v0.4.3/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88=
-github.com/roadrunner-server/amqp/v3 v3.0.2 h1:RqrhIiXxnthrSXLEAJohs434ZGP96zal9QTe4bb7Ikk=
-github.com/roadrunner-server/amqp/v3 v3.0.2/go.mod h1:t2gYk1PNcK2Cs2U5l8WQtP7OP1/Tb9q737A6usGmoK8=
-github.com/roadrunner-server/app-logger/v3 v3.0.1 h1:3RBKC0RtH2hU3uYf9Toi3lcVxxkPOeW8S1exIoD5ulw=
-github.com/roadrunner-server/app-logger/v3 v3.0.1/go.mod h1:n1ncVSoz/GaFkjH7qPyNLwLj0VKRVYGDP0sZcJEmeJM=
-github.com/roadrunner-server/beanstalk/v3 v3.0.2 h1:XoS/UiBGZOUH0lrezN7n5L+uUz2WFi1gU1a4nqP5dxQ=
-github.com/roadrunner-server/beanstalk/v3 v3.0.2/go.mod h1:/fO0eVRAHzK6PUdRubSwGx2VDfGQEd+lR7DEovYvIoI=
-github.com/roadrunner-server/boltdb/v3 v3.0.2 h1:MFonzRZhqnUDsrZZiQK1WV0COBF4WfVNkdnjSNqmtxw=
-github.com/roadrunner-server/boltdb/v3 v3.0.2/go.mod h1:W56lbWrQ/rMk8Um5a3t7GnL+AsesSVeC77hNKOKVY+g=
-github.com/roadrunner-server/centrifuge/v3 v3.0.2 h1:yz6tt1tuM/dGR84+PSDsKsfWXGExtSVsghNYSTsCTfM=
-github.com/roadrunner-server/centrifuge/v3 v3.0.2/go.mod h1:h1+Zz+f6Tn+2wwbSbB9M8gKEFajn560BPur7TguRIJU=
-github.com/roadrunner-server/config/v3 v3.0.2 h1:B2ONTKfdbUCLYf4xg9GpNjD2TwK9Zw21t4ziEruQy6M=
-github.com/roadrunner-server/config/v3 v3.0.2/go.mod h1:KyS+on9l5YcKgdQx2hjvOhKbiL3PI6aPZ0KwCAp5Occ=
-github.com/roadrunner-server/endure v1.4.5 h1:kInGwZc9Xd55gXsdAQonajz5I202MDyJdV+biJ6+asI=
-github.com/roadrunner-server/endure v1.4.5/go.mod h1:FLqkppN/DAXhdMpuoVAlMt1L2odLCvCDRQr83gTHOl4=
+github.com/roadrunner-server/amqp/v3 v3.0.4 h1:XnCe/ig/WUh1x4uz41jD3+JE/Omyr5qEcpu5Dz/OAqc=
+github.com/roadrunner-server/amqp/v3 v3.0.4/go.mod h1:jaDg13Pii+TQr8RlPMbVpQKoLx5wbgKOF1fin/RsM0A=
+github.com/roadrunner-server/app-logger/v3 v3.0.2 h1:4fZObK73geWmbgxv6Sfssi2a/Xggd8Amz9jt8pWGcZ8=
+github.com/roadrunner-server/app-logger/v3 v3.0.2/go.mod h1:5BzNlVgyqfg8y8luq16qHyFc4TVzu7t8sB2GNfMyh50=
+github.com/roadrunner-server/beanstalk/v3 v3.0.4 h1:ETyKRkDcCt0/Bu/5eMJ4lVvRhDq5gIHkgIFDdySMaag=
+github.com/roadrunner-server/beanstalk/v3 v3.0.4/go.mod h1:MQ4yKo4pyXTCA5SOlOzq2M41TeZaRqGnZErzeT37YdQ=
+github.com/roadrunner-server/boltdb/v3 v3.0.4 h1:FnSv0xPLg1Sg5HzbUSMVbeC4cyNuAMD16jMEwYi1vsk=
+github.com/roadrunner-server/boltdb/v3 v3.0.4/go.mod h1:8n5OCAHY8x6XkFsP0DWqzlawLRMC8xJTxyoDfk0wfwA=
+github.com/roadrunner-server/centrifuge/v3 v3.0.4 h1:ky1rbEjcxUu1y9I6Yf6jQ1MOmbnm8ONlwFeRn0O/NTQ=
+github.com/roadrunner-server/centrifuge/v3 v3.0.4/go.mod h1:806827FjvXdC1BFzA8NOXgmD2OSGkDHxXQ0My3PqJU0=
+github.com/roadrunner-server/config/v3 v3.0.4 h1:BpItCRZeFQLpLZltH7t/ynNxn1snfp2gUjf4ZTVwh7s=
+github.com/roadrunner-server/config/v3 v3.0.4/go.mod h1:p5Gz7c0Wu9N/54dEElK13yu582ah1cR223l8oyTy1qw=
+github.com/roadrunner-server/endure v1.4.6 h1:YogRSfh0sEvIEyhXh0K3aAzL0Ngim7d5Mx2QZkvgX6o=
+github.com/roadrunner-server/endure v1.4.6/go.mod h1:KZBQ4gz8H0znndK698fQyWxVpw3SYmbG2nHEszC5ijI=
github.com/roadrunner-server/errors v1.2.0 h1:qBmNXt8Iex9QnYTjCkbJKsBZu2EtYkQCM06GUDcQBbI=
github.com/roadrunner-server/errors v1.2.0/go.mod h1:z0ECxZp/dDa5RahtMcy4mBIavVxiZ9vwE5kByl7kFtY=
-github.com/roadrunner-server/fileserver/v3 v3.0.2 h1:TTiGWQEauWrunpIc3BCrCbaGB67x0ToWoPseojDmh00=
-github.com/roadrunner-server/fileserver/v3 v3.0.2/go.mod h1:L61cIw+bQWAZliASsHzOCNeqDeWZEIqmirzqzAvdck8=
+github.com/roadrunner-server/fileserver/v3 v3.0.4 h1:hFgtyvf+fQInGTGvp/H7vk3kIdeJ4cngZ0YOcR44rc0=
+github.com/roadrunner-server/fileserver/v3 v3.0.4/go.mod h1:xV0lXawe3MSUdfY8Ypw7Ky7+pfOrUTjx5Oe1degY9T4=
github.com/roadrunner-server/goridge/v3 v3.6.2 h1:LH5HXfCygDp05KnOaXpa4fqVPWTsH7V3lfvPtMwFU3k=
github.com/roadrunner-server/goridge/v3 v3.6.2/go.mod h1:3B95k/wM5GGAD0h2hZlJagS9PlTDGs5jh8MpZYC12vA=
-github.com/roadrunner-server/grpc/v3 v3.0.2 h1:6nwR6HRI0xo0/A8jb5OTC/c7jO20zoMD86cJe8h64Yc=
-github.com/roadrunner-server/grpc/v3 v3.0.2/go.mod h1:zVRjKkCDS67GEgcpzG4aLMPx2qpA5K1oW62C5zwe9jQ=
-github.com/roadrunner-server/gzip/v3 v3.0.2 h1:kqz3eyp/NSZEcnE47bxYYwrmxVVOGdsXByEE3nwSqUI=
-github.com/roadrunner-server/gzip/v3 v3.0.2/go.mod h1:PT2Syx5/eMXVSJhPey50aODIR+WOBiS/xL2Ckl6lXSc=
-github.com/roadrunner-server/headers/v3 v3.0.2 h1:/i1/NgSEACCQ2rFHAIhc+1B1phz9MOyOpRBQEkyWs5I=
-github.com/roadrunner-server/headers/v3 v3.0.2/go.mod h1:RxxTY8jDcBunaBM4WiI+1yqcu35KueJS533PTxG7tn8=
-github.com/roadrunner-server/http/v3 v3.0.3 h1:aFTviUuZT5V9lkYL0m3SzzecrbN/Aa2qBpSsO5WyJis=
-github.com/roadrunner-server/http/v3 v3.0.3/go.mod h1:E4jon4/41RLJKAdoPlCAyWQpzeRaUhd+WBQ1taYMYFg=
-github.com/roadrunner-server/informer/v3 v3.0.2 h1:PqqvdJAlDdtomavMaM20WWWs1YNkNGk8+vo3TuScCrg=
-github.com/roadrunner-server/informer/v3 v3.0.2/go.mod h1:sH09PfnZ2xYOhifiNVi+Vbul3hF2fmdEDDiICEKEu6I=
-github.com/roadrunner-server/jobs/v3 v3.0.2 h1:cwFd+0ostvqladEbYLvHp1nuTYJdkwLDO6VcSa3X7GM=
-github.com/roadrunner-server/jobs/v3 v3.0.2/go.mod h1:pBf/wPhCbhZ9W4KSsmURvw4vz6ZMslOOyy9tazSSNXM=
-github.com/roadrunner-server/kafka/v3 v3.0.2 h1:kxsnInTbDY8xyX/dreWnJuDWTUITscJFK0PtoH1H5iQ=
-github.com/roadrunner-server/kafka/v3 v3.0.2/go.mod h1:tKyGvnLPCD/QOQ35LQ6hMNx6dKRl5t3xhnnUg8Cp5hc=
-github.com/roadrunner-server/kv/v3 v3.0.2 h1:IfFG/OfaS2tUj6woz7YK6kE9dHxvmMTPz98+xR7GRgU=
-github.com/roadrunner-server/kv/v3 v3.0.2/go.mod h1:bo9WGfH70+xsbq5duGArtrPDdFIuviC5FR8Mf3wv06U=
-github.com/roadrunner-server/logger/v3 v3.0.1 h1:gcz4PCmrFGjHjzpLLFy2T+KmlH5Oen2/iUHY08OIA5w=
-github.com/roadrunner-server/logger/v3 v3.0.1/go.mod h1:Uc6P2arkF1au8nfnlMl1Bif+zac5HR1rfaAioJeot5I=
-github.com/roadrunner-server/memcached/v3 v3.0.2 h1:FiMhaOqTBZyG84u9ZU26O7I5i2awdwTQn+be8qcE56k=
-github.com/roadrunner-server/memcached/v3 v3.0.2/go.mod h1:lPjv5rEIzKLCw3QEcIn18/qAdB8eXcxrYjC6FpNa3Ik=
-github.com/roadrunner-server/memory/v3 v3.1.0 h1:aZvXBSdKuucY9FSlJErUSSHcwEnzjFZPKqIqmHrjCyw=
-github.com/roadrunner-server/memory/v3 v3.1.0/go.mod h1:dVh6Flg3C5DQ5YcgKyPZv3cBX8q0Y9MAMlJEkU5Tbmg=
-github.com/roadrunner-server/metrics/v3 v3.1.0 h1:YQ8874w6aWQaw7LrX4r5Nn8zyFQvyQbB9Ll1YnNnzY0=
-github.com/roadrunner-server/metrics/v3 v3.1.0/go.mod h1:4Mh7S2g9KZ0WMFri0eYBNx6XzGW324SGYkWsK+qdwi8=
-github.com/roadrunner-server/nats/v3 v3.0.2 h1:yf5RcYdj5FENH5OS4/gitztw8nbpJ1WgXJRgh/zRe0M=
-github.com/roadrunner-server/nats/v3 v3.0.2/go.mod h1:nB5qlzsn8rB3imwljttEPOEterGDApqiYPDIeax9oQc=
-github.com/roadrunner-server/otel/v3 v3.0.2 h1:/joMx5cQl03cduv+E2aHR0meAtQwJ/BT/yBCLd0qPF0=
-github.com/roadrunner-server/otel/v3 v3.0.2/go.mod h1:qCRpT4YqQ30QWLTaKyIAS3eRc0Ke4yYs6xtKzAkdv+4=
-github.com/roadrunner-server/prometheus/v3 v3.0.2 h1:nm5TYdo/QBYMiT2rmepe6065i4l8FgzSvMWqq22Apkc=
-github.com/roadrunner-server/prometheus/v3 v3.0.2/go.mod h1:x9iqqajtNXk3As30/F3G/pI1/Dvuq6TatAOov/6L9d0=
-github.com/roadrunner-server/proxy_ip_parser/v3 v3.0.2 h1:d1zK4C4qEN3ZPAV2evwLjMJfo8RQrdHJIr1+CRC+W/w=
-github.com/roadrunner-server/proxy_ip_parser/v3 v3.0.2/go.mod h1:SrPN7RMZfLNboNTBXQ7tdnCeZB3obYqZEFTOdrDFlRI=
-github.com/roadrunner-server/redis/v3 v3.0.2 h1:BXYAP61VDdBeeqqZ3+Syvk1BQBFjcIseerbmQw8Hc+M=
-github.com/roadrunner-server/redis/v3 v3.0.2/go.mod h1:HDX5DMjx8ibdHPjjwRrXtyE0j4qiVLDzpGXMXbNgz1Q=
-github.com/roadrunner-server/reload/v3 v3.0.1 h1:JRb6y652TNc7mKKlv3vYMR9COFJKXcPKZVIeUQzki+I=
-github.com/roadrunner-server/reload/v3 v3.0.1/go.mod h1:4l3xjs8dZCesNh/OyKoOymYOnbNHdWdBHVw5U09BpiY=
-github.com/roadrunner-server/resetter/v3 v3.0.1 h1:tt/zUSNspfeeM7/JbCAjmgQ198WNJa0NubVbpnT3URI=
-github.com/roadrunner-server/resetter/v3 v3.0.1/go.mod h1:+6pgq8TUvcQDsC1R4axEgjDhJTFzKzF2A95LvgRMDAI=
-github.com/roadrunner-server/rpc/v3 v3.0.2 h1:OsJFSNQDE1/DIw7OqKNXipDeSDiM47aUHLC3FcZ6Vko=
-github.com/roadrunner-server/rpc/v3 v3.0.2/go.mod h1:dOYfm+i+h0ZzIDBgob1PcabBqmq4EzFXd1h+ksS4XyY=
-github.com/roadrunner-server/sdk/v3 v3.0.0 h1:DhSLwTCAP5yzUwgBcUo6M1jK8e1XufxYvpFCuGACruw=
-github.com/roadrunner-server/sdk/v3 v3.0.0/go.mod h1:R8CbJAIsHjye7asTIl0zLDRl89aIRETLFFfHbmczw04=
-github.com/roadrunner-server/send/v3 v3.0.2 h1:zcOxT+Ukk6+72XQuMkm6182pWZICc+Y+iVo0P0MZxik=
-github.com/roadrunner-server/send/v3 v3.0.2/go.mod h1:rXotgARjYZ8KGmQ9+FGE4ogD9i6W/cSPIFZB0tetM+g=
-github.com/roadrunner-server/server/v3 v3.0.2 h1:wdFoVIcUNALBZOa92ZUz0PPAqBhQA0FnVNQVOCpTuPM=
-github.com/roadrunner-server/server/v3 v3.0.2/go.mod h1:hEDq7JtXzy4jJmepJWvzlDj5WHoo1jdwEPGH56Fil7g=
-github.com/roadrunner-server/service/v3 v3.0.2 h1:/in32R/6mssk+E2KHCMpIPfjBGKi9vnHEemGpIxSTgM=
-github.com/roadrunner-server/service/v3 v3.0.2/go.mod h1:Ab5W+H3LjH+69S0Y78YirJcaxBj9WVDFvb16dhM2MXY=
-github.com/roadrunner-server/sqs/v3 v3.1.0 h1:rmJA3MmqAKEuwKKbIV/OcnIeYkWDLH5j8WU+EWaQe3k=
-github.com/roadrunner-server/sqs/v3 v3.1.0/go.mod h1:EDNdTuEiXfGF1m5gnC+RuNofeqMJ8cyYxUMjY6U+Muc=
-github.com/roadrunner-server/static/v3 v3.0.2 h1:G/YAIqTX4SeBDv2GTQwnrwc0lNXiimLor271+S7+YRk=
-github.com/roadrunner-server/static/v3 v3.0.2/go.mod h1:e5w5JltWvctvDabsFZkgr/qK8SktCwkJHw/nr2Xz5QE=
-github.com/roadrunner-server/status/v3 v3.0.2 h1:cYIUlvnCkS22l2osT90G2zB0J2Lu6iC3cECVBjgP2BA=
-github.com/roadrunner-server/status/v3 v3.0.2/go.mod h1:3UubQgEnfiXtqHoR9KuXiy04IGj+S1oT+SOCcQTHyJI=
-github.com/roadrunner-server/tcp/v3 v3.0.2 h1:svwqxhutJI4PPAdkJyi+YLQhvGgsxYaUeabaFfg603k=
-github.com/roadrunner-server/tcp/v3 v3.0.2/go.mod h1:Y0b7nCih4TVQ+A8hh5qMav6DPOf11jWrso2+zhjFbxU=
-github.com/roadrunner-server/tcplisten v1.2.0 h1:nsiXEEb0zP7vjAsCWNHKpM0HdwFK/KlafFF/2gsTJlg=
-github.com/roadrunner-server/tcplisten v1.2.0/go.mod h1:NhumKvt7dbIKVNZnqR1fA4ET1D8ngIKsg0TxnuJTL6A=
+github.com/roadrunner-server/grpc/v3 v3.0.5 h1:No3bxkIBWWDGrvrV+lwoDfRpa7MNIt3OMPLz9X/RAxI=
+github.com/roadrunner-server/grpc/v3 v3.0.5/go.mod h1:DKZai+6t1iGQNR4oIvZ6vMNa2X35xOBbbe8XeQ0fRZQ=
+github.com/roadrunner-server/gzip/v3 v3.0.4 h1:Uqlji74ZC/NNwmTmKp7v+hJz3olmXKWD98nscgoUySk=
+github.com/roadrunner-server/gzip/v3 v3.0.4/go.mod h1:96x7PTYkWGbvXG8I2aMwGmPt1D29zcJ5CTI6gYZ1m5s=
+github.com/roadrunner-server/headers/v3 v3.0.4 h1:euxTUa4GGVrXwTWGC3WNlDVMbQijtlSkTBKX4OYngTk=
+github.com/roadrunner-server/headers/v3 v3.0.4/go.mod h1:5ReBYpMYo639GE+Lj+UL5xCMzpg7vpLCxJKB+yl/Z98=
+github.com/roadrunner-server/http/v3 v3.0.5 h1:Xho37jtGqQlVjgw6XWsLPYN2usVOJsDlNjBLhNP6KFA=
+github.com/roadrunner-server/http/v3 v3.0.5/go.mod h1:NY2vcASNjLokR0O+Ww7p6IdEmUqU73mTU0XSu30wa58=
+github.com/roadrunner-server/informer/v3 v3.0.4 h1:lhazjrUN1QgrtECWcaa2SXmlp2gH4l8nXzCluLo4J7s=
+github.com/roadrunner-server/informer/v3 v3.0.4/go.mod h1:FRyaFqUm/VqzHGGhnd8iVBLFotDgbFZs0jFx2Jqcqsc=
+github.com/roadrunner-server/jobs/v3 v3.0.4 h1:WFJ4p1y1ATNAenhNm8lGpPo1/YMH8CyMw1OOUbHs6sc=
+github.com/roadrunner-server/jobs/v3 v3.0.4/go.mod h1:S/f7j7vjUVQFrWMsmpy5mbGEzVAHGLmPF76zqsR+2xA=
+github.com/roadrunner-server/kafka/v3 v3.0.4 h1:xijppvMHYik9CnEUXcsx+wSB0h4mjq4hhYhO10i58R8=
+github.com/roadrunner-server/kafka/v3 v3.0.4/go.mod h1:C6ZbfwS6DhPxXI2OakRc/juy/JcHc/wWa23aVbAzO/o=
+github.com/roadrunner-server/kv/v3 v3.0.4 h1:3oR+r552wD9F/dakSXur9gzqSmkd8Im7oFLe3zsxdzw=
+github.com/roadrunner-server/kv/v3 v3.0.4/go.mod h1:gljvzU8nM6sFqWFKAy3XUtp7/NrbZCXzvhMx2Kcdqc0=
+github.com/roadrunner-server/logger/v3 v3.0.2 h1:nMnggIcf6m494e9KNs3JUSEZ3GUFUisC84hrh/3P1pM=
+github.com/roadrunner-server/logger/v3 v3.0.2/go.mod h1:T6LtoQFaPgIfevWVOIW05fyaRdws8au6I7+m4fP/KJg=
+github.com/roadrunner-server/memcached/v3 v3.0.4 h1:JKucA0ofe5BtQVWsmKk/gYIM8fQONZjOGNH8NNujM1U=
+github.com/roadrunner-server/memcached/v3 v3.0.4/go.mod h1:Ge2TVXlk/Wp9Iv2aw/F6+wntAXVCjquIpL+f64yldHE=
+github.com/roadrunner-server/memory/v3 v3.1.3 h1:UiY00Wid4cJ/Xr51UiKHHmZM9ANmCzO7Tr8FXjISBps=
+github.com/roadrunner-server/memory/v3 v3.1.3/go.mod h1:2qnchbwdO+VGFWuigJYRAn5HAJ5b7f4/YVGa9AQki94=
+github.com/roadrunner-server/metrics/v3 v3.1.1 h1:DqTJmHOLTwagAGIffKDdQXbt5nIP8dfmXbrvQynpQjY=
+github.com/roadrunner-server/metrics/v3 v3.1.1/go.mod h1:Hw+1x63zflVcnWyBtT+3k/i4vWmbAQnjHisO88VZnJw=
+github.com/roadrunner-server/nats/v3 v3.0.4 h1:whoP6HGyWJ3CllNzN6LSM5CJkTckSiDE39NRjm6nL6g=
+github.com/roadrunner-server/nats/v3 v3.0.4/go.mod h1:Gl+dhCeGq6blMmYOhpREgUMPerO65gqHHfEo6G/9HE8=
+github.com/roadrunner-server/otel/v3 v3.0.4 h1:VWbmy+zuo4rWSBzk/bXN/AFJ7g6ZSBVDDQugcER2ikI=
+github.com/roadrunner-server/otel/v3 v3.0.4/go.mod h1:C6UlmtnP5XlxB0JGOzvOCRBnCPeN2LMgClc9zabQAgU=
+github.com/roadrunner-server/prometheus/v3 v3.0.4 h1:3SmHMZdzy1MqZSkHsHvp4dy9JcVzuso2RFx55SIVw68=
+github.com/roadrunner-server/prometheus/v3 v3.0.4/go.mod h1:LoAFOvOtlsoi87Qy5LwlnQCGKQx2232HRdSL4KAIJag=
+github.com/roadrunner-server/proxy_ip_parser/v3 v3.0.4 h1:T+V48nibT30eA173zcbxHCAeYYGy36k0KI7DAheAbvU=
+github.com/roadrunner-server/proxy_ip_parser/v3 v3.0.4/go.mod h1:bjnERkgphLtQdLy/3mTI3LFh8O8/mHvXHqlc9WvRj98=
+github.com/roadrunner-server/redis/v3 v3.0.4 h1:hqvrWn/w1N/gSDn6VfuARdnoWocXs4YkA9CZsCM7taU=
+github.com/roadrunner-server/redis/v3 v3.0.4/go.mod h1:ec6x4f0g5sMEhvdzsIG2QQQWTXLKJAGpKLxJ7QLvjio=
+github.com/roadrunner-server/reload/v3 v3.0.2 h1:adZiNihk6128Q7eYJNvdGIuGsfckeNPU2XNxLlN24Oo=
+github.com/roadrunner-server/reload/v3 v3.0.2/go.mod h1:H1D6LzVy9OnWF+4x4vYVHe+SZYtyA6R7jJevpWzQWeU=
+github.com/roadrunner-server/resetter/v3 v3.0.2 h1:eNn56Scr1tgKjpJ0D2p5UbreKg3iWc0hzPmtEoTqLlk=
+github.com/roadrunner-server/resetter/v3 v3.0.2/go.mod h1:XTT7T74+Tkar9cM4iAmqCAmyZxIjH3vAKfYOg75nKC4=
+github.com/roadrunner-server/rpc/v3 v3.0.4 h1:xqZHvzB4J4hxCkS7+9IDzYgImcRXRAiLcG+wXNDbVBU=
+github.com/roadrunner-server/rpc/v3 v3.0.4/go.mod h1:qZiTvx6FgrtyqaeGV2mDVjj2RcXgUJoUMWWYOWqymiQ=
+github.com/roadrunner-server/sdk/v3 v3.0.1 h1:yF+j9sVaQN0pvrt1U8MByeD2qBNbnQngIT08lpV7TwI=
+github.com/roadrunner-server/sdk/v3 v3.0.1/go.mod h1:eisnv7rDW5DFLAFes+XXgWCFYE+7Xn40jv+H0ZOJ2tA=
+github.com/roadrunner-server/send/v3 v3.0.4 h1:vISgUY8+rvNNzRq1lETOAsz+mTKdCEcWne0Vmdbvuaw=
+github.com/roadrunner-server/send/v3 v3.0.4/go.mod h1:eNsO6O7bNGVxn8lj5z6FAy/AqZJZexz2ZCSMeVvJvxI=
+github.com/roadrunner-server/server/v3 v3.0.4 h1:/M/FNnzs5HM5JPMRz3+XJYKwGRE637Fgx02HnmCpA5U=
+github.com/roadrunner-server/server/v3 v3.0.4/go.mod h1:zUBBzizT0BL0iIcUUGqiYr99dJ9JfBvv6M1Mv4hNZSg=
+github.com/roadrunner-server/service/v3 v3.0.4 h1:yu+P65IXN+6UjnyHp3uWTpok8nJ8KUeKwK7mXhm4f6g=
+github.com/roadrunner-server/service/v3 v3.0.4/go.mod h1:/8Ec/h4y+7LREn/buji+o7fSsCokwfuzncDPkTYDLro=
+github.com/roadrunner-server/sqs/v3 v3.1.3 h1:93Q3c0CDF6JJVl54p3chTVg4zdyhcnthlnoSRT3z3h8=
+github.com/roadrunner-server/sqs/v3 v3.1.3/go.mod h1:6dlLwX/q1clKGtdIqKrd+GabsxLpOD4coK2pvlO52kY=
+github.com/roadrunner-server/static/v3 v3.0.4 h1:MWU3lCZxkuqxrIsIaV2rTwkgXcSVTiqniUWHv7Td7F4=
+github.com/roadrunner-server/static/v3 v3.0.4/go.mod h1:QCqBmcXmwnx3zgUBtHHaeBa4PwQ2DLG0u8/UijFPNKY=
+github.com/roadrunner-server/status/v3 v3.0.4 h1:kgfMVYHK/KfCuIeKZNDegJYjdbVzPe/cKwJmKOJ0hRE=
+github.com/roadrunner-server/status/v3 v3.0.4/go.mod h1:31W6Ai+xpX/CUIme9C2ZUChsuDFro2UUc8M2SH6xQZ4=
+github.com/roadrunner-server/tcp/v3 v3.0.4 h1:xZwYXfvu4t4rmzs8+MlcQiVZtAa2g4D9G4TI3S1yRK4=
+github.com/roadrunner-server/tcp/v3 v3.0.4/go.mod h1:1uFLBFIOm7mXdfCyuwDlCFp2WaVVvhsRXLxOmbHXdPs=
+github.com/roadrunner-server/tcplisten v1.2.1 h1:9hVVMlCRvMPewnJCnfSe/kKAqn2ZOF3wHy+ji0M/NKU=
+github.com/roadrunner-server/tcplisten v1.2.1/go.mod h1:TRJLGwIruiJ7QhmGVRgJFY5Ch72mPoLhLAxuxLnavpU=
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=
@@ -950,8 +950,8 @@ github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKs
github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
github.com/subosito/gotenv v1.4.1 h1:jyEFiXpy21Wm81FBN71l9VoMMV8H8jG+qIK3GCpY6Qs=
github.com/subosito/gotenv v1.4.1/go.mod h1:ayKnFf/c6rvx/2iiLrJUk1e6plDbT3edrFNGqEflhK0=
-github.com/temporalio/roadrunner-temporal/v2 v2.0.0 h1:PjUJ1GV+s6WhGnI0jaPMaCtVBfjg+p2x9EKxq9tlw2I=
-github.com/temporalio/roadrunner-temporal/v2 v2.0.0/go.mod h1:GQgReSmp4i0x4QInVtb9E5+PaUxkCfQ0dNYOw7IRXEI=
+github.com/temporalio/roadrunner-temporal/v2 v2.0.1 h1:K0T4my7G+awWq6cSfjuY6XUp5/EXjk72CR12JuOddWE=
+github.com/temporalio/roadrunner-temporal/v2 v2.0.1/go.mod h1:V6+cnYIlzo3q+3a2xWaqYBlmcwsEEC/DhNBWRdNIEZ4=
github.com/tklauser/go-sysconf v0.3.11 h1:89WgdJhk5SNwJfu+GKyYveZ4IaJ7xAkecBo+KdJV0CM=
github.com/tklauser/go-sysconf v0.3.11/go.mod h1:GqXfhXY3kiPa0nAXPDIQIWzJbMCB7AmcWpGR8lSZfqI=
github.com/tklauser/numcpus v0.6.0 h1:kebhY2Qt+3U6RNK7UqpYNA+tJ23IBEGKkB7JQBfDYms=
@@ -1075,8 +1075,8 @@ go.uber.org/multierr v1.8.0/go.mod h1:7EAYxJLBy9rStEaz58O2t4Uvip6FSURkq8/ppBp95a
go.uber.org/zap v1.10.0/go.mod h1:vwi/ZaCAaUcBkycHslxD9B2zi4UTXhF60s6SWpuDF0Q=
go.uber.org/zap v1.17.0/go.mod h1:MXVU+bhUf/A7Xi2HNOnopQOrmycQ5Ih87HtOu4q5SSo=
go.uber.org/zap v1.21.0/go.mod h1:wjWOCqI0f2ZZrJF/UufIOkiC8ii6tm1iqIsLo76RfJw=
-go.uber.org/zap v1.23.0 h1:OjGQ5KQDEUawVHxNwQgPpiypGHOxo2mNZsOqTak4fFY=
-go.uber.org/zap v1.23.0/go.mod h1:D+nX8jyLsMHMYrln8A0rJjFt/T/9/bGgIhAqxv5URuY=
+go.uber.org/zap v1.24.0 h1:FiJd5l1UOLj0wCgbSE0rwwXHzEdAZS6hiiSnxJN/D60=
+go.uber.org/zap v1.24.0/go.mod h1:2kMP+WWQ8aoFoedH3T2sq6iJ2yDWpHbP0f6MQbS9Gkg=
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
golang.org/x/crypto v0.0.0-20181029021203-45a5f77698d3/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
golang.org/x/crypto v0.0.0-20181203042331-505ab145d0a9/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
@@ -1602,8 +1602,8 @@ google.golang.org/genproto v0.0.0-20221014213838-99cd37c6964a/go.mod h1:1vXfmgAz
google.golang.org/genproto v0.0.0-20221024153911-1573dae28c9c/go.mod h1:9qHF0xnpdSfF6knlcsnpzUu5y+rpwgbvsyGAZPBMg4s=
google.golang.org/genproto v0.0.0-20221024183307-1bc688fe9f3e/go.mod h1:9qHF0xnpdSfF6knlcsnpzUu5y+rpwgbvsyGAZPBMg4s=
google.golang.org/genproto v0.0.0-20221027153422-115e99e71e1c/go.mod h1:CGI5F/G+E5bKwmfYo09AXuVN4dD894kIKUFmVbP2/Fo=
-google.golang.org/genproto v0.0.0-20221118155620-16455021b5e6 h1:a2S6M0+660BgMNl++4JPlcAO/CjkqYItDEZwkoDQK7c=
-google.golang.org/genproto v0.0.0-20221118155620-16455021b5e6/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg=
+google.golang.org/genproto v0.0.0-20221130183247-a2ec334bae6f h1:G9JGt1JAvAkcv0+x6gGEWkgjEPxsI3fQhNq6L/DJTZ8=
+google.golang.org/genproto v0.0.0-20221130183247-a2ec334bae6f/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg=
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=
diff --git a/schemas/config/2.0.schema.json b/schemas/config/2.0.schema.json
index f40bbc55..8dc5f80f 100644
--- a/schemas/config/2.0.schema.json
+++ b/schemas/config/2.0.schema.json
@@ -1437,17 +1437,17 @@
"default": "amqp.default"
},
"exchange_durable": {
- "description": "Durable exchange",
+ "description": "Durable exchange (rabbitmq option: https://www.rabbitmq.com/tutorials/amqp-concepts.html#exchanges)",
"type": "boolean",
"default": false
},
"exchange_auto_deleted": {
- "description": "Auto delete exchange",
+ "description": "Auto-delete (exchange is deleted when last queue is unbound from it): https://www.rabbitmq.com/tutorials/amqp-concepts.html#exchanges",
"type": "boolean",
"default": false
},
"queue_auto_deleted": {
- "description": "Queue auto delete",
+ "description": "Auto-delete (queue that has had at least one consumer is deleted when last consumer unsubscribes)",
"type": "boolean",
"default": false
},
@@ -1621,7 +1621,7 @@
"default": 10
},
"prefetch": {
- "description": "Number of job to prefetch from the driver",
+ "description": "Number of job to prefetch from the driver until ACK/NACK",
"type": "integer",
"default": 100000
}
@@ -1669,7 +1669,7 @@
"default": 10
},
"prefetch": {
- "description": "Number of job to prefetch from the driver",
+ "description": "Number of job to prefetch from the driver until ACK/NACK",
"type": "integer",
"default": 100000
},