Module: Lambdakiq

Extended by:
Lambdakiq
Included in:
Lambdakiq
Defined in:
lib/lambdakiq.rb,
lib/lambdakiq/job.rb,
lib/lambdakiq/error.rb,
lib/lambdakiq/event.rb,
lib/lambdakiq/queue.rb,
lib/lambdakiq/client.rb,
lib/lambdakiq/record.rb,
lib/lambdakiq/worker.rb,
lib/lambdakiq/backoff.rb,
lib/lambdakiq/message.rb,
lib/lambdakiq/metrics.rb,
lib/lambdakiq/railtie.rb,
lib/lambdakiq/version.rb

Defined Under Namespace

Modules: Event, Worker Classes: Backoff, Client, Error, FifoDelayError, Job, Message, Metrics, Queue, Railtie, Record

Constant Summary collapse

VERSION = 
'2.2.0'

Instance Method Summary collapse

Instance Method Details

#client ⇒ Object 



35
36
37
 
# File 'lib/lambdakiq.rb', line 35

def client
  @client ||= Client.new
end

#cmd(event:, context:) ⇒ Object 



23
24
25
 
# File 'lib/lambdakiq.rb', line 23

def cmd(event:, context:)
  handler(event)
end

#config ⇒ Object 



39
40
41
 
# File 'lib/lambdakiq.rb', line 39

def config
  Lambdakiq::Railtie.config.lambdakiq
end

#handler(event) ⇒ Object 



27
28
29
 
# File 'lib/lambdakiq.rb', line 27

def handler(event)
  Job.handler(event)
end

#jobs?(event) ⇒ Boolean

Returns:

  • (Boolean) 


31
32
33
 
# File 'lib/lambdakiq.rb', line 31

def jobs?(event)
  Event.jobs?(event)
end