Module: Massive

Defined in:
lib/massive.rb,
lib/massive/job.rb,
lib/massive/file.rb,
lib/massive/step.rb,
lib/massive/retry.rb,
lib/massive/status.rb,
lib/massive/locking.rb,
lib/massive/process.rb,
lib/massive/version.rb,
lib/massive/file_job.rb,
lib/massive/file_step.rb,
lib/massive/notifiers.rb,
lib/massive/cancelling.rb,
lib/massive/file_process.rb,
lib/massive/notifications.rb,
lib/massive/notifiers/base.rb,
lib/massive/timing_support.rb,
lib/massive/file_serializer.rb,
lib/massive/step_serializer.rb,
lib/massive/notifiers/pusher.rb,
lib/massive/authenticators/s3.rb,
lib/massive/memory_consumption.rb,
lib/massive/process_serializer.rb

Defined Under Namespace

Modules: Authenticators, Cancelling, Locking, MemoryConsumption, Notifications, Notifiers, Retry, Status, TimingSupport Classes: Cancelled, File, FileJob, FileProcess, FileSerializer, FileStep, Job, Process, ProcessSerializer, Step, StepSerializer

Constant Summary collapse

VERSION = 
"0.4.0"

Class Method Summary collapse

Class Method Details

.redis ⇒ Object 



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

def self.redis
  @redis ||= Resque.redis
end

.split_jobs ⇒ Object 



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

def self.split_jobs
  @split_jobs
end

.split_jobs=(value) ⇒ Object 



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

def self.split_jobs=(value)
  @split_jobs = value
end

.storage_config ⇒ Object 



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

def self.storage_config
  @storage_config
end

.storage_config=(value) ⇒ Object 



49
50
51
52
 
# File 'lib/massive.rb', line 49

def self.storage_config=(value)
  @storage_config ||= {}
  @storage_config.merge!(value)
end