Versions in this module Expand all Collapse all v0 v0.26.0 Apr 9, 2022 Changes in this version + var DefaultInMemoryIndexCacheConfig = InMemoryIndexCacheConfig + func NewCachingBucketFromYaml(yamlContent []byte, bucket objstore.Bucket, logger log.Logger, ...) (objstore.InstrumentedBucket, error) + type BucketCacheProvider string + const GroupcacheBucketCacheProvider + const InMemoryBucketCacheProvider + const MemcachedBucketCacheProvider + const RedisBucketCacheProvider + type CachingBucket struct + func NewCachingBucket(b objstore.Bucket, cfg *cache.CachingBucketConfig, logger log.Logger, ...) (*CachingBucket, error) + func (cb *CachingBucket) Attributes(ctx context.Context, name string) (objstore.ObjectAttributes, error) + func (cb *CachingBucket) Exists(ctx context.Context, name string) (bool, error) + func (cb *CachingBucket) Get(ctx context.Context, name string) (io.ReadCloser, error) + func (cb *CachingBucket) GetRange(ctx context.Context, name string, off, length int64) (io.ReadCloser, error) + func (cb *CachingBucket) IsObjNotFoundErr(err error) bool + func (cb *CachingBucket) Iter(ctx context.Context, dir string, f func(string) error, ...) error + func (cb *CachingBucket) Name() string + func (cb *CachingBucket) ReaderWithExpectedErrs(expectedFunc objstore.IsOpFailureExpectedFunc) objstore.BucketReader + func (cb *CachingBucket) WithExpectedErrs(expectedFunc objstore.IsOpFailureExpectedFunc) objstore.Bucket + type CachingWithBackendConfig struct + BackendConfig interface{} + BlocksIterTTL time.Duration + ChunkObjectAttrsTTL time.Duration + ChunkSubrangeSize int64 + ChunkSubrangeTTL time.Duration + MaxChunksGetRangeRequests int + MetafileContentTTL time.Duration + MetafileDoesntExistTTL time.Duration + MetafileExistsTTL time.Duration + MetafileMaxSize model.Bytes + Type BucketCacheProvider + func (cfg *CachingWithBackendConfig) Defaults() + type InMemoryIndexCache struct + func NewInMemoryIndexCache(logger log.Logger, reg prometheus.Registerer, conf []byte) (*InMemoryIndexCache, error) + func NewInMemoryIndexCacheWithConfig(logger log.Logger, reg prometheus.Registerer, config InMemoryIndexCacheConfig) (*InMemoryIndexCache, error) + func (c *InMemoryIndexCache) FetchMultiPostings(_ context.Context, blockID ulid.ULID, keys []labels.Label) (hits map[labels.Label][]byte, misses []labels.Label) + func (c *InMemoryIndexCache) FetchMultiSeries(_ context.Context, blockID ulid.ULID, ids []storage.SeriesRef) (hits map[storage.SeriesRef][]byte, misses []storage.SeriesRef) + func (c *InMemoryIndexCache) StorePostings(_ context.Context, blockID ulid.ULID, l labels.Label, v []byte) + func (c *InMemoryIndexCache) StoreSeries(_ context.Context, blockID ulid.ULID, id storage.SeriesRef, v []byte) + type InMemoryIndexCacheConfig struct + MaxItemSize model.Bytes + MaxSize model.Bytes + type IndexCache interface + FetchMultiPostings func(ctx context.Context, blockID ulid.ULID, keys []labels.Label) (hits map[labels.Label][]byte, misses []labels.Label) + FetchMultiSeries func(ctx context.Context, blockID ulid.ULID, ids []storage.SeriesRef) (hits map[storage.SeriesRef][]byte, misses []storage.SeriesRef) + StorePostings func(ctx context.Context, blockID ulid.ULID, l labels.Label, v []byte) + StoreSeries func(ctx context.Context, blockID ulid.ULID, id storage.SeriesRef, v []byte) + func NewIndexCache(logger log.Logger, confContentYaml []byte, reg prometheus.Registerer) (IndexCache, error) + type IndexCacheConfig struct + Config interface{} + Type IndexCacheProvider + type IndexCacheProvider string + const INMEMORY + const MEMCACHED + const REDIS + type JSONIterCodec struct + func (jic JSONIterCodec) Decode(data []byte) ([]string, error) + func (jic JSONIterCodec) Encode(files []string) ([]byte, error) + type RemoteIndexCache struct + func NewMemcachedIndexCache(logger log.Logger, memcached cacheutil.RemoteCacheClient, ...) (*RemoteIndexCache, error) + func NewRemoteIndexCache(logger log.Logger, cacheClient cacheutil.RemoteCacheClient, ...) (*RemoteIndexCache, error) + func (c *RemoteIndexCache) FetchMultiPostings(ctx context.Context, blockID ulid.ULID, lbls []labels.Label) (hits map[labels.Label][]byte, misses []labels.Label) + func (c *RemoteIndexCache) FetchMultiSeries(ctx context.Context, blockID ulid.ULID, ids []storage.SeriesRef) (hits map[storage.SeriesRef][]byte, misses []storage.SeriesRef) + func (c *RemoteIndexCache) StorePostings(ctx context.Context, blockID ulid.ULID, l labels.Label, v []byte) + func (c *RemoteIndexCache) StoreSeries(ctx context.Context, blockID ulid.ULID, id storage.SeriesRef, v []byte)