Contents

module SplitIoClient
  module Cache
    module Repositories
      class SegmentsRepository < Repository
        KEYS_SLICE = 3000

        def initialize(adapter)
          @adapter = adapter

          @adapter.set_bool(namespace_key('ready'), false)
        end

        # Receives segment data, adds and removes segements from the store
        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

        def get_segment_keys(name)
          @adapter.get_set(segment_data(name))
        end

        def in_segment?(name, key)
          @adapter.in_set?(segment_data(name), key)
        end

        def used_segment_names
          @adapter.get_set(namespace_key('segments.registered'))
        end

        def set_change_number(name, last_change)
          @adapter.set_string(namespace_key("segment.#{name}.till"), last_change)
        end

        def get_change_number(name)
          @adapter.string(namespace_key("segment.#{name}.till")) || -1
        end

        private

        def segment_data(name)
          namespace_key("segmentData.#{name}")
        end

        def add_keys(name, keys)
          keys.each_slice(KEYS_SLICE) do |keys_slice|
            @adapter.add_to_set(segment_data(name), keys_slice)
          end
        end

        def remove_keys(name, keys)
          keys.each_slice(KEYS_SLICE) do |keys_slice|
            @adapter.delete_from_set(segment_data(name), keys_slice)
          end
        end
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
splitclient-rb-3.1.2	lib/cache/repositories/segments_repository.rb
splitclient-rb-3.1.1	lib/cache/repositories/segments_repository.rb
splitclient-rb-3.1.0	lib/cache/repositories/segments_repository.rb
splitclient-rb-3.1.0.pre.rc12	lib/cache/repositories/segments_repository.rb
splitclient-rb-3.1.0.pre.rc11	lib/cache/repositories/segments_repository.rb
splitclient-rb-3.1.0.pre.rc10	lib/cache/repositories/segments_repository.rb
splitclient-rb-3.1.0.pre.rc9	lib/cache/repositories/segments_repository.rb
splitclient-rb-3.1.0.pre.rc8	lib/cache/repositories/segments_repository.rb