Sha256: ef4dccba8eb5676503a01969b811f0bc4d2aa754f88bcfe4c3b21cf4e8666ed7
Contents?: true
Size: 512 Bytes
Versions: 16
Compression:
Stored size: 512 Bytes
Contents
class CountPublisher
INCREMENT_SIZE = 1000
def initialize(redis_row_count)
@redis_row_count = redis_row_count
@redis = Redis.current
end
def callbacks
{ during_execute: publish_ongoing, after_execute: expire_count }
end
private
def publish_ongoing
lambda do |_row, row_count|
if row_count % INCREMENT_SIZE == 0
@redis_row_count.increment_count_by(INCREMENT_SIZE)
end
end
end
def expire_count
->(_row_count) { @redis_row_count.expire }
end
end
Version data entries
16 entries across 16 versions & 1 rubygems