diff --git a/.rr.yaml b/.rr.yaml index daa2ec421..7832789b3 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/go.mod b/go.mod index ee64f83e6..2744c1011 100644 --- a/go.mod +++ b/go.mod @@ -43,7 +43,7 @@ require ( 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.2 + 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 diff --git a/go.sum b/go.sum index 1f0eba28f..1e076ac9d 100644 --- a/go.sum +++ b/go.sum @@ -587,7 +587,6 @@ github.com/gorilla/sessions v1.2.1/go.mod h1:dk2InVEVJ0sfLlnXv9EAgkf6ecYs/i80K/z github.com/grpc-ecosystem/go-grpc-middleware v1.3.0 h1:+9834+KizmvFV7pXQGSXQTsaWhq2GjuNUt0aUU0YBYw= github.com/grpc-ecosystem/go-grpc-middleware v1.3.0/go.mod h1:z0ButlSOZa5vEBq9m2m2hlwIgKw+rp3sdCBRoJY+30Y= github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0/go.mod h1:8NvIoxWQoOIhqOTXgfV/d3M/q6VIi02HzZEHgUlZvzk= -github.com/grpc-ecosystem/grpc-gateway v1.16.0 h1:gmcG1KaJ57LophUzW0Hy8NmPhnMZb4M0+kPpLofRdBo= github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw= github.com/grpc-ecosystem/grpc-gateway/v2 v2.7.0/go.mod h1:hgWBS7lorOAVIJEQMi4ZsPv9hVvWI6+ch50m39Pf2Ks= github.com/grpc-ecosystem/grpc-gateway/v2 v2.14.0 h1:t7uX3JBHdVwAi3G7sSSdbsk8NfgA+LnUS88V/2EKaA0= @@ -814,204 +813,82 @@ 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/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.1 h1:3RBKC0RtH2hU3uYf9Toi3lcVxxkPOeW8S1exIoD5ulw= -github.com/roadrunner-server/app-logger/v3 v3.0.1/go.mod h1:n1ncVSoz/GaFkjH7qPyNLwLj0VKRVYGDP0sZcJEmeJM= 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.2 h1:XoS/UiBGZOUH0lrezN7n5L+uUz2WFi1gU1a4nqP5dxQ= -github.com/roadrunner-server/beanstalk/v3 v3.0.2/go.mod h1:/fO0eVRAHzK6PUdRubSwGx2VDfGQEd+lR7DEovYvIoI= -github.com/roadrunner-server/beanstalk/v3 v3.0.3 h1:Y90ZZos+r8obkaTL2CBiMV/XjMjAnjNVD7qDotU5rd8= -github.com/roadrunner-server/beanstalk/v3 v3.0.3/go.mod h1:zL853WB1ohQAC6nSeZjEFpVCkuBMMej44SdAJ4dTF44= 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.2 h1:MFonzRZhqnUDsrZZiQK1WV0COBF4WfVNkdnjSNqmtxw= -github.com/roadrunner-server/boltdb/v3 v3.0.2/go.mod h1:W56lbWrQ/rMk8Um5a3t7GnL+AsesSVeC77hNKOKVY+g= -github.com/roadrunner-server/boltdb/v3 v3.0.3 h1:5n9JSmKvSO3jz8iZa+kRGGou82BTJuTW1ZYfdUTI93g= -github.com/roadrunner-server/boltdb/v3 v3.0.3/go.mod h1:56940xgGGd/DX3B5pVuLy+SLvCTSNdkdoUJBATTFij8= 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.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/centrifuge/v3 v3.0.3 h1:Pb2q3NjbwAHKKpWzcInlQz6gU0YRc1Kb04v9eYm6Xn8= -github.com/roadrunner-server/centrifuge/v3 v3.0.3/go.mod h1:0gydQwXagzj+SpPVoOWVIOdGZc1QNCMPkgttcbsbJpI= 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.2 h1:B2ONTKfdbUCLYf4xg9GpNjD2TwK9Zw21t4ziEruQy6M= -github.com/roadrunner-server/config/v3 v3.0.2/go.mod h1:KyS+on9l5YcKgdQx2hjvOhKbiL3PI6aPZ0KwCAp5Occ= -github.com/roadrunner-server/config/v3 v3.0.3 h1:iwNIL0vdjsR9H8ETW6ZtM9JNwyNutPHVqS5BsnJuT4o= -github.com/roadrunner-server/config/v3 v3.0.3/go.mod h1:IKr2yB4+33Ga5KSbNoanapSA10cMC+Cu1h+flqBXCbk= 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.5 h1:kInGwZc9Xd55gXsdAQonajz5I202MDyJdV+biJ6+asI= -github.com/roadrunner-server/endure v1.4.5/go.mod h1:FLqkppN/DAXhdMpuoVAlMt1L2odLCvCDRQr83gTHOl4= 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.3 h1:PVdFdS42IsBbbaAK2j+PFTsf62J9AlkYix89I1DYWLs= -github.com/roadrunner-server/fileserver/v3 v3.0.3/go.mod h1:cyOoMUkpU9jkOw24oMpTuuPFPV9P/kvYMPt8LdOY2c8= 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/grpc/v3 v3.0.4 h1:OYD3W9zSEc4LEl5yqJG0meBpeeDTMKpzMYo41FNlKvQ= -github.com/roadrunner-server/grpc/v3 v3.0.4/go.mod h1:5baxYubCffR+M6RhVL8+/CX7yMNBhuZzZ/7P3+OF3DA= 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.2 h1:kqz3eyp/NSZEcnE47bxYYwrmxVVOGdsXByEE3nwSqUI= -github.com/roadrunner-server/gzip/v3 v3.0.2/go.mod h1:PT2Syx5/eMXVSJhPey50aODIR+WOBiS/xL2Ckl6lXSc= -github.com/roadrunner-server/gzip/v3 v3.0.3 h1:FHN1JtD1h+OMDMzJ5eEZUqAGgj69nluARLvIiIWJS50= -github.com/roadrunner-server/gzip/v3 v3.0.3/go.mod h1:Mojl7B7bBUc6727Wnlz17h3xTXMGyXfaN+HNCyuHWNk= 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.2 h1:/i1/NgSEACCQ2rFHAIhc+1B1phz9MOyOpRBQEkyWs5I= -github.com/roadrunner-server/headers/v3 v3.0.2/go.mod h1:RxxTY8jDcBunaBM4WiI+1yqcu35KueJS533PTxG7tn8= -github.com/roadrunner-server/headers/v3 v3.0.3 h1:nNRPR2SRk/jPAhCcwGZ9I4NKdBHP8gHg4FHrUYv+7Qc= -github.com/roadrunner-server/headers/v3 v3.0.3/go.mod h1:uKMmga8HrOHPVPyLP05o1buZD9u83kYphHTwRqsjEfs= 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.3 h1:aFTviUuZT5V9lkYL0m3SzzecrbN/Aa2qBpSsO5WyJis= -github.com/roadrunner-server/http/v3 v3.0.3/go.mod h1:E4jon4/41RLJKAdoPlCAyWQpzeRaUhd+WBQ1taYMYFg= -github.com/roadrunner-server/http/v3 v3.0.4 h1:bgD88Yqw7++jvkm4/I1KlAaI0JiaBfNfgw62TMxkjss= -github.com/roadrunner-server/http/v3 v3.0.4/go.mod h1:QrrKyh0Mvh8Ysf9ihnocQfmce8DnG7DEIMADz0/ic/o= 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.2 h1:PqqvdJAlDdtomavMaM20WWWs1YNkNGk8+vo3TuScCrg= -github.com/roadrunner-server/informer/v3 v3.0.2/go.mod h1:sH09PfnZ2xYOhifiNVi+Vbul3hF2fmdEDDiICEKEu6I= -github.com/roadrunner-server/informer/v3 v3.0.3 h1:3ffdZCq/q4UXyujq3y8U+nAAjfvcoHp9Vv9EK8PSHLw= -github.com/roadrunner-server/informer/v3 v3.0.3/go.mod h1:bwgVpiOuQ86DZwOVXK5Ii8C78V5zykmuSfdojbNAoho= 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.2 h1:cwFd+0ostvqladEbYLvHp1nuTYJdkwLDO6VcSa3X7GM= -github.com/roadrunner-server/jobs/v3 v3.0.2/go.mod h1:pBf/wPhCbhZ9W4KSsmURvw4vz6ZMslOOyy9tazSSNXM= 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.2 h1:kxsnInTbDY8xyX/dreWnJuDWTUITscJFK0PtoH1H5iQ= -github.com/roadrunner-server/kafka/v3 v3.0.2/go.mod h1:tKyGvnLPCD/QOQ35LQ6hMNx6dKRl5t3xhnnUg8Cp5hc= -github.com/roadrunner-server/kafka/v3 v3.0.3 h1:fwCUBkYe8sbR+BxwqAmXZvoVYqZOSJKdN/ndggD1zUQ= -github.com/roadrunner-server/kafka/v3 v3.0.3/go.mod h1:uyzB7KNgNYcb+/BKpW/hJqIAosif4N6EcQXpzivueKI= 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.2 h1:IfFG/OfaS2tUj6woz7YK6kE9dHxvmMTPz98+xR7GRgU= -github.com/roadrunner-server/kv/v3 v3.0.2/go.mod h1:bo9WGfH70+xsbq5duGArtrPDdFIuviC5FR8Mf3wv06U= 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.1 h1:gcz4PCmrFGjHjzpLLFy2T+KmlH5Oen2/iUHY08OIA5w= -github.com/roadrunner-server/logger/v3 v3.0.1/go.mod h1:Uc6P2arkF1au8nfnlMl1Bif+zac5HR1rfaAioJeot5I= 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.2 h1:FiMhaOqTBZyG84u9ZU26O7I5i2awdwTQn+be8qcE56k= -github.com/roadrunner-server/memcached/v3 v3.0.2/go.mod h1:lPjv5rEIzKLCw3QEcIn18/qAdB8eXcxrYjC6FpNa3Ik= -github.com/roadrunner-server/memcached/v3 v3.0.3 h1:wcjN5BQSBCDFl5fiJJ+jjR1knv+aQpInc8rb9vhipyY= -github.com/roadrunner-server/memcached/v3 v3.0.3/go.mod h1:xqPaEc9I0MUYJrcEaHUTfCzJPsFP2FLjh6QM93gYY6Y= 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.0 h1:aZvXBSdKuucY9FSlJErUSSHcwEnzjFZPKqIqmHrjCyw= -github.com/roadrunner-server/memory/v3 v3.1.0/go.mod h1:dVh6Flg3C5DQ5YcgKyPZv3cBX8q0Y9MAMlJEkU5Tbmg= -github.com/roadrunner-server/memory/v3 v3.1.2 h1:IGm8ws8BwWDIXNG9+NNNYZ/eyvU+owtmuiZvb2OO0Ao= -github.com/roadrunner-server/memory/v3 v3.1.2/go.mod h1:u9Dkdy+EwmGyS82mDedGWCYss25gHs5NoTR58WhIHro= 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.0 h1:YQ8874w6aWQaw7LrX4r5Nn8zyFQvyQbB9Ll1YnNnzY0= -github.com/roadrunner-server/metrics/v3 v3.1.0/go.mod h1:4Mh7S2g9KZ0WMFri0eYBNx6XzGW324SGYkWsK+qdwi8= 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.2 h1:yf5RcYdj5FENH5OS4/gitztw8nbpJ1WgXJRgh/zRe0M= -github.com/roadrunner-server/nats/v3 v3.0.2/go.mod h1:nB5qlzsn8rB3imwljttEPOEterGDApqiYPDIeax9oQc= 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.2 h1:/joMx5cQl03cduv+E2aHR0meAtQwJ/BT/yBCLd0qPF0= -github.com/roadrunner-server/otel/v3 v3.0.2/go.mod h1:qCRpT4YqQ30QWLTaKyIAS3eRc0Ke4yYs6xtKzAkdv+4= -github.com/roadrunner-server/otel/v3 v3.0.3 h1:q5BSheaITbFqUiehDumnWVp0RgGggo38jYNG64w7pEg= -github.com/roadrunner-server/otel/v3 v3.0.3/go.mod h1:zVZyxQwo8kS35XihsdS/Gf66XmKiV0hMtMunD6jyKi4= 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.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/prometheus/v3 v3.0.3 h1:yfVp03NchQag/bF6mxZgJvtleygiMFGXD0hqQj2m76Y= -github.com/roadrunner-server/prometheus/v3 v3.0.3/go.mod h1:qhv3zMu8rT63fpCZFlQ56pVpNylJyK9DPKmagGZKmpI= 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.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/proxy_ip_parser/v3 v3.0.3 h1:e1dXcLmFATwKH+YKdLgw5CkluCDSP27N6d9Q5D1efiI= -github.com/roadrunner-server/proxy_ip_parser/v3 v3.0.3/go.mod h1:eDV6qQzBAWuJ+DwBuxxGQ6+aGVKLnYVSa/n+JrzEwoQ= 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.2 h1:BXYAP61VDdBeeqqZ3+Syvk1BQBFjcIseerbmQw8Hc+M= -github.com/roadrunner-server/redis/v3 v3.0.2/go.mod h1:HDX5DMjx8ibdHPjjwRrXtyE0j4qiVLDzpGXMXbNgz1Q= 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.1 h1:JRb6y652TNc7mKKlv3vYMR9COFJKXcPKZVIeUQzki+I= -github.com/roadrunner-server/reload/v3 v3.0.1/go.mod h1:4l3xjs8dZCesNh/OyKoOymYOnbNHdWdBHVw5U09BpiY= 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.1 h1:tt/zUSNspfeeM7/JbCAjmgQ198WNJa0NubVbpnT3URI= -github.com/roadrunner-server/resetter/v3 v3.0.1/go.mod h1:+6pgq8TUvcQDsC1R4axEgjDhJTFzKzF2A95LvgRMDAI= 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.2 h1:OsJFSNQDE1/DIw7OqKNXipDeSDiM47aUHLC3FcZ6Vko= -github.com/roadrunner-server/rpc/v3 v3.0.2/go.mod h1:dOYfm+i+h0ZzIDBgob1PcabBqmq4EzFXd1h+ksS4XyY= -github.com/roadrunner-server/rpc/v3 v3.0.3 h1:ClLfFu/EazYqf/LltIL7tsGZdFuVf2bpIEHRYLqdeJ0= -github.com/roadrunner-server/rpc/v3 v3.0.3/go.mod h1:98pgeqM1IVB883l06pR0K/ONkKFCs7o/0LSbxt54/RA= 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.0 h1:DhSLwTCAP5yzUwgBcUo6M1jK8e1XufxYvpFCuGACruw= -github.com/roadrunner-server/sdk/v3 v3.0.0/go.mod h1:R8CbJAIsHjye7asTIl0zLDRl89aIRETLFFfHbmczw04= 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.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/send/v3 v3.0.3 h1:YO3rX6WzpxtkSQVaozJAfIArHBvcYPhnMuHRm4W1gTQ= -github.com/roadrunner-server/send/v3 v3.0.3/go.mod h1:zDlOXyrxIZ0nQmkQ4/BiQEbQSrh4mdylJLUliOeWn1E= 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.2 h1:wdFoVIcUNALBZOa92ZUz0PPAqBhQA0FnVNQVOCpTuPM= -github.com/roadrunner-server/server/v3 v3.0.2/go.mod h1:hEDq7JtXzy4jJmepJWvzlDj5WHoo1jdwEPGH56Fil7g= -github.com/roadrunner-server/server/v3 v3.0.3 h1:eIwZRDRWjjuHQKd2okLhP0j6NkAnCPqspKqT6sHP9yU= -github.com/roadrunner-server/server/v3 v3.0.3/go.mod h1:8xHi6/JEH8XRANNIPd4t6jYi6LN2iV77fYRaEZpVdmI= 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.2 h1:/in32R/6mssk+E2KHCMpIPfjBGKi9vnHEemGpIxSTgM= -github.com/roadrunner-server/service/v3 v3.0.2/go.mod h1:Ab5W+H3LjH+69S0Y78YirJcaxBj9WVDFvb16dhM2MXY= -github.com/roadrunner-server/service/v3 v3.0.3 h1:q53zSmKx57uVYtIm7V3fUQjCKRZ5v9Wq9zyMtoYQbzM= -github.com/roadrunner-server/service/v3 v3.0.3/go.mod h1:6XsRqIzZXxe8WJy2U4VhGat/NsTdg1mtA6RXjlHc1MI= 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.0 h1:rmJA3MmqAKEuwKKbIV/OcnIeYkWDLH5j8WU+EWaQe3k= -github.com/roadrunner-server/sqs/v3 v3.1.0/go.mod h1:EDNdTuEiXfGF1m5gnC+RuNofeqMJ8cyYxUMjY6U+Muc= -github.com/roadrunner-server/sqs/v3 v3.1.1 h1:9TyOQ8zPgrsxCPZ1MMloSwcW27AcgyLHQ4e5N8IdOvI= -github.com/roadrunner-server/sqs/v3 v3.1.1/go.mod h1:/pghrU/W+s0FS3433aIl30jmx1OlJcXMYTv710bn2Jg= -github.com/roadrunner-server/sqs/v3 v3.1.2 h1:9gKPvFm3ZG7z1pe6zAX4i/GR47t83C0YlXK7AN4g8bY= -github.com/roadrunner-server/sqs/v3 v3.1.2/go.mod h1:6dlLwX/q1clKGtdIqKrd+GabsxLpOD4coK2pvlO52kY= -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/static/v3 v3.0.3 h1:0uxHEnidzumVoVVI9HqbWps3SyyZQqMWEdDX25n2lZk= -github.com/roadrunner-server/static/v3 v3.0.3/go.mod h1:K3s6vnK+QgnsBQuEiYWtfcUS/+nOCb49DPHqpGsOdcY= +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.2 h1:cYIUlvnCkS22l2osT90G2zB0J2Lu6iC3cECVBjgP2BA= -github.com/roadrunner-server/status/v3 v3.0.2/go.mod h1:3UubQgEnfiXtqHoR9KuXiy04IGj+S1oT+SOCcQTHyJI= -github.com/roadrunner-server/status/v3 v3.0.3 h1:XocG/PjVBFjfDQAqFY0UZQHKmghP3g4D3Ef8YzWMXMI= -github.com/roadrunner-server/status/v3 v3.0.3/go.mod h1:lHOI2v0RfWFLxn1AGgNwkE8/RXEJ/CtWSY4MB7ss6tQ= 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.2 h1:svwqxhutJI4PPAdkJyi+YLQhvGgsxYaUeabaFfg603k= -github.com/roadrunner-server/tcp/v3 v3.0.2/go.mod h1:Y0b7nCih4TVQ+A8hh5qMav6DPOf11jWrso2+zhjFbxU= -github.com/roadrunner-server/tcp/v3 v3.0.3 h1:RPbwPewbQmpVGP1t/XZvlQypg4QLOVJqmEXT4oS9Aes= -github.com/roadrunner-server/tcp/v3 v3.0.3/go.mod h1:V7SfyLPjNvg7QfHFaX6Xp14mWqI4iMYJyzhImeV+6dM= 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.0 h1:nsiXEEb0zP7vjAsCWNHKpM0HdwFK/KlafFF/2gsTJlg= -github.com/roadrunner-server/tcplisten v1.2.0/go.mod h1:NhumKvt7dbIKVNZnqR1fA4ET1D8ngIKsg0TxnuJTL6A= 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= @@ -1073,8 +950,6 @@ 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= @@ -1200,8 +1075,6 @@ 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= @@ -1729,8 +1602,6 @@ 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= diff --git a/schemas/config/2.0.schema.json b/schemas/config/2.0.schema.json index f40bbc556..8dc5f80fc 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 },