requestappender

package
v0.0.0-...-be370ba Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 20, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrInvalidLabel = errors.New("invalid labels")

Functions

func NewAppender

func NewAppender(ctx context.Context, inner storage.Appender, opts Options) storage.Appender

NewAppender creates a new Appender that handle a single remote write request. It will enforce some SquirrelDB's features, like: - Enforce tenant Labels when set - Limit concurrent writes This appender should be created HTTP per-request.

Types

type Options

type Options struct {
	TenantLabel         labels.Label
	IgnoreLabelCallback func(ctx context.Context, tenant string, value string) (bool, error)
	// IngestedPoints counts points forwarded to the backend (ingress); optional.
	IngestedPoints prometheus.Counter
	// CommitSeconds observes the backend Commit duration (SquirrelDB<->TSDB write); optional.
	CommitSeconds prometheus.Observer
}

Jump to

Keyboard shortcuts

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