module Taskinator

:nocov:

Constants

DEFAULTS
LICENSE
NAME
VERSION

Attributes

queue_adapter[R]

the queue adapter to use supported adapters include :delayed_job, :redis and :sidekiq NOTE: ensure that the respective gem is included

queue_config[R]

configuration, usually a hash, which will be passed to the configured queue adapter

Public Class Methods

configure() { |self| ... } click to toggle source

Configuration for Taskinator client, use like:

Taskinator.configure do |config|
  config.redis = { :namespace => 'myapp', :pool_size => 1, :url => 'redis://myhost:8877/0' }
  config.queue_config = { :process_queue => 'processes', :task_queue => 'tasks' }
end

# File lib/taskinator.rb, line 66
def configure
  yield self if block_given?
end

generate_uuid() click to toggle source

# File lib/taskinator.rb, line 54
def generate_uuid
  SecureRandom.uuid
end

instrumenter() click to toggle source

set the instrumenter to use. can be ActiveSupport::Notifications

# File lib/taskinator.rb, line 129
def instrumenter
  @instrumenter ||= NoOpInstrumenter.new
end

instrumenter=(value) click to toggle source

# File lib/taskinator.rb, line 132
def instrumenter=(value)
  @instrumenter = value
end

logger() click to toggle source

# File lib/taskinator.rb, line 83
def logger
  Taskinator::Logging.logger
end

logger=(log) click to toggle source

# File lib/taskinator.rb, line 87
def logger=(log)
  Taskinator::Logging.logger = log
end

options() click to toggle source

# File lib/taskinator.rb, line 47
def options
  @options ||= DEFAULTS.dup
end

options=(opts) click to toggle source

# File lib/taskinator.rb, line 50
def options=(opts)
  @options = opts
end

queue() click to toggle source

# File lib/taskinator.rb, line 119
def queue
  @queue ||= begin
    adapter = self.queue_adapter || :resque
    config = queue_config || {}
    Taskinator::Queues.create_adapter(adapter, config)
  end
end

queue_adapter=(adapter) click to toggle source

# File lib/taskinator.rb, line 105
def queue_adapter=(adapter)
  @queue_adapter = adapter
  @queue = nil
end

queue_config=(config) click to toggle source

# File lib/taskinator.rb, line 114
def queue_config=(config)
  @queue_config = config
  @queue = nil
end

redis(&block) click to toggle source

# File lib/taskinator.rb, line 70
def redis(&block)
  raise ArgumentError, "requires a block" unless block_given?
  redis_pool.with(&block)
end

redis=(hash) click to toggle source

# File lib/taskinator.rb, line 79
def redis=(hash)
  @redis = Taskinator::RedisConnection.create(hash)
end

redis_pool() click to toggle source

# File lib/taskinator.rb, line 75
def redis_pool
  @redis ||= Taskinator::RedisConnection.create
end

statsd_client() click to toggle source

# File lib/taskinator.rb, line 91
def statsd_client
  Taskinator::LogStats.client
end

statsd_client=(client) click to toggle source

# File lib/taskinator.rb, line 95
def statsd_client=(client)
  Taskinator::LogStats.client = client
end