class ActiveJob::QueueAdapters::KubeQueueAdapter
KubeQueue
adapter for ActiveJob
==¶ ↑
To use KubeQueue
set the queue_adapter config to :kube_queue
.
Rails.application.config.active_job.queue_adapter = :kube_queue
Public Class Methods
enqueue(job)
click to toggle source
Interface for ActiveJob
4.2
# File lib/active_job/adapters/kube_queue_adapter.rb, line 12 def enqueue(job) KubeQueue.executor.enqueue(job) end
enqueue_at(job, timestamp)
click to toggle source
# File lib/active_job/adapters/kube_queue_adapter.rb, line 16 def enqueue_at(job, timestamp) job.scheduled_at = timestamp KubeQueue.executor.enqueue(job) end
Public Instance Methods
enqueue(job)
click to toggle source
Interface for ActiveJob
5.0
# File lib/active_job/adapters/kube_queue_adapter.rb, line 23 def enqueue(job) KubeQueueAdapter.enqueue(job) end
enqueue_at(job, timestamp)
click to toggle source
# File lib/active_job/adapters/kube_queue_adapter.rb, line 27 def enqueue_at(job, timestamp) job.scheduled_at = timestamp KubeQueueAdapter.enqueue(job) end