[#103]: elapsed time to milliseconds

roadrunner-server · Feb 17, 2024 · cf5d1a2 · cf5d1a2
1 parent 60b64e4
commit cf5d1a2
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/beanstalkjobs/driver.go b/beanstalkjobs/driver.go
@@ -268,7 +268,7 @@ func (d *Driver) Run(ctx context.Context, p jobs.Pipeline) error {
 
 	go d.listen()
 
-	d.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)))
+	d.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
 }
 
@@ -286,7 +286,7 @@ func (d *Driver) Stop(ctx context.Context) error {
 	// release associated resources
 	d.pool.Stop()
 
-	d.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)))
+	d.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
 }
 
@@ -311,7 +311,7 @@ func (d *Driver) Pause(ctx context.Context, p string) error {
 	atomic.AddUint32(&d.listeners, ^uint32(0))
 
 	d.stopCh <- struct{}{}
-	d.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)))
+	d.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
 }
@@ -339,7 +339,7 @@ func (d *Driver) Resume(ctx context.Context, p string) error {
 
 	// increase num of listeners
 	atomic.AddUint32(&d.listeners, 1)
-	d.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)))
+	d.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
 }