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

4 files changed, 4 insertions, 4 deletions

diff --git a/pkg/priorityqueue/binary_heap.go b/pkg/priority_queue/binary_heap.go
index e47dd2c8..e47dd2c8 100644
--- a/pkg/priorityqueue/binary_heap.go
+++ b/pkg/priority_queue/binary_heap.go
diff --git a/pkg/priorityqueue/binary_heap_test.go b/pkg/priority_queue/binary_heap_test.go
index 06d0735c..06d0735c 100644
--- a/pkg/priorityqueue/binary_heap_test.go
+++ b/pkg/priority_queue/binary_heap_test.go
diff --git a/pkg/priorityqueue/interface.go b/pkg/priority_queue/interface.go
index 8278dc8d..8278dc8d 100644
--- a/pkg/priorityqueue/interface.go
+++ b/pkg/priority_queue/interface.go
diff --git a/pkg/process/state.go b/pkg/process/state.go
index 652ec77c..bfc3a287 100644
--- a/pkg/process/state.go
+++ b/pkg/process/state.go
@@ -32,20 +32,20 @@ type State struct {
 }
 
 // WorkerProcessState creates new worker state definition.
-func WorkerProcessState(w worker.BaseProcess) (State, error) {
+func WorkerProcessState(w worker.BaseProcess) (*State, error) {
 	const op = errors.Op("worker_process_state")
 	p, _ := process.NewProcess(int32(w.Pid()))
 	i, err := p.MemoryInfo()
 	if err != nil {
-		return State{}, errors.E(op, err)
+		return nil, errors.E(op, err)
 	}
 
 	percent, err := p.CPUPercent()
 	if err != nil {
-		return State{}, err
+		return nil, err
 	}
 
-	return State{
+	return &State{
 		CPUPercent:  percent,
 		Pid:         int(w.Pid()),
 		Status:      w.State().String(),