diff options
Diffstat (limited to 'plugins')
| -rw-r--r-- | plugins/jobs/brokers/ephemeral/entry.go | 7 | ||||
| -rw-r--r-- | plugins/jobs/plugin.go | 2 |
2 files changed, 7 insertions, 2 deletions
diff --git a/plugins/jobs/brokers/ephemeral/entry.go b/plugins/jobs/brokers/ephemeral/entry.go index bf8796d5..3cedec3e 100644 --- a/plugins/jobs/brokers/ephemeral/entry.go +++ b/plugins/jobs/brokers/ephemeral/entry.go @@ -1,13 +1,18 @@ package ephemeral type entry struct { - id string + id string + priority uint64 } func (e *entry) ID() string { return e.id } +func (e *entry) Priority() uint64 { + return e.priority +} + func (e *entry) Ask() { // no-op } diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go index 690402d6..6bf43a11 100644 --- a/plugins/jobs/plugin.go +++ b/plugins/jobs/plugin.go @@ -71,7 +71,7 @@ func (p *Plugin) Init(cfg config.Configurer, log logger.Logger, server server.Se } // initialize priority queue - p.queue = priorityqueue.NewPriorityQueue() + p.queue = priorityqueue.NewBinHeap() p.log = log return nil |