Sha256: 397b90bade319ed13da569815b1498a6e9ce3d138b4924041cb4860352a8e4e5
Contents?: true
Size: 1.37 KB
Versions: 120
Compression:
Stored size: 1.37 KB
Contents
# frozen_string_literal: true
module SplitIoClient
module Cache
module Senders
class MetricsSender
def initialize(metrics_repository, api_key, config)
@metrics_repository = metrics_repository
@api_key = api_key
@config = config
end
def call
metrics_thread
if defined?(PhusionPassenger)
PhusionPassenger.on_event(:starting_worker_process) do |forked|
metrics_thread if forked
end
end
end
private
def metrics_thread
@config.threads[:metrics_sender] = Thread.new do
begin
@config.logger.info('Starting metrics service')
loop do
post_metrics
sleep(SplitIoClient::Utilities.randomize_interval(@config.metrics_refresh_rate))
end
rescue SplitIoClient::SDKShutdownException
post_metrics
@config.logger.info('Posting metrics due to shutdown')
end
end
end
def post_metrics
metrics_api.post
rescue StandardError => error
@config.log_found_exception(__method__.to_s, error)
end
def metrics_api
@metrics_api ||= SplitIoClient::Api::Metrics.new(@api_key, @metrics_repository, @config)
end
end
end
end
end
Version data entries
120 entries across 120 versions & 1 rubygems