Contents

# frozen_string_literal: true

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

7 entries across 7 versions & 1 rubygems

Version	Path
ruby-kafka-0.7.0.alpha3	lib/kafka/heartbeat.rb
ruby-kafka-0.7.0.alpha2	lib/kafka/heartbeat.rb
ruby-kafka-0.7.0.alpha1	lib/kafka/heartbeat.rb
ruby-kafka-0.6.3	lib/kafka/heartbeat.rb
ruby-kafka-0.6.2	lib/kafka/heartbeat.rb
ruby-kafka-0.6.1	lib/kafka/heartbeat.rb
ruby-kafka-0.6.0	lib/kafka/heartbeat.rb