reader

package

v0.99.0 Latest Latest Go to latest Published: Apr 22, 2024 License: Apache-2.0 Imports: 16 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

Repository

github.com/open-telemetry/opentelemetry-collector-contrib

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Factory
type Metadata
- func (m Metadata) GetFingerprint() *fingerprint.Fingerprint
type Reader

Constants ¶

View Source

const (
	DefaultMaxLogSize  = 1024 * 1024
	DefaultFlushPeriod = 500 * time.Millisecond
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Factory ¶

type Factory struct {
	*zap.SugaredLogger
	HeaderConfig      *header.Config
	FromBeginning     bool
	FingerprintSize   int
	InitialBufferSize int
	MaxLogSize        int
	Encoding          encoding.Encoding
	SplitFunc         bufio.SplitFunc
	TrimFunc          trim.Func
	FlushTimeout      time.Duration
	EmitFunc          emit.Callback
	Attributes        attrs.Resolver
	DeleteAtEOF       bool
}

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 ¶ added in v0.89.0

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
}

func (Metadata) GetFingerprint ¶ added in v0.93.0

func (m Metadata) GetFingerprint() *fingerprint.Fingerprint

type Reader ¶

type Reader struct {
	*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 ¶ added in v0.88.0

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

func (*Reader) Read ¶

func (r *Reader) Read(dst []byte) (n int, err 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 ¶ added in v0.88.0

func (r *Reader) Validate() bool

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

Source Files ¶

View all Source files

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