Support InfluxDB clusters

Closes #143
This commit is contained in:
Cameron Sparr
2015-09-09 15:56:10 -06:00
parent a7ed46160a
commit 3c7c8926fb
4 changed files with 78 additions and 27 deletions

View File

@@ -84,6 +84,9 @@ func NewAgent(config *Config) (*Agent, error) {
// Connect connects to all configured outputs
func (a *Agent) Connect() error {
for _, o := range a.outputs {
if a.Debug {
log.Printf("Attempting connection to output: %s\n", o.name)
}
err := o.output.Connect()
if err != nil {
return err