Package ai.pipestream.module.pipelineprobe
package ai.pipestream.module.pipelineprobe
-
ClassDescriptionGlobal exception mapper that captures unhandled errors, records them in
LastErrorTracker, and returns a structured JSON 500 response.OpenSearch index administration REST API for the Quinoa UI.In-memory tracker for the most recent 500-level error.Immutable snapshot of a single recorded error.REST resource for the module-testing-sidecar harness.Produces a protobufTypeRegistrypopulated from generated Java classes.Per-(key, step)rich observation collector for the Pipeline-tab panels, fed live byPipelineEventsConsumerfrom the engine'spipeline-eventsaudit stream.Snapshot returned byRichObservationCollector.snapshot(String, String); immutable.Curated set of well-known sample documents bundled into the sidecar JAR for quick testing without needing a repository or manual upload.Demand-pull processor for the module-testing-sidecar service.Helper class for building test requests to the TestProcessor.Processing modes supported by the test processor.Builder for creating test documents with various configurations.Builder for creating test requests with various configurations.Per-account, per-step document counter for transport + e2e validation.Per-step totals for REST / worker status (copy of live counters).