Age | Commit message (Collapse) | Author |
|
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]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Fix bugs in the AMQP, update proto-api
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
# Conflicts:
# pkg/worker_watcher/interface.go
|
|
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]>
|
|
Fix isssues in the AMQP driver.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
level.
AMQP consumer replace sync.Map with atomic.Value, because we associate
only 1 pipeline with a driver. So, we can store pipeline in the
atomic.Value.
Implement events handler, add job events. Use job events to push
information to the logger.
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]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
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]>
|
|
Skeleton for the amqp plugin.
Add Timeout and Pipeline to the job.Context() method.
Implement queue limits for the ephemeral driver with main priority queue
limits.
Update configuration, add pipeline_size for every pipeline and jobs
priority queue size.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
reached, insert operation will be blocked until all pending messages
have been fully consumed.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Add Len() method to the Binary Heaps interface with implementation.
Start consumers only for the user-defined set from the config.
Add Headers field to the proto
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Implement core of the root jobs plugin with a proper drivers/pipelines
handling mechanism.
Add delayed jobs for the ephemeral plugin.
Remove ResumeAll, Resume, StopAll, Stop. Replaced with Pause/Resume with
a slice of the pipelines.
Other small improvements.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Use bh.len everywhere in the binary heaps algo instead of direct len
check.
Add Ack/Nack to the main jobs loop.
Add PushBatch method to the jobs rpc layer.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Implemented a sync.Cond for binary heap algo to save processor from
spinning in the for loop and receiving nil Items until the Queue will be
filled.
Add num_pollers option to the configuration to specify number of
pollers from the queue.
Add Resume, ResumeAll, Stop, StopAll, PushBatch methods to the ephemeral.
Remove map and use sync.Map in the ephemeral broker.
Add protobuf schema.
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]>
|
|
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]>
|
|
|
|
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 binary heap mock
- Connect first sub-plugin (ephemeral) with root jobs plugin
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
value changed.
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
- Update tests
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]>
|
|
- Rework internal message bus
- Add new tests for the broadcast plugin and include them into the GA
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]>
|