Class: Kafka::Heartbeat

Inherits:

Object

• Object
• Kafka::Heartbeat

Defined in:

lib/kafka/heartbeat.rb

Instance Method Summary

• #initialize(group:, interval:) ⇒ Heartbeat constructor

  A new instance of Heartbeat.

• #trigger ⇒ Object
• #trigger! ⇒ Object

Constructor Details

#initialize(group:, interval:) ⇒ Heartbeat

Returns a new instance of Heartbeat.

# File 'lib/kafka/heartbeat.rb', line 5

def initialize(group:, interval:)
  @group = group
  @interval = interval
  @last_heartbeat = Time.now
end

Instance Method Details

#trigger ⇒ Object

# File 'lib/kafka/heartbeat.rb', line 16

def trigger
  trigger! if Time.now > @last_heartbeat + @interval
end

#trigger! ⇒ Object

# File 'lib/kafka/heartbeat.rb', line 11

def trigger!
  @group.heartbeat
  @last_heartbeat = Time.now
end