Sha256: cf326a7efd4dee06472a13589fba8e34a5567c5638918db05913db59e2ae9354
Contents?: true
Size: 1.44 KB
Versions: 7
Compression:
Stored size: 1.44 KB
Contents
# encoding: utf-8
# This file is distributed under New Relic's license terms.
# See https://github.com/newrelic/rpm/blob/master/LICENSE for complete details.
module NewRelic
module Agent
class NewRelicService
class Marshaller
def parsed_error(error)
error_class = error['error_type'].split('::') \
.inject(Module) {|mod,const| mod.const_get(const) }
error_class.new(error['message'])
rescue NameError
CollectorError.new("#{error['error_type']}: #{error['message']}")
end
def prepare(data, options={})
encoder = options[:encoder] || default_encoder
if data.respond_to?(:to_collector_array)
data.to_collector_array(encoder)
elsif data.kind_of?(Array)
data.map { |element| prepare(element, options) }
else
data
end
end
def default_encoder
Encoders::Identity
end
def self.human_readable?
false
end
protected
def return_value(data)
if data.respond_to?(:has_key?)
if data.has_key?('exception')
raise parsed_error(data['exception'])
elsif data.has_key?('return_value')
return data['return_value']
end
end
::NewRelic::Agent.logger.debug("Unexpected response from collector: #{data}")
nil
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems