Versions in this module Expand all Collapse all v0 v0.1.0 Jul 20, 2026 Changes in this version + const ADD + const ANCE + const AND + const AVG + const AVG_OVER_TIME + const AggregateModeFinal + const AggregateModeRaw + const AggregateModeSum + const BOTTOMK + const BY + const CHILDCOUNT + const CLOSE_BRACE + const CLOSE_PARENS + const COALESCE + const COMMA + const COMPARE + const COUNT + const COUNT_OVER_TIME + const DESC + const DIV + const DOT + const DURATION + const DefaultMaxConditionGroupsPerTagQuery + const DefaultSpansPerSpanSet + const END_ATTRIBUTE + const EQ + const EVENT_COLON + const EVENT_DOT + const FALSE + const FLOAT + const GT + const GTE + const HISTOGRAM_OVER_TIME + const HintConcurrentBlocks + const HintDebug + const HintDebugDataFactor + const HintDebugReturnIn + const HintDebugStdDev + const HintExemplars + const HintInfo + const HintJobSize + const HintMostRecent + const HintNewFetch + const HintSample + const HintSkipASTTransformations + const HintSpanSample + const HintTimeOverlapCutoff + const HintTraceSample + const ID + const IDENTIFIER + const IDURATION + const INSTRUMENTATION_COLON + const INSTRUMENTATION_DOT + const INTEGER + const KIND + const KIND_CLIENT + const KIND_CONSUMER + const KIND_INTERNAL + const KIND_PRODUCER + const KIND_SERVER + const KIND_UNSPECIFIED + const LINK_COLON + const LINK_DOT + const LT + const LTE + const MAX + const MAX_OVER_TIME + const MIN + const MIN_OVER_TIME + const MOD + const MUL + const NAME + const NEQ + const NESTEDSETLEFT + const NESTEDSETPARENT + const NESTEDSETRIGHT + const NIL + const NOT + const NOT_ANCE + const NOT_CHILD + const NOT_DESC + const NOT_PARENT + const NRE + const OPEN_BRACE + const OPEN_PARENS + const OR + const PARENT + const PARENT_DOT + const PARENT_ID + const PIPE + const POW + const QUANTILE_OVER_TIME + const RATE + const RE + const RESOURCE_DOT + const ROOTNAME + const ROOTSERVICE + const ROOTSERVICENAME + const SELECT + const SIBL + const SPAN_COLON + const SPAN_DOT + const SPAN_ID + const STATUS + const STATUS_ERROR + const STATUS_MESSAGE + const STATUS_OK + const STATUS_UNSET + const STRING + const SUB + const SUM + const SUM_OVER_TIME + const TIMESINCESTART + const TOPK + const TRACEDURATION + const TRACE_COLON + const TRACE_ID + const TRUE + const TimestampNever + const TransformationAll + const TransformationOrToIn + const UNION_ANCE + const UNION_CHILD + const UNION_DESC + const UNION_PARENT + const UNION_SIBL + const VERSION + const WITH + var ErrMathNotSupported = errors.New("math expressions not supported") + var ErrMaxConditionGroupsPerTagQueryReached = errors.New("maximum condition groups reached") + var IntrinsicChildCountAttribute = NewIntrinsic(IntrinsicChildCount) + var IntrinsicDurationAttribute = NewIntrinsic(IntrinsicDuration) + var IntrinsicEventNameAttribute = NewIntrinsic(IntrinsicEventName) + var IntrinsicEventTimeSinceStartAttribute = NewIntrinsic(IntrinsicEventTimeSinceStart) + var IntrinsicInstrumentationNameAttribute = NewIntrinsic(IntrinsicInstrumentationName) + var IntrinsicInstrumentationVersionAttribute = NewIntrinsic(IntrinsicInstrumentationVersion) + var IntrinsicKindAttribute = NewIntrinsic(IntrinsicKind) + var IntrinsicLinkSpanIDAttribute = NewIntrinsic(IntrinsicLinkSpanID) + var IntrinsicLinkTraceIDAttribute = NewIntrinsic(IntrinsicLinkTraceID) + var IntrinsicNameAttribute = NewIntrinsic(IntrinsicName) + var IntrinsicNestedSetLeftAttribute = NewIntrinsic(IntrinsicNestedSetLeft) + var IntrinsicNestedSetParentAttribute = NewIntrinsic(IntrinsicNestedSetParent) + var IntrinsicNestedSetRightAttribute = NewIntrinsic(IntrinsicNestedSetRight) + var IntrinsicParentIDAttribute = NewIntrinsic(IntrinsicParentID) + var IntrinsicSpanIDAttribute = NewIntrinsic(IntrinsicSpanID) + var IntrinsicSpanStartTimeAttribute = NewIntrinsic(IntrinsicSpanStartTime) + var IntrinsicStatusAttribute = NewIntrinsic(IntrinsicStatus) + var IntrinsicStatusMessageAttribute = NewIntrinsic(IntrinsicStatusMessage) + var IntrinsicTraceDurationAttribute = NewIntrinsic(IntrinsicTraceDuration) + var IntrinsicTraceIDAttribute = NewIntrinsic(IntrinsicTraceID) + var IntrinsicTraceRootServiceAttribute = NewIntrinsic(IntrinsicTraceRootService) + var IntrinsicTraceRootSpanAttribute = NewIntrinsic(IntrinsicTraceRootSpan) + var StaticFalse = NewStaticBool(false) + var StaticNil = NewStaticNil() + var StaticTrue = NewStaticBool(true) + func AlignEndToLeft(req *tempopb.QueryRangeRequest) + func AlignRequest(req *tempopb.QueryRangeRequest) + func Compile(query string, opts ...CompileOption) (*RootExpr, Pipeline, SpansetFilterFunc, *FetchSpansRequest, error) + func ContainsNonAttributeRune(s string) bool + func DefaultQueryRangeStep(start, end uint64) uint64 + func ExtractConditionGroups(query string, maxGroups int) ([][]Condition, error) + func IsEmptyQuery(query string) bool + func IsInstant(req *tempopb.QueryRangeRequest) bool + func IsValidTransformationName(name string) bool + func KnownTransformationNames() []string + func Log2Bucketize(v uint64) float64 + func Log2Quantile(p float64, buckets []HistogramBucket) float64 + func Log2QuantileWithBucket(p float64, buckets []HistogramBucket) (float64, int) + func MakeCollectTagValueFunc(collect func(tempopb.TagValue) bool) func(v Static) bool + func NeedsFullTrace(e ...Element) bool + func NormalizeQuery(query string) string + func TrimToAfter(req *tempopb.QueryRangeRequest, before time.Time) + func TrimToBefore(req *tempopb.QueryRangeRequest, before time.Time) + func TrimToBlockOverlap(req *tempopb.QueryRangeRequest, blockStart, blockEnd time.Time) (uint64, uint64, uint64) + func Validate(expr *RootExpr) error + type ASTRewriter interface + RewriteRoot func(*RootExpr) *RootExpr + type Aggregate struct + func (a Aggregate) String() string + type AggregateMode int + type AggregateOp int + func (a AggregateOp) String() string + type Attribute struct + Intrinsic Intrinsic + Name string + Parent bool + Scope AttributeScope + func MustParseIdentifier(s string) Attribute + func NewAttribute(att string) Attribute + func NewIntrinsic(n Intrinsic) Attribute + func NewScopedAttribute(scope AttributeScope, parent bool, att string) Attribute + func ParseIdentifier(s string) (Attribute, error) + func (a Attribute) String() string + type AttributeScope int8 + const AttributeScopeEvent + const AttributeScopeInstrumentation + const AttributeScopeLink + const AttributeScopeNone + const AttributeScopeResource + const AttributeScopeSpan + const AttributeScopeTrace + const AttributeScopeUnknown + func AllAttributeScopes() []AttributeScope + func AttributeScopeFromString(s string) AttributeScope + func (s AttributeScope) String() string + type BaselineAggregator struct + func NewBaselineAggregator(req *tempopb.QueryRangeRequest, topN int, exemplars uint32) *BaselineAggregator + func (b *BaselineAggregator) Combine(ss []*tempopb.TimeSeries) + func (b *BaselineAggregator) Length() int + func (b *BaselineAggregator) Results() SeriesSet + type BinaryOperation struct + LHS FieldExpression + Op Operator + RHS FieldExpression + func (o *BinaryOperation) String() string + type ChainedSecondStage []secondStageElement + func (c ChainedSecondStage) String() string + type CoalesceOperation struct + func (o CoalesceOperation) String() string + type CommonIterator interface + Close func() + Next func(context.Context) (T, error) + type CompileOption func(*compileOptions) + func WithSkipOptimization(name string) CompileOption + func WithSpanOnlyFetch(v bool) CompileOption + func WithTimeOverlapCutoff(v float64) CompileOption + func WithUnsafeHints(v bool) CompileOption + type Condition struct + Attribute Attribute + CallBack func() bool + Op Operator + Operands Operands + Precision time.Duration + func ExemplarMetaConditions(cb func() bool) []Condition + func ExemplarMetaConditionsWithout(cb func() bool, remove []Condition, allConditions bool) []Condition + func SearchMetaConditions() []Condition + func SearchMetaConditionsWithout(remove []Condition, allConditions bool) []Condition + type CountOverTimeAggregator struct + func NewCountOverTimeAggregator() *CountOverTimeAggregator + func NewRateAggregator(rateMult float64) *CountOverTimeAggregator + func (c *CountOverTimeAggregator) Observe(_ Span) + func (c *CountOverTimeAggregator) Sample() float64 + type Element interface + type Engine struct + func NewEngine() *Engine + func (e *Engine) CompileMetricsQueryRange(req *tempopb.QueryRangeRequest, opts ...CompileOption) (MetricsEvaluator, error) + func (e *Engine) CompileMetricsQueryRangeNonRaw(req *tempopb.QueryRangeRequest, mode AggregateMode, opts ...CompileOption) (*MetricsFrontendEvaluator, error) + func (e *Engine) ExecuteSearch(ctx context.Context, searchReq *tempopb.SearchRequest, fetcher SpansetFetcher, ...) (*tempopb.SearchResponse, error) + func (e *Engine) ExecuteTagNames(ctx context.Context, scope AttributeScope, conditionGroups [][]Condition, ...) error + func (e *Engine) ExecuteTagValues(ctx context.Context, tag Attribute, conditionGroups [][]Condition, ...) error + type Exemplar struct + Labels Labels + TimestampMs uint64 + Value float64 + type FastStatic interface + type FastStatic1 [1]StaticMapKey + type FastStatic2 [2]StaticMapKey + type FastStatic3 [3]StaticMapKey + type FastStatic4 [4]StaticMapKey + type FastStatic5 [5]StaticMapKey + type FetchSpansOnlyResponse struct + Bytes func() uint64 + Results SpanIterator + type FetchSpansRequest struct + AllConditions bool + Conditions []Condition + EndTimeUnixNanos uint64 + SecondPass SecondPassFn + SecondPassConditions []Condition + SecondPassSelectAll bool + SpanSampler Sampler + StartTimeUnixNanos uint64 + TraceSampler Sampler + func ExtractFetchSpansRequest(query string) (FetchSpansRequest, error) + func MustExtractFetchSpansRequestWithMetadata(query string) FetchSpansRequest + func (f *FetchSpansRequest) HasAttribute(a Attribute) bool + func (f *FetchSpansRequest) HasAttributeWithOp(a Attribute, o Operator) bool + func (f *FetchSpansRequest) SecondPassHasAttribute(a Attribute) bool + type FetchSpansResponse struct + Bytes func() uint64 + Results SpansetIterator + type FetchTagValuesCallback func(static Static) bool + type FetchTagValuesRequest struct + ConditionGroups [][]Condition + TagName Attribute + type FetchTagsCallback func(tag string, scope AttributeScope) bool + type FetchTagsRequest struct + ConditionGroups [][]Condition + Scope AttributeScope + type FieldExpression interface + type GroupOperation struct + Expression FieldExpression + func (o GroupOperation) String() string + type GroupingAggregator struct + func (g *GroupingAggregator[F, S]) Length() int + func (g *GroupingAggregator[F, S]) Observe(span Span) + func (g *GroupingAggregator[F, S]) ObserveExemplar(span Span, value float64, ts uint64) + func (g *GroupingAggregator[F, S]) Series() SeriesSet + type Hint struct + Name string + Value Static + type Hints struct + Hints []*Hint + func (h *Hints) Get(k string, t StaticType, allowUnsafe bool) (v Static, ok bool) + func (h *Hints) GetBool(k string, allowUnsafe bool) (v, ok bool) + func (h *Hints) GetDuration(k string, allowUnsafe bool) (v time.Duration, ok bool) + func (h *Hints) GetFloat(k string, allowUnsafe bool) (v float64, ok bool) + func (h *Hints) GetInt(k string, allowUnsafe bool) (v int, ok bool) + func (h *Hints) GetStringSlice(k string, allowUnsafe bool) (v []string, ok bool) + func (h *Hints) String() string + type Histogram struct + Buckets []HistogramBucket + func (h *Histogram) Record(bucket float64, count int) + type HistogramAggregator struct + func NewHistogramAggregator(req *tempopb.QueryRangeRequest, qs []float64, exemplarLimit uint32) *HistogramAggregator + func (h *HistogramAggregator) Combine(in []*tempopb.TimeSeries) + func (h *HistogramAggregator) Length() int + func (h *HistogramAggregator) Results() SeriesSet + type HistogramBucket struct + Count int + Max float64 + type InstantAggregator struct + func NewInstantAggregator(start, end uint64, innerAgg func() VectorAggregator) *InstantAggregator + func (i *InstantAggregator) Exemplars() []Exemplar + func (i *InstantAggregator) Length() int + func (i *InstantAggregator) Observe(span Span) + func (i *InstantAggregator) ObserveExemplar(float64, uint64, Labels) + func (i *InstantAggregator) Samples() []float64 + type IntervalMapper interface + Interval func(ts uint64) int + IntervalCount func() int + IntervalMs func(ts int64) int + TimestampOf func(interval int) uint64 + func NewIntervalMapper(start, end, step uint64, instant bool) IntervalMapper + func NewIntervalMapperFromReq(req *tempopb.QueryRangeRequest) IntervalMapper + type IntervalMapperInstant struct + func (i IntervalMapperInstant) Interval(ts uint64) int + func (i IntervalMapperInstant) IntervalCount() int + func (i IntervalMapperInstant) IntervalMs(tsmill int64) int + func (i IntervalMapperInstant) TimestampOf(int) uint64 + type IntervalMapperQueryRange struct + func (i IntervalMapperQueryRange) Interval(ts uint64) int + func (i IntervalMapperQueryRange) IntervalCount() int + func (i IntervalMapperQueryRange) IntervalMs(tsmill int64) int + func (i IntervalMapperQueryRange) TimestampOf(interval int) uint64 + type Intrinsic int8 + const IntrinsicChildCount + const IntrinsicDuration + const IntrinsicEventName + const IntrinsicEventTimeSinceStart + const IntrinsicInstrumentationName + const IntrinsicInstrumentationVersion + const IntrinsicKind + const IntrinsicLinkSpanID + const IntrinsicLinkTraceID + const IntrinsicName + const IntrinsicNestedSetLeft + const IntrinsicNestedSetParent + const IntrinsicNestedSetRight + const IntrinsicNone + const IntrinsicParent + const IntrinsicParentID + const IntrinsicServiceStats + const IntrinsicSpanID + const IntrinsicSpanStartTime + const IntrinsicStatus + const IntrinsicStatusMessage + const IntrinsicStructuralChild + const IntrinsicStructuralDescendant + const IntrinsicStructuralSibling + const IntrinsicTraceDuration + const IntrinsicTraceID + const IntrinsicTraceRootService + const IntrinsicTraceRootSpan + const IntrinsicTraceStartTime + const ScopedIntrinsicSpanDuration + const ScopedIntrinsicSpanKind + const ScopedIntrinsicSpanName + const ScopedIntrinsicSpanStatus + const ScopedIntrinsicSpanStatusMessage + const ScopedIntrinsicTraceDuration + const ScopedIntrinsicTraceRootName + const ScopedIntrinsicTraceRootService + func (i Intrinsic) String() string + type Kind int + const KindClient + const KindConsumer + const KindInternal + const KindProducer + const KindServer + const KindUnspecified + func (k Kind) String() string + type Label struct + Name string + Value Static + type Labels []Label + func LabelsFromArgs(args ...any) Labels + func LabelsFromProto(ls []commonv1proto.KeyValue) Labels + func (ls Labels) Add(label Label) Labels + func (ls Labels) GetValue(name string) Static + func (ls Labels) Has(name string) bool + func (ls Labels) MapKey() SeriesMapKey + func (ls Labels) String() string + type MetadataCombiner interface + AddMetadata func(*tempopb.TraceSearchMetadata) bool + IsCompleteFor func(ts uint32) bool + Metadata func() []*tempopb.TraceSearchMetadata + MetadataAfter func(ts uint32) []*tempopb.TraceSearchMetadata + func NewMetadataCombiner(limit int, keepMostRecent bool) MetadataCombiner + type MetricsAggregate struct + func (a MetricsAggregate) String() string + type MetricsAggregateOp int + func (a MetricsAggregateOp) String() string + type MetricsCompare struct + func (m *MetricsCompare) String() string + type MetricsEvaluator interface + Do func(ctx context.Context, f SpansetFetcher, fetcherStart, fetcherEnd uint64, ...) error + Length func() int + Metrics func() (uint64, uint64, uint64) + Results func() SeriesSet + type MetricsFilter struct + func (m *MetricsFilter) String() string + type MetricsFrontendEvaluator struct + func (m *MetricsFrontendEvaluator) Length() int + func (m *MetricsFrontendEvaluator) ObserveSeries(in []*tempopb.TimeSeries) + func (m *MetricsFrontendEvaluator) Results() SeriesSet + type Operands []Static + type Operator int + const OpAdd + const OpAnd + const OpDiv + const OpEqual + const OpExists + const OpGreater + const OpGreaterEqual + const OpIn + const OpLess + const OpLessEqual + const OpMod + const OpMult + const OpNone + const OpNot + const OpNotEqual + const OpNotExists + const OpNotIn + const OpNotRegex + const OpOr + const OpPower + const OpRegex + const OpRegexMatchAny + const OpRegexMatchNone + const OpSpansetAncestor + const OpSpansetAnd + const OpSpansetChild + const OpSpansetDescendant + const OpSpansetNotAncestor + const OpSpansetNotChild + const OpSpansetNotDescendant + const OpSpansetNotParent + const OpSpansetNotSibling + const OpSpansetParent + const OpSpansetSibling + const OpSpansetUnion + const OpSpansetUnionAncestor + const OpSpansetUnionChild + const OpSpansetUnionDescendant + const OpSpansetUnionParent + const OpSpansetUnionSibling + const OpSub + func (op Operator) String() string + type OverTimeAggregator struct + func NewOverTimeAggregator(attr Attribute, op SimpleAggregationOp) *OverTimeAggregator + func (c *OverTimeAggregator) Observe(s Span) + func (c *OverTimeAggregator) Sample() float64 + type ParseError struct + func (p *ParseError) Error() string + type Pipeline struct + Elements []PipelineElement + func (p Pipeline) String() string + type PipelineElement interface + type QueryRangeCombiner struct + func QueryRangeCombinerFor(req *tempopb.QueryRangeRequest, mode AggregateMode, maxSeriesLimit int) (*QueryRangeCombiner, error) + func (q *QueryRangeCombiner) Combine(resp *tempopb.QueryRangeResponse) + func (q *QueryRangeCombiner) MaxSeriesReached() bool + func (q *QueryRangeCombiner) Response() *tempopb.QueryRangeResponse + type RangeAggregator interface + Exemplars func() []Exemplar + Length func() int + Observe func(s Span) + ObserveExemplar func(float64, uint64, Labels) + Samples func() []float64 + type RootExpr struct + BatchSpanProcessor map[string]spanProcessor + Hints *Hints + OptimizationCount int + Pipeline map[string]Pipeline + SeriesProcessor map[string]seriesProcessor + func ApplyASTRewrites(r *RootExpr, skip []string) *RootExpr + func CompileFetchSpanRequests(query string, opts ...CompileOption) (*RootExpr, map[string]FetchSpansRequest, error) + func Parse(s string, opts ...CompileOption) (expr *RootExpr, err error) + func ParseLenient(s string) (*RootExpr, error) + func ParseNoOptimizations(s string) (*RootExpr, error) + func (r *RootExpr) IsNoop() bool + func (r *RootExpr) MetricsSecondStage() secondStageElement + func (r *RootExpr) SinglePipeline() (Pipeline, bool) + func (r RootExpr) String() string + type Sampler interface + Expect func(count uint64) + FinalScalingFactor func() float64 + Measured func() + Sample func() bool + type ScalarExpression interface + type ScalarFilter struct + LHS ScalarExpression + Op Operator + RHS ScalarExpression + func (f ScalarFilter) String() string + type ScalarOperation struct + LHS ScalarExpression + Op Operator + RHS ScalarExpression + func (o ScalarOperation) String() string + type SecondPassFn func(*Spanset) ([]*Spanset, error) + type SecondStageOp int + const OpBottomK + const OpTopK + func (op SecondStageOp) String() string + type SelectOperation struct + func (o SelectOperation) String() string + type SeriesAggregator interface + Combine func([]*tempopb.TimeSeries) + Length func() int + Results func() SeriesSet + type SeriesMapKey [maxGroupBys]SeriesMapLabel + type SeriesMapLabel struct + Name string + Value StaticMapKey + type SeriesSet map[SeriesMapKey]TimeSeries + func (set SeriesSet) ToProto(req *tempopb.QueryRangeRequest) []*tempopb.TimeSeries + type ServiceStats struct + ErrorCount uint32 + SpanCount uint32 + type SimpleAggregationOp int + type SimpleAggregator struct + func NewSimpleCombiner(req *tempopb.QueryRangeRequest, op SimpleAggregationOp) *SimpleAggregator + func (b *SimpleAggregator) Combine(in []*tempopb.TimeSeries) + func (b *SimpleAggregator) Length() int + func (b *SimpleAggregator) Results() SeriesSet + type Span interface + AllAttributes func() map[Attribute]Static + AllAttributesFunc func(func(Attribute, Static)) + AttributeFor func(Attribute) (Static, bool) + ChildOf func(lhs []Span, rhs []Span, falseForAll bool, invert bool, union bool, ...) []Span + DescendantOf func(lhs []Span, rhs []Span, falseForAll bool, invert bool, union bool, ...) []Span + DurationNanos func() uint64 + ID func() []byte + SiblingOf func(lhs []Span, rhs []Span, falseForAll bool, union bool, buffer []Span) []Span + StartTimeUnixNanos func() uint64 + type SpanAggregator interface + Length func() int + Observe func(Span) + ObserveExemplar func(Span, float64, uint64) + Series func() SeriesSet + func NewGroupingAggregator(aggName string, innerAgg func() RangeAggregator, by []Attribute, ...) SpanAggregator + type SpanIterator interface + type Spanset struct + Attributes []*SpansetAttribute + DurationNanos uint64 + ReleaseFn func(*Spanset) + RootServiceName string + RootSpanName string + Scalar Static + ServiceStats map[string]ServiceStats + Spans []Span + StartTimeUnixNanos uint64 + TraceID []byte + func (s *Spanset) AddAttribute(key string, value Static) + func (s *Spanset) Release() + type SpansetAttribute struct + Name string + Val Static + type SpansetExpression interface + type SpansetFetcher interface + Fetch func(context.Context, FetchSpansRequest) (FetchSpansResponse, error) + FetchSpans func(context.Context, FetchSpansRequest) (FetchSpansOnlyResponse, error) + func NewSpansetFetcherWrapper(...) SpansetFetcher + func NewSpansetFetcherWrapperBoth(...) SpansetFetcher + type SpansetFetcherWrapper struct + func (s SpansetFetcherWrapper) Fetch(ctx context.Context, request FetchSpansRequest) (FetchSpansResponse, error) + func (s SpansetFetcherWrapper) FetchSpans(ctx context.Context, request FetchSpansRequest) (FetchSpansOnlyResponse, error) + type SpansetFilter struct + Expression FieldExpression + func (f SpansetFilter) String() string + type SpansetFilterFunc func(input []*Spanset) (result []*Spanset, err error) + type SpansetIterator interface + type SpansetOperation struct + LHS SpansetExpression + Op Operator + RHS SpansetExpression + func (o SpansetOperation) String() string + type Static struct + Type StaticType + func NewStaticBool(b bool) Static + func NewStaticBooleanArray(b []bool) Static + func NewStaticDuration(d time.Duration) Static + func NewStaticFloat(f float64) Static + func NewStaticFloatArray(f []float64) Static + func NewStaticInt(i int) Static + func NewStaticIntArray(i []int) Static + func NewStaticKind(k Kind) Static + func NewStaticNil() Static + func NewStaticStatus(s Status) Static + func NewStaticString(s string) Static + func NewStaticStringArray(s []string) Static + func StaticFromAnyValue(a *common_v1.AnyValue) Static + func (s Static) AsAnyValue() *common_v1.AnyValue + func (s Static) Bool() (bool, bool) + func (s Static) BooleanArray() ([]bool, bool) + func (s Static) Duration() (time.Duration, bool) + func (s Static) Elements() iter.Seq2[int, Static] + func (s Static) EncodeToString(quotes bool) string + func (s Static) Equals(o *Static) bool + func (s Static) Float() float64 + func (s Static) FloatArray() ([]float64, bool) + func (s Static) Int() (int, bool) + func (s Static) Int64Array() ([]int64, bool) + func (s Static) IntArray() ([]int, bool) + func (s Static) IsNil() bool + func (s Static) Kind() (Kind, bool) + func (s Static) MapKey() StaticMapKey + func (s Static) NotEquals(o *Static) bool + func (s Static) Status() (Status, bool) + func (s Static) StrictEquals(o *Static) bool + func (s Static) String() string + func (s Static) StringArray() ([]string, bool) + type StaticMapKey struct + type StaticType int + const TypeAttribute + const TypeBoolean + const TypeBooleanArray + const TypeDuration + const TypeFloat + const TypeFloatArray + const TypeInt + const TypeIntArray + const TypeKind + const TypeNil + const TypeSpanset + const TypeStatus + const TypeString + const TypeStringArray + func FloatizeAttribute(s Span, a Attribute) (float64, StaticType) + func (t StaticType) String() string + type StaticVals interface + type StaticVals1 [1]Static + type StaticVals2 [2]Static + type StaticVals3 [3]Static + type StaticVals4 [4]Static + type StaticVals5 [5]Static + type Status int + const StatusError + const StatusOk + const StatusUnset + func (s Status) String() string + type StepAggregator struct + func NewStepAggregator(q *tempopb.QueryRangeRequest, innerAgg func() VectorAggregator) *StepAggregator + func (s *StepAggregator) Exemplars() []Exemplar + func (s *StepAggregator) Length() int + func (s *StepAggregator) Observe(span Span) + func (s *StepAggregator) ObserveExemplar(value float64, ts uint64, lbls Labels) + func (s *StepAggregator) Samples() []float64 + type TagNamesFetcher interface + Fetch func(context.Context, FetchTagsRequest, FetchTagsCallback) error + func NewTagNamesFetcherWrapper(f func(context.Context, FetchTagsRequest, FetchTagsCallback) error) TagNamesFetcher + type TagNamesFetcherWrapper struct + func (s TagNamesFetcherWrapper) Fetch(ctx context.Context, request FetchTagsRequest, callback FetchTagsCallback) error + type TagValuesFetcher interface + Fetch func(context.Context, FetchTagValuesRequest, FetchTagValuesCallback) error + func NewTagValuesFetcherWrapper(f func(context.Context, FetchTagValuesRequest, FetchTagValuesCallback) error) TagValuesFetcher + type TagValuesFetcherWrapper struct + func (s TagValuesFetcherWrapper) Fetch(ctx context.Context, request FetchTagValuesRequest, ...) error + type TimeSeries struct + Exemplars []Exemplar + Labels Labels + Values []float64 + type TopKBottomK struct + func (m *TopKBottomK) String() string + type UnaryOperation struct + Expression FieldExpression + Op Operator + func (o UnaryOperation) String() string + type UngroupedAggregator struct + func (u *UngroupedAggregator) Length() int + func (u *UngroupedAggregator) Observe(span Span) + func (u *UngroupedAggregator) ObserveExemplar(span Span, value float64, ts uint64) + func (u *UngroupedAggregator) Series() SeriesSet + type VectorAggregator interface + Observe func(s Span) + Sample func() float64
Go to main page