Consul disvocery.go refactoring

consul/discovery.go

@@ -80,19 +80,17 @@ func (s *Service) Register() error {
 	go func(s *Service) { // startup register
 		ticker := time.NewTicker(time.Millisecond * 100)
 		for range ticker.C {
-			ok, _ := s.healthCheck()
+			if ok, _ := s.healthCheck(); ok {
-			if ok {
 				ticker.Stop()
 			}
 		}
 	}(s)
 
 	go func(s *Service) { // TTL
-		interval := s.ttl - time.Second*2
+		interval := s.ttl - time.Second*2 // 2 seconds overhead
 		ticker := time.NewTicker(interval)
 		for range ticker.C {
-			_, err := s.healthCheck()
+			if _, err := s.healthCheck(); err != nil {
-			if err != nil {
 				fmt.Printf("TTL Error: %v\n", err)
 			}
 		}

fluentd/config.go

@@ -10,7 +10,7 @@ func ParseAddr(addr string) (string, int, error) {
 	fHost := p[0]
 	fPort, err := strconv.Atoi(p[1])
 	if err != nil {
-		return nil, nil, err
+		return "", 0, err
 	}
 
 	return fHost, fPort, nil