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