Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type OffsetGetter ¶
type OffsetGetter interface { // GetOffset returns the current transaction head file offset. GetOffset() int64 }
OffsetGetter defines the interface for transaction head file offset getters.
type Option ¶
type Option func(*reader)
Option configures watch readers.
func StartOffset ¶
StartOffset sets the initial offset for the reader.
type Reader ¶
type Reader interface { io.ReadCloser Watcher OffsetGetter }
Reader defines the interface for transaction head file readers.
Click to show internal directories.
Click to hide internal directories.