diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-06 17:30:31 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-06 17:30:31 +0300 |
| commit | 2c78e93222cc9d3b88456175348e42f7f40c449b (patch) | |
| tree | be4fc671db33ceb8700019a5ede900c8d900d7c0 /Makefile | |
| parent | 207739f7346c98e16087547bc510e1f909671260 (diff) | |
Rework ephemeral and binary heaps
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]>
Diffstat (limited to 'Makefile')
| -rwxr-xr-x | Makefile | 5 |
1 files changed, 3 insertions, 2 deletions
@@ -14,7 +14,7 @@ test_coverage: go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage/worker.out -covermode=atomic ./pkg/worker go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage/worker_stack.out -covermode=atomic ./pkg/worker_watcher go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage/bst.out -covermode=atomic ./pkg/bst - go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage/pq.out -covermode=atomic ./pkg/priority_queue + go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage/pq.out -covermode=atomic ./pkg/priorityqueue go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage/struct_jobs.out -covermode=atomic ./plugins/jobs/structs go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage/pipeline_jobs.out -covermode=atomic ./plugins/jobs/pipeline go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage/http_config.out -covermode=atomic ./plugins/http/config @@ -48,7 +48,7 @@ test: ## Run application tests go test -v -race -tags=debug ./pkg/worker go test -v -race -tags=debug ./pkg/worker_watcher go test -v -race -tags=debug ./pkg/bst - go test -v -race -tags=debug ./pkg/priority_queue + go test -v -race -tags=debug ./pkg/priorityqueue go test -v -race -tags=debug ./plugins/jobs/structs go test -v -race -tags=debug ./plugins/jobs/pipeline go test -v -race -tags=debug ./plugins/http/config @@ -81,6 +81,7 @@ testGo1.17beta1: ## Run application tests go1.17beta1 test -v -race -tags=debug ./pkg/worker go1.17beta1 test -v -race -tags=debug ./pkg/worker_watcher go1.17beta1 test -v -race -tags=debug ./pkg/bst + go1.17beta1 test -v -race -tags=debug ./pkg/priorityqueue go1.17beta1 test -v -race -tags=debug ./tests/plugins/http go1.17beta1 test -v -race -tags=debug ./plugins/http/config go1.17beta1 test -v -race -tags=debug ./plugins/server |