iter

Documentation

Index

• func ReadAll(it Iterator) (*logproto.QueryPatternsResponse, error)
• func ReadBatch(it Iterator, batchSize int) (*logproto.QueryPatternsResponse, error)
• type Iterator
  • func NewMerge(iters ...Iterator) Iterator
  • func NewNonOverlappingIterator(pattern string, iterators []Iterator) Iterator
  • func NewQueryClientIterator(client logproto.Pattern_QueryClient) Iterator
  • func NewQueryResponseIterator(resp *logproto.QueryPatternsResponse) Iterator
  • func NewSlice(pattern string, s []logproto.PatternSample) Iterator

Functions

func ReadAll

func ReadAll(it Iterator) (*logproto.QueryPatternsResponse, error)

func ReadBatch

func ReadBatch(it Iterator, batchSize int) (*logproto.QueryPatternsResponse, error)

Types

type Iterator

type Iterator interface {
	Next() bool

	Pattern() string
	At() logproto.PatternSample

	Error() error
	Close() error
}

var Empty Iterator = &emptyIterator{}

func NewMerge

func NewMerge(iters ...Iterator) Iterator

func NewNonOverlappingIterator

func NewNonOverlappingIterator(pattern string, iterators []Iterator) Iterator

NewNonOverlappingIterator gives a chained iterator over a list of iterators.

func NewQueryClientIterator

func NewQueryClientIterator(client logproto.Pattern_QueryClient) Iterator

NewQueryClientIterator returns an iterator over a QueryClient.

func NewQueryResponseIterator

func NewQueryResponseIterator(resp *logproto.QueryPatternsResponse) Iterator

func NewSlice

func NewSlice(pattern string, s []logproto.PatternSample) Iterator