Versions in this module Expand all Collapse all v1 v1.6.2 Jan 17, 2024 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() + func NewCachedIterator(it EntryIterator, cap int) CacheEntryIterator + type CacheSampleIterator interface + Reset func() + func NewCachedSampleIterator(it SampleIterator, cap int) CacheSampleIterator + type EntryIterator interface + Close func() error + Entry func() logproto.Entry + Error func() error + Labels func() string + Next func() bool + func NewEntryReversedIter(it EntryIterator) (EntryIterator, error) + func NewNonOverlappingIterator(iterators []EntryIterator, labels string) EntryIterator + func NewQueryClientIterator(client logproto.Querier_QueryClient, direction logproto.Direction) EntryIterator + func NewQueryResponseIterator(ctx context.Context, resp *logproto.QueryResponse, ...) EntryIterator + func NewReversedIter(it EntryIterator, limit uint32, preload bool) (EntryIterator, error) + func NewStreamIterator(stream logproto.Stream) EntryIterator + func NewStreamsIterator(ctx context.Context, 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 NewHeapIterator(ctx context.Context, is []EntryIterator, direction logproto.Direction) HeapIterator + 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 + Close func() error + Error func() error + Labels func() string + Next func() bool + Sample func() logproto.Sample + func NewHeapSampleIterator(ctx context.Context, is []SampleIterator) SampleIterator + func NewMultiSeriesIterator(ctx context.Context, series []logproto.Series) SampleIterator + func NewNonOverlappingSampleIterator(iterators []SampleIterator, labels string) SampleIterator + func NewSampleQueryClientIterator(client QuerySampleClient) SampleIterator + func NewSampleQueryResponseIterator(ctx context.Context, resp *logproto.SampleQueryResponse) SampleIterator + func NewSeriesIterator(series logproto.Series) SampleIterator + func NewTimeRangedSampleIterator(it SampleIterator, mint, maxt int64) SampleIterator
Go to main page