Sha256: 64edaa09785994a310f33bc13a80179d42201eaa844915203b9c34511e4d5124
Contents?: true
Size: 1.33 KB
Versions: 142
Compression:
Stored size: 1.33 KB
Contents
# frozen_string_literal: true
module SplitIoClient
module Cache
module Repositories
module Impressions
class MemoryRepository < ImpressionsRepository
def initialize(config)
@config = config
@adapter = @config.impressions_adapter
end
def add_bulk(impressions)
return 0 if impressions.nil?
count = 0
impressions.each do |impression|
@adapter.add_to_queue(impression)
count += 1
end
0
rescue ThreadError # queue is full
if random_sampler.rand(1..1000) <= 2 # log only 0.2 % of the time
@config.logger.warn("Dropping impressions. Current size is \
#{@config.impressions_queue_size}. " \
'Consider increasing impressions_queue_size')
end
impressions.length - count
end
def batch
return [] if @config.impressions_bulk_size.zero?
@adapter.get_batch(@config.impressions_bulk_size)
end
def clear
@adapter.clear
end
def empty?
@adapter.empty?
end
private
def random_sampler
@random_sampler ||= Random.new
end
end
end
end
end
end
Version data entries
142 entries across 142 versions & 1 rubygems