88 lines
1.4 KiB
Go
88 lines
1.4 KiB
Go
package main
|
|
|
|
import (
|
|
"flag"
|
|
"log"
|
|
"os"
|
|
"os/signal"
|
|
"strings"
|
|
|
|
"github.com/influxdb/tivan"
|
|
_ "github.com/influxdb/tivan/plugins/all"
|
|
)
|
|
|
|
var fDebug = flag.Bool("debug", false, "show metrics as they're generated to stdout")
|
|
var fTest = flag.Bool("test", false, "gather metrics, print them out, and exit")
|
|
var fConfig = flag.String("config", "", "configuration file to load")
|
|
|
|
func main() {
|
|
flag.Parse()
|
|
|
|
var (
|
|
config *tivan.Config
|
|
err error
|
|
)
|
|
|
|
if *fConfig != "" {
|
|
config, err = tivan.LoadConfig(*fConfig)
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
} else {
|
|
config = tivan.DefaultConfig()
|
|
}
|
|
|
|
ag, err := tivan.NewAgent(config)
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
|
|
if *fDebug {
|
|
ag.Debug = true
|
|
}
|
|
|
|
plugins, err := ag.LoadPlugins()
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
|
|
if *fTest {
|
|
err = ag.Test()
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
err = ag.Connect()
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
|
|
shutdown := make(chan struct{})
|
|
|
|
signals := make(chan os.Signal)
|
|
|
|
signal.Notify(signals, os.Interrupt)
|
|
|
|
go func() {
|
|
<-signals
|
|
close(shutdown)
|
|
}()
|
|
|
|
log.Print("InfluxDB Agent running")
|
|
log.Printf("Loaded plugins: %s", strings.Join(plugins, " "))
|
|
if ag.Debug {
|
|
log.Printf("Debug: enabled")
|
|
log.Printf("Agent Config: %#v", ag)
|
|
}
|
|
|
|
if config.URL != "" {
|
|
log.Printf("Sending metrics to: %s", config.URL)
|
|
log.Printf("Tags enabled: %v", config.ListTags())
|
|
}
|
|
|
|
ag.Run(shutdown)
|
|
}
|