From 207739f7346c98e16087547bc510e1f909671260 Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Mon, 5 Jul 2021 18:44:29 +0300 Subject: - Update PQ - Update ephemeral plugin, complete Push - Add Jobs full configuration Signed-off-by: Valery Piashchynski --- plugins/jobs/pipeline/pipeline_test.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) (limited to 'plugins/jobs/pipeline/pipeline_test.go') 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) -- cgit v1.2.3