Index

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
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
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