Age | Commit message (Collapse) | Author |
|
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]>
|
|
Move all dockerfiles, docker-compose files into the env folder inside
the tests folder.
Add elasticmq dockerfile to build SQS compatible test env.
Add beanstalk, rabbitmq, sqs to the main tests docker-compose file.
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]>
|
|
request
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
|
|
#741 feat(release): `v2.3.1` release
|
|
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]>
|
|
|
|
#738 fix(allocator): workers were not reallocating when `exec_ttl` was hit
|
|
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]>
|
|
|
|
#736 feat(kv): `clear` RPC method which completely cleans storage
|
|
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]>
|
|
- 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]>
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
|
|
- Initial ephemeral broker commit
- Initial RPC
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
- Update tests
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
- Remove old PHP 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]>
|
|
# Conflicts:
# plugins/websockets/plugin.go
|
|
Signed-off-by: Valery Piashchynski <[email protected]>
|
|
#732 feat(plugin): rework `broadcast` plugin
|