Package org.bsc.langgraph4j.checkpoint

Class SQLiteSaverV2Dashboard

java.lang.Object

org.bsc.langgraph4j.checkpoint.AbstractCheckpointSaver

org.bsc.langgraph4j.checkpoint.AbstractSQLiteSaver

org.bsc.langgraph4j.checkpoint.AbstractSQLiteSaverV2

org.bsc.langgraph4j.checkpoint.SQLiteSaverV2Dashboard

All Implemented Interfaces:

BaseCheckpointSaver, LG4JLoggable

public class SQLiteSaverV2Dashboard
extends AbstractSQLiteSaverV2

Nested Class Summary

Nested Classes

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

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

THREAD_ROW_ID

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

Constructor	Description
SQLiteSaverV2Dashboard(SQLiteSaverV2Dashboard.Builder builder)

Method Summary

Modifier and Type	Method	Description
static SQLiteSaverV2Dashboard.Builder	builder()
protected void	initTable(boolean dropTablesFirst, boolean createTables)
<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)
List<SQLiteSaverV2Dashboard.TagRecord>	selectAllTags()
List<SQLiteSaverV2Dashboard.ThreadRecord>	selectAllThreads()
protected String	sqlCommandsResourcePath()
protected String	sqlInitResourcePath()

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

addThreadRowId, tag

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

datasource, decodeState, encodeState, exec, execTransaction, 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

SQLiteSaverV2Dashboard

public SQLiteSaverV2Dashboard(SQLiteSaverV2Dashboard.Builder builder)
                       throws Exception

Throws:

Exception

Method Details

builder

public static SQLiteSaverV2Dashboard.Builder builder()

sqlCommandsResourcePath

protected String sqlCommandsResourcePath()

Specified by:

sqlCommandsResourcePath in class AbstractSQLiteSaver

selectAllThreads

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

Throws:

Exception

selectAllTags

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

Throws:

Exception

sqlInitResourcePath

protected 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

initTable

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

Overrides:

initTable in class AbstractSQLiteSaver

Throws:

Exception