MCPcopy Create free account

hub / github.com/cloudflare/parquet-tsdb-poc / functions

Functions341 in github.com/cloudflare/parquet-tsdb-poc

⨍ Functions 341◇ Types & classes 94
↓ 35 callersFunctionwriteErrorResponse
(w http.ResponseWriter, r errorResponse)
api/http/query.go:112
↓ 34 callersMethodString
()
proto/metapb/meta.pb.go:107
↓ 25 callersMethodClose
()
db/db.go:126
↓ 21 callersMethodInfo
(_ context.Context, _ *infopb.InfoRequest)
api/grpc/thanos.go:39
↓ 8 callersMethodSchema
()
search/search.go:434
↓ 8 callersMethodSeek
(int64)
db/iterator.go:43
↓ 7 callersFunctionBeginOfDay
(t time.Time)
internal/util/date.go:31
↓ 7 callersFunctionLabelNameToColumn
(lbl string)
schema/schema.go:29
↓ 7 callersFunctionparseTimeParam
(r *http.Request, param string, defaultValue time.Time)
api/http/query.go:183
↓ 6 callersFunctionEqual
(path string, value parquet.Value)
search/constraint.go:31
↓ 6 callersMethodLabels
()
db/iterator.go:22
↓ 6 callersMethodQueryable
Queryable returns a storage.Queryable to evaluate queries with.
db/db.go:71
↓ 6 callersFunctionsimplify
(rr []rowRange)
search/rowrange.go:42
↓ 5 callersFunctionBlockNameForDay
(t time.Time)
schema/block.go:35
↓ 5 callersMethodClose
()
search/search.go:324
↓ 5 callersMethodErr
()
db/seriesset.go:79
↓ 5 callersMethodNext
()
db/seriesset.go:74
↓ 5 callersMethodSeekToRow
(rowIndex int64)
search/search.go:339
↓ 5 callersMethodTimerange
()
db/db.go:52
↓ 5 callersFunctionwithTracing
(r *route.Router, path string, h http.HandlerFunc)
api/http/query.go:61
↓ 4 callersMethodAt
()
db/seriesset.go:84
↓ 4 callersMethodAtT
()
db/iterator.go:52
↓ 4 callersMethodClose
()
convert/tsdb.go:103
↓ 4 callersFunctionProjection
(schema *parquet.Schema, projections []string)
schema/schema.go:62
↓ 4 callersFunctionSpanFromContext
(ctx context.Context)
internal/tracing/tracer.go:19
↓ 4 callersMethodclear
()
search/search.go:194
↓ 4 callersMethodinit
init initializes the constraint with respect to the file schema and projections.
search/search.go:26
↓ 4 callersFunctionstorageToDB
(tb testing.TB, st *teststorage.TestStorage)
db/db_test.go:1027
↓ 3 callersMethodBlocks
()
db/db.go:29
↓ 3 callersMethodClose
()
convert/sort.go:157
↓ 3 callersMethodFlush
()
convert/convert.go:350
↓ 3 callersFunctionIntersects
Intersects returns if [a, b] and [c, d] intersect.
internal/util/interval.go:8
↓ 3 callersMethodMeta
()
convert/convert.go:30
↓ 3 callersFunctionNot
(cs Constraint)
search/constraint.go:207
↓ 3 callersMethodReadRows
(rows []parquet.Row)
search/search.go:355
↓ 3 callersMethodReset
()
search/search.go:317
↓ 3 callersMethodSchema
()
convert/tsdb.go:111
↓ 3 callersMethodaccept
accept returns if this constraint is satisfied by the row.
search/search.go:24
↓ 3 callersMethodclear
()
search/search.go:310
↓ 3 callersFunctioncolumnIDForKnownColumn
(schema *parquet.Schema, columnName string)
convert/tsdb.go:98
↓ 3 callersMethodhead
()
convert/sort.go:226
↓ 3 callersFunctionparseDurationParam
(r *http.Request, param string, defaultValue time.Duration)
api/http/query.go:195
↓ 3 callersMethodrowRanges
rowRanges returns a set of non-overlapping increasing row indexes that may satisfy the constraint.
search/search.go:22
↓ 3 callersFunctionsetupBucket
(log *slog.Logger, opts bucketOpts)
cmd/config.go:80
↓ 3 callersFunctionzLabelsFromMetric
(metric labels.Labels)
api/grpc/thanos.go:194
↓ 2 callersFunctionAnd
(cs ...Constraint)
search/constraint.go:163
↓ 2 callersMethodAt
()
db/iterator.go:45
↓ 2 callersMethodAtFloatHistogram
(*histogram.FloatHistogram)
db/iterator.go:49
↓ 2 callersMethodAtHistogram
(*histogram.Histogram)
db/iterator.go:46
↓ 2 callersMethodAtT
()
db/iterator.go:98
↓ 2 callersFunctionChunksPfileNameForShard
(name string, shard int)
schema/block.go:49
↓ 2 callersMethodClose
parquet.Rows interface stuff we care about
search/search_test.go:175
↓ 2 callersFunctionContains
Contains returns if [a, b] contains [c, d].
internal/util/interval.go:13
↓ 2 callersFunctionConvertTSDBBlock
( ctx context.Context, bkt objstore.Bucket, day time.Time, blks []Convertible, opts ...ConvertOption, )
convert/convert.go:94
↓ 2 callersMethodDiscover
(ctx context.Context)
db/discover.go:67
↓ 2 callersFunctionEndOfDay
(t time.Time)
internal/util/date.go:36
↓ 2 callersMethodErr
()
db/iterator.go:53
↓ 2 callersFunctionJoined
(l, r *parquet.Schema)
schema/schema.go:108
↓ 2 callersFunctionLabelsPfileNameForShard
(name string, shard int)
schema/block.go:46
↓ 2 callersFunctionMatch
( ctx context.Context, c Constraint, labelPfile *parquet.File, labelSchema *parquet.Schema, chunkPfile *p
search/search.go:34
↓ 2 callersFunctionMetaFileNameForBlock
(name string)
schema/block.go:53
↓ 2 callersMethodMetas
()
db/discover.go:57
↓ 2 callersMethodNext
()
db/iterator.go:44
↓ 2 callersFunctionNull
()
search/constraint.go:228
↓ 2 callersMethodQuerier
(mint, maxt int64)
db/db.go:101
↓ 2 callersMethodReadValues
(values []parquet.Value)
search/search.go:222
↓ 2 callersFunctionRegex
(path string, regex string)
search/constraint.go:303
↓ 2 callersMethodReplicaQueryable
ReplicaQueryable returns a storage.Queryable that drops replica labels at runtime. Replica labels are labels that identify a replica, i.e. one member
db/db.go:82
↓ 2 callersMethodRowReader
()
convert/sort.go:82
↓ 2 callersMethodSelect
(ctx context.Context, sorted bool, hints *storage.SelectHints, matchers ...*labels.Matcher)
db/db.go:156
↓ 2 callersMethodSync
(ctx context.Context, metas map[string]Meta)
db/syncer.go:106
↓ 2 callersMethodUpdate
(ctx context.Context)
db/syncer.go:234
↓ 2 callersMethodWarnings
()
db/seriesset.go:89
↓ 2 callersFunctionWithCompression
(s *parquet.Schema)
schema/schema.go:51
↓ 2 callersFunctionZigZagDecode
(v uint64)
internal/encoding/zigzag.go:11
↓ 2 callersFunctionZigZagEncode
(x int64)
internal/encoding/zigzag.go:7
↓ 2 callersFunctionalignsToStartOfDay
(t time.Time)
internal/util/date.go:40
↓ 2 callersFunctionbuildFile
(t testing.TB, rows []T)
search/search_test.go:150
↓ 2 callersFunctionengineFromQueryOpts
(opts queryOpts)
cmd/serve.go:137
↓ 2 callersFunctionequalRows
(l, r []parquet.Row)
search/search_test.go:138
↓ 2 callersFunctionfile_meta_proto_rawDescGZIP
()
proto/metapb/meta.pb.go:170
↓ 2 callersFunctionintersectRowRanges
intersect intserects the row ranges from left hand sight with the row ranges from rhs it assumes that lhs and rhs are simplified and returns a simplif
search/rowrange.go:19
↓ 2 callersFunctionnewBlockForMeta
(ctx context.Context, bkt objstore.Bucket, m Meta, opts ...BlockOption)
db/syncer.go:256
↓ 2 callersFunctionnewConcatRowReader
(rrs []RowReaderCloser)
search/search.go:133
↓ 2 callersFunctionnewFlushingWriter
(w rowWriterFlusher, flush int)
convert/convert.go:359
↓ 2 callersFunctionnewLazySeriesSet
(ctx context.Context, selectFn selectFn, sorted bool, hints *storage.SelectHints, matchers ...*labels.Matcher)
db/seriesset.go:39
↓ 2 callersFunctionparseLimitParam
(r *http.Request)
api/http/query.go:248
↓ 2 callersFunctionparseQueryParam
(r *http.Request)
api/http/query.go:221
↓ 2 callersMethodqueryOpts
()
api/http/query.go:265
↓ 2 callersMethodread
()
convert/sort.go:239
↓ 2 callersFunctionreadAll
(t *testing.T, rr parquet.RowReader)
search/search_test.go:213
↓ 2 callersFunctionreadMetafile
(ctx context.Context, bkt objstore.Bucket, name string)
db/discover.go:141
↓ 2 callersFunctiontoQueryStats
(stats *stats.Statistics)
api/grpc/thanos.go:214
↓ 2 callersFunctionwriteQueryResponse
(w http.ResponseWriter, r *promql.Result)
api/http/query.go:135
↓ 1 callersFunctionBufferPool
(p parquet.BufferPool)
convert/convert.go:88
↓ 1 callersFunctionBuildSchemaFromLabels
(lbls []string)
schema/schema.go:37
↓ 1 callersFunctionChunkProjection
(s *parquet.Schema)
schema/schema.go:79
↓ 1 callersMethodChunks
()
convert/convert.go:28
↓ 1 callersMethodClose
()
db/shard.go:64
↓ 1 callersFunctionColumnToLabelName
(col string)
schema/schema.go:33
next →1–100 of 341, ranked by callers