iter

Documentation

Index

• func ReadBatch(i EntryIterator, size uint32) (*logproto.QueryResponse, uint32, error)
• type EntryIterator
  • func NewEntryIteratorBackward(it EntryIterator) (EntryIterator, error)
  • func NewEntryIteratorForward(it EntryIterator, limit uint32, preload bool) (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

Functions

func ReadBatch

func ReadBatch(i EntryIterator, size uint32) (*logproto.QueryResponse, uint32, error)

ReadBatch reads a set of entries off an iterator.

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 NewEntryIteratorForward

func NewEntryIteratorForward(it EntryIterator, limit uint32, preload bool) (EntryIterator, error)

NewEntryIteratorBackward returns an iterator which loads all or upton N entries of an existing iterator, and then iterates over them backward. preload entries when they are being queried with a timeout

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.