Module: KubeQueue

Defined in:
lib/kube_queue.rb,
lib/kube_queue/cli.rb,
lib/kube_queue/client.rb,
lib/kube_queue/runner.rb,
lib/kube_queue/worker.rb,
lib/kube_queue/version.rb,
lib/kube_queue/executor.rb,
lib/kube_queue/configuration.rb,
lib/kube_queue/job_configuration.rb

Defined Under Namespace

Modules: Worker Classes: CLI, Client, Configuration, Error, Executor, JobConfiguration, Runner

Constant Summary collapse

VERSION = 
"0.1.0".freeze

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.executor ⇒ Object 



13
14
15
 
# File 'lib/kube_queue.rb', line 13

def executor
  @executor ||= default_executor
end

Class Method Details

.client ⇒ Object 



21
22
23
 
# File 'lib/kube_queue.rb', line 21

def client
  @client ||= Client.new
end

.configuration ⇒ Object 



33
34
35
 
# File 'lib/kube_queue.rb', line 33

def configuration
  @configuration ||= Configuration.new
end

.configure(&block) ⇒ Object 



29
30
31
 
# File 'lib/kube_queue.rb', line 29

def configure(&block)
  configuration.configure(&block)
end

.default_executor ⇒ Object 



25
26
27
 
# File 'lib/kube_queue.rb', line 25

def default_executor
  Executor.new
end

.fetch_worker(name) ⇒ Object 



37
38
39
 
# File 'lib/kube_queue.rb', line 37

def fetch_worker(name)
  worker_registry.fetch(name)
end

.kubernetes_configure {|client| ... } ⇒ Object

Yields:



17
18
19
 
# File 'lib/kube_queue.rb', line 17

def kubernetes_configure
  yield client
end

.register_worker(name, klass) ⇒ Object 



41
42
43
 
# File 'lib/kube_queue.rb', line 41

def register_worker(name, klass)
  worker_registry[name] = klass
end

.worker_registry ⇒ Object 



45
46
47
 
# File 'lib/kube_queue.rb', line 45

def worker_registry
  @worker_registry ||= {}
end