Sha256: 989f677f517d34feb7dce9ab01e3742f34aac5a489f406c1ba573f61b9ed3d0b
Contents?: true
Size: 1.84 KB
Versions: 12
Compression:
Stored size: 1.84 KB
Contents
module SplitIoClient
module Api
class Metrics < Client
def initialize(api_key, metrics_repository)
@api_key = api_key
@metrics_repository = metrics_repository
end
def post
post_latencies
post_counts
end
private
def post_latencies
if @metrics_repository.latencies.empty?
SplitIoClient.configuration.logger.debug('No latencies to report.') if SplitIoClient.configuration.debug_enabled
else
@metrics_repository.latencies.each do |name, latencies|
metrics_time = { name: name, latencies: latencies }
response = post_api("#{SplitIoClient.configuration.events_uri}/metrics/time", @api_key, metrics_time)
log_status(response, metrics_time.size)
end
end
@metrics_repository.clear_latencies
end
def post_counts
if @metrics_repository.counts.empty?
SplitIoClient.configuration.logger.debug('No counts to report.') if SplitIoClient.configuration.debug_enabled
else
@metrics_repository.counts.each do |name, count|
metrics_count = { name: name, delta: count }
response = post_api("#{SplitIoClient.configuration.events_uri}/metrics/counter", @api_key, metrics_count)
log_status(response, metrics_count.size)
end
end
@metrics_repository.clear_counts
end
private
def log_status(response, info_to_log)
if response.success?
SplitLogger.log_if_debug("Metric time reported: #{info_to_log}")
else
SplitLogger.log_error("Unexpected status code while posting time metrics: #{response.status}" \
" - Check your API key and base URI")
raise 'Split SDK failed to connect to backend to post metrics'
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems