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.0.1'
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_port ⇒ Integer
Port on which the metrics server will listen.
-
.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.
-
.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.
77 78 79 |
# File 'lib/sidekiq_prometheus.rb', line 77 def client @client ||= Prometheus::Client end |
.custom_labels ⇒ Hash{Symbol => Array<Symbol>}
Returns Custom labels applied to specific metrics.
21 22 23 |
# File 'lib/sidekiq_prometheus.rb', line 21 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.
36 37 38 |
# File 'lib/sidekiq_prometheus.rb', line 36 def custom_metrics @custom_metrics end |
.gc_metrics_enabled ⇒ Boolean
Returns Setting to control enabling/disabling GC metrics. Default: true.
39 40 41 |
# File 'lib/sidekiq_prometheus.rb', line 39 def gc_metrics_enabled @gc_metrics_enabled end |
.global_metrics_enabled ⇒ Boolean
Returns Setting to control enabling/disabling global metrics. Default: true.
42 43 44 |
# File 'lib/sidekiq_prometheus.rb', line 42 def global_metrics_enabled @global_metrics_enabled end |
.metrics_port ⇒ Integer
Returns Port on which the metrics server will listen. Default: 9357.
51 52 53 |
# File 'lib/sidekiq_prometheus.rb', line 51 def metrics_port @metrics_port end |
.periodic_metrics_enabled ⇒ Boolean
Returns Setting to control enabling/disabling periodic metrics. Default: true.
45 46 47 |
# File 'lib/sidekiq_prometheus.rb', line 45 def periodic_metrics_enabled @periodic_metrics_enabled end |
.periodic_reporting_interval ⇒ Integer
Returns Interval in seconds to record metrics. Default: 30.
48 49 50 |
# File 'lib/sidekiq_prometheus.rb', line 48 def periodic_reporting_interval @periodic_reporting_interval end |
.preset_labels ⇒ Hash
Returns Preset labels applied to every registered metric.
18 19 20 |
# File 'lib/sidekiq_prometheus.rb', line 18 def preset_labels @preset_labels end |
.registry ⇒ Prometheus::Client::Registry
Prometheus client metric registry
132 133 134 |
# File 'lib/sidekiq_prometheus.rb', line 132 def registry @registry ||= client::Registry.new end |
.setup_complete=(value) ⇒ Object (writeonly)
62 63 64 |
# File 'lib/sidekiq_prometheus.rb', line 62 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
120 121 122 |
# File 'lib/sidekiq_prometheus.rb', line 120 def [](metric) registry.get(metric.to_sym) end |
.configure {|_self| ... } ⇒ Object Also known as: configure!
Configure SidekiqPrometheus and setup for reporting
89 90 91 92 |
# File 'lib/sidekiq_prometheus.rb', line 89 def configure yield self setup end |
.gc_metrics_enabled? ⇒ Boolean
Helper method for gc_metrics_enabled
configuration setting
96 97 98 |
# File 'lib/sidekiq_prometheus.rb', line 96 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
104 105 106 |
# File 'lib/sidekiq_prometheus.rb', line 104 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_port
183 184 185 186 187 188 189 190 191 192 193 194 |
# File 'lib/sidekiq_prometheus.rb', line 183 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, BindAddress: '127.0.0.1', ) end end |
.periodic_metrics_enabled? ⇒ Boolean
Helper method for periodic_metrics_enabled
configuration setting Requires Sidekiq::Enterprise
as it uses the leader election functionality
112 113 114 |
# File 'lib/sidekiq_prometheus.rb', line 112 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.
139 140 141 142 143 144 145 |
# File 'lib/sidekiq_prometheus.rb', line 139 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
149 150 151 152 153 154 155 156 157 158 159 160 |
# File 'lib/sidekiq_prometheus.rb', line 149 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
164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 |
# File 'lib/sidekiq_prometheus.rb', line 164 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 config.on(:startup) { SidekiqPrometheus.metrics_server } config.on(:shutdown) { SidekiqPrometheus.metrics_server.kill } end end |