summaryrefslogtreecommitdiff
path: root/pkg/worker_watcher
AgeCommit message (Collapse)Author
2021-09-16Move plugins to a separate repositoryValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-08-28Re-allocate a worker with allocate frequency (every 500ms per try)Valery Piashchynski
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-17Update to go 1.17Valery Piashchynski
Add Stat with tests 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-19Worker watcher interface update.Valery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-18Remove channel from the QueueValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-18Started beanstalk driver. Add new Queue impl (not finished yet).Valery Piashchynski
Fix bugs in the AMQP, update proto-api Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-14Merge masterValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-14Merge remote-tracking branch 'origin/master' into feature/jobs_pluginValery Piashchynski
# Conflicts: # pkg/worker_watcher/interface.go
2021-07-14Fix TTL issue, added explanation comments.Valery Piashchynski
The worker after it executed the request, may overwrite the TTL state. This inconsistency leads to the +1 worker in the FIFO channel. In this state, the Push operation was blocked. Add RR_BROADCAST_PATH. Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-10Move interfaces to its consumersValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-26- Add more testsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-26- Better channel handlingValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-25- Fix bug with an exec_ttl reallocation issueValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-13- Optimize sync_worker payload execValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-03- Do not write an error into the responseWriter if this is internalValery Piashchynski
error - Handle SoftJob error Signed-off-by: Valery Piashchynski <[email protected]>
2021-05-20- Update lintersValery Piashchynski
- Implement base interfaces - Implement BST search algo for the in-memory storage Signed-off-by: Valery Piashchynski <[email protected]>
2021-04-28- Update CHANGELOGValery Piashchynski
- Add tests for the etags functionality Signed-off-by: Valery Piashchynski <[email protected]>
2021-03-28- Fix bug with the worker reallocating during the responseValery Piashchynski
- Update .golangci and fix new warnings Signed-off-by: Valery Piashchynski <[email protected]>
2021-02-16Add support for parsing env variables in the `.rr.yaml` configValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-02-11Doc commentsValery Piashchynski
2021-02-10Fix linters warningsValery Piashchynski
2021-02-10Rewrite container for the workersValery Piashchynski
Update tests
2021-02-08BaseProcess interface as a return type in the worker_watcher,pool andValery Piashchynski
worker interface
2021-02-08Push worker to the stack typoValery Piashchynski
2021-02-08Rewrite stack.Get operation w/o recursion callsValery Piashchynski
Add fast and slow paths
2021-02-05fmt-edValery Piashchynski
2021-02-05handle worker state before sending to the execValery Piashchynski
2021-02-04pre-rc stabilization of the interfaces and internal codeValery Piashchynski
2021-02-02Move worker states out of internalValery Piashchynski
2021-01-25Add new Supervisor test in the http pluginValery Piashchynski
Uniform supervisor config keys to use same notation as pool (10s, 10h not just 10)
2021-01-24Update Pool and WorkerWatcher interfacesValery Piashchynski
2021-01-23interfaces folder deprecatedValery Piashchynski
2021-01-19Uniform all errors operationsValery Piashchynski
Add new ExecTTL event Update tests Signed-off-by: Valery Piashchynski <[email protected]>
2021-01-18Update CIValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-01-15Use uniform snake case in the configs, fix critical issue with wrongValery Piashchynski
calculation of workers in stack at the Destroy stage
2021-01-15gofmt stack_test.goValery Piashchynski
2021-01-15Update worker_watcher stack testsValery Piashchynski
2021-01-15Move stack data structure to the separate fileValery Piashchynski
2021-01-13Add IdleTTL testValery Piashchynski
Add removed state to the worker before it being removed
2021-01-05Finish implementation of the KVValery Piashchynski
2020-12-24Remove unnecessary mutex when adding worker to watcherv2.0.0-alpha30Valery Piashchynski
2020-12-23Initial implementation of serve, reset, workers commands for the RR2Valery Piashchynski
2020-12-22events listeners refactor, CLI initial commitValery Piashchynski
2020-12-17Redis initial commitValery Piashchynski
2020-12-17Update events handler, add mutex to pushValery Piashchynski
2020-12-17Attempt to fix race #1Valery Piashchynski