Versions in this module Expand all Collapse all v0 v0.1.0 Jun 3, 2019 Changes in this version + const GzipLogChunk + 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") + func NewFacade(c Chunk) encoding.Chunk + 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) (iter.EntryIterator, error) + Size func() int + SpaceFor func(*logproto.Entry) bool + func NewDumbChunk() Chunk + 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 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) (iter.EntryIterator, error) + func (c *MemChunk) Size() int + func (c *MemChunk) SpaceFor(*logproto.Entry) bool