seqfile

Documentation

Index

• type LineSkipper
• type SeqFile
  • func NewSeqFile(meta *reader.Meta, path string, ignoreHidden, newFileNewLine bool, ...) (sf *SeqFile, err error)
  • func (sf *SeqFile) Close() (err error)
  • func (sf *SeqFile) IsNewOpen() bool
  • func (sf *SeqFile) Lag() (rl *LagInfo, err error)
  • func (sf *SeqFile) Name() string
  • func (sf *SeqFile) NewSourceIndex() []reader.SourceIndex
  • func (sf *SeqFile) Read(p []byte) (n int, err error)
  • func (sf *SeqFile) SetSkipped()
  • func (sf *SeqFile) Source() string
  • func (sf *SeqFile) SyncMeta() (err error)

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)