Sha256: f968806f6ea17fa50b934e895704699446982ba3eb77cc4239df9140d71a8bc5
Contents?: true
Size: 1.99 KB
Versions: 9
Compression:
Stored size: 1.99 KB
Contents
require 'alephant/broker/cache'
require 'alephant/broker/errors/content_not_found'
require 'alephant/logger'
require 'faraday'
module Alephant
module Broker
module LoadStrategy
class HTTP
include Logger
class URL
def generate
raise NotImplementedError
end
end
def initialize(url_generator)
@url_generator = url_generator
end
def load(component_meta)
cache_object(component_meta)
rescue
logger.metric(:name => "BrokerLoadStrategyHTTPCacheMiss", :unit => "Count", :value => 1)
cache.set(component_meta.cache_key, content(component_meta))
end
private
attr_reader :cache, :url_generator
def cache
@cache ||= Cache::Client.new
end
def cache_object(component_meta)
cache.get(component_meta.cache_key) { content component_meta }
end
def content(component_meta)
resp = request component_meta
{
:content => resp.body,
:content_type => extract_content_type_from(resp.env.response_headers)
}
end
def extract_content_type_from(headers)
headers['content-type'].split(';').first
end
def request(component_meta)
before = Time.new
component_meta.cached = false
Faraday.get(url_for component_meta).tap do |r|
unless r.success?
logger.metric(:name => "BrokerLoadStrategyHTTPContentNotFound", :unit => "Count", :value => 1)
raise Alephant::Broker::Errors::ContentNotFound
end
request_time = Time.new - before
logger.metric(:name => "BrokerHTTPLoadComponentTime", :unit => "Seconds", :value => request_time)
end
end
def url_for(component_meta)
url_generator.generate(
component_meta.id,
component_meta.options
)
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems