Module: Upperkut::Util

Included in:
Strategies::BufferedQueue, Strategies::PriorityQueue, Strategies::ScheduledQueue
Defined in:
lib/upperkut/util.rb

Instance Method Summary collapse

Instance Method Details

#decode_json_items(items) ⇒ Object 



46
47
48
49
50
51
52
53
54
 
# File 'lib/upperkut/util.rb', line 46

def decode_json_items(items)
  items.each_with_object([]) do |item_json, memo|
    next unless item_json

    hash = JSON.parse(item_json)
    id, body, enqueued_at = hash.values_at('id', 'body', 'enqueued_at')
    memo << Item.new(id: id, body: body, enqueued_at: enqueued_at)
  end
end

#encode_json_items(items) ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/upperkut/util.rb', line 34

def encode_json_items(items)
  items = [items] unless items.is_a?(Array)

  items.map do |item|
    JSON.generate(
      'id' => item.id,
      'body' => item.body,
      'enqueued_at' => item.enqueued_at
    )
  end
end

#normalize_items(items) ⇒ Object

Public:

Normalize hash and hash arrays into a hash of Items.
An Item object contains metadata, for example the timestamp from the moment it was enqueued,
 that we need to carry through multiple execution tries.

When the execution fails, we need to schedule the whole batch for retry, and scheduling
 an Item will make Upperkut understand that we're not dealing with a new batch,
 so metrics like latency will increase.



24
25
26
27
28
29
30
31
32
 
# File 'lib/upperkut/util.rb', line 24

def normalize_items(items)
  items = [items] unless items.is_a?(Array)

  items.map do |item|
    next item if item.is_a?(Item)

    Item.new(id: SecureRandom.uuid, body: item)
  end
end

#retry_block(retries_limit = 3, base_sleep = 2) ⇒ Object 



56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
 
# File 'lib/upperkut/util.rb', line 56

def retry_block(retries_limit = 3, base_sleep = 2)
  retries = 0

  begin
    yield
  rescue StandardError => err
    if retries < retries_limit
      retries += 1
      sleep_time = base_sleep**retries
      Kernel.sleep(sleep_time)
      retry
    end

    raise err
  end
end

#to_underscore(object) ⇒ Object 



6
7
8
9
10
11
12
13
14
 
# File 'lib/upperkut/util.rb', line 6

def to_underscore(object)
  klass_name = object.dup
  klass_name.gsub!(/::/, '_')
  klass_name.gsub!(/([A-Z\d]+)([A-Z][a-z])/, '\1_\2')
  klass_name.gsub!(/([a-z\d])([A-Z])/, '\1_\2')
  klass_name.tr!('-', '_')
  klass_name.downcase!
  klass_name
end