module Lambdakiq::Event
Public Instance Methods
job?(record)
click to toggle source
# File lib/lambdakiq/event.rb, line 8 def job?(record) record.dig('messageAttributes', 'lambdakiq', 'stringValue') == '1' end
jobs?(event)
click to toggle source
# File lib/lambdakiq/event.rb, line 4 def jobs?(event) records(event).any? { |r| job?(r) } end
records(event)
click to toggle source
# File lib/lambdakiq/event.rb, line 12 def records(event) event['Records'] || [] end