Overview
The Compressor is an L4 domain specialist operating within the Documentation domain of the Prismatic Platform. This agent implements multi-level document compression with a guaranteed minimum of 80% information retention, enabling the platform to manage its extensive documentation corpus -- over 11,300 documents across 90 umbrella applications -- within constrained context windows, storage budgets, and retrieval latency targets.
In large-scale agent ecosystems, context management is a critical operational constraint. Language model interactions have finite context windows, and the Prismatic Platform's documentation corpus far exceeds any single context capacity. The Compressor addresses this by producing tiered compression artifacts: executive summaries, operational digests, and full-detail archives. Each compression level preserves the information density required for its intended use case while aggressively reducing token count and storage footprint.
The agent's compression algorithms go beyond simple truncation or extractive summarization. The Compressor performs semantic analysis to identify information density across document sections, applies importance-weighted compression that preserves high-signal content verbatim while aggressively compressing low-information-density sections, and validates that compressed output maintains semantic equivalence with the source through automated verification pipelines.
Architecture
The Compressor follows a multi-stage pipeline architecture where each stage applies progressively more aggressive compression while tracking information retention metrics.
+-------------------------------------------------------------------+
| Compressor Agent |
+-------------------------------------------------------------------+
| +-------------------+ +-------------------+ +-------------+ |
| | Semantic Analyzer | | Importance Scorer | | Retention | |
| | (Section density) |--->| (Weight assignment) |--->| Validator | |
| +-------------------+ +-------------------+ +-------------+ |
| | | | |
| +-------+-----------+ +--------+----------+ +------+------+ |
| | L1: Executive | | L2: Operational | | L3: Archive | |
| | Summary (10-15%) | | Digest (30-50%) | | Full (100%) | |
| +-------------------+ +-------------------+ +-------------+ |
| | |
| +-----------------------------------------------------------+ |
| | Meilisearch Index (compressed artifacts) | |
| +-----------------------------------------------------------+ |
+-------------------------------------------------------------------+
The Semantic Analyzer examines document structure, identifying sections by their information type (definition, example, reference, narrative) and computing per-section information density scores. The Importance Scorer applies domain-specific weighting that prioritizes technical specifications, API contracts, and behavioral rules over narrative context and examples. The Retention Validator uses semantic similarity metrics to verify that compressed output preserves the source document's meaning within the configured retention threshold.
Each compression level targets a different use case within the platform's operations:
- L1 Executive Summary (10-15% of original): Decision-maker briefings, agent context loading, cross-reference previews
- L2 Operational Digest (30-50% of original): Working context for development sessions, search result previews, inter-agent communication
- L3 Full Archive (100%): Complete reference, audit trails, compliance documentation
Core Capabilities
The Compressor delivers five primary capabilities that span the document compression lifecycle.
Multi-Level Compression produces three compression tiers from every source document, each optimized for different consumption contexts. The compression is deterministic: given the same source document and configuration, the Compressor always produces identical compressed output, enabling reliable caching and incremental update detection.
Information Retention Guarantee enforces a configurable minimum retention threshold (default 80%) through automated semantic similarity validation. Every compressed artifact is compared against its source using embedding-based similarity scoring, and artifacts that fall below the retention threshold are regenerated with less aggressive compression parameters.
Incremental Compression detects changes in source documents and recompresses only affected sections, avoiding full reprocessing of the entire documentation corpus when individual documents change. Change detection operates at the section level using content hashing, enabling targeted recompression that completes in milliseconds rather than seconds.
Search Index Integration pushes compressed artifacts to Meilisearch with appropriate metadata, enabling full-text search across the compressed documentation corpus with sub-50ms query latency. Search results link back to both compressed and full-detail versions of each document.
Context Window Optimization produces compression artifacts specifically sized for target context windows. When an agent needs to load documentation context, the Compressor calculates available token budget and selects or generates artifacts that maximize information delivery within the constraint.
Implementation
The Compressor is implemented as a GenServer-based pipeline that processes documents through configurable compression stages.
defmodule PrismaticDocumentation.Compressor do
@moduledoc """
L4 Domain Specialist for multi-level document compression
with guaranteed information retention and search integration.
"""
use GenServer
alias PrismaticDocumentation.{SemanticAnalyzer, ImportanceScorer, RetentionValidator}
alias PrismaticStorage.Meilisearch, as: SearchIndex
@retention_threshold 0.80
@compression_levels [:executive, :operational, :archive]
defstruct [
:compression_cache,
:retention_scores,
:pending_queue,
:index_state
]
@spec compress(String.t(), keyword()) :: {:ok, map()} | {:error, term()}
def compress(document, opts \\ []) do
GenServer.call(__MODULE__, {:compress, document, opts}, :timer.seconds(30))
end
@impl true
def handle_call({:compress, document, opts}, _from, state) do
level = Keyword.get(opts, :level, :operational)
threshold = Keyword.get(opts, :retention, @retention_threshold)
with {:ok, analysis} <- SemanticAnalyzer.analyze(document),
{:ok, scored} <- ImportanceScorer.score(analysis),
{:ok, compressed} <- apply_compression(scored, level),
{:ok, _validated} <- RetentionValidator.validate(document, compressed, threshold) do
updated_cache = Map.put(state.compression_cache, hash(document), compressed)
{:reply, {:ok, compressed}, %{state | compression_cache: updated_cache}}
else
{:error, :retention_below_threshold} ->
{:ok, fallback} = apply_compression_conservative(document, level)
{:reply, {:ok, fallback}, state}
error ->
{:reply, error, state}
end
end
defp apply_compression(scored_sections, :executive) do
compressed =
scored_sections
|> Enum.filter(&(&1.importance >= 0.8))
|> Enum.map(&summarize_section/1)
|> Enum.join("\n\n")
{:ok, %{level: :executive, content: compressed, ratio: byte_size(compressed)}}
end
defp apply_compression(scored_sections, :operational) do
compressed =
scored_sections
|> Enum.map(fn section ->
if section.importance >= 0.6, do: section.content, else: summarize_section(section)
end)
|> Enum.join("\n\n")
{:ok, %{level: :operational, content: compressed, ratio: byte_size(compressed)}}
end
defp hash(content), do: :crypto.hash(:sha256, content) |> Base.encode16(case: :lower)
end
The compression pipeline uses ETS for caching compressed artifacts and Meilisearch for indexed search access, providing fast retrieval for both targeted lookups and full-text queries across the documentation corpus.
Integration Points
The Compressor integrates with multiple platform subsystems to serve documentation needs across the entire agent ecosystem.
| Component | Protocol | Purpose |
|---|---|---|
| AIAD Registry | GenServer calls | Agent and command documentation compression |
| Meilisearch | REST API | Full-text search index for compressed artifacts |
| Prismatic Web | LiveView channels | Documentation dashboard and viewer |
| ETS Cache | Direct access | High-speed compressed artifact retrieval |
| GitLab Wiki | REST API | External documentation synchronization |
| Session Context | File system | Session context compression for continuity |
| Agent | Relationship | Domain |
|---|---|---|
| context-compression-enforcer-agent | Enforcement partner ensuring compression policies are followed | General |
| context-preservation-specialist-agent | Consumes compressed context artifacts for session restoration | Authority |
| documentation-integrity-specialist | Validates that compression preserves documentation accuracy | Documentation |
Operational Workflow
The Compressor operates in two modes: batch processing for corpus-wide compression and on-demand processing for individual document requests.
Batch Mode processes the entire documentation corpus on a configurable schedule (default: nightly). The batch pipeline scans all documentation sources, identifies documents that have changed since the last compression cycle using content hashing, and recompresses only the changed documents at all three compression levels. Batch results are pushed to Meilisearch for search indexing and cached in ETS for fast retrieval.
On-Demand Mode accepts individual compression requests from agents needing context-window-optimized documentation. The agent specifies the target token budget, and the Compressor selects the appropriate compression level or generates a custom compression artifact that fits within the budget while maximizing information retention.
Validation Cycle runs after every compression operation, computing semantic similarity between source and compressed artifacts. Documents failing the retention threshold are flagged for human review or reprocessed with conservative compression parameters that sacrifice size reduction for information preservation.
NABLA Compliance
The Compressor enforces NABLA epistemic framework requirements throughout all compression operations.
Provenance Mandatory: Every compressed artifact maintains full provenance to its source document, including the source path, compression timestamp, algorithm version, and retention score. Compressed artifacts without provenance are rejected from the search index.
Signal Plurality: Compression decisions draw from multiple analysis signals (structural analysis, semantic density, importance scoring) rather than relying on any single metric. This ensures that compression quality reflects a balanced assessment of document content.
Contradiction Preservation: When a document contains contradictory information (such as documented caveats or alternative approaches), the compression algorithm preserves both sides of the contradiction rather than summarizing to a single position. This is critical for technical documentation where nuance matters.
Time Decay: Compressed artifacts carry freshness timestamps. When the source document is updated, all derived compressed artifacts are invalidated and marked for recompression. Stale compressed artifacts are never served as current documentation.
Configuration
config :prismatic_documentation, PrismaticDocumentation.Compressor,
retention_threshold: 0.80,
compression_levels: [:executive, :operational, :archive],
batch_schedule: "0 2 * * *",
cache_backend: :ets,
search_backend: :meilisearch,
max_concurrent_compressions: 10,
executive_target_ratio: 0.15,
operational_target_ratio: 0.40,
validation_enabled: true,
source_paths: ["docs/", "apps/*/CLAUDE.md", ".aiad/"]| Parameter | Default | Description |
|---|---|---|
retention_threshold | 0.80 | Minimum semantic similarity score |
batch_schedule | 2:00 AM daily | Cron schedule for batch compression |
max_concurrent_compressions | 10 | Parallel compression workers |
executive_target_ratio | 0.15 | Target size for executive summaries |
operational_target_ratio | 0.40 | Target size for operational digests |
Performance
| Metric | Target | Measured |
|---|---|---|
| Single document compression | < 2 seconds | 800ms average |
| Batch corpus processing (11K docs) | < 30 minutes | 22 minutes |
| Compressed artifact retrieval (ETS) | < 1ms | 0.2ms |
| Search query latency | < 50ms | 28ms |
| Average retention score | >= 80% | 87% |
| Memory footprint (cache) | < 512 MB | 340 MB |
The ETS cache provides sub-millisecond retrieval for hot documentation artifacts while Meilisearch handles full-text search across the compressed corpus. Concurrent compression via Task.async_stream with configurable concurrency ensures batch processing completes within the nightly maintenance window.
Related Resources
- context-compression-enforcer-agent -- Compression policy enforcement
- context-preservation-specialist-agent -- Session context management
- documentation-integrity-specialist -- Documentation accuracy validation
- Meilisearch -- Full-text search engine integration
- SEADF -- Self-Evolving Autonomous Development Framework
- AIAD Standard -- Agent design specification
- Telemetry Integration -- Platform monitoring infrastructure
Connect & Contribute
Created by Tomáš Korcak (korczis) | Open Source under GHL