Home
last modified time | relevance | path

Searched refs:seriesID (Results 1 – 25 of 80) sorted by relevance

1234

/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/stores/shipper/compactor/retention/
H A Dseries.go15 func newUserSeries(seriesID []byte, userID []byte) userSeries {
16 key := make([]byte, 0, len(seriesID)+len(userID))
17 key = append(key, seriesID...)
21 seriesIDLen: len(seriesID),
37 func (us *userSeries) Reset(seriesID []byte, userID []byte) {
39 us.key = make([]byte, 0, len(seriesID)+len(userID))
42 us.key = append(us.key, seriesID...)
44 us.seriesIDLen = len(seriesID)
60 us := newUserSeries(seriesID, userID)
74 us := newUserSeries(seriesID, userID)
[all …]
H A Dindex.go148 var seriesID []byte
159 seriesID = components[1]
161 seriesID = components[0]
165 return seriesID, true, nil
250 func seriesFromHash(h []byte) (seriesID []byte) {
257 seriesID = h[i+1:]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/
H A Dschema.go275 seriesID := string(labelsSeriesID(metric))
674 seriesID := labelsSeriesID(labels)
705 seriesID := labelsSeriesID(labels)
712 HashValue: bucket.hashKey + ":" + string(seriesID),
775 seriesID := labelsSeriesID(labels)
778 shard := binary.BigEndian.Uint32(seriesID) % s.rowShards
809 seriesID := labelsSeriesID(labels)
816 HashValue: bucket.hashKey + ":" + string(seriesID),
909 seriesID := labelsSeriesID(labels)
936 HashValue: string(seriesID),
[all …]
H A Dschema_caching.go41 func (s *schemaCaching) GetChunksForSeries(from, through model.Time, userID string, seriesID []byte…
42 queries, err := s.SeriesStoreSchema.GetChunksForSeries(from, through, userID, seriesID)
49 func (s *schemaCaching) GetLabelNamesForSeries(from, through model.Time, userID string, seriesID []…
50 queries, err := s.SeriesStoreSchema.GetLabelNamesForSeries(from, through, userID, seriesID)
H A Dseries_store.go361 for _, seriesID := range seriesIDs {
362 qs, err := c.schema.GetChunksForSeries(from, through, userID, []byte(seriesID))
386 for _, seriesID := range seriesIDs {
387 qs, err := c.schema.GetLabelNamesForSeries(from, through, userID, []byte(seriesID))
556 …hema.GetSeriesDeleteEntries(from, through, userID, metric, func(userID, seriesID string, from, thr…
557 return c.hasChunksForInterval(ctx, userID, seriesID, from, through)
571 func (c *seriesStore) hasChunksForInterval(ctx context.Context, userID, seriesID string, from, thro…
572 chunkIDs, err := c.lookupChunksBySeries(ctx, from, through, userID, []string{seriesID})
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/
H A Dschema.go274 seriesID := string(labelsSeriesID(metric))
673 seriesID := labelsSeriesID(labels)
704 seriesID := labelsSeriesID(labels)
711 HashValue: bucket.hashKey + ":" + string(seriesID),
774 seriesID := labelsSeriesID(labels)
777 shard := binary.BigEndian.Uint32(seriesID) % s.rowShards
808 seriesID := labelsSeriesID(labels)
815 HashValue: bucket.hashKey + ":" + string(seriesID),
908 seriesID := labelsSeriesID(labels)
935 HashValue: string(seriesID),
[all …]
H A Dschema_caching.go41 func (s *schemaCaching) GetChunksForSeries(from, through model.Time, userID string, seriesID []byte…
42 queries, err := s.SeriesStoreSchema.GetChunksForSeries(from, through, userID, seriesID)
49 func (s *schemaCaching) GetLabelNamesForSeries(from, through model.Time, userID string, seriesID []…
50 queries, err := s.SeriesStoreSchema.GetLabelNamesForSeries(from, through, userID, seriesID)
H A Dseries_store.go359 for _, seriesID := range seriesIDs {
360 qs, err := c.schema.GetChunksForSeries(from, through, userID, []byte(seriesID))
384 for _, seriesID := range seriesIDs {
385 qs, err := c.schema.GetLabelNamesForSeries(from, through, userID, []byte(seriesID))
555 …hema.GetSeriesDeleteEntries(from, through, userID, metric, func(userID, seriesID string, from, thr…
556 return c.hasChunksForInterval(ctx, userID, seriesID, from, through)
570 func (c *seriesStore) hasChunksForInterval(ctx context.Context, userID, seriesID string, from, thro…
571 chunkIDs, err := c.lookupChunksBySeries(ctx, from, through, userID, []string{seriesID})
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/
H A Dschema.go274 seriesID := string(labelsSeriesID(metric))
673 seriesID := labelsSeriesID(labels)
704 seriesID := labelsSeriesID(labels)
711 HashValue: bucket.hashKey + ":" + string(seriesID),
774 seriesID := labelsSeriesID(labels)
777 shard := binary.BigEndian.Uint32(seriesID) % s.rowShards
808 seriesID := labelsSeriesID(labels)
815 HashValue: bucket.hashKey + ":" + string(seriesID),
908 seriesID := labelsSeriesID(labels)
935 HashValue: string(seriesID),
[all …]
H A Dschema_caching.go41 func (s *schemaCaching) GetChunksForSeries(from, through model.Time, userID string, seriesID []byte…
42 queries, err := s.SeriesStoreSchema.GetChunksForSeries(from, through, userID, seriesID)
49 func (s *schemaCaching) GetLabelNamesForSeries(from, through model.Time, userID string, seriesID []…
50 queries, err := s.SeriesStoreSchema.GetLabelNamesForSeries(from, through, userID, seriesID)
H A Dseries_store.go359 for _, seriesID := range seriesIDs {
360 qs, err := c.schema.GetChunksForSeries(from, through, userID, []byte(seriesID))
384 for _, seriesID := range seriesIDs {
385 qs, err := c.schema.GetLabelNamesForSeries(from, through, userID, []byte(seriesID))
555 …hema.GetSeriesDeleteEntries(from, through, userID, metric, func(userID, seriesID string, from, thr…
556 return c.hasChunksForInterval(ctx, userID, seriesID, from, through)
570 func (c *seriesStore) hasChunksForInterval(ctx context.Context, userID, seriesID string, from, thro…
571 chunkIDs, err := c.lookupChunksBySeries(ctx, from, through, userID, []string{seriesID})
/dports/net-mgmt/promscale/promscale-0.6.2/pkg/pgmodel/model/
H A Dseries.go42 seriesID SeriesID member
51 seriesID: invalidSeriesID,
93 return l.seriesID != invalidSeriesID
114 switch l.seriesID {
120 return l.seriesID, l.epoch, nil
128 l.seriesID = sid
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/tools/blocksconvert/scanner/
H A Dscanner_processor.go42 seriesID string member
85 …user, index, seriesID, chunkID, err := GetSeriesToChunkMapping(indexEntry.HashValue, indexEntry.Ra…
97 seriesID: seriesID,
133 SeriesID: w.lastKey.seriesID,
H A Dindex_entry.go53 func GetSeriesToChunkMapping(HashValue string, RangeValue []byte) (user string, index int, seriesID…
63 seriesID = parts[len(parts)-1]
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/influxdata/influxdb/tsdb/index/tsi1/
H A Dmeasurement_block.go212 seriesID := itr.prev + uint64(delta)
213 itr.prev = seriesID
226 seriesID := prev + uint64(delta)
227 prev = seriesID
228 ss.AddNoLock(seriesID)
400 seriesID := prev + uint64(delta)
401 if err = fn(seriesID); err != nil {
404 prev = seriesID
597 for _, seriesID := range mm.seriesIDs {
598 delta := seriesID - prev
[all …]
H A Dlog_file.go741 ss.AddNoLock(seriesID)
1071 var seriesID uint64
1255 for seriesID := range m.series {
1256 fn(seriesID)
1268 for seriesID := range m.series {
1269 a = append(a, seriesID)
1283 for seriesID := range m.series {
1284 ss.AddNoLock(seriesID)
1432 for seriesID := range tv.series {
1433 a = append(a, seriesID)
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/influxdata/influxdb/tsdb/index/tsi1/
H A Dmeasurement_block.go216 seriesID := itr.prev + uint64(delta)
217 itr.prev = seriesID
218 return tsdb.SeriesIDElem{SeriesID: seriesID}, nil
230 seriesID := prev + uint64(delta)
231 prev = seriesID
232 ss.AddNoLock(seriesID)
417 seriesID := prev + uint64(delta)
418 if err = fn(seriesID); err != nil {
421 prev = seriesID
507 for _, seriesID := range seriesIDs {
[all …]
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/tsdb/index/tsi1/
H A Dmeasurement_block.go216 seriesID := itr.prev + uint64(delta)
217 itr.prev = seriesID
218 return tsdb.SeriesIDElem{SeriesID: seriesID}, nil
230 seriesID := prev + uint64(delta)
231 prev = seriesID
232 ss.AddNoLock(seriesID)
417 seriesID := prev + uint64(delta)
418 if err = fn(seriesID); err != nil {
421 prev = seriesID
507 for _, seriesID := range seriesIDs {
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/tsdb/index/tsi1/
H A Dmeasurement_block.go216 seriesID := itr.prev + uint64(delta)
217 itr.prev = seriesID
218 return tsdb.SeriesIDElem{SeriesID: seriesID}, nil
230 seriesID := prev + uint64(delta)
231 prev = seriesID
232 ss.AddNoLock(seriesID)
417 seriesID := prev + uint64(delta)
418 if err = fn(seriesID); err != nil {
421 prev = seriesID
507 for _, seriesID := range seriesIDs {
[all …]
/dports/net-mgmt/promscale/promscale-0.6.2/pkg/tests/end_to_end_tests/
H A Dfunctions_test.go225 var seriesID int
226 …context.Background(), "SELECT _prom_catalog.get_or_create_series_id($1)", jsonOrig).Scan(&seriesID)
236 if seriesID != seriesIDKeyVal {
237 t.Fatalf("Expected the series ids to be equal: %v != %v", seriesID, seriesIDKeyVal)
245 seriesID).Scan(&jsonRes)
252 …t.Fatalf("Json not equal: id %v\n got\n%v\nexpected\n%v", seriesID, string(jsonRes), string(jsonOr…
255 err = db.QueryRow(context.Background(), "SELECT jsonb(labels($1))", seriesID).Scan(&jsonRes)
262 …t.Fatalf("Json not equal: id %v\n got\n%v\nexpected\n%v", seriesID, string(jsonRes), string(jsonOr…
266 seriesID).Scan(&retKeys, &retVals)
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/influxdata/influxdb/tsdb/
H A Dseries_file_test.go75 if seriesID := sfile.SeriesID(s.Name, s.Tags, nil); seriesID == 0 {
121 if seriesID := sfile.SeriesID(names[i], tagsSlice[i], nil); seriesID == 0 {
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/aws/
H A Ddynamodb_index_reader.go127 orgStr, day, seriesID, err := decodeHashValue(hashValue)
141 err = decodeBase64(seriesSha256[:], seriesID)
160 err = r.queryChunkEntriesForSeries(ctx, processor, tableName, bucketHashKey+":"+seriesID)
228 func decodeHashValue(hashValue string) (orgStr, day, seriesID string, err error) {
236 seriesID = hashParts[2]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/aws/
H A Ddynamodb_index_reader.go127 orgStr, day, seriesID, err := decodeHashValue(hashValue)
141 err = decodeBase64(seriesSha256[:], seriesID)
160 err = r.queryChunkEntriesForSeries(ctx, processor, tableName, bucketHashKey+":"+seriesID)
227 func decodeHashValue(hashValue string) (orgStr, day, seriesID string, err error) {
235 seriesID = hashParts[2]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/aws/
H A Ddynamodb_index_reader.go127 orgStr, day, seriesID, err := decodeHashValue(hashValue)
141 err = decodeBase64(seriesSha256[:], seriesID)
160 err = r.queryChunkEntriesForSeries(ctx, processor, tableName, bucketHashKey+":"+seriesID)
227 func decodeHashValue(hashValue string) (orgStr, day, seriesID string, err error) {
235 seriesID = hashParts[2]
/dports/security/vault/vault-1.8.2/vendor/github.com/influxdata/influxdb/tsdb/
H A Dseries_file_test.go89 if seriesID := sfile.SeriesID(s.Name, s.Tags, nil); seriesID == 0 {
135 if seriesID := sfile.SeriesID(names[i], tagsSlice[i], nil); seriesID == 0 {

1234