History

Chris Goller d5a60cf2dd fix(scraper): remove enriched type label Scraping was enriching the tag set by adding the prometheus data type in the tag key name, "type." If a scraped metric already had the tag, "type," then this would cause errors far away from problem in flux. Co-authored-by: Kelvin Wang <sherkrainwang@gmail.com>		2019-01-17 10:22:22 -06:00
..
README.md	add(gather): add writer interface	2019-01-11 13:09:18 -05:00
handler.go	add(gather): add writer interface	2019-01-11 13:09:18 -05:00
metrics.go	fix(scraper): remove enriched type label	2019-01-17 10:22:22 -06:00
metrics_test.go	fix(scraper): remove enriched type label	2019-01-17 10:22:22 -06:00
prometheus.go	add(gather): add writer interface	2019-01-11 13:09:18 -05:00
recorder.go	add(gather): add writer interface	2019-01-11 13:09:18 -05:00
scheduler.go	add(gather): add writer interface	2019-01-11 13:09:18 -05:00
scheduler_test.go	add(gather): add writer interface	2019-01-11 13:09:18 -05:00
scraper.go	add(gather): add writer interface	2019-01-11 13:09:18 -05:00
scraper_test.go	add(gather): add writer interface	2019-01-11 13:09:18 -05:00

README.md

How to use this package

Make sure nats is running. Both publisher and subscriber are open

// NATS streaming server
m.natsServer = nats.NewServer(nats.Config{FilestoreDir: m.natsPath})
if err := m.natsServer.Open(); err != nil {
    m.logger.Error("failed to start nats streaming server", zap.Error(err))
    return err
}

publisher := nats.NewAsyncPublisher("nats-publisher")
if err := publisher.Open(); err != nil {
    m.logger.Error("failed to connect to streaming server", zap.Error(err))
    return err
}

subscriber := nats.NewQueueSubscriber("nats-subscriber")
if err := subscriber.Open(); err != nil {
    m.logger.Error("failed to connect to streaming server", zap.Error(err))
    return err
}

Make sure the scraperTargetStorageService is accessible

scraperTargetSvc influxdb.ScraperTargetStoreService = m.boltClient

Setup recorder, Make sure subscriber subscribes use the correct recorder with the correct write service

recorder := gather.PlatformWriter{
    Timeout: time.Millisecond * 30,
    Writer: writer,
}
subscriber.Subscribe(MetricsSubject, "", &RecorderHandler{
    Logger:   logger,
    Recorder: recorder,
})

Start the scheduler

scraperScheduler, err := gather.NewScheduler(10, m.logger, scraperTargetSvc, publisher, subscriber, 0, 0)
if err != nil {
    m.logger.Error("failed to create scraper subscriber", zap.Error(err))
    return err
}