summaryrefslogtreecommitdiff
path: root/plugins/amqp
AgeCommit message (Collapse)Author
2021-09-02Profiling session fixes:Valery Piashchynski
- Drain local pipeline channel - sync.Map instead of map - Add start-elapsed timings Signed-off-by: Valery Piashchynski <[email protected]>
2021-09-01Close connection in the amqp driver.Valery Piashchynski
bytes.Buffer update in the beanstalk driver Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-31Type casting for the amqp headersValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-31Finish boltdb testsValery 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-26Move drivers to the plugin's root.Valery Piashchynski
Fix #771, add tests. Signed-off-by: Valery Piashchynski <[email protected]>