Module: KubeQueue::Worker::ClassMethods

Includes:

DSL

Defined in:

lib/kube_queue/worker.rb

Instance Method Summary

• #enqueue(body = nil) ⇒ Object (also: #perform_async)
• #enqueue_at(body = nil) ⇒ Object
• #read_template ⇒ Object

Methods included from DSL

#active_deadline_seconds, #backoff_limit, #command, #container_name, #env, #image, #job_spec, #labels, #namespace, #restart_policy, #worker_name

Instance Method Details

#enqueue(body = nil) ⇒ Object Also known as: perform_async

# File 'lib/kube_queue/worker.rb', line 15

def enqueue(body = nil)
  KubeQueue.executor.enqueue(new, body)
end

#enqueue_at(body = nil) ⇒ Object

# File 'lib/kube_queue/worker.rb', line 20

def enqueue_at(body = nil)
  KubeQueue.executor.enqueue(new, body)
end

#read_template ⇒ Object

# File 'lib/kube_queue/worker.rb', line 24

def read_template
  File.read(@template || File.expand_path('../../../template/job.yaml', __FILE__))
end