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
↓ 1 callersFunctionwriteLabelsResponse
(w http.ResponseWriter, values []string, annos annotations.Annotations)
api/http/query.go:160
↓ 1 callersMethodwriteMetaFile
(ctx context.Context)
convert/convert.go:202
↓ 1 callersFunctionwriteSeriesResponse
(w http.ResponseWriter, series []labels.Labels, annos annotations.Annotations)
api/http/query.go:149
↓ 1 callersMethodwriteShardChunksPfile
( ctx context.Context, sw *sortingWriter, shard int, )
convert/convert.go:308
↓ 1 callersMethodwriteShardLabelsPfile
( ctx context.Context, sw *sortingWriter, shard int, )
convert/convert.go:268
MethodAt
()
db/seriesset.go:119
MethodAt
()
db/seriesset.go:156
MethodAt
()
db/iterator.go:86
MethodAt
()
db/iterator.go:146
MethodAtFloatHistogram
(fh *histogram.FloatHistogram)
db/iterator.go:94
MethodAtFloatHistogram
(fh *histogram.FloatHistogram)
db/iterator.go:154
MethodAtHistogram
(h *histogram.Histogram)
db/iterator.go:90
MethodAtHistogram
(h *histogram.Histogram)
db/iterator.go:150
MethodAtT
()
db/iterator.go:158
FunctionBenchmarkQuery
(b *testing.B)
db/db_test.go:1186
FunctionBlockConcurrency
(c int)
db/syncer.go:62
FunctionBlockOptions
(opts ...BlockOption)
db/syncer.go:50
MethodBlocks
()
db/db_test.go:1056
MethodBlocks
()
db/syncer.go:99
MethodClose
()
search/search.go:124
MethodClose
()
search/search.go:159
MethodClose
()
search/search.go:180
MethodClose
()
search/search.go:212
MethodClose
()
db/block.go:66
FunctionDefaultLookback
(d time.Duration)
api/http/query.go:43
FunctionDefaultStep
(s time.Duration)
api/http/query.go:49
FunctionDefaultTimeout
(s time.Duration)
api/http/query.go:55
MethodDescriptor
Deprecated: Use Metadata.ProtoReflect.Descriptor instead.
proto/metapb/meta.pb.go:60
MethodDescriptor
Deprecated: Use Columns.ProtoReflect.Descriptor instead.
proto/metapb/meta.pb.go:126
MethodErr
()
db/seriesset.go:120
MethodErr
()
db/seriesset.go:157
MethodErr
()
db/iterator.go:184
FunctionExternalLabels
(extlabels labels.Labels)
db/db.go:38
FunctionFilterMetas
(f MetaFilter)
db/syncer.go:56
MethodFlush
()
convert/sort.go:72
MethodLabelNames
(context.Context, *storage.LabelHints, ...*labels.Matcher)
db/shard.go:83
MethodLabelNames
(context.Context, *storage.LabelHints, ...*labels.Matcher)
db/block.go:91
MethodLabelValues
(_ context.Context, name string, _ *storage.LabelHints, ms ...*labels.Matcher)
db/shard.go:66
MethodLabelValues
(ctx context.Context, name string, hints *storage.LabelHints, ms ...*labels.Matcher)
db/block.go:74
MethodLen
()
convert/sort.go:200
MethodLen
()
db/db_test.go:1068
MethodLess
(i, j int)
convert/sort.go:196
MethodLess
(i, j int)
db/db_test.go:1064
MethodLess
(i, j int)
db/db_test.go:1070
MethodLog
(args ...interface{})
cmd/config.go:132
FunctionMetaConcurrency
(c int)
db/discover.go:37
FunctionNewAPI
(queryable storage.Queryable, engine promql.QueryEngine, opts ...APIOption)
api/http/api.go:27
FunctionNewDiscoverer
(bkt objstore.Bucket, opts ...DiscoveryOption)
db/discover.go:43
FunctionNewInfoServer
(db *cfdb.DB)
api/grpc/thanos.go:35
FunctionNewQueryServer
(db *cfdb.DB, engine promql.QueryEngine)
api/grpc/thanos.go:67
FunctionNewSyncer
(bkt objstore.Bucket, opts ...SyncerOption)
db/syncer.go:80
FunctionNewThanosBackfillMetaFilter
(endpoint string)
db/syncer.go:201
MethodNext
()
db/seriesset.go:106
MethodNext
()
db/seriesset.go:148
MethodNext
()
db/iterator.go:162
MethodProtoMessage
()
proto/metapb/meta.pb.go:45
MethodProtoMessage
()
proto/metapb/meta.pb.go:111
MethodProtoReflect
()
proto/metapb/meta.pb.go:47
MethodProtoReflect
()
proto/metapb/meta.pb.go:113
MethodPush
(_ interface{})
convert/sort.go:208
MethodQuerier
(mint, maxt int64)
db/shard.go:44
MethodQuerier
(mint, maxt int64)
db/block.go:48
MethodQuery
(req *querypb.QueryRequest, srv querypb.Query_QueryServer)
api/grpc/thanos.go:71
FunctionQueryOptions
(opts ...QueryAPIOption)
api/http/api.go:21
MethodQueryRange
(req *querypb.QueryRangeRequest, srv querypb.Query_QueryRangeServer)
api/grpc/thanos.go:126
MethodQueryable
(extlabels labels.Labels, replicaLabelNames []string)
db/shard.go:33
MethodQueryable
(extlabels labels.Labels, replicaLabelNames []string)
db/block.go:34
MethodReadAt
(b []byte, off int64)
convert/sort.go:282
MethodReadAt
(p []byte, off int64)
db/util.go:32
FunctionReadBufferSize
(sz units.Base2Bytes)
db/syncer.go:74
MethodReadRows
(buf []parquet.Row)
search/search.go:105
MethodReadRows
(r []parquet.Row)
search/search.go:137
MethodReadRows
(r []parquet.Row)
search/search.go:176
MethodReadRows
(r []parquet.Row)
search/search_test.go:177
MethodReadRows
(buf []parquet.Row)
convert/convert.go:389
MethodReadRows
(buf []parquet.Row)
convert/tsdb.go:119
MethodReset
()
proto/metapb/meta.pb.go:34
MethodReset
()
proto/metapb/meta.pb.go:100
MethodReset
()
search/search.go:202
FunctionRowGroupSize
(rbs int)
convert/convert.go:66
MethodSeekToRow
(rowIndex int64)
search/search.go:251
MethodSelect
(ctx context.Context, sorted bool, hints *storage.SelectHints, matchers ...*labels.Matcher)
db/shard.go:88
MethodSelect
(ctx context.Context, sorted bool, hints *storage.SelectHints, matchers ...*labels.Matcher)
db/block.go:96
FunctionSplitDays
(start time.Time, end time.Time)
internal/util/date.go:12
MethodString
()
proto/metapb/meta.pb.go:41
MethodSwap
(i, j int)
convert/sort.go:204
MethodSwap
(i, j int)
db/db_test.go:1063
MethodSwap
(i, j int)
db/db_test.go:1069
FunctionTestBlockNameForDay
(t *testing.T)
schema/block_test.go:12
FunctionTestConcatRowReader
(t *testing.T)
search/search_test.go:190
FunctionTestInstantQuery
(t *testing.T)
db/db_test.go:37
FunctionTestIntersect
(t *testing.T)
search/rowrange_test.go:12
FunctionTestMutipleSearchCallbacks
(t *testing.T)
db/db_test.go:982
FunctionTestRangeQuery
(t *testing.T)
db/db_test.go:826
FunctionTestSearch
(t *testing.T)
search/search_test.go:19
FunctionTestSimplify
(t *testing.T)
search/rowrange_test.go:83
MethodTimerange
()
db/block.go:30
MethodWarnings
()
db/seriesset.go:128
MethodWarnings
()
db/seriesset.go:158
MethodWriteRows
(buf []parquet.Row)
convert/convert.go:363
← previousnext →201–300 of 341, ranked by callers