Class: Datadog::Core::Telemetry::MetricsManager Private

Inherits:
Object
  • Object
show all
Defined in:
lib/datadog/core/telemetry/metrics_manager.rb

Overview

This class is part of a private API. You should avoid using this class if possible, as it may be removed or be changed in the future.

MetricsManager aggregates and flushes metrics and distributions

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(aggregation_interval:, enabled:) ⇒ MetricsManager

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns a new instance of MetricsManager.



15
16
17
18
19
20
21
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 15

def initialize(aggregation_interval:, enabled:)
  @interval = aggregation_interval
  @enabled = enabled
  @mutex = Mutex.new

  @collections = {}
end

Instance Attribute Details

#collections ⇒ Object (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



13
14
15
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 13

def collections
  @collections
end

#enabled ⇒ Object (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



12
13
14
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 12

def enabled
  @enabled
end

Instance Method Details

#clear ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



74
75
76
77
78
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 74

def clear
  @mutex.synchronize do
    @collections = {}
  end
end

#dec(namespace, metric_name, value, tags: {}, common: true) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



31
32
33
34
35
36
37
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 31

def dec(namespace, metric_name, value, tags: {}, common: true)
  return unless @enabled

  # collection is thread-safe internally
  collection = fetch_or_create_collection(namespace)
  collection.dec(metric_name, value, tags: tags, common: common)
end

#disable! ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



70
71
72
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 70

def disable!
  @enabled = false
end

#distribution(namespace, metric_name, value, tags: {}, common: true) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



55
56
57
58
59
60
61
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 55

def distribution(namespace, metric_name, value, tags: {}, common: true)
  return unless @enabled

  # collection is thread-safe internally
  collection = fetch_or_create_collection(namespace)
  collection.distribution(metric_name, value, tags: tags, common: common)
end

#flush! ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



63
64
65
66
67
68
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 63

def flush!
  return [] unless @enabled

  collections = @mutex.synchronize { @collections.values }
  collections.reduce([]) { |events, collection| events + collection.flush! }
end

#gauge(namespace, metric_name, value, tags: {}, common: true) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



39
40
41
42
43
44
45
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 39

def gauge(namespace, metric_name, value, tags: {}, common: true)
  return unless @enabled

  # collection is thread-safe internally
  collection = fetch_or_create_collection(namespace)
  collection.gauge(metric_name, value, tags: tags, common: common)
end

#inc(namespace, metric_name, value, tags: {}, common: true) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



23
24
25
26
27
28
29
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 23

def inc(namespace, metric_name, value, tags: {}, common: true)
  return unless @enabled

  # collection is thread-safe internally
  collection = fetch_or_create_collection(namespace)
  collection.inc(metric_name, value, tags: tags, common: common)
end

#rate(namespace, metric_name, value, tags: {}, common: true) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



47
48
49
50
51
52
53
 
# File 'lib/datadog/core/telemetry/metrics_manager.rb', line 47

def rate(namespace, metric_name, value, tags: {}, common: true)
  return unless @enabled

  # collection is thread-safe internally
  collection = fetch_or_create_collection(namespace)
  collection.rate(metric_name, value, tags: tags, common: common)
end