class Fluorite::BatchQueue

• Fluorite::BatchQueue
• Reference
• Object

Defined in:

fluorite/batch.cr

Constructors

• .new(concurrency : Int32 = 1)

Instance Method Summary

• #add(input : String, output : String, &) : BatchJob
• #add(job : BatchJob) : self
• #completed_count : Int32
• #concurrency : Int32
• #concurrency=(concurrency : Int32)
• #failed_count : Int32
• #jobs : Array(BatchJob)
• #on_job_complete(&block : BatchJob -> Nil) : self
• #on_job_fail(&block : BatchJob, Exception -> Nil) : self
• #on_job_progress(&block : BatchJob, Runner::Progress -> Nil) : self
• #on_job_start(&block : BatchJob -> Nil) : self
• #run : Nil

  Runs all jobs sequentially or up to concurrency limit

• #total_count : Int32

Constructor Detail

Instance Method Detail