Index
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
accessKeyIdrecord component. - accountId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload
-
Returns the value of the
accountIdrecord component. - AccountManager - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl
-
Resolves the test account for a
RunPipelineCrawlrun. - 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
ackedFailrecord component. - ackedOk() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot
-
Returns the value of the
ackedOkrecord 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-flightOrchestrationDriverrun). - 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
ActiveGraphrecord 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
apiKeyrecord 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
artifactIdrecord 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
auditLogrecord 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
baseBackoffMsfor each successive attempt. - baseBackoffMs() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy
-
Returns the value of the
baseBackoffMsrecord 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
datasourceIdtographIdatentryNodeId. - body() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker.DoorResponse
-
Returns the value of the
bodyrecord component. - bucket() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload
-
Returns the value of the
bucketrecord component. - build() - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestDocumentBuilder
-
Builds the
PipeDocwith 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
ProcessDataRequestwith the configured document, service metadata, and (when any config fields were set) aProcessConfigurationcarrying 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()forTestProcessor. - Built(PipelineGraph, String, String, List, List, List, Set) - Constructor for record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built
-
Creates an instance of a
Builtrecord class.
C
- call(String, Supplier, GrpcRetry.RetryPolicy) - Static method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry
-
Invoke
stubCallwith bounded retry perpolicy. - 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
captureNoderecord 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
chunkerSentenceIdrecord component. - chunkerSentencesInternalId() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult
-
Returns the value of the
chunkerSentencesInternalIdrecord 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
CleanupFailurerecord 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
CleanupSummaryrecord class. - clear() - Static method in class ai.pipestream.module.pipelineprobe.LastErrorTracker
-
Clears the recorded error so that
LastErrorTracker.get()returnsnullagain. - 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
concurrencyrecord 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
consumedByModulerecord component. - content() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader.Sample
-
Returns the value of the
contentrecord 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>.pbresources 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
countsrecord 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
crawlIdrecord component. - crawlName() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcCrawlManager.JdbcDispatch
-
Returns the value of the
crawlNamerecord 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
CrawlProgressrecord class. - created() - Method in record class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient.ActiveGraph
-
Returns the value of the
createdrecord 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 ofDatasourceManager.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
credentialsTyperecord component.
D
- DatasourceCredentials(String, String) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager.DatasourceCredentials
-
Creates an instance of a
DatasourceCredentialsrecord class. - datasourceId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources
-
Returns the value of the
datasourceIdrecord component. - datasourceId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.DatasourceManager.DatasourceCredentials
-
Returns the value of the
datasourceIdrecord component. - DatasourceManager - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl
-
Creates a datasource for a
RunPipelineCrawlrun 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_configfor 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
deletedrecord 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
DocAckrecord class. - docId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.SingleDocDispatcher.SingleDocDispatch
-
Returns the value of the
docIdrecord 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
DoorResponserecord 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
duplicateCountrecord component. - duplicates() - Method in record class ai.pipestream.module.pipelineprobe.TransportTestCounter.StepCounts
-
Returns the value of the
duplicatesrecord 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
edgeTransportsrecord 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
embeddingMinilmIdrecord 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
detailsStruct (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
endpointrecord component. - endpointOverride() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload
-
Returns the value of the
endpointOverriderecord 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
docscorpus 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
entryNodeIdrecord 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
errorrecord 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
errorCountrecord 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
exceptionClassrecord 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
failedrecord 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
failedRetryingrecord component. - failedTerminal() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress
-
Returns the value of the
failedTerminalrecord component. - familyCounts(String, String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller
-
Get per-index counts of docs indexed under
crawlIdacross thebaseIndexNamefamily. - FamilySnapshot(Map) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.OpenSearchPoller.FamilySnapshot
-
Creates an instance of a
FamilySnapshotrecord 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
fileNamerecord component. - finishedAt() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot
-
Returns the value of the
finishedAtrecord component. - firstGrpcError() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot
-
Returns the value of the
firstGrpcErrorrecord component. - firstNackReason() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot
-
Returns the value of the
firstNackReasonrecord 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
formatrecord 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
nullif 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
graphrecord 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
graphIdrecord component. - graphId() - Method in record class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient.ActiveGraph
-
Returns the value of the
graphIdrecord component. - graphId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources
-
Returns the value of the
graphIdrecord component. - GrpcFutures - Class in ai.pipestream.module.pipelineprobe.grpc
-
Tiny
StreamObserver-to-CompletableFutureadapter 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
httpStatusrecord 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
hydratedCountrecord component. - hydrateSampleData() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload
-
Returns the value of the
hydrateSampleDatarecord 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
indexNamerecord component. - indexName() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup
-
Returns the value of the
indexNamerecord 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
inFlightrecord component. - inFlight() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress
-
Returns the value of the
inFlightrecord 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
intakeAccountrecord 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 (IntakeCrawlStreamis the reference implementation):StreamContexthandshake first (datasource + api key + crawl_id), then onePipeDocItemper 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
intakeMintedrecord component. - intakeMode() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.SingleDocPayload
-
Returns the value of the
intakeModerecord component. - invoke(String, byte[]) - Method in class ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker
-
POST
payloadto<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
jdbcrecord component. - JdbcCrawlManager - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl
-
Drives the JDBC source for a
RunPipelineCrawlrun: 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 thecrawl_idon 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
JdbcDispatchrecord class. - JdbcDispatchSubscriber - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl
-
Subscribes to the JDBC connector's
streamCrawlStatusserver-streaming RPC and hydrates aRunLedgerfrom 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
jdbcPasswordrecord component. - JdbcPayload(Boolean, String, String, String, Integer) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload
-
Creates an instance of a
JdbcPayloadrecord class. - jdbcUrl() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload
-
Returns the value of the
jdbcUrlrecord component. - jdbcUsername() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.JdbcPayload
-
Returns the value of the
jdbcUsernamerecord component. - jobId() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot
-
Returns the value of the
jobIdrecord 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
journalDroppedrecord component. - journalSize() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo
-
Returns the value of the
journalSizerecord component.
K
- kafkaPartitions() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload
-
Returns the value of the
kafkaPartitionsrecord component.
L
- last(String) - Method in class ai.pipestream.module.pipelineprobe.pipelinecrawl.TerminalDocCapture
-
The last terminal doc for
accountId, ornullif none. - LastError(Instant, String, String, String, String, String) - Constructor for record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError
-
Creates an instance of a
LastErrorrecord class. - lastErrorMessage() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot
-
Returns the value of the
lastErrorMessagerecord 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
lastMessagerecord component. - latencyMaxMs() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot
-
Returns the value of the
latencyMaxMsrecord component. - latencyP50Ms() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot
-
Returns the value of the
latencyP50Msrecord component. - latencyP95Ms() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot
-
Returns the value of the
latencyP95Msrecord component. - latencyP99Ms() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot
-
Returns the value of the
latencyP99Msrecord component. - leasesReleased() - Method in record class ai.pipestream.module.pipelineprobe.cleanup.TestGraphCleanupService.CleanupSummary
-
Returns the value of the
leasesReleasedrecord 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
IndexPlanEntityknown 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 feedsstage.
M
- mainFlowNodeIds() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built
-
Returns the value of the
mainFlowNodeIdsrecord 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
maxDocumentsrecord component. - maxRetries() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy
-
Returns the value of the
maxRetriesrecord component. - message() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError
-
Returns the value of the
messagerecord component. - message() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream.DocAck
-
Returns the value of the
messagerecord component. - method() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError
-
Returns the value of the
methodrecord component. - mimeType() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.S3SampleDocLoader.Sample
-
Returns the value of the
mimeTyperecord 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
MockWorkEngineServicehands 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
ModuleWorkServiceengine 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 devprocess-oncedoor. - 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
PipeStreamto 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
noOpCountrecord 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
observeStepsrecord 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
limitPipeDocs 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
opensearchInstancerecord 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-chosenIndexingStrategy(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 rideStreamMetadata.context_params— whatOpenSearchSinkOptionsParserreads. - 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'sregisterConfigs(...)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
pairingrecord 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
parserConfigrecord component. - ParserScaffold - Class in ai.pipestream.module.pipelineprobe.moduletest.scaffold
-
Parser scaffold: the parser has no captured
<step>-input-courtdataset — 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
partialSuccessrecord 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
pathrecord component. - pathStyleAccess() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload
-
Returns the value of the
pathStyleAccessrecord 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
moduleand 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
persistStepsrecord 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
PipeDocinto a readableStructfor the UI's single-doc output panel. - pipelineAccount() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources
-
Returns the value of the
pipelineAccountrecord component. - pipelineAccountId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload
-
Returns the value of the
pipelineAccountIdrecord 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
PipelineCrawlPayloadrecord 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
PipelineGraphfrom aRunPipelineCrawlRequest's source / steps / observe / transport selection. - PipelineGraphFactory() - Constructor for class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory
-
Creates the pipeline-graph factory.
- PipelineGraphFactory.Built - Record Class in ai.pipestream.module.pipelineprobe.e2e
-
Result of
PipelineGraphFactory.build(String, String, PipelineSource, Set, Set, Set, List, int, Struct, Struct, Struct, Struct, Struct, String)— graph + names callers need to dispatch into it. - pipelineMinted() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources
-
Returns the value of the
pipelineMintedrecord component. - planId() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult
-
Returns the value of the
planIdrecord component. - planId() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup
-
Returns the value of the
planIdrecord component. - planId() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.CrawlCleanupService.RunResources
-
Returns the value of the
planIdrecord component. - planIds() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot
-
Returns the value of the
planIdsrecord component. - planName() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SetupResult
-
Returns the value of the
planNamerecord 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
planStatusrecord component. - pollingTimeoutSeconds() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload
-
Returns the value of the
pollingTimeoutSecondsrecord component. - prefix() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload
-
Returns the value of the
prefixrecord 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
producedByModulerecord 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
TypeRegistrypopulated 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 thevector_set_index_bindingcache. - 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
PushSnapshotrecord 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 <= 0clears). - 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
rateOverallrecord component. - rateRecent() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot
-
Returns the value of the
rateRecentrecord 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
reasonrecord 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
receiveNodeIdsrecord component. - recentDocIds() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot
-
Returns the value of the
recentDocIdsrecord 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_DISPATCHEDevent 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
regionrecord 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
rejectCountrecord 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
rejectReasonsrecord 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
requestIdrecord 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
countfresh units (or the configured default whencount < 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
retainIndexrecord component. - retainIndex() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload
-
Returns the value of the
retainIndexrecord component. - retryable() - Method in record class ai.pipestream.module.pipelineprobe.moduletest.engineperf.IntakeDocStream.DocAck
-
Returns the value of the
retryablerecord component. - RetryPolicy(int, long) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.GrpcRetry.RetryPolicy
-
Creates an instance of a
RetryPolicyrecord class. - RichObservationCollector - Class in ai.pipestream.module.pipelineprobe
-
Per-
(key, step)rich observation collector for the Pipeline-tab panels, fed live byPipelineEventsConsumerfrom the engine'spipeline-eventsaudit 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
nullif 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
richTapNodeIdsrecord 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
countunits. - 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
runIdrecord 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
RunInforecord 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
RunResourcesrecord 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
s3record component. - S3CrawlManager - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl
-
Drives the S3 source for a
RunPipelineCrawlrun — the analogue ofJdbcCrawlManagerfor 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
S3Dispatchrecord 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
StreamCrawlStatusfor one crawl and mirrors its state into aS3DispatchSubscriber.S3DispatchStatethe orchestrator's wait loop reads each tick — the S3 counterpart ofJdbcDispatchSubscriber, 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
S3Payloadrecord 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_datais 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
Samplerecord 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.jsonresource. - 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
SampleDataDescriptorrecord 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.jsondescriptor, 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
ObjectMapperis 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
sampleNamesrecord component. - secretAccessKey() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.S3Payload
-
Returns the value of the
secretAccessKeyrecord component. - sent() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot
-
Returns the value of the
sentrecord 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
separateIntakePipelinerecord 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_KNOWNevent. - 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 resolvesplan_ids[]entries viaGetIndexPlan(id), so the id must be the value we hand it), the caller-chosenIndexingStrategy, and the caller's vector-set ids (the e2e 2×2 fromEmbedderFixturesRegistrar.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
SetupResultrecord class. - setupToJson(OpenSearchTestSetupService.SetupResult) - Method in class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService
-
Flattens a
OpenSearchTestSetupService.SetupResultinto 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
singleDocrecord component. - SingleDocDispatch(String) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.SingleDocDispatcher.SingleDocDispatch
-
Creates an instance of a
SingleDocDispatchrecord class. - SingleDocDispatcher - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl
-
Drives the SINGLE_DOC source for a
RunPipelineCrawlrun. - SingleDocDispatcher() - Constructor for class ai.pipestream.module.pipelineprobe.pipelinecrawl.SingleDocDispatcher
-
Creates the single-doc dispatcher.
- SingleDocDispatcher.SingleDocDispatch - Record Class in ai.pipestream.module.pipelineprobe.pipelinecrawl
-
Result of
SingleDocDispatcher.uploadAndDispatch(String, String, String, SingleDocSourceConfig, String): thedoc_idthe upload produced. - SingleDocPayload(List, String) - Constructor for record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload.SingleDocPayload
-
Creates an instance of a
SingleDocPayloadrecord class. - SinkPerfSetup(String, String, List) - Constructor for record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup
-
Creates an instance of a
SinkPerfSetuprecord class. - skipCleanup() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload
-
Returns the value of the
skipCleanuprecord component. - skipped() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress
-
Returns the value of the
skippedrecord 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
Snapshotrecord 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
softErrorCountrecord component. - source() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload
-
Returns the value of the
sourcerecord component. - source() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo
-
Returns the value of the
sourcerecord component. - sourceDocCount() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor
-
Returns the value of the
sourceDocCountrecord component. - stackTrace() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError
-
Returns the value of the
stackTracerecord component. - stage() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot
-
Returns the value of the
stagerecord component. - stage() - Method in record class ai.pipestream.module.pipelineprobe.sampledata.SampleDataDescriptor
-
Returns the value of the
stagerecord 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
docscorpus 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
startedAtrecord component. - startedAt() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo
-
Returns the value of the
startedAtrecord 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.StreamDocumentsbidi RPC. - state() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot
-
Returns the value of the
staterecord component. - state() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.RunRegistry.RunInfo
-
Returns the value of the
staterecord 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
StepCountsrecord class. - stepName() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot
-
Returns the value of the
stepNamerecord component. - steps() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.PipelineCrawlerResource.PipelineCrawlPayload
-
Returns the value of the
stepsrecord 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
requestIdand 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
successrecord component. - success() - Method in record class ai.pipestream.module.pipelineprobe.pipelinecrawl.IndexingLedgerPoller.CrawlProgress
-
Returns the value of the
successrecord 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
tapNodeIdsrecord 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 asOpenSearchTestSetupService.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
terminalAtrecord component. - TerminalDocCapture - Class in ai.pipestream.module.pipelineprobe.pipelinecrawl
-
Captures the most recent
PipeDocthat 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
nullif everything has gone fine so far. - terminalNodeId() - Method in record class ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built
-
Returns the value of the
terminalNodeIdrecord 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
throughputDocsPerSecrecord component. - timestamp() - Method in record class ai.pipestream.module.pipelineprobe.LastErrorTracker.LastError
-
Returns the value of the
timestamprecord 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
ProcessDataRequestfixture into thePipeStreamthe demand-pullTestProcessorconsumes. - 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
docto 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
totalrecord 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
totalrecord 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
totalCountrecord 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
totalRequestedrecord 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
triggerIdrecord 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
TypeRegistryby 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
CompletableFuturethat completes with the single response, fails with the gRPC status, or fails withIllegalStateExceptionif 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
uniquerecord component. - uniqueCount() - Method in record class ai.pipestream.module.pipelineprobe.RichObservationCollector.Snapshot
-
Returns the value of the
uniqueCountrecord 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/rawendpoint, 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
useExternalDbrecord 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
vectorSetIdsrecord component. - vectorSetIds() - Method in record class ai.pipestream.module.pipelineprobe.opensearch.OpenSearchTestSetupService.SinkPerfSetup
-
Returns the value of the
vectorSetIdsrecord component. - version() - Method in record class ai.pipestream.module.pipelineprobe.grpc.EngineGraphClient.ActiveGraph
-
Returns the value of the
versionrecord 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
addMetadataconfig 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
modeconfig 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
requireSchemaconfig field. - withSimulateError(boolean) - Method in class ai.pipestream.module.pipelineprobe.TestProcessorHelper.TestRequestBuilder
-
Sets the
simulateErrorconfig 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, …).
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form