Make similar func similar by args

Author: anahan

cmd/docker-fpm-wrapper/main.go

@@ -77,7 +77,7 @@ func main() {
 	}
 
 	if !cfg.FpmSlowlogProxyDisabled {
-		if err = startSlowlogProxies(ctx, fpmConfig, log); err != nil {
+		if err = startSlowlogProxies(ctx, log.Named("php-fpm"), fpmConfig.Pools); err != nil {
 			log.Fatal("Can't start slowlog proxies", zap.Error(err))
 			os.Exit(1)
 		}

cmd/docker-fpm-wrapper/slowlog.go

@@ -24,7 +24,7 @@ func startSlowlogProxyForPool(ctx context.Context, pool phpfpm.Pool, out chan ph
 	return nil
 }
 
-func startSlowlogProxies(ctx context.Context, fpmConfig phpfpm.Config, log *zap.Logger) error {
+func startSlowlogProxies(ctx context.Context, log *zap.Logger, pools []phpfpm.Pool) error {
 	outCh := make(chan phpfpm.SlowlogEntry)
 	go func() {
 		slowlogEnc := zapx.NewSlowlogEncoder()
@@ -33,15 +33,15 @@ func startSlowlogProxies(ctx context.Context, fpmConfig phpfpm.Config, log *zap.
 			case <-ctx.Done():
 				return
 			case entry := <-outCh:
-				if ce := log.Check(zap.WarnLevel, "slowlog detected"); ce != nil {
+				if ce := log.Check(zap.WarnLevel, "slowlog"); ce != nil {
 					ce.Time = entry.CreatedAt
 					ce.Write(slowlogEnc.Encode(entry)...)
 				}
 			}
 		}
 	}()
 
-	for _, pool := range fpmConfig.Pools {
+	for _, pool := range pools {
 		if pool.SlowlogPath == "" {
 			continue
 		}