Documentation
¶
Index ¶
- func EmitCompactionDirtyRatio(ctx context.Context, schemaID int16, ratio float64)
- func EmitCompactionManifestContractViolation(ctx context.Context, schemaID int16)
- func EmitCompactionRewritePending(ctx context.Context, schemaID int16)
- func EmitLatency(ctx context.Context, stage string, ms int64)
- func EmitPushdownEfficiency(ctx context.Context, schemaID int16, ratio float64)
- func EmitRowCount(ctx context.Context, source string, rows int64)
- func RegisterTelemetryEmitter(fn Emitter)
- type Emitter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EmitCompactionDirtyRatio ¶
EmitCompactionDirtyRatio records the evaluated dirty ratio for a compaction pass. name: "compaction_dirty_ratio" with label {"schema_id": "<id>"}
func EmitCompactionManifestContractViolation ¶
EmitCompactionManifestContractViolation records a contract violation event when compaction detects SaveManifest succeeded without metadata advancement. name: "compaction_manifest_contract_violation_total" with label {"schema_id": "<id>"}
func EmitCompactionRewritePending ¶
EmitCompactionRewritePending records that a rewrite is needed but cannot be applied yet. name: "compaction_rewrite_pending_total" with label {"schema_id": "<id>"}
func EmitLatency ¶
EmitLatency records a latency measure (milliseconds) for a named stage. name: "fed_query_latency_histogram" with label {"stage": "<translation|execution|streaming>"}
func EmitPushdownEfficiency ¶
EmitPushdownEfficiency records pushdown efficiency as a ratio (float64). name: "fed_query_pushdown_efficiency" with label {"schema_id": "<id>"}
func EmitRowCount ¶
EmitRowCount records row counts per source. name: "fed_query_row_count" with label {"source": "pg"|"s3"|"duckdb"}
func RegisterTelemetryEmitter ¶
func RegisterTelemetryEmitter(fn Emitter)
RegisterTelemetryEmitter registers a custom emitter function. Callers can provide an OpenTelemetry-backed emitter or a test stub. Passing nil resets the emitter back to the default no-op implementation.
Source Files