Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 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, cm storage.ClientMetrics, registerer prometheus.Registerer) + func UsingBoltdbShipper(configs []chunk.PeriodConfig) bool + type AsyncStore struct + func NewAsyncStore(store chunk.Store, scfg chunk.SchemaConfig, querier IngesterQuerier, ...) *AsyncStore + func (a *AsyncStore) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, ...) ([][]chunk.Chunk, []*chunk.Fetcher, error) + type ChunkFilterer interface + ShouldFilter func(metric labels.Labels) bool + type ChunkMetrics struct + func NewChunkMetrics(r prometheus.Registerer, maxBatchSize int) *ChunkMetrics + type ChunkStoreConfig struct + MaxLookBackPeriod model.Duration + func (cfg *ChunkStoreConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *ChunkStoreConfig) Validate(logger log.Logger) error + 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, ...) (iter.SampleIterator, error) + type RequestChunkFilterer interface + ForRequest func(ctx context.Context) ChunkFilterer + 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) + SetChunkFilterer func(chunkFilter RequestChunkFilterer) + func NewStore(cfg Config, schemaCfg SchemaConfig, chunkStore chunk.Store, ...) (Store, error) Other modules containing this package github.com/frelon/loki
Go to main page