1#@!#!123s

: / opt / td-agent / embedded / lib / ruby / gems / 2.1.0 / gems / ruby-kafka-0.4.2 / lib / kafka /

Filename : heartbeat.rb

back

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