- Update PQ

- Update ephemeral plugin, complete Push
- Add Jobs full configuration

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

2 files changed, 13 insertions, 13 deletions

diff --git a/plugins/jobs/pipeline/pipeline.go b/plugins/jobs/pipeline/pipeline.go
index f27f6ede..987f6826 100644
--- a/plugins/jobs/pipeline/pipeline.go
+++ b/plugins/jobs/pipeline/pipeline.go
@@ -15,7 +15,7 @@ func InitPipelines(pipes map[string]*Pipeline) (Pipelines, error) {
 	out := make(Pipelines, 0)
 
 	for name, pipe := range pipes {
-		if pipe.Broker() == "" {
+		if pipe.Driver() == "" {
 			return nil, errors.E(op, errors.Errorf("found the pipeline without defined broker"))
 		}
 
@@ -42,7 +42,7 @@ func (ps Pipelines) Broker(broker string) Pipelines {
 	out := make(Pipelines, 0)
 
 	for _, p := range ps {
-		if p.Broker() != broker {
+		if p.Driver() != broker {
 			continue
 		}
 
@@ -98,9 +98,9 @@ func (p Pipeline) Name() string {
 	return p.String("name", "")
 }
 
-// Broker associated with the pipeline.
-func (p Pipeline) Broker() string {
-	return p.String("broker", "")
+// Driver associated with the pipeline.
+func (p Pipeline) Driver() string {
+	return p.String("driver", "")
 }
 
 // Has checks if value presented in pipeline.
diff --git a/plugins/jobs/pipeline/pipeline_test.go b/plugins/jobs/pipeline/pipeline_test.go
index f03dcbb8..77acf96e 100644
--- a/plugins/jobs/pipeline/pipeline_test.go
+++ b/plugins/jobs/pipeline/pipeline_test.go
@@ -58,23 +58,23 @@ func TestPipeline_Has(t *testing.T) {
 
 func TestPipeline_FilterBroker(t *testing.T) {
 	pipes := Pipelines{
-		&Pipeline{"name": "first", "broker": "a"},
-		&Pipeline{"name": "second", "broker": "a"},
-		&Pipeline{"name": "third", "broker": "b"},
-		&Pipeline{"name": "forth", "broker": "b"},
+		&Pipeline{"name": "first", "driver": "a"},
+		&Pipeline{"name": "second", "driver": "a"},
+		&Pipeline{"name": "third", "driver": "b"},
+		&Pipeline{"name": "forth", "driver": "b"},
 	}
 
 	filtered := pipes.Names("first", "third")
 	assert.True(t, len(filtered) == 2)
 
-	assert.Equal(t, "a", filtered[0].Broker())
-	assert.Equal(t, "b", filtered[1].Broker())
+	assert.Equal(t, "a", filtered[0].Driver())
+	assert.Equal(t, "b", filtered[1].Driver())
 
 	filtered = pipes.Names("first", "third").Reverse()
 	assert.True(t, len(filtered) == 2)
 
-	assert.Equal(t, "a", filtered[1].Broker())
-	assert.Equal(t, "b", filtered[0].Broker())
+	assert.Equal(t, "a", filtered[1].Driver())
+	assert.Equal(t, "b", filtered[0].Driver())
 
 	filtered = pipes.Broker("a")
 	assert.True(t, len(filtered) == 2)