Directories
¶
| Path | Synopsis |
|---|---|
|
Package alerts implements CREATE ALERT DDL runtime: scheduler, sinks (webhook, alert_history table), and Prometheus metrics.
|
Package alerts implements CREATE ALERT DDL runtime: scheduler, sinks (webhook, alert_history table), and Prometheus metrics. |
|
Package auth provides authentication and authorization for Wadjet's HTTP API.
|
Package auth provides authentication and authorization for Wadjet's HTTP API. |
|
Package benchnotify pushes benchmark lifecycle events to an SQS queue so an operator can watch a remote run with a blocking receive loop instead of grepping a remembered log format over SSM.
|
Package benchnotify pushes benchmark lifecycle events to an SQS queue so an operator can watch a remote run with a blocking receive loop instead of grepping a remembered log format over SSM. |
|
Package config provides YAML configuration loading for Wadjet.
|
Package config provides YAML configuration loading for Wadjet. |
|
Package coordinator manages query planning, scheduling, and lifecycle tracking.
|
Package coordinator manages query planning, scheduling, and lifecycle tracking. |
|
Package dataplane is the worker↔coord transport for high-rate task traffic that NATS JetStream is a poor fit for at scale: task dispatch, result batches, gather payloads, and per-task progress.
|
Package dataplane is the worker↔coord transport for high-rate task traffic that NATS JetStream is a poor fit for at scale: task dispatch, result batches, gather payloads, and per-task progress. |
|
Package distributed provides NATS-based distributed coordination.
|
Package distributed provides NATS-based distributed coordination. |
|
Package embedding provides text embedding via external APIs (OpenAI, Ollama).
|
Package embedding provides text embedding via external APIs (OpenAI, Ollama). |
|
engine
|
|
|
batch
Package batch provides the core columnar data structures for the execution engine.
|
Package batch provides the core columnar data structures for the execution engine. |
|
diskio
Package diskio bounds the page-cache impact of the worker's large sequential file writes (operator spill files, local cache downloads, stage-output files).
|
Package diskio bounds the page-cache impact of the worker's large sequential file writes (operator spill files, local cache downloads, stage-output files). |
|
exec
Package exec provides the push-based pipeline execution framework.
|
Package exec provides the push-based pipeline execution framework. |
|
exec/kernel
Package kernel provides type-specialized vectorized operations for the query engine.
|
Package kernel provides type-specialized vectorized operations for the query engine. |
|
expr
Package expr provides a typed expression engine for evaluating SQL expressions against record batches.
|
Package expr provides a typed expression engine for evaluating SQL expressions against record batches. |
|
memory
Package memory provides memory tracking and budget enforcement for the query engine.
|
Package memory provides memory tracking and budget enforcement for the query engine. |
|
scan
Package scan provides table scanning with 3-level predicate pushdown.
|
Package scan provides table scanning with 3-level predicate pushdown. |
|
Package format provides output formatting for query results.
|
Package format provides output formatting for query results. |
|
Package geoip provides MaxMind GeoIP2/GeoLite2 database lookups for IP geolocation and ASN enrichment.
|
Package geoip provides MaxMind GeoIP2/GeoLite2 database lookups for IP geolocation and ASN enrichment. |
|
Package harness implements the distributed test harness used by cmd/tpch-harness.
|
Package harness implements the distributed test harness used by cmd/tpch-harness. |
|
Package iceberg provides read-only support for Apache Iceberg table metadata.
|
Package iceberg provides read-only support for Apache Iceberg table metadata. |
|
Package logio decouples log production from the log sink.
|
Package logio decouples log production from the log sink. |
|
Package metrics provides Prometheus instrumentation for Wadjet.
|
Package metrics provides Prometheus instrumentation for Wadjet. |
|
Package optswitch is the registry of optimization kill switches (#287).
|
Package optswitch is the registry of optimization kill switches (#287). |
|
Package oracle is the optimization-invariance differential harness (#287): every corpus query runs with all registered optimizations enabled (baseline), then once per optswitch toggle with just that optimization disabled, then with all of them disabled — and every configuration must produce identical results.
|
Package oracle is the optimization-invariance differential harness (#287): every corpus query runs with all registered optimizations enabled (baseline), then once per optswitch toggle with just that optimization disabled, then with all of them disabled — and every configuration must produce identical results. |
|
collide
Package collide is the COLLIDING-BARE-NAME fixture: three relations whose columns are all called c0, c1, c2, the way SQLancer names every schema it generates.
|
Package collide is the COLLIDING-BARE-NAME fixture: three relations whose columns are all called c0, c1, c2, the way SQLancer names every schema it generates. |
|
dmlassign
Package dmlassign is the SET-value matrix for DML assignment casts, and the PostgreSQL answers it is checked against.
|
Package dmlassign is the SET-value matrix for DML assignment casts, and the PostgreSQL answers it is checked against. |
|
multikey
Package multikey is the fixture and query corpus for correlated subqueries that correlate on MORE THAN ONE column.
|
Package multikey is the fixture and query corpus for correlated subqueries that correlate on MORE THAN ONE column. |
|
shapegen
Package shapegen generates random-but-valid SQL over a described schema, aimed at the shapes a BI client emits and the fixed benchmark corpus does not contain.
|
Package shapegen generates random-but-valid SQL over a described schema, aimed at the shapes a BI client emits and the fixed benchmark corpus does not contain. |
|
sqlgen
Package sqlgen generates random-but-valid SQL queries over a described schema, for differential testing (#288).
|
Package sqlgen generates random-but-valid SQL queries over a described schema, for differential testing (#288). |
|
typematrix
Package typematrix is the fixture and query corpus for the type-coverage gates: one table carrying all 22 column types, and a generated corpus that pushes every type through every consumer that can retain, re-key, re-order or re-encode a value.
|
Package typematrix is the fixture and query corpus for the type-coverage gates: one table carrying all 22 column types, and a generated corpus that pushes every type through every consumer that can retain, re-key, re-order or re-encode a value. |
|
planner
|
|
|
logical
Package logical provides logical query plan representation and optimization.
|
Package logical provides logical query plan representation and optimization. |
|
physical
Package physical defines stage-type string constants used by Stage.Type.
|
Package physical defines stage-type string constants used by Stage.Type. |
|
sql
Package sql provides SQL parsing using a custom recursive descent parser.
|
Package sql provides SQL parsing using a custom recursive descent parser. |
|
Package server provides the HTTP API for Wadjet.
|
Package server provides the HTTP API for Wadjet. |
|
mcp
Package mcp implements a Model Context Protocol (MCP) server for Wadjet.
|
Package mcp implements a Model Context Protocol (MCP) server for Wadjet. |
|
pgwire
Package pgwire implements the PostgreSQL v3 wire protocol frontend.
|
Package pgwire implements the PostgreSQL v3 wire protocol frontend. |
|
Package sqlerr carries a PostgreSQL SQLSTATE alongside an error message.
|
Package sqlerr carries a PostgreSQL SQLSTATE alongside an error message. |
|
storage
|
|
|
catalog
Package catalog manages table schema and partition metadata.
|
Package catalog manages table schema and partition metadata. |
|
compaction
Package compaction merges small Parquet files within a partition into larger files, reducing S3 list overhead and scan file-open costs.
|
Package compaction merges small Parquet files within a partition into larger files, reducing S3 list overhead and scan file-open costs. |
|
dbscan
Package dbscan provides table-function sources for querying external SQL databases (PostgreSQL, MySQL) and producing columnar RecordBatches.
|
Package dbscan provides table-function sources for querying external SQL databases (PostgreSQL, MySQL) and producing columnar RecordBatches. |
|
ingest
Package ingest provides micro-batch accumulation and flushing to object storage.
|
Package ingest provides micro-batch accumulation and flushing to object storage. |
|
json
Package json reads JSON data (JSONL or JSON array format) and converts it to the columnar RecordBatch format used by Wadjet's execution engine.
|
Package json reads JSON data (JSONL or JSON array format) and converts it to the columnar RecordBatch format used by Wadjet's execution engine. |
|
objstore
Package objstore provides an abstraction over S3-compatible object storage.
|
Package objstore provides an abstraction over S3-compatible object storage. |
|
parquet
Package parquet provides Parquet file reading and writing on top of objstore.
|
Package parquet provides Parquet file reading and writing on top of objstore. |
|
partition
Package partition implements Hive-style partitioning for table data.
|
Package partition implements Hive-style partitioning for table data. |
|
Package telemetry provides OpenTelemetry tracing for Wadjet.
|
Package telemetry provides OpenTelemetry tracing for Wadjet. |
|
Package worker implements the distributed task execution worker.
|
Package worker implements the distributed task execution worker. |
|
Package wshf owns the WSHF columnar shuffle wire format: the magics, the envelope codecs, and the one bounds-checked decoder every consumer uses.
|
Package wshf owns the WSHF columnar shuffle wire format: the magics, the envelope codecs, and the one bounds-checked decoder every consumer uses. |
Click to show internal directories.
Click to hide internal directories.