Documentation
¶
Index ¶
- type Fetcher
- func (c *Fetcher) Cache() cache.Cache
- func (c *Fetcher) Client() client.Client
- func (c *Fetcher) FetchChunks(ctx context.Context, chunks []chunk.Chunk) ([]chunk.Chunk, error)
- func (c *Fetcher) IsChunkNotFoundErr(err error) bool
- func (c *Fetcher) Stop()
- func (c *Fetcher) WriteBackCache(ctx context.Context, chunks []chunk.Chunk) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Fetcher ¶
type Fetcher struct {
// contains filtered or unexported fields
}
Fetcher deals with fetching chunk contents from the cache/store, and writing back any misses to the cache. Also responsible for decoding chunks from the cache, in parallel.
func New ¶
func New(cache cache.Cache, cachel2 cache.Cache, cacheStubs bool, schema config.SchemaConfig, storage client.Client, l2CacheHandoff time.Duration) (*Fetcher, error)
New makes a new ChunkFetcher.
func (*Fetcher) FetchChunks ¶
FetchChunks fetches a set of chunks from cache and store. Note, returned chunks are not in the same order they are passed in
func (*Fetcher) IsChunkNotFoundErr ¶
Source Files
Click to show internal directories.
Click to hide internal directories.