go-kit
/
tail
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

tail: Minor code cleanup. 

Change-Id: Ib33db2c41cfd6117a9e9bfe64eab002f2b87331d
This commit is contained in:
Benoit Sigoure 2016-12-13 17:05:48 -08:00
parent 915e5feba0
commit 74e17d03ab
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tail.go
View File

@ -22,7 +22,7 @@ import (
) )
var ( var (
ErrStop = fmt.Errorf("tail should now stop") ErrStop = errors.New("tail should now stop")
) )
type Line struct { type Line struct {
@ -250,7 +250,7 @@ func (tail *Tail) tailFileSync() {
tail.openReader() tail.openReader()
var offset int64 = 0 var offset int64
var err error var err error
// Read line by line. // Read line by line.
@ -273,10 +273,9 @@ func (tail *Tail) tailFileSync() {
if cooloff { if cooloff {
// Wait a second before seeking till the end of // Wait a second before seeking till the end of
// file when rate limit is reached. // file when rate limit is reached.
msg := fmt.Sprintf( msg := ("Too much log activity; waiting a second " +
"Too much log activity; waiting a second " + "before resuming tailing")
"before resuming tailing") tail.Lines <- &Line{msg, time.Now(), errors.New(msg)}
tail.Lines <- &Line{msg, time.Now(), fmt.Errorf(msg)}
select { select {
case <-time.After(time.Second): case <-time.After(time.Second):
case <-tail.Dying(): case <-tail.Dying():