[#118]: elapsed time to milliseconds

roadrunner-server · Feb 17, 2024 · 1f585d8 · 1f585d8
1 parent 3fdd961
commit 1f585d8
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/natsjobs/driver.go b/natsjobs/driver.go
@@ -295,7 +295,7 @@ func (c *Driver) Run(ctx context.Context, p jobs.Pipeline) error {
 
 	c.listenerStart()
 
-	c.log.Debug("pipeline was started", zap.String("driver", pipe.Driver()), zap.String("pipeline", pipe.Name()), zap.Time("start", start), zap.Duration("elapsed", time.Since(start)))
+	c.log.Debug("pipeline was started", zap.String("driver", pipe.Driver()), zap.String("pipeline", pipe.Name()), zap.Time("start", start), zap.Int64("elapsed", time.Since(start).Milliseconds()))
 	return nil
 }
 
@@ -325,7 +325,7 @@ func (c *Driver) Pause(ctx context.Context, p string) error {
 
 	c.stopCh <- struct{}{}
 
-	c.log.Debug("pipeline was paused", zap.String("driver", pipe.Driver()), zap.String("pipeline", pipe.Name()), zap.Time("start", start), zap.Duration("elapsed", time.Since(start)))
+	c.log.Debug("pipeline was paused", zap.String("driver", pipe.Driver()), zap.String("pipeline", pipe.Name()), zap.Time("start", start), zap.Int64("elapsed", time.Since(start).Milliseconds()))
 
 	return nil
 }
@@ -356,7 +356,7 @@ func (c *Driver) Resume(ctx context.Context, p string) error {
 
 	atomic.AddUint32(&c.listeners, 1)
 
-	c.log.Debug("pipeline was resumed", zap.String("driver", pipe.Driver()), zap.String("pipeline", pipe.Name()), zap.Time("start", start), zap.Duration("elapsed", time.Since(start)))
+	c.log.Debug("pipeline was resumed", zap.String("driver", pipe.Driver()), zap.String("pipeline", pipe.Name()), zap.Time("start", start), zap.Int64("elapsed", time.Since(start).Milliseconds()))
 
 	return nil
 }
@@ -425,7 +425,7 @@ func (c *Driver) Stop(ctx context.Context) error {
 	}
 
 	c.conn.Close()
-	c.log.Debug("pipeline was stopped", zap.String("driver", pipe.Driver()), zap.String("pipeline", pipe.Name()), zap.Time("start", start), zap.Duration("elapsed", time.Since(start)))
+	c.log.Debug("pipeline was stopped", zap.String("driver", pipe.Driver()), zap.String("pipeline", pipe.Name()), zap.Time("start", start), zap.Int64("elapsed", time.Since(start).Milliseconds()))
 
 	return nil
 }