Directories
¶
| Path | Synopsis |
|---|---|
|
Package analytics provides real-time search analytics collection and aggregation.
|
Package analytics provides real-time search analytics collection and aggregation. |
|
aggregator
Package aggregator provides persistent storage and periodic snapshotting of aggregated analytics stats to PostgreSQL.
|
Package aggregator provides persistent storage and periodic snapshotting of aggregated analytics stats to PostgreSQL. |
|
collector
Package collector provides a batch-oriented analytics event collector that accumulates events in memory and flushes them to Kafka in bulk.
|
Package collector provides a batch-oriented analytics event collector that accumulates events in memory and flushes them to Kafka in bulk. |
|
auth
|
|
|
apikey
Package apikey provides SHA-256-based API key validation against PostgreSQL.
|
Package apikey provides SHA-256-based API key validation against PostgreSQL. |
|
ratelimit
Package ratelimit provides an in-memory token-bucket rate limiter.
|
Package ratelimit provides an in-memory token-bucket rate limiter. |
|
gateway
|
|
|
handler
Package handler implements the API gateway's HTTP endpoints.
|
Package handler implements the API gateway's HTTP endpoints. |
|
middleware
Package middleware provides HTTP middleware for the API gateway including authentication, CORS, and rate limiting.
|
Package middleware provides HTTP middleware for the API gateway including authentication, CORS, and rate limiting. |
|
router
Package router wires up all API gateway routes and applies the middleware chain (RequestID → CORS → Auth → RateLimit).
|
Package router wires up all API gateway routes and applies the middleware chain (RequestID → CORS → Auth → RateLimit). |
|
Package indexer implements the core indexing engine.
|
Package indexer implements the core indexing engine. |
|
consumer
Package consumer reads ingestion events from Kafka and indexes them via the indexer engine, optionally routing documents through the shard router for partitioned indexing.
|
Package consumer reads ingestion events from Kafka and indexes them via the indexer engine, optionally routing documents through the shard router for partitioned indexing. |
|
index
Package index defines the in-memory inverted-index data structures used by the indexer.
|
Package index defines the in-memory inverted-index data structures used by the indexer. |
|
segment
Package segment implements a custom binary segment file format (.spdx) for persisting inverted-index data to disk.
|
Package segment implements a custom binary segment file format (.spdx) for persisting inverted-index data to disk. |
|
shard
Package shard provides hash-based shard routing for index engines.
|
Package shard provides hash-based shard routing for index engines. |
|
tokenizer
Package tokenizer provides text tokenisation for the search engine.
|
Package tokenizer provides text tokenisation for the search engine. |
|
Package ingestion defines the request/response types and Kafka event schemas used by the document ingestion pipeline.
|
Package ingestion defines the request/response types and Kafka event schemas used by the document ingestion pipeline. |
|
handler
Package handler exposes the HTTP endpoints for the ingestion service, including document ingest and health check.
|
Package handler exposes the HTTP endpoints for the ingestion service, including document ingest and health check. |
|
publisher
Package publisher persists documents to PostgreSQL and publishes ingest events to Kafka for downstream indexing.
|
Package publisher persists documents to PostgreSQL and publishes ingest events to Kafka for downstream indexing. |
|
validator
Package validator provides input validation for ingestion requests.
|
Package validator provides input validation for ingestion requests. |
|
searcher
|
|
|
cache
Package cache provides a Redis-backed query cache with singleflight deduplication.
|
Package cache provides a Redis-backed query cache with singleflight deduplication. |
|
executor
Package executor runs parsed query plans against one or more indexer engines, applying Boolean filtering (AND/OR/NOT) and BM25 ranking.
|
Package executor runs parsed query plans against one or more indexer engines, applying Boolean filtering (AND/OR/NOT) and BM25 ranking. |
|
handler
Package handler exposes the search service HTTP endpoints including query execution, cache management, and health checks.
|
Package handler exposes the search service HTTP endpoints including query execution, cache management, and health checks. |
|
merger
Package merger provides a min-heap based merge of scored results from multiple shards, returning the global top-K documents.
|
Package merger provides a min-heap based merge of scored results from multiple shards, returning the global top-K documents. |
|
parser
Package parser converts raw search query strings into structured QueryPlan objects, recognising AND, OR, and NOT operators and delegating token normalisation to the indexer tokenizer.
|
Package parser converts raw search query strings into structured QueryPlan objects, recognising AND, OR, and NOT operators and delegating token normalisation to the indexer tokenizer. |
|
ranker
Package ranker implements BM25 relevance scoring for search results.
|
Package ranker implements BM25 relevance scoring for search results. |
Click to show internal directories.
Click to hide internal directories.