summaryrefslogtreecommitdiff
path: root/plugins/jobs/drivers/amqp/consumer.go
AgeCommit message (Expand)Author
2021-08-25BoltDB local queue initial commitValery Piashchynski
2021-08-18Add prometheus metrics for the jobs, update testsValery Piashchynski
2021-08-17Update to go 1.17Valery Piashchynski
2021-08-14Update broadcast tests, add redis flusing. Initial impl of the jobValery Piashchynski
2021-08-11Durable requeue algo. Update AMQP and Beanstalk tests to use mockValery Piashchynski
2021-08-11Replace all 'localhost' with '127.0.0.1'. Fix default configuration andValery Piashchynski
2021-08-10Add jobs protocol support for the AMQP driverValery Piashchynski
2021-08-01Rework vec based on the channel. Use select statement with the defaultValery Piashchynski
2021-07-27Initial support for the cancellation via contextValery Piashchynski
2021-07-23SQS initial durability testValery Piashchynski
2021-07-23EventPipeRun -> EvenPipeActiveValery Piashchynski
2021-07-22Fix AMQP bugs, add more amqp testsValery Piashchynski
2021-07-22Update consumers, tests stabilizationValery Piashchynski
2021-07-18Started beanstalk driver. Add new Queue impl (not finished yet).Valery Piashchynski
2021-07-14Fix incorrect path in the CI. Implement FromPipeline for the sqs.Valery Piashchynski
2021-07-14SQS driver.Valery Piashchynski