Sha256: 71e70493294a531f50f817c004a7e0537542b0c8c0b0b2754f20cfd858f985cc
Contents?: true
Size: 1.59 KB
Versions: 10
Compression:
Stored size: 1.59 KB
Contents
module SplitIoClient
class ImpressionRouter
attr_reader :router_thread
def initialize(config)
@config = config
@listener = @config.impression_listener
return unless @listener
@queue = Queue.new
router_thread
if defined?(PhusionPassenger)
PhusionPassenger.on_event(:starting_worker_process) do |forked|
router_thread if forked
end
end
end
def add(impression)
enqueue(impression)
end
def add_bulk(impressions)
impressions[:split_names].each do |split_name|
enqueue(
split_name: split_name.to_s,
matching_key: impressions[:matching_key],
bucketing_key: impressions[:bucketing_key],
treatment: {
label: impressions[:treatments_labels_change_numbers][split_name.to_sym][:label],
treatment: impressions[:treatments_labels_change_numbers][split_name.to_sym][:treatment],
change_number: impressions[:treatments_labels_change_numbers][split_name.to_sym][:change_number]
},
attributes: impressions[:attributes]
) unless impressions[:treatments_labels_change_numbers][split_name.to_sym].nil?
end
end
private
def enqueue(impression)
@queue.push(impression) if @listener
end
def router_thread
@config.threads[:impression_router] = Thread.new do
loop do
begin
@listener.log(@queue.pop)
rescue StandardError => error
@config.log_found_exception(__method__.to_s, error)
end
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems