Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cloudflare/parquet-tsdb-poc
/ types & classes
Types & classes
94 in github.com/cloudflare/parquet-tsdb-poc
⨍
Functions
341
◇
Types & classes
94
↓ 2 callers
TypeAlias
samplesByLabels
db/db_test.go:1066
↓ 2 callers
TypeAlias
seriesByLabels
db/db_test.go:1060
↓ 1 callers
Struct
readerAt
convert/sort.go:277
FuncType
APIOption
func(*apiConfig)
api/http/api.go:19
Struct
Block
db/block.go:18
FuncType
BlockOption
func(*blockConfig)
db/syncer.go:68
Struct
BlockQuerier
db/block.go:60
Struct
BlockQueryable
db/block.go:42
Struct
Columns
proto/metapb/meta.pb.go:92
Interface
Constraint
search/search.go:20
FuncType
ConvertOption
func(*convertOpts)
convert/convert.go:64
Interface
Convertible
convert/convert.go:26
Struct
DB
DB is a horizontal partitioning of multiple non-overlapping blocks that are aligned to 24h and span exactly 24h.
db/db.go:23
FuncType
DBOption
func(*dbConfig)
db/db.go:36
Struct
DBQuerier
db/db.go:118
Struct
DBQueryable
db/db.go:90
Struct
Discoverer
db/discover.go:22
FuncType
DiscoveryOption
func(*discoveryConfig)
db/discover.go:35
Struct
Meta
db/block.go:23
Interface
MetaFilter
db/syncer.go:181
Struct
Metadata
proto/metapb/meta.pb.go:23
FuncType
QueryAPIOption
func(*queryAPI)
api/http/query.go:41
Interface
RowReaderCloser
search/search.go:29
Struct
S
search/search_test.go:22
Struct
Shard
db/shard.go:27
Struct
ShardQuerier
db/shard.go:54
Struct
ShardQueryable
db/shard.go:37
Struct
Syncer
db/syncer.go:29
FuncType
SyncerOption
func(*syncerConfig)
db/syncer.go:42
Struct
T
search/search_test.go:69
Struct
ThanosBackfillMetaFilter
db/syncer.go:194
Struct
allMetas
db/syncer.go:188
Struct
andConstraint
search/constraint.go:157
Struct
apiConfig
api/http/api.go:15
Struct
apiResponse
api/http/query.go:98
Struct
blockConfig
db/syncer.go:70
Struct
blockOpts
cmd/serve.go:157
Struct
blockOrError
db/syncer.go:107
Struct
boundedSeriesIterator
Taken from https://github.com/thanos-io/thanos/blob/main/pkg/dedup/iter.go
db/iterator.go:127
Struct
bucketOpts
cmd/config.go:27
Struct
bucketReaderAt
TODO: timeouts retries whatnot
db/util.go:17
Struct
bufferedRowReader
convert/sort.go:219
Struct
chunkSeries
Taken from https://github.com/thanos-io/thanos/blob/main/pkg/query/iter.go
db/iterator.go:16
Struct
chunkSeriesIterator
db/iterator.go:55
Struct
columnChunkRows
search/search.go:271
Struct
columnChunkValueReader
Copied from parquet-go https://github.com/parquet-go/parquet-go/blob/main/row_group.go Needs to be upstreamed eventually; Adapted to work with column
search/search.go:187
Struct
concatRowReader
search/search.go:128
Struct
concatSeriesSet
db/seriesset.go:136
Struct
conversionOpts
cmd/convert.go:101
Struct
convertOpts
convert/convert.go:33
Struct
convertOpts
cmd/convert.go:29
Struct
converter
convert/convert.go:143
Struct
dbConfig
db/db.go:32
Struct
discoveryConfig
db/discover.go:31
Struct
equalConstraint
search/constraint.go:17
Struct
errSeriesIterator
db/iterator.go:39
Struct
errorResponse
api/http/query.go:107
Struct
filterRowReader
search/search.go:167
Struct
flushingWriter
convert/convert.go:353
Struct
hints
db/seriesset.go:17
Struct
indexRowReader
convert/tsdb.go:23
Struct
infoServer
Taken from https://github.com/thanos-community/thanos-promql-connector/blob/main/main.go
api/grpc/thanos.go:29
Struct
internalAPIOpts
cmd/serve.go:373
Struct
lazySeriesSet
db/seriesset.go:54
Struct
limitReader
convert/convert.go:379
Struct
mergedRowReader
Taken from https://github.com/parquet-go/parquet-go/blob/main/merge.go This was necessary to fix corruption that happened because the head was not clo
convert/sort.go:103
Struct
metaOrError
db/discover.go:81
Struct
notConstraint
search/constraint.go:201
Struct
nullConstraint
search/constraint.go:223
Struct
orConstraint
search/constraint.go:244
Struct
promAPIOpts
cmd/serve.go:336
Struct
queryAPI
api/http/query.go:32
Struct
queryOpts
cmd/serve.go:120
Struct
queryResponse
api/http/query.go:130
Struct
queryServer
api/grpc/thanos.go:60
Struct
rangeQuery
db/db_test.go:830
Struct
rangesRowReader
search/search.go:82
Struct
regexConstraint
search/constraint.go:292
Struct
rowGroupRows
search/search.go:262
Struct
rowRange
search/rowrange.go:11
Interface
rowWriterFlusher
convert/convert.go:348
FuncType
selectFn
func(context.Context, bool, *storage.SelectHints, ...*labels.Matcher) storage.SeriesSet
db/seriesset.go:37
Struct
seriesSetBuilder
db/shard.go:236
Struct
serveOpts
cmd/serve.go:40
Struct
singleBlockSyncer
db/db_test.go:1052
Struct
slogAdapter
cmd/config.go:128
Struct
sortingWriter
convert/sort.go:17
Interface
syncer
db/db.go:28
Struct
syncerConfig
db/syncer.go:44
Struct
testRows
search/search_test.go:169
Struct
thanosAPIOpts
cmd/serve.go:285
Struct
tracingOpts
cmd/config.go:137
Struct
verticalSeriesSet
db/seriesset.go:94
Struct
x
proto/metapb/meta.pb.go:198