All Classes and Interfaces
Class
Description
Deprecated.
Parity with
sdk/ts/src/database/types/action.interface.ts.where = Map or string; limit/offset = number or string placeholder.Template parsed for placeholders.
Sprint 5 — streaming and human-in-the-loop callbacks.
Sprint 5 — mutable agent runtime context: history, memory, tools, conversation state.
TS parity: sdk/ts/src/agents/agents.service.ts
AgentErrorSnapshot of the resolved inputs handed to an
AgentLocalExecutor.Local executor seam for
AgentsService.Sprint 5 — chat message model used by the agent executor and LLM providers.
TS parity: sdk/ts/src/agents/agents.service.ts (define/register/dispatch/local registry).
Sprint 5 — single tool-call dispatch record.
Parity with
sdk/ts/src/database/types/aggregation.interface.ts.Per-alias map of aggregation operations.
Sprint 5 — Anthropic Messages API provider with tool-schema request support.
App-action runtime façade: parity with TS
ductape.api.run / .dispatch.TS parity:
Ductape.auths — auth/credential CRUD for an app, backed by the same
appApi.updateApp(appId, { component: 'auth', action, ...data }) dispatch used by
AppCatalogOperations/AppEnvironmentOperations.TS parity:
Ductape.app workspace app CRUD surface.TS
app.environments.Sprint 3 — Apps fluent chain.
Inline action builder used by
AppChain.withAction(String, Consumer).Inline notification builder.
Inline storage builder.
Customer-managed VPC security groups for AWS RDS / Neptune provision.
Azure AI Search REST adapter — parity with TS azure-search.adapter.ts
Azure Service Bus provider — parity with TS azure-servicebus.service.ts
Java counterpart to TS
BaseVectorAdapter — connection + vector ops.Marks a public symbol as beta: usable, but its signature and behavior may
change in any release prior to its promotion to
Stable.In-memory bootstrap response cache (5 min TTL).
Sprint 3 — Broker fluent chain (
.broker(...) with
withTopic / withConsumer / withIdempotency).Provider seam that mirrors the TS dynamic broker loader (createBrokerService)
and lets tests / advanced callers substitute provider implementations without
touching
ProviderFactory.create(app.ductape.sdk.brokers.types.BrokerTypes.MessageBrokerType, java.util.Map<java.lang.String, java.lang.Object>).Java parity models for TS brokers/types/index.ts.
TS parity utility helpers from brokers/utils/broker.util.ts.
Executes built aggregations from
AggregationBuilder against an in-memory BaseAdapter.TS
CacheError: typed failures from CacheService operations.TS parity:
sdk/ts/src/cache/cache.manager.ts.TS
cache.service.ts: remote cache via ProcessorApiService, optional local Redis (Lettuce) for reads/writes.Option and result types aligned with TS
sdk/ts/src/cache/types/index.ts.Real Cassandra adapter via the DataStax Java driver 4.x (Go/.NET Cassandra live-adapter
parity).
Cloud provider connections API; mirrors
cloudApi.service.ts.Resolves cloud connection tags to internal connection ids (mirrors cloud-api.util.ts).
Post-materialize env processing: workspace secrets + product private-key encryption.
Create-time secret materialization for cloud-linked product components (TS ProductsService parity).
Materializes cloud-linked storage, broker, and database envs (mirrors TS cloud-*-link.util.ts).
Shared provision cache for multi-env cloud materialization (mirrors TS cloud-materialize.util.ts).
AWS networking modes on a cloud connection.
Runtime credential refresh and VPC connector helpers; mirrors TS
cloud-runtime.util.ts.Workspace cloud connections (AWS, GCP, Azure); mirrors
cloud.service.ts.Maps cloud provider to integrations service key per component kind.
Parity with
sdk/ts/src/database/types/connection.interface.ts.Short connection key (previously top-level
ConnectionContext in this package).TS
IConnectionContext — full connection state (not only product/database/env).TS parity utility mirroring the
VECTOR_LOG_DEBOUNCE_MS,
GRAPH_CONNECT_LOG_DEBOUNCE_MS, and CONNECT_LOG_DEBOUNCE_MS
pattern used in the TypeScript SDK to suppress duplicate
connect/disconnect log rows within a short window.Bucket discriminator for connect/disconnect lifecycle.
Azure Cosmos DB Gremlin adapter (in-memory stub; Gremlin live via connection URL).
Parity with
sdk/ts/src/database/types/dashboard.interface.ts.Sprint 3 — Database fluent chain.
TS parity:
sdk/ts/src/database/databases.service.ts DatabaseConnection.Parity with
sdk/ts/src/database/utils/database-error.ts (typed DatabaseTypes.DatabaseErrorType).Vendor / engine selector — parity with
DatabaseType in sdk/ts/src/database/types/enums.ts.TypeScript parity:
sdk/ts/src/database/types/enums.ts.Discoverability index for TypeScript
sdk/ts/src/database/index.ts type re-exports.TS parity: sdk/ts/src/warehouse/registry/data-source-registry.ts
Sprint 5 — default LLM/tool loop with max-iteration guard and HITL callbacks.
Safe default provider used when no live provider is configured.
Sprint 4 — default in-process feature executor.
Java SDK entrypoint; mirrors the service surface of
sdk/ts/src/index.ts (see
PARITY_MAP.md Ductape row for gaps).Common contract for typed SDK exceptions without forcing existing classes into a new hierarchy.
Stable SDK-wide error-code catalog used by the Java facade and parity tests.
Multipart part: text or binary.
Sprint 8 production hardening: a single source of truth for SDK-owned thread naming.
Real DynamoDB adapter via the AWS SDK for Java v2 (Go
DynamoLiveAdapter / .NET
DynamoDbDriverLiveAdapter parity).Internal API host routing.
Sprint 3 — Executable fluent chain.
Inline payload params builder.
Sprint 3 — Fallback fluent chain.
Sprint 4 — Java fluent feature step-composition builder mirroring TS
workflow-builder.ts.Step-level fluent builder.
Sprint 4 — serializable checkpoint used by replay/resume flows.
Snapshot of the resolved inputs handed to a
FeatureLocalExecutor.Sprint 4 — full in-process feature execution state, TS-shaped for fixtures.
Local executor seam for
FeatureService.Sprint 4 — rollback summary matching TS
rollback_info.Sprint 4 — queued or applied feature signal.
Sprint 4 — Feature status enum, mirroring TS
WorkflowStatus.Sprint 4 — TS-shaped runtime state for a single feature step.
Google Pub/Sub provider runtime parity with TS google-pubsub.service.ts.
Sprint 3 — Graph fluent chain (
.graph(...) with withAction / withSchema).Graph operations facade; tracks
sdk/ts/src/graph/graphs.service.ts (see PARITY_MAP.md +
PARITY_ROADMAP.md § Graph for Redisson-native processJob and adapter depth).TS
graphs.service.ts#get action().dispatch — predefined graph-action jobs tagged
graph-action:{graph}:{event} (vs GraphService.GraphActionDispatchSubsystem.dispatch(java.util.Map<java.lang.String, java.lang.Object>) for raw graph-operation jobs).Mirrors TS
graph.dispatch vs graph.action.dispatch.TS parity for
transactions/transaction-manager.ts: lifecycle owner for a single
graph adapter's transactions.Sprint 3 — Healthcheck fluent chain.
Per-host outbound HTTP rate limit.
Thrown when the SDK-side outbound HTTP token bucket is exhausted for a host.
App-collection importer: parity with TS
ImportService (uploads Postman v2.1
and OpenAPI v3.0 documents to the Ductape Apps API).TS
ImportDocsTypes enum values.Human-readable messages from integrations service responses.
Marks a public symbol as an internal implementation detail.
Kafka provider runtime parity with TS kafka.service.ts.
Bridges Lettuce
StatefulRedisConnection to CacheManager.RedisClient
for the optional Redis cache tier (TS/Java three-tier CacheManager parity).Sprint 5 — LLM provider SPI for chat, tool calling, and optional streaming.
Sprint 5 — LLM provider chat completion result.
Normalizes SDK log rows for backend ingestion and workbench filters.
Batched log buffer with fire-and-forget publish; mirrors logs.service.ts.
Real MariaDB adapter — extends
MySqlJdbcLiveAdapter (same MariaDB Connector/J driver,
same plain-Connection/no-pool behavior) and overrides only the reported
DatabaseType and connection-string resolution priority (mirrors .NET
MariaDbConnectorLiveAdapter extends MySqlConnectorLiveAdapter / Go's shared
MySQLLiveAdapter backend parameterized by dbType).Parity with TS
memory.adapter.ts / MemoryAdapter.Sprint 5 — short/long-term memory with simple summarization and retrieval scoring.
Parity with
sdk/ts/src/database/types/migration.interface.ts.TS
FieldType string union — wire values match TS literals.TS migration
IConstraintDefinition (embedded in SQL options / addConstraint).Builds TS-shaped migration operation maps.
Sprint 3 — Model fluent chain.
TS parity: sdk/ts/src/models/models.service.ts — LLM model configs via product
model components.Real MongoDB adapter via the official MongoDB Java Sync Driver (Go/.NET Mongo live-adapter
parity).
Real MySQL adapter via the MariaDB Connector/J driver (Go
MySQLLiveAdapter / .NET
MySqlConnectorLiveAdapter parity).NATS provider runtime parity with TS nats.service.ts.
Production Neo4j connectivity via official Bolt driver (
bolt://, neo4j://, neo4j+s://, …).Sprint 5 — OpenAI Chat Completions provider with tool-schema request support.
AWS OpenSearch k-NN REST adapter — parity with TS opensearch.adapter.ts
Fire-and-forget operation logs (createNode, query, etc.) for LogAPI.
Parity with TS
pinecone.adapter.ts / PineconeAdapter.Real PostgreSQL adapter via pgjdbc (Go
PostgresPgxAdapter / .NET
NpgsqlPostgreSqlAdapter parity).Parity with
sdk/ts/src/database/types/presave.interface.ts.data is a single row map or list of row maps (TS Record | Record[]).Runtime job executor aligned to TS
processor.service#runJobs.TS parity:
Ductape.product.apps in sdk/ts/src/index.ts.Sprint 3 — Fluent
ProductBuilder entry point.TS parity:
Ductape.product.environments.Product-field AES-256-CBC encryption (TS/Java sessions/cache parity).
TS parity:
Ductape.product in sdk/ts/src/index.ts.Storage, message broker, and database component CRUD with cloud-linked env materialization
(mirrors TS createStorage / createMessageBroker / createDatabase and updates).
Provider chooser mirroring TS dynamic provider loader switch.
Parity with TS
qdrant.adapter.ts / QdrantAdapter.Parity with
Operators in sdk/ts/src/database/operators/query-builder.ts.Parity with
sdk/ts/src/database/types/query.interface.ts.Result of the internal build step before adapter execution.
IInclude —
type is DatabaseTypes.RelationshipType.wire() or TS string literal form.IOrderBy — use
DatabaseTypes.SortOrder#name() for order when not using string literals.TypeScript
IQueryOptions; filter shape is Map ( IWhereClause ).TS parity: sdk/ts/src/warehouse/parser/query-parser.ts
QueryValidationErrorSprint 3 — Quota fluent chain.
RabbitMQ provider runtime parity with TS rabbitmq.service.ts.
Redis provider runtime parity using lettuce (already a project dependency).
Redisson-native queue adapter that mirrors the queue touchpoints used by TS
JobsService
(which is BullMQ-backed in TS).TS parity:
IRegisteredDataSourceTS parity:
resilience.service.ts / sub-services HealthcheckError, QuotaError, FallbackError.TS parity: unified facade over
ResilienceApiService matching sdk/ts/src/resilience/index.ts
namespaces (healthcheck, quota, fallback), plus ResilienceService.define(java.lang.String, java.lang.String, java.lang.String, app.ductape.sdk.resilience.ResilienceService.ResilienceDefineHandler) / ResilienceService.register(java.lang.String, java.util.Map<java.lang.String, java.lang.Object>).TS
resilience.fallback.*.TS
resilience.healthcheck.* via integrations API.TS
resilience.quota.*.TS
RecordingResilienceContext — collects payloads for ResilienceService.define(java.lang.String, java.lang.String, java.lang.String, app.ductape.sdk.resilience.ResilienceService.ResilienceDefineHandler).Constructor-level product tag and environment slug inherited by database/graph/vector calls.
Parity with
sdk/ts/src/database/types/schema.interface.ts (core + introspection + index stats;
simplified Mongoose-style block uses stringly-typed fields until migration DTOs land).type is DatabaseTypes.ColumnType name or a driver-specific string.OpenTelemetry helper for SDK spans and W3C trace-context propagation.
Sprint 3 — Secret fluent chain.
TS parity: sdk/ts/src/secrets/secrets.resolver.ts
TS parity: sdk/ts/src/secrets/secrets.service.ts
TS parity: sdk/ts/src/secrets/secrets.types.ts (subset used by Java service).
Java parity utility for TS sessions.helper.ts.
Java parity utility for TS sessions.resolver.ts.
Shared DTO/record types for sessions module parity.
GCP Spanner Graph adapter (in-memory stub; use query() with GQL for live Spanner).
AWS SQS provider runtime parity with TS aws-sqs.service.ts.
Marks a public type, method, field, or constructor as part of the stable, supported public
surface of the Ductape Java SDK.
TS
WorkflowStepKind parity covering the step types supported by the
default executor: action / database / graph / vector / broker / storage /
notification / quota / fallback / healthcheck / sequence / parallel /
conditional / loop / wait / signal / checkpoint.Mirrors sdk/ts/src/apps/utils/string.utils.ts
tagify.TS parity: sdk/ts/src/agents/tool-registry.ts (registry surface without LLM format helpers).
Parity with TS
database/transactions/transaction-manager.ts.Parity with
sdk/ts/src/database/types/transaction.interface.ts.isolationLevel is an DatabaseTypes.IsolationLevel name (e.g.TS parity:
trigger-processor.ts exported Trigger helper object.TS parity:
interpolateTemplate / getNestedValue from trigger-processor.ts.In-memory trigger registry + persisted-shape CRUD (
TriggerTypes.TriggerManager).Parity with
sdk/ts/src/database/types/trigger.interface.ts.Persisted/API shape:
config holds type-specific fields (TS IPersistedTriggerAction).TS
ITriggerConfig without functional hooks.Full trigger definition.
TS
ITriggerManager — implement with HTTP/SDK clients; async variants omitted.TS parity:
sdk/ts/src/vector/types/action.interface.ts plus VectorActionTypes from
sdk/ts/src/types/productsBuilder.types.ts.TS
IVectorActionCreateOptionsTS
IVectorActionDefinitionTS
IVectorActionDeleteOptionsTS
IVectorActionExecuteOptionsTS
IVectorActionFetchOptionsTS
VectorActionTypes enum — wire values match TS string initializer valuesTS
IVectorActionParamTS
IVectorActionResultTS
IVectorActionTemplate — declared fields plus extra for additional keys
(TS index signature [key: string]: any).TS
IVectorActionUpdateOptionsMap/json helpers for TS
action.interface.ts (VectorActionInterfaceTypes).Factory matching TS module layout:
index.ts exports one adapter per provider;
there is no separate adapter.factory.ts in TS, but the registry mirrors
GraphAdapterFactory and AdapterFactory.Sprint 3 — Vector fluent chain (
.vector(...) with withAction / withEmbedding).Map/json helpers for TS
connection.interface.ts records (VectorConnectionTypes).TS parity:
sdk/ts/src/vector/types/connection.interface.ts — connection and product config shapes.Nested
index on TS IVectorTestConnectionResultTS
IVectorConfigTS
IVectorConnectionConfigTS
IVectorConnectionContextTS
IVectorConnectionOptionsTS
IVectorConnectionResultTS
IVectorEnvConfigTS
IVectorServiceConfigTS
IVectorTestConnectionResultProduct-level vector management; delegates runtime operations to
VectorService
(parity with vector-database.service.ts + shared registry in TS).JSON/map helpers for TS
embedding.interface.ts (VectorEmbeddingTypes).TS parity:
sdk/ts/src/vector/types/embedding.interface.ts — embedding provider config and results.TS
IBatchEmbeddingResultTS
ICohereEmbeddingConfigTS
IEmbeddingModelConfigTS
EmbeddingProviderTS
IEmbeddingResultTS
IEmbedOptionsTS
IHuggingFaceEmbeddingConfigTS
ILocalEmbeddingConfigTS
IOpenAIEmbeddingConfigTS
IVoyageEmbeddingConfigConverts TS-shaped JSON maps for vector operations into
VectorInterfaceTypes records and back.TS parity:
sdk/ts/src/vector/types/vector.interface.ts — vector CRUD/index shapes.TS
ICreateIndexOptionsTS
ICreateIndexResultTS
IDeleteIndexOptionsTS
IDeleteIndexResultTS
IDeleteVectorsOptionsTS
IDeleteVectorsResultTS
IFetchVectorsOptionsTS
IFetchVectorsResultTS index status literal
TS
IListNamespacesResultTS
IListVectorsOptionsTS
IListVectorsResultTS
IMetadataFilter.TS
IMetadataFilterGroup.Recursive TS
IMetadataFilter | IMetadataFilterGroup.TS
MetadataFilterOperatorTS
INamespaceInfoTS
IQueryMatchTS
IQueryVectorsOptions (dense + hybrid fields).TS
IQueryVectorsResultTS
ISparseVectorTS
IUpdateVectorOptionsTS
IUpdateVectorResultTS
IUpsertVectorsOptionsTS
IUpsertVectorsResultTS
IVectorIndexInfoTS
IVectorIndexStatsTS
IVectorTS parity:
sdk/ts/src/vector/utils/metadata-schema.ts — VectorMetadataSchemaInferer.inferVectorMetadataSchema(java.util.List<java.util.Map<java.lang.String, java.lang.Object>>) samples are
metadata objects (flat maps).TS
IVectorMetadataFieldSchemaTS
IVectorMetadataSchemaTS
VectorMetadataValueTypeParity with TS
vector.service.ts / VectorService (synchronous Java API).Parity with TS
IVectorServiceOptions (see vector.service.ts).Sprint 5 — bridge agent long-term memory to
VectorDatabaseService.TS parity:
sdk/ts/src/vector/types/enums.ts — wire strings match TS enum values for API payloads.TS
DistanceMetricTS
VectorDBTypeTS
VectorErrorTypeTS
VectorFeatureTS
VectorIndexTypeGCP Vertex AI Vector Search REST adapter — parity with TS vertex-vector-search.adapter.ts
Opens a TCP-over-WebSocket tunnel to a private VPC host via the Ductape VPC connector relay,
then exposes it as a loopback-only local TCP proxy so any plain JDBC driver (which has no
custom-stream hook, unlike
pg's Pool on the TS side) can connect to it as if it
were an ordinary local socket.Live tunnel handle: a
stream_id-correlated WebSocket session plus the local loopback
TCP proxy that relays bytes to/from it.Target VPC-private TCP endpoint to relay to, plus the cloud connection tag authorizing it.
TS parity: sdk/ts/src/warehouse/executor/joins/join-executor.ts (hash, nested loop, sort-merge).
TS parity:
sdk/ts/src/warehouse/types/join.interface.ts — join kinds, conditions, configs, and helpers.TS
ICompoundJoinConditionTS
IGraphJoinConfigTS
IJoinConditionTS
JoinType — standard + semantic + graphTS
parseFieldPath resultTS
ISemanticJoinConfigTS
StandardJoinTypeTS parity: sdk/ts/src/warehouse/types/join.interface.ts
validateJoinClause.Parsed join clause (parser output).
TS parity:
IQueryAST from query-parser.ts.TS parity: sdk/ts/src/warehouse/parser/query-parser.ts (validation + AST shape).
TS parity:
sdk/ts/src/warehouse/types/query.interface.ts — query shapes, hints, and result metadata.TS
IAggregationTS
IExecutionHintsTS
IExecutionPlanTS
IExecutionStepTS
IFieldMappingTS
IJoinStatsTS
IOrderByTS
IDataSourceTS
IQueryMetadata (subset used by Java result maps)TS
ISourceStatsTS
WarehouseOperationTS parity: sdk/ts/src/warehouse/types/transaction.interface.ts
generateCompensation.TS parity: sdk/ts/src/warehouse/transactions/saga-orchestrator.ts (synchronous).
TS parity: sdk/ts/src/warehouse/executor/joins/semantic-join.ts
TS parity: sdk/ts/src/warehouse/warehouse.service.ts
TS parity: sdk/ts/src/warehouse/executor/single-source-executor.ts
TS parity:
sdk/ts/src/warehouse/types/transaction.interface.ts — saga enums, retry config, and helpers.TS
IRetryConfigTS
SagaIsolationTS
SagaStatusTS
StepStatusTS parity: sdk/ts/src/warehouse/types — runtime context, config, embedder hooks, and result map helpers
used by
WarehouseService.TS async
embedFn returning a Promise-like future; used when set on
WarehouseTypes.WarehouseConfig (semantic join prefers WarehouseTypes.TextEmbedder when both are set).TS parity:
ISagaOrchestratorOptions.persistState / loadState in
saga-orchestrator.ts (synchronous callbacks).TS
embedFn for semantic joins: text → embedding components.Default warehouse context (TS
IWarehouseContext).TS parity:
sdk/ts/src/warehouse/types/where.interface.ts — IUnifiedWhereClause wire shape
(Map<String, Object>) plus the same helper functions as TS.Parity with TS
weaviate.adapter.ts / WeaviateAdapter.Parity with
sdk/ts/src/database/types/write.interface.ts.TS
IUpdateOperator — model as a map of operator keys ($inc, $set, …).
ApiServiceviaDuctape.api().