Documentation
¶
Index ¶
- Variables
- func NewParquetQueryable(shardFinder ShardsFinderFunction, constraintCacheFunc ConstraintCacheFunction, ...) (prom_storage.Queryable, error)
- type ConstraintCacheFunction
- type QueryableOpts
- func WithCacheRowRangesForConstraints(cache bool) QueryableOpts
- func WithChunkBytesLimitFunc(fn search.QuotaLimitFunc) QueryableOpts
- func WithConcurrency(concurrency int) QueryableOpts
- func WithDataBytesLimitFunc(fn search.QuotaLimitFunc) QueryableOpts
- func WithHonorProjectionHints(honor bool) QueryableOpts
- func WithMaterializedLabelsFilterCallback(cb search.MaterializedLabelsFilterCallback) QueryableOpts
- func WithMaterializedSeriesCallback(fn search.MaterializedSeriesFunc) QueryableOpts
- func WithRowCountLimitFunc(fn search.QuotaLimitFunc) QueryableOpts
- type ShardsFinderFunction
Constants ¶
This section is empty.
Variables ¶
var DefaultQueryableOpts = queryableOpts{ // contains filtered or unexported fields }
Functions ¶
func NewParquetQueryable ¶
func NewParquetQueryable( shardFinder ShardsFinderFunction, constraintCacheFunc ConstraintCacheFunction, chunksDecoder *schema.PrometheusParquetChunksDecoder, opts ...QueryableOpts, ) (prom_storage.Queryable, error)
Types ¶
type ConstraintCacheFunction ¶
type ConstraintCacheFunction func(ctx context.Context) (search.RowRangesForConstraintsCache, error)
type QueryableOpts ¶
type QueryableOpts func(*queryableOpts)
func WithCacheRowRangesForConstraints ¶
func WithCacheRowRangesForConstraints(cache bool) QueryableOpts
WithCacheRowRangesForConstraints set the concurrency that can be used to run the query
func WithChunkBytesLimitFunc ¶
func WithChunkBytesLimitFunc(fn search.QuotaLimitFunc) QueryableOpts
WithChunkBytesLimitFunc sets a callback function to get limit for chunk column page bytes fetched.
func WithConcurrency ¶
func WithConcurrency(concurrency int) QueryableOpts
WithConcurrency set the concurrency that can be used to run the query
func WithDataBytesLimitFunc ¶
func WithDataBytesLimitFunc(fn search.QuotaLimitFunc) QueryableOpts
WithDataBytesLimitFunc sets a callback function to get limit for data (including label and chunk) column page bytes fetched.
func WithHonorProjectionHints ¶
func WithHonorProjectionHints(honor bool) QueryableOpts
WithHonorProjectionHints enables or disables projection pushdown optimization. When enabled, only the labels specified in SelectHints.ProjectionLabels will be materialized.
func WithMaterializedLabelsFilterCallback ¶
func WithMaterializedLabelsFilterCallback(cb search.MaterializedLabelsFilterCallback) QueryableOpts
WithMaterializedLabelsFilterCallback sets a callback function to create a filter that can be used to filter series based on their labels before materializing chunks.
func WithMaterializedSeriesCallback ¶
func WithMaterializedSeriesCallback(fn search.MaterializedSeriesFunc) QueryableOpts
WithMaterializedSeriesCallback sets a callback function to process the materialized series.
func WithRowCountLimitFunc ¶
func WithRowCountLimitFunc(fn search.QuotaLimitFunc) QueryableOpts
WithRowCountLimitFunc sets a callback function to get limit for matched row count.
Source Files