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
• type PatternIter
  • func NewEmpty(pattern string) *PatternIter
  • func NewSlice(pattern string, s []logproto.PatternSample) *PatternIter
  • func (s *PatternIter) Pattern() string

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 {
	iter.CloseIterator[logproto.PatternSample]

	Pattern() string
}

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

type PatternIter

type PatternIter struct {
	iter.CloseIterator[logproto.PatternSample]
	// contains filtered or unexported fields
}

func NewEmpty

func NewEmpty(pattern string) *PatternIter

func NewSlice

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

func (*PatternIter) Pattern

func (s *PatternIter) Pattern() string