Class: Prometheus::Client::Push
- Inherits:
-
Object
- Object
- Prometheus::Client::Push
- Defined in:
- lib/prometheus/client/push.rb
Overview
Push implements a simple way to transmit a given registry to a given Pushgateway.
Constant Summary collapse
- DEFAULT_GATEWAY =
'http://localhost:9091'.freeze
- PATH =
'/metrics/jobs/%s'.freeze
- INSTANCE_PATH =
'/metrics/jobs/%s/instances/%s'.freeze
- SUPPORTED_SCHEMES =
%w(http https).freeze
Instance Attribute Summary collapse
-
#gateway ⇒ Object
readonly
Returns the value of attribute gateway.
-
#instance ⇒ Object
readonly
Returns the value of attribute instance.
-
#job ⇒ Object
readonly
Returns the value of attribute job.
-
#path ⇒ Object
readonly
Returns the value of attribute path.
Instance Method Summary collapse
- #add(registry) ⇒ Object
- #delete ⇒ Object
-
#initialize(job, instance = nil, gateway = nil) ⇒ Push
constructor
A new instance of Push.
- #replace(registry) ⇒ Object
Constructor Details
#initialize(job, instance = nil, gateway = nil) ⇒ Push
Returns a new instance of Push.
23 24 25 26 27 28 29 30 31 32 33 |
# File 'lib/prometheus/client/push.rb', line 23 def initialize(job, instance = nil, gateway = nil) @mutex = Mutex.new @job = job @instance = instance @gateway = gateway || DEFAULT_GATEWAY @path = build_path(job, instance) @uri = parse("#{@gateway}#{@path}") @http = Net::HTTP.new(@uri.host, @uri.port) @http.use_ssl = (@uri.scheme == 'https') end |
Instance Attribute Details
#gateway ⇒ Object (readonly)
Returns the value of attribute gateway.
21 22 23 |
# File 'lib/prometheus/client/push.rb', line 21 def gateway @gateway end |
#instance ⇒ Object (readonly)
Returns the value of attribute instance.
21 22 23 |
# File 'lib/prometheus/client/push.rb', line 21 def instance @instance end |
#job ⇒ Object (readonly)
Returns the value of attribute job.
21 22 23 |
# File 'lib/prometheus/client/push.rb', line 21 def job @job end |
#path ⇒ Object (readonly)
Returns the value of attribute path.
21 22 23 |
# File 'lib/prometheus/client/push.rb', line 21 def path @path end |
Instance Method Details
#add(registry) ⇒ Object
35 36 37 38 39 |
# File 'lib/prometheus/client/push.rb', line 35 def add(registry) synchronize do request(Net::HTTP::Post, registry) end end |
#delete ⇒ Object
47 48 49 50 51 |
# File 'lib/prometheus/client/push.rb', line 47 def delete synchronize do request(Net::HTTP::Delete) end end |
#replace(registry) ⇒ Object
41 42 43 44 45 |
# File 'lib/prometheus/client/push.rb', line 41 def replace(registry) synchronize do request(Net::HTTP::Put, registry) end end |