summaryrefslogtreecommitdiff
path: root/plugins
AgeCommit message (Collapse)Author
2021-08-31Type casting for the amqp headersValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-31Naming: service -> pluginValery Piashchynski
Fix bug with survived workers in the debug mode Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-31Tune listener timersValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-31Update arch diagrammValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-31Finish boltdb testsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-30Add error to the EventJobError eventValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-30Tests for the boltdb jobs.Valery Piashchynski
Fix issue with Stop in the jobs plugin which didn't destroy the pool. Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-29Implement Init, FromPipeline methodsValery Piashchynski
Update receiver in the amqp driver Add simple (initial) boltdb tests Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-28Reduce error check operationsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-26Move drivers to the plugin's root.Valery Piashchynski
Fix #771, add tests. Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-25BoltDB local queue initial commitValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-23Add worker's description for the PrometheusValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-21Update dependencies (go.mod)Valery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-20Fix sqs maps parsingValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-20Correct AMQP Declare RPC constantsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-20Move jobs protocol document to the doc folderValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-19Add support for the IPv6Valery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-18Add prometheus metrics for the jobs, update testsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-18Update jobs stats testsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-18Update broadcast tests, improve stop mechanism.Valery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-17Update Resetter plugin, remove old and unused codeValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-17Update to go 1.17Valery Piashchynski
Add Stat with tests Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-14Update broadcast tests, add redis flusing. Initial impl of the jobValery Piashchynski
drivers state. Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-13Update deprecated prometheus collectors.Valery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-13Update go.mod dependencies to the most recent version.Valery Piashchynski
Fix tests according to the new mocks. Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-12Update AMQP driver defaultsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-12Remove unneeded options, complete tests for the ephemeral, update protoValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-12Fix various bugs in the SQS. Implement SQS tests for theValery Piashchynski
jobs_ok.php/jobs_err.php workers. Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-12Made QoS production likeValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-11Durable requeue algo. Update AMQP and Beanstalk tests to use mockValery Piashchynski
logger. Fix bugs discovered during testing. Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-11Remove attempts from the proto, and general jobs optionsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-11Add headers support to the jobs protocolValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-11Add headers to the protocolValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-11Increase timeout to 60s.Valery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-11Replace all 'localhost' with '127.0.0.1'. Fix default configuration andValery Piashchynski
other small bugs. Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-10Add support for the jobs-worker protocol for the beanstalk,ephemeral andValery Piashchynski
sqs drivers Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-10Add jobs protocol support for the AMQP driverValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-09Add initial support for the php worker protocol.Valery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-09Update response_protocol.mdValery Piashchynski
2021-08-09Update goridge to v3.2.0, update all frames operations.Valery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-02Update CI, move all tests to the single source of truth - makefileValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-01Rework vec based on the channel. Use select statement with the defaultValery Piashchynski
branch to handle dead workers inside the channel. Update docker-compose.yaml used for the tests. Update rabbitmq to 3.9.1. Replace third-party amqp091 with the official implementation. Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-27Initial support for the cancellation via contextValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-23SQS initial durability testValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-23Add AMQP initial durability testValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-23Use zap logger in AMQP tests instead of mocked (temporarly)Valery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-23SQS configuration and tests updateValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-23EventPipeRun -> EvenPipeActiveValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-23Remove time.Now() from beanstalk tube declarationValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-23Update beanstalk options. Fix tube priority (correctly pass to the PutValery Piashchynski
method). Signed-off-by: Valery Piashchynski <[email protected]>