storage

Aug 13, 2020

Changes in this version

+ func ActivePeriodConfig(cfg SchemaConfig) int

+ func IsBlockOverlapping(b chunkenc.Block, with *LazyChunk, direction logproto.Direction) bool

+ func NewTableClient(name string, cfg Config) (chunk.TableClient, error)

+ func UsingBoltdbShipper(cfg SchemaConfig) bool

+ 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, filter logql.LineFilter, ...) (iter.SampleIterator, error)

+ type SchemaConfig struct

+ func (cfg *SchemaConfig) Validate() error

type Store

+ SelectLogs func(ctx context.Context, req logql.SelectLogParams) (iter.EntryIterator, error)

+ SelectSamples func(ctx context.Context, req logql.SelectSampleParams) (iter.SampleIterator, error)

May 20, 2020

Changes in this version

+ func RegisterCustomIndexClients(cfg Config, registerer prometheus.Registerer)

type Config

+ BoltDBShipperConfig local.ShipperConfig

type Store

+ GetSeries func(ctx context.Context, req logql.SelectParams) ([]logproto.SeriesIdentifier, error)

Aug 2, 2019

Changes in this version

+ type Config struct

+ MaxChunkBatchSize int

+ func (cfg *Config) RegisterFlags(f *flag.FlagSet)

+ type Store interface

+ LazyQuery func(ctx context.Context, req *logproto.QueryRequest) (iter.EntryIterator, error)

+ func NewStore(cfg Config, storeCfg chunk.StoreConfig, schemaCfg chunk.SchemaConfig, ...) (Store, error)