Contents

# frozen_string_literal: true

module SalesforceStreamer
  # Store values for a given key in a sorted sequence
  # Retrieves the highest value given a key
  class ReplayPersistence
    class << self
      def record(key, value)
        Log.debug { "Recording #{key}=#{value}" }
        Configuration.instance.persistence_adapter&.record key, value
      end

      def retrieve(key)
        Configuration.instance.persistence_adapter&.retrieve(key).tap do |v|
          Log.debug { "Retrieved for #{key} #{v || 'nil'}" }
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
salesforce_streamer-0.3.0	lib/salesforce_streamer/replay_persistence.rb