xfile

package

v0.0.0-...-e1f17c8 Latest Latest Go to latest Published: Aug 27, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const AppendingFileReaderBuffSize = 1 << 4

View Source

const EventsBuffSize = 1 << 4

View Source

const StaticFileReaderBuffSize = 1 << 4

View Source

var (
	FatalError = errors.New("FatalError")
)

This section is empty.

type AppendingFileAppendReader struct {
	// contains filtered or unexported fields
}

func (afr *AppendingFileAppendReader) CurrentCursor() int64

current offset

func (afr *AppendingFileAppendReader) Events(ctx context.Context) chan EventGetter

func (afr *AppendingFileAppendReader) ReadLines(ctx context.Context) chan FileLineGetter

func (afr *AppendingFileAppendReader) Watch(fileName string) error

type EventGetter interface {
	FileName() string
	Operation() Operation
}

type FileEventGetter struct {
	// contains filtered or unexported fields
}

func (f *FileEventGetter) FileName() string

func (f *FileEventGetter) Operation() Operation

type FileLine struct {
	// contains filtered or unexported fields
}

func (fl *FileLine) Error() error

func (fl *FileLine) Line() []byte

type FileLineGetter interface {
	Line() []byte
	Error() error
}

type Operation uint32

const (
	Create Operation = 1 << iota
	Write
	Remove
	Rename
	Chmod
)

func (op Operation) String() string

type StaticFileReader struct {
	// contains filtered or unexported fields
}

StaticFileReader reader static file.

func (fr *StaticFileReader) ReadLines(ctx context.Context) chan FileLineGetter

type XReader interface {
	ReadLines(ctx context.Context) chan FileLineGetter
}

func NewStaticFileReader(filename string) (XReader, error)

type XWatchReader interface {
	Watch(fileName string) error
	Events(ctx context.Context) chan EventGetter
	XReader
}

func NewAppendingFileAppendReader(filename string) (XWatchReader, error)