Package ai.pipestream.module.pipelineprobe.opensearch

package ai.pipestream.module.pipelineprobe.opensearch

Related Packages

Package	Description
ai.pipestream.module.pipelineprobe

Class	Description
CourtFixtureSource	Streams court-1000 PipeDoc fixtures off the classpath.
CourtFixtureSource.Stage	Stage selector for the court-1000 corpus.
IndexPushDriver	Drives court-1000 PipeDocs at the opensearch-sink (OSS) production indexing path: PipeStepProcessorService.processData (unary).
IndexPushDriver.PushSnapshot	Snapshot of a push job's progress.
OpenSearchIndexingTestsResource	REST resource backing the testing-sidecar's "OpenSearch Index Tests" tab.
OpenSearchTestSetupService	Blocking, non-Mutiny equivalent of E2EPipelineTestService's registerConfigs(...) chain — registers the minimum ChunkerConfigs, EmbeddingConfigs, VectorSet recipes, and IndexPlan the opensearch-sink needs to resolve a plan and publish indexing work (inline Kafka event below the size threshold, S3 claim-check + pointer above it; OSM's KafkaIndexingConsumer indexes — no redis on this path).
OpenSearchTestSetupService.SetupResult	Result of a single setup run.
OpenSearchTestSetupService.SinkPerfSetup	Result of a sink-perf setup: the plan the sink resolves plus what to tear down afterwards.