Versions in this module Expand all Collapse all v3 v3.0.1 Mar 21, 2022 v3.0.0 Mar 21, 2022 Changes in this version + var NoopIterator = noOpIterator + func ReadBatch(i EntryIterator, size uint32) (*logproto.QueryResponse, uint32, error) + func ReadSampleBatch(i SampleIterator, size uint32) (*logproto.SampleQueryResponse, uint32, error) + type CacheEntryIterator interface + Reset func() + Wrapped func() EntryIterator + func NewCachedIterator(it EntryIterator, cap int) CacheEntryIterator + type CacheSampleIterator interface + Reset func() + Wrapped func() SampleIterator + func NewCachedSampleIterator(it SampleIterator, cap int) CacheSampleIterator + type EntryIterator interface + Entry func() logproto.Entry + func NewEntryReversedIter(it EntryIterator) (EntryIterator, error) + func NewNonOverlappingIterator(iterators []EntryIterator) EntryIterator + func NewQueryClientIterator(client logproto.Querier_QueryClient, direction logproto.Direction) EntryIterator + func NewQueryResponseIterator(resp *logproto.QueryResponse, direction logproto.Direction) EntryIterator + func NewReversedIter(it EntryIterator, limit uint32, preload bool) (EntryIterator, error) + func NewSortEntryIterator(is []EntryIterator, direction logproto.Direction) EntryIterator + func NewStreamIterator(stream logproto.Stream) EntryIterator + func NewStreamsIterator(streams []logproto.Stream, direction logproto.Direction) EntryIterator + func NewTimeRangedIterator(it EntryIterator, mint, maxt time.Time) EntryIterator + type HeapIterator interface + Len func() int + Peek func() time.Time + Push func(EntryIterator) + func NewMergeEntryIterator(ctx context.Context, is []EntryIterator, direction logproto.Direction) HeapIterator + type Iterator interface + Close func() error + Error func() error + Labels func() string + Next func() bool + StreamHash func() uint64 + type PeekingEntryIterator interface + Peek func() (string, logproto.Entry, bool) + func NewPeekingIterator(iter EntryIterator) PeekingEntryIterator + type PeekingSampleIterator interface + Peek func() (string, logproto.Sample, bool) + func NewPeekingSampleIterator(iter SampleIterator) PeekingSampleIterator + type QuerySampleClient interface + CloseSend func() error + Context func() context.Context + Recv func() (*logproto.SampleQueryResponse, error) + type SampleIterator interface + Sample func() logproto.Sample + func NewMergeSampleIterator(ctx context.Context, is []SampleIterator) SampleIterator + func NewMultiSeriesIterator(series []logproto.Series) SampleIterator + func NewNonOverlappingSampleIterator(iterators []SampleIterator) SampleIterator + func NewSampleQueryClientIterator(client QuerySampleClient) SampleIterator + func NewSampleQueryResponseIterator(resp *logproto.SampleQueryResponse) SampleIterator + func NewSeriesIterator(series logproto.Series) SampleIterator + func NewSortSampleIterator(is []SampleIterator) SampleIterator + func NewTimeRangedSampleIterator(it SampleIterator, mint, maxt int64) SampleIterator + func SampleIteratorWithClose(it SampleIterator, closeFn func() error) SampleIterator Other modules containing this package github.com/pao214/loki github.com/pao214/loki/v2
Go to main page