Module: Consumer::PositionStore::Get

Defined in:
lib/consumer/position_store.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.prepended(cls) ⇒ Object 



59
60
61
62
63
 
# File 'lib/consumer/position_store.rb', line 59

def self.prepended(cls)
  cls.class_exec do
    template_method! :get
  end
end

Instance Method Details

#get ⇒ Object 



65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/consumer/position_store.rb', line 65

def get
  logger.trace(tags: [:position_store, :get]) { "Get position" }

  position = super

  logger.debug(tags: [:position_store, :get]) { "Get position done (Position: #{position || '(none)'})" }

  telemetry.record(:get, Telemetry::Get.new(position))

  position
end