diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-11 10:11:22 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-11 10:11:22 +0300 |
| commit | 589f759cc2411319adbca2ece0dbe212407d1eba (patch) | |
| tree | 2fbea4a6033d65813c41fd80f6339a524b46c9b2 /tests/plugins/jobs | |
| parent | cb2665d93ad7abe1ab30508ff0e2bd4d0bc379ea (diff) | |
Update informer interface to return slice of pointers (do not over-copy
the Stat structure).
Make amqp Push concurrent safe.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests/plugins/jobs')
| -rw-r--r-- | tests/plugins/jobs/configs/.rr-jobs-init.yaml | 7 | ||||
| -rw-r--r-- | tests/plugins/jobs/jobs_plugin_test.go | 2 |
2 files changed, 6 insertions, 3 deletions
diff --git a/tests/plugins/jobs/configs/.rr-jobs-init.yaml b/tests/plugins/jobs/configs/.rr-jobs-init.yaml index 6ff2ab70..93c978c2 100644 --- a/tests/plugins/jobs/configs/.rr-jobs-init.yaml +++ b/tests/plugins/jobs/configs/.rr-jobs-init.yaml @@ -23,6 +23,9 @@ sqs: declare: MessageRetentionPeriod: 86400 +logs: + level: debug + mode: development jobs: # num logical cores by default @@ -65,7 +68,7 @@ jobs: test-2-amqp: driver: amqp priority: 2 - pipeline_size: 1000 + pipeline_size: 100000 queue: test-2-queue exchange: default exchange_type: direct @@ -85,5 +88,5 @@ jobs: queue: default # list of pipelines to be consumed by the server, keep empty if you want to start consuming manually - consume: [ "test-local", "test-local-2", "test-local-3", "test-1" ] + consume: [ "test-local", "test-local-2", "test-local-3", "test-1", "test-2-amqp" ] diff --git a/tests/plugins/jobs/jobs_plugin_test.go b/tests/plugins/jobs/jobs_plugin_test.go index b2f05f0f..76b7b879 100644 --- a/tests/plugins/jobs/jobs_plugin_test.go +++ b/tests/plugins/jobs/jobs_plugin_test.go @@ -84,7 +84,7 @@ func TestJobsInit(t *testing.T) { } }() - time.Sleep(time.Second * 120) + time.Sleep(time.Second * 1200) stopCh <- struct{}{} |