Contents

module Lambdakiq
  module Event

    def jobs?(event)
      records(event).any? { |r| job?(r) }
    end

    def job?(record)
      record.dig('messageAttributes', 'lambdakiq', 'stringValue') == '1'
    end

    def records(event)
      event['Records'] || []
    end

    extend self

  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
lambdakiq-2.3.0	lib/lambdakiq/event.rb
lambdakiq-2.2.0	lib/lambdakiq/event.rb
lambdakiq-2.1.0	lib/lambdakiq/event.rb
lambdakiq-2.0.2	lib/lambdakiq/event.rb
lambdakiq-2.0.1	lib/lambdakiq/event.rb
lambdakiq-2.0.0	lib/lambdakiq/event.rb
lambdakiq-1.0.4	lib/lambdakiq/event.rb
lambdakiq-1.0.3	lib/lambdakiq/event.rb
lambdakiq-1.0.2	lib/lambdakiq/event.rb
lambdakiq-1.0.1	lib/lambdakiq/event.rb