Contents

require "pallets/version"

require 'pallets/backends/base'
require 'pallets/backends/redis'
require 'pallets/configuration'
require 'pallets/context'
require 'pallets/dsl/workflow'
require 'pallets/errors'
require 'pallets/graph'
require 'pallets/logger'
require 'pallets/manager'
require 'pallets/pool'
require 'pallets/scheduler'
require 'pallets/serializers/base'
require 'pallets/serializers/json'
require 'pallets/serializers/msgpack'
require 'pallets/task'
require 'pallets/util'
require 'pallets/worker'
require 'pallets/workflow'

require 'securerandom'

module Pallets
  def self.configuration
    @configuration ||= Configuration.new
  end

  def self.configure
    yield configuration
  end

  def self.backend
    @backend ||= begin
      cls = Pallets::Util.constantize("Pallets::Backends::#{configuration.backend.capitalize}")
      cls.new(
        namespace: configuration.namespace,
        blocking_timeout: configuration.blocking_timeout,
        failed_job_lifespan: configuration.failed_job_lifespan,
        job_timeout: configuration.job_timeout,
        pool_size: configuration.pool_size,
        **configuration.backend_args
      )
    end
  end

  def self.serializer
    @serializer ||= begin
      cls = Pallets::Util.constantize("Pallets::Serializers::#{configuration.serializer.capitalize}")
      cls.new
    end
  end

  def self.logger
    @logger ||= begin
      logger = Pallets::Logger.new(STDOUT)
      # TODO: Ruby 2.4 supports Logger initialization with the arguments below, so
      #       we can drop this after we drop support for Ruby 2.3
      logger.level = Pallets::Logger::INFO
      logger.formatter = Pallets::Logger::Formatters::Pretty.new
      logger
    end
  end

  def self.logger=(logger)
    @logger = logger
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
pallets-0.3.0	lib/pallets.rb