Versions in this module Expand all Collapse all v1 v1.0.2 Jul 26, 2019 Changes in this version + const GzipLogChunk + var BufReaderPool = &BufioReaderPool + var BytesBufferPool = pool.New(1 << 9, 1 << 13, 2, func(size int) interface{} { ... }) + var ErrChunkFull = errors.New("chunk full") + var ErrInvalidChecksum = errors.New("invalid checksum") + var ErrInvalidFlag = errors.New("invalid flag") + var ErrInvalidSize = errors.New("invalid size") + var ErrOutOfOrder = errors.New("entry out of order") + var Gzip GzipPool + func NewFacade(c Chunk) encoding.Chunk + type BufioReaderPool struct + func (bufPool *BufioReaderPool) Get(r io.Reader) *bufio.Reader + func (bufPool *BufioReaderPool) Put(b *bufio.Reader) + type Chunk interface + Append func(*logproto.Entry) error + Bounds func() (time.Time, time.Time) + Bytes func() ([]byte, error) + Iterator func(from, through time.Time, direction logproto.Direction, filter logql.Filter) (iter.EntryIterator, error) + Size func() int + SpaceFor func(*logproto.Entry) bool + func NewDumbChunk() Chunk + type CompressionPool interface + GetReader func(io.Reader) CompressionReader + GetWriter func(io.Writer) CompressionWriter + PutReader func(CompressionReader) + PutWriter func(CompressionWriter) + type CompressionReader interface + Read func(p []byte) (int, error) + Reset func(r io.Reader) error + type CompressionWriter interface + Close func() error + Flush func() error + Reset func(w io.Writer) + Write func(p []byte) (int, error) + type Encoding uint8 + const EncDumb + const EncGZIP + const EncNone + func (e Encoding) String() string + type Facade struct + func (Facade) Encoding() encoding.Encoding + func (f *Facade) UnmarshalFromBuf(buf []byte) error + func (f Facade) LokiChunk() Chunk + func (f Facade) Marshal(w io.Writer) error + type GzipPool struct + func (pool *GzipPool) GetReader(src io.Reader) (reader CompressionReader) + func (pool *GzipPool) GetWriter(dst io.Writer) (writer CompressionWriter) + func (pool *GzipPool) PutReader(reader CompressionReader) + func (pool *GzipPool) PutWriter(writer CompressionWriter) + type LazyChunk struct + Chunk chunk.Chunk + Fetcher *chunk.Fetcher + func (c *LazyChunk) Iterator(ctx context.Context, from, through time.Time, direction logproto.Direction, ...) (iter.EntryIterator, error) + type MemChunk struct + func NewByteChunk(b []byte) (*MemChunk, error) + func NewMemChunk(enc Encoding) *MemChunk + func NewMemChunkSize(enc Encoding, blockSize int) *MemChunk + func (c *MemChunk) Append(entry *logproto.Entry) error + func (c *MemChunk) Bounds() (fromT, toT time.Time) + func (c *MemChunk) Bytes() ([]byte, error) + func (c *MemChunk) Close() error + func (c *MemChunk) Encoding() Encoding + func (c *MemChunk) Iterator(mintT, maxtT time.Time, direction logproto.Direction, filter logql.Filter) (iter.EntryIterator, error) + func (c *MemChunk) Size() int + func (c *MemChunk) SpaceFor(*logproto.Entry) bool