Versions in this module Expand all Collapse all v2 v2.6.2 Aug 12, 2022 Changes in this version + func IsBlockOverlapping(b chunkenc.Block, with *LazyChunk, direction logproto.Direction) bool + func NewBucketClient(storageConfig Config) (index.BucketClient, error) + func NewChunkClient(name string, cfg Config, schemaCfg config.SchemaConfig, ...) (client.Client, error) + func NewIndexClient(name string, cfg Config, schemaCfg config.SchemaConfig, limits StoreLimits, ...) (index.Client, error) + func NewObjectClient(name string, cfg Config, clientMetrics ClientMetrics) (client.ObjectClient, error) + func NewTableClient(name string, cfg Config, cm ClientMetrics, registerer prometheus.Registerer) (index.TableClient, error) + func ResetBoltDBIndexClientWithShipper() + type AsyncStore struct + func NewAsyncStore(cfg AsyncStoreCfg, store stores.Store, scfg config.SchemaConfig) *AsyncStore + func (a *AsyncStore) GetChunkRefs(ctx context.Context, userID string, from, through model.Time, ...) ([][]chunk.Chunk, []*fetcher.Fetcher, error) + func (a *AsyncStore) Stats(ctx context.Context, userID string, from, through model.Time, ...) (*stats.Stats, error) + type AsyncStoreCfg struct + IngesterQuerier IngesterQuerier + QueryIngestersWithin time.Duration + type ChunkMetrics struct + func NewChunkMetrics(r prometheus.Registerer, maxBatchSize int) *ChunkMetrics + type ClientMetrics struct + AzureMetrics azure.BlobStorageMetrics + func NewClientMetrics() ClientMetrics + func (c *ClientMetrics) Unregister() + type Config struct + AWSStorageConfig aws.StorageConfig + AsyncStoreConfig AsyncStoreCfg + AzureStorageConfig azure.BlobStorageConfig + BOSStorageConfig baidubce.BOSStorageConfig + BoltDBConfig local.BoltDBConfig + BoltDBShipperConfig shipper.Config + CassandraStorageConfig cassandra.Config + DisableBroadIndexQueries bool + EnableAsyncStore bool + FSConfig local.FSConfig + GCPStorageConfig gcp.Config + GCSConfig gcp.GCSConfig + GrpcConfig grpc.Config + Hedging hedging.Config + IndexCacheValidity time.Duration + IndexQueriesCacheConfig cache.Config + MaxChunkBatchSize int + MaxParallelGetChunk int + Swift openstack.SwiftConfig + TSDBShipperConfig indexshipper.Config + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate() error + type IngesterQuerier interface + GetChunkIDs func(ctx context.Context, from, through model.Time, matchers ...*labels.Matcher) ([]string, error) + Stats func(ctx context.Context, userID string, from, through model.Time, ...) (*stats.Stats, error) + type LazyChunk struct + Chunk chunk.Chunk + Fetcher *fetcher.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 Store interface + GetSchemaConfigs func() []config.PeriodConfig + SelectLogs func(ctx context.Context, req logql.SelectLogParams) (iter.EntryIterator, error) + SelectSamples func(ctx context.Context, req logql.SelectSampleParams) (iter.SampleIterator, error) + Series func(ctx context.Context, req logql.SelectLogParams) ([]logproto.SeriesIdentifier, error) + SetChunkFilterer func(chunkFilter chunk.RequestChunkFilterer) + func NewStore(cfg Config, storeCfg config.ChunkStoreConfig, schemaCfg config.SchemaConfig, ...) (Store, error) + type StoreLimits interface + CardinalityLimit func(userID string) int + MaxChunksPerQueryFromStore func(userID string) int + MaxQueryLength func(userID string) time.Duration Other modules containing this package github.com/yankunsam/loki
Go to main page