Documentation
¶
Index ¶
- type EntryIterator
- func NewEntryIteratorBackward(it EntryIterator) (EntryIterator, error)
- func NewFilter(f func(string) bool, i EntryIterator) EntryIterator
- func NewHeapIterator(is []EntryIterator, direction logproto.Direction) EntryIterator
- 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 NewTimeRangedIterator(it EntryIterator, mint, maxt time.Time) EntryIterator
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 NewFilter ¶
func NewFilter(f func(string) bool, i EntryIterator) EntryIterator
NewFilter builds a filtering iterator.
func NewHeapIterator ¶
func NewHeapIterator(is []EntryIterator, direction logproto.Direction) EntryIterator
NewHeapIterator returns a new iterator which uses a heap to merge together entries for multiple interators.
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 NewTimeRangedIterator ¶
func NewTimeRangedIterator(it EntryIterator, mint, maxt time.Time) EntryIterator
NewTimeRangedIterator returns an iterator which filters entries by time range.
Source Files
Click to show internal directories.
Click to hide internal directories.