module Telemetry::AMQP::Management

Public Instance Methods

ex_q_bindings(exchange:, queue:, **) click to toggle source
# File lib/telemetry/amqp/management.rb, line 56
def ex_q_bindings(exchange:, queue:, **)
  mgmt_connection.get("/api/bindings/telegraf/e/#{exchange}/q/#{queue}").body
rescue StandardError => e
  puts e.message

  []
end
headers() click to toggle source
# File lib/telemetry/amqp/management.rb, line 10
def headers
  {
    'Content-Type' => 'application/json',
    'Accept' => 'application/json'
  }
end
mgmt_connection(node = mgmt_node) click to toggle source
# File lib/telemetry/amqp/management.rb, line 45
def mgmt_connection(node = mgmt_node)
  @mgmt_connection ||= Faraday.new(mgmt_url(node), headers: headers) do |conn|
    conn.request :json
    conn.basic_auth(mgmt_user, mgmt_password)
    conn.response :json, parser_options: { symbolize_names: true }
  end
rescue StandardError => e
  puts e.message
  nil
end
mgmt_node() click to toggle source
# File lib/telemetry/amqp/management.rb, line 25
def mgmt_node
  opts[:mgmt_node] || ENV["#{env_prefix})_mgmt_node"] || 'localhost'
end
mgmt_password() click to toggle source
# File lib/telemetry/amqp/management.rb, line 21
def mgmt_password
  opts[:mgmt_password] || ENV["#{env_prefix}_mgmt_password"] || password
end
mgmt_port() click to toggle source
# File lib/telemetry/amqp/management.rb, line 29
def mgmt_port
  @mgmt_port ||= if opts.key? :mgmt_port
                   opts[:mgmt_port]
                 elsif ENV.key? "#{env_prefix}_mgmt_port"
                   ENV["#{env_prefix}_mgmt_port"].to_i
                 elsif use_ssl?
                   443
                 else
                   80
                 end
end
mgmt_url(node = mgmt_node) click to toggle source
# File lib/telemetry/amqp/management.rb, line 41
def mgmt_url(node = mgmt_node)
  "http#{'s' if use_ssl?}://#{node}:#{mgmt_port}"
end
mgmt_user() click to toggle source
# File lib/telemetry/amqp/management.rb, line 17
def mgmt_user
  opts[:mgmt_user] || ENV["#{env_prefix}_mgmt_user"] || username
end
remove_binding(exchange: 'influxdb.out', queue: "influxdb. click to toggle source
# File lib/telemetry/amqp/management.rb, line 64
def remove_binding(exchange: 'influxdb.out', queue: "influxdb.#{hostname}", key: '#', vhost: 'telegraf', **)
  mgmt_connection.delete("/api/bindings/#{vhost}/e/#{exchange}/q/#{queue}/#{key}").success?
rescue StandardError => e
  puts e.message

  false
end