module Qyu

Constants

SplitWorker
SyncWorker
VERSION
Worker

Public Class Methods

config() click to toggle source

# File lib/qyu.rb, line 27
def config
  fail 'Undefined configuration' unless defined?(@@__config)

  @@__config
end

Also aliased as: configuration

configuration()

Alias for: config

configure(queue:, store:, logger: nil) click to toggle source

# File lib/qyu.rb, line 18
def configure(queue:, store:, logger: nil)
  self.config = Qyu::Config.new(
    queue: queue,
    store: store
  )
  self.logger = logger || default_logger unless defined?(@@__logger)
  self.test_connections
end

configured?() click to toggle source

# File lib/qyu.rb, line 34
def configured?
  defined?(@@__config)
end

logger() click to toggle source

# File lib/qyu.rb, line 42
def logger
  @@__logger ||= default_logger
end

logger=(logger) click to toggle source

# File lib/qyu.rb, line 38
def logger=(logger)
  @@__logger = logger
end

queue() click to toggle source

# File lib/qyu.rb, line 46
def queue
  @@__queue ||= Qyu::Factory::QueueFactory.get(config.queue)
end

store() click to toggle source

# File lib/qyu.rb, line 50
def store
  @@__store ||= Qyu::Factory::StoreFactory.get(config.store)
end

test_connections() click to toggle source

# File lib/qyu.rb, line 54
def test_connections
  queue
  store
end

Private Class Methods

config=(config) click to toggle source

# File lib/qyu.rb, line 61
def config=(config)
  fail 'Can not re-define configuration' if configured?
  fail 'Invalid configuration' unless config.is_a?(Qyu::Config)

  @@__config = config
end

default_logger() click to toggle source

# File lib/qyu.rb, line 68
def default_logger
  logger = Logger.new(STDOUT)
  logger.level = Logger::DEBUG
  logger
end