Class: Rage::Deferred::Metadata

Inherits:
Object
  • Object
show all
Defined in:
lib/rage/deferred/metadata.rb

Overview

Metadata for deferred tasks. The class encapsulates the metadata associated with a deferred task, and allows to store it without modifying the task instance.

Class Method Summary collapse

Class Method Details

.build(task, args, kwargs) ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/rage/deferred/metadata.rb', line 8

def self.build(task, args, kwargs)
  request_id = Thread.current[:rage_logger][:tags][0] if Thread.current[:rage_logger]

  [
    task,
    args.empty? ? nil : args,
    kwargs.empty? ? nil : kwargs,
    nil,
    request_id
  ]
end

.get_args(metadata) ⇒ Object 



24
25
26
 
# File 'lib/rage/deferred/metadata.rb', line 24

def self.get_args(metadata)
  metadata[1]
end

.get_attempts(metadata) ⇒ Object 



32
33
34
 
# File 'lib/rage/deferred/metadata.rb', line 32

def self.get_attempts(metadata)
  metadata[3]
end

.get_kwargs(metadata) ⇒ Object 



28
29
30
 
# File 'lib/rage/deferred/metadata.rb', line 28

def self.get_kwargs(metadata)
  metadata[2]
end

.get_request_id(metadata) ⇒ Object 



36
37
38
 
# File 'lib/rage/deferred/metadata.rb', line 36

def self.get_request_id(metadata)
  metadata[4]
end

.get_task(metadata) ⇒ Object 



20
21
22
 
# File 'lib/rage/deferred/metadata.rb', line 20

def self.get_task(metadata)
  metadata[0]
end

.inc_attempts(metadata) ⇒ Object 



40
41
42
 
# File 'lib/rage/deferred/metadata.rb', line 40

def self.inc_attempts(metadata)
  metadata[3] = metadata[3].to_i + 1
end