query

package
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 24, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package query provides the query common interfaces and utilities.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Span

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

Span is a span of the tracer.

func (*Span) AddSubTrace

func (s *Span) AddSubTrace(trace *commonv1.Trace)

AddSubTrace adds a sub trace to the span.

func (*Span) Error

func (s *Span) Error(err error) *Span

Error marks the span as an error span.

func (*Span) Stop

func (s *Span) Stop()

Stop stops the span.

func (*Span) Tag

func (s *Span) Tag(key, value string) *Span

Tag adds a tag to the span.

func (*Span) Tagf

func (s *Span) Tagf(key, format string, args ...any) *Span

Tagf adds a formatted tag to the span.

type Tracer

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

Tracer is a simple tracer for query. Thread-safety: StartSpan and span mutations are thread-safe and can be called concurrently from multiple goroutines. ToProto() is safe to call concurrently with span operations - it will wait for any async operations to complete.

func GetTracer

func GetTracer(ctx context.Context) *Tracer

GetTracer returns the tracer from the context.

func NewTracer

func NewTracer(ctx context.Context, id string) (*Tracer, context.Context)

NewTracer creates a new tracer.

func (*Tracer) DeepCopy added in v0.9.0

func (t *Tracer) DeepCopy() *commonv1.Trace

DeepCopy creates a deep copy of the trace. This method is thread-safe and can be called concurrently with span operations. It captures a consistent snapshot of the trace tree by locking the tracer and each span as needed.

func (*Tracer) StartSpan

func (t *Tracer) StartSpan(ctx context.Context, format string, args ...interface{}) (*Span, context.Context)

StartSpan starts a new span.

func (*Tracer) ToProto

func (t *Tracer) ToProto() *commonv1.Trace

ToProto returns the proto representation of the tracer.

Directories

Path Synopsis
Package aggregation implements aggregation functions to statistic a range of values.
Package aggregation implements aggregation functions to statistic a range of values.
Package executor defines the specifications accessing underlying data repositories.
Package executor defines the specifications accessing underlying data repositories.
Package logical implements the executable operations.
Package logical implements the executable operations.
measure
Package measure implements execution operations for querying measure data.
Package measure implements execution operations for querying measure data.
stream
Package stream implements execution operations for querying stream data.
Package stream implements execution operations for querying stream data.
trace
Package trace implements execution operations for querying trace data.
Package trace implements execution operations for querying trace data.
Package model defines the structures and interfaces for query options and results.
Package model defines the structures and interfaces for query options and results.
Package tracelabels defines stable query trace tag keys.
Package tracelabels defines stable query trace tag keys.
Package vectorized provides RecordBatch-based columnar execution primitives: schema, columns, operator interfaces, pipeline composition, and memory tracking.
Package vectorized provides RecordBatch-based columnar execution primitives: schema, columns, operator interfaces, pipeline composition, and memory tracking.
frame
Package frame defines the shared, engine-agnostic non-proto columnar binary frame carried as the SendResponse.body for a vec-native query topic.
Package frame defines the shared, engine-agnostic non-proto columnar binary frame carried as the SendResponse.body for a vec-native query topic.
measure
Package measure implements measure-specific vectorized operators (scan, cursor, extract, limit, group-by, aggregation, top, output serialization).
Package measure implements measure-specific vectorized operators (scan, cursor, extract, limit, group-by, aggregation, top, output serialization).
measure/frame
Package frame binds the shared vec columnar frame codec (pkg/query/vectorized/frame) to the measure engine.
Package frame binds the shared vec columnar frame codec (pkg/query/vectorized/frame) to the measure engine.
measure/plan
Package plan is the vectorized measure-query plan tree (G8).
Package plan is the vectorized measure-query plan tree (G8).
stream
Package stream implements stream-specific vectorized query operators: the pull pipeline that scans elements into columnar batches and merges them in index or timestamp order at egress.
Package stream implements stream-specific vectorized query operators: the pull pipeline that scans elements into columnar batches and merges them in index or timestamp order at egress.
stream/frame
Package frame binds the shared vec columnar frame codec (pkg/query/vectorized/frame) to the stream engine.
Package frame binds the shared vec columnar frame codec (pkg/query/vectorized/frame) to the stream engine.
trace
Package trace implements trace-specific vectorized query operators: the two-phase pull pipeline that resolves trace IDs (Phase 1) and materializes spans grouped per trace (Phase 2).
Package trace implements trace-specific vectorized query operators: the two-phase pull pipeline that resolves trace IDs (Phase 1) and materializes spans grouped per trace (Phase 2).

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL