Age | Commit message (Collapse) | Author |
|
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]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Fix sqs queue re-creation.
Complete redia for the beanstalk.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Fix isssues in the AMQP driver.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Add redialer, consumer, rabbit queues initializer.
Update configuration (.rr.yaml).
Add ack/nack for the jobs main plugin with error handling.
Add Qos, queues bining and declaration.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Create a config sample with RR2 support. Progress on root JOBS plugin.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
- Add path scan with regex (find .php/.ph/.sh scripts). When found, try
to stat path for potential fix for the [file not exists problem]
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
- Use EXISTS to check of the particular topic exists in the redis
cluster instead of SMEMBERS
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
error
- Handle SoftJob error
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
# Conflicts:
# go.sum
|
|
Bumps [github.com/go-redis/redis/v8](https://github.com/go-redis/redis) from 8.8.3 to 8.9.0.
- [Release notes](https://github.com/go-redis/redis/releases)
- [Changelog](https://github.com/go-redis/redis/blob/master/CHANGELOG.md)
- [Commits](https://github.com/go-redis/redis/compare/v8.8.3...v8.9.0)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
Bumps [github.com/alicebob/miniredis/v2](https://github.com/alicebob/miniredis) from 2.14.4 to 2.14.5.
- [Release notes](https://github.com/alicebob/miniredis/releases)
- [Changelog](https://github.com/alicebob/miniredis/blob/master/CHANGELOG.md)
- [Commits](https://github.com/alicebob/miniredis/compare/v2.14.4...v2.14.5)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
# Conflicts:
# go.mod
# go.sum
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Bumps [go.uber.org/zap](https://github.com/uber-go/zap) from 1.16.0 to 1.17.0.
- [Release notes](https://github.com/uber-go/zap/releases)
- [Changelog](https://github.com/uber-go/zap/blob/master/CHANGELOG.md)
- [Commits](https://github.com/uber-go/zap/compare/v1.16.0...v1.17.0)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
Bumps [github.com/fatih/color](https://github.com/fatih/color) from 1.11.0 to 1.12.0.
- [Release notes](https://github.com/fatih/color/releases)
- [Commits](https://github.com/fatih/color/compare/v1.11.0...v1.12.0)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
- Implement base interfaces
- Implement BST search algo for the in-memory storage
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Bumps [github.com/gofiber/fiber/v2](https://github.com/gofiber/fiber) from 2.9.0 to 2.10.0.
- [Release notes](https://github.com/gofiber/fiber/releases)
- [Commits](https://github.com/gofiber/fiber/compare/v2.9.0...v2.10.0)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
Bumps [github.com/alicebob/miniredis/v2](https://github.com/alicebob/miniredis) from 2.14.3 to 2.14.4.
- [Release notes](https://github.com/alicebob/miniredis/releases)
- [Changelog](https://github.com/alicebob/miniredis/blob/master/CHANGELOG.md)
- [Commits](https://github.com/alicebob/miniredis/compare/v2.14.3...v2.14.4)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
- Update arch diagram
- Update interfaces
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Bumps [github.com/go-redis/redis/v8](https://github.com/go-redis/redis) from 8.8.2 to 8.8.3.
- [Release notes](https://github.com/go-redis/redis/releases)
- [Changelog](https://github.com/go-redis/redis/blob/master/CHANGELOG.md)
- [Commits](https://github.com/go-redis/redis/compare/v8.8.2...v8.8.3)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
Bumps [github.com/fatih/color](https://github.com/fatih/color) from 1.10.0 to 1.11.0.
- [Release notes](https://github.com/fatih/color/releases)
- [Commits](https://github.com/fatih/color/compare/v1.10.0...v1.11.0)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
Bumps [github.com/google/flatbuffers](https://github.com/google/flatbuffers) from 1.12.0 to 1.12.1.
- [Release notes](https://github.com/google/flatbuffers/releases)
- [Commits](https://github.com/google/flatbuffers/compare/v1.12.0...v1.12.1)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
Bumps [go.uber.org/multierr](https://github.com/uber-go/multierr) from 1.6.0 to 1.7.0.
- [Release notes](https://github.com/uber-go/multierr/releases)
- [Changelog](https://github.com/uber-go/multierr/blob/master/CHANGELOG.md)
- [Commits](https://github.com/uber-go/multierr/compare/v1.6.0...v1.7.0)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Bumps [github.com/gofiber/fiber/v2](https://github.com/gofiber/fiber) from 2.8.0 to 2.9.0.
- [Release notes](https://github.com/gofiber/fiber/releases)
- [Commits](https://github.com/gofiber/fiber/compare/v2.8.0...v2.9.0)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
Bumps [github.com/json-iterator/go](https://github.com/json-iterator/go) from 1.1.10 to 1.1.11.
- [Release notes](https://github.com/json-iterator/go/releases)
- [Commits](https://github.com/json-iterator/go/compare/v1.1.10...v1.1.11)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
|
|
Bumps [github.com/gofiber/fiber/v2](https://github.com/gofiber/fiber) from 2.7.1 to 2.8.0.
- [Release notes](https://github.com/gofiber/fiber/releases)
- [Commits](https://github.com/gofiber/fiber/compare/v2.7.1...v2.8.0)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
Bumps [github.com/go-redis/redis/v8](https://github.com/go-redis/redis) from 8.8.0 to 8.8.2.
- [Release notes](https://github.com/go-redis/redis/releases)
- [Changelog](https://github.com/go-redis/redis/blob/master/CHANGELOG.md)
- [Commits](https://github.com/go-redis/redis/compare/v8.8.0...v8.8.2)
Signed-off-by: dependabot[bot] <[email protected]>
|
|
|
|
feature/readiness_probe_healthcheck_endpoint
# Conflicts:
# go.sum
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
|