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