module Soda

Constants

DEFAULTS
NAME
VERSION

Public Class Methods

client_middleware() { |chain| ... } click to toggle source
# File lib/soda.rb, line 114
def client_middleware
  (@client_middleware ||= Middleware::Chain.new).tap do |chain|
    yield(chain) if block_given?
  end
end
configure_client() { |self| ... } click to toggle source
# File lib/soda.rb, line 41
def configure_client
  yield(self) unless server?
end
configure_server() { |self| ... } click to toggle source
# File lib/soda.rb, line 37
def configure_server
  yield(self) if server?
end
default_queue!() click to toggle source
# File lib/soda.rb, line 110
def default_queue!
  queues.default!
end
dump_json(hash) click to toggle source
# File lib/soda.rb, line 126
def dump_json(hash)
  JSON.dump(hash)
end
load_json(str) click to toggle source
# File lib/soda.rb, line 130
def load_json(str)
  JSON.load(str)
end
logger() click to toggle source
# File lib/soda.rb, line 29
def logger
  @logger ||= Soda::Logger.new(STDOUT)
end
options() click to toggle source
# File lib/soda.rb, line 33
def options
  @options ||= DEFAULTS.dup
end
queue(name) { |queue| ... } click to toggle source
# File lib/soda.rb, line 104
def queue(name)
  queues.select(name).tap do |queue|
    yield(queue) if block_given?
  end
end
queues() { |registry| ... } click to toggle source
# File lib/soda.rb, line 64
def queues
  (@queues ||= Queues::Registry.new).tap do |registry|
    yield(registry) if block_given?
  end
end
queues=(configs) click to toggle source
# File lib/soda.rb, line 70
def queues=(configs)
  queues do |registry|
    names = []
    configs.each do |cfg|
      # Find or create the queue.
      queue = registry.select(cfg.delete(:name))

      # Update the attributes
      name = queue.name
      url  = cfg.delete(:url) || queue.url

      registry.register(
        name,
        url,
        queue.options.merge(cfg),
      )

      names << queue.name
    end

    # For queues that are not included in the command, set their weight to
    # zero so they can still be accessed.
    registry.each do |queue|
      unless names.include?(queue.name)
        registry.register(
          queue.name,
          queue.url,
          queue.options.merge(weight: 0),
        )
      end
    end
  end
end
server?() click to toggle source
# File lib/soda.rb, line 45
def server?
  defined?(Soda::CLI)
end
server_middleware() { |chain| ... } click to toggle source
# File lib/soda.rb, line 120
def server_middleware
  (@server_middleware ||= Middleware::Chain.new).tap do |chain|
    yield(chain) if block_given?
  end
end
sqs() { |client| ... } click to toggle source
# File lib/soda.rb, line 49
def sqs
  (@sqs ||= Aws::SQS::Client.new).tap do |client|
    yield(client) if block_given?
  end
end
sqs=(options) click to toggle source
# File lib/soda.rb, line 55
def sqs=(options)
  @sqs_options = options || {}
  @sqs         = Aws::SQS::Client.new(@sqs_options)
end
sqs_options() click to toggle source
# File lib/soda.rb, line 60
def sqs_options
  @sqs_options ||= {}
end