Sha256: 4f4d5497976e498d04564b14b64beaee804ea9559b0fa8f3cb274335f3976e05
Contents?: true
Size: 858 Bytes
Versions: 29
Compression:
Stored size: 858 Bytes
Contents
module SplitIoClient
module Cache
module Repositories
module Events
class MemoryRepository < EventsRepository
EVENTS_SLICE = 100
def initialize(adapter, config)
@adapter = adapter
@config = config
end
def add(key, traffic_type, event_type, time, value)
@adapter.add_to_queue(m: metadata, e: event(key, traffic_type, event_type, time, value))
rescue ThreadError # queue is full
if @config.debug_enabled
@config.logger.warn("Dropping events. Current size is #{@config.events_queue_size}. " \
"Consider increasing events_queue_size")
end
@adapter.clear
end
def clear
@adapter.clear
end
end
end
end
end
end
Version data entries
29 entries across 29 versions & 1 rubygems