prometheus

Documentation

Index

• Constants
• func Handler(MaxRequestsInFlight int) http.Handler
• func NewPrometheusScraper(ch chan<- prometheus.Metric) *prometheusScraper
• type DomainStatsCollector
  • func SetupDomainStatsCollector(virtCli kubecli.KubevirtClient, virtShareDir, nodeName string, ...) *DomainStatsCollector
  • func (co *DomainStatsCollector) Collect(ch chan<- prometheus.Metric)
  • func (co *DomainStatsCollector) Describe(_ chan<- *prometheus.Desc)

Constants

const (
	PrometheusCollectionTimeout            = vms.CollectionTimeout
	MigrateVmiDataRemainingMetricName      = "kubevirt_migrate_vmi_data_remaining_bytes"
	MigrateVmiDataProcessedMetricName      = "kubevirt_migrate_vmi_data_processed_bytes"
	MigrateVmiDirtyMemoryRateMetricName    = "kubevirt_migrate_vmi_dirty_memory_rate_bytes"
	MigrateVmiMemoryTransferRateMetricName = "kubevirt_migrate_vmi_memory_transfer_rate_bytes"
	MigrateVmiDiskTransferRateMetricName   = "kubevirt_migrate_vmi_disk_transfer_rate_bytes"
)

Functions

func Handler

func Handler(MaxRequestsInFlight int) http.Handler

func NewPrometheusScraper

func NewPrometheusScraper(ch chan<- prometheus.Metric) *prometheusScraper

Types

type DomainStatsCollector

type DomainStatsCollector struct {
	// contains filtered or unexported fields
}

func SetupDomainStatsCollector

func SetupDomainStatsCollector(virtCli kubecli.KubevirtClient, virtShareDir, nodeName string, MaxRequestsInFlight int, vmiInformer cache.SharedIndexInformer) *DomainStatsCollector

aggregates to virt-launcher

func (*DomainStatsCollector) Collect

func (co *DomainStatsCollector) Collect(ch chan<- prometheus.Metric)

Note that Collect could be called concurrently

func (*DomainStatsCollector) Describe

func (co *DomainStatsCollector) Describe(_ chan<- *prometheus.Desc)