Index (module-testing-sidecar 0.0.1 API)

A B C D E F G H I J K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accessKeyId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns the value of the accessKeyId record component.
accountId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the accountId record component.
AccountManager - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Resolves the test account for a RunPipelineCrawl run.
AccountManager() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.AccountManager: Creates the account manager.
ackedFail() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the ackedFail record component.
ackedOk() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the ackedOk record component.
ActiveCrawlRegistry - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Tracks the crawl_ids of pipeline-crawl runs that currently have an open observation stream (an in-flight OrchestrationDriver run).
ActiveCrawlRegistry() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.ActiveCrawlRegistry: Default constructor for CDI.
ActiveGraph(String, int, boolean) - Constructor for record class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient.ActiveGraph: Creates an instance of a ActiveGraph record class.
ai.pipestream.module.pipelineprobe - package ai.pipestream.module.pipelineprobe
ai.pipestream.module.pipelineprobe.cleanup - package ai.pipestream.module.pipelineprobe.cleanup
ai.pipestream.module.pipelineprobe.e2e - package ai.pipestream.module.pipelineprobe.e2e
ai.pipestream.module.pipelineprobe.grpc - package ai.pipestream.module.pipelineprobe.grpc
ai.pipestream.module.pipelineprobe.mockengine - package ai.pipestream.module.pipelineprobe.mockengine
ai.pipestream.module.pipelineprobe.moduletest - package ai.pipestream.module.pipelineprobe.moduletest
ai.pipestream.module.pipelineprobe.moduletest.engineperf - package ai.pipestream.module.pipelineprobe.moduletest.engineperf
ai.pipestream.module.pipelineprobe.moduletest.scaffold - package ai.pipestream.module.pipelineprobe.moduletest.scaffold
ai.pipestream.module.pipelineprobe.opensearch - package ai.pipestream.module.pipelineprobe.opensearch
ai.pipestream.module.pipelineprobe.pipelinecrawl - package ai.pipestream.module.pipelineprobe.pipelinecrawl
ai.pipestream.module.pipelineprobe.sampledata - package ai.pipestream.module.pipelineprobe.sampledata
ai.pipestream.module.pipelineprobe.seed - package ai.pipestream.module.pipelineprobe.seed
ALICE_IN_WONDERLAND - Enum constant in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Lewis Carroll's classic novel, as plain text.
all() - Method in class ai.pipestream.module.pipelineprobe.sampledata.SampleDataRegistry: All discovered datasets, ordered by step it feeds.
apiKey() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager.DatasourceCredentials: Returns the value of the apiKey record component.
APPLE_FINANCIALS - Enum constant in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Apple quarterly financial statements, as a PDF.
applyKafkaPartitions(GraphNode.Builder, int) - Method in class ai.pipestream.module.pipelineprobe.e2e.E2ETuningHelper: Applies the kafka partition count to a GraphNode builder if the partition override is positive.
artifactId() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns the value of the artifactId record component.
ATTENTION_PAPER - Enum constant in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Vaswani et al.
auditLog() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns the value of the auditLog record component.
awaitTerminal(Duration) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunHandle: Block until the run reaches a terminal state.

B

backoffMs(int) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy: Computes the backoff delay before the given 0-based retry attempt, doubling baseBackoffMs for each successive attempt.
baseBackoffMs() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy: Returns the value of the baseBackoffMs record component.
baseCount(String) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller.FamilySnapshot: The headline count: docs in the base index for this crawl.
BIBLE_KJV - Enum constant in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Full text of the King James Bible, as plain text — a large stress-test corpus.
bindDatasourceToGraph(String, long, String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.GraphBinder: Bind datasourceId to graphId at entryNodeId.
body() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker.DoorResponse: Returns the value of the body record component.
bucket() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns the value of the bucket record component.
build() - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestDocumentBuilder: Builds the PipeDoc with document-type "test" search metadata, including the title, body, and any custom fields set so far.
build() - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Builds the ProcessDataRequest with the configured document, service metadata, and (when any config fields were set) a ProcessConfiguration carrying the JSON config.
build(String, String, PipelineSource, Set, Set, Set, List, int, Struct, Struct, Struct, Struct, Struct, String) - Method in class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory: Build the graph for a request.
buildPipeStream() - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Demand-pull fixture: same shape as TestProcessorHelper.TestRequestBuilder.build() for TestProcessor.
Built(PipelineGraph, String, String, List, List, List, Set) - Constructor for record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Creates an instance of a Built record class.

C

call(String, Supplier, GrpcRetry.RetryPolicy) - Static method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry: Invoke stubCall with bounded retry per policy.
cancel() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcDispatchSubscriber.Subscription: Cancel the subscription.
cancel() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunHandle: Request cancellation: interrupts the run thread.
cancelRun(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource: Cancel a live run.
capture(String, PipeDoc) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.TerminalDocCapture: Record the terminal doc for accountId (overwrites the previous).
captureNode() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns the value of the captureNode record component.
CATH_AND_BRAZZ - Enum constant in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Short story, as plain text.
CHUNKER - Enum constant in enum class ai.pipestream.module.pipelineprobe.opensearch.CourtFixtureSource.Stage: Post-chunker, no embedding vectors.
ChunkerScaffold - Class in ai.pipestream.module.pipelineprobe.moduletest.scaffold: Chunker scaffold: the raw chunker input (echo output) carries no vector-set directives, so the chunker no-ops ("nothing to chunk").
ChunkerScaffold(DefaultChunkerConfig) - Constructor for class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ChunkerScaffold: Creates the chunker scaffold, precomputing the vector-set directives from the sentence10x3OnBody(true) preset so each wrapped doc carries the same directives the engine would stamp.
chunkerSentenceId() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns the value of the chunkerSentenceId record component.
chunkerSentencesInternalId() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns the value of the chunkerSentencesInternalId record component.
cleanup() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.OpenSearchSinkScaffold: Destroy this session's plan, index (all strategy-derived indices incl.
cleanup() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ParserScaffold
cleanup() - Method in interface ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffold: Tear down anything StepScaffold.prepare() created (e.g.
CleanupFailure(String, String) - Constructor for record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupFailure: Creates an instance of a CleanupFailure record class.
cleanupPlan(String) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchIndexingTestsResource: Drop both per-plan redis streams and (when the index name passes the prefix safety guard) the underlying OpenSearch index.
cleanupRun(CrawlCleanupService.RunResources) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService: Per-run ninja teardown.
CleanupSummary(List, List) - Constructor for record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupSummary: Convenience constructor with zero leases released.
CleanupSummary(List, List, int) - Constructor for record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupSummary: Creates an instance of a CleanupSummary record class.
clear() - Static method in class ai.pipestream.module.pipelineprobe.LastErrorTracker: Clears the recorded error so that LastErrorTracker.get() returns null again.
clear(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.TerminalDocCapture: Drop the captured doc for accountId (called on run cleanup).
close() - Method in class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream: Half-close and wait (bounded) for the server's terminal completion.
close() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EventEmitter: Close the response stream.
concurrency() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the concurrency record component.
Concurrency model - Section in class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver
CONNECTOR_TYPE - Static variable in class ai.pipestream.module.pipelineprobe.moduletest.engineperf.ModuleEnginePerfSession: Connector type this sidecar registers itself under.
consumedByModule() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns the value of the consumedByModule record component.
content() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader.Sample: Returns the value of the content record component.
controlPlane() - Static method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy: Standard policy for sidecar control-plane setup calls (account, datasource, graph bind, config registration).
corpusDoc(int) - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ParserScaffold
corpusDoc(int) - Method in interface ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffold: The scaffold-supplied corpus doc at 1-based index; empty when out of range.
corpusName() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ParserScaffold
corpusName() - Method in interface ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffold: Display name of the scaffold-supplied corpus (e.g.
corpusSize() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ParserScaffold
corpusSize() - Method in interface ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffold: Number of docs in the scaffold-supplied corpus; empty = use the fixture-jar dataset.
count(CourtFixtureSource.Stage, int) - Method in class ai.pipestream.module.pipelineprobe.opensearch.CourtFixtureSource: Cheap probe — counts how many doc_<N>.pb resources are actually present on the classpath for the given stage.
countForCrawl(String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller: Headline base-index count for crawlId — kept for callers that only gate on the base index.
counts() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller.FamilySnapshot: Returns the value of the counts record component.
CourtFixtureSource - Class in ai.pipestream.module.pipelineprobe.opensearch: Streams court-1000 PipeDoc fixtures off the classpath.
CourtFixtureSource() - Constructor for class ai.pipestream.module.pipelineprobe.opensearch.CourtFixtureSource: CDI.
CourtFixtureSource.Stage - Enum Class in ai.pipestream.module.pipelineprobe.opensearch: Stage selector for the court-1000 corpus.
CourtListenerSeedService - Class in ai.pipestream.module.pipelineprobe.seed: Seeds the courtlistener_test database on startup for JDBC crawl E2E tests.
CourtListenerSeedService() - Constructor for class ai.pipestream.module.pipelineprobe.seed.CourtListenerSeedService: Creates the CourtListener seed service.
CRAWL_PREFIX - Static variable in class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService: Naming-convention prefix every disposable crawl resource carries.
CrawlCleanupService - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Ninja cleanup for pipeline-crawl runs: by default a run deletes every resource it provisioned, so an hourly health-check e2e leaves the platform exactly as it found it.
CrawlCleanupService() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService: Creates the crawl cleanup service.
CrawlCleanupService.RunResources - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Everything one run needs torn down.
crawlId() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns the value of the crawlId record component.
crawlName() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcCrawlManager.JdbcDispatch: Returns the value of the crawlName record component.
CrawlProgress(int, int, int, int, int, int, int) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Creates an instance of a CrawlProgress record class.
created() - Method in record class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient.ActiveGraph: Returns the value of the created record component.
createDatasource(String, PipelineSource) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager: Get-or-create a datasource under the given account, bound to the connector type that matches the requested PipelineSource.
createDatasourceForType(String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager: Get-or-create the (account, connector-type) datasource — the PipelineSource-agnostic core of DatasourceManager.createDatasource(String, PipelineSource).
createDocumentWithoutBody() - Static method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper: Creates a document missing the body field (invalid for schema validation).
createDocumentWithoutTitle() - Static method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper: Creates a document missing the title field (invalid for schema validation).
createErrorRequest() - Static method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper: Creates a request configured to simulate an error.
createIndex(Map) - Method in class ai.pipestream.module.pipelineprobe.IndexAdminResource: Creates a kNN vector index.
createSchemaValidationRequest(PipeDoc) - Static method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper: Creates a request configured for schema validation mode.
createSimpleRequest() - Static method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper: Creates a simple test request with a valid document.
createValidDocument() - Static method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper: Creates a valid document with all required fields for schema validation.
credentialsType() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns the value of the credentialsType record component.

D

DatasourceCredentials(String, String) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager.DatasourceCredentials: Creates an instance of a DatasourceCredentials record class.
datasourceId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Returns the value of the datasourceId record component.
datasourceId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager.DatasourceCredentials: Returns the value of the datasourceId record component.
DatasourceManager - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Creates a datasource for a RunPipelineCrawl run and returns its id + api key directly.
DatasourceManager() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager: Creates the datasource manager.
DatasourceManager.DatasourceCredentials - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Credentials for a freshly-created datasource.
DEFAULT_INDEX_NAME - Static variable in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService: Default index name when the caller doesn't override.
DefaultChunkerConfig - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Builds the chunker module's custom_config for a pipeline-crawl run.
DefaultChunkerConfig() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.DefaultChunkerConfig: Creates the default chunker config builder.
deleteAllTestGraphs() - Method in class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService: Deletes all graph versions for every test-prefixed graph currently registered in Consul.
deleteAllTestGraphs() - Method in class ai.pipestream.module.pipelineprobe.ModuleTestingSidecarResource: Deletes all test graphs and returns a summary of the operation.
deleted() - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupSummary: Returns the value of the deleted record component.
deleteIndex(String, boolean) - Method in class ai.pipestream.module.pipelineprobe.IndexAdminResource: Deletes a single index.
deprovisionIndex(Map) - Method in class ai.pipestream.module.pipelineprobe.IndexAdminResource: Tears down a previously-provisioned index set: deletes the parent index plus every index whose name starts with indexName + "--" (the OSM convention for --chunk--… and --vs--… side indices).
dirName() - Method in enum class ai.pipestream.module.pipelineprobe.opensearch.CourtFixtureSource.Stage: Returns the classpath subdirectory name for this stage's fixtures.
dispatched() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber.S3DispatchState: Number of objects the connector has dispatched so far.
dispatchedCount() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: The number of doc ids the connector has reported dispatched.
dispatchedIdsSnapshot() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: A snapshot copy of the connector's dispatched doc ids.
dlqRecent(String, int) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchIndexingTestsResource: Most recent N entries from the per-plan DLQ stream.
DocAck(boolean, boolean, String) - Constructor for record class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream.DocAck: Creates an instance of a DocAck record class.
docId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.SingleDocDispatcher.SingleDocDispatch: Returns the value of the docId record component.
documentBuilder() - Static method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper: Creates a builder for test documents.
DoorResponse(int, String) - Constructor for record class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker.DoorResponse: Creates an instance of a DoorResponse record class.
dropForGraph(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRedisStreamsCleanup: Drop every per-run stream for graphId.
duplicateCount() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the duplicateCount record component.
duplicates() - Method in record class ai.pipestream.module.pipelineprobe.TransportTestCounter.StepCounts: Returns the value of the duplicates record component.

E

E2ETuningHelper - Class in ai.pipestream.module.pipelineprobe.e2e: Shared helper for pipeline-crawl graph building: applies per-run tuning overrides to graph nodes.
E2ETuningHelper() - Constructor for class ai.pipestream.module.pipelineprobe.e2e.E2ETuningHelper: Creates the tuning helper.
edgeTransports() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the edgeTransports record component.
elapsed(IndexPushDriver.PushSnapshot) - Static method in class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver: Compute the duration since job start as a wall-clock helper for the receipts-tail endpoint (deciding whether a job has been quiescent long enough to declare done).
EMBEDDER - Enum constant in enum class ai.pipestream.module.pipelineprobe.opensearch.CourtFixtureSource.Stage: Post-embedder, vectors attached.
EmbedderFixturesRegistrar - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Idempotent registration of the chunker / embedder / VectorSet fixtures the chunker→embedder→sink Pipeline tab shape needs before its IndexPlan can provision KNN fields.
EmbedderFixturesRegistrar() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.EmbedderFixturesRegistrar: Creates the embedder fixtures registrar.
EMBEDDING_DIM - Static variable in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EmbedderFixturesRegistrar: Vector dimensions.
embeddingMinilmId() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns the value of the embeddingMinilmId record component.
emit(String, E2EStepOutcome, String, long, List) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EventEmitter: Push a single progress event.
emit(String, E2EStepOutcome, String, long, List, Struct) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EventEmitter: Push a single progress event carrying a free-form details Struct (e.g.
emitOutput(String, Struct) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EventEmitter: Emit an out-of-band "output" event carrying the final processed document (single-doc flow) in details.
endpoint() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Returns the value of the endpoint record component.
endpointOverride() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns the value of the endpointOverride record component.
EngineGraphClient - Class in ai.pipestream.module.pipelineprobe.grpc: gRPC client wrapper for engine pipeline-graph queries used by the pipeline-crawl orchestrator.
EngineGraphClient() - Constructor for class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient: Creates the engine pipeline-graph client.
EngineGraphClient.ActiveGraph - Record Class in ai.pipestream.module.pipelineprobe.grpc: Outcome of EngineGraphClient.getOrCreateActiveGraph(PipelineGraph, String, String, String): the active graph's id and version, plus whether this call created it.
enginePerfStart(String, int) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Start an engine-path perf run: stream docs corpus docs through connector-intake (the production front door) into the module's stable single-step graph; the engine stages, fans out, and the module's own worker loop pulls.
enginePerfStatus() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Live engine-perf status: intake counters + audit-plane counts/rates.
enginePerfStop() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Stop publishing and close the intake stream.
ensureConnectorType(String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager: Idempotently register a connector TYPE — for harnesses that act as their own connector (the engine-perf test registers testing-sidecar).
entryNodeId() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Returns the value of the entryNodeId record component.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupFailure: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupSummary: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient.ActiveGraph: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream.DocAck: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker.DoorResponse: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager.DatasourceCredentials: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcCrawlManager.JdbcDispatch: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller.FamilySnapshot: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.SingleDocPayload: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3CrawlManager.S3Dispatch: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader.Sample: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.SingleDocDispatcher.SingleDocDispatch: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.module.pipelineprobe.TransportTestCounter.StepCounts: Indicates whether some other object is "equal to" this one.
error() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the error record component.
error() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber.S3DispatchState: The last error message reported on the status stream, if any.
errorCount() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the errorCount record component.
EventEmitter - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Wraps the gRPC response observer with the boilerplate common to every progress event: serialization on the observer, Timestamp build, pretty step name lookup.
EventEmitter(StreamObserver) - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.EventEmitter: Creates the emitter bound to a single run's response observer.
exceptionClass() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Returns the value of the exceptionClass record component.
expectedCountOrNegative() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.StageLedger: The expected receive-count, or -1 if not yet set.
expectedDocCount(String) - Method in class ai.pipestream.module.pipelineprobe.sampledata.SampleDataRegistry: Expected doc count for a step's input dataset, or empty if no such dataset.
expectedRowCountOrNegative() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: The announced expected row count, or -1 if the connector hasn't announced it yet.

F

failed() - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupSummary: Returns the value of the failed record component.
failed() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Docs that ended in a state the e2e should call a failure.
failedRetrying() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Returns the value of the failedRetrying record component.
failedTerminal() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Returns the value of the failedTerminal record component.
familyCounts(String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller: Get per-index counts of docs indexed under crawlId across the baseIndexName family.
FamilySnapshot(Map) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller.FamilySnapshot: Creates an instance of a FamilySnapshot record class.
familyTotal() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller.FamilySnapshot: Sum across the family — the "did anything anywhere move" signal.
fileName() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader.Sample: Returns the value of the fileName record component.
finishedAt() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the finishedAt record component.
firstGrpcError() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the firstGrpcError record component.
firstNackReason() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the firstNackReason record component.
forArtifact(String) - Method in class ai.pipestream.module.pipelineprobe.sampledata.SampleDataRegistry: Dataset by Maven artifactId, if present.
forKnownDocs(String, Collection) - Static method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: Pre-populate a ledger for runs that know their doc set up front (e.g., SINGLE_DOC source — the dispatcher uploads exactly one doc and gets back its id).
format() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns the value of the format record component.
forStage(String) - Method in class ai.pipestream.module.pipelineprobe.sampledata.SampleDataRegistry: Dataset that feeds the given step (e.g.
forStage(String) - Method in class ai.pipestream.module.pipelineprobe.sampledata.SampleDataResource: The dataset that feeds a given step, e.g.
forStep(String) - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffolds: Scaffold with default options (sink → CHUNK_COMBINED, the e2e default).
forStep(String, String) - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffolds: A fresh scaffold for the given module.
fromId(String) - Static method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Resolves a sample document from its id (the enum constant name).

G

get() - Static method in class ai.pipestream.module.pipelineprobe.LastErrorTracker: Returns the most recently recorded error, or null if none has been recorded.
get(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry: Look up a run by id.
getCount(String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Total receipts across every step observed for this account.
getCount(String, String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Total receipts for one (account, step), including duplicates.
getDescription() - Method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Returns the human-readable description of this sample document.
getDocument(String, String) - Method in class ai.pipestream.module.pipelineprobe.IndexAdminResource: Fetches a single stored document by index and document id.
getDuplicateCount(String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Total duplicated doc_ids across every step observed for this account.
getDuplicateCount(String, String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Number of duplicated doc_ids for one (account, step).
getDuplicateDocIds(String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Snapshot of doc_ids duplicated at any step for this account.
getDuplicateDocIds(String, String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Snapshot of duplicated doc_ids for one (account, step).
getFileName() - Method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Returns the bundled resource file name (without the directory prefix).
getIndexMapping(String) - Method in class ai.pipestream.module.pipelineprobe.IndexAdminResource: Returns the field mapping of the named index as JSON.
getIndexStats(String) - Method in class ai.pipestream.module.pipelineprobe.IndexAdminResource: Returns document-count and size statistics for a single index.
getLastError() - Method in class ai.pipestream.module.pipelineprobe.ModuleTestingSidecarResource: Returns the most recently recorded error for quick diagnosis, or a placeholder message when none has been recorded.
getMimeType() - Method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Returns the MIME type of the bundled file (e.g.
getOrCreate(String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.AccountManager: Idempotently create (or reuse) an account with a CALLER-CHOSEN id — used by tests that need a STABLE account across runs (e.g.
getOrCreateActiveGraph(PipelineGraph, String, String, String) - Method in class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient: Idempotent get-or-create for an active pipeline graph in a cluster.
getOrCreateDatasourceInstance(String, long, String, String, String) - Method in class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient: Idempotent get-or-create of the datasource-to-entry-node binding for a graph version.
getReceivedDocIds(String, String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Snapshot of every distinct doc_id received at one (account, step).
getResourcePath() - Method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Returns the full classpath resource path of the bundled file, formed by prefixing the file name with the sample-data directory.
getSizeBytes() - Method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Returns the size of the bundled file in bytes.
getStepNames(String) - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: Step names with at least one observation for the given key.
getStepNames(String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Step names observed for this account (in insertion order).
getTitle() - Method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Returns the human-readable display title of this sample document.
getUniqueCount(String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Distinct doc_ids across every step observed for this account.
getUniqueCount(String, String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Distinct doc_ids for one (account, step).
GlobalExceptionMapper - Class in ai.pipestream.module.pipelineprobe: Global exception mapper that captures unhandled errors, records them in LastErrorTracker, and returns a structured JSON 500 response.
GlobalExceptionMapper() - Constructor for class ai.pipestream.module.pipelineprobe.GlobalExceptionMapper: Creates the global exception mapper.
graph() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Returns the value of the graph record component.
GraphBinder - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Binds a datasource to an active graph at its entry node, returning the datasource-instance id directly.
GraphBinder() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.GraphBinder: Creates the graph binder.
graphId() - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupFailure: Returns the value of the graphId record component.
graphId() - Method in record class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient.ActiveGraph: Returns the value of the graphId record component.
graphId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Returns the value of the graphId record component.
GrpcFutures - Class in ai.pipestream.module.pipelineprobe.grpc: Tiny StreamObserver-to-CompletableFuture adapter for unary gRPC calls.
GrpcRetry - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Bounded retry wrapper around a blocking gRPC stub call.
GrpcRetry.RetryPolicy - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Retry budget for a single op.

H

hasActiveCrawls() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.ActiveCrawlRegistry: Reports whether any crawl currently has an open observation stream.
hasCorpusFor(String) - Method in class ai.pipestream.module.pipelineprobe.sampledata.SampleDataLoader: True if a dataset feeds the given step (i.e.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupFailure: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupSummary: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient.ActiveGraph: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream.DocAck: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker.DoorResponse: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager.DatasourceCredentials: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcCrawlManager.JdbcDispatch: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller.FamilySnapshot: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.SingleDocPayload: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3CrawlManager.S3Dispatch: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader.Sample: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.SingleDocDispatcher.SingleDocDispatch: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.module.pipelineprobe.TransportTestCounter.StepCounts: Returns a hash code value for this object.
httpStatus() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker.DoorResponse: Returns the value of the httpStatus record component.
hydrateAndTrigger(String, String, String, S3SourceConfig) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3CrawlManager: Optionally hydrate the bucket, then trigger the crawl.
hydratedCount() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3CrawlManager.S3Dispatch: Returns the value of the hydratedCount record component.
hydrateSampleData() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns the value of the hydrateSampleData record component.

I

increment(String, String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Backwards-compatible increment without a step dimension.
increment(String, String, String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Increment for a (account, step) pair.
IndexAdminResource - Class in ai.pipestream.module.pipelineprobe: OpenSearch index administration REST API for the Quinoa UI.
IndexAdminResource() - Constructor for class ai.pipestream.module.pipelineprobe.IndexAdminResource: Creates the index administration resource.
indexExists(String) - Method in class ai.pipestream.module.pipelineprobe.IndexAdminResource: Reports whether the named index exists.
IndexingLedgerPoller - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Polls repository-service's indexing ledger for per-crawl receipt progress.
IndexingLedgerPoller() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller: Creates the poller; its gRPC stub is injected and it is managed by CDI.
IndexingLedgerPoller.CrawlProgress - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Receipt counts for one crawl, partitioned the way the run report wants them.
indexName() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns the value of the indexName record component.
indexName() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup: Returns the value of the indexName record component.
IndexPushDriver - Class in ai.pipestream.module.pipelineprobe.opensearch: Drives court-1000 PipeDocs at the opensearch-sink (OSS) production indexing path: PipeStepProcessorService.processData (unary).
IndexPushDriver() - Constructor for class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver: CDI.
IndexPushDriver.PushSnapshot - Record Class in ai.pipestream.module.pipelineprobe.opensearch: Snapshot of a push job's progress.
inFlight() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the inFlight record component.
inFlight() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Returns the value of the inFlight record component.
info() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.OpenSearchSinkScaffold
info() - Method in interface ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffold: What the scaffold provisioned, for display/logging.
info() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunHandle: Summary snapshot of this run.
intakeAccount() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Returns the value of the intakeAccount record component.
IntakeDocStream - Class in ai.pipestream.module.pipelineprobe.moduletest.engineperf: One open bidi stream to connector-intake's uploadPipeDocStream — the SAME protocol the JDBC connector speaks (IntakeCrawlStream is the reference implementation): StreamContext handshake first (datasource + api key + crawl_id), then one PipeDocItem per doc with per-doc acks; backpressure is HTTP/2 native.
IntakeDocStream(ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub, String, String, String, Duration, Duration) - Constructor for class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream: Opens the stream, sends the context handshake, and blocks (up to contextAckTimeout) for the server's accept before returning.
IntakeDocStream.DocAck - Record Class in ai.pipestream.module.pipelineprobe.moduletest.engineperf: Per-doc intake outcome.
intakeMinted() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Returns the value of the intakeMinted record component.
intakeMode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.SingleDocPayload: Returns the value of the intakeMode record component.
invoke(String, byte[]) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker: POST payload to <configured baseUrl>/module-runtime/v1/process-once.
IRS_1040 - Enum constant in enum class ai.pipestream.module.pipelineprobe.SampleDocument: U.S.
isActive(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.ActiveCrawlRegistry: Reports whether the given crawl currently has an open observation stream.
isClosedSuccessfully() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: True iff dispatch is complete AND the connector's dispatched-id set is fully covered at every registered stage's receive set.
isComplete() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber.S3DispatchState: Whether the crawl has reached the COMPLETED phase.
isDispatchComplete() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: Whether the connector has emitted DISPATCH_COMPLETE.
isFailed() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber.S3DispatchState: Whether the crawl has reached the FAILED phase.
isGraphCached(String, long) - Method in class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient: Returns true if the engine has the given graph version cached and ready to route to.
isTerminal() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunHandle: Whether the run has finished (successfully or not).

J

jdbc() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the jdbc record component.
JdbcCrawlManager - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Drives the JDBC source for a RunPipelineCrawl run: Create the crawl definition via gRPC.
JdbcCrawlManager() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcCrawlManager: Creates the JDBC crawl manager.
JdbcCrawlManager.JdbcDispatch - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Result of JdbcCrawlManager.setupAndTrigger(String, String, String, JdbcSourceConfig): the connector's triggerId (also the crawl_id on every dispatched PipeStream) and the crawlName the connector now has registered.
JdbcDispatch(String, String) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcCrawlManager.JdbcDispatch: Creates an instance of a JdbcDispatch record class.
JdbcDispatchSubscriber - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Subscribes to the JDBC connector's streamCrawlStatus server-streaming RPC and hydrates a RunLedger from the per-event payload.
JdbcDispatchSubscriber() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcDispatchSubscriber: Creates the JDBC dispatch subscriber.
JdbcDispatchSubscriber.Subscription - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: The active subscription.
jdbcPassword() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload: Returns the value of the jdbcPassword record component.
JdbcPayload(Boolean, String, String, String, Integer) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload: Creates an instance of a JdbcPayload record class.
jdbcUrl() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload: Returns the value of the jdbcUrl record component.
jdbcUsername() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload: Returns the value of the jdbcUsername record component.
jobId() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the jobId record component.
jobSnapshot(String) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchIndexingTestsResource: Snapshot of a push job's progress.
journalDropped() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Returns the value of the journalDropped record component.
journalSize() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Returns the value of the journalSize record component.

K

kafkaPartitions() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the kafkaPartitions record component.

L

last(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.TerminalDocCapture: The last terminal doc for accountId, or null if none.
LastError(Instant, String, String, String, String, String) - Constructor for record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Creates an instance of a LastError record class.
lastErrorMessage() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the lastErrorMessage record component.
LastErrorTracker - Class in ai.pipestream.module.pipelineprobe: In-memory tracker for the most recent 500-level error.
LastErrorTracker.LastError - Record Class in ai.pipestream.module.pipelineprobe: Immutable snapshot of a single recorded error.
lastMessage() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Returns the value of the lastMessage record component.
latencyMaxMs() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the latencyMaxMs record component.
latencyP50Ms() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the latencyP50Ms record component.
latencyP95Ms() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the latencyP95Ms record component.
latencyP99Ms() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the latencyP99Ms record component.
leasesReleased() - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupSummary: Returns the value of the leasesReleased record component.
list() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry: Snapshot of all known runs (live and recently terminal).
list() - Method in class ai.pipestream.module.pipelineprobe.sampledata.SampleDataResource: All discovered datasets (ordered by the step each feeds).
listIndices(String) - Method in class ai.pipestream.module.pipelineprobe.IndexAdminResource: Lists OpenSearch indices, optionally filtered by name prefix.
listJobs() - Method in class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver: Snapshots every tracked job (active and completed), sorted by start time with the most recently started first.
listJobs() - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchIndexingTestsResource: List all push jobs the sidecar has tracked since startup, newest first.
listLeakedCrawlRuns() - Method in class ai.pipestream.module.pipelineprobe.ModuleTestingSidecarResource: Leaked pipeline-crawl sweep: dry-run report of every resource the pipeline-crawl-* naming convention owns — accounts, drives, datasources, graphs, index plans + indices — left behind by runs that predate per-run ninja cleanup (or whose sidecar died mid-run).
listPlans() - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchIndexingTestsResource: List every IndexPlanEntity known to OSM, projected to a UI-friendly shape.
listRuns() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource: List known runs (live + recently terminal).
listSamples() - Method in class ai.pipestream.module.pipelineprobe.ModuleTestingSidecarResource: Sample document catalog for future corpus / single-doc pipeline presets.
listTestGraphIds() - Method in class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService: Lists every graph ID whose slot keys currently live in Consul that matches a configured test-prefix.
listTestGraphsForCleanup() - Method in class ai.pipestream.module.pipelineprobe.ModuleTestingSidecarResource: Lists the ids of test graphs that are eligible for cleanup.
loadBytes() - Method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Loads the full contents of this sample's bundled file from the thread-context classloader.
loadDoc(String, int) - Method in class ai.pipestream.module.pipelineprobe.sampledata.SampleDataLoader: Load the index-th (1-based) doc of the dataset that feeds stage.

M

mainFlowNodeIds() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Returns the value of the mainFlowNodeIds record component.
mapUnexpectedErrors(Throwable) - Method in class ai.pipestream.module.pipelineprobe.GlobalExceptionMapper: Maps an unhandled throwable to an HTTP response.
mapValidationErrors(IllegalArgumentException) - Method in class ai.pipestream.module.pipelineprobe.ModuleTestingSidecarResource: Maps validation failures to HTTP 400.
markDispatchComplete() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: Called once when the connector emits DISPATCH_COMPLETE.
maxDocuments() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload: Returns the value of the maxDocuments record component.
maxRetries() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy: Returns the value of the maxRetries record component.
message() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Returns the value of the message record component.
message() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream.DocAck: Returns the value of the message record component.
method() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Returns the value of the method record component.
mimeType() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader.Sample: Returns the value of the mimeType record component.
MINILM - Static variable in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EmbedderFixturesRegistrar: Embedding config_id wired by DefaultChunkerConfig.
MINILM_MODEL_ID - Static variable in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EmbedderFixturesRegistrar: Underlying model identifier for the minilm embedding config.
missingAt(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: Doc ids the connector said it dispatched but that haven't landed at the given stage's tap.
MockWorkCorpus - Class in ai.pipestream.module.pipelineprobe.mockengine: The bounded supply of work the MockWorkEngineService hands out.
MockWorkCorpus() - Constructor for class ai.pipestream.module.pipelineprobe.mockengine.MockWorkCorpus: CDI.
MockWorkEngineResource - Class in ai.pipestream.module.pipelineprobe.mockengine: Control + observability for the MockWorkEngineService.
MockWorkEngineResource() - Constructor for class ai.pipestream.module.pipelineprobe.mockengine.MockWorkEngineResource: Creates the mock work engine control resource.
MockWorkEngineService - Class in ai.pipestream.module.pipelineprobe.mockengine: A mock ModuleWorkService engine for exercising a module's demand-pull work loop in isolation — no real engine, Kafka, Redis or S3.
MockWorkEngineService() - Constructor for class ai.pipestream.module.pipelineprobe.mockengine.MockWorkEngineService: CDI.
MockWorkStats - Class in ai.pipestream.module.pipelineprobe.mockengine: Accumulates what the module-under-test did with the served work: how many units it acked, by ProcessingStatus (SUCCESS / RETRYABLE / PERMANENT) and by result disposition (UPDATED_PAYLOAD / NO_OP / REJECT), plus a wall-clock throughput between the first served unit and the last ack.
MockWorkStats() - Constructor for class ai.pipestream.module.pipelineprobe.mockengine.MockWorkStats: CDI.
module() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ChunkerScaffold
module() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.OpenSearchSinkScaffold
module() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ParserScaffold
module() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.PassthroughScaffold
module() - Method in interface ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffold: The module/step this scaffold targets (e.g.
ModuleEnginePerfSession - Class in ai.pipestream.module.pipelineprobe.moduletest.engineperf: Engine-path perf (Test 2): the sidecar acts as its OWN connector and pushes corpus docs through the production front door — connector-intake's uploadPipeDocStream — so the engine does everything it does for a real crawl: claim-check staging, fan-out to the subscribed graph, work dispensing over the bidi work stream, and the module's own worker loop self-ramps against the backlog.
ModuleEnginePerfSession() - Constructor for class ai.pipestream.module.pipelineprobe.moduletest.engineperf.ModuleEnginePerfSession: Creates the engine-perf session.
ModulePerfSession - Class in ai.pipestream.module.pipelineprobe.moduletest: Live, interactive load generator for one module's process() interface, driven through the dev process-once door.
ModulePerfSession() - Constructor for class ai.pipestream.module.pipelineprobe.moduletest.ModulePerfSession: Creates the module perf session.
ModuleTestConfig - Interface in ai.pipestream.module.pipelineprobe.moduletest: Static, config-driven map of module name → base URL for the Module Test door.
ModuleTestingSidecarResource - Class in ai.pipestream.module.pipelineprobe: REST resource for the module-testing-sidecar harness.
ModuleTestingSidecarResource() - Constructor for class ai.pipestream.module.pipelineprobe.ModuleTestingSidecarResource: Creates the sidecar REST resource.
ModuleTestInvoker - Class in ai.pipestream.module.pipelineprobe.moduletest: Forwards a serialized PipeStream to a module's dev test door (POST /module-runtime/v1/process-once) and returns the door's raw JSON outcome.
ModuleTestInvoker() - Constructor for class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker: Creates the module test invoker.
ModuleTestInvoker.DoorResponse - Record Class in ai.pipestream.module.pipelineprobe.moduletest: The door's HTTP status plus its raw response body (JSON on success).
ModuleTestResource - Class in ai.pipestream.module.pipelineprobe.moduletest: Module Test — invoke a single module's processor directly via its dev test door (POST /module-runtime/v1/process-once), bypassing the engine pull-loop and queue (roadmap #3).
ModuleTestResource() - Constructor for class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Creates the module-test JAX-RS resource.
Mutiny-free reference - Section in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchIndexingTestsResource

N

next() - Method in class ai.pipestream.module.pipelineprobe.mockengine.MockWorkCorpus: The next work unit, or empty once the count is exhausted.
noOpCount() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the noOpCount record component.

O

OBSERVE_RICH_PARAM - Static variable in class ai.pipestream.module.pipelineprobe.TestProcessor: Graph-builder key for rich observation taps.
observeSteps() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the observeSteps record component.
onCompleted() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcDispatchSubscriber.Subscription
onError(Throwable) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcDispatchSubscriber.Subscription
onNext(StreamCrawlStatusResponse) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcDispatchSubscriber.Subscription
onStepRecord(Record) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineEventsConsumer: Fold one audit record into the observation collector for its crawl.
open(CourtFixtureSource.Stage, int) - Method in class ai.pipestream.module.pipelineprobe.opensearch.CourtFixtureSource: Open a single-pass iterator over up to limit PipeDocs from the selected stage.
OpenSearchIndexingTestsResource - Class in ai.pipestream.module.pipelineprobe.opensearch: REST resource backing the testing-sidecar's "OpenSearch Index Tests" tab.
OpenSearchIndexingTestsResource() - Constructor for class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchIndexingTestsResource: CDI.
opensearchInstance() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the opensearchInstance record component.
OpenSearchPoller - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Polls opensearch-manager for per-crawl indexed-doc counts across the whole index family (base + --chunk--* + --vs--*).
OpenSearchPoller() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller: Creates the poller; its gRPC stub is injected and it is managed by CDI.
OpenSearchPoller.FamilySnapshot - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: One tick's view of the crawl's index family.
OpenSearchSinkScaffold - Class in ai.pipestream.module.pipelineprobe.moduletest.scaffold: opensearch-sink scaffold, e2e-faithful: provisions exactly what a pipeline crawl provisions before the sink sees a doc — the full 2×2 vector-set registration (sentence-10-3 + sentences_internal × minilm + paraphrase-minilm) via EmbedderFixturesRegistrar, matching what the captured corpus docs actually carry; an IndexPlan with a PINNED id and the caller-chosen IndexingStrategy (NESTED / SEPARATE_INDICES / CHUNK_COMBINED — the same three the e2e exercises; default CHUNK_COMBINED, the e2e default), gated on READY like the crawl gates dispatch; the semantic centroid configs assigned to the index, so the sink can write the document/section/paragraph centroid SPRs the corpus carries ("KNN field not provisioned at bind time" otherwise). The plan id + instance ride StreamMetadata.context_params — what OpenSearchSinkOptionsParser reads.
OpenSearchSinkScaffold(OpenSearchTestSetupService, EmbedderFixturesRegistrar, IndexingStrategy) - Constructor for class ai.pipestream.module.pipelineprobe.moduletest.scaffold.OpenSearchSinkScaffold: Creates the opensearch-sink scaffold, choosing a unique per-session index name so each run writes into a clean index.
OpenSearchTestSetupService - Class in ai.pipestream.module.pipelineprobe.opensearch: 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() - Constructor for class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService: CDI.
OpenSearchTestSetupService.SetupResult - Record Class in ai.pipestream.module.pipelineprobe.opensearch: Result of a single setup run.
OpenSearchTestSetupService.SinkPerfSetup - Record Class in ai.pipestream.module.pipelineprobe.opensearch: Result of a sink-perf setup: the plan the sink resolves plus what to tear down afterwards.
OrchestrationDriver - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: The actual pipeline-crawl orchestration body (preferred harness path — blocking gRPC, no Mutiny).
OrchestrationDriver() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.OrchestrationDriver: Creates the orchestration driver.
OrchestrationDriver.RunDeadlineExceeded - Exception Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Hard wall-clock deadline exceeded.
OrchestrationDriver.RunInterrupted - Exception Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Wait loop interrupted (sidecar shutdown, etc).
OrchestrationDriver.RunOsDrainFailed - Exception Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: The OS-drain phase found docs the platform terminally failed to index.
OrchestrationDriver.RunSubscriptionFailed - Exception Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Dispatch-stream subscription terminated with a real failure: either the connector emitted a malformed event our handler refused to accept, or the gRPC stream errored with a non-CANCELLED status.

P

pairing() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns the value of the pairing record component.
PARAPHRASE_MINILM_L3 - Static variable in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EmbedderFixturesRegistrar: Second embedder.
PARAPHRASE_MINILM_L3_MODEL_ID - Static variable in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EmbedderFixturesRegistrar: Underlying model identifier for the paraphrase-minilm embedding config.
parse(String) - Static method in enum class ai.pipestream.module.pipelineprobe.opensearch.CourtFixtureSource.Stage: Parse a stage name from a request body / query string.
parserConfig() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the parserConfig record component.
ParserScaffold - Class in ai.pipestream.module.pipelineprobe.moduletest.scaffold: Parser scaffold: the parser has no captured <step>-input-court dataset — its input is the raw source file, which exists BEFORE any capture tap (and the court corpus is JDBC, which skips the parser entirely).
ParserScaffold(S3SampleDocLoader) - Constructor for class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ParserScaffold: Creates the parser scaffold.
partialSuccess() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Returns the value of the partialSuccess record component.
PassthroughScaffold - Class in ai.pipestream.module.pipelineprobe.moduletest.scaffold: No-setup scaffold: the corpus doc already carries everything the step needs.
PassthroughScaffold(String) - Constructor for class ai.pipestream.module.pipelineprobe.moduletest.scaffold.PassthroughScaffold: Creates a passthrough scaffold for the given module.
path() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns the value of the path record component.
pathStyleAccess() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns the value of the pathStyleAccess record component.
pause() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModulePerfSession: Pause the load without ending the session: workers drain to zero but the scaffold's provisioned state (plan, index) stays live — so downstream (OSM's indexing consumer) can drain its backlog against a valid plan and be measured cleanly.
perfPause() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Pause the load (workers to zero) WITHOUT tearing down the scaffold — the plan/index stay live so downstream consumers can drain and be measured.
perfRampDown() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Step concurrency down one geometric level.
perfRampUp() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Step concurrency up one geometric level (1→2→4→8→16→32→64).
perfStart(String, int, String) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Start a perf session for module and begin a sustained door load at concurrency 1; drive it with ramp-up / ramp-down and poll /perf/stats.
perfStats() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Live metrics snapshot for the current ramp level (min/max/mean/p50/p95/p99 + docs/sec).
perfStop() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Stop the perf session and release the load pool.
persistSteps() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the persistSteps record component.
phase() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber.S3DispatchState: Current crawl phase last reported by the connector.
PipeDocOutputSummary - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Renders a final PipeDoc into a readable Struct for the UI's single-doc output panel.
pipelineAccount() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Returns the value of the pipelineAccount record component.
pipelineAccountId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the pipelineAccountId record component.
PipelineCrawlerImpl - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: gRPC entry point for RunPipelineCrawl.
PipelineCrawlerImpl() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerImpl: Creates the pipeline crawler gRPC service.
PipelineCrawlerResource - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: REST/SSE bridge from the FE's Pipeline tab to the gRPC PipelineCrawlerImpl.
PipelineCrawlerResource() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource: Creates the pipeline-crawl REST/SSE resource.
PipelineCrawlerResource.PipelineCrawlPayload - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: FE-facing payload.
PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: JDBC source payload.
PipelineCrawlerResource.PipelineCrawlPayload.S3Payload - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: S3 source payload.
PipelineCrawlerResource.PipelineCrawlPayload.SingleDocPayload - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: SINGLE_DOC source payload.
PipelineCrawlPayload(String, List, List, List, List, String, boolean, boolean, Map, Boolean, String, Integer, Integer, PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload, PipelineCrawlerResource.PipelineCrawlPayload.SingleDocPayload, PipelineCrawlerResource.PipelineCrawlPayload.S3Payload) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Creates an instance of a PipelineCrawlPayload record class.
PipelineEventsConsumer - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Live observation feed for the Pipeline-tab panels.
PipelineEventsConsumer() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineEventsConsumer: Default constructor for CDI.
PipelineGraphFactory - Class in ai.pipestream.module.pipelineprobe.e2e: Builds a PipelineGraph from a RunPipelineCrawlRequest's source / steps / observe / transport selection.
PipelineGraphFactory() - Constructor for class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory: Creates the pipeline-graph factory.
PipelineGraphFactory.Built - Record Class in ai.pipestream.module.pipelineprobe.e2e: Result of PipelineGraphFactory.build(String, String, PipelineSource, Set, Set, Set, List, int, Struct, Struct, Struct, Struct, Struct, String) — graph + names callers need to dispatch into it.
pipelineMinted() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Returns the value of the pipelineMinted record component.
planId() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns the value of the planId record component.
planId() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup: Returns the value of the planId record component.
planId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Returns the value of the planId record component.
planIds() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the planIds record component.
planName() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns the value of the planName record component.
planState(String) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchIndexingTestsResource: Live redis-stream state for one plan: how many entries are sitting on the indexing stream (XLEN), how many are pending an XACK from the consumer group (XPENDING), and how many failures are in the DLQ (XLEN of the dlq stream).
planStatus() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns the value of the planStatus record component.
pollingTimeoutSeconds() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the pollingTimeoutSeconds record component.
prefix() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns the value of the prefix record component.
prepare() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.OpenSearchSinkScaffold
prepare() - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ParserScaffold
prepare() - Method in interface ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffold: Provision external state (vector sets, fresh index, …).
PRIDE_AND_PREJUDICE - Enum constant in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Jane Austen's novel, as plain text.
process(PipeStream) - Method in class ai.pipestream.module.pipelineprobe.TestProcessor
producedByModule() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns the value of the producedByModule record component.
progress(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller: Fetch the indexing-ledger receipt progress for one crawl.
ProtobufTypeRegistryProducer - Class in ai.pipestream.module.pipelineprobe: Produces a protobuf TypeRegistry populated from generated Java classes.
ProtobufTypeRegistryProducer() - Constructor for class ai.pipestream.module.pipelineprobe.ProtobufTypeRegistryProducer: Creates the producer.
provisionIndex(Map) - Method in class ai.pipestream.module.pipelineprobe.IndexAdminResource: Pre-provisions a fresh parent index plus every --chunk-- / --vs-- side index required by the supplied SemanticConfigs, and populates the vector_set_index_binding cache.
PushSnapshot(String, List, String, String, int, int, long, long, long, long, Long, Long, String, String, String, String, double) - Constructor for record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Creates an instance of a PushSnapshot record class.

R

ramp(String, String) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker: Proxy to the module's ops ramp surface (/module-runtime/v1/ramp): body == null → GET (current pool state), otherwise POST it (JSON {"ceiling": N}).
rampDown() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModulePerfSession: Step concurrency down one geometric level (a no-op when stopped; stays paused when already paused).
rampGet(String) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Module pool state from its ops ramp surface (workers/min/max/ceiling).
rampSet(String, String) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Set/clear the module's live concurrency ceiling ({"ceiling": N}; N <= 0 clears).
rampUp() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModulePerfSession: Step concurrency up one geometric level (a no-op when stopped; resumes at the first level when paused).
rateOverall() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the rateOverall record component.
rateRecent() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the rateRecent record component.
RawUploadRestClient - Interface in ai.pipestream.module.pipelineprobe.pipelinecrawl: Streaming HTTP client to connector-intake's raw upload endpoint (POST /uploads/raw) — the S3-style path that streams a document of any length straight to :intake/S3 without ever buffering it whole.
reason() - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupFailure: Returns the value of the reason record component.
receivedCount() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.StageLedger: The number of doc ids in the current received snapshot.
receivedSnapshot() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.StageLedger: The immutable snapshot of received doc ids visible to this caller.
receiveNodeIds() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Returns the value of the receiveNodeIds record component.
recentDocIds() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the recentDocIds record component.
record(String, String, String, long) - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: Record a PROCESSED observation (the node forwarded the doc onward).
record(String, String, Throwable) - Static method in class ai.pipestream.module.pipelineprobe.LastErrorTracker: Records the given throwable as the most recent error, overwriting any prior one.
recordDispatched(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: Called per DOC_DISPATCHED event from the connector.
recordError(String, String, String, String) - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: Record a failed observation — bumps error count and replaces last_error_message.
recordNoOp(String, String, String) - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: Record a NO-OP outcome (node forwarded the doc unchanged — nothing to do).
recordReject(String, String, String, String) - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: Record a terminal REJECT for a doc at this step, with the reason name.
recordSoftError(String, String, String, String) - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: Record a non-fatal SOFT ERROR (the doc continued) for a doc at this step.
region() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns the value of the region record component.
register(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.ActiveCrawlRegistry: Mark a crawl as having an open observation stream.
registerForEmbedderPipeline() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EmbedderFixturesRegistrar: Idempotently registers chunker + embedder + VectorSet fixtures for the chunker→embedder→sink Pipeline shape.
registerSemanticConfigsForIndex(String, IndexingStrategy) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EmbedderFixturesRegistrar: Registers the semantic-graph SemanticConfigs and eagerly provisions their centroid side-indices on indexName, so the sink can write the document/section/paragraph centroid SPRs semantic-graph emits.
registerStage(StageLedger) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: Register a receive-side stage.
rejectCount() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the rejectCount record component.
rejectedDocIds(String) - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: The distinct rejected doc-id set itself (same dedupe semantics as RichObservationCollector.totalRejectedDocs(String)).
rejectReasons() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the rejectReasons record component.
releaseAllTestLeases() - Method in class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService: Releases every Consul KV lease key under pipestream/node-topics/ whose graph segment matches a configured test prefix (TestGraphCleanupService.testGraphPrefixesCsv).
releaseLeasesForCluster(String) - Method in class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService: Releases every Consul KV lease key under pipestream/node-topics/{clusterPrefix}.* — the lock entries the kafka sidecar uses to acquire ownership of node topics for a graph.
replaceReceived(Set) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.StageLedger: Replace the received set in bulk.
requestBuilder() - Static method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper: Creates a builder for test requests.
requestId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3CrawlManager.S3Dispatch: Returns the value of the requestId record component.
requireGraphCached(String, long) - Method in class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient: Asserts that the given graph version is cached on the engine, throwing if it is not (after the retry budget in EngineGraphClient.isGraphCached(String, long) is spent).
reset() - Method in class ai.pipestream.module.pipelineprobe.mockengine.MockWorkEngineResource: Drain the corpus and clear the stats.
reset(int) - Method in class ai.pipestream.module.pipelineprobe.mockengine.MockWorkCorpus: Reset the corpus to serve count fresh units (or the configured default when count < 0).
reset(String) - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: Reset all buckets for one key.
reset(String) - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Reset all steps for one account.
resetAccount(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.SidecarTapPoller: Reset all per-account state across both collectors.
resetAll() - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: Reset every key.
resetAll() - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Reset every account.
resolveAccount(String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.AccountManager: Resolve the test account: use the caller's preferred id if set, otherwise mint one and create it.
resolveSamples() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader: Resolve the documents to hydrate: optional disk override → sample-doc-types jar → bundled fallback.
resourceDir() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Classpath directory holding the per-doc files (derived from SampleDataDescriptor.path).
retainIndex() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Returns the value of the retainIndex record component.
retainIndex() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the retainIndex record component.
retryable() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream.DocAck: Returns the value of the retryable record component.
RetryPolicy(int, long) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy: Creates an instance of a RetryPolicy record class.
RichObservationCollector - Class in ai.pipestream.module.pipelineprobe: Per-(key, step) rich observation collector for the Pipeline-tab panels, fed live by PipelineEventsConsumer from the engine's pipeline-events audit stream.
RichObservationCollector() - Constructor for class ai.pipestream.module.pipelineprobe.RichObservationCollector: Default constructor for CDI.
RichObservationCollector.Snapshot - Record Class in ai.pipestream.module.pipelineprobe: Snapshot returned by RichObservationCollector.snapshot(String, String); immutable.
richSnapshot(String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.SidecarTapPoller: Rich snapshot for one observed tap, or null if no rich data has been collected yet (no docs received OR the tap isn't in rich-collection mode).
richTapNodeIds() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Returns the value of the richTapNodeIds record component.
rotateApiKey(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager: Rotate the datasource's API key and return the NEW key.
run(int) - Method in class ai.pipestream.module.pipelineprobe.mockengine.MockWorkEngineResource: (Re)load the corpus with a fresh budget and clear the stats, so the next module to dial in pulls count units.
run(RunPipelineCrawlRequest, EventEmitter) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.OrchestrationDriver: Run one orchestration.
runCorpus(String, int) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Run the module against one corpus doc: load its stage-appropriate input PipeDoc, wrap it, and POST to the door.
RunDeadlineExceeded(String) - Constructor for exception class ai.pipestream.module.pipelineprobe.pipelinecrawl.OrchestrationDriver.RunDeadlineExceeded: Create the exception.
runId() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunHandle: Registry id for this run.
runId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Returns the value of the runId record component.
RunInfo(String, String, RunRegistry.RunState, Instant, Instant, int, long, String) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Creates an instance of a RunInfo record class.
RunInterrupted(String, Throwable) - Constructor for exception class ai.pipestream.module.pipelineprobe.pipelinecrawl.OrchestrationDriver.RunInterrupted: Create the exception.
RunLedger - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Single source of truth for one pipeline-crawl run's progress.
RunLedger(String) - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: Creates a ledger for one pipeline-crawl run, stamping the start time as now.
RUNNING - Enum constant in enum class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunState: The run thread is still executing.
runOrchestration(RunPipelineCrawlRequest, StreamObserver) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerImpl: Execute one orchestration on the calling thread (assumed to already be a virtual thread — the gRPC entry above and the SSE bridge both spawn one before calling this).
RunOsDrainFailed(String) - Constructor for exception class ai.pipestream.module.pipelineprobe.pipelinecrawl.OrchestrationDriver.RunOsDrainFailed: Create the exception.
runPipelineCrawl(PipelineCrawlerResource.PipelineCrawlPayload, Sse, SseEventSink) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource: Start a pipeline-crawl run and stream its events over SSE.
runPipelineCrawl(RunPipelineCrawlRequest, StreamObserver) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerImpl
runRaw(String, String, byte[]) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: Run the module against an ad-hoc uploaded protobuf.
RunRedisStreamsCleanup - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Drops a run's per-graph redis streams once the pipeline-crawl finishes.
RunRedisStreamsCleanup() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRedisStreamsCleanup: Creates the redis streams cleanup service.
RunRegistry - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Owns the lifetime of pipeline-crawl runs INDEPENDENTLY of any transport connection.
RunRegistry() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry: Default constructor for CDI.
RunRegistry.RunHandle - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: One run: its thread, journal, and subscribers.
RunRegistry.RunInfo - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Summary row for one run.
RunRegistry.RunState - Enum Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Run state for the runs listing.
RunResources(String, boolean, String, boolean, String, String, String, boolean) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Creates an instance of a RunResources record class.
RunSubscriptionFailed(String, Throwable) - Constructor for exception class ai.pipestream.module.pipelineprobe.pipelinecrawl.OrchestrationDriver.RunSubscriptionFailed: Create the exception.

S

s3() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the s3 record component.
S3CrawlManager - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Drives the S3 source for a RunPipelineCrawl run — the analogue of JdbcCrawlManager for buckets.
S3CrawlManager() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3CrawlManager: Creates the S3 crawl manager.
S3CrawlManager.S3Dispatch - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Result of S3CrawlManager.hydrateAndTrigger(String, String, String, S3SourceConfig): the connector's request id (the crawl's idempotency key) and how many docs were uploaded during hydration (0 when hydration was skipped).
S3Dispatch(String, int) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3CrawlManager.S3Dispatch: Creates an instance of a S3Dispatch record class.
S3DispatchState() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber.S3DispatchState: Creates an empty state in the initial (unspecified phase, no total) condition.
S3DispatchSubscriber - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Subscribes to the s3-connector's StreamCrawlStatus for one crawl and mirrors its state into a S3DispatchSubscriber.S3DispatchState the orchestrator's wait loop reads each tick — the S3 counterpart of JdbcDispatchSubscriber, but count-based: the connector reports how many objects it dispatched (and, at COMPLETED, the final total) rather than per-doc ids.
S3DispatchSubscriber() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber: Creates the subscriber; its gRPC stub is injected and it is managed by CDI.
S3DispatchSubscriber.S3DispatchState - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Live mirror of one crawl's connector-side state.
S3Payload(String, String, String, String, String, Boolean, String, String, Boolean) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Creates an instance of a S3Payload record class.
S3SampleDocLoader - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Resolves the set of documents to upload into S3 before an S3 pipeline-crawl run, when hydrate_sample_data is set.
S3SampleDocLoader() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader: Creates the sample-doc loader.
S3SampleDocLoader.Sample - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: One document to upload: its object key (path within the corpus), bytes, mime type.
Sample(String, byte[], String) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader.Sample: Creates an instance of a Sample record class.
SAMPLE_ARTICLE - Enum constant in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Short news-style article, as plain text.
SampleDataDescriptor - Record Class in ai.pipestream.module.pipelineprobe.sampledata: One sample-data fixture jar's self-description, read from its META-INF/pipestream-sample-data.json resource.
SampleDataDescriptor(String, String, String, String, String, String, int, String, String, String) - Constructor for record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Creates an instance of a SampleDataDescriptor record class.
SampleDataLoader - Class in ai.pipestream.module.pipelineprobe.sampledata: Reads the per-doc PipeDocs out of a registered sample-data set.
SampleDataLoader() - Constructor for class ai.pipestream.module.pipelineprobe.sampledata.SampleDataLoader: Creates the sample-data loader.
SampleDataRegistry - Class in ai.pipestream.module.pipelineprobe.sampledata: Discovers every sample-data fixture jar on the classpath by scanning for its META-INF/pipestream-sample-data.json descriptor, and exposes them as a queryable registry — keyed by artifactId and by the step each dataset feeds.
SampleDataRegistry() - Constructor for class ai.pipestream.module.pipelineprobe.sampledata.SampleDataRegistry: Creates the registry; its ObjectMapper is injected and it is managed by CDI.
SampleDataResource - Class in ai.pipestream.module.pipelineprobe.sampledata: Read-only view of the SampleDataRegistry: which sample-data fixture jars are on the classpath, and what each one is.
SampleDataResource() - Constructor for class ai.pipestream.module.pipelineprobe.sampledata.SampleDataResource: Creates the sample-data resource.
SampleDocument - Enum Class in ai.pipestream.module.pipelineprobe: Curated set of well-known sample documents bundled into the sidecar JAR for quick testing without needing a repository or manual upload.
sampleNames() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.SingleDocPayload: Returns the value of the sampleNames record component.
secretAccessKey() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns the value of the secretAccessKey record component.
sent() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the sent record component.
SENTENCE_CHUNKER - Static variable in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EmbedderFixturesRegistrar: Chunker config_id for the body-text sentence chunker.
sentence10x3OnBody(boolean) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.DefaultChunkerConfig: Sentence chunker, 10 sentences per chunk, 3-sentence overlap, body-only.
SENTENCES_INTERNAL_CHUNKER - Static variable in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EmbedderFixturesRegistrar: Chunker config_id for the always-emitted Stage-2 sentences SPR.
separateIntakePipeline() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the separateIntakePipeline record component.
servedCount() - Method in class ai.pipestream.module.pipelineprobe.mockengine.MockWorkCorpus: Returns the number of work units handed out so far, capped at the effective limit.
setExpectedCount(int) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.StageLedger: Set the expected receive-count for this stage.
setExpectedRowCount(int) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: Set by the connector's EXPECTED_COUNT_KNOWN event.
setProcessingDelayMs(long) - Method in class ai.pipestream.module.pipelineprobe.TestProcessor: Overrides the per-document artificial processing delay and logs the new value.
setRandomFailureRate(double) - Method in class ai.pipestream.module.pipelineprobe.TestProcessor: Overrides the random failure rate and logs the new value.
setup(String) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService: Run the full setup.
setupAndTrigger(String, String, String, JdbcSourceConfig) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcCrawlManager: Create the crawl definition and start it.
setupCourtPlan(Map) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchIndexingTestsResource: One-shot setup: register ChunkerConfigs, EmbeddingConfig, VectorSets, and an IndexPlan matching the court-1000 chunker fixtures.
setupForSink(String, IndexingStrategy, List) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService: E2E-faithful sink setup for the module perf test: create an IndexPlan with a PINNED id (plan-<indexName> — the sink resolves plan_ids[] entries via GetIndexPlan(id), so the id must be the value we hand it), the caller-chosen IndexingStrategy, and the caller's vector-set ids (the e2e 2×2 from EmbedderFixturesRegistrar.registerForEmbedderPipeline()), then gate on READY exactly like the crawl does — the sink rejects any doc whose plan isn't READY.
SetupResult(String, String, String, String, String, String, String, List, List) - Constructor for record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Creates an instance of a SetupResult record class.
setupToJson(OpenSearchTestSetupService.SetupResult) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService: Flattens a OpenSearchTestSetupService.SetupResult into an ordered map shape suitable for JAX-RS serialization, exposing every id field plus the audit log.
SidecarTapPoller - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Reads in-process tap counters and rich-observation snapshots for the orchestrator's poll loop.
SidecarTapPoller() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.SidecarTapPoller: Creates the tap poller; its collaborators are injected and it is managed by CDI.
singleDoc() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the singleDoc record component.
SingleDocDispatch(String) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.SingleDocDispatcher.SingleDocDispatch: Creates an instance of a SingleDocDispatch record class.
SingleDocDispatcher - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Drives the SINGLE_DOC source for a RunPipelineCrawl run.
SingleDocDispatcher() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.SingleDocDispatcher: Creates the single-doc dispatcher.
SingleDocDispatcher.SingleDocDispatch - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Result of SingleDocDispatcher.uploadAndDispatch(String, String, String, SingleDocSourceConfig, String): the doc_id the upload produced.
SingleDocPayload(List, String) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.SingleDocPayload: Creates an instance of a SingleDocPayload record class.
SinkPerfSetup(String, String, List) - Constructor for record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup: Creates an instance of a SinkPerfSetup record class.
skipCleanup() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the skipCleanup record component.
skipped() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Returns the value of the skipped record component.
snapshot() - Method in class ai.pipestream.module.pipelineprobe.mockengine.MockWorkStats: Builds a snapshot of the accumulated stats: served and acked counts, pending count, per-status and per-disposition tallies, the elapsed wall-clock seconds between the first served unit and the last ack, and the resulting acks-per-second throughput.
snapshot() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModulePerfSession: Non-destructive live snapshot of the current level + lifetime totals.
snapshot(String) - Method in class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver: Look up a job by id.
snapshot(String, String) - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: Snapshot the rich state for one (key, step).
Snapshot(String, long, long, long, double, double, long, long, long, long, List, long, String, long, long, long, Map) - Constructor for record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Creates an instance of a Snapshot record class.
snapshotByAccount() - Method in class ai.pipestream.module.pipelineprobe.TransportTestCounter: Snapshot of all in-memory counters keyed by account then step name.
softErrorCount() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the softErrorCount record component.
source() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the source record component.
source() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Returns the value of the source record component.
sourceDocCount() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns the value of the sourceDocCount record component.
stackTrace() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Returns the value of the stackTrace record component.
stage() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the stage record component.
stage() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns the value of the stage record component.
stage(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: Look up a registered receive-side stage by its id.
stageId() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.StageLedger: The stage identifier this ledger tracks.
StageLedger - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: One stage's receive-side view in a RunLedger: which doc ids landed at this stage's tap, and how many we expect.
StageLedger(String) - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.StageLedger: Create a ledger for one stage's tap.
stages() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: A snapshot copy of all registered stages keyed by stage id.
stages() - Method in class ai.pipestream.module.pipelineprobe.sampledata.SampleDataRegistry: The set of steps that have a registered input dataset.
start(RunPipelineCrawlRequest, BiConsumer) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry: Start a run on its own virtual thread and return its handle.
start(String, int) - Method in class ai.pipestream.module.pipelineprobe.moduletest.engineperf.ModuleEnginePerfSession: Start an engine-path perf run: ensure the stable identity (account, datasource, graph — all idempotent get-or-create), rotate the API key (the run lock), then stream docs corpus docs through intake on a background thread.
start(String, int) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModulePerfSession: Default-options overload — see ModulePerfSession.start(String, int, String).
start(String, int, String) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModulePerfSession: Start a fresh session for module, replacing any prior run.
start(List, String, CourtFixtureSource.Stage, int, Integer) - Method in class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver: Start a push job.
startedAt() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the startedAt record component.
startedAt() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Returns the value of the startedAt record component.
startEpochMs() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: The run's start time, stamped at construction.
startPush(String, Map) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchIndexingTestsResource: Start a push job driving court-1000 PipeDocs at OSS over the OpenSearchIngestionService.StreamDocuments bidi RPC.
state() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the state record component.
state() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Returns the value of the state record component.
stats() - Method in class ai.pipestream.module.pipelineprobe.mockengine.MockWorkEngineResource: Returns the live run statistics together with the total number of units being served.
status() - Method in class ai.pipestream.module.pipelineprobe.moduletest.engineperf.ModuleEnginePerfSession: Live status: intake-side counters + audit-plane counts/rates.
StepCounts(int, int, int) - Constructor for record class ai.pipestream.module.pipelineprobe.TransportTestCounter.StepCounts: Creates an instance of a StepCounts record class.
stepName() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the stepName record component.
steps() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns the value of the steps record component.
StepScaffold - Interface in ai.pipestream.module.pipelineprobe.moduletest.scaffold: Per-step integration scaffolding for module perf / isolation tests.
StepScaffolds - Class in ai.pipestream.module.pipelineprobe.moduletest.scaffold: Factory for per-step StepScaffolds — forStep("embedder") etc.
StepScaffolds() - Constructor for class ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffolds: Creates the scaffold factory.
stop() - Method in class ai.pipestream.module.pipelineprobe.moduletest.engineperf.ModuleEnginePerfSession: Stop publishing, close the intake stream, unregister the crawl.
stop() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModulePerfSession: Stop the session: signal workers to finish, interrupt the streaming loader, shut down the worker pool, and run the scaffold cleanup (swallowing any cleanup failure with a warning).
streamRunEvents(String, Sse, SseEventSink) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource: Re-attach to a run: full journal replay, then live tail.
subscribe(StreamObserver) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunHandle: Attach a subscriber: full journal replay, then live tail, in order, with no gap (replay and appends share the handle lock).
subscribe(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber: Open the status stream for requestId and drain it on a virtual thread.
subscribe(String, RunLedger) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcDispatchSubscriber: Open a subscription against triggerId.
success() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream.DocAck: Returns the value of the success record component.
success() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Returns the value of the success record component.
sweepLeakedCrawlRuns() - Method in class ai.pipestream.module.pipelineprobe.ModuleTestingSidecarResource: Execute the leaked pipeline-crawl sweep.
sweepLeakedRuns(boolean) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService: Admin sweep over every leaked pipeline-crawl-* resource.

T

tapNodeIds() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Returns the value of the tapNodeIds record component.
targets() - Method in interface ai.pipestream.module.pipelineprobe.moduletest.ModuleTestConfig: The configured map of module name to base URL (e.g.
targets() - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestResource: List configured module targets and, for each, whether a corpus dataset feeds it and how many docs it carries (the expected stress count).
teardown(OpenSearchTestSetupService.SetupResult) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService: Inverse of OpenSearchTestSetupService.setup(String): destroy everything a setup run provisioned for one index, leaving the shared deterministic recipes (ChunkerConfigs, EmbeddingConfig, VectorSet definitions) in place for the next run to reuse.
teardown(OpenSearchTestSetupService.SinkPerfSetup) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService: Teardown for a OpenSearchTestSetupService.setupForSink(String, IndexingStrategy, List) session — same steps as OpenSearchTestSetupService.teardown(SetupResult), driven off the sink-perf result's ids.
teardown(String, String, List) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService: Core teardown by ids — see OpenSearchTestSetupService.teardown(SetupResult) for semantics.
terminal() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Docs OSM has finished with — success, partial, hard-failed, or skipped.
TERMINAL - Enum constant in enum class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunState: The run has finished (succeeded or failed).
terminalAt() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Returns the value of the terminalAt record component.
TerminalDocCapture - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl: Captures the most recent PipeDoc that reached the terminal sidecar node, keyed by account.
TerminalDocCapture() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.TerminalDocCapture: CDI.
terminalErrorIfReal() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcDispatchSubscriber.Subscription: The first real failure the subscription saw, or null if everything has gone fine so far.
terminalNodeId() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Returns the value of the terminalNodeId record component.
TEST - Enum constant in enum class ai.pipestream.module.pipelineprobe.TestProcessorHelper.ProcessingMode: Passthrough mode — minimal processing.
TestDocumentBuilder() - Constructor for class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestDocumentBuilder: Creates a builder with a random doc id and no title, body, or custom fields.
TestGraphCleanupService - Class in ai.pipestream.module.pipelineprobe.cleanup: Batch cleanup of leftover test graphs.
TestGraphCleanupService() - Constructor for class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService: Default constructor for CDI.
TestGraphCleanupService.CleanupFailure - Record Class in ai.pipestream.module.pipelineprobe.cleanup: A single failed graph delete.
TestGraphCleanupService.CleanupSummary - Record Class in ai.pipestream.module.pipelineprobe.cleanup: Outcome of a batch cleanup run.
TestProcessor - Class in ai.pipestream.module.pipelineprobe: Demand-pull processor for the module-testing-sidecar service.
TestProcessor() - Constructor for class ai.pipestream.module.pipelineprobe.TestProcessor: Creates the demand-pull test processor; instances are managed by CDI.
TestProcessorHelper - Class in ai.pipestream.module.pipelineprobe: Helper class for building test requests to the TestProcessor.
TestProcessorHelper.ProcessingMode - Enum Class in ai.pipestream.module.pipelineprobe: Processing modes supported by the test processor.
TestProcessorHelper.TestDocumentBuilder - Class in ai.pipestream.module.pipelineprobe: Builder for creating test documents with various configurations.
TestProcessorHelper.TestRequestBuilder - Class in ai.pipestream.module.pipelineprobe: Builder for creating test requests with various configurations.
TestRequestBuilder() - Constructor for class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Creates a builder pre-populated with default pipeline, step, stream, and hop values.
throughputDocsPerSec() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the throughputDocsPerSec record component.
timestamp() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Returns the value of the timestamp record component.
toInfo() - Method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Builds a metadata map describing this sample document, suitable for JSON serialization.
toJson(IndexPushDriver.PushSnapshot) - Static method in class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver: Project a snapshot to a UI-friendly map ordered for the tab's progress panel.
toMap() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Renders this snapshot as a map with string values, substituting empty strings for any null fields, suitable for JSON serialization.
toPipeStream(ProcessDataRequest) - Static method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper: Converts a legacy ProcessDataRequest fixture into the PipeStream the demand-pull TestProcessor consumes.
toStartResponse(IndexPushDriver.PushSnapshot) - Static method in class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver: Convenience for a "started" response that callers (e.g.
toString() - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupFailure: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupSummary: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient.ActiveGraph: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream.DocAck: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker.DoorResponse: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager.DatasourceCredentials: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcCrawlManager.JdbcDispatch: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller.FamilySnapshot: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.SingleDocPayload: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3CrawlManager.S3Dispatch: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader.Sample: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.SingleDocDispatcher.SingleDocDispatch: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.module.pipelineprobe.TransportTestCounter.StepCounts: Returns a string representation of this record class.
toStruct(PipeDoc) - Static method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipeDocOutputSummary: Convert doc to a Struct with raw vectors stripped to their dimension.
total() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress: Returns the value of the total record component.
total() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber.S3DispatchState: Final object count; -1 until the connector reports COMPLETED.
total() - Method in record class ai.pipestream.module.pipelineprobe.TransportTestCounter.StepCounts: Returns the value of the total record component.
TOTAL_STEPS - Static variable in class ai.pipestream.module.pipelineprobe.pipelinecrawl.EventEmitter: All step ids we emit, in order.
totalCount() - Method in class ai.pipestream.module.pipelineprobe.mockengine.MockWorkCorpus: Returns the effective unit budget this corpus will serve before draining.
totalCount() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the totalCount record component.
totalCount(String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.SidecarTapPoller: Total receipts (including duplicates) at one tap.
totalRejectedDocs(String) - Method in class ai.pipestream.module.pipelineprobe.RichObservationCollector: Distinct docs whose terminal outcome anywhere in the run is REJECT — the run-wide "intentionally dropped" tally (e.g.
totalRequested() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot: Returns the value of the totalRequested record component.
TRANSFORM - Enum constant in enum class ai.pipestream.module.pipelineprobe.TestProcessorHelper.ProcessingMode: Transform mode — can modify document content.
TransportTestCounter - Class in ai.pipestream.module.pipelineprobe: Per-account, per-step document counter for transport + e2e validation.
TransportTestCounter() - Constructor for class ai.pipestream.module.pipelineprobe.TransportTestCounter: Creates the transport-test counter.
TransportTestCounter.StepCounts - Record Class in ai.pipestream.module.pipelineprobe: Per-step totals for REST / worker status (copy of live counters).
triggerId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcCrawlManager.JdbcDispatch: Returns the value of the triggerId record component.
triggerId() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunLedger: The run's trigger id, as supplied at construction.
typeRegistry() - Method in class ai.pipestream.module.pipelineprobe.ProtobufTypeRegistryProducer: Builds the singleton protobuf TypeRegistry by seeding it with a fixed set of generated message descriptors, transitively collecting their file-descriptor dependencies, and registering every (including nested) message type.

U

unary(Consumer) - Static method in class ai.pipestream.module.pipelineprobe.grpc.GrpcFutures: Invokes a unary gRPC call and returns a CompletableFuture that completes with the single response, fails with the gRPC status, or fails with IllegalStateException if the call closes without producing a response.
unavailable() - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber.S3DispatchState: True when the status stream could not be established — fall back to stability gating.
unique() - Method in record class ai.pipestream.module.pipelineprobe.TransportTestCounter.StepCounts: Returns the value of the unique record component.
uniqueCount() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot: Returns the value of the uniqueCount record component.
uniqueCount(String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.SidecarTapPoller: Unique-doc count seen at one specific tap node for the given account.
unregister(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.ActiveCrawlRegistry: Mark a crawl's observation stream as closed.
unsubscribe(StreamObserver) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunHandle: Detach a subscriber (client went away).
upload(PipeDoc, String) - Method in class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream: Push one doc.
uploadAndDispatch(String, String, String, SingleDocSourceConfig, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.SingleDocDispatcher: Upload a single bundled sample to connector-intake and return the resulting doc_id.
uploadRaw(InputStream, long, String, String, String, String, String, String) - Method in interface ai.pipestream.module.pipelineprobe.pipelinecrawl.RawUploadRestClient: Streams a raw document body to connector-intake's POST /uploads/raw endpoint, forwarding it chunk-by-chunk so arbitrarily large docs never buffer in memory.
US_CONSTITUTION - Enum constant in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Full text of the United States Constitution, as plain text.
useExternalDb() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload: Returns the value of the useExternalDb record component.

V

VALIDATE - Enum constant in enum class ai.pipestream.module.pipelineprobe.TestProcessorHelper.ProcessingMode: Schema validation mode — validates required fields.
validateShape(PipelineSource, Set, List) - Method in class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory: Validate the request-derived graph shape without building anything.
valueOf(String) - Static method in enum class ai.pipestream.module.pipelineprobe.opensearch.CourtFixtureSource.Stage: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunState: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class ai.pipestream.module.pipelineprobe.TestProcessorHelper.ProcessingMode: Returns the enum constant of this class with the specified name.
values() - Static method in enum class ai.pipestream.module.pipelineprobe.opensearch.CourtFixtureSource.Stage: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunState: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class ai.pipestream.module.pipelineprobe.SampleDocument: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class ai.pipestream.module.pipelineprobe.TestProcessorHelper.ProcessingMode: Returns an array containing the constants of this enum class, in the order they are declared.
vectorSetIds() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult: Returns the value of the vectorSetIds record component.
vectorSetIds() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup: Returns the value of the vectorSetIds record component.
version() - Method in record class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient.ActiveGraph: Returns the value of the version record component.

W

Why processData, not the experimental StreamDocuments - Section in class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver
withAddMetadata(boolean) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Sets the addMetadata config field.
withBody(String) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestDocumentBuilder: Sets the document body.
withCustomField(String, boolean) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestDocumentBuilder: Adds a boolean-valued custom field.
withCustomField(String, double) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestDocumentBuilder: Adds a numeric custom field.
withCustomField(String, String) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestDocumentBuilder: Adds a string-valued custom field.
withDocId(String) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestDocumentBuilder: Sets the doc id, overriding the default random one.
withDocument(PipeDoc) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Sets the document to include in the request.
withHopNumber(long) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Sets the current hop number in the request metadata.
withMode(TestProcessorHelper.ProcessingMode) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Sets the processing mode config field to the lower-cased mode name.
withPipelineName(String) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Sets the pipeline name in the request metadata.
withSchemaValidation(boolean) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Sets the requireSchema config field.
withSimulateError(boolean) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Sets the simulateError config field.
withStepName(String) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Sets the pipe-step name in the request metadata.
withStreamId(String) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder: Sets the stream id in the request metadata.
withTitle(String) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestDocumentBuilder: Sets the document title.
work(StreamObserver) - Method in class ai.pipestream.module.pipelineprobe.mockengine.MockWorkEngineService
wrap(PipeDoc) - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ChunkerScaffold
wrap(PipeDoc) - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.OpenSearchSinkScaffold
wrap(PipeDoc) - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.ParserScaffold
wrap(PipeDoc) - Method in class ai.pipestream.module.pipelineprobe.moduletest.scaffold.PassthroughScaffold
wrap(PipeDoc) - Method in interface ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffold: Turn a corpus doc into the step's expected input PipeStream (directives, context_params, …).

A B C D E F G H I J K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form