Update JOBS interface, remove List() method, implemented on the root RPC

level.
AMQP consumer replace sync.Map with atomic.Value, because we associate
only 1 pipeline with a driver. So, we can store pipeline in the
atomic.Value.
Implement events handler, add job events. Use job events to push
information to the logger.

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 6 insertions, 1 deletions

diff --git a/proto/jobs/v1beta/jobs.proto b/proto/jobs/v1beta/jobs.proto
index eb920fb8..9ff967d4 100644
--- a/proto/jobs/v1beta/jobs.proto
+++ b/proto/jobs/v1beta/jobs.proto
@@ -18,8 +18,13 @@ message MaintenanceRequest {
     repeated string pipelines = 1;
 }
 
+// some endpoints receives nothing
 // all endpoints returns nothing
-message EmptyResponse {}
+message Empty {}
+
+message List {
+    repeated string pipelines = 1;
+}
 
 message Job {
     string job = 1;