validation

package

Go to main page

Versions in this module

v2

v2.3.1

Sep 8, 2026

v2.3.0

Aug 24, 2026

Changes in this version

type MockLimits

+ SymbolRefTreesEnabledValue bool

+ SymbolizerMaxUnresolvedLocationsValue int

+ func (m MockLimits) SymbolRefTreesEnabled(s string) bool

+ func (m MockLimits) SymbolizerMaxUnresolvedLocations(s string) int

type Overrides

+ func (o *Overrides) SymbolRefTreesEnabled(tenantID string) bool

+ func (o *Overrides) SymbolizerMaxUnresolvedLocations(tenantID string) int

type Symbolizer

+ MaxUnresolvedLocations int

+ SymbolRefTreesEnabled bool

v2.2.2

Sep 8, 2026

v2.2.1

Aug 6, 2026

v2.2.0

Jul 21, 2026

Changes in this version

type Limits

+ IncludeStrippedProfiles bool

+ KeepStrippedProfiles bool

+ MaxAsyncQueryConcurrency int

+ PushMaxConcurrency int

type MockLimits

+ MaxAsyncQueryConcurrencyValue int

+ PushMaxConcurrencyValue int

+ func (m MockLimits) MaxAsyncQueryConcurrency(s string) int

+ func (m MockLimits) PushMaxConcurrency(string) int

type Overrides

+ func (o *Overrides) IncludeStrippedProfiles(tenantID string) bool

+ func (o *Overrides) KeepStrippedProfiles(tenantID string) bool

+ func (o *Overrides) MaxAsyncQueryConcurrency(tenantID string) int

+ func (o *Overrides) PushMaxConcurrency(tenantID string) int

v2.1.2

Aug 6, 2026

v2.1.1

Jul 10, 2026

v2.1.0

Jun 17, 2026

Changes in this version

type Limits

+ MaxRecordingRules int

type Overrides

+ func (o *Overrides) MaxRecordingRules(tenantId string) int

v2.0.6

Jul 10, 2026

v2.0.5

Jun 23, 2026

v2.0.4

Jun 17, 2026

v2.0.3

Jun 3, 2026

v2.0.2

May 7, 2026

v2.0.1

Apr 20, 2026

v2.0.0

Apr 20, 2026

Changes in this version

+ const BodySizeLimit

+ const DroppedByRelabelRules

+ const DuplicateLabelNames

+ const DuplicateLabelNamesAfterSanitizationErrorMsg

+ const DuplicateLabelNamesErrorMsg

+ const FlameGraphLimit

+ const IngestLimitReached

+ const InvalidLabels

+ const InvalidLabelsErrorMsg

+ const LabelNameTooLong

+ const LabelNameTooLongErrorMsg

+ const LabelValueTooLong

+ const LabelValueTooLongErrorMsg

+ const MalformedProfile

+ const MaxFlameGraphNodesErrorMsg

+ const MaxFlameGraphNodesUnlimitedErrorMsg

+ const MaxLabelNamesPerSeries

+ const MaxLabelNamesPerSeriesErrorMsg

+ const MinCompactorPartialBlockDeletionDelay

+ const MissingLabels

+ const MissingLabelsErrorMsg

+ const NotInIngestionWindow

+ const NotInIngestionWindowErrorMsg

+ const ProfileSizeLimit

+ const ProfileTooBigErrorMsg

+ const ProfileTooManySampleLabelsErrorMsg

+ const ProfileTooManySamplesErrorMsg

+ const QueryInvalidTimeRange

+ const QueryLimit

+ const QueryMissingTimeRange

+ const QueryMissingTimeRangeErrorMsg

+ const QueryStartAfterEndErrorMsg

+ const QueryTooLongErrorMsg

+ const RateLimited

+ const ReasonLabel

+ const SampleLabelsLimit

+ const SamplesLimit

+ const SeriesLimit

+ const SeriesLimitErrorMsg

+ const SkippedBySamplingRules

+ const Unknown

+ var DiscardedBytes = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var DiscardedProfiles = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ func GetOverride[T any](o *Overrides, fn func(string, *Limits) T) (defaults T, overrides iter.Seq2[string, T])

+ func SanitizeLegacyLabelName(ln string) (old, sanitized string, ok bool)

+ func SanitizeTimeRange(limits RangeRequestLimits, tenant []string, start, end *int64) (empty bool, err error)

+ func SetDefaultLimitsForYAMLUnmarshalling(defaults Limits)

+ func TenantLimitsHandler(defaultLimits Limits, tenantLimits TenantLimits) http.HandlerFunc

+ func ValidateLabels(limits LabelValidationLimits, tenantID string, ls []*typesv1.LabelPair, ...) ([]*typesv1.LabelPair, error)

+ func ValidateMaxNodes(l FlameGraphLimits, tenantIDs []string, n int64) (int64, error)

+ type Error struct

+ Reason Reason

+ func NewErrorf(reason Reason, msg string, args ...interface{}) *Error

+ func (e *Error) Error() string

+ type FlameGraphLimits interface

+ MaxFlameGraphNodesDefault func(string) int

+ MaxFlameGraphNodesMax func(string) int

+ MaxFlameGraphNodesOnSelectMergeProfile func(string) bool

+ type IngestionRelabelRules []*relabel.Config

+ func (r *IngestionRelabelRules) ExampleDoc() (comment string, yaml interface{})

+ func (r *IngestionRelabelRules) Set(s string) error

+ func (r *IngestionRelabelRules) String() string

+ type LabelValidationLimits interface

+ DisableLabelSanitization func(tenantID string) bool

+ MaxLabelNameLength func(tenantID string) int

+ MaxLabelNamesPerSeries func(tenantID string) int

+ MaxLabelValueLength func(tenantID string) int

+ type LimitError string

+ func (e LimitError) Error() string

+ type Limits struct

+ AdaptivePlacementLimits placement.PlacementLimits

+ CompactorBlocksRetentionPeriod model.Duration

+ CompactorDownsamplerEnabled bool

+ CompactorPartialBlockDeletionDelay model.Duration

+ CompactorSplitAndMergeShards int

+ CompactorSplitAndMergeStageSize int

+ CompactorSplitGroups int

+ CompactorTenantShardSize int

+ DisableLabelSanitization bool

+ DistributorAggregationPeriod model.Duration

+ DistributorAggregationWindow model.Duration

+ DistributorSampling *sampling.Config

+ DistributorUsageGroups *UsageGroupConfig

+ EnforceLabelsOrder bool

+ IngestionArtificialDelay model.Duration

+ IngestionBodyLimitMB float64

+ IngestionBurstSizeMB float64

+ IngestionLimit *ingestlimits.Config

+ IngestionRateMB float64

+ IngestionRelabelingDefaultRulesPosition RelabelRulesPosition

+ IngestionRelabelingRules IngestionRelabelRules

+ IngestionTenantShardSize int

+ MaxFlameGraphNodesDefault int

+ MaxFlameGraphNodesMax int

+ MaxFlameGraphNodesOnSelectMergeProfile bool

+ MaxGlobalSeriesPerTenant int

+ MaxLabelNameLength int

+ MaxLabelNamesPerSeries int

+ MaxLabelValueLength int

+ MaxLocalSeriesPerTenant int

+ MaxProfileSizeBytes int

+ MaxProfileStacktraceDepth int

+ MaxProfileStacktraceSampleLabels int

+ MaxProfileStacktraceSamples int

+ MaxProfileSymbolValueLength int

+ MaxQueryLength model.Duration

+ MaxQueryLookback model.Duration

+ MaxQueryParallelism int

+ MaxSessionsPerSeries int

+ QueryAnalysisEnabled bool

+ QueryAnalysisSeriesEnabled bool

+ QuerySanitizeOnMerge bool

+ QuerySplitDuration model.Duration

+ ReadPathOverrides readpath.Config

+ RecordingRules RecordingRules

+ RejectNewerThan model.Duration

+ RejectOlderThan model.Duration

+ Retention retention.Config

+ S3SSEKMSEncryptionContext string

+ S3SSEKMSKeyID string

+ S3SSEType string

+ SampleTypeRelabelingRules SampleTypeRelabelRules

+ StoreGatewayTenantShardSize int

+ Symbolizer Symbolizer

+ WritePathOverrides writepath.Config

+ func MockDefaultLimits() *Limits

+ func (l *Limits) RegisterFlags(f *flag.FlagSet)

+ func (l *Limits) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (l *Limits) Validate() error

+ type MockLimits struct

+ DisableLabelSanitizationValue bool

+ DistributorAggregationPeriodValue time.Duration

+ DistributorAggregationWindowValue time.Duration

+ IngestionBodyLimitBytesValue int64

+ MaxFlameGraphNodesDefaultValue int

+ MaxFlameGraphNodesMaxValue int

+ MaxFlameGraphNodesOnSelectMergeProfileValue bool

+ MaxLabelNameLengthValue int

+ MaxLabelNamesPerSeriesValue int

+ MaxLabelValueLengthValue int

+ MaxProfileSizeBytesValue int

+ MaxProfileStacktraceDepthValue int

+ MaxProfileStacktraceSampleLabelsValue int

+ MaxProfileStacktraceSamplesValue int

+ MaxProfileSymbolValueLengthValue int

+ MaxQueriersPerTenantValue int

+ MaxQueryLengthValue time.Duration

+ MaxQueryLookbackValue time.Duration

+ MaxQueryParallelismValue int

+ QueryAnalysisEnabledValue bool

+ QueryAnalysisSeriesEnabledValue bool

+ QuerySanitizeOnMergeValue bool

+ QuerySplitDurationValue time.Duration

+ QueryTreeEnabledValue bool

+ RejectNewerThanValue time.Duration

+ RejectOlderThanValue time.Duration

+ SymbolizerEnabledValue bool

+ func (m MockLimits) DisableLabelSanitization(userID string) bool

+ func (m MockLimits) DistributorAggregationPeriod(userID string) time.Duration

+ func (m MockLimits) DistributorAggregationWindow(userID string) time.Duration

+ func (m MockLimits) IngestionBodyLimitBytes(tenantID string) int64

+ func (m MockLimits) MaxFlameGraphNodesDefault(string) int

+ func (m MockLimits) MaxFlameGraphNodesMax(string) int

+ func (m MockLimits) MaxFlameGraphNodesOnSelectMergeProfile(string) bool

+ func (m MockLimits) MaxLabelNameLength(userID string) int

+ func (m MockLimits) MaxLabelNamesPerSeries(userID string) int

+ func (m MockLimits) MaxLabelValueLength(userID string) int

+ func (m MockLimits) MaxProfileSizeBytes(userID string) int

+ func (m MockLimits) MaxProfileStacktraceDepth(userID string) int

+ func (m MockLimits) MaxProfileStacktraceSampleLabels(userID string) int

+ func (m MockLimits) MaxProfileStacktraceSamples(userID string) int

+ func (m MockLimits) MaxProfileSymbolValueLength(userID string) int

+ func (m MockLimits) MaxQueriersPerTenant(_ string) int

+ func (m MockLimits) MaxQueryLength(tenantID string) time.Duration

+ func (m MockLimits) MaxQueryLookback(tenantID string) time.Duration

+ func (m MockLimits) MaxQueryParallelism(string) int

+ func (m MockLimits) QueryAnalysisEnabled(tenantID string) bool

+ func (m MockLimits) QueryAnalysisSeriesEnabled(tenantID string) bool

+ func (m MockLimits) QuerySanitizeOnMerge(tenantID string) bool

+ func (m MockLimits) QuerySplitDuration(string) time.Duration

+ func (m MockLimits) QueryTreeEnabled(s string) bool

+ func (m MockLimits) RejectNewerThan(userID string) time.Duration

+ func (m MockLimits) RejectOlderThan(userID string) time.Duration

+ func (m MockLimits) SymbolizerEnabled(s string) bool

+ type Overrides struct

+ func MockDefaultOverrides() *Overrides

+ func MockOverrides(customize func(defaults *Limits, tenantLimits map[string]*Limits)) *Overrides

+ func NewOverrides(defaults Limits, tenantLimits TenantLimits) (*Overrides, error)

+ func (o *Overrides) AllByTenantID() map[string]*Limits

+ func (o *Overrides) CompactorBlocksRetentionPeriod(userID string) time.Duration

+ func (o *Overrides) CompactorDownsamplerEnabled(userId string) bool

+ func (o *Overrides) CompactorPartialBlockDeletionDelay(userID string) (delay time.Duration, valid bool)

+ func (o *Overrides) CompactorSplitAndMergeShards(userID string) int

+ func (o *Overrides) CompactorSplitAndMergeStageSize(userID string) int

+ func (o *Overrides) CompactorSplitGroups(userID string) int

+ func (o *Overrides) CompactorTenantShardSize(userID string) int

+ func (o *Overrides) DefaultLimits() *Limits

+ func (o *Overrides) DisableLabelSanitization(tenantID string) bool

+ func (o *Overrides) DistributorAggregationPeriod(tenantID string) model.Duration

+ func (o *Overrides) DistributorAggregationWindow(tenantID string) model.Duration

+ func (o *Overrides) DistributorSampling(tenantID string) *sampling.Config

+ func (o *Overrides) DistributorUsageGroups(tenantID string) *UsageGroupConfig

+ func (o *Overrides) EnforceLabelsOrder(tenantID string) bool

+ func (o *Overrides) IngestionArtificialDelay(tenantID string) time.Duration

+ func (o *Overrides) IngestionBodyLimitBytes(tenantID string) int64

+ func (o *Overrides) IngestionBurstSizeBytes(tenantID string) int

+ func (o *Overrides) IngestionLimit(tenantID string) *ingestlimits.Config

+ func (o *Overrides) IngestionRateBytes(tenantID string) float64

+ func (o *Overrides) IngestionRelabelingRules(tenantID string) []*relabel.Config

+ func (o *Overrides) IngestionTenantShardSize(tenantID string) int

+ func (o *Overrides) MaxFlameGraphNodesDefault(tenantID string) int

+ func (o *Overrides) MaxFlameGraphNodesMax(tenantID string) int

+ func (o *Overrides) MaxFlameGraphNodesOnSelectMergeProfile(tenantID string) bool

+ func (o *Overrides) MaxGlobalSeriesPerTenant(tenantID string) int

+ func (o *Overrides) MaxLabelNameLength(tenantID string) int

+ func (o *Overrides) MaxLabelNamesPerSeries(tenantID string) int

+ func (o *Overrides) MaxLabelValueLength(tenantID string) int

+ func (o *Overrides) MaxLocalSeriesPerTenant(tenantID string) int

+ func (o *Overrides) MaxProfileSizeBytes(tenantID string) int

+ func (o *Overrides) MaxProfileStacktraceDepth(tenantID string) int

+ func (o *Overrides) MaxProfileStacktraceSampleLabels(tenantID string) int

+ func (o *Overrides) MaxProfileStacktraceSamples(tenantID string) int

+ func (o *Overrides) MaxProfileSymbolValueLength(tenantID string) int

+ func (o *Overrides) MaxQueriersPerTenant(tenant string) int

+ func (o *Overrides) MaxQueryLength(tenantID string) time.Duration

+ func (o *Overrides) MaxQueryLookback(tenantID string) time.Duration

+ func (o *Overrides) MaxQueryParallelism(tenantID string) int

+ func (o *Overrides) MaxSessionsPerSeries(tenantID string) int

+ func (o *Overrides) PlacementLimits(tenantID string) placement.PlacementLimits

+ func (o *Overrides) QueryAnalysisEnabled(tenantID string) bool

+ func (o *Overrides) QueryAnalysisSeriesEnabled(tenantID string) bool

+ func (o *Overrides) QuerySanitizeOnMerge(tenantID string) bool

+ func (o *Overrides) QuerySplitDuration(tenantID string) time.Duration

+ func (o *Overrides) QueryTreeEnabled(tenantID string) bool

+ func (o *Overrides) ReadPathOverrides(tenantID string) readpath.Config

+ func (o *Overrides) RecordingRules(tenantId string) []*settingsv1.RecordingRule

+ func (o *Overrides) RejectNewerThan(tenantID string) time.Duration

+ func (o *Overrides) RejectOlderThan(tenantID string) time.Duration

+ func (o *Overrides) Retention() (defaults retention.Config, overrides iter.Seq2[string, retention.Config])

+ func (o *Overrides) S3SSEKMSEncryptionContext(user string) string

+ func (o *Overrides) S3SSEKMSKeyID(user string) string

+ func (o *Overrides) S3SSEType(user string) string

+ func (o *Overrides) SampleTypeRelabelingRules(tenantID string) []*relabel.Config

+ func (o *Overrides) StoreGatewayTenantShardSize(userID string) int

+ func (o *Overrides) SymbolizerEnabled(tenantID string) bool

+ func (o *Overrides) SymbolizerMaxSymbolSizeBytes(tenantID string) int

+ func (o *Overrides) WritePathOverrides(tenantID string) writepath.Config

+ type OverwriteMarshalingStringMap struct

+ func NewOverwriteMarshalingStringMap(m map[string]string) OverwriteMarshalingStringMap

+ func (sm *OverwriteMarshalingStringMap) Map() map[string]string

+ func (sm *OverwriteMarshalingStringMap) UnmarshalJSON(val []byte) error

+ func (sm *OverwriteMarshalingStringMap) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (sm OverwriteMarshalingStringMap) MarshalJSON() ([]byte, error)

+ func (sm OverwriteMarshalingStringMap) MarshalYAML() (interface{}, error)

+ type ProfileValidationLimits interface

+ MaxProfileSizeBytes func(tenantID string) int

+ MaxProfileStacktraceDepth func(tenantID string) int

+ MaxProfileStacktraceSampleLabels func(tenantID string) int

+ MaxProfileStacktraceSamples func(tenantID string) int

+ MaxProfileSymbolValueLength func(tenantID string) int

+ RejectNewerThan func(tenantID string) time.Duration

+ RejectOlderThan func(tenantID string) time.Duration

+ type RangeRequestLimits interface

+ MaxQueryLength func(tenantID string) time.Duration

+ MaxQueryLookback func(tenantID string) time.Duration

+ type Reason string

+ func ReasonOf(err error) Reason

+ type RecordingRules []*settingsv1.RecordingRule

+ func (r *RecordingRules) RegisterFlags(f *flag.FlagSet)

+ func (r *RecordingRules) Set(s string) error

+ func (r *RecordingRules) String() string

+ func (r *RecordingRules) UnmarshalYAML(value *yaml.Node) error

+ type RelabelRules []*relabel.Config

+ func (p *RelabelRules) Set(s string) error

+ func (p *RelabelRules) String() string

+ type RelabelRulesPosition string

+ const RelabelRulePositionDisabled

+ const RelabelRulePositionFirst

+ const RelabelRulePositionLast

+ func (p *RelabelRulesPosition) Set(s string) error

+ func (p *RelabelRulesPosition) String() string

+ type RuntimeConfigValues struct

+ TenantLimits map[string]*Limits

+ func LoadRuntimeConfig(r io.Reader) (*RuntimeConfigValues, error)

+ type SampleTypeRelabelRules []*relabel.Config

+ func (r *SampleTypeRelabelRules) ExampleDoc() (comment string, yaml interface{})

+ func (r *SampleTypeRelabelRules) Set(s string) error

+ func (r *SampleTypeRelabelRules) String() string

+ type Symbolizer struct

+ Enabled bool

+ MaxSymbolSizeBytes int

+ func (s *Symbolizer) RegisterFlags(f *flag.FlagSet)

+ type TenantLimits interface

+ AllByTenantID func() map[string]*Limits

+ RuntimeConfig func() *RuntimeConfigValues

+ TenantLimits func(tenantID string) *Limits

+ func NewMockTenantLimits(limits map[string]*Limits) TenantLimits

+ type TenantLimitsResponse struct

+ IngestionBurstSize int

+ IngestionRate float64

+ MaxGlobalSeriesPerTenant int

+ type UsageGroupConfig struct

+ func NewUsageGroupConfig(m map[string]string) (*UsageGroupConfig, error)

+ func (c *UsageGroupConfig) UnmarshalJSON(bytes []byte) error

+ func (c *UsageGroupConfig) UnmarshalYAML(value *yaml.Node) error

+ type UsageGroupEvaluator struct

+ func NewUsageGroupEvaluator(logger log.Logger) *UsageGroupEvaluator

+ func (e *UsageGroupEvaluator) GetMatch(tenantID string, c *UsageGroupConfig, lbls phlaremodel.Labels) UsageGroupMatch

+ type UsageGroupMatch struct

+ func (m UsageGroupMatch) CountDiscardedBytes(reason string, n int64)

+ func (m UsageGroupMatch) CountReceivedBytes(profileType string, n int64)

+ func (m UsageGroupMatch) Names() []UsageGroupMatchName

+ type UsageGroupMatchName struct

+ ConfiguredName string

+ ResolvedName string

+ func (m *UsageGroupMatchName) IsMoreSpecificThan(other *UsageGroupMatchName) bool

+ func (m *UsageGroupMatchName) String() string

+ type ValidatedProfile struct

+ func ValidateProfile(limits ProfileValidationLimits, tenantID string, prof *pprof.Profile, ...) (ValidatedProfile, error)

+ type ValidatedRangeRequest struct

+ IsEmpty bool

+ func ValidateRangeRequest(limits RangeRequestLimits, tenantIDs []string, req model.Interval, ...) (ValidatedRangeRequest, error)

Other modules containing this package

github.com/grafana/pyroscope

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