module AtomicSidekiq::Heartbeat::InstanceMethods

Public Instance Methods

heartbeat!(timeout = nil) click to toggle source
# File lib/atomic_sidekiq/heartbeat.rb, line 8
def heartbeat!(timeout = nil)
  heartbeat_operation.perform(
    jid: jid,
    timeout: timeout || default_heartbeat_timeout
  )
end

Private Instance Methods

default_heartbeat_timeout() click to toggle source
# File lib/atomic_sidekiq/heartbeat.rb, line 17
def default_heartbeat_timeout
  AtomicSidekiq::AtomicFetch::DEFAULT_EXPIRATION_TIME
end
heartbeat_operation() click to toggle source
# File lib/atomic_sidekiq/heartbeat.rb, line 21
def heartbeat_operation
  @heartbeat_operation ||= AtomicSidekiq::AtomicOperation::Heartbeat.new(
    in_flight_keymaker: keymaker
  )
end
keymaker() click to toggle source
# File lib/atomic_sidekiq/heartbeat.rb, line 27
def keymaker
  @keymaker ||= AtomicSidekiq::InFlightKeymaker.new(
    AtomicSidekiq::AtomicFetch::IN_FLIGHT_KEY_PREFIX
  )
end