Module: Pallets

Defined in:
lib/pallets.rb,
lib/pallets/cli.rb,
lib/pallets/pool.rb,
lib/pallets/task.rb,
lib/pallets/util.rb,
lib/pallets/graph.rb,
lib/pallets/errors.rb,
lib/pallets/logger.rb,
lib/pallets/worker.rb,
lib/pallets/context.rb,
lib/pallets/manager.rb,
lib/pallets/version.rb,
lib/pallets/workflow.rb,
lib/pallets/scheduler.rb,
lib/pallets/dsl/workflow.rb,
lib/pallets/backends/base.rb,
lib/pallets/configuration.rb,
lib/pallets/backends/redis.rb,
lib/pallets/middleware/stack.rb,
lib/pallets/serializers/base.rb,
lib/pallets/serializers/json.rb,
lib/pallets/serializers/msgpack.rb,
lib/pallets/middleware/job_logger.rb,
lib/pallets/middleware/appsignal_instrumenter.rb

Defined Under Namespace

Modules: Backends, DSL, Middleware, Serializers, Util Classes: CLI, Configuration, Context, Graph, Logger, Manager, PalletsError, Pool, Scheduler, Shutdown, Task, Worker, Workflow, WorkflowError

Constant Summary collapse

VERSION = 
"0.6.0"

Class Method Summary collapse

Class Method Details

.backend ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/pallets.rb', line 35

def self.backend
  @backend ||= begin
    cls = Pallets::Util.constantize("Pallets::Backends::#{configuration.backend.capitalize}")
    cls.new(
      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

.configuration ⇒ Object 



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

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

.configure {|configuration| ... } ⇒ Object

Yields:



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

def self.configure
  yield configuration
end

.logger ⇒ Object 



59
60
61
62
63
64
 
# File 'lib/pallets.rb', line 59

def self.logger
  @logger ||= Pallets::Logger.new(STDOUT,
    level: Pallets::Logger::INFO,
    formatter: Pallets::Logger::Formatters::Pretty.new
  )
end

.logger=(logger) ⇒ Object 



66
67
68
 
# File 'lib/pallets.rb', line 66

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

.middleware ⇒ Object 



55
56
57
 
# File 'lib/pallets.rb', line 55

def self.middleware
  @middleware ||= configuration.middleware
end

.serializer ⇒ Object 



48
49
50
51
52
53
 
# File 'lib/pallets.rb', line 48

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