Class: Karafka::Web::Ui::Models::Jobs

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Includes:
Enumerable
Defined in:
lib/karafka/web/ui/models/jobs.rb

Overview

Model representing group of jobs

It simplifies filtering on running jobs and others, etc

Instance Method Summary collapse

Constructor Details

#initialize(jobs_array) ⇒ Jobs

Returns a new instance of Jobs.

Parameters:

  • jobs_array (Array<Job>) —

    all jobs we want to enclose



18
19
20
 
# File 'lib/karafka/web/ui/models/jobs.rb', line 18

def initialize(jobs_array)
  @jobs_array = jobs_array
end

Instance Method Details

#each ⇒ Object

Allows for iteration over jobs



39
40
41
 
# File 'lib/karafka/web/ui/models/jobs.rb', line 39

def each(&)
  @jobs_array.each(&)
end

#pending ⇒ Jobs

Returns pending jobs.

Returns:

  • (Jobs) —

    pending jobs



28
29
30
 
# File 'lib/karafka/web/ui/models/jobs.rb', line 28

def pending
  select { |job| job.status == 'pending' }
end

#running ⇒ Jobs

Returns running jobs.

Returns:

  • (Jobs) —

    running jobs



23
24
25
 
# File 'lib/karafka/web/ui/models/jobs.rb', line 23

def running
  select { |job| job.status == 'running' }
end

#select ⇒ Jobs

Creates a new Jobs object with selected jobs

Returns:

  • (Jobs) —

    selected jobs enclosed with the Jobs object



34
35
36
 
# File 'lib/karafka/web/ui/models/jobs.rb', line 34

def select(&)
  self.class.new(super)
end