vms

Documentation

Index

• Constants
• type Collector
• type ConcurrentCollector
  • func NewConcurrentCollector(MaxRequestsPerKey int) *ConcurrentCollector
  • func (cc *ConcurrentCollector) Collect(vmis []*k6tv1.VirtualMachineInstance, scraper MetricsScraper, ...) ([]string, bool)
• type MetricsScraper

Constants

const CollectionTimeout = 10 * time.Second // "long enough", crude heuristic

const StatsMaxAge = CollectionTimeout + 2*time.Second // "a bit more" than timeout, heuristic again

Types

type Collector

type Collector interface {
	Scrape(key string, vmi *k6tv1.VirtualMachineInstance)
	Collect(vmis []*k6tv1.VirtualMachineInstance, scraper MetricsScraper, timeout time.Duration) (skipped []string, completed bool)
}

type ConcurrentCollector

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

func NewConcurrentCollector

func NewConcurrentCollector(MaxRequestsPerKey int) *ConcurrentCollector

func (*ConcurrentCollector) Collect

func (cc *ConcurrentCollector) Collect(vmis []*k6tv1.VirtualMachineInstance, scraper MetricsScraper, timeout time.Duration) ([]string, bool)

type MetricsScraper

type MetricsScraper interface {
	Scrape(key string, vmi *k6tv1.VirtualMachineInstance)
}