seqfile

package
v1.5.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 18, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LineSkipper

type LineSkipper interface {
	IsNewOpen() bool
	SetSkipped()
}

type SeqFile

type SeqFile struct {
	SkipFileFirstLine bool //跳过新文件的第一行,常用于带title的csv文件,title与实际格式不同

	ReadSameInode bool //记录已经读过的filename_inode是否继续读
	// contains filtered or unexported fields
}

SeqFile 按最终修改时间依次读取文件的Reader类型

func NewSeqFile

func NewSeqFile(meta *reader.Meta, path string, ignoreHidden, newFileNewLine bool, suffixes []string, validFileRegex, whence string, expireMap map[string]int64, inodeSensitive bool) (sf *SeqFile, err error)

func (*SeqFile) Close

func (sf *SeqFile) Close() (err error)

func (*SeqFile) IsNewOpen

func (sf *SeqFile) IsNewOpen() bool

func (*SeqFile) Lag

func (sf *SeqFile) Lag() (rl *LagInfo, err error)

func (*SeqFile) Name

func (sf *SeqFile) Name() string

func (*SeqFile) NewSourceIndex

func (sf *SeqFile) NewSourceIndex() []reader.SourceIndex

func (*SeqFile) Read

func (sf *SeqFile) Read(p []byte) (n int, err error)

func (*SeqFile) SetSkipped

func (sf *SeqFile) SetSkipped()

func (*SeqFile) Source

func (sf *SeqFile) Source() string

func (*SeqFile) SyncMeta

func (sf *SeqFile) SyncMeta() (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL