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]>

3 files changed, 8 insertions, 5 deletions

diff --git a/tests/plugins/informer/test_plugin.go b/tests/plugins/informer/test_plugin.go
index 62816d02..095140b8 100644
--- a/tests/plugins/informer/test_plugin.go
+++ b/tests/plugins/informer/test_plugin.go
@@ -51,13 +51,13 @@ func (p1 *Plugin1) Name() string {
 
 func (p1 *Plugin1) Available() {}
 
-func (p1 *Plugin1) Workers() []process.State {
+func (p1 *Plugin1) Workers() []*process.State {
 	p, err := p1.server.NewWorkerPool(context.Background(), testPoolConfig, nil)
 	if err != nil {
 		panic(err)
 	}
 
-	ps := make([]process.State, 0, len(p.Workers()))
+	ps := make([]*process.State, 0, len(p.Workers()))
 	workers := p.Workers()
 	for i := 0; i < len(workers); i++ {
 		state, err := process.WorkerProcessState(workers[i])
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{}{}