logql

type Engine struct {
	// contains filtered or unexported fields
}

type EngineOpts struct {
	// Timeout for queries execution
	Timeout time.Duration `yaml:"timeout"`
	// MaxLookBackPeriod is the maximun amount of time to look back for log lines.
	// only used for instant log queries.
	MaxLookBackPeriod time.Duration `yaml:"max_look_back_period"`
}

type Expr interface{}

type Filter func(line []byte) bool

type LogSelectorExpr interface {
	Filter() (Filter, error)
	Matchers() []*labels.Matcher
	fmt.Stringer
}

type ParseError struct {
	// contains filtered or unexported fields
}

type Querier interface {
	Select(context.Context, SelectParams) (iter.EntryIterator, error)
}

type QuerierFunc func(context.Context, SelectParams) (iter.EntryIterator, error)

type Query interface {
	// Exec processes the query.
	Exec(ctx context.Context) (promql.Value, error)
}

type RangeVectorAggregator func(int64, []promql.Point) float64

type RangeVectorIterator interface {
	Next() bool
	At(aggregator RangeVectorAggregator) (int64, promql.Vector)
	Close() error
}

type SampleExpr interface {
	// Selector is the LogQL selector to apply when retrieving logs.
	Selector() LogSelectorExpr
	// Evaluator returns a `StepEvaluator` that can evaluate the expression step by step
	Evaluator() StepEvaluator
	// Close all resources used.
	Close() error
}

type SelectParams struct {
	*logproto.QueryRequest
}

type StepEvaluator interface {
	Next() (bool, int64, promql.Vector)
}

type StepEvaluatorFn func() (bool, int64, promql.Vector)

type Streams []*logproto.Stream