Module: SidekiqPrometheus
- Defined in:
- lib/sidekiq_prometheus.rb,
lib/sidekiq_prometheus/version.rb
Defined Under Namespace
Modules: Metrics Classes: Error, JobMetrics, PeriodicMetrics
Constant Summary collapse
- VERSION =
'1.4.0'
Class Attribute Summary collapse
-
.client ⇒ Object
Prometheus::Client.
-
.custom_labels ⇒ Hash{Symbol => Array<Symbol>}
Custom labels applied to specific metrics.
-
.custom_metrics ⇒ Array
Custom metrics that will be registered on setup.
-
.gc_metrics_enabled ⇒ Boolean
Setting to control enabling/disabling GC metrics.
-
.global_metrics_enabled ⇒ Boolean
Setting to control enabling/disabling global metrics.
-
.metrics_host ⇒ String
Host on which the metrics server will listen.
-
.metrics_port ⇒ Integer
Port on which the metrics server will listen.
-
.metrics_server_enabled ⇒ Boolean
Setting to control enabling/disabling the metrics server.
-
.periodic_metrics_enabled ⇒ Boolean
Setting to control enabling/disabling periodic metrics.
-
.periodic_reporting_interval ⇒ Integer
Interval in seconds to record metrics.
-
.preset_labels ⇒ Hash
Preset labels applied to every registered metric.
-
.registry ⇒ Prometheus::Client::Registry
Prometheus client metric registry.
- .setup_complete ⇒ Object writeonly
Class Method Summary collapse
-
.[](metric) ⇒ Prometheus::Client::Metric
(also: get)
Get a metric from the registry.
-
.configure {|_self| ... } ⇒ Object
(also: configure!)
Configure SidekiqPrometheus and setup for reporting.
-
.gc_metrics_enabled? ⇒ Boolean
Helper method for
gc_metrics_enabled
configuration setting. -
.global_metrics_enabled? ⇒ Boolean
Helper method for
global_metrics_enabled
configuration setting RequiresSidekiq::Enterprise
as it uses the leader election functionality. -
.metrics_server ⇒ Object
Start a new Prometheus exporter in a new thread.
-
.metrics_server_enabled? ⇒ Boolean
Helper method for
metrics_server_enabled
configuration setting. -
.periodic_metrics_enabled? ⇒ Boolean
Helper method for
periodic_metrics_enabled
configuration setting RequiresSidekiq::Enterprise
as it uses the leader election functionality. -
.register_custom_metrics ⇒ Object
Register custom metrics Internal method called by
setup
. -
.setup ⇒ Object
register metrics and instrument sidekiq.
-
.sidekiq_setup ⇒ Object
Add Prometheus instrumentation to sidekiq.
Class Attribute Details
.client ⇒ Object
Returns Prometheus::Client.
86 87 88 |
# File 'lib/sidekiq_prometheus.rb', line 86 def client @client ||= Prometheus::Client end |
.custom_labels ⇒ Hash{Symbol => Array<Symbol>}
Returns Custom labels applied to specific metrics.
22 23 24 |
# File 'lib/sidekiq_prometheus.rb', line 22 def custom_labels @custom_labels end |
.custom_metrics ⇒ Array
Each element of the array is a hash and must have the required keys: ‘:name`, `:type`, and `:docstring`. The values for `:name` and `:type` should be symbols and `:docstring` should be a string. `preset_labels` is optional and, if used, must be a hash of labels that will be included on every instance of this metric.
Returns Custom metrics that will be registered on setup.
37 38 39 |
# File 'lib/sidekiq_prometheus.rb', line 37 def custom_metrics @custom_metrics end |
.gc_metrics_enabled ⇒ Boolean
Returns Setting to control enabling/disabling GC metrics. Default: true.
40 41 42 |
# File 'lib/sidekiq_prometheus.rb', line 40 def gc_metrics_enabled @gc_metrics_enabled end |
.global_metrics_enabled ⇒ Boolean
Returns Setting to control enabling/disabling global metrics. Default: true.
43 44 45 |
# File 'lib/sidekiq_prometheus.rb', line 43 def global_metrics_enabled @global_metrics_enabled end |
.metrics_host ⇒ String
Returns Host on which the metrics server will listen. Default: localhost.
55 56 57 |
# File 'lib/sidekiq_prometheus.rb', line 55 def metrics_host @metrics_host end |
.metrics_port ⇒ Integer
Returns Port on which the metrics server will listen. Default: 9357.
58 59 60 |
# File 'lib/sidekiq_prometheus.rb', line 58 def metrics_port @metrics_port end |
.metrics_server_enabled ⇒ Boolean
Returns Setting to control enabling/disabling the metrics server. Default: true.
52 53 54 |
# File 'lib/sidekiq_prometheus.rb', line 52 def metrics_server_enabled @metrics_server_enabled end |
.periodic_metrics_enabled ⇒ Boolean
Returns Setting to control enabling/disabling periodic metrics. Default: true.
46 47 48 |
# File 'lib/sidekiq_prometheus.rb', line 46 def periodic_metrics_enabled @periodic_metrics_enabled end |
.periodic_reporting_interval ⇒ Integer
Returns Interval in seconds to record metrics. Default: 30.
49 50 51 |
# File 'lib/sidekiq_prometheus.rb', line 49 def periodic_reporting_interval @periodic_reporting_interval end |
.preset_labels ⇒ Hash
Returns Preset labels applied to every registered metric.
19 20 21 |
# File 'lib/sidekiq_prometheus.rb', line 19 def preset_labels @preset_labels end |
.registry ⇒ Prometheus::Client::Registry
Prometheus client metric registry
148 149 150 |
# File 'lib/sidekiq_prometheus.rb', line 148 def registry @registry ||= client::Registry.new end |
.setup_complete=(value) ⇒ Object (writeonly)
69 70 71 |
# File 'lib/sidekiq_prometheus.rb', line 69 def setup_complete=(value) @setup_complete = value end |
Class Method Details
.[](metric) ⇒ Prometheus::Client::Metric Also known as: get
Get a metric from the registry
136 137 138 |
# File 'lib/sidekiq_prometheus.rb', line 136 def [](metric) registry.get(metric.to_sym) end |
.configure {|_self| ... } ⇒ Object Also known as: configure!
Configure SidekiqPrometheus and setup for reporting
98 99 100 101 |
# File 'lib/sidekiq_prometheus.rb', line 98 def configure yield self setup end |
.gc_metrics_enabled? ⇒ Boolean
Helper method for gc_metrics_enabled
configuration setting
105 106 107 |
# File 'lib/sidekiq_prometheus.rb', line 105 def gc_metrics_enabled? gc_metrics_enabled end |
.global_metrics_enabled? ⇒ Boolean
Helper method for global_metrics_enabled
configuration setting Requires Sidekiq::Enterprise
as it uses the leader election functionality
113 114 115 |
# File 'lib/sidekiq_prometheus.rb', line 113 def global_metrics_enabled? Object.const_defined?('Sidekiq::Enterprise') && global_metrics_enabled end |
.metrics_server ⇒ Object
Start a new Prometheus exporter in a new thread. Will listen on SidekiqPrometheus.metrics_host and SidekiqPrometheus.metrics_port
202 203 204 205 206 207 208 209 210 211 212 213 |
# File 'lib/sidekiq_prometheus.rb', line 202 def metrics_server @_metrics_server ||= Thread.new do Rack::Handler::WEBrick.run( Rack::Builder.new { use Prometheus::Middleware::Exporter, registry: SidekiqPrometheus.registry run ->(_) { [301, { 'Location' => '/metrics' }, []] } }, Port: SidekiqPrometheus.metrics_port, Host: SidekiqPrometheus.metrics_host, ) end end |
.metrics_server_enabled? ⇒ Boolean
Helper method for metrics_server_enabled
configuration setting
128 129 130 |
# File 'lib/sidekiq_prometheus.rb', line 128 def metrics_server_enabled? metrics_server_enabled end |
.periodic_metrics_enabled? ⇒ Boolean
Helper method for periodic_metrics_enabled
configuration setting Requires Sidekiq::Enterprise
as it uses the leader election functionality
121 122 123 |
# File 'lib/sidekiq_prometheus.rb', line 121 def periodic_metrics_enabled? periodic_metrics_enabled end |
.register_custom_metrics ⇒ Object
Register custom metrics Internal method called by setup
. This method should not be called from application code in most cases.
155 156 157 158 159 160 161 |
# File 'lib/sidekiq_prometheus.rb', line 155 def register_custom_metrics return if custom_metrics.empty? raise SidekiqPrometheus::Error, 'custom_metrics is not an array.' unless custom_metrics.is_a?(Array) SidekiqPrometheus::Metrics.register_metrics(custom_metrics) end |
.setup ⇒ Object
register metrics and instrument sidekiq
165 166 167 168 169 170 171 172 173 174 175 176 |
# File 'lib/sidekiq_prometheus.rb', line 165 def setup return false if @setup_complete SidekiqPrometheus::Metrics.register_sidekiq_job_metrics SidekiqPrometheus::Metrics.register_sidekiq_gc_metric if gc_metrics_enabled? SidekiqPrometheus::Metrics.register_sidekiq_worker_gc_metrics if gc_metrics_enabled? && periodic_metrics_enabled? SidekiqPrometheus::Metrics.register_sidekiq_global_metrics if global_metrics_enabled? && periodic_metrics_enabled? register_custom_metrics sidekiq_setup self.setup_complete = true end |
.sidekiq_setup ⇒ Object
Add Prometheus instrumentation to sidekiq
180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 |
# File 'lib/sidekiq_prometheus.rb', line 180 def sidekiq_setup Sidekiq.configure_server do |config| config.server_middleware do |chain| chain.add SidekiqPrometheus::JobMetrics end if periodic_metrics_enabled? config.on(:startup) { SidekiqPrometheus::PeriodicMetrics.reporter.start } config.on(:shutdown) { SidekiqPrometheus::PeriodicMetrics.reporter.stop } end if metrics_server_enabled? config.on(:startup) { SidekiqPrometheus.metrics_server } config.on(:shutdown) { SidekiqPrometheus.metrics_server.kill } end end end |