summaryrefslogtreecommitdiff
AgeCommit message (Collapse)Author
2021-07-07New Methods in the binary heap interface...Valery Piashchynski
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]>
2021-07-07Updated ephemeral plugin, PQ and protobuf...Valery Piashchynski
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]>
2021-07-07Rework test env...Valery Piashchynski
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]>
2021-07-06Update Jobs interface...Valery Piashchynski
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]>
2021-07-06Rework ephemeral and binary heapsValery Piashchynski
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]>
2021-07-05- Update PQValery Piashchynski
- Update ephemeral plugin, complete Push - Add Jobs full configuration Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-05- Update PQ testsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-05- Include PQ tests into the CIValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-05- Finish binary_heapValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-03- Initial binary_heapValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-02- joinTopics/Server as constants, do not allocate strings on everyValery Piashchynski
request Signed-off-by: Valery Piashchynski <[email protected]>
2021-07-01- Remove DispatcherValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-30Merge remote-tracking branch 'origin/master' into feature/jobs_pluginValery Piashchynski
2021-06-30#741 feat(release): `v2.3.1` releasev2.3.1Valery Piashchynski
#741 feat(release): `v2.3.1` release
2021-06-30- Update CHANGELOGValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-30- Remove unused methods from the QueueImplValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-30- Update arch diagramsValery Piashchynski
- Update ephemeral plugin Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-28Merge remote-tracking branch 'origin/master' into feature/jobs_pluginValery Piashchynski
2021-06-28Fix typos in the CHANGELOGValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-26- Merge master branchValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-26Merge remote-tracking branch 'origin/master' into feature/jobs_pluginValery Piashchynski
2021-06-26#738 fix(allocator): workers were not reallocating when `exec_ttl` was hitv2.3.1-rc.1Valery Piashchynski
#738 fix(allocator): workers were not reallocating when `exec_ttl` was hit
2021-06-26- Update CHANGELOGValery 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-25- Update jobs interfaceValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-25Merge remote-tracking branch 'origin/master' into feature/jobs_pluginValery Piashchynski
2021-06-24#736 feat(kv): `clear` RPC method which completely cleans storagev2.3.1-beta.6Valery Piashchynski
#736 feat(kv): `clear` RPC method which completely cleans storage
2021-06-24- Linters fixValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-24- Fix deadlocks in the websockets testsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-24- Update GA testsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-24- Clear BOLTDB TTL memory region on Clear RPC callValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-24- Update CHANGELOGValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-24- Add Clear method to the storagesValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-24- Update logger for the broadcast testsValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-23- Fix broadcast tests panicValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-23- Add PQ (priority_queue) mockValery Piashchynski
- Add binary heap mock - Connect first sub-plugin (ephemeral) with root jobs plugin Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-23- Swithc from value to pointer to the pool configuration. InterfaceValery Piashchynski
value changed. Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-23- Update arch, pluignValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-22Merge branch 'master' into feature/jobs_pluginValery Piashchynski
2021-06-22- Folders structValery Piashchynski
- Initial ephemeral broker commit - Initial RPC Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-22- Move common interfaces and structures to the 'common' folderValery Piashchynski
- Update tests Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-22Update bug_report.mdValery Piashchynski
2021-06-22- Remove all old code, reformat, fix linters, return GAValery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-22- Temporary turn off CIValery Piashchynski
- Remove old PHP tests Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-21- Rework dispatcher, pipeline, job (not completely)Valery Piashchynski
Create a config sample with RR2 support. Progress on root JOBS plugin. Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-21Merge remote-tracking branch 'origin/master' into feature/jobs_pluginValery Piashchynski
# Conflicts: # plugins/websockets/plugin.go
2021-06-21Correct Websockets test namev2.3.1-beta.4Valery Piashchynski
Signed-off-by: Valery Piashchynski <[email protected]>
2021-06-21#732 feat(plugin): rework `broadcast` pluginValery Piashchynski
#732 feat(plugin): rework `broadcast` plugin