Package org.bsc.langgraph4j.checkpoint

Class PostgresSaverV2Dashboard

java.lang.Object

org.bsc.langgraph4j.checkpoint.AbstractCheckpointSaver

org.bsc.langgraph4j.checkpoint.AbstractPostgresSaver

org.bsc.langgraph4j.checkpoint.AbstractPostgresSaverV2

org.bsc.langgraph4j.checkpoint.PostgresSaverV2Dashboard

All Implemented Interfaces:

BaseCheckpointSaver, LG4JLoggable

public class PostgresSaverV2Dashboard
extends AbstractPostgresSaverV2

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PostgresSaverV2Dashboard.Builder
static final record	PostgresSaverV2Dashboard.TagRecord
static final record	PostgresSaverV2Dashboard.ThreadRecord

Nested classes/interfaces inherited from class org.bsc.langgraph4j.checkpoint.AbstractPostgresSaver

AbstractPostgresSaver.AbstractBuilder<B extends AbstractPostgresSaver.AbstractBuilder<B>>

Nested classes/interfaces inherited from interface org.bsc.langgraph4j.checkpoint.BaseCheckpointSaver

BaseCheckpointSaver.SubGraphSaver, BaseCheckpointSaver.Tag

Field Summary

Fields inherited from class org.bsc.langgraph4j.checkpoint.AbstractPostgresSaverV2

POSTGRES_THREAD_ROW_ID

Fields inherited from class org.bsc.langgraph4j.checkpoint.AbstractPostgresSaver

datasource, sqlCommands

Fields inherited from interface org.bsc.langgraph4j.checkpoint.BaseCheckpointSaver

THREAD_ID_DEFAULT

Fields inherited from interface org.bsc.langgraph4j.LG4JLoggable

log

Constructor Summary

Constructors

Constructor	Description
PostgresSaverV2Dashboard(PostgresSaverV2Dashboard.Builder builder)

Method Summary

Modifier and Type	Method	Description
static PostgresSaverV2Dashboard.Builder	builder()
protected void	initTable(boolean dropTablesFirst, boolean createTables)
protected void	insertCheckpoint(Connection conn, RunnableConfig config, LinkedList<Checkpoint> checkpoints, Checkpoint checkpoint)
<State extends AgentState> CompletableFuture<InterruptionMetadata<State>>	registerInterruption(RunnableConfig config, InterruptionMetadata<State> interruptionMetadata)	Register Interrupt of the execution for the given config and provide interruption metadata.
protected BaseCheckpointSaver.Tag	releaseCheckpoints(RunnableConfig config, LinkedList<Checkpoint> checkpoints, @Nullable String message)
protected BaseCheckpointSaver.Tag	releaseCheckpointsOnError(RunnableConfig config, LinkedList<Checkpoint> checkpoints, Throwable exception)
List<PostgresSaverV2Dashboard.TagRecord>	selectAllTags()
List<PostgresSaverV2Dashboard.ThreadRecord>	selectAllThreads()
protected String	sqlCommandsResourcePath()
protected String	sqlInitResourcePath()

Methods inherited from class org.bsc.langgraph4j.checkpoint.AbstractPostgresSaverV2

addThreadRowId, tag

Methods inherited from class org.bsc.langgraph4j.checkpoint.AbstractPostgresSaver

decodeState, encoderStateSerializer, encodeState, exec, execTransaction, insertedCheckpoint, loadCheckpoints, updatedCheckpoint, updatedCheckpoint2

Methods inherited from class org.bsc.langgraph4j.checkpoint.AbstractCheckpointSaver

get, list, listSubGraphSaver, put, putSubGraphSaver, release, release, releaseOnError

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.bsc.langgraph4j.checkpoint.BaseCheckpointSaver

lastTag, threadId

Constructor Details

PostgresSaverV2Dashboard

public PostgresSaverV2Dashboard(PostgresSaverV2Dashboard.Builder builder)
                         throws Exception

Throws:

Exception

Method Details

builder

public static PostgresSaverV2Dashboard.Builder builder()

sqlCommandsResourcePath

protected String sqlCommandsResourcePath()

Overrides:

sqlCommandsResourcePath in class AbstractPostgresSaver

selectAllThreads

public List<PostgresSaverV2Dashboard.ThreadRecord> selectAllThreads()
                                                             throws Exception

Throws:

Exception

selectAllTags

public List<PostgresSaverV2Dashboard.TagRecord> selectAllTags()
                                                       throws Exception

Throws:

Exception

sqlInitResourcePath

protected String sqlInitResourcePath()

Overrides:

sqlInitResourcePath in class AbstractPostgresSaver

releaseCheckpoints

protected BaseCheckpointSaver.Tag releaseCheckpoints(RunnableConfig config,
 LinkedList<Checkpoint> checkpoints,
 @Nullable String message)
                                              throws Exception

Specified by:

releaseCheckpoints in class AbstractCheckpointSaver

Throws:

Exception

releaseCheckpointsOnError

protected BaseCheckpointSaver.Tag releaseCheckpointsOnError(RunnableConfig config,
 LinkedList<Checkpoint> checkpoints,
 Throwable exception)
                                                     throws Exception

Specified by:

releaseCheckpointsOnError in class AbstractCheckpointSaver

Throws:

Exception

registerInterruption

public <State extends AgentState>
CompletableFuture<InterruptionMetadata<State>> registerInterruption(RunnableConfig config,
 InterruptionMetadata<State> interruptionMetadata)

Description copied from interface: BaseCheckpointSaver

Register Interrupt of the execution for the given config and provide interruption metadata. this is used internally and should not be called directly by the user.

Parameters:

config - the RunnableConfig for which to register the interruption

interruptionMetadata - the metadata associated with the interruption

initTable

protected void initTable(boolean dropTablesFirst,
 boolean createTables)
                  throws Exception

Overrides:

initTable in class AbstractPostgresSaver

Throws:

Exception

insertCheckpoint

protected void insertCheckpoint(Connection conn,
 RunnableConfig config,
 LinkedList<Checkpoint> checkpoints,
 Checkpoint checkpoint)
                         throws Exception

Specified by:

insertCheckpoint in class AbstractPostgresSaver

Throws:

Exception