Sha256: 2a561dca278be881ca6e3e4aeff56cd207c800c16067c35d81da78e28d2f435e
Contents?: true
Size: 1.23 KB
Versions: 16
Compression:
Stored size: 1.23 KB
Contents
module SplitIoClient
module Cache
module Senders
class MetricsSender
def initialize(metrics_repository, api_key)
@metrics_repository = metrics_repository
@api_key = api_key
end
def call
return if ENV['SPLITCLIENT_ENV'] == 'test'
metrics_thread
if defined?(PhusionPassenger)
PhusionPassenger.on_event(:starting_worker_process) do |forked|
metrics_thread if forked
end
end
end
private
def metrics_thread
SplitIoClient.configuration.threads[:metrics_sender] = Thread.new do
SplitIoClient.configuration.logger.info('Starting metrics service')
loop do
post_metrics
sleep(SplitIoClient::Utilities.randomize_interval(SplitIoClient.configuration.metrics_refresh_rate))
end
end
end
def post_metrics
metrics_client.post
rescue StandardError => error
SplitIoClient.configuration.log_found_exception(__method__.to_s, error)
end
def metrics_client
SplitIoClient::Api::Metrics.new(@api_key, @metrics_repository)
end
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems