iter

package

v3.0.0 Latest Latest Go to latest Published: Apr 8, 2024 License: AGPL-3.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

type Iterator interface {
	Next() bool

	Pattern() string
	At() logproto.PatternSample

	Error() error
	Close() error
}

var Empty Iterator = &emptyIterator{}

func NewMerge(iters ...Iterator) Iterator

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

NewNonOverlappingIterator gives a chained iterator over a list of iterators.

func NewQueryClientIterator(client logproto.Pattern_QueryClient) Iterator

NewQueryClientIterator returns an iterator over a QueryClient.

func NewQueryResponseIterator(resp *logproto.QueryPatternsResponse) Iterator

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