push

type Action string

type AttributesConfig struct {
	Action     Action         `` /* 251-byte string literal not displayed */
	Attributes []string       `` /* 147-byte string literal not displayed */
	Regex      relabel.Regexp `yaml:"regex" json:"regex" doc:"description=Regex to choose attributes to configure how to store them or drop them altogether"`
}

type EmptyLimits struct{}

type ErrorWriter func(w http.ResponseWriter, errorStr string, code int, logger log.Logger)

type GlobalOTLPConfig struct {
	DefaultOTLPResourceAttributesAsIndexLabels []string `yaml:"default_resource_attributes_as_index_labels"`
}

type Limits interface {
	OTLPConfig(userID string) OTLPConfig
	DiscoverServiceName(userID string) []string
}

type OTLPConfig struct {
	ResourceAttributes  ResourceAttributesConfig `` /* 206-byte string literal not displayed */
	ScopeAttributes     []AttributesConfig       `` /* 181-byte string literal not displayed */
	LogAttributes       []AttributesConfig       `` /* 191-byte string literal not displayed */
	SeverityTextAsLabel bool                     `` /* 266-byte string literal not displayed */
}

type PolicyWithRetentionWithBytes map[string]map[time.Duration]int64

type RequestParser func(userID string, r *http.Request, limits Limits, tenantConfigs *runtime.TenantConfigs, maxRecvMsgSize int, maxDecompressedSize int64, tracker UsageTracker, streamResolver StreamResolver, logger log.Logger) (*logproto.PushRequest, *Stats, error)

type RequestParserWrapper func(inner RequestParser) RequestParser

type ResourceAttributesConfig struct {
	IgnoreDefaults   bool               `` /* 314-byte string literal not displayed */
	AttributesConfig []AttributesConfig `yaml:"attributes_config,omitempty" json:"attributes_config,omitempty"`
}

type Stats struct {
	Errs           []error
	PolicyNumLines map[string]int64

	// LogLinesBytes holds the total size of all log lines, per policy per retention. Used in billing.
	LogLinesBytes PolicyWithRetentionWithBytes

	// StructuredMetadataBytes holds the size of the original structured metadata (but after it was enriched by OLTP
	// parser) per policy per retention. Used in billing.
	StructuredMetadataBytes PolicyWithRetentionWithBytes

	// ResourceAndSourceMetadataLabels holds structured metadata that was added by OLTP parser (scope and resource attributes)
	ResourceAndSourceMetadataLabels map[string]map[time.Duration]push.LabelsAdapter

	// StreamLabelsSize holds the total size of stream labels after sanitization (empty labels removed and
	// non-meaningful whitespaces removed). Not used in billing.
	StreamLabelsSize int64

	MostRecentEntryTimestamp          time.Time
	MostRecentEntryTimestampPerStream map[string]time.Time

	// StreamSizeBytes holds the total size of log lines and structured metadata. Is used only when logPushRequestStreams is true.
	StreamSizeBytes map[string]int64

	HashOfAllStreams uint64
	ContentType      string
	ContentEncoding  string

	BodySize int64
	// Extra is a place for a wrapped parser to record any interesting stats as key-value pairs to be logged
	Extra []any

	HasInternalStreams bool // True if any of the streams has aggregated metrics or is a pattern stream
}

type StreamResolver interface {
	RetentionPeriodFor(lbs labels.Labels) time.Duration
	RetentionHoursFor(lbs labels.Labels) string
	PolicyFor(ctx context.Context, lbs labels.Labels) string
}

type TenantsRetention interface {
	RetentionPeriodFor(userID string, lbs labels.Labels) time.Duration
}

type UsageTracker interface {

	// ReceivedBytesAdd records ingested bytes by tenant, retention period and labels.
	ReceivedBytesAdd(ctx context.Context, tenant string, retentionPeriod time.Duration, labels labels.Labels, value float64, format string)

	// DiscardedBytesAdd records discarded bytes by tenant and labels.
	DiscardedBytesAdd(ctx context.Context, tenant, reason string, labels labels.Labels, value float64, format string)
}