predicate

Documentation

Index

• type DataReader
• type LogCacheQuerier
  • func (l *LogCacheQuerier) Close() error
  • func (l *LogCacheQuerier) LabelValues(name string) ([]string, error)
  • func (l *LogCacheQuerier) Select(ll ...*labels.Matcher) (storage.SeriesSet, error)
• type PromQL
  • func NewPromQL(query string, maxFailures int, r DataReader, ticker <-chan time.Time, ...) *PromQL
  • func (p *PromQL) Predicate() bool

Types

type DataReader

type DataReader interface {
	Read(
		ctx context.Context,
		sourceID string,
		start time.Time,
		opts ...logcache.ReadOption,
	) ([]*loggregator_v2.Envelope, error)
}

type LogCacheQuerier

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

func (*LogCacheQuerier) Close

func (l *LogCacheQuerier) Close() error

func (*LogCacheQuerier) LabelValues

func (l *LogCacheQuerier) LabelValues(name string) ([]string, error)

func (*LogCacheQuerier) Select

func (l *LogCacheQuerier) Select(ll ...*labels.Matcher) (storage.SeriesSet, error)

type PromQL

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

func NewPromQL

func NewPromQL(
	query string,
	maxFailures int,
	r DataReader,
	ticker <-chan time.Time,
	log *log.Logger,
) *PromQL

func (*PromQL) Predicate

func (p *PromQL) Predicate() bool