iter

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

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.