[#121]: elapsed time to milliseconds

roadrunner-server · Feb 17, 2024 · 0bd16ae · 0bd16ae
1 parent 203f753
commit 0bd16ae
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/amqpjobs/driver.go b/amqpjobs/driver.go
@@ -421,7 +421,7 @@ func (d *Driver) Run(ctx context.Context, p jobs.Pipeline) error {
 	d.listener(deliv)
 
 	atomic.StoreUint32(&d.listeners, 1)
-	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
 }
 
@@ -526,7 +526,7 @@ func (d *Driver) Pause(ctx context.Context, p string) error {
 		zap.String("driver", pipe.Driver()),
 		zap.String("pipeline", pipe.Name()),
 		zap.Time("start", start),
-		zap.Duration("elapsed", time.Since(start)),
+		zap.Int64("elapsed", time.Since(start).Milliseconds()),
 	)
 
 	return nil
@@ -595,7 +595,7 @@ func (d *Driver) Resume(ctx context.Context, p string) error {
 		zap.String("driver", pipe.Driver()),
 		zap.String("pipeline", pipe.Name()),
 		zap.Time("start", start),
-		zap.Duration("elapsed", time.Since(start)),
+		zap.Int64("elapsed", time.Since(start).Milliseconds()),
 	)
 
 	return nil
@@ -611,7 +611,7 @@ func (d *Driver) Stop(ctx context.Context) error {
 	d.stopCh <- struct{}{}
 
 	pipe := *d.pipeline.Load()
-	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()))
 	close(d.redialCh)
 	return nil
 }

diff --git a/amqpjobs/redial.go b/amqpjobs/redial.go
@@ -323,7 +323,7 @@ func (d *Driver) redial(rm *redialMsg) {
 		return
 	}
 
-	d.log.Info("connection was successfully restored", zap.String("pipeline", pipe.Name()), zap.String("driver", pipe.Driver()), zap.Time("start", t), zap.Duration("elapsed", time.Since(t)))
+	d.log.Info("connection was successfully restored", zap.String("pipeline", pipe.Name()), zap.String("driver", pipe.Driver()), zap.Time("start", t), zap.Int64("elapsed", time.Since(t).Milliseconds()))
 
 	// restart redialer
 	d.redialer()