Sha256: 40e899592c74507ea07c821635e9a5c19c1ecbf383965be480f34c2201344fbb
Contents?: true
Size: 1.7 KB
Versions: 16
Compression:
Stored size: 1.7 KB
Contents
module SplitIoClient
module Cache
module Repositories
module Impressions
class MemoryRepository
def initialize(adapter)
@adapter = adapter
end
# Store impression data in the selected adapter
def add(split_name, data)
@adapter.add_to_queue(feature: split_name, impressions: data)
rescue ThreadError # queue is full
if random_sampler.rand(1..1000) <= 2 # log only 0.2 % of the time
SplitIoClient.configuration.logger.warn("Dropping impressions. Current size is #{SplitIoClient.configuration.impressions_queue_size}. " \
"Consider increasing impressions_queue_size")
end
end
def add_bulk(key, bucketing_key, treatments, time)
treatments.each do |split_name, treatment|
add(
split_name,
'keyName' => key,
'bucketingKey' => bucketing_key,
'treatment' => treatment[:treatment],
'label' => SplitIoClient.configuration.labels_enabled ? treatment[:label] : nil,
'changeNumber' => treatment[:change_number],
'time' => time
)
end
end
def get_batch
return [] if SplitIoClient.configuration.impressions_bulk_size == 0
@adapter.get_batch(SplitIoClient.configuration.impressions_bulk_size).map do |impression|
impression.update(ip: SplitIoClient.configuration.machine_ip)
end
end
private
def random_sampler
@random_sampler ||= Random.new
end
end
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems