Sha256: 5738f763e2dc3e94ef1b6cb8d90089d61b3846eb0a6fa95f1fa130e80b3b3de7

Contents?: true

Size: 1008 Bytes

Versions: 3

Compression:

Stored size: 1008 Bytes

Contents

require 'uri'
require 'drb'
require 'json'
require 'tmpdir'
require 'logger'
require 'net/http'
require 'singleton'
require 'lambda_punch/api'
require 'lambda_punch/error'
require 'lambda_punch/logger'
require 'lambda_punch/queue'
require 'lambda_punch/server'
require 'lambda_punch/worker'
require 'lambda_punch/version'
require 'lambda_punch/notifier'
if defined?(Rails)
  require 'lambda_punch/railtie'
  require 'lambda_punch/rails/active_job'
end

module LambdaPunch
  
  def push(&block)
    Queue.push(block)
  end

  def register!
    Api.register!
  end

  def loop
    Api.loop
  end

  def start_server!
    Server.start!
  end

  def start_worker!
    Worker.start!
  end

  def logger
    @logger ||= Logger.new.logger
  end

  def handled!(context)
    Notifier.handled!(context)
  end

  def error_handler
    @error_handler ||= lambda do |e| 
      logger.error "Queue#call::error => #{e.message}"
    end
  end

  def error_handler=(func)
    @error_handler = func
  end

  extend self

end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
lambda_punch-1.0.2 lib/lambda_punch.rb
lambda_punch-1.0.1 lib/lambda_punch.rb
lambda_punch-1.0.0 lib/lambda_punch.rb