header

package

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

Variables
type Config
- func NewConfig(matchRegex string, metadataOperators []operator.Config, enc encoding.Encoding) (*Config, error)
type Reader
- func NewReader(logger *zap.SugaredLogger, cfg Config) (*Reader, error)
- func (r *Reader) Process(ctx context.Context, token []byte, fileAttributes map[string]any) error
- func (r *Reader) Stop() error

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrEndOfHeader = errors.New("end of header")

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	SplitFunc bufio.SplitFunc
	// contains filtered or unexported fields
}

func NewConfig ¶

func NewConfig(matchRegex string, metadataOperators []operator.Config, enc encoding.Encoding) (*Config, error)

type Reader ¶

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

func NewReader ¶

func NewReader(logger *zap.SugaredLogger, cfg Config) (*Reader, error)

func (*Reader) Process ¶

func (r *Reader) Process(ctx context.Context, token []byte, fileAttributes map[string]any) error

Process checks if the given token is a line of the header, and consumes it if it is. An EndOfHeaderError is returned if the given line was not a header line.

func (*Reader) Stop ¶

func (r *Reader) Stop() error

Source Files ¶

View all Source files

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