Sha256: 934b3ff65088ca0f8d06f96dd1c3f4ae08d8cce5cec4efcf7dd9ccf2b942ffc8
Contents?: true
Size: 839 Bytes
Versions: 89
Compression:
Stored size: 839 Bytes
Contents
require 'json'
# Job public methods get turned into Lambda functions.
#
# Jets::Job::Base < Jets::Lambda::Functions
# Both Jets::Job::Base and Jets::Lambda::Functions have Dsl modules included.
# So the Jets::Job::Dsl overrides some of the Jets::Lambda::Functions behavior.
class Jets::Job
class Base < Jets::Lambda::Functions
include Dsl
class << self
def process(event, context, meth)
job = new(event, context, meth)
job.send(meth)
end
def perform_now(meth, event={}, context={})
new(event, context, meth).send(meth)
end
def perform_later(meth, event={}, context={})
function_name = "#{self.to_s.underscore}-#{meth}"
call = Jets::Commands::Call.new(function_name, JSON.dump(event), invocation_type: "Event")
call.run
end
end
end
end
Version data entries
89 entries across 89 versions & 2 rubygems