Module: Consumer::PositionStore::Put

Defined in:
lib/consumer/position_store.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.prepended(cls) ⇒ Object 



79
80
81
82
83
 
# File 'lib/consumer/position_store.rb', line 79

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

Instance Method Details

#put(position) ⇒ Object 



85
86
87
88
89
90
91
92
93
94
95
 
# File 'lib/consumer/position_store.rb', line 85

def put(position)
  logger.trace(tags: [:position_store, :put]) { "Put position (Position: #{position})" }

  super

  logger.info(tags: [:position_store, :put]) { "Put position done (Position: #{position})" }

  telemetry.record(:put, Telemetry::Put.new(position))

  nil
end