diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-05 18:44:29 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-05 18:44:29 +0300 |
| commit | 207739f7346c98e16087547bc510e1f909671260 (patch) | |
| tree | 5c6eac27beb4eb5e127c7d8dae3464edb3359be9 /tests | |
| parent | 300166eda7b138847008a7653f90753bd8397b9e (diff) | |
- Update PQ
- Update ephemeral plugin, complete Push
- Add Jobs full configuration
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/plugins/http/configs/.rr-http.yaml | 4 | ||||
| -rw-r--r-- | tests/plugins/jobs/configs/.rr-jobs-init.yaml | 9 | ||||
| -rw-r--r-- | tests/plugins/jobs/jobs_plugin_test.go | 2 |
3 files changed, 7 insertions, 8 deletions
diff --git a/tests/plugins/http/configs/.rr-http.yaml b/tests/plugins/http/configs/.rr-http.yaml index c95bc049..b4910160 100644 --- a/tests/plugins/http/configs/.rr-http.yaml +++ b/tests/plugins/http/configs/.rr-http.yaml @@ -3,10 +3,6 @@ rpc: server: command: "php ../../http/client.php echo pipes" - user: "" - group: "" - env: - "RR_HTTP": "true" relay: "pipes" relay_timeout: "20s" diff --git a/tests/plugins/jobs/configs/.rr-jobs-init.yaml b/tests/plugins/jobs/configs/.rr-jobs-init.yaml index 320f41b1..d86a8ad8 100644 --- a/tests/plugins/jobs/configs/.rr-jobs-init.yaml +++ b/tests/plugins/jobs/configs/.rr-jobs-init.yaml @@ -1,8 +1,8 @@ rpc: - listen: tcp://127.0.0.1:6001 + listen: unix:///home/valery/Downloads/rr.sock server: - command: "php ../../psr-worker-bench.php" + command: "php ../../client.php echo pipes" relay: "pipes" relay_timeout: "20s" @@ -24,7 +24,10 @@ sqs: jobs: # worker pool configuration pool: - num_workers: 4 + num_workers: 10 + max_jobs: 0 + allocate_timeout: 60s + destroy_timeout: 60s # list of broker pipelines associated with endpoints pipelines: diff --git a/tests/plugins/jobs/jobs_plugin_test.go b/tests/plugins/jobs/jobs_plugin_test.go index e8b4e83d..754f60bc 100644 --- a/tests/plugins/jobs/jobs_plugin_test.go +++ b/tests/plugins/jobs/jobs_plugin_test.go @@ -82,7 +82,7 @@ func TestJobsInit(t *testing.T) { } }() - time.Sleep(time.Second * 1) + time.Sleep(time.Second * 60) stopCh <- struct{}{} |