class JobFactory

Defined in:

lib/job.cr

Constant Summary

TTL = ENV["DEFAULT_TTL"]? || 3600

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new(data : Hash(String, String), tube : String, priority : Int32) #

[View source]

Class Method Detail

def self.build_job_factory_from_hash(data : JSON::Any) #

[View source]
def self.normalize_json_hash(json_hash : JSON::Any) #

[View source]
def self.to_hash(job) #

[View source]

Instance Method Detail

def body : String #

[View source]
def body=(body : String) #

[View source]
def created_time : Int64 #

[View source]
def created_time=(created_time : Int64) #

[View source]
def expired_limit : Int32 #

[View source]
def expired_limit=(expired_limit : Int32) #

[View source]
def expireds : Int32 #

[View source]
def expireds=(expireds : Int32) #

[View source]
def get_job #

[View source]
def id : String #

[View source]
def id=(id : String) #

[View source]
def noop : Bool #

[View source]
def noop=(noop : Bool) #

[View source]
def parent_id : String #

[View source]
def parent_id=(parent_id : String) #

[View source]
def priority : Int32 #

[View source]
def priority=(priority : Int32) #

[View source]
def releases : Int32 #

[View source]
def releases=(releases : Int32) #

[View source]
def reserved : Bool #

[View source]
def reserved=(reserved : Bool) #

[View source]
def ttl : Int32 #

[View source]
def ttl=(ttl : Int32) #

[View source]
def tube : String #

[View source]
def tube=(tube : String) #

[View source]