summaryrefslogtreecommitdiff
path: root/tests/plugins/jobs/sqs
diff options
context:
space:
mode:
Diffstat (limited to 'tests/plugins/jobs/sqs')
-rw-r--r--tests/plugins/jobs/sqs/.rr-no-global.yaml39
-rw-r--r--tests/plugins/jobs/sqs/.rr-sqs-declare.yaml4
-rw-r--r--tests/plugins/jobs/sqs/.rr-sqs-init.yaml4
-rw-r--r--tests/plugins/jobs/sqs/.rr-sqs-jobs-err.yaml28
4 files changed, 69 insertions, 6 deletions
diff --git a/tests/plugins/jobs/sqs/.rr-no-global.yaml b/tests/plugins/jobs/sqs/.rr-no-global.yaml
new file mode 100644
index 00000000..2c97a37e
--- /dev/null
+++ b/tests/plugins/jobs/sqs/.rr-no-global.yaml
@@ -0,0 +1,39 @@
+rpc:
+ listen: tcp://127.0.0.1:6001
+
+server:
+ command: "php ../../jobs_ok.php"
+ relay: "pipes"
+ relay_timeout: "20s"
+
+logs:
+ level: error
+ mode: development
+
+jobs:
+ num_pollers: 10
+ pipeline_size: 100000
+ pool:
+ num_workers: 10
+ max_jobs: 0
+ allocate_timeout: 60s
+ destroy_timeout: 60s
+
+ pipelines:
+ test-1:
+ driver: sqs
+ prefetch: 1000
+ visibility_timeout: 0
+ wait_time_seconds: 0
+ queue: default
+ attributes:
+ DelaySeconds: 0
+ MaximumMessageSize: 262144
+ MessageRetentionPeriod: 345600
+ ReceiveMessageWaitTimeSeconds: 0
+ VisibilityTimeout: 30
+ tags:
+ test: "tag"
+
+ consume: [ "test-1" ]
+
diff --git a/tests/plugins/jobs/sqs/.rr-sqs-declare.yaml b/tests/plugins/jobs/sqs/.rr-sqs-declare.yaml
index c4eb9cf9..21209cbb 100644
--- a/tests/plugins/jobs/sqs/.rr-sqs-declare.yaml
+++ b/tests/plugins/jobs/sqs/.rr-sqs-declare.yaml
@@ -2,7 +2,7 @@ rpc:
listen: tcp://127.0.0.1:6001
server:
- command: "php ../../client.php echo pipes"
+ command: "php ../../jobs_ok.php"
relay: "pipes"
relay_timeout: "20s"
@@ -20,7 +20,7 @@ logs:
mode: development
jobs:
- num_pollers: 10
+ num_pollers: 1
pipeline_size: 100000
pool:
num_workers: 10
diff --git a/tests/plugins/jobs/sqs/.rr-sqs-init.yaml b/tests/plugins/jobs/sqs/.rr-sqs-init.yaml
index 239f9954..ffdec1fd 100644
--- a/tests/plugins/jobs/sqs/.rr-sqs-init.yaml
+++ b/tests/plugins/jobs/sqs/.rr-sqs-init.yaml
@@ -33,7 +33,6 @@ jobs:
visibility_timeout: 0
wait_time_seconds: 0
queue: default
- # https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_SetQueueAttributes.html
attributes:
DelaySeconds: 0
MaximumMessageSize: 262144
@@ -51,8 +50,5 @@ jobs:
MessageRetentionPeriod: 86400
tags:
test: "tag"
-
-
- # list of pipelines to be consumed by the server, keep empty if you want to start consuming manually
consume: [ "test-1", "test-2" ]
diff --git a/tests/plugins/jobs/sqs/.rr-sqs-jobs-err.yaml b/tests/plugins/jobs/sqs/.rr-sqs-jobs-err.yaml
new file mode 100644
index 00000000..b518d433
--- /dev/null
+++ b/tests/plugins/jobs/sqs/.rr-sqs-jobs-err.yaml
@@ -0,0 +1,28 @@
+rpc:
+ listen: tcp://127.0.0.1:6001
+
+server:
+ command: "php ../../jobs_err.php"
+ relay: "pipes"
+ relay_timeout: "20s"
+
+sqs:
+ key: api-key
+ secret: api-secret
+ region: us-west-1
+ endpoint: http://127.0.0.1:9324
+
+logs:
+ level: debug
+ encoding: console
+ mode: development
+
+jobs:
+ num_pollers: 10
+ timeout: 60
+ pipeline_size: 100000
+ pool:
+ num_workers: 10
+ max_jobs: 0
+ allocate_timeout: 60s
+ destroy_timeout: 60s