Package app.ductape.sdk.warehouse

Class WarehouseService

java.lang.Object

app.ductape.sdk.warehouse.WarehouseService

public class WarehouseService
extends Object

TS parity: sdk/ts/src/warehouse/warehouse.service.ts

Constructor Summary

Constructors

Constructor	Description
WarehouseService(DatabaseService databaseService, GraphService graphService, VectorDatabaseService vectorService, WarehouseTypes.WarehouseContext context, WarehouseTypes.WarehouseConfig config)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	delete(Map<String,Object> source, Map<String,Object> where, Boolean returning)
void	destroy()	TS WarehouseService#destroy: release registry resources.
List<RegisteredDataSource>	getDataSources(WarehouseTypes.DataSourceType type)
Map<String,Object>	getSagaState(String sagaId)	TS SagaOrchestrator#getState for the in-flight saga id (while query(java.util.Map<java.lang.String, java.lang.Object>) transaction is executing).
Map<String,Object>	insert(Map<String,Object> source, Object data, Boolean returning)
Map<String,Object>	query(Map<String,Object> query)
void	registerDatabase(String tag, String env, String product)
void	registerGraph(String tag, String env, String product)
void	registerVector(String tag, String env, String product)
DataSourceRegistry	registry()
Map<String,Object>	resumeSaga(String sagaId)	TS SagaOrchestrator#resume when WarehouseTypes.WarehouseConfig.sagaStateHooks defines loadState.
List<Map<String,Object>>	select(Map<String,Object> source, Map<String,Object> options)
WarehouseSemanticJoinExecutor	semanticJoin()	Direct access for TS-style semanticJoinExecutor.executeBatch(...).
Map<String,Object>	transaction(List<Map<String,Object>> operations, Map<String,Object> sagaOptions)
Map<String,Object>	update(Map<String,Object> source, Map<String,Object> data, Map<String,Object> where, Boolean returning)
Map<String,Object>	upsert(Map<String,Object> source, Map<String,Object> data, Boolean returning)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WarehouseService

public WarehouseService(DatabaseService databaseService,
 GraphService graphService,
 VectorDatabaseService vectorService,
 WarehouseTypes.WarehouseContext context,
 WarehouseTypes.WarehouseConfig config)

Method Details

registry

public DataSourceRegistry registry()

semanticJoin

public WarehouseSemanticJoinExecutor semanticJoin()

Direct access for TS-style semanticJoinExecutor.executeBatch(...).

resumeSaga

public Map<String,Object> resumeSaga(String sagaId)

TS SagaOrchestrator#resume when WarehouseTypes.WarehouseConfig.sagaStateHooks defines loadState.

getSagaState

public Map<String,Object> getSagaState(String sagaId)

TS SagaOrchestrator#getState for the in-flight saga id (while query(java.util.Map<java.lang.String, java.lang.Object>) transaction is executing).

registerDatabase

public void registerDatabase(String tag,
 String env,
 String product)

registerGraph

public void registerGraph(String tag,
 String env,
 String product)

registerVector

public void registerVector(String tag,
 String env,
 String product)

getDataSources

public List<RegisteredDataSource> getDataSources(WarehouseTypes.DataSourceType type)

destroy

public void destroy()

TS WarehouseService#destroy: release registry resources.

query

public Map<String,Object> query(Map<String,Object> query)

select

public List<Map<String,Object>> select(Map<String,Object> source,
 Map<String,Object> options)

insert

public Map<String,Object> insert(Map<String,Object> source,
 Object data,
 Boolean returning)

update

public Map<String,Object> update(Map<String,Object> source,
 Map<String,Object> data,
 Map<String,Object> where,
 Boolean returning)

delete

public Map<String,Object> delete(Map<String,Object> source,
 Map<String,Object> where,
 Boolean returning)

upsert

public Map<String,Object> upsert(Map<String,Object> source,
 Map<String,Object> data,
 Boolean returning)

transaction

public Map<String,Object> transaction(List<Map<String,Object>> operations,
 Map<String,Object> sagaOptions)