commit ddab175c90f268b4e040fd4cd9f10ba8592101e8
Author: Mickael BOURNEUF <mickael.bourneuf@celeonet.fr>
Date:   Tue Feb 11 18:56:26 2025 +0100

    Intégration de prometheus

diff --git a/.gitgnore b/.gitgnore
new file mode 100644
index 0000000..943c67c
--- /dev/null
+++ b/.gitgnore
@@ -0,0 +1,21 @@
+# Allowlisting gitignore template for GO projects prevents us
+# from adding various unwanted local files, such as generated
+# files, developer configurations or IDE-specific files etc.
+#
+# Recommended: Go.AllowList.gitignore
+
+# Ignore everything
+*
+
+# But not these files...
+!/.gitignore
+
+!*.proto
+!*.go
+!go.sum
+!go.mod
+
+!README.md
+!LICENSE
+
+!Makefile
\ No newline at end of file
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..e69de29
diff --git a/cmd/qemu/metrics/compute.go b/cmd/qemu/metrics/compute.go
new file mode 100644
index 0000000..a4979e2
--- /dev/null
+++ b/cmd/qemu/metrics/compute.go
@@ -0,0 +1,65 @@
+package metrics
+
+import (
+	"log"
+	"strconv"
+
+	"github.com/prometheus/client_golang/prometheus"
+	"libvirt.org/go/libvirt"
+)
+
+var (
+	// Compute
+	libvirtNodeCPUUsage = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "node", "cpu_time_seconds_total"),
+		"CPU usage of node",
+		[]string{"cluster", "node", "thread"},
+		nil)
+
+	libvirtNodeMemoryUsageBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "node", "memory_usage_bytes"),
+		"Memory usage of the node, in bytes.",
+		[]string{"cluster", "node", "total"},
+		nil)
+)
+
+func CollectNode(conn *libvirt.Connect, ch chan<- prometheus.Metric, hostname string) error {
+	config, err := Config()
+	if err != nil {
+		log.Fatalf("Fail to read file: %v", err)
+	}
+
+	// Node
+	node_info, err := conn.GetNodeInfo()
+	if err != nil {
+		return err
+	}
+
+	nodeCPU, _ := conn.GetCPUStats(int(libvirt.NODE_CPU_STATS_ALL_CPUS), 0) // rate(libvirt_node_cpu_time_seconds_total[10s]) * 100
+	nodeMemory, _ := conn.GetMemoryStats(libvirt.NODE_MEMORY_STATS_ALL_CELLS, 0)
+
+	ch <- prometheus.MustNewConstMetric(
+		libvirtNodeCPUUsage,
+		prometheus.CounterValue,
+		float64(nodeCPU.Kernel+nodeCPU.User+nodeCPU.Iowait)/1e9, // From nsec to sec
+		config.Section("").Key("id").String(),
+		hostname,
+		strconv.FormatInt(int64(node_info.Sockets*node_info.Cores*node_info.Threads), 10),
+	)
+
+	ch <- prometheus.MustNewConstMetric(
+		libvirtNodeMemoryUsageBytes,
+		prometheus.GaugeValue,
+		float64(nodeMemory.Total-(nodeMemory.Buffers+nodeMemory.Free+nodeMemory.Cached))*1024,
+		config.Section("").Key("id").String(),
+		hostname,
+		strconv.FormatInt(int64(nodeMemory.Total), 10),
+	)
+
+	return nil
+}
+
+func (e *LibvirtExporter) DescribeNode(ch chan<- *prometheus.Desc) {
+	ch <- libvirtNodeCPUUsage
+	ch <- libvirtNodeMemoryUsageBytes
+}
diff --git a/cmd/qemu/metrics/domains.go b/cmd/qemu/metrics/domains.go
new file mode 100644
index 0000000..a9c730b
--- /dev/null
+++ b/cmd/qemu/metrics/domains.go
@@ -0,0 +1,739 @@
+package metrics
+
+import (
+	"encoding/xml"
+	"log"
+	"strconv"
+
+	"deevirt.fr/compute/cmd/qemu/metrics/schema"
+	"github.com/prometheus/client_golang/prometheus"
+	"gopkg.in/ini.v1"
+	"libvirt.org/go/libvirt"
+)
+
+var (
+	// Domain CPU
+	libvirtDomainInfoMaxMemBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain", "memory_maximum_allocated_bytes"),
+		"Maximum allowed memory of the domain, in bytes.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainInfoMemoryUsageBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain", "memory_allocated_bytes"),
+		"Memory usage of the domain, in bytes.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainInfoNrVirtCPU = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain", "virtual_cpus"),
+		"Number of virtual CPUs for the domain.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainInfoCPUTime = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain", "cpu_time_seconds_total"),
+		"Amount of CPU time used by the domain, in seconds.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainInfoVirDomainState = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain", "state"),
+		"Virtual domain state. 0: no state, 1: the domain is running, 2: the domain is blocked on resource,"+
+			" 3: the domain is paused by user, 4: the domain is being shut down, 5: the domain is shut off,"+
+			"6: the domain is crashed, 7: the domain is suspended by guest power management",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+
+	// VCPU
+	libvirtDomainVcpuState = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_vcpu", "state"),
+		"VCPU state. 0: offline, 1: running, 2: blocked",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "vcpu"},
+		nil)
+	libvirtDomainVcpuTime = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_vcpu", "time_seconds_total"),
+		"Amount of CPU time used by the domain's VCPU, in seconds.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "vcpu"},
+		nil)
+	libvirtDomainVcpuWait = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_vcpu", "wait_seconds_total"),
+		"Vcpu's wait_sum metric. CONFIG_SCHEDSTATS has to be enabled",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "vcpu"},
+		nil)
+	libvirtDomainVcpuDelay = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_vcpu", "delay_seconds_total"),
+		"Amount of CPU time used by the domain's VCPU, in seconds. "+
+			"Vcpu's delay metric. Time the vcpu thread was enqueued by the "+
+			"host scheduler, but was waiting in the queue instead of running. "+
+			"Exposed to the VM as a steal time.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "vcpu"},
+		nil)
+
+	// Domain Balloon
+	libvirtDomainBalloonStatCurrentBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "current_bytes"),
+		"The memory currently used (in bytes).",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainBalloonStatMaximumBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "maximum_bytes"),
+		"The maximum memory (in bytes).",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainBalloonStatSwapInBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "swap_in_bytes"),
+		"The amount of data read from swap space (in bytes).",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainBalloonStatSwapOutBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "swap_out_bytes"),
+		"The amount of memory written out to swap space (in bytes).",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainBalloonStatMajorFaultTotal = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "major_fault_total"),
+		"Page faults occur when a process makes a valid access to virtual memory that is not available. "+
+			"When servicing the page fault, if disk IO is required, it is considered a major fault.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainBalloonStatMinorFaultTotal = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "minor_fault_total"),
+		"Page faults occur when a process makes a valid access to virtual memory that is not available. "+
+			"When servicing the page not fault, if disk IO is required, it is considered a minor fault.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainBalloonStatUnusedBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "unused_bytes"),
+		"The amount of memory left completely unused by the system. Memory that is available but used for "+
+			"reclaimable caches should NOT be reported as free. This value is expressed in bytes.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainBalloonStatAvailableBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "available_bytes"),
+		"The total amount of usable memory as seen by the domain. This value may be less than the amount of "+
+			"memory assigned to the domain if a balloon driver is in use or if the guest OS does not initialize all "+
+			"assigned pages. This value is expressed in bytes.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainBalloonStatRssBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "rss_bytes"),
+		"Resident Set Size of the process running the domain. This value is in bytes",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainBalloonStatUsableBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "usable_bytes"),
+		"How much the balloon can be inflated without pushing the guest system to swap, corresponds "+
+			"to 'Available' in /proc/meminfo",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+	libvirtDomainBalloonStatDiskCachesBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_balloon", "disk_cache_bytes"),
+		"The amount of memory, that can be quickly reclaimed without additional I/O (in bytes)."+
+			"Typically these pages are used for caching files from disk.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id"},
+		nil)
+
+	// Domain Block
+	libvirtDomainBlockRdBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "read_bytes_total"),
+		"Number of bytes read from a block device, in bytes.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainBlockRdReq = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "read_requests_total"),
+		"Number of read requests from a block device.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainBlockRdTotalTimeSeconds = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "read_time_seconds_total"),
+		"Total time spent on reads from a block device, in seconds.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainBlockWrBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "write_bytes_total"),
+		"Number of bytes written to a block device, in bytes.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainBlockWrReq = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "write_requests_total"),
+		"Number of write requests to a block device.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainBlockWrTotalTimes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "write_time_seconds_total"),
+		"Total time spent on writes on a block device, in seconds",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainBlockFlushReq = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "flush_requests_total"),
+		"Total flush requests from a block device.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainBlockFlushTotalTimeSeconds = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "flush_time_seconds_total"),
+		"Total time in seconds spent on cache flushing to a block device",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainBlockAllocation = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "allocation"),
+		"Offset of the highest written sector on a block device.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainBlockCapacityBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "capacity_bytes"),
+		"Logical size in bytes of the block device	backing image.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainBlockPhysicalSizeBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_block", "physicalsize_bytes"),
+		"Physical size in bytes of the container of the backing image.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+
+	// Domain Net
+	libvirtDomainInterfaceRxBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_interface", "receive_bytes_total"),
+		"Number of bytes received on a network interface, in bytes.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainInterfaceRxPackets = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_interface", "receive_packets_total"),
+		"Number of packets received on a network interface.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainInterfaceRxErrs = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_interface", "receive_errors_total"),
+		"Number of packet receive errors on a network interface.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainInterfaceRxDrop = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_interface", "receive_drops_total"),
+		"Number of packet receive drops on a network interface.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainInterfaceTxBytes = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_interface", "transmit_bytes_total"),
+		"Number of bytes transmitted on a network interface, in bytes.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainInterfaceTxPackets = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_interface", "transmit_packets_total"),
+		"Number of packets transmitted on a network interface.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainInterfaceTxErrs = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_interface", "transmit_errors_total"),
+		"Number of packet transmit errors on a network interface.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+	libvirtDomainInterfaceTxDrop = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "domain_interface", "transmit_drops_total"),
+		"Number of packet transmit drops on a network interface.",
+		[]string{"cluster_id", "company_id", "datacenter_id", "domain_id", "target_device"},
+		nil)
+)
+
+func CollectDomain(ch chan<- prometheus.Metric, stat libvirt.DomainStats, hostname string) error {
+	config, err := Config()
+	if err != nil {
+		log.Fatalf("Fail to read file: %v", err)
+	}
+
+	domainUUID, err := stat.Domain.GetUUIDString()
+	if err != nil {
+		return err
+	}
+
+	// Decode XML description of domain to get block device names, etc.
+	xmlDesc, err := stat.Domain.GetXMLDesc(0)
+	if err != nil {
+		return err
+	}
+	var desc schema.Domain
+	err = xml.Unmarshal([]byte(xmlDesc), &desc)
+	if err != nil {
+		return err
+	}
+
+	// Report domain info.
+	info, err := stat.Domain.GetInfo()
+	if err != nil {
+		return err
+	}
+
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainInfoMaxMemBytes,
+		prometheus.GaugeValue,
+		float64(info.MaxMem)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainInfoMemoryUsageBytes,
+		prometheus.GaugeValue,
+		float64(info.Memory)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainInfoNrVirtCPU,
+		prometheus.GaugeValue,
+		float64(info.NrVirtCpu),
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainInfoCPUTime,
+		prometheus.CounterValue,
+		float64(info.CpuTime)/1e9, // From nsec to sec
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainInfoVirDomainState,
+		prometheus.GaugeValue,
+		float64(info.State),
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+
+	// Block Stats
+	CollectDomainVCPU(ch, stat.Vcpu, hostname, domainUUID, config, desc)
+	CollectDomainBlock(ch, stat.Block, hostname, domainUUID, config, desc)
+	CollectDomainNet(ch, stat.Net, hostname, domainUUID, config, desc)
+	CollectDomainBalloon(ch, stat.Balloon, hostname, domainUUID, config, desc)
+
+	return nil
+}
+
+func CollectDomainVCPU(ch chan<- prometheus.Metric, stat []libvirt.DomainStatsVcpu, hostname string, domainUUID string, config *ini.File, desc schema.Domain) {
+	for idx, vcpu := range stat {
+		ch <- prometheus.MustNewConstMetric(
+			libvirtDomainVcpuState,
+			prometheus.GaugeValue,
+			float64(vcpu.State),
+			config.Section("").Key("id").String(),
+			desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+			desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+			domainUUID,
+			strconv.FormatInt(int64(idx), 10))
+		ch <- prometheus.MustNewConstMetric(
+			libvirtDomainVcpuTime,
+			prometheus.CounterValue,
+			float64(vcpu.Time)/1000/1000/1000, // From nsec to sec
+			config.Section("").Key("id").String(),
+			desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+			desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+			domainUUID,
+			strconv.FormatInt(int64(idx), 10))
+		ch <- prometheus.MustNewConstMetric(
+			libvirtDomainVcpuWait,
+			prometheus.CounterValue,
+			float64(vcpu.Wait)/1e9, // From nsec to sec
+			config.Section("").Key("id").String(),
+			desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+			desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+			domainUUID,
+			strconv.FormatInt(int64(idx), 10))
+		ch <- prometheus.MustNewConstMetric(
+			libvirtDomainVcpuDelay,
+			prometheus.CounterValue,
+			float64(vcpu.Delay)/1e9, // From nsec to sec
+			config.Section("").Key("id").String(),
+			desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+			desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+			domainUUID,
+			strconv.FormatInt(int64(idx), 10))
+
+	}
+}
+
+func CollectDomainBalloon(ch chan<- prometheus.Metric, stat *libvirt.DomainStatsBalloon, hostname string, domainUUID string, config *ini.File, desc schema.Domain) {
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatCurrentBytes,
+		prometheus.GaugeValue,
+		float64(stat.Current)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatMaximumBytes,
+		prometheus.GaugeValue,
+		float64(stat.Maximum)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatSwapInBytes,
+		prometheus.GaugeValue,
+		float64(stat.SwapIn)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatSwapOutBytes,
+		prometheus.GaugeValue,
+		float64(stat.SwapOut)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatMajorFaultTotal,
+		prometheus.CounterValue,
+		float64(stat.MajorFault),
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatMinorFaultTotal,
+		prometheus.CounterValue,
+		float64(stat.MinorFault),
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatUnusedBytes,
+		prometheus.GaugeValue,
+		float64(stat.Unused)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatAvailableBytes,
+		prometheus.GaugeValue,
+		float64(stat.Available)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatRssBytes,
+		prometheus.GaugeValue,
+		float64(stat.Rss)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatUsableBytes,
+		prometheus.GaugeValue,
+		float64(stat.Usable)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+	ch <- prometheus.MustNewConstMetric(
+		libvirtDomainBalloonStatDiskCachesBytes,
+		prometheus.GaugeValue,
+		float64(stat.DiskCaches)*1024,
+		config.Section("").Key("id").String(),
+		desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+		desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+		domainUUID)
+
+}
+
+func CollectDomainBlock(ch chan<- prometheus.Metric, stat []libvirt.DomainStatsBlock, hostname string, domainUUID string, config *ini.File, desc schema.Domain) {
+	for _, block := range stat {
+
+		if block.RdBytesSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockRdBytes,
+				prometheus.CounterValue,
+				float64(block.RdBytes),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+		if block.RdReqsSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockRdReq,
+				prometheus.CounterValue,
+				float64(block.RdReqs),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+		if block.RdTimesSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockRdTotalTimeSeconds,
+				prometheus.CounterValue,
+				float64(block.RdTimes)/1e9,
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+		if block.WrBytesSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockWrBytes,
+				prometheus.CounterValue,
+				float64(block.WrBytes),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+		if block.WrReqsSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockWrReq,
+				prometheus.CounterValue,
+				float64(block.WrReqs),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+		if block.WrTimesSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockWrTotalTimes,
+				prometheus.CounterValue,
+				float64(block.WrTimes)/1e9,
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+		if block.FlReqsSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockFlushReq,
+				prometheus.CounterValue,
+				float64(block.FlReqs),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+		if block.FlTimesSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockFlushTotalTimeSeconds,
+				prometheus.CounterValue,
+				float64(block.FlTimes)/1e9,
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+		if block.AllocationSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockAllocation,
+				prometheus.GaugeValue,
+				float64(block.Allocation),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+		if block.CapacitySet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockCapacityBytes,
+				prometheus.GaugeValue,
+				float64(block.Capacity),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+		if block.PhysicalSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainBlockPhysicalSizeBytes,
+				prometheus.GaugeValue,
+				float64(block.Physical),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				block.Name)
+		}
+	}
+}
+
+func CollectDomainNet(ch chan<- prometheus.Metric, stat []libvirt.DomainStatsNet, hostname string, domainUUID string, config *ini.File, desc schema.Domain) {
+	for _, iface := range stat {
+
+		if iface.RxBytesSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainInterfaceRxBytes,
+				prometheus.CounterValue,
+				float64(iface.RxBytes),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				iface.Name)
+		}
+		if iface.RxPktsSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainInterfaceRxPackets,
+				prometheus.CounterValue,
+				float64(iface.RxPkts),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				iface.Name)
+		}
+		if iface.RxErrsSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainInterfaceRxErrs,
+				prometheus.CounterValue,
+				float64(iface.RxErrs),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				iface.Name)
+		}
+		if iface.RxDropSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainInterfaceRxDrop,
+				prometheus.CounterValue,
+				float64(iface.RxDrop),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				iface.Name)
+		}
+		if iface.TxBytesSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainInterfaceTxBytes,
+				prometheus.CounterValue,
+				float64(iface.TxBytes),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				iface.Name)
+		}
+		if iface.TxPktsSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainInterfaceTxPackets,
+				prometheus.CounterValue,
+				float64(iface.TxPkts),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				iface.Name)
+		}
+		if iface.TxErrsSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainInterfaceTxErrs,
+				prometheus.CounterValue,
+				float64(iface.TxErrs),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				iface.Name)
+		}
+		if iface.TxDropSet {
+			ch <- prometheus.MustNewConstMetric(
+				libvirtDomainInterfaceTxDrop,
+				prometheus.CounterValue,
+				float64(iface.TxDrop),
+				config.Section("").Key("id").String(),
+				desc.Metadata.DeevirtInstance.DeevirtCompanyID,
+				desc.Metadata.DeevirtInstance.DeevirtDatacenterID,
+				domainUUID,
+				iface.Name)
+		}
+	}
+}
+
+func CollectDomains(conn *libvirt.Connect, ch chan<- prometheus.Metric, hostname string) error {
+
+	stats, err := conn.GetAllDomainStats([]*libvirt.Domain{},
+		libvirt.DOMAIN_STATS_STATE|libvirt.DOMAIN_STATS_CPU_TOTAL|libvirt.DOMAIN_STATS_BALLOON|
+			libvirt.DOMAIN_STATS_VCPU|libvirt.DOMAIN_STATS_BLOCK|libvirt.DOMAIN_STATS_INTERFACE,
+		libvirt.CONNECT_GET_ALL_DOMAINS_STATS_RUNNING|libvirt.CONNECT_GET_ALL_DOMAINS_STATS_SHUTOFF)
+	defer func(stats []libvirt.DomainStats) {
+		for _, stat := range stats {
+			stat.Domain.Free()
+		}
+	}(stats)
+	if err != nil {
+		return err
+	}
+	for _, stat := range stats {
+		err = CollectDomain(ch, stat, hostname)
+		if err != nil {
+			log.Printf("Failed to scrape metrics: %s", err)
+		}
+	}
+
+	return nil
+}
+
+func (e *LibvirtExporter) DescribeDomains(ch chan<- *prometheus.Desc) {
+	// Domain info
+	ch <- libvirtDomainInfoMaxMemBytes
+	ch <- libvirtDomainInfoMemoryUsageBytes
+	ch <- libvirtDomainInfoNrVirtCPU
+	ch <- libvirtDomainInfoCPUTime
+	ch <- libvirtDomainInfoVirDomainState
+
+	// VCPU info
+	ch <- libvirtDomainVcpuState
+	ch <- libvirtDomainVcpuTime
+	ch <- libvirtDomainVcpuWait
+	ch <- libvirtDomainVcpuDelay
+
+	// Domain Balloon Memory
+	ch <- libvirtDomainBalloonStatCurrentBytes
+	ch <- libvirtDomainBalloonStatMaximumBytes
+	ch <- libvirtDomainBalloonStatSwapInBytes
+	ch <- libvirtDomainBalloonStatSwapOutBytes
+	ch <- libvirtDomainBalloonStatMajorFaultTotal
+	ch <- libvirtDomainBalloonStatMinorFaultTotal
+	ch <- libvirtDomainBalloonStatUnusedBytes
+	ch <- libvirtDomainBalloonStatAvailableBytes
+	ch <- libvirtDomainBalloonStatRssBytes
+	ch <- libvirtDomainBalloonStatUsableBytes
+	ch <- libvirtDomainBalloonStatDiskCachesBytes
+
+	// Domain block stats
+	ch <- libvirtDomainBlockRdBytes
+	ch <- libvirtDomainBlockRdReq
+	ch <- libvirtDomainBlockRdTotalTimeSeconds
+	ch <- libvirtDomainBlockWrBytes
+	ch <- libvirtDomainBlockWrReq
+	ch <- libvirtDomainBlockWrTotalTimes
+	ch <- libvirtDomainBlockFlushReq
+	ch <- libvirtDomainBlockFlushTotalTimeSeconds
+	ch <- libvirtDomainBlockAllocation
+	ch <- libvirtDomainBlockCapacityBytes
+	ch <- libvirtDomainBlockPhysicalSizeBytes
+
+	// Domain net interfaces stats
+	ch <- libvirtDomainInterfaceRxBytes
+	ch <- libvirtDomainInterfaceRxPackets
+	ch <- libvirtDomainInterfaceRxErrs
+	ch <- libvirtDomainInterfaceRxDrop
+	ch <- libvirtDomainInterfaceTxBytes
+	ch <- libvirtDomainInterfaceTxPackets
+	ch <- libvirtDomainInterfaceTxErrs
+	ch <- libvirtDomainInterfaceTxDrop
+}
diff --git a/cmd/qemu/metrics/schema/domain.go b/cmd/qemu/metrics/schema/domain.go
new file mode 100644
index 0000000..6e6bdf8
--- /dev/null
+++ b/cmd/qemu/metrics/schema/domain.go
@@ -0,0 +1,92 @@
+package schema
+
+type Domain struct {
+	Devices  Devices  `xml:"devices"`
+	Metadata Metadata `xml:"metadata"`
+}
+
+type Metadata struct {
+	DeevirtInstance Instance `xml:"instance"`
+}
+
+type Instance struct {
+	DeevirtCompanyID    string `xml:"company_id"`
+	DeevirtDatacenterID string `xml:"datacenter_id"`
+}
+
+type User struct {
+	UserName string `xml:",chardata"`
+	UserUUID string `xml:"uuid,attr"`
+}
+
+type Project struct {
+	ProjectName string `xml:",chardata"`
+	ProjectUUID string `xml:"uuid,attr"`
+}
+
+type Root struct {
+	RootType string `xml:"type,attr"`
+	RootUUID string `xml:"uuid,attr"`
+}
+
+type Devices struct {
+	Disks      []Disk      `xml:"disk"`
+	Interfaces []Interface `xml:"interface"`
+}
+
+type Disk struct {
+	Device   string     `xml:"device,attr"`
+	Driver   DiskDriver `xml:"driver"`
+	Source   DiskSource `xml:"source"`
+	Target   DiskTarget `xml:"target"`
+	DiskType string     `xml:"type,attr"`
+	Serial   string     `xml:"serial"`
+}
+
+type DiskDriver struct {
+	Type    string `xml:"type,attr"`
+	Cache   string `xml:"cache,attr"`
+	Discard string `xml:"discard,attr"`
+}
+
+type DiskSource struct {
+	File string `xml:"file,attr"`
+	Name string `xml:"name,attr"`
+}
+
+type DiskTarget struct {
+	Device string `xml:"dev,attr"`
+	Bus    string `xml:"bus,attr"`
+}
+
+type Interface struct {
+	Source      InterfaceSource      `xml:"source"`
+	Target      InterfaceTarget      `xml:"target"`
+	Virtualport InterfaceVirtualPort `xml:"virtualport"`
+}
+
+type InterfaceVirtualPort struct {
+	Parameters InterfaceVirtualPortParam `xml:"parameters"`
+}
+type InterfaceVirtualPortParam struct {
+	InterfaceID string `xml:"interfaceid,attr"`
+}
+
+type InterfaceSource struct {
+	Bridge string `xml:"bridge,attr"`
+}
+
+type InterfaceTarget struct {
+	Device string `xml:"dev,attr"`
+}
+
+type VirDomainMemoryStats struct {
+	MajorFault    uint64
+	MinorFault    uint64
+	Unused        uint64
+	Available     uint64
+	ActualBalloon uint64
+	Rss           uint64
+	Usable        uint64
+	DiskCaches    uint64
+}
diff --git a/cmd/qemu/metrics/server.go b/cmd/qemu/metrics/server.go
new file mode 100644
index 0000000..41f7c9a
--- /dev/null
+++ b/cmd/qemu/metrics/server.go
@@ -0,0 +1,150 @@
+package metrics
+
+import (
+	"net/http"
+
+	"fmt"
+	"log"
+
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/prometheus/client_golang/prometheus/promhttp"
+	"gopkg.in/ini.v1"
+	"libvirt.org/go/libvirt"
+)
+
+var (
+	Version = ""
+
+	libvirtUpDesc = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "", "up"),
+		"Whether scraping libvirt's metrics was successful.",
+		nil,
+		nil)
+	libvirtVersionsInfoDesc = prometheus.NewDesc(
+		prometheus.BuildFQName("libvirt", "", "versions_info"),
+		"Versions of virtualization components",
+		[]string{"hypervisor_running", "libvirtd_running", "libvirt_library"},
+		nil)
+
+	errorsMap map[string]struct{}
+)
+
+func Config() (*ini.File, error) {
+	return ini.Load("/etc/deevirt/config.ini")
+}
+
+// WriteErrorOnce writes message to stdout only once
+// for the error
+// "err" - an error message
+// "name" - name of an error, to count it
+func WriteErrorOnce(err string, name string) {
+	if _, ok := errorsMap[name]; !ok {
+		log.Printf("%s", err)
+		errorsMap[name] = struct{}{}
+	}
+}
+
+// CollectFromLibvirt obtains Prometheus metrics from all domains in a
+// libvirt setup.
+func CollectFromLibvirt(ch chan<- prometheus.Metric, uri string) error {
+	conn, err := libvirt.NewConnect(uri)
+	if err != nil {
+		return err
+	}
+	defer conn.Close()
+
+	hostname, err := conn.GetHostname()
+	if err != nil {
+		return err
+	}
+
+	hypervisorVersionNum, err := conn.GetVersion() // virConnectGetVersion, hypervisor running, e.g. QEMU
+	if err != nil {
+		return err
+	}
+	hypervisorVersion := fmt.Sprintf("%d.%d.%d", hypervisorVersionNum/1000000%1000, hypervisorVersionNum/1000%1000, hypervisorVersionNum%1000)
+
+	libvirtdVersionNum, err := conn.GetLibVersion() // virConnectGetLibVersion, libvirt daemon running
+	if err != nil {
+		return err
+	}
+	libvirtdVersion := fmt.Sprintf("%d.%d.%d", libvirtdVersionNum/1000000%1000, libvirtdVersionNum/1000%1000, libvirtdVersionNum%1000)
+
+	libraryVersionNum, err := libvirt.GetVersion() // virGetVersion, version of libvirt (dynamic) library used by this binary (exporter), not the daemon version
+	if err != nil {
+		return err
+	}
+	libraryVersion := fmt.Sprintf("%d.%d.%d", libraryVersionNum/1000000%1000, libraryVersionNum/1000%1000, libraryVersionNum%1000)
+
+	ch <- prometheus.MustNewConstMetric(
+		libvirtVersionsInfoDesc,
+		prometheus.GaugeValue,
+		1.0,
+		hypervisorVersion,
+		libvirtdVersion,
+		libraryVersion)
+
+	CollectNode(conn, ch, hostname)
+	CollectDomains(conn, ch, hostname)
+
+	return nil
+}
+
+// LibvirtExporter implements a Prometheus exporter for libvirt state.
+type LibvirtExporter struct {
+	uri string
+}
+
+// NewLibvirtExporter creates a new Prometheus exporter for libvirt.
+func NewLibvirtExporter(uri string) (*LibvirtExporter, error) {
+	return &LibvirtExporter{
+		uri: uri,
+	}, nil
+}
+
+// Describe returns metadata for all Prometheus metrics that may be exported.
+func (e *LibvirtExporter) Describe(ch chan<- *prometheus.Desc) {
+	// Status and versions
+	ch <- libvirtUpDesc
+	e.DescribeNode(ch)
+	e.DescribeDomains(ch)
+}
+
+// Collect scrapes Prometheus metrics from libvirt.
+func (e *LibvirtExporter) Collect(ch chan<- prometheus.Metric) {
+	err := CollectFromLibvirt(ch, e.uri)
+	if err == nil {
+		ch <- prometheus.MustNewConstMetric(
+			libvirtUpDesc,
+			prometheus.GaugeValue,
+			1.0)
+	} else {
+		log.Printf("Failed to scrape metrics: %s", err)
+		ch <- prometheus.MustNewConstMetric(
+			libvirtUpDesc,
+			prometheus.GaugeValue,
+			0.0)
+	}
+}
+
+func Server(c *libvirt.Connect) {
+	exporter, err := NewLibvirtExporter("qemu:///system")
+	if err != nil {
+		panic(err)
+	}
+
+	prometheus.MustRegister(exporter)
+
+	http.Handle("/metrics", promhttp.Handler())
+	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
+		w.Write([]byte(`
+			<html>
+			<head><title>Libvirt Exporter</title></head>
+			<body>
+			<h1>Libvirt Exporter</h1>
+			<p><a href='/metrics'>Metrics</a></p>
+			</body>
+			</html>`))
+	})
+	log.Fatal(http.ListenAndServe(":9177", nil))
+}
diff --git a/cmd/qemu/qemu.go b/cmd/qemu/qemu.go
new file mode 100644
index 0000000..159743b
--- /dev/null
+++ b/cmd/qemu/qemu.go
@@ -0,0 +1,32 @@
+package main
+
+import (
+	"log"
+	"os"
+
+	"deevirt.fr/compute/cmd/qemu/metrics"
+	"libvirt.org/go/libvirt"
+)
+
+func main() {
+	err := libvirt.EventRegisterDefaultImpl()
+	if err != nil {
+		log.Fatalf("Échec d'EventRegisterDefaultImpl: %v", err)
+		os.Exit(0)
+	}
+
+	conn, err := libvirt.NewConnect("qemu:///system")
+	if err != nil {
+		log.Println("Connexion Error")
+	}
+	defer conn.Close()
+
+	conn.SetKeepAlive(5, 3)
+
+	go metrics.Server(conn)
+	//go app.NewDomainsMonitor(conn)
+
+	for {
+		libvirt.EventRunDefaultImpl()
+	}
+}
diff --git a/go.mod b/go.mod
new file mode 100644
index 0000000..79a2a5f
--- /dev/null
+++ b/go.mod
@@ -0,0 +1,20 @@
+module deevirt.fr/compute
+
+go 1.22.9
+
+require (
+	github.com/beorn7/perks v1.0.1 // indirect
+	github.com/cespare/xxhash/v2 v2.3.0 // indirect
+	github.com/denisbrodbeck/machineid v1.0.1 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/klauspost/compress v1.17.9 // indirect
+	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
+	github.com/prometheus/client_golang v1.20.5 // indirect
+	github.com/prometheus/client_model v0.6.1 // indirect
+	github.com/prometheus/common v0.55.0 // indirect
+	github.com/prometheus/procfs v0.15.1 // indirect
+	golang.org/x/sys v0.22.0 // indirect
+	google.golang.org/protobuf v1.34.2 // indirect
+	gopkg.in/ini.v1 v1.67.0 // indirect
+	libvirt.org/go/libvirt v1.11001.0 // indirect
+)
diff --git a/go.sum b/go.sum
new file mode 100644
index 0000000..d2317a6
--- /dev/null
+++ b/go.sum
@@ -0,0 +1,28 @@
+github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=
+github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/denisbrodbeck/machineid v1.0.1 h1:geKr9qtkB876mXguW2X6TU4ZynleN6ezuMSRhl4D7AQ=
+github.com/denisbrodbeck/machineid v1.0.1/go.mod h1:dJUwb7PTidGDeYyUBmXZ2GphQBbjJCrnectwCyxcUSI=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/klauspost/compress v1.17.9 h1:6KIumPrER1LHsvBVuDa0r5xaG0Es51mhhB9BQB2qeMA=
+github.com/klauspost/compress v1.17.9/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw=
+github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA=
+github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ=
+github.com/prometheus/client_golang v1.20.5 h1:cxppBPuYhUnsO6yo/aoRol4L7q7UFfdm+bR9r+8l63Y=
+github.com/prometheus/client_golang v1.20.5/go.mod h1:PIEt8X02hGcP8JWbeHyeZ53Y/jReSnHgO035n//V5WE=
+github.com/prometheus/client_model v0.6.1 h1:ZKSh/rekM+n3CeS952MLRAdFwIKqeY8b62p8ais2e9E=
+github.com/prometheus/client_model v0.6.1/go.mod h1:OrxVMOVHjw3lKMa8+x6HeMGkHMQyHDk9E3jmP2AmGiY=
+github.com/prometheus/common v0.55.0 h1:KEi6DK7lXW/m7Ig5i47x0vRzuBsHuvJdi5ee6Y3G1dc=
+github.com/prometheus/common v0.55.0/go.mod h1:2SECS4xJG1kd8XF9IcM1gMX6510RAEL65zxzNImwdc8=
+github.com/prometheus/procfs v0.15.1 h1:YagwOFzUgYfKKHX6Dr+sHT7km/hxC76UB0learggepc=
+github.com/prometheus/procfs v0.15.1/go.mod h1:fB45yRUv8NstnjriLhBQLuOUt+WW4BsoGhij/e3PBqk=
+golang.org/x/sys v0.22.0 h1:RI27ohtqKCnwULzJLqkv897zojh5/DwS/ENaMzUOaWI=
+golang.org/x/sys v0.22.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+google.golang.org/protobuf v1.34.2 h1:6xV6lTsCfpGD21XK49h7MhtcApnLqkfYgPcdHftf6hg=
+google.golang.org/protobuf v1.34.2/go.mod h1:qYOHts0dSfpeUzUFpOMr/WGzszTmLH+DiWniOlNbLDw=
+gopkg.in/ini.v1 v1.67.0 h1:Dgnx+6+nfE+IfzjUEISNeydPJh9AXNNsWbGP9KzCsOA=
+gopkg.in/ini.v1 v1.67.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
+libvirt.org/go/libvirt v1.11001.0 h1:QJgpslxY7qkpXZIDxdMHpkDl7FfhgQJwqRTGBbg/S8E=
+libvirt.org/go/libvirt v1.11001.0/go.mod h1:1WiFE8EjZfq+FCVog+rvr1yatKbKZ9FaFMZgEqxEJqQ=