diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-10 11:17:29 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-10 11:17:29 +0300 |
| commit | 96d437f96785ada6aa5eb6d6ec9505b977ab3e74 (patch) | |
| tree | e413299670acfe94d983029f9b9137571d925b10 /plugins/jobs/brokers/ephemeral/consumer.go | |
| parent | fa57fa609d14e4ebf4cbffc154804402906eecaa (diff) | |
Update Consumer interface, List method returns []string of the
pipelines.
Update packing and unpacking
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs/brokers/ephemeral/consumer.go')
| -rw-r--r-- | plugins/jobs/brokers/ephemeral/consumer.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/plugins/jobs/brokers/ephemeral/consumer.go b/plugins/jobs/brokers/ephemeral/consumer.go index 030dcae8..09e78249 100644 --- a/plugins/jobs/brokers/ephemeral/consumer.go +++ b/plugins/jobs/brokers/ephemeral/consumer.go @@ -121,11 +121,11 @@ func (j *JobBroker) Resume(pipeline string) { } } -func (j *JobBroker) List() []*pipeline.Pipeline { - out := make([]*pipeline.Pipeline, 0, 2) +func (j *JobBroker) List() []string { + out := make([]string, 0, 2) j.queues.Range(func(key, value interface{}) bool { - pipe := key.(*pipeline.Pipeline) + pipe := key.(string) out = append(out, pipe) return true }) |