Class: Jets::Job::Base
- Inherits:
-
Lambda::Functions
- Object
- Lambda::Functions
- Jets::Job::Base
- Includes:
- ExceptionReporting::Process, Dsl, Helpers::KinesisEvent, Helpers::LogEvent, Helpers::S3Event, Helpers::SnsEvent, Helpers::SqsEvent
- Defined in:
- lib/jets/job/base.rb
Direct Known Subclasses
Instance Attribute Summary
Attributes inherited from Lambda::Functions
Class Method Summary collapse
- .perform_later(meth, event = {}, context = {}) ⇒ Object
- .perform_now(meth, event = {}, context = {}) ⇒ Object
- .process(event, context, meth) ⇒ Object
Methods included from Helpers::SqsEvent
#sqs_event_payload, #sqs_events, #sqs_events?
Methods included from Helpers::SnsEvent
#sns_event_payload, #sns_events, #sns_events?
Methods included from Helpers::S3Event
#s3_event, #s3_events, #s3_events?, #s3_object, #s3_objects, #s3_objects?
Methods included from Helpers::LogEvent
Methods included from Helpers::KinesisEvent
Methods inherited from Lambda::Functions
#_normalize_options, _prefixes, abstract!, inherited, #initialize, #logger, output_keys, subclasses
Methods included from Lambda::Dsl
Constructor Details
This class inherits a constructor from Jets::Lambda::Functions
Class Method Details
.perform_later(meth, event = {}, context = {}) ⇒ Object
35 36 37 38 39 40 41 42 43 44 |
# File 'lib/jets/job/base.rb', line 35 def perform_later(meth, event={}, context={}) if on_lambda? function_name = "#{self.to_s.underscore}-#{meth}" call = Jets::Commands::Call::Caller.new(function_name, JSON.dump(event), invocation_type: "Event") call.run else Jets.logger.info "INFO: Not on AWS Lambda. In local mode perform_later executes the job with perform_now instead." perform_now(meth, event, context) end end |
.perform_now(meth, event = {}, context = {}) ⇒ Object
31 32 33 |
# File 'lib/jets/job/base.rb', line 31 def perform_now(meth, event={}, context={}) process(event, context, meth) end |
.process(event, context, meth) ⇒ Object
26 27 28 29 |
# File 'lib/jets/job/base.rb', line 26 def process(event, context, meth) job = new(event, context, meth) job.send(meth) end |