executor

Nov 24, 2025

Changes in this version

type DistributedExecutionContext

+ NodeSelectors func() map[string][]string

+ type TraceExecutable interface

+ Close func()

+ Execute func(context.Context) (iter.Iterator[model.TraceResult], error)

+ type TraceExecutionContext interface

+ Query func(ctx context.Context, opts model.TraceQueryOptions) (model.TraceQueryResult, error)

Oct 7, 2024

Changes in this version

type StreamExecutable

+ Close func()

May 9, 2024

Changes in this version

type MeasureExecutionContext

+ Query func(ctx context.Context, opts pbv1.MeasureQueryOptions) (pbv1.MeasureQueryResult, error)

type StreamExecutionContext

+ Filter func(ctx context.Context, opts pbv1.StreamFilterOptions) (pbv1.StreamFilterResult, error)

+ Query func(ctx context.Context, opts pbv1.StreamQueryOptions) (pbv1.StreamQueryResult, error)

+ Sort func(ctx context.Context, opts pbv1.StreamSortOptions) (pbv1.StreamSortResult, error)

Oct 17, 2023

Changes in this version

+ func WithDistributedExecutionContext(ctx context.Context, ec DistributedExecutionContext) context.Context

+ func WithMeasureExecutionContext(ctx context.Context, ec MeasureExecutionContext) context.Context

+ func WithStreamExecutionContext(ctx context.Context, ec StreamExecutionContext) context.Context

+ type DistributedExecutionContext interface

+ TimeRange func() *modelv1.TimeRange

+ func FromDistributedExecutionContext(ctx context.Context) DistributedExecutionContext

+ type DistributedExecutionContextKey struct

type MeasureExecutionContext

+ func FromMeasureExecutionContext(ctx context.Context) MeasureExecutionContext

+ type MeasureExecutionContextKey struct

type StreamExecutionContext

+ func FromStreamExecutionContext(ctx context.Context) StreamExecutionContext

+ type StreamExecutionContextKey struct

Jun 2, 2022

Changes in this version

+ var EmptyMIterator = emptyMIterator

+ type ExecutionContext interface

+ ParseTagFamily func(family string, item tsdb.Item) (*modelv1.TagFamily, error)

+ Shard func(id common.ShardID) (tsdb.Shard, error)

+ Shards func(entity tsdb.Entity) ([]tsdb.Shard, error)

+ type MIterator interface

+ Close func() error

+ Current func() []*measurev1.DataPoint

+ Next func() bool

+ type MeasureExecutable interface

+ Execute func(MeasureExecutionContext) (MIterator, error)

+ type MeasureExecutionContext interface

+ ParseField func(name string, item tsdb.Item) (*measurev1.DataPoint_Field, error)

+ type StreamExecutable interface

+ Execute func(StreamExecutionContext) ([]*streamv1.Element, error)

+ type StreamExecutionContext interface

+ ParseElementID func(item tsdb.Item) (string, error)