Class: EntityCache::Storage::Persistent::Telemetry::Sink

Inherits:
Object
  • Object
show all
Includes:
Telemetry::Sink
Defined in:
lib/entity_cache/storage/persistent/telemetry.rb

Instance Method Summary collapse

Instance Method Details

#retrieved?(&blk) ⇒ Boolean

Returns:

  • (Boolean) 


17
18
19
20
21
22
23
24
 
# File 'lib/entity_cache/storage/persistent/telemetry.rb', line 17

def retrieved?(&blk)
  return get_records if blk.nil?

  recorded_get? do |record|
    data = record.data
    blk.call(data.id, data.entity, data.version, data.time)
  end
end

#stored?(&blk) ⇒ Boolean

Returns:

  • (Boolean) 


26
27
28
29
30
31
32
33
 
# File 'lib/entity_cache/storage/persistent/telemetry.rb', line 26

def stored?(&blk)
  return put_records if blk.nil?

  recorded_put? do |record|
    data = record.data
    blk.call(data.id, data.entity, data.version, data.time)
  end
end