reader

Documentation

Index

• type Config
• type Factory
  • func (f *Factory) NewFingerprint(file *os.File) (*fingerprint.Fingerprint, error)
  • func (f *Factory) NewReader(file *os.File, fp *fingerprint.Fingerprint) (*Reader, error)
  • func (f *Factory) NewReaderFromMetadata(file *os.File, m *Metadata) (r *Reader, err error)
• type Metadata
• type Reader
  • func (r *Reader) Close() *Metadata
  • func (r *Reader) NameEquals(other *Reader) bool
  • func (r *Reader) NewFingerprintFromFile() (*fingerprint.Fingerprint, error)
  • func (r *Reader) Read(dst []byte) (int, error)
  • func (r *Reader) ReadToEnd(ctx context.Context)
  • func (r *Reader) Validate() bool

Types

type Config

type Config struct {
	FingerprintSize         int
	MaxLogSize              int
	Emit                    emit.Callback
	IncludeFileName         bool
	IncludeFilePath         bool
	IncludeFileNameResolved bool
	IncludeFilePathResolved bool
	DeleteAtEOF             bool
	FlushTimeout            time.Duration
}

type Factory

type Factory struct {
	*zap.SugaredLogger
	Config        *Config
	FromBeginning bool
	Encoding      encoding.Encoding
	HeaderConfig  *header.Config
	SplitFunc     bufio.SplitFunc
	TrimFunc      trim.Func
}

func (*Factory) NewFingerprint

func (f *Factory) NewFingerprint(file *os.File) (*fingerprint.Fingerprint, error)

func (*Factory) NewReader

func (f *Factory) NewReader(file *os.File, fp *fingerprint.Fingerprint) (*Reader, error)

func (*Factory) NewReaderFromMetadata

func (f *Factory) NewReaderFromMetadata(file *os.File, m *Metadata) (r *Reader, err error)

type Metadata

type Metadata struct {
	Fingerprint     *fingerprint.Fingerprint
	Offset          int64
	FileAttributes  map[string]any
	HeaderFinalized bool
	FlushState      *flush.State
}

type Reader

type Reader struct {
	*Config
	*Metadata
	// contains filtered or unexported fields
}

Reader manages a single file

func (*Reader) Close

func (r *Reader) Close() *Metadata

Close will close the file and return the metadata

func (*Reader) NameEquals

func (r *Reader) NameEquals(other *Reader) bool

func (*Reader) NewFingerprintFromFile

func (r *Reader) NewFingerprintFromFile() (*fingerprint.Fingerprint, error)

func (*Reader) Read

func (r *Reader) Read(dst []byte) (int, error)

Read from the file and update the fingerprint if necessary

func (*Reader) ReadToEnd

func (r *Reader) ReadToEnd(ctx context.Context)

ReadToEnd will read until the end of the file

func (*Reader) Validate

func (r *Reader) Validate() bool

Validate returns true if the reader still has a valid file handle, false otherwise.