initial commit
Change-Id: I2ec47c1f516a8c930360f0f13a11c651595e6e1c
This commit is contained in:
Mohammed Naser
parent
84ffffb268
commit
a3bb10846a
30
.zuul.yaml
Normal file
30
.zuul.yaml
Normal file
@ -0,0 +1,30 @@
|
||||
- job:
|
||||
name: libvirtd_exporter:image:build
|
||||
parent: vexxhost-build-docker-image
|
||||
provides: libvirtd_exporter:image
|
||||
vars: &libvirtd_exporter_images
|
||||
docker_images:
|
||||
- context: .
|
||||
repository: vexxhost/libvirtd-exporter
|
||||
|
||||
- job:
|
||||
name: libvirtd_exporter:image:upload
|
||||
parent: vexxhost-upload-docker-image
|
||||
provides: libvird_exporter:image
|
||||
vars: *libvirtd_exporter_images
|
||||
|
||||
- job:
|
||||
name: libvirtd_exporter:image:promote
|
||||
parent: vexxhost-promote-docker-image
|
||||
vars: *libvirtd_exporter_images
|
||||
|
||||
- project:
|
||||
check:
|
||||
jobs:
|
||||
- libvirtd_exporter:image:build
|
||||
gate:
|
||||
jobs:
|
||||
- libvirtd_exporter:image:upload
|
||||
promote:
|
||||
jobs:
|
||||
- libvirtd_exporter:image:promote
|
||||
14
Dockerfile
Normal file
14
Dockerfile
Normal file
@ -0,0 +1,14 @@
|
||||
FROM golang:1.13.5 AS builder
|
||||
WORKDIR /go/src/app
|
||||
COPY . .
|
||||
RUN apt-get update && \
|
||||
apt-get -y install libvirt-dev && \
|
||||
apt-get clean all
|
||||
RUN go build
|
||||
|
||||
FROM golang:1.13.5
|
||||
RUN apt-get update && \
|
||||
apt-get -y install libvirt0 && \
|
||||
apt-get clean all
|
||||
COPY --from=builder /go/src/app/libvirtd_exporter /libvirtd_exporter
|
||||
ENTRYPOINT ["/libvirtd_exporter"]
|
||||
3
bindep.txt
Normal file
3
bindep.txt
Normal file
@ -0,0 +1,3 @@
|
||||
gcc
|
||||
pkg-config
|
||||
libvirt-dev
|
||||
558
collectors/domain_stats.go
Normal file
558
collectors/domain_stats.go
Normal file
@ -0,0 +1,558 @@
|
||||
// Copyright 2019 VEXXHOST, Inc.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
// See the License for the specific language governing permissions and
|
||||
// limitations under the License.
|
||||
|
||||
package collectors
|
||||
|
||||
import (
|
||||
"encoding/xml"
|
||||
"strconv"
|
||||
"time"
|
||||
|
||||
"github.com/libvirt/libvirt-go"
|
||||
"github.com/prometheus/client_golang/prometheus"
|
||||
"github.com/prometheus/common/log"
|
||||
)
|
||||
|
||||
type DomainStatsCollector struct {
|
||||
prometheus.Collector
|
||||
|
||||
Connection *libvirt.Connect
|
||||
Nova bool
|
||||
|
||||
DomainSeconds *prometheus.Desc
|
||||
|
||||
DomainDomainState *prometheus.Desc
|
||||
DomainDomainStateReason *prometheus.Desc
|
||||
|
||||
DomainCPUTime *prometheus.Desc
|
||||
DomainCPUUser *prometheus.Desc
|
||||
DomainCPUSystem *prometheus.Desc
|
||||
|
||||
DomainBalloonCurrent *prometheus.Desc
|
||||
DomainBalloonMaximum *prometheus.Desc
|
||||
|
||||
DomainVcpuState *prometheus.Desc
|
||||
DomainVcpuTime *prometheus.Desc
|
||||
|
||||
DomainNetRxBytes *prometheus.Desc
|
||||
DomainNetRxPkts *prometheus.Desc
|
||||
DomainNetRxErrs *prometheus.Desc
|
||||
DomainNetRxDrop *prometheus.Desc
|
||||
DomainNetTxBytes *prometheus.Desc
|
||||
DomainNetTxPkts *prometheus.Desc
|
||||
DomainNetTxErrs *prometheus.Desc
|
||||
DomainNetTxDrop *prometheus.Desc
|
||||
|
||||
DomainBlockRdReqs *prometheus.Desc
|
||||
DomainBlockRdBytes *prometheus.Desc
|
||||
DomainBlockRdTimes *prometheus.Desc
|
||||
DomainBlockWrReqs *prometheus.Desc
|
||||
DomainBlockWrBytes *prometheus.Desc
|
||||
DomainBlockWrTimes *prometheus.Desc
|
||||
DomainBlockFlReqs *prometheus.Desc
|
||||
DomainBlockFlTimes *prometheus.Desc
|
||||
DomainBlockErrors *prometheus.Desc
|
||||
DomainBlockAllocation *prometheus.Desc
|
||||
DomainBlockCapacity *prometheus.Desc
|
||||
DomainBlockPhysical *prometheus.Desc
|
||||
}
|
||||
|
||||
type NovaFlavorMetadata struct {
|
||||
Name string `xml:"name,attr"`
|
||||
}
|
||||
|
||||
type NovaOwnerMetadata struct {
|
||||
UUID string `xml:"uuid,attr"`
|
||||
}
|
||||
|
||||
type NovaMetadata struct {
|
||||
Seconds float64 `xml:"omitempty"`
|
||||
CreationTime string `xml:"creationTime"`
|
||||
Flavor NovaFlavorMetadata `xml:"flavor"`
|
||||
User NovaOwnerMetadata `xml:"owner>user"`
|
||||
Project NovaOwnerMetadata `xml:"owner>project"`
|
||||
}
|
||||
|
||||
// nolint:funlen
|
||||
func NewDomainStatsCollector(uri string, nova bool) (*DomainStatsCollector, error) {
|
||||
conn, err := libvirt.NewConnect(uri)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &DomainStatsCollector{
|
||||
Connection: conn,
|
||||
Nova: nova,
|
||||
|
||||
DomainSeconds: prometheus.NewDesc(
|
||||
"libvirtd_domain_seconds",
|
||||
"seconds since creation time",
|
||||
[]string{"uuid", "instance_type", "user_id", "project_id"}, nil,
|
||||
),
|
||||
|
||||
DomainDomainState: prometheus.NewDesc(
|
||||
"libvirtd_domain_domain_state",
|
||||
"state of the VM (virDomainState enum)",
|
||||
[]string{"uuid"}, nil,
|
||||
),
|
||||
DomainDomainStateReason: prometheus.NewDesc(
|
||||
"libvirtd_domain_domain_state_reason",
|
||||
"reason for entering given state (virDomain*Reason enum)",
|
||||
[]string{"uuid"}, nil,
|
||||
),
|
||||
|
||||
DomainCPUTime: prometheus.NewDesc(
|
||||
"libvirtd_domain_cpu_time",
|
||||
"total cpu time spent for this domain in nanoseconds",
|
||||
[]string{"uuid"}, nil,
|
||||
),
|
||||
DomainCPUUser: prometheus.NewDesc(
|
||||
"libvirtd_domain_cpu_user",
|
||||
"user cpu time spent in nanoseconds",
|
||||
[]string{"uuid"}, nil,
|
||||
),
|
||||
DomainCPUSystem: prometheus.NewDesc(
|
||||
"libvirtd_domain_cpu_system",
|
||||
"system cpu time spent in nanoseconds",
|
||||
[]string{"uuid"}, nil,
|
||||
),
|
||||
|
||||
DomainBalloonCurrent: prometheus.NewDesc(
|
||||
"libvirtd_domain_balloon_current",
|
||||
"the memory in kiB currently used",
|
||||
[]string{"uuid"}, nil,
|
||||
),
|
||||
DomainBalloonMaximum: prometheus.NewDesc(
|
||||
"libvirtd_domain_balloon_maximum",
|
||||
"the maximum memory in kiB allowed",
|
||||
[]string{"uuid"}, nil,
|
||||
),
|
||||
|
||||
DomainVcpuState: prometheus.NewDesc(
|
||||
"libvirtd_domain_vcpu_state",
|
||||
"state of the virtual CPU (virVcpuState enum)",
|
||||
[]string{"uuid", "vcpu"}, nil,
|
||||
),
|
||||
DomainVcpuTime: prometheus.NewDesc(
|
||||
"libvirtd_domain_vcpu_time",
|
||||
"virtual cpu time spent",
|
||||
[]string{"uuid", "vcpu"}, nil,
|
||||
),
|
||||
|
||||
DomainNetRxBytes: prometheus.NewDesc(
|
||||
"libvirtd_domain_net_rx_bytes",
|
||||
"bytes received",
|
||||
[]string{"uuid", "interface"}, nil,
|
||||
),
|
||||
DomainNetRxPkts: prometheus.NewDesc(
|
||||
"libvirtd_domain_net_rx_packets",
|
||||
"packets received",
|
||||
[]string{"uuid", "interface"}, nil,
|
||||
),
|
||||
DomainNetRxErrs: prometheus.NewDesc(
|
||||
"libvirtd_domain_net_rx_errors",
|
||||
"receive errors",
|
||||
[]string{"uuid", "interface"}, nil,
|
||||
),
|
||||
DomainNetRxDrop: prometheus.NewDesc(
|
||||
"libvirtd_domain_net_rx_drop",
|
||||
"receive packets dropped",
|
||||
[]string{"uuid", "interface"}, nil,
|
||||
),
|
||||
DomainNetTxBytes: prometheus.NewDesc(
|
||||
"libvirtd_domain_net_tx_bytes",
|
||||
"bytes transmitted",
|
||||
[]string{"uuid", "interface"}, nil,
|
||||
),
|
||||
DomainNetTxPkts: prometheus.NewDesc(
|
||||
"libvirtd_domain_net_tx_packets",
|
||||
"packets transmitted",
|
||||
[]string{"uuid", "interface"}, nil,
|
||||
),
|
||||
DomainNetTxErrs: prometheus.NewDesc(
|
||||
"libvirtd_domain_net_tx_errors",
|
||||
"transmission errors",
|
||||
[]string{"uuid", "interface"}, nil,
|
||||
),
|
||||
DomainNetTxDrop: prometheus.NewDesc(
|
||||
"libvirtd_domain_net_tx_drop",
|
||||
"transmit packets dropped",
|
||||
[]string{"uuid", "interface"}, nil,
|
||||
),
|
||||
|
||||
DomainBlockRdReqs: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_read_requests",
|
||||
"number of read requests",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
DomainBlockRdBytes: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_read_bytes",
|
||||
"number of read bytes",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
DomainBlockRdTimes: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_read_times",
|
||||
"total time (ns) spent on reads",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
DomainBlockWrReqs: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_write_requests",
|
||||
"number of written requests",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
DomainBlockWrBytes: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_write_bytes",
|
||||
"number of written bytes",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
DomainBlockWrTimes: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_write_times",
|
||||
"total time (ns) spent on writes",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
DomainBlockFlReqs: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_flush_requests",
|
||||
"total flush requests",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
DomainBlockFlTimes: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_flush_times",
|
||||
"total time (ns) spent on cache flushing",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
DomainBlockAllocation: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_allocation",
|
||||
"offset of the highest written sector",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
DomainBlockCapacity: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_capacity",
|
||||
"logical size in bytes of the block device backing image",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
DomainBlockPhysical: prometheus.NewDesc(
|
||||
"libvirtd_domain_block_physical",
|
||||
"physical size in bytes of the container of the backing image",
|
||||
[]string{"uuid", "device", "path"}, nil,
|
||||
),
|
||||
}, nil
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) Describe(ch chan<- *prometheus.Desc) {
|
||||
c.describeNova(ch)
|
||||
c.describeState(ch)
|
||||
c.describeCPU(ch)
|
||||
c.describeBalloon(ch)
|
||||
c.describeVcpu(ch)
|
||||
c.describeNet(ch)
|
||||
c.describeBlock(ch)
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) describeNova(ch chan<- *prometheus.Desc) {
|
||||
if c.Nova {
|
||||
ch <- c.DomainSeconds
|
||||
}
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) describeState(ch chan<- *prometheus.Desc) {
|
||||
ch <- c.DomainDomainState
|
||||
ch <- c.DomainDomainStateReason
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) describeCPU(ch chan<- *prometheus.Desc) {
|
||||
ch <- c.DomainCPUTime
|
||||
ch <- c.DomainCPUUser
|
||||
ch <- c.DomainCPUSystem
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) describeBalloon(ch chan<- *prometheus.Desc) {
|
||||
ch <- c.DomainBalloonCurrent
|
||||
ch <- c.DomainBalloonMaximum
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) describeVcpu(ch chan<- *prometheus.Desc) {
|
||||
ch <- c.DomainVcpuState
|
||||
ch <- c.DomainVcpuTime
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) describeNet(ch chan<- *prometheus.Desc) {
|
||||
ch <- c.DomainNetRxBytes
|
||||
ch <- c.DomainNetRxPkts
|
||||
ch <- c.DomainNetRxErrs
|
||||
ch <- c.DomainNetRxDrop
|
||||
ch <- c.DomainNetTxBytes
|
||||
ch <- c.DomainNetTxPkts
|
||||
ch <- c.DomainNetTxErrs
|
||||
ch <- c.DomainNetTxDrop
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) describeBlock(ch chan<- *prometheus.Desc) {
|
||||
ch <- c.DomainBlockRdReqs
|
||||
ch <- c.DomainBlockRdBytes
|
||||
ch <- c.DomainBlockRdTimes
|
||||
ch <- c.DomainBlockWrReqs
|
||||
ch <- c.DomainBlockWrBytes
|
||||
ch <- c.DomainBlockWrTimes
|
||||
ch <- c.DomainBlockFlReqs
|
||||
ch <- c.DomainBlockFlTimes
|
||||
ch <- c.DomainBlockAllocation
|
||||
ch <- c.DomainBlockCapacity
|
||||
ch <- c.DomainBlockPhysical
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) Collect(ch chan<- prometheus.Metric) {
|
||||
stats, err := c.Connection.GetAllDomainStats(
|
||||
[]*libvirt.Domain{},
|
||||
libvirt.DOMAIN_STATS_STATE|libvirt.DOMAIN_STATS_CPU_TOTAL|libvirt.DOMAIN_STATS_BALLOON|
|
||||
libvirt.DOMAIN_STATS_VCPU|libvirt.DOMAIN_STATS_INTERFACE|libvirt.DOMAIN_STATS_BLOCK,
|
||||
0,
|
||||
)
|
||||
|
||||
if err != nil {
|
||||
log.Errorln(err)
|
||||
return
|
||||
}
|
||||
|
||||
for _, stat := range stats {
|
||||
uuid, err := stat.Domain.GetUUIDString()
|
||||
if err != nil {
|
||||
log.Errorln(err)
|
||||
continue
|
||||
}
|
||||
|
||||
c.collectNova(uuid, stat, ch)
|
||||
c.collectState(uuid, stat, ch)
|
||||
c.collectCPU(uuid, stat, ch)
|
||||
c.collectBalloon(uuid, stat, ch)
|
||||
c.collectVcpu(uuid, stat, ch)
|
||||
c.collectNet(uuid, stat, ch)
|
||||
c.collectBlock(uuid, stat, ch)
|
||||
}
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) collectNova(uuid string, stat libvirt.DomainStats, ch chan<- prometheus.Metric) {
|
||||
if c.Nova {
|
||||
metadata, err := c.getNovaMetadata(stat.Domain)
|
||||
|
||||
if err != nil {
|
||||
log.Errorln(err)
|
||||
} else {
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainSeconds,
|
||||
prometheus.CounterValue,
|
||||
metadata.Seconds, uuid, metadata.Flavor.Name, metadata.User.UUID, metadata.Project.UUID,
|
||||
)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) collectState(uuid string, stat libvirt.DomainStats, ch chan<- prometheus.Metric) {
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainDomainState,
|
||||
prometheus.GaugeValue,
|
||||
float64(stat.State.State), uuid,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainDomainStateReason,
|
||||
prometheus.GaugeValue,
|
||||
float64(stat.State.Reason), uuid,
|
||||
)
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) collectCPU(uuid string, stat libvirt.DomainStats, ch chan<- prometheus.Metric) {
|
||||
if stat.Cpu != nil {
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainCPUTime,
|
||||
prometheus.CounterValue,
|
||||
float64(stat.Cpu.Time), uuid,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainCPUUser,
|
||||
prometheus.CounterValue,
|
||||
float64(stat.Cpu.User), uuid,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainCPUSystem,
|
||||
prometheus.CounterValue,
|
||||
float64(stat.Cpu.System), uuid,
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) collectBalloon(uuid string, stat libvirt.DomainStats, ch chan<- prometheus.Metric) {
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBalloonCurrent,
|
||||
prometheus.GaugeValue,
|
||||
float64(stat.Balloon.Current), uuid,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBalloonMaximum,
|
||||
prometheus.GaugeValue,
|
||||
float64(stat.Balloon.Maximum), uuid,
|
||||
)
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) collectVcpu(uuid string, stat libvirt.DomainStats, ch chan<- prometheus.Metric) {
|
||||
for vcpu, vcpuStats := range stat.Vcpu {
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainVcpuState,
|
||||
prometheus.GaugeValue,
|
||||
float64(vcpuStats.State), uuid, strconv.Itoa(vcpu),
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainVcpuTime,
|
||||
prometheus.CounterValue,
|
||||
float64(vcpuStats.Time), uuid, strconv.Itoa(vcpu),
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) collectNet(uuid string, stat libvirt.DomainStats, ch chan<- prometheus.Metric) {
|
||||
for _, netStats := range stat.Net {
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainNetRxBytes,
|
||||
prometheus.CounterValue,
|
||||
float64(netStats.RxBytes), uuid, netStats.Name,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainNetRxPkts,
|
||||
prometheus.CounterValue,
|
||||
float64(netStats.RxPkts), uuid, netStats.Name,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainNetRxErrs,
|
||||
prometheus.CounterValue,
|
||||
float64(netStats.RxErrs), uuid, netStats.Name,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainNetRxDrop,
|
||||
prometheus.CounterValue,
|
||||
float64(netStats.RxDrop), uuid, netStats.Name,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainNetTxBytes,
|
||||
prometheus.CounterValue,
|
||||
float64(netStats.TxBytes), uuid, netStats.Name,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainNetTxPkts,
|
||||
prometheus.CounterValue,
|
||||
float64(netStats.TxPkts), uuid, netStats.Name,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainNetTxErrs,
|
||||
prometheus.CounterValue,
|
||||
float64(netStats.TxErrs), uuid, netStats.Name,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainNetTxDrop,
|
||||
prometheus.GaugeValue,
|
||||
float64(netStats.TxDrop), uuid, netStats.Name,
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) collectBlock(uuid string, stat libvirt.DomainStats, ch chan<- prometheus.Metric) {
|
||||
for device, blockStats := range stat.Block {
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockRdReqs,
|
||||
prometheus.CounterValue,
|
||||
float64(blockStats.RdReqs), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockRdBytes,
|
||||
prometheus.CounterValue,
|
||||
float64(blockStats.RdBytes), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockRdTimes,
|
||||
prometheus.CounterValue,
|
||||
float64(blockStats.RdTimes), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockWrReqs,
|
||||
prometheus.CounterValue,
|
||||
float64(blockStats.RdReqs), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockWrBytes,
|
||||
prometheus.CounterValue,
|
||||
float64(blockStats.RdBytes), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockWrTimes,
|
||||
prometheus.CounterValue,
|
||||
float64(blockStats.RdTimes), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockFlReqs,
|
||||
prometheus.CounterValue,
|
||||
float64(blockStats.FlReqs), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockFlTimes,
|
||||
prometheus.CounterValue,
|
||||
float64(blockStats.FlTimes), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockAllocation,
|
||||
prometheus.GaugeValue,
|
||||
float64(blockStats.Allocation), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockCapacity,
|
||||
prometheus.GaugeValue,
|
||||
float64(blockStats.Capacity), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
ch <- prometheus.MustNewConstMetric(
|
||||
c.DomainBlockPhysical,
|
||||
prometheus.GaugeValue,
|
||||
float64(blockStats.Physical), uuid, strconv.Itoa(device), blockStats.Path,
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) getNovaMetadata(domain *libvirt.Domain) (*NovaMetadata, error) {
|
||||
data, err := domain.GetMetadata(
|
||||
libvirt.DOMAIN_METADATA_ELEMENT,
|
||||
"http://openstack.org/xmlns/libvirt/nova/1.0",
|
||||
libvirt.DOMAIN_AFFECT_LIVE,
|
||||
)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
m := &NovaMetadata{}
|
||||
err = xml.Unmarshal([]byte(data), &m)
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
// Parse creationTime from Nova format: "%Y-%m-%d %H:%M:%S"
|
||||
layout := "2006-01-02 15:04:05"
|
||||
creationTime, err := time.Parse(layout, m.CreationTime)
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
m.Seconds = time.Since(creationTime).Seconds()
|
||||
|
||||
return m, nil
|
||||
}
|
||||
|
||||
func (c *DomainStatsCollector) Close() {
|
||||
c.Connection.Close()
|
||||
}
|
||||
11
go.mod
Normal file
11
go.mod
Normal file
@ -0,0 +1,11 @@
|
||||
module opendev.org/vexxhost/libvirtd_exporter
|
||||
|
||||
go 1.13
|
||||
|
||||
require (
|
||||
github.com/libvirt/libvirt-go v5.10.0+incompatible
|
||||
github.com/prometheus/client_golang v1.0.0
|
||||
github.com/prometheus/common v0.7.0
|
||||
github.com/vexxhost/libvirtd_exporter v0.0.0-20200314024639-aa298d3ca901
|
||||
gopkg.in/alecthomas/kingpin.v2 v2.2.6
|
||||
)
|
||||
77
go.sum
Normal file
77
go.sum
Normal file
@ -0,0 +1,77 @@
|
||||
github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
|
||||
github.com/alecthomas/template v0.0.0-20190718012654-fb15b899a751 h1:JYp7IbQjafoB+tBA3gMyHYHrpOtNuDiK/uB5uXxq5wM=
|
||||
github.com/alecthomas/template v0.0.0-20190718012654-fb15b899a751/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
|
||||
github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
|
||||
github.com/alecthomas/units v0.0.0-20190717042225-c3de453c63f4 h1:Hs82Z41s6SdL1CELW+XaDYmOH4hkBN4/N9og/AsOv7E=
|
||||
github.com/alecthomas/units v0.0.0-20190717042225-c3de453c63f4/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
|
||||
github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q=
|
||||
github.com/beorn7/perks v1.0.0 h1:HWo1m869IqiPhD389kmkxeTalrjNbbJTC8LXupb+sl0=
|
||||
github.com/beorn7/perks v1.0.0/go.mod h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+CedLV8=
|
||||
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/go-kit/kit v0.8.0/go.mod h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2as=
|
||||
github.com/go-kit/kit v0.9.0/go.mod h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2as=
|
||||
github.com/go-logfmt/logfmt v0.3.0/go.mod h1:Qt1PoO58o5twSAckw1HlFXLmHsOX5/0LbT9GBnD5lWE=
|
||||
github.com/go-logfmt/logfmt v0.4.0/go.mod h1:3RMwSq7FuexP4Kalkev3ejPJsZTpXXBr9+V4qmtdjCk=
|
||||
github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
|
||||
github.com/gogo/protobuf v1.1.1/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
|
||||
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
|
||||
github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
|
||||
github.com/golang/protobuf v1.3.2 h1:6nsPYzhq5kReh6QImI3k5qWzO4PEbvbIW2cwSfR/6xs=
|
||||
github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
|
||||
github.com/json-iterator/go v1.1.6/go.mod h1:+SdeFBvtyEkXs7REEP0seUULqWtbJapLOCVDaaPEHmU=
|
||||
github.com/julienschmidt/httprouter v1.2.0/go.mod h1:SYymIcj16QtmaHHD7aYtjjsJG7VTCxuUUipMqKk8s4w=
|
||||
github.com/konsorten/go-windows-terminal-sequences v1.0.1 h1:mweAR1A6xJ3oS2pRaGiHgQ4OO8tzTaLawm8vnODuwDk=
|
||||
github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
|
||||
github.com/kr/logfmt v0.0.0-20140226030751-b84e30acd515/go.mod h1:+0opPa2QZZtGFBFZlji/RkVcI2GknAs/DXo4wKdlNEc=
|
||||
github.com/libvirt/libvirt-go v5.10.0+incompatible h1:01fwkdUHH2hk4YyFNCr48OvSGqXYLzp9cofUpeyeLNc=
|
||||
github.com/libvirt/libvirt-go v5.10.0+incompatible/go.mod h1:34zsnB4iGeOv7Byj6qotuW8Ya4v4Tr43ttjz/F0wjLE=
|
||||
github.com/matttproud/golang_protobuf_extensions v1.0.1 h1:4hp9jkHxhMHkqkrB3Ix0jegS5sx/RkqARlsWZ6pIwiU=
|
||||
github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
|
||||
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
|
||||
github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
|
||||
github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
|
||||
github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
|
||||
github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
|
||||
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
|
||||
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
|
||||
github.com/prometheus/client_golang v0.9.1/go.mod h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw=
|
||||
github.com/prometheus/client_golang v1.0.0 h1:vrDKnkGzuGvhNAL56c7DBz29ZL+KxnoR0x7enabFceM=
|
||||
github.com/prometheus/client_golang v1.0.0/go.mod h1:db9x61etRT2tGnBNRi70OPL5FsnadC4Ky3P0J6CfImo=
|
||||
github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo=
|
||||
github.com/prometheus/client_model v0.0.0-20190129233127-fd36f4220a90 h1:S/YWwWx/RA8rT8tKFRuGUZhuA90OyIBpPCXkcbwU8DE=
|
||||
github.com/prometheus/client_model v0.0.0-20190129233127-fd36f4220a90/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
|
||||
github.com/prometheus/common v0.4.1/go.mod h1:TNfzLD0ON7rHzMJeJkieUDPYmFC7Snx/y86RQel1bk4=
|
||||
github.com/prometheus/common v0.7.0 h1:L+1lyG48J1zAQXA3RBX/nG/B3gjlHq0zTt2tlbJLyCY=
|
||||
github.com/prometheus/common v0.7.0/go.mod h1:DjGbpBbp5NYNiECxcL/VnbXCCaQpKd3tt26CguLLsqA=
|
||||
github.com/prometheus/procfs v0.0.0-20181005140218-185b4288413d/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk=
|
||||
github.com/prometheus/procfs v0.0.2 h1:6LJUbpNm42llc4HRCuvApCSWB/WfhuNo9K98Q9sNGfs=
|
||||
github.com/prometheus/procfs v0.0.2/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
|
||||
github.com/sirupsen/logrus v1.2.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo=
|
||||
github.com/sirupsen/logrus v1.4.2 h1:SPIRibHv4MatM3XXNO2BJeFLZwZ2LvZgfQ5+UNI2im4=
|
||||
github.com/sirupsen/logrus v1.4.2/go.mod h1:tLMulIdttU9McNUspp0xgXVQah82FyeX6MwdIuYE2rE=
|
||||
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
|
||||
github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
|
||||
github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
|
||||
github.com/stretchr/testify v1.3.0 h1:TivCn/peBQ7UY8ooIcPgZFpTNSz0Q2U6UrFlUfqbe0Q=
|
||||
github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
|
||||
github.com/vexxhost/libvirtd_exporter v0.0.0-20200314024639-aa298d3ca901 h1:+Q2+NsO677P7tqUldcesbGpH3fhganXHSiUmdhzTQCc=
|
||||
github.com/vexxhost/libvirtd_exporter v0.0.0-20200314024639-aa298d3ca901/go.mod h1:vOV8Sa6zGZrMV8PKxz21ZbSeErrMYVviINDCov0EPto=
|
||||
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
|
||||
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
|
||||
golang.org/x/net v0.0.0-20181114220301-adae6a3d119a/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
|
||||
golang.org/x/net v0.0.0-20190613194153-d28f0bde5980/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
|
||||
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||
golang.org/x/sys v0.0.0-20181116152217-5ac8a444bdc5/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||
golang.org/x/sys v0.0.0-20190422165155-953cdadca894 h1:Cz4ceDQGXuKRnVBDTS23GTn/pU5OE2C0WrNTOYK1Uuc=
|
||||
golang.org/x/sys v0.0.0-20190422165155-953cdadca894/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
|
||||
gopkg.in/alecthomas/kingpin.v2 v2.2.6 h1:jMFz6MfLP0/4fUyZle81rXUoxOBFi19VUFKVDOQfozc=
|
||||
gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw=
|
||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||
gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
|
||||
gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
|
||||
78
libvirtd_exporter.go
Normal file
78
libvirtd_exporter.go
Normal file
@ -0,0 +1,78 @@
|
||||
// Copyright 2019 VEXXHOST, Inc.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
// See the License for the specific language governing permissions and
|
||||
// limitations under the License.
|
||||
|
||||
package main
|
||||
|
||||
import (
|
||||
"net/http"
|
||||
|
||||
"github.com/prometheus/client_golang/prometheus"
|
||||
"github.com/prometheus/client_golang/prometheus/promhttp"
|
||||
"github.com/prometheus/common/log"
|
||||
"github.com/prometheus/common/version"
|
||||
"gopkg.in/alecthomas/kingpin.v2"
|
||||
|
||||
"github.com/vexxhost/libvirtd_exporter/collectors"
|
||||
)
|
||||
|
||||
func main() {
|
||||
var (
|
||||
listenAddress = kingpin.Flag(
|
||||
"web.listen-address",
|
||||
"Address on which to expose metrics and web interface.",
|
||||
).Default(":9474").String()
|
||||
metricsPath = kingpin.Flag(
|
||||
"web.telemetry-path",
|
||||
"Path under which to expose metrics.",
|
||||
).Default("/metrics").String()
|
||||
libvirtURI = kingpin.Flag(
|
||||
"libvirt.uri",
|
||||
"Libvirt Connection URI",
|
||||
).Default("qemu:///system").String()
|
||||
libvirtNova = kingpin.Flag(
|
||||
"libvirt.nova",
|
||||
"Parse Libvirt Nova metadata",
|
||||
).Bool()
|
||||
)
|
||||
|
||||
kingpin.Version(version.Print("libvirtd_exporter"))
|
||||
kingpin.HelpFlag.Short('h')
|
||||
kingpin.Parse()
|
||||
|
||||
domainStats, err := collectors.NewDomainStatsCollector(*libvirtURI, *libvirtNova)
|
||||
if err != nil {
|
||||
log.Fatalln(err)
|
||||
}
|
||||
|
||||
prometheus.MustRegister(domainStats)
|
||||
|
||||
defer domainStats.Close()
|
||||
|
||||
http.Handle("/metrics", promhttp.Handler())
|
||||
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
|
||||
_, _ = w.Write([]byte(`<html>
|
||||
<head><title>Libvirtd Exporter</title></head>
|
||||
<body>
|
||||
<h1>Libvirtd Exporter</h1>
|
||||
<p><a href="` + *metricsPath + `">Metrics</a></p>
|
||||
<h2>Build</h2>
|
||||
<pre>` + version.Info() + ` ` + version.BuildContext() + `</pre>
|
||||
</body>
|
||||
</body>
|
||||
</html>`))
|
||||
})
|
||||
|
||||
log.Infoln("Listening on", *listenAddress)
|
||||
log.Fatal(http.ListenAndServe(*listenAddress, nil))
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user