summaryrefslogtreecommitdiff
path: root/internal/clients/stats.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/clients/stats.go')
-rw-r--r--internal/clients/stats.go8
1 files changed, 5 insertions, 3 deletions
diff --git a/internal/clients/stats.go b/internal/clients/stats.go
index d36cef6..ec6adfe 100644
--- a/internal/clients/stats.go
+++ b/internal/clients/stats.go
@@ -1,11 +1,13 @@
package clients
import (
- "github.com/mimecast/dtail/internal/logger"
+ "context"
"fmt"
"runtime"
"sync"
"time"
+
+ "github.com/mimecast/dtail/internal/io/logger"
)
// Used to collect and display various client stats.
@@ -28,14 +30,14 @@ func newTailStats(connectionsTotal int) *stats {
}
}
-func (s *stats) periodicLogStats(throttleCh chan struct{}, stop <-chan struct{}) {
+func (s *stats) periodicLogStats(ctx context.Context, throttleCh chan struct{}) {
connectedLast := 0
statsInterval := 5
for {
select {
case <-time.After(time.Second * time.Duration(statsInterval)):
- case <-stop:
+ case <-ctx.Done():
return
}