update

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 {
+			if ok, _ := s.healthCheck(); 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 != nil {
+			if _, err := s.healthCheck(); err != nil {
 				fmt.Printf("TTL Error: %v\n", err)
 			}
 		}
@@ -156,6 +154,7 @@ func (s *Service) getTags() []string {
 		"traefik.http.services." + s.Name + ".loadbalancer.server.port=" + strconv.Itoa(s.port),
 		"traefik.http.services." + s.Name + ".loadbalancer.passhostheader=false",
 		"traefik.http.middlewares.auth.forwardauth.address=http://identity-svc/api/v1/traefik",
+		"traefik.http.middlewares.auth.forwardauth.authRequestHeaders=Cookie",
 		"traefik.http.middlewares.auth.forwardauth.authResponseHeaders=Set-Cookie, Server",
 		"traefik.http.middlewares.auth.forwardauth.trustForwardHeader=true",
 		"traefik.http.middlewares.requestid.plugin.requestid.headerName=X-Request-ID",

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