Class: Prometheus::Client::Push

Inherits:
Object
  • Object
show all
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
HEADER = 
{ 'Content-Type' => Formats::Text::CONTENT_TYPE }.freeze
SUPPORTED_SCHEMES = 
%w(http https).freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(job, instance = nil, gateway = nil) ⇒ Push

Returns a new instance of Push.



23
24
25
26
27
28
29
30
31
 
# File 'lib/prometheus/client/push.rb', line 23

def initialize(job, instance = nil, gateway = nil)
  @job = job
  @instance = instance
  @gateway = gateway || DEFAULT_GATEWAY
  @uri = parse(@gateway)
  @path = build_path(job, instance)
  @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 



33
34
35
 
# File 'lib/prometheus/client/push.rb', line 33

def add(registry)
  request('POST', registry)
end

#delete ⇒ Object 



41
42
43
 
# File 'lib/prometheus/client/push.rb', line 41

def delete
  @http.send_request('DELETE', path)
end

#replace(registry) ⇒ Object 



37
38
39
 
# File 'lib/prometheus/client/push.rb', line 37

def replace(registry)
  request('PUT', registry)
end