seqfile

package

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

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/marc47marc47/logkit

Links

Open Source Insights

Documentation ¶

Index ¶

type LineSkipper
type SeqFile
- func NewSeqFile(meta *reader.Meta, path string, ignoreHidden, newFileNewLine bool, ...) (sf *SeqFile, err error)

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)

Source Files ¶

View all Source files

seqfile.go

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