Function NewMetricsCollector

pkg/collector/metrics_collector.go:14–18

()

}

func NewMetricsCollector() *MetricsCollector {
	return &MetricsCollector{
		totalValue: atomic.NewUint64(0),
	}
}

// Add adds new bytes read to TotalValue. this method is thread safe and
// satisfies the common.MetricsCallback type so it's used as callback at a lot of places