Sha256: 477923740d7046c138b479c15a47c683c0154a41a57affab24575db15f0a2429
Contents?: true
Size: 944 Bytes
Versions: 272
Compression:
Stored size: 944 Bytes
Contents
module SplitIoClient
module Cache
module Repositories
module Events
class RedisRepository < EventsRepository
def initialize(config)
@config = config
@adapter = @config.events_adapter
end
def add(key, traffic_type, event_type, time, value, properties, size)
@adapter.add_to_queue(
namespace_key('.events'),
{ m: metadata, e: event(key, traffic_type, event_type, time, value, properties) }.to_json
)
end
def clear
@adapter.get_from_queue(namespace_key('.events'), 0).map do |e|
JSON.parse(e, symbolize_names: true)
end
rescue StandardError => e
@config.logger.error("Exception while clearing events cache: #{e}")
[]
end
def batch
clear()
end
end
end
end
end
end
Version data entries
272 entries across 272 versions & 1 rubygems