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