Documentation
¶
Index ¶
Constants ¶
View Source
const CollectionTimeout = 10 * time.Second // "long enough", crude heuristic
View Source
const StatsMaxAge = CollectionTimeout + 2*time.Second // "a bit more" than timeout, heuristic again
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Collector ¶
type Collector interface {
Collect(vmis []*k6tv1.VirtualMachineInstance, scraper MetricsScraper, timeout time.Duration) (skipped []string, completed bool)
}
func NewConcurrentCollector ¶
func NewConcurrentCollectorWithMapper ¶
func NewConcurrentCollectorWithMapper(MaxRequestsPerKey int, mapper func(vmis []*k6tv1.VirtualMachineInstance) vmiSocketMap) Collector
type ConcurrentCollector ¶
type ConcurrentCollector struct {
// contains filtered or unexported fields
}
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) Complete() }
Click to show internal directories.
Click to hide internal directories.