Documentation
¶
Index ¶
- type EntryIterator
- func NewEntryIteratorBackward(it EntryIterator) (EntryIterator, error)
- func NewNonOverlappingIterator(iterators []EntryIterator, labels string) EntryIterator
- func NewQueryClientIterator(client logproto.Querier_QueryClient, direction logproto.Direction) EntryIterator
- func NewQueryResponseIterator(resp *logproto.QueryResponse, direction logproto.Direction) EntryIterator
- func NewStreamIterator(stream *logproto.Stream) EntryIterator
- func NewTimeRangedIterator(it EntryIterator, mint, maxt time.Time) EntryIterator
- type HeapIterator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EntryIterator ¶
type EntryIterator interface {
Next() bool
Entry() logproto.Entry
Labels() string
Error() error
Close() error
}
EntryIterator iterates over entries in time-order.
func NewEntryIteratorBackward ¶
func NewEntryIteratorBackward(it EntryIterator) (EntryIterator, error)
NewEntryIteratorBackward returns an iterator which loads all the entries of an existing iterator, and then iterates over them backward.
func NewNonOverlappingIterator ¶
func NewNonOverlappingIterator(iterators []EntryIterator, labels string) EntryIterator
NewNonOverlappingIterator gives a chained iterator over a list of iterators.
func NewQueryClientIterator ¶
func NewQueryClientIterator(client logproto.Querier_QueryClient, direction logproto.Direction) EntryIterator
NewQueryClientIterator returns an iterator over a QueryClient.
func NewQueryResponseIterator ¶
func NewQueryResponseIterator(resp *logproto.QueryResponse, direction logproto.Direction) EntryIterator
NewQueryResponseIterator returns an iterator over a QueryResponse.
func NewStreamIterator ¶
func NewStreamIterator(stream *logproto.Stream) EntryIterator
NewStreamIterator iterates over entries in a stream.
func NewTimeRangedIterator ¶
func NewTimeRangedIterator(it EntryIterator, mint, maxt time.Time) EntryIterator
NewTimeRangedIterator returns an iterator which filters entries by time range.
type HeapIterator ¶
type HeapIterator interface {
EntryIterator
Peek() time.Time
Len() int
Push(EntryIterator)
}
HeapIterator iterates over a heap of iterators with ability to push new iterators and get some properties like time of entry at peek and len Not safe for concurrent use
func NewHeapIterator ¶
func NewHeapIterator(is []EntryIterator, direction logproto.Direction) HeapIterator
NewHeapIterator returns a new iterator which uses a heap to merge together entries for multiple interators.
Source Files