module KubeQueue
Constants
- VERSION
Attributes
client[W]
default_env[W]
executor[W]
Public Class Methods
client()
click to toggle source
# File lib/kube_queue.rb, line 22 def client @client ||= default_client end
configuration()
click to toggle source
# File lib/kube_queue.rb, line 38 def configuration @configuration ||= Configuration.new end
configure(&block)
click to toggle source
# File lib/kube_queue.rb, line 34 def configure(&block) configuration.configure(&block) end
default_client()
click to toggle source
# File lib/kube_queue.rb, line 30 def default_client Client.new end
default_env()
click to toggle source
# File lib/kube_queue.rb, line 44 def default_env return @default_env if @default_env return {} unless defined?(Rails) { RAILS_LOG_TO_STDOUT: ENV['RAILS_LOG_TO_STDOUT'], RAILS_ENV: ENV['RAILS_ENV'] } end
default_executor()
click to toggle source
# File lib/kube_queue.rb, line 26 def default_executor Executor.new end
executor()
click to toggle source
# File lib/kube_queue.rb, line 14 def executor @executor ||= default_executor end
fetch_worker(name)
click to toggle source
# File lib/kube_queue.rb, line 55 def fetch_worker(name) worker_registry.fetch(name) end
kubernetes_configure() { |client| ... }
click to toggle source
# File lib/kube_queue.rb, line 18 def kubernetes_configure yield client end
register_worker(name, klass)
click to toggle source
# File lib/kube_queue.rb, line 59 def register_worker(name, klass) worker_registry[name] = klass end
worker_registry()
click to toggle source
# File lib/kube_queue.rb, line 63 def worker_registry @worker_registry ||= {} end