Class RemoteRelationalStore

Remote Storage — PG-wire relational + Bolt protocol graph clients.

RemoteRelationalStore: PostgreSQL via pg.Client, testable via client DI. RemoteGraphStore: Neo4j via neo4j-driver-lite, testable via _Driver DI.

Shared types: MtlsConfig, TrustStrategy (./types.js) Shared interface: PgClientLike (./remote-relational-store.js)

Implements

IRelationalStore

Index

Constructors

constructor

Methods

beginTransaction close commitTransaction gracefulShutdown healthCheck loadCPT loadRegressionModel queryHistoricalResults readMetrics rollbackToCheckpoint saveCPT saveRCAResult saveRegressionModel setCheckpoint writeDetections

Constructors

constructor

new RemoteRelationalStore(
config?: RemoteRelationalConfig,
): RemoteRelationalStore
Parameters
- config: RemoteRelationalConfig = {}
Returns RemoteRelationalStore
- Defined in remote-relational-store.ts:111

Methods

beginTransaction

beginTransaction(sid: string): Promise<void>
Begin a new transaction (maps to SAVEPOINT in SQL databases)
Parameters
- sid: string
Returns Promise<void>
Implementation of IRelationalStore.beginTransaction
- Defined in remote-relational-store.ts:143

close

close(): Promise<void>
Close the store and release all resources

Returns Promise<void>
Implementation of IRelationalStore.close
- Defined in remote-relational-store.ts:147

commitTransaction

commitTransaction(sid: string): Promise<void>
Commit the current transaction
Parameters
- sid: string
Returns Promise<void>
Implementation of IRelationalStore.commitTransaction
- Defined in remote-relational-store.ts:144

gracefulShutdown

gracefulShutdown(ms?: number): Promise<void>
Graceful shutdown with timeout
Parameters
- ms: number = 5000
Returns Promise<void>
- Defined in remote-relational-store.ts:155

healthCheck

healthCheck(): Promise<boolean>
Health check: verifies database connectivity

Returns Promise<boolean>
- Defined in remote-relational-store.ts:150

loadCPT

loadCPT(gid: string, n: string): Promise<ConditionalProbabilityTable | null>
Load a CPT for a specific graph/node combination
Parameters
- gid: string
- n: string
Returns Promise<ConditionalProbabilityTable | null>
Implementation of IRelationalStore.loadCPT
- Defined in remote-relational-store.ts:138

loadRegressionModel

loadRegressionModel(gid: string, n: string): Promise<RegressionParams | null>
Load regression model parameters
Parameters
- gid: string
- n: string
Returns Promise<RegressionParams | null>
Implementation of IRelationalStore.loadRegressionModel
- Defined in remote-relational-store.ts:140

queryHistoricalResults

queryHistoricalResults(q: ResultQuery): Promise<RCAResult[]>
Query historical RCA results by time range and optional filters
Parameters
- q: ResultQuery
Returns Promise<RCAResult[]>
Implementation of IRelationalStore.queryHistoricalResults
- Defined in remote-relational-store.ts:142

readMetrics

readMetrics<S extends TableSchema>(q: MetricQuery): Promise<ColumnarTable<S>>
Read metric data within a time window
Type Parameters
- S extends TableSchema
Parameters
- q: MetricQuery
Returns Promise<ColumnarTable<S>>
Implementation of IRelationalStore.readMetrics
- Defined in remote-relational-store.ts:135

rollbackToCheckpoint

rollbackToCheckpoint(_sid: string, cp: string): Promise<void>
Roll back to a previously set checkpoint
Parameters
- _sid: string
- cp: string
Returns Promise<void>
Implementation of IRelationalStore.rollbackToCheckpoint
- Defined in remote-relational-store.ts:145

saveCPT

saveCPT(gid: string, n: string, cpt: ConditionalProbabilityTable): Promise<void>
Save a conditional probability table for a Bayesian network node
Parameters
- gid: string
- n: string
- cpt: ConditionalProbabilityTable
Returns Promise<void>
Implementation of IRelationalStore.saveCPT
- Defined in remote-relational-store.ts:137

saveRCAResult

saveRCAResult(cid: string, r: RCAResult): Promise<void>
Persist an RCA analysis result
Parameters
- cid: string
- r: RCAResult
Returns Promise<void>
Implementation of IRelationalStore.saveRCAResult
- Defined in remote-relational-store.ts:141

saveRegressionModel

saveRegressionModel(gid: string, n: string, m: RegressionParams): Promise<void>
Save regression model parameters for HT-based RCA
Parameters
- gid: string
- n: string
- m: RegressionParams
Returns Promise<void>
Implementation of IRelationalStore.saveRegressionModel
- Defined in remote-relational-store.ts:139

setCheckpoint

setCheckpoint(sid: string, name: string): Promise<void>
Set a named checkpoint within the current transaction
Parameters
- sid: string
- name: string
Returns Promise<void>
Implementation of IRelationalStore.setCheckpoint
- Defined in remote-relational-store.ts:146

writeDetections

writeDetections(d: DetectionResult[]): Promise<void>
Persist anomaly detection results
Parameters
- d: DetectionResult[]
Returns Promise<void>
Implementation of IRelationalStore.writeDetections
- Defined in remote-relational-store.ts:136

Class RemoteRelationalStore

Implements

Index

Constructors

Methods

Constructors

constructor

Parameters

Returns RemoteRelationalStore

Methods

beginTransaction

Parameters

Returns Promise<void>

close

Returns Promise<void>

commitTransaction

Parameters

Returns Promise<void>

gracefulShutdown

Parameters

Returns Promise<void>

healthCheck

Returns Promise<boolean>

loadCPT

Parameters

Returns Promise<ConditionalProbabilityTable | null>

loadRegressionModel

Parameters

Returns Promise<RegressionParams | null>

queryHistoricalResults

Parameters

Returns Promise<RCAResult[]>

readMetrics

Type Parameters

Parameters

Returns Promise<ColumnarTable<S>>

rollbackToCheckpoint

Parameters

Returns Promise<void>

saveCPT

Parameters

Returns Promise<void>

saveRCAResult

Parameters

Returns Promise<void>

saveRegressionModel

Parameters

Returns Promise<void>

setCheckpoint

Parameters

Returns Promise<void>

writeDetections

Parameters

Returns Promise<void>

Settings

On This Page