Class: SplitIoClient::Api::Impressions
- Defined in:
- lib/splitclient-rb/engine/api/impressions.rb
Instance Method Summary collapse
-
#initialize(api_key, config, telemetry_runtime_producer) ⇒ Impressions
constructor
A new instance of Impressions.
- #post(impressions) ⇒ Object
- #post_count(impressions_count) ⇒ Object
- #total_impressions(impressions) ⇒ Object
Methods inherited from Client
Constructor Details
#initialize(api_key, config, telemetry_runtime_producer) ⇒ Impressions
Returns a new instance of Impressions.
6 7 8 9 10 |
# File 'lib/splitclient-rb/engine/api/impressions.rb', line 6 def initialize(api_key, config, telemetry_runtime_producer) super(config) @api_key = api_key @telemetry_runtime_producer = telemetry_runtime_producer end |
Instance Method Details
#post(impressions) ⇒ Object
12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 |
# File 'lib/splitclient-rb/engine/api/impressions.rb', line 12 def post(impressions) if impressions.empty? @config.split_logger.log_if_debug('No impressions to report') return end start = Time.now response = post_api("#{@config.events_uri}/testImpressions/bulk", @api_key, impressions, impressions_headers) if response.success? @config.split_logger.log_if_debug("Impressions reported: #{total_impressions(impressions)}") bucket = BinarySearchLatencyTracker.get_bucket((Time.now - start) * 1000.0) @telemetry_runtime_producer.record_sync_latency(Telemetry::Domain::Constants::IMPRESSIONS_SYNC, bucket) @telemetry_runtime_producer.record_successful_sync(Telemetry::Domain::Constants::IMPRESSIONS_SYNC, (Time.now.to_f * 1000.0).to_i) else @telemetry_runtime_producer.record_sync_error(Telemetry::Domain::Constants::IMPRESSIONS_SYNC, response.status) @config.logger.error("Unexpected status code while posting impressions: #{response.status}." \ ' - Check your API key and base URI') raise 'Split SDK failed to connect to backend to post impressions' end end |
#post_count(impressions_count) ⇒ Object
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
# File 'lib/splitclient-rb/engine/api/impressions.rb', line 37 def post_count(impressions_count) if impressions_count.nil? || impressions_count[:pf].empty? @config.split_logger.log_if_debug('No impressions count to send') return end start = Time.now response = post_api("#{@config.events_uri}/testImpressions/count", @api_key, impressions_count) if response.success? @config.split_logger.log_if_debug("Impressions count sent: #{impressions_count[:pf].length}") bucket = BinarySearchLatencyTracker.get_bucket((Time.now - start) * 1000.0) @telemetry_runtime_producer.record_sync_latency(Telemetry::Domain::Constants::IMPRESSION_COUNT_SYNC, bucket) @telemetry_runtime_producer.record_successful_sync(Telemetry::Domain::Constants::IMPRESSION_COUNT_SYNC, (Time.now.to_f * 1000.0).to_i) else @telemetry_runtime_producer.record_sync_error(Telemetry::Domain::Constants::IMPRESSION_COUNT_SYNC, response.status) @config.logger.error("Unexpected status code while posting impressions count: #{response.status}." \ ' - Check your API key and base URI') raise 'Split SDK failed to connect to backend to post impressions' end end |
#total_impressions(impressions) ⇒ Object
62 63 64 65 66 67 68 |
# File 'lib/splitclient-rb/engine/api/impressions.rb', line 62 def total_impressions(impressions) return 0 if impressions.nil? impressions.reduce(0) do |impressions_count, impression| impressions_count += impression[:i].length end end |