Package org.bsc.langgraph4j.checkpoint

Class SQLiteSaver

java.lang.Object

org.bsc.langgraph4j.checkpoint.AbstractCheckpointSaver

org.bsc.langgraph4j.checkpoint.AbstractSQLiteSaver

org.bsc.langgraph4j.checkpoint.SQLiteSaver

All Implemented Interfaces:

BaseCheckpointSaver, LG4JLoggable

public class SQLiteSaver
extends AbstractSQLiteSaver

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SQLiteSaver.Builder

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

AbstractSQLiteSaver.AbstractBuilder<B extends AbstractSQLiteSaver.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.AbstractSQLiteSaver

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	SQLiteSaver(SQLiteSaver.Builder builder)

Method Summary

Modifier and Type	Method	Description
static SQLiteSaver.Builder	builder()
<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, Exception exception)
protected final String	sqlCommandsResourcePath()
protected final String	sqlInitResourcePath()
Optional<BaseCheckpointSaver.Tag>	tag(RunnableConfig config, Integer version)

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

datasource, decodeState, encodeState, exec, execTransaction, initTable, insertedCheckpoint, loadCheckpoints, requireNotBlank, sqlCommands, updatedCheckpoint

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

SQLiteSaver

protected SQLiteSaver(SQLiteSaver.Builder builder)
               throws Exception

Throws:

Exception

Method Details

builder

public static SQLiteSaver.Builder builder()

sqlCommandsResourcePath

protected final String sqlCommandsResourcePath()

Specified by:

sqlCommandsResourcePath in class AbstractSQLiteSaver

sqlInitResourcePath

protected final String sqlInitResourcePath()

Specified by:

sqlInitResourcePath in class AbstractSQLiteSaver

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,
 Exception 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

tag

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

Throws:

Exception