Package org.bsc.langgraph4j.checkpoint

Class PostgresSaver

java.lang.Object

org.bsc.langgraph4j.checkpoint.AbstractCheckpointSaver

org.bsc.langgraph4j.checkpoint.AbstractPostgresSaver

org.bsc.langgraph4j.checkpoint.PostgresSaver

All Implemented Interfaces:

BaseCheckpointSaver, LG4JLoggable

public class PostgresSaver
extends AbstractPostgresSaver

Postgres checkpoint saver.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PostgresSaver.Builder

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.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

Modifier	Constructor	Description
protected	PostgresSaver(PostgresSaver.Builder builder)

Method Summary

Modifier and Type	Method	Description
static PostgresSaver.Builder	builder()
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)
Optional<BaseCheckpointSaver.Tag>	tag(RunnableConfig config, Integer version)

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

decodeState, encoderStateSerializer, encodeState, exec, execTransaction, initTable, insertedCheckpoint, loadCheckpoints, sqlCommandsResourcePath, sqlInitResourcePath, 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

PostgresSaver

protected PostgresSaver(PostgresSaver.Builder builder)
                 throws Exception

Throws:

Exception

Method Details

builder

public static PostgresSaver.Builder builder()

insertCheckpoint

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

Specified by:

insertCheckpoint in class AbstractPostgresSaver

Throws:

Exception

tag

public Optional<BaseCheckpointSaver.Tag> tag(RunnableConfig config,
 Integer version)
                                      throws Exception

Throws:

Exception

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