Commit 43ee3ad
committed
feat: add OTel resource attributes persistence per time series
Add end-to-end support for persisting OTel resource and scope attributes
from OTLP metrics ingestion through to query-time enrichment via info().
Key changes:
- Implement AppenderV2 in MimirAppender for OTLP resource context
- Store resource/scope attributes in TSDB head per-series
- Persist attributes to series_metadata.parquet on block flush
- Upload series_metadata.parquet to object storage
- Add distributed query path for resource attributes
- Wire store-gateway and ingester to /api/v1/resources endpoint
- Implement ResourceQuerier for info() PromQL function
- Port block builder to support resource attributes
- Use ReadSeriesMetadataFromReaderAt for content-addressed Parquet
Signed-off-by: Arve Knudsen <arve.knudsen@gmail.com>1 parent 7e20aba commit 43ee3ad
File tree
674 files changed
+351397
-7415
lines changed- cmd/mimir
- development
- mimir-ingest-storage
- config
- scripts
- mimir-monolithic-mode
- config
- scripts
- docs/sources/mimir/configure/configuration-parameters
- pkg
- api
- blockbuilder
- distributor
- otlpappender
- ingester
- client
- mimirpb
- mimir
- querier
- ruler
- storage
- lazyquery
- tsdb/block
- storegateway
- hintspb
- storegatewaypb
- storepb
- streamingpromql/testdata/upstream
- util/validation
- vendor
- github.com
- andybalholm/brotli
- matchfinder
- parquet-go
- bitpack
- unsafecast
- jsonlite
- parquet-go
- bloom
- xxhash
- compress
- brotli
- gzip
- lz4
- snappy
- uncompressed
- zstd
- deprecated
- encoding
- bitpacked
- bytestreamsplit
- delta
- plain
- rle
- thrift
- format
- hashprobe
- aeshash
- wyhash
- internal
- bytealg
- debug
- memory
- unsafecast
- sparse
- pb33f
- libopenapi-validator
- cache
- config
- errors
- helpers
- parameters
- paths
- requests
- responses
- schema_validation
- strict
- libopenapi
- datamodel
- high
- base
- overlay
- v3
- low
- base
- overlay
- v2
- v3
- index
- overlay
- utils
- what-changed/model
- prometheus/prometheus
- config
- model/relabel
- promql
- promqltest/testdata
- storage
- remote
- otlptranslator/prometheusremotewrite
- tsdb
- errors
- index
- record
- seriesmetadata
- wlog
- util
- annotations
- teststorage
- web/api
- testhelpers
- v1
- go.opentelemetry.io/collector/pdata/xpdata
- entity
- go.yaml.in/yaml/v4
- internal/libyaml
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
674 files changed
+351397
-7415
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
6793 | 6793 | | |
6794 | 6794 | | |
6795 | 6795 | | |
| 6796 | + | |
| 6797 | + | |
| 6798 | + | |
| 6799 | + | |
| 6800 | + | |
| 6801 | + | |
| 6802 | + | |
| 6803 | + | |
| 6804 | + | |
| 6805 | + | |
| 6806 | + | |
6796 | 6807 | | |
6797 | 6808 | | |
6798 | 6809 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1315 | 1315 | | |
1316 | 1316 | | |
1317 | 1317 | | |
| 1318 | + | |
| 1319 | + | |
1318 | 1320 | | |
1319 | 1321 | | |
1320 | 1322 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
39 | 39 | | |
40 | 40 | | |
41 | 41 | | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
42 | 54 | | |
43 | 55 | | |
44 | 56 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
184 | 184 | | |
185 | 185 | | |
186 | 186 | | |
| 187 | + | |
187 | 188 | | |
188 | 189 | | |
189 | 190 | | |
| |||
193 | 194 | | |
194 | 195 | | |
195 | 196 | | |
196 | | - | |
| 197 | + | |
197 | 198 | | |
198 | 199 | | |
199 | 200 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
291 | 291 | | |
292 | 292 | | |
293 | 293 | | |
| 294 | + | |
294 | 295 | | |
295 | 296 | | |
296 | 297 | | |
| |||
299 | 300 | | |
300 | 301 | | |
301 | 302 | | |
302 | | - | |
| 303 | + | |
303 | 304 | | |
304 | 305 | | |
305 | 306 | | |
| |||
0 commit comments