telemetry

type NoopTelemetry struct {
	fmt.Stringer
}

type ObservableVectorOperator interface {
	model.VectorOperator
	OperatorTelemetry
}

type OperatorTelemetry interface {
	fmt.Stringer

	AddExecutionTimeTaken(time.Duration)
	ExecutionTimeTaken() time.Duration
	IncrementSamplesAtTimestamp(samples int, t int64)
	Samples() *stats.QuerySamples
	LogicalNode() logicalplan.Node
}

type TrackedTelemetry struct {
	fmt.Stringer

	ExecutionTime time.Duration
	LoadedSamples *stats.QuerySamples
	// contains filtered or unexported fields
}