fix doc for fake input && linter && race on get offsets

ozontech · Oct 4, 2024 · 083240e · 083240e
1 parent c0b71e3
commit 083240e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/plugin/input/fake/README.md b/plugin/input/fake/README.md
@@ -4,7 +4,7 @@ It provides an API to test pipelines and other plugins.
 > No config params
 
 ### API description
-``In(sourceID pipeline.SourceID, sourceName string, offset int64, bytes []byte)``
+``In(sourceID pipeline.SourceID, sourceName string, offset pipeline.Offsets, bytes []byte)``
 
 It sends a test event into the pipeline.
 

diff --git a/plugin/input/file/worker.go b/plugin/input/file/worker.go
@@ -44,6 +44,7 @@ func (w *worker) work(controller inputer, jobProvider *jobProvider, readBufferSi
 		sourceName := job.filename
 		skipLine := job.shouldSkip.Load()
 		lastOffset := job.curOffset
+		offsets := job.offsets
 		if job.symlink != "" {
 			sourceName = job.symlink
 		}
@@ -125,7 +126,7 @@ func (w *worker) work(controller inputer, jobProvider *jobProvider, readBufferSi
 						}
 					}
 
-					job.lastEventSeq = controller.In(sourceID, sourceName, Offset{lastOffset + scanned, job.offsets}, inBuf, isVirgin, metadataInfo)
+					job.lastEventSeq = controller.In(sourceID, sourceName, Offset{lastOffset + scanned, offsets}, inBuf, isVirgin, metadataInfo)
 				}
 				// restore the line buffer
 				accumBuf = accumBuf[:0]
@@ -205,7 +206,7 @@ type Offset struct {
 }
 
 func (o Offset) Current() int64 {
-	return int64(o.current)
+	return o.current
 }
 
 func (o Offset) ByStream(stream string) int64 {