Class: SplitIoClient::Cache::Repositories::EventsRepository
- Inherits:
-
SplitIoClient::Cache::Repository
- Object
- SplitIoClient::Cache::Repository
- SplitIoClient::Cache::Repositories::EventsRepository
- Extended by:
- Forwardable
- Defined in:
- lib/splitclient-rb/cache/repositories/events_repository.rb
Overview
Repository which forwards events interface to the selected adapter
Direct Known Subclasses
SplitIoClient::Cache::Repositories::Events::MemoryRepository, SplitIoClient::Cache::Repositories::Events::RedisRepository
Instance Method Summary collapse
- #empty? ⇒ Boolean
-
#initialize(config, api_key, telemetry_runtime_producer) ⇒ EventsRepository
constructor
A new instance of EventsRepository.
- #post_events ⇒ Object
Methods inherited from SplitIoClient::Cache::Repository
Constructor Details
#initialize(config, api_key, telemetry_runtime_producer) ⇒ EventsRepository
Returns a new instance of EventsRepository.
9 10 11 12 13 14 15 16 17 18 19 20 |
# File 'lib/splitclient-rb/cache/repositories/events_repository.rb', line 9 def initialize(config, api_key, telemetry_runtime_producer) super(config) @repository = case @config.events_adapter.class.to_s when 'SplitIoClient::Cache::Adapters::MemoryAdapter' Repositories::Events::MemoryRepository.new(@config, telemetry_runtime_producer) when 'SplitIoClient::Cache::Adapters::RedisAdapter' Repositories::Events::RedisRepository.new(@config) end @api_key = api_key @telemetry_runtime_producer = telemetry_runtime_producer end |
Instance Method Details
#empty? ⇒ Boolean
28 29 30 |
# File 'lib/splitclient-rb/cache/repositories/events_repository.rb', line 28 def empty? @repository.empty? end |
#post_events ⇒ Object
22 23 24 25 26 |
# File 'lib/splitclient-rb/cache/repositories/events_repository.rb', line 22 def post_events events_api.post(self.clear) rescue StandardError => e @config.log_found_exception(__method__.to_s, e) end |