-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
add timer package as copy of emergent one, to avoid circular dependen…
…cy; update go.mod
- Loading branch information
Showing
6 changed files
with
95 additions
and
18 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,86 @@ | ||
| // Copyright (c) 2019, The Emergent Authors. All rights reserved. | ||
| // Use of this source code is governed by a BSD-style | ||
| // license that can be found in the LICENSE file. | ||
|
|
||
| // Package timer provides a simple wall-clock duration timer based on standard | ||
| // time. Accumulates total and average over multiple Start / Stop intervals. | ||
| // This is copied from emergent/timer, to avoid circular dependency. | ||
| package timer | ||
|
|
||
| //go:generate core generate -add-types | ||
|
|
||
| import "time" | ||
|
|
||
| // Time manages the timer accumulated time and count | ||
| type Time struct { | ||
|
|
||
| // the most recent starting time | ||
| St time.Time | ||
|
|
||
| // the total accumulated time | ||
| Total time.Duration | ||
|
|
||
| // the number of start/stops | ||
| N int | ||
| } | ||
|
|
||
| // Reset resets the overall accumulated Total and N counters and start time to zero | ||
| func (t *Time) Reset() { | ||
| t.St = time.Time{} | ||
| t.Total = 0 | ||
| t.N = 0 | ||
| } | ||
|
|
||
| // Start starts the timer | ||
| func (t *Time) Start() { | ||
| t.St = time.Now() | ||
| } | ||
|
|
||
| // ResetStart reset then start the timer | ||
| func (t *Time) ResetStart() { | ||
| t.Reset() | ||
| t.Start() | ||
| } | ||
|
|
||
| // Stop stops the timer and accumulates the latest start - stop interval, and also returns it | ||
| func (t *Time) Stop() time.Duration { | ||
| if t.St.IsZero() { | ||
| t.Total = 0 | ||
| t.N = 0 | ||
| return 0 | ||
| } | ||
| iv := time.Now().Sub(t.St) | ||
| t.Total += iv | ||
| t.N++ | ||
| return iv | ||
| } | ||
|
|
||
| // Avg returns the average start / stop interval (assumes each was measuring the same thing). | ||
| func (t *Time) Avg() time.Duration { | ||
| if t.N == 0 { | ||
| return 0 | ||
| } | ||
| return t.Total / time.Duration(t.N) | ||
| } | ||
|
|
||
| // AvgSecs returns the average start / stop interval (assumes each was measuring the same thing) | ||
| // as a float64 of seconds | ||
| func (t *Time) AvgSecs() float64 { | ||
| if t.N == 0 { | ||
| return 0 | ||
| } | ||
| return float64(t.Total) / (float64(t.N) * float64(time.Second)) | ||
| } | ||
|
|
||
| // AvgMSecs returns the average start / stop interval as a float64 of milliseconds | ||
| func (t *Time) AvgMSecs() float64 { | ||
| if t.N == 0 { | ||
| return 0 | ||
| } | ||
| return float64(t.Total) / (float64(t.N) * float64(time.Millisecond)) | ||
| } | ||
|
|
||
| // TotalSecs returns the total start / stop intervals as a float64 of seconds. | ||
| func (t *Time) TotalSecs() float64 { | ||
| return float64(t.Total) / float64(time.Second) | ||
| } |