metricsview

Jan 30, 2025

Changes in this version

type TimestampsResult

+ Now time.Time

Jan 27, 2025

Changes in this version

type Executor

+ func (e *Executor) BindQuery(ctx context.Context, qry *Query, timestamps TimestampsResult) error

+ func (e *Executor) Timestamps(ctx context.Context) (TimestampsResult, error)

type TimeRange

+ Expression string

+ type TimestampsResult struct

+ Max time.Time

+ Min time.Time

+ Watermark time.Time

Jan 22, 2025

Changes in this version

type Executor

+ func (e *Executor) CacheKey(ctx context.Context) ([]byte, bool, error)

Jan 17, 2025

Changes in this version

type SelectNode

+ RawSelect *ExprNode

Dec 19, 2024

Changes in this version

+ type IndexErr struct

+ Err error

+ Idx int

+ type ValidateMetricsViewResult struct

+ DimensionErrs []IndexErr

+ MeasureErrs []IndexErr

+ OtherErrs []error

+ TimeDimensionErr error

+ func (r *ValidateMetricsViewResult) Error() error

+ func (r *ValidateMetricsViewResult) IsZero() bool

Nov 20, 2024

Changes in this version

type FieldNode

+ DisplayName string

type Query

+ UseDisplayNames bool

Sep 13, 2024

Changes in this version

type Executor

+ func (e *Executor) Search(ctx context.Context, qry *SearchQuery, executionTime *time.Time) ([]SearchResult, error)

type MeasureCompute

+ PercentOfTotal *MeasureComputePercentOfTotal

+ URI *MeasureComputeURI

+ type MeasureComputePercentOfTotal struct

+ Measure string

+ Total *float64

+ type MeasureComputeURI struct

+ Dimension string

+ type SearchQuery struct

+ Dimensions []string

+ Having *Expression

+ Limit *int64

+ MetricsView string

+ Search string

+ TimeRange *TimeRange

+ Where *Expression

+ type SearchResult struct

+ Dimension string

+ Value any

Aug 28, 2024

Changes in this version

type FieldNode

+ AutoUnnest bool

Aug 8, 2024

Changes in this version

type AST

+ CTEs []*SelectNode

type Executor

+ func (e *Executor) Cacheable(qry *Query) bool

type SelectNode

+ IsCTE bool

Jul 9, 2024

Changes in this version

+ type JoinType string

+ const JoinTypeFull

+ const JoinTypeLeft

+ const JoinTypeRight

+ const JoinTypeUnspecified

Jul 8, 2024

Changes in this version

+ func ExpressionToString(e *Expression) (string, error)

+ type AST struct

+ Root *SelectNode

+ func NewAST(mv *runtimev1.MetricsViewSpec, sec *runtime.ResolvedSecurity, qry *Query, ...) (*AST, error)

+ func (a *AST) SQL() (string, []any, error)

+ type Condition struct

+ Expressions []*Expression

+ Operator Operator

+ type Dimension struct

+ Compute *DimensionCompute

+ Name string

+ type DimensionCompute struct

+ TimeFloor *DimensionComputeTimeFloor

+ type DimensionComputeTimeFloor struct

+ Dimension string

+ Grain TimeGrain

+ type Executor struct

+ func NewExecutor(ctx context.Context, rt *runtime.Runtime, instanceID string, ...) (*Executor, error)

+ func (e *Executor) Close()

+ func (e *Executor) Export(ctx context.Context, qry *Query, executionTime *time.Time, ...) (string, error)

+ func (e *Executor) Query(ctx context.Context, qry *Query, executionTime *time.Time) (*drivers.Result, bool, error)

+ func (e *Executor) Schema(ctx context.Context) (*runtimev1.StructType, error)

+ func (e *Executor) ValidateMetricsView(ctx context.Context) error

+ func (e *Executor) ValidateQuery(qry *Query) error

+ func (e *Executor) Watermark(ctx context.Context) (time.Time, error)

+ type ExprNode struct

+ Args []any

+ Expr string

+ type Expression struct

+ Condition *Condition

+ Name string

+ Subquery *Subquery

+ Value any

+ func NewExpressionFromProto(expr *runtimev1.Expression) *Expression

+ type FieldNode struct

+ Expr string

+ Label string

+ Name string

+ type Measure struct

+ Compute *MeasureCompute

+ Name string

+ type MeasureCompute struct

+ ComparisonDelta *MeasureComputeComparisonDelta

+ ComparisonRatio *MeasureComputeComparisonRatio

+ ComparisonValue *MeasureComputeComparisonValue

+ Count bool

+ CountDistinct *MeasureComputeCountDistinct

+ func (m *MeasureCompute) Validate() error

+ type MeasureComputeComparisonDelta struct

+ Measure string

+ type MeasureComputeComparisonRatio struct

+ Measure string

+ type MeasureComputeComparisonValue struct

+ Measure string

+ type MeasureComputeCountDistinct struct

+ Dimension string

+ type Operator string

+ const OperatorAnd

+ const OperatorEq

+ const OperatorGt

+ const OperatorGte

+ const OperatorIlike

+ const OperatorIn

+ const OperatorLt

+ const OperatorLte

+ const OperatorNeq

+ const OperatorNilike

+ const OperatorNin

+ const OperatorOr

+ const OperatorUnspecified

+ func (o Operator) Valid() bool

+ type OrderFieldNode struct

+ Desc bool

+ Name string

+ type Query struct

+ ComparisonTimeRange *TimeRange

+ Dimensions []Dimension

+ Having *Expression

+ Label bool

+ Limit *int64

+ Measures []Measure

+ MetricsView string

+ Offset *int64

+ PivotOn []string

+ Sort []Sort

+ Spine *Spine

+ TimeRange *TimeRange

+ TimeZone string

+ Where *Expression

+ type SelectNode struct

+ Alias string

+ DimFields []FieldNode

+ FromSelect *SelectNode

+ FromTable *string

+ Group bool

+ Having *ExprNode

+ JoinComparisonSelect *SelectNode

+ JoinComparisonType string

+ LeftJoinSelects []*SelectNode

+ Limit *int64

+ MeasureFields []FieldNode

+ Offset *int64

+ OrderBy []OrderFieldNode

+ SpineSelect *SelectNode

+ TimeWhere *ExprNode

+ Unnests []string

+ Where *ExprNode

+ type Sort struct

+ Desc bool

+ Name string

+ type Spine struct

+ TimeRange *TimeSpine

+ Where *WhereSpine

+ type Subquery struct

+ Dimension Dimension

+ Having *Expression

+ Measures []Measure

+ Where *Expression

+ type TimeGrain string

+ const TimeGrainDay

+ const TimeGrainHour

+ const TimeGrainMillisecond

+ const TimeGrainMinute

+ const TimeGrainMonth

+ const TimeGrainQuarter

+ const TimeGrainSecond

+ const TimeGrainUnspecified

+ const TimeGrainWeek

+ const TimeGrainYear

+ func TimeGrainFromProto(t runtimev1.TimeGrain) TimeGrain

+ func (t TimeGrain) ToProto() runtimev1.TimeGrain

+ func (t TimeGrain) ToTimeutil() timeutil.TimeGrain

+ func (t TimeGrain) Valid() bool

+ type TimeRange struct

+ End time.Time

+ IsoDuration string

+ IsoOffset string

+ RoundToGrain TimeGrain

+ Start time.Time

+ func (tr *TimeRange) IsZero() bool

+ type TimeSpine struct

+ End time.Time

+ Grain TimeGrain

+ Start time.Time

+ type WhereSpine struct

+ Expression *Expression