Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 Changes in this version + const DuplicateLabelNames + const DuplicateLabelNamesErrorMsg + const GlobalIngestionRateStrategy + const GreaterThanMaxSampleAge + const GreaterThanMaxSampleAgeErrorMsg + const InvalidLabels + const InvalidLabelsErrorMsg + const LabelNameTooLong + const LabelNameTooLongErrorMsg + const LabelValueTooLong + const LabelValueTooLongErrorMsg + const LineTooLong + const LineTooLongErrorMsg + const LocalIngestionRateStrategy + const MaxLabelNamesPerSeries + const MaxLabelNamesPerSeriesErrorMsg + const MissingLabels + const MissingLabelsErrorMsg + const OutOfOrder + const RateLimited + const RateLimitedErrorMsg + const ReasonLabel + const StreamLimit + const StreamLimitErrorMsg + const StreamRateLimit + const TooFarBehind + const TooFarInFuture + const TooFarInFutureErrorMsg + var DiscardedBytes = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var DiscardedSamples = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var MutatedBytes = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var MutatedSamples = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + var Unlimited = RateLimit + func SetDefaultLimitsForYAMLUnmarshalling(defaults Limits) + type ErrStreamRateLimit struct + Bytes flagext.ByteSize + Labels string + RateLimit flagext.ByteSize + func (e *ErrStreamRateLimit) Error() string + type Limits struct + CardinalityLimit int + CreationGracePeriod model.Duration + EnforceMetricName bool + IngestionBurstSizeMB float64 + IngestionRateMB float64 + IngestionRateStrategy string + MaxCacheFreshness model.Duration + MaxChunksPerQuery int + MaxConcurrentTailRequests int + MaxEntriesLimitPerQuery int + MaxGlobalStreamsPerUser int + MaxLabelNameLength int + MaxLabelNamesPerSeries int + MaxLabelValueLength int + MaxLineSize flagext.ByteSize + MaxLineSizeTruncate bool + MaxLocalStreamsPerUser int + MaxQueriersPerTenant int + MaxQueryLength model.Duration + MaxQueryLookback model.Duration + MaxQueryParallelism int + MaxQuerySeries int + MaxStreamsMatchersPerQuery int + MinShardingLookback model.Duration + PerStreamRateLimit flagext.ByteSize + PerStreamRateLimitBurst flagext.ByteSize + PerTenantOverrideConfig string + PerTenantOverridePeriod model.Duration + QuerySplitDuration model.Duration + RejectOldSamples bool + RejectOldSamplesMaxAge model.Duration + RetentionPeriod model.Duration + RulerEvaluationDelay model.Duration + RulerMaxRuleGroupsPerTenant int + RulerMaxRulesPerRuleGroup int + RulerRemoteWriteDisabled bool + RulerRemoteWriteHeaders OverwriteMarshalingStringMap + RulerRemoteWriteQueueBatchSendDeadline time.Duration + RulerRemoteWriteQueueCapacity int + RulerRemoteWriteQueueMaxBackoff time.Duration + RulerRemoteWriteQueueMaxSamplesPerSend int + RulerRemoteWriteQueueMaxShards int + RulerRemoteWriteQueueMinBackoff time.Duration + RulerRemoteWriteQueueMinShards int + RulerRemoteWriteQueueRetryOnRateLimit bool + RulerRemoteWriteRelabelConfigs []*util.RelabelConfig + RulerRemoteWriteTimeout time.Duration + RulerRemoteWriteURL string + StreamRetention []StreamRetention + UnorderedWrites bool + func (l *Limits) RegisterFlags(f *flag.FlagSet) + func (l *Limits) UnmarshalYAML(unmarshal func(interface{}) error) error + func (l *Limits) Validate() error + type Overrides struct + func NewOverrides(defaults Limits, tenantLimits TenantLimits) (*Overrides, error) + func (o *Overrides) AllByUserID() map[string]*Limits + func (o *Overrides) CardinalityLimit(userID string) int + func (o *Overrides) CreationGracePeriod(userID string) time.Duration + func (o *Overrides) DefaultLimits() *Limits + func (o *Overrides) EnforceMetricName(userID string) bool + func (o *Overrides) EvaluationDelay(userID string) time.Duration + func (o *Overrides) IngestionBurstSizeBytes(userID string) int + func (o *Overrides) IngestionRateBytes(userID string) float64 + func (o *Overrides) IngestionRateStrategy() string + func (o *Overrides) MaxCacheFreshness(userID string) time.Duration + func (o *Overrides) MaxChunksPerQuery(userID string) int + func (o *Overrides) MaxChunksPerQueryFromStore(userID string) int + func (o *Overrides) MaxConcurrentTailRequests(userID string) int + func (o *Overrides) MaxEntriesLimitPerQuery(userID string) int + func (o *Overrides) MaxGlobalStreamsPerUser(userID string) int + func (o *Overrides) MaxLabelNameLength(userID string) int + func (o *Overrides) MaxLabelNamesPerSeries(userID string) int + func (o *Overrides) MaxLabelValueLength(userID string) int + func (o *Overrides) MaxLineSize(userID string) int + func (o *Overrides) MaxLineSizeTruncate(userID string) bool + func (o *Overrides) MaxLocalStreamsPerUser(userID string) int + func (o *Overrides) MaxQueriersPerUser(userID string) int + func (o *Overrides) MaxQueryLength(userID string) time.Duration + func (o *Overrides) MaxQueryLookback(userID string) time.Duration + func (o *Overrides) MaxQueryParallelism(userID string) int + func (o *Overrides) MaxQuerySeries(userID string) int + func (o *Overrides) MaxStreamsMatchersPerQuery(userID string) int + func (o *Overrides) MinShardingLookback(userID string) time.Duration + func (o *Overrides) PerStreamRateLimit(userID string) RateLimit + func (o *Overrides) QuerySplitDuration(userID string) time.Duration + func (o *Overrides) RejectOldSamples(userID string) bool + func (o *Overrides) RejectOldSamplesMaxAge(userID string) time.Duration + func (o *Overrides) RetentionPeriod(userID string) time.Duration + func (o *Overrides) RulerMaxRuleGroupsPerTenant(userID string) int + func (o *Overrides) RulerMaxRulesPerRuleGroup(userID string) int + func (o *Overrides) RulerRemoteWriteDisabled(userID string) bool + func (o *Overrides) RulerRemoteWriteHeaders(userID string) map[string]string + func (o *Overrides) RulerRemoteWriteQueueBatchSendDeadline(userID string) time.Duration + func (o *Overrides) RulerRemoteWriteQueueCapacity(userID string) int + func (o *Overrides) RulerRemoteWriteQueueMaxBackoff(userID string) time.Duration + func (o *Overrides) RulerRemoteWriteQueueMaxSamplesPerSend(userID string) int + func (o *Overrides) RulerRemoteWriteQueueMaxShards(userID string) int + func (o *Overrides) RulerRemoteWriteQueueMinBackoff(userID string) time.Duration + func (o *Overrides) RulerRemoteWriteQueueMinShards(userID string) int + func (o *Overrides) RulerRemoteWriteQueueRetryOnRateLimit(userID string) bool + func (o *Overrides) RulerRemoteWriteRelabelConfigs(userID string) []*util.RelabelConfig + func (o *Overrides) RulerRemoteWriteTimeout(userID string) time.Duration + func (o *Overrides) RulerRemoteWriteURL(userID string) string + func (o *Overrides) RulerTenantShardSize(userID string) int + func (o *Overrides) StreamRetention(userID string) []StreamRetention + func (o *Overrides) UnorderedWrites(userID string) bool + type OverridesExporter struct + func NewOverridesExporter(overrides *Overrides) *OverridesExporter + func (oe *OverridesExporter) Collect(ch chan<- prometheus.Metric) + func (oe *OverridesExporter) Describe(ch chan<- *prometheus.Desc) + 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 RateLimit struct + Burst int + Limit rate.Limit + type StreamRetention struct + Matchers []*labels.Matcher + Period model.Duration + Priority int + Selector string + type TenantLimits interface + AllByUserID func() map[string]*Limits + TenantLimits func(userID string) *Limits
Go to main page