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