Sha256: c1e9b025d0b6d89df3542887304f060049f55bc8720b94b38b2eb3f6fe140f37

Contents?: true

Size: 1.08 KB

Versions: 3

Compression:

Stored size: 1.08 KB

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}"
      logger.error e.backtrace[0..10].join("\n")
    end
  end

  def error_handler=(func)
    @error_handler = func
  end

  def tmp_file
    Notifier.tmp_file
  end

  extend self

end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
lambda_punch-1.1.4 lib/lambda_punch.rb
lambda_punch-1.1.3 lib/lambda_punch.rb
lambda_punch-1.1.2 lib/lambda_punch.rb