wal

Documentation

Index

• type BlockStorage
• type ChunkData
• type ChunksEntryIterator
  • func NewChunksEntryIterator(ctx context.Context, storage BlockStorage, chunks []ChunkData, ...) *ChunksEntryIterator[iter.EntryIterator]
  • func (c *ChunksEntryIterator[T]) At() push.Entry
  • func (b *ChunksEntryIterator) Close() error
  • func (b *ChunksEntryIterator) Err() error
  • func (b *ChunksEntryIterator) Labels() string
  • func (b *ChunksEntryIterator) Next() bool
  • func (b *ChunksEntryIterator) StreamHash() uint64
• type ChunksSampleIterator
  • func NewChunksSampleIterator(ctx context.Context, storage BlockStorage, chunks []ChunkData, ...) *ChunksSampleIterator[iter.SampleIterator]
  • func (c *ChunksSampleIterator[T]) At() logproto.Sample
  • func (b *ChunksSampleIterator) Close() error
  • func (b *ChunksSampleIterator) Err() error
  • func (b *ChunksSampleIterator) Labels() string
  • func (b *ChunksSampleIterator) Next() bool
  • func (b *ChunksSampleIterator) StreamHash() uint64
• type Metastore
• type Querier
  • func New(metaStore Metastore, blockStorage BlockStorage) (*Querier, error)
  • func (q *Querier) SelectLogs(ctx context.Context, req logql.SelectLogParams) (iter.EntryIterator, error)
  • func (q *Querier) SelectSamples(ctx context.Context, req logql.SelectSampleParams) (iter.SampleIterator, error)

Types

type BlockStorage

type BlockStorage interface {
	GetObjectRange(ctx context.Context, objectKey string, off, length int64) (io.ReadCloser, error)
}

type ChunkData

type ChunkData struct {
	// contains filtered or unexported fields
}

type ChunksEntryIterator

type ChunksEntryIterator[T iter.EntryIterator] struct {
	// contains filtered or unexported fields
}

ChunksEntryIterator iterates over log entries

func NewChunksEntryIterator

func NewChunksEntryIterator(
	ctx context.Context,
	storage BlockStorage,
	chunks []ChunkData,
	pipeline log.Pipeline,
	direction logproto.Direction,
	minT, maxT int64,
) *ChunksEntryIterator[iter.EntryIterator]

func (*ChunksEntryIterator[T]) At

func (c *ChunksEntryIterator[T]) At() push.Entry

func (*ChunksEntryIterator) Close

func (b *ChunksEntryIterator) Close() error

func (*ChunksEntryIterator) Err

func (b *ChunksEntryIterator) Err() error

func (*ChunksEntryIterator) Labels

func (b *ChunksEntryIterator) Labels() string

func (*ChunksEntryIterator) Next

func (b *ChunksEntryIterator) Next() bool

todo: better chunk batch iterator

func (*ChunksEntryIterator) StreamHash

func (b *ChunksEntryIterator) StreamHash() uint64

type ChunksSampleIterator

type ChunksSampleIterator[T iter.SampleIterator] struct {
	// contains filtered or unexported fields
}

ChunksSampleIterator iterates over metric samples

func NewChunksSampleIterator

func NewChunksSampleIterator(
	ctx context.Context,
	storage BlockStorage,
	chunks []ChunkData,
	extractor log.SampleExtractor,
	minT, maxT int64,
) *ChunksSampleIterator[iter.SampleIterator]

func (*ChunksSampleIterator[T]) At

func (c *ChunksSampleIterator[T]) At() logproto.Sample

func (*ChunksSampleIterator) Close

func (b *ChunksSampleIterator) Close() error

func (*ChunksSampleIterator) Err

func (b *ChunksSampleIterator) Err() error

func (*ChunksSampleIterator) Labels

func (b *ChunksSampleIterator) Labels() string

func (*ChunksSampleIterator) Next

func (b *ChunksSampleIterator) Next() bool

todo: better chunk batch iterator

func (*ChunksSampleIterator) StreamHash

func (b *ChunksSampleIterator) StreamHash() uint64

type Metastore

type Metastore interface {
	ListBlocksForQuery(ctx context.Context, in *metastorepb.ListBlocksForQueryRequest, opts ...grpc.CallOption) (*metastorepb.ListBlocksForQueryResponse, error)
}

type Querier

type Querier struct {
	// contains filtered or unexported fields
}

func New

func New(
	metaStore Metastore,
	blockStorage BlockStorage,
) (*Querier, error)

func (*Querier) SelectLogs

func (q *Querier) SelectLogs(ctx context.Context, req logql.SelectLogParams) (iter.EntryIterator, error)

func (*Querier) SelectSamples

func (q *Querier) SelectSamples(ctx context.Context, req logql.SelectSampleParams) (iter.SampleIterator, error)