diff --git a/reader/journal.go b/reader/journal.go index 8721bf34385..e67ad571a24 100644 --- a/reader/journal.go +++ b/reader/journal.go @@ -35,6 +35,7 @@ import ( "github.com/elastic/beats/journalbeat/config" "github.com/elastic/beats/libbeat/beat" "github.com/elastic/beats/libbeat/common" + "github.com/elastic/beats/libbeat/common/backoff" "github.com/elastic/beats/libbeat/logp" ) @@ -44,7 +45,7 @@ type Reader struct { config Config done chan struct{} logger *logp.Logger - backoff *common.Backoff + backoff backoff.Backoff } // New creates a new journal reader and moves the FP to the configured position. @@ -98,7 +99,7 @@ func newReader(logger *logp.Logger, done chan struct{}, c Config, journal *sdjou config: c, done: done, logger: logger, - backoff: common.NewBackoff(done, c.Backoff, c.MaxBackoff), + backoff: backoff.NewExpBackoff(done, c.Backoff, c.MaxBackoff), } r.seek(state.Cursor)