Class: Karafka::Web::Tracking::Helpers::Ttls::Hash

Inherits:

Hash

• Object
• Hash
• Karafka::Web::Tracking::Helpers::Ttls::Hash

Defined in:

lib/karafka/web/tracking/helpers/ttls/hash.rb

Overview

Hash that accumulates data that has an expiration date (ttl) Used to keep track of metrics in a window

Instance Method Summary

• #initialize(ttl) ⇒ Hash constructor

  A new instance of Hash.

• #inspect ⇒ String

  Thread-safe inspect of the ttls hash.

• #stats_from(&block) {|key, samples| ... } ⇒ Stats

  Takes a block where we provide a hash select filtering to select keys we are interested in using for aggregated stats.

Constructor Details

#initialize(ttl) ⇒ Hash

Returns a new instance of Hash.

Parameters:

• ttl (Integer) —

  milliseconds ttl

# File 'lib/karafka/web/tracking/helpers/ttls/hash.rb', line 12

def initialize(ttl)
  @ttl = ttl
  super() { |k, v| k[v] = Ttls::Array.new(@ttl) }
end

Instance Method Details

#inspect ⇒ String

Returns thread-safe inspect of the ttls hash.

Returns:

• (String) —

  thread-safe inspect of the ttls hash

# File 'lib/karafka/web/tracking/helpers/ttls/hash.rb', line 32

def inspect
  "#<#{self.class.name}:#{format('%#x', object_id)} size=#{size} ttl=#{@ttl}ms>"
end

#stats_from(&block) {|key, samples| ... } ⇒ Stats

Takes a block where we provide a hash select filtering to select keys we are interested in using for aggregated stats. Once filtered, builds a Stats object out of the candidates

Parameters:

• block (Proc) —

  block for selection of elements for stats

Yield Parameters:

• key (String)
• samples (Ttls::Array)

Returns:

• (Stats)

# File 'lib/karafka/web/tracking/helpers/ttls/hash.rb', line 25

def stats_from(&block)
  Stats.new(
    select(&block)
  )
end