Class: Mantle::LocalRedis

Inherits:
Object
  • Object
show all
Defined in:
lib/mantle/local_redis.rb

Constant Summary collapse

SUCCESSFUL_MESSAGE_KEY = 
"last_successful_message_received"
CATCH_UP_CLEANUP_KEY = 
"mantle:catch_up:cleanup"

Class Method Summary collapse

Class Method Details

.last_catch_up_cleanup_at ⇒ Object 



23
24
25
26
 
# File 'lib/mantle/local_redis.rb', line 23

def self.last_catch_up_cleanup_at
  result = Sidekiq.redis { |conn| conn.get(CATCH_UP_CLEANUP_KEY) }
  process_redis_response(result)
end

.last_message_successfully_received_at ⇒ Object 



12
13
14
15
 
# File 'lib/mantle/local_redis.rb', line 12

def self.last_message_successfully_received_at
  result = Sidekiq.redis { |conn| conn.get(SUCCESSFUL_MESSAGE_KEY) }
  process_redis_response(result)
end

.set_catch_up_cleanup(time = Time.now.utc.to_f.to_s) ⇒ Object 



17
18
19
20
21
 
# File 'lib/mantle/local_redis.rb', line 17

def self.set_catch_up_cleanup(time = Time.now.utc.to_f.to_s)
  Sidekiq.redis { |conn| conn.set(CATCH_UP_CLEANUP_KEY, time) }
  Mantle.logger.debug("Set last catch up cleanup time: #{time}")
  process_redis_response(time)
end

.set_message_successfully_received(time = Time.now.utc.to_f.to_s) ⇒ Object 



6
7
8
9
10
 
# File 'lib/mantle/local_redis.rb', line 6

def self.set_message_successfully_received(time = Time.now.utc.to_f.to_s)
  Sidekiq.redis { |conn| conn.set(SUCCESSFUL_MESSAGE_KEY, time) }
  Mantle.logger.debug("Set last successful message received time: #{time}")
  process_redis_response(time)
end