Versions in this module Expand all Collapse all v1 v1.6.2 Jan 17, 2024 Changes in this version + func ActivePeriodConfig(configs []chunk.PeriodConfig) int + func IsBlockOverlapping(b chunkenc.Block, with *LazyChunk, direction logproto.Direction) bool + func NewTableClient(name string, cfg Config) (chunk.TableClient, error) + func RegisterCustomIndexClients(cfg *Config, registerer prometheus.Registerer) + func UsingBoltdbShipper(configs []chunk.PeriodConfig) bool + type AsyncStore struct + func NewAsyncStore(store chunk.Store, querier IngesterQuerier) *AsyncStore + func (a *AsyncStore) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, ...) ([][]chunk.Chunk, []*chunk.Fetcher, error) + type ChunkMetrics struct + func NewChunkMetrics(r prometheus.Registerer, maxBatchSize int) *ChunkMetrics + type Config struct + BoltDBShipperConfig shipper.Config + MaxChunkBatchSize int + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type IngesterQuerier interface + GetChunkIDs func(ctx context.Context, from, through model.Time, matchers ...*labels.Matcher) ([]string, error) + type LazyChunk struct + Chunk chunk.Chunk + Fetcher *chunk.Fetcher + IsValid bool + func (c *LazyChunk) IsOverlapping(with *LazyChunk, direction logproto.Direction) bool + func (c *LazyChunk) Iterator(ctx context.Context, from, through time.Time, direction logproto.Direction, ...) (iter.EntryIterator, error) + func (c *LazyChunk) SampleIterator(ctx context.Context, from, through time.Time, extractor logql.SampleExtractor, ...) (iter.SampleIterator, error) + type SchemaConfig struct + func (cfg *SchemaConfig) Validate() error + type Store interface + GetSchemaConfigs func() []chunk.PeriodConfig + GetSeries func(ctx context.Context, req logql.SelectLogParams) ([]logproto.SeriesIdentifier, error) + SelectLogs func(ctx context.Context, req logql.SelectLogParams) (iter.EntryIterator, error) + SelectSamples func(ctx context.Context, req logql.SelectSampleParams) (iter.SampleIterator, error) + func NewStore(cfg Config, schemaCfg SchemaConfig, chunkStore chunk.Store, ...) (Store, error)
Go to main page