Sha256: 2ace01bf588382693bd9616b13699496169fe5481780f7883be9ea411d81842e
Contents?: true
Size: 321 Bytes
Versions: 52
Compression:
Stored size: 321 Bytes
Contents
module Kafka
class Heartbeat
def initialize(group:, interval:)
@group = group
@interval = interval
@last_heartbeat = Time.now
end
def send_if_necessary
if Time.now > @last_heartbeat + @interval
@group.heartbeat
@last_heartbeat = Time.now
end
end
end
end
Version data entries
52 entries across 52 versions & 1 rubygems