Directories
¶
| Path | Synopsis |
|---|---|
|
cache
|
|
|
memory
Package memory provides an in-memory LRU cache with TTL expiration.
|
Package memory provides an in-memory LRU cache with TTL expiration. |
|
multi_level
Package multilevel provides a multi-level cache (L1 memory + L2 Redis) with cache warming, stampede protection, and promotion between levels.
|
Package multilevel provides a multi-level cache (L1 memory + L2 Redis) with cache warming, stampede protection, and promotion between levels. |
|
redis
Package redis provides a Redis-backed cache adapter implementing CachePort.
|
Package redis provides a Redis-backed cache adapter implementing CachePort. |
|
Package enrichment provides OPTIONAL infrastructure adapters for data enrichment — fetching supplementary data from external sources (APIs, databases, Redis) to augment transformation inputs.
|
Package enrichment provides OPTIONAL infrastructure adapters for data enrichment — fetching supplementary data from external sources (APIs, databases, Redis) to augment transformation inputs. |
|
api
Package api provides an HTTP API-based data enrichment adapter with rate limiting, health checks, and circuit breaker support.
|
Package api provides an HTTP API-based data enrichment adapter with rate limiting, health checks, and circuit breaker support. |
|
database
Package database provides a database-backed data enrichment adapter with connection pooling and query building.
|
Package database provides a database-backed data enrichment adapter with connection pooling and query building. |
|
redis
Package redis provides a Redis-backed data enrichment adapter for fast key-value lookups.
|
Package redis provides a Redis-backed data enrichment adapter for fast key-value lookups. |
|
shared
Package shared provides shared utilities for enrichment adapters including circuit breaker and fallback strategies.
|
Package shared provides shared utilities for enrichment adapters including circuit breaker and fallback strategies. |
|
pkg/adapter/error/backoff.go
|
pkg/adapter/error/backoff.go |
|
function
|
|
|
local
Package local provides a local function executor that runs Go functions in-process without network calls.
|
Package local provides a local function executor that runs Go functions in-process without network calls. |
|
serverless
Package serverless provides serverless function executors for AWS Lambda, Azure Functions, and GCP Cloud Functions.
|
Package serverless provides serverless function executors for AWS Lambda, Azure Functions, and GCP Cloud Functions. |
|
Package metrics provides OPTIONAL infrastructure adapters for recording transformation metrics (in-memory, Prometheus, or async).
|
Package metrics provides OPTIONAL infrastructure adapters for recording transformation metrics (in-memory, Prometheus, or async). |
|
async
Package async provides a non-blocking metrics adapter with configurable buffer size and sampling rate for high-throughput applications.
|
Package async provides a non-blocking metrics adapter with configurable buffer size and sampling rate for high-throughput applications. |
|
memory
Package memory provides an in-memory metrics adapter for testing and development.
|
Package memory provides an in-memory metrics adapter for testing and development. |
|
prometheus
Package prometheus provides a Prometheus-compatible metrics adapter that exposes counters, gauges, and histograms via the Prometheus client.
|
Package prometheus provides a Prometheus-compatible metrics adapter that exposes counters, gauges, and histograms via the Prometheus client. |
|
pipeline
|
|
|
dag
Package dag provides a directed acyclic graph implementation for pipeline stage dependency resolution with cycle detection and topological sorting.
|
Package dag provides a directed acyclic graph implementation for pipeline stage dependency resolution with cycle detection and topological sorting. |
|
orchestrator
Package orchestrator provides a DAG pipeline orchestrator that executes pipeline stages in topologically-sorted waves, running independent stages in parallel.
|
Package orchestrator provides a DAG pipeline orchestrator that executes pipeline stages in topologically-sorted waves, running independent stages in parallel. |
|
pkg/adapter/privacy/audit_logger.go
|
pkg/adapter/privacy/audit_logger.go |
|
Package queue provides OPTIONAL infrastructure adapters for job queuing (in-memory or Redis-backed) with priority routing and backpressure.
|
Package queue provides OPTIONAL infrastructure adapters for job queuing (in-memory or Redis-backed) with priority routing and backpressure. |
|
memory
Package memory provides an in-memory priority queue with worker pools, circuit breaker, and backpressure handling.
|
Package memory provides an in-memory priority queue with worker pools, circuit breaker, and backpressure handling. |
|
redis
Package redis provides a Redis-backed queue adapter with priority routing and distributed worker support.
|
Package redis provides a Redis-backed queue adapter with priority routing and distributed worker support. |
|
shared
Package shared provides shared types and utilities for queue adapters including configuration, backpressure, circuit breaker, and priority routing.
|
Package shared provides shared types and utilities for queue adapters including configuration, backpressure, circuit breaker, and priority routing. |
|
Package rule provides a YAML-driven rule engine that compiles rules, indexes fields for fast lookup, evaluates conditions against data, and applies transformations when conditions match.
|
Package rule provides a YAML-driven rule engine that compiles rules, indexes fields for fast lookup, evaluates conditions against data, and applies transformations when conditions match. |
|
Package storage provides OPTIONAL infrastructure adapters for persistent key-value storage (file-based or SQLite database).
|
Package storage provides OPTIONAL infrastructure adapters for persistent key-value storage (file-based or SQLite database). |
|
database
Package database provides a SQLite-backed key-value storage adapter.
|
Package database provides a SQLite-backed key-value storage adapter. |
|
file
Package file provides a file system-backed key-value storage adapter.
|
Package file provides a file system-backed key-value storage adapter. |
Click to show internal directories.
Click to hide internal directories.