Class: SplitIoClient::Cache::Repositories::SegmentsRepository
- Inherits:
-
SplitIoClient::Cache::Repository
- Object
- SplitIoClient::Cache::Repository
- SplitIoClient::Cache::Repositories::SegmentsRepository
- Defined in:
- lib/splitclient-rb/cache/repositories/segments_repository.rb
Constant Summary collapse
- KEYS_SLICE =
3000
Instance Attribute Summary collapse
-
#adapter ⇒ Object
readonly
Returns the value of attribute adapter.
Instance Method Summary collapse
-
#add_to_segment(segment) ⇒ Object
Receives segment data, adds and removes segements from the store.
- #clear ⇒ Object
- #get_change_number(name) ⇒ Object
- #get_segment_keys(name) ⇒ Object
- #in_segment?(name, key) ⇒ Boolean
-
#initialize(config) ⇒ SegmentsRepository
constructor
A new instance of SegmentsRepository.
- #not_ready! ⇒ Object
- #ready! ⇒ Object
- #ready? ⇒ Boolean
- #segment_keys_count ⇒ Object
- #segments_count ⇒ Object
- #set_change_number(name, last_change) ⇒ Object
- #used_segment_names ⇒ Object
Methods inherited from SplitIoClient::Cache::Repository
Constructor Details
#initialize(config) ⇒ SegmentsRepository
Returns a new instance of SegmentsRepository.
9 10 11 12 13 14 15 16 17 18 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 9 def initialize(config) super(config) @adapter = case @config.cache_adapter.class.to_s when 'SplitIoClient::Cache::Adapters::RedisAdapter' SplitIoClient::Cache::Adapters::CacheAdapter.new(@config) else @config.cache_adapter end @adapter.set_bool(namespace_key('.ready'), false) unless @config.mode.equal?(:consumer) end |
Instance Attribute Details
#adapter ⇒ Object (readonly)
Returns the value of attribute adapter.
7 8 9 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 7 def adapter @adapter end |
Instance Method Details
#add_to_segment(segment) ⇒ Object
Receives segment data, adds and removes segements from the store
21 22 23 24 25 26 27 28 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 21 def add_to_segment(segment) name = segment[:name] @adapter.initialize_set(segment_data(name)) unless @adapter.exists?(segment_data(name)) add_keys(name, segment[:added]) remove_keys(name, segment[:removed]) end |
#clear ⇒ Object
62 63 64 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 62 def clear @adapter.clear(namespace_key) end |
#get_change_number(name) ⇒ Object
46 47 48 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 46 def get_change_number(name) @adapter.string(namespace_key(".segment.#{name}.till")) || -1 end |
#get_segment_keys(name) ⇒ Object
30 31 32 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 30 def get_segment_keys(name) @adapter.get_set(segment_data(name)) end |
#in_segment?(name, key) ⇒ Boolean
34 35 36 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 34 def in_segment?(name, key) @adapter.in_set?(segment_data(name), key) end |
#not_ready! ⇒ Object
54 55 56 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 54 def not_ready! @adapter.set_string(namespace_key('.segments.ready'), -1) end |
#ready! ⇒ Object
58 59 60 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 58 def ready! @adapter.set_string(namespace_key('.segments.ready'), Time.now.utc.to_i) end |
#ready? ⇒ Boolean
50 51 52 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 50 def ready? @adapter.string(namespace_key('.segments.ready')).to_i != -1 end |
#segment_keys_count ⇒ Object
70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 70 def segment_keys_count names = used_segment_names keys = 0 names.each do |name| segment_keys = get_segment_keys(name) keys += segment_keys.length end keys rescue StandardError => e @config.log_found_exception(__method__.to_s, e) 0 end |
#segments_count ⇒ Object
66 67 68 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 66 def segments_count used_segment_names.length end |
#set_change_number(name, last_change) ⇒ Object
42 43 44 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 42 def set_change_number(name, last_change) @adapter.set_string(namespace_key(".segment.#{name}.till"), last_change) end |
#used_segment_names ⇒ Object
38 39 40 |
# File 'lib/splitclient-rb/cache/repositories/segments_repository.rb', line 38 def used_segment_names @adapter.get_set(namespace_key('.segments.registered')) end |