Age | Commit message (Collapse) | Author |
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
logger. Fix bugs discovered during testing.
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]>
|
|
Fix isssues in the AMQP driver.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Add DYNAMIC declaration of the pipelines. Update Jobs constructor
interface, add FromPipeline method to construct jobs driver (unique)
via the `Declare` RPC call.
Add `Stop` method to gracefully stop all consumers.
Binary heaps `GetMax` to canonical `ExtractMin`.
Other small improvements.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
the Stat structure).
Make amqp Push concurrent safe.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
- Update ephemeral plugin, complete Push
- Add Jobs full configuration
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
- Update ephemeral plugin
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
- Add binary heap mock
- Connect first sub-plugin (ephemeral) with root jobs plugin
Signed-off-by: Valery Piashchynski <[email protected]>
|