iter

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
  • func NewHeapIterator(is []EntryIterator, direction logproto.Direction) HeapIterator

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.