Documentation
¶
Index ¶
- type Config
- type File
- type Positions
- func (p *Positions) Get(path string) (int64, error)
- func (p *Positions) GetString(path string) string
- func (p *Positions) Put(path string, pos int64)
- func (p *Positions) PutString(path string, pos string)
- func (p *Positions) Remove(path string)
- func (p *Positions) Stop()
- func (p *Positions) SyncPeriod() time.Duration
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
SyncPeriod time.Duration `yaml:"sync_period"`
PositionsFile string `yaml:"filename"`
}
Config describes where to get postition information from.
func (*Config) RegisterFlags ¶
RegisterFlags register flags.
type Positions ¶
type Positions struct {
// contains filtered or unexported fields
}
Positions tracks how far through each file we've read.
func (*Positions) Get ¶
Get returns how far we've read through a file. Returns an error if the value stored for the file is not an integer.
func (*Positions) GetString ¶ added in v0.2.0
GetString returns how far we've through a file as a string. JournalTarget writes a journal cursor to the positions file, while FileTarget writes an integer offset. Use Get to read the integer offset.
func (*Positions) PutString ¶ added in v0.2.0
PutString records (asynchronsouly) how far we've read through a file. Unlike Put, it records a string offset and is only useful for JournalTargets which doesn't have integer offsets.
func (*Positions) SyncPeriod ¶
SyncPeriod returns how often the positions file gets resynced
Source Files