executor

package

v0.9.0 Latest Latest Go to latest Published: Nov 24, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Package executor defines the specifications accessing underlying data repositories.

This section is empty.

This section is empty.

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

WithDistributedExecutionContext returns a new context with distributed execution context.

type DistributedExecutionContext interface {
	bus.Broadcaster
	TimeRange() *modelv1.TimeRange
	NodeSelectors() map[string][]string
}

DistributedExecutionContext allows retrieving data through the distributed module.

func FromDistributedExecutionContext(ctx context.Context) DistributedExecutionContext

FromDistributedExecutionContext returns the distributed execution context from context.Context.

type DistributedExecutionContextKey struct{}

DistributedExecutionContextKey is the key of distributed execution context in context.Context.

type MIterator interface {
	Next() bool

	Current() []*measurev1.DataPoint

	Close() error
}

MIterator allows iterating in a measure data set.

type MeasureExecutable interface {
	Execute(context.Context) (MIterator, error)
}

MeasureExecutable allows querying in the measure schema.

type MeasureExecutionContext interface {
	Query(ctx context.Context, opts model.MeasureQueryOptions) (model.MeasureQueryResult, error)
}

MeasureExecutionContext allows retrieving data through the measure module.

type StreamExecutable interface {
	Execute(context.Context) ([]*streamv1.Element, error)
	Close()
}

StreamExecutable allows querying in the stream schema.

type StreamExecutionContext interface {
	Query(ctx context.Context, opts model.StreamQueryOptions) (model.StreamQueryResult, error)
}

StreamExecutionContext allows retrieving data through the stream module.

type TraceExecutable interface {
	Execute(context.Context) (iter.Iterator[model.TraceResult], error)
	Close()
}

TraceExecutable allows querying in the trace schema.

type TraceExecutionContext interface {
	Query(ctx context.Context, opts model.TraceQueryOptions) (model.TraceQueryResult, error)
}

TraceExecutionContext allows retrieving data through the trace module.