Package org.bsc.langgraph4j.checkpoint

Class FileSystemSaver

java.lang.Object

org.bsc.langgraph4j.checkpoint.MemorySaver

org.bsc.langgraph4j.checkpoint.FileSystemSaver

All Implemented Interfaces:

BaseCheckpointSaver

public class FileSystemSaver
extends MemorySaver

A CheckpointSaver that stores Checkpoints in the filesystem.

Each RunnableConfig is associated with a file in the provided targetFolder. The file is named "thread-threadId.saver" if the RunnableConfig has a threadId, or "thread-$default.saver" if it doesn't.

Constructor Summary

Constructors

Constructor	Description
FileSystemSaver(@NonNull Path targetFolder, @NonNull StateSerializer<? extends AgentState> stateSerializer)

Method Summary

Modifier and Type	Method	Description
boolean	clear(RunnableConfig config)	Clears the checkpoint file associated with the given RunnableConfig.
Optional<Checkpoint>	get(RunnableConfig config)
protected LinkedList<Checkpoint>	getCheckpoints(RunnableConfig config)
Collection<Checkpoint>	list(RunnableConfig config)
RunnableConfig	put(RunnableConfig config, Checkpoint checkpoint)

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

getLast

Methods inherited from class java.lang.Object

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

Constructor Details

FileSystemSaver

public FileSystemSaver(@NonNull
 @NonNull Path targetFolder,
 @NonNull
 @NonNull StateSerializer<? extends AgentState> stateSerializer)

Method Details

getCheckpoints

protected LinkedList<Checkpoint> getCheckpoints(RunnableConfig config)

Overrides:

getCheckpoints in class MemorySaver

clear

public boolean clear(RunnableConfig config)

Clears the checkpoint file associated with the given RunnableConfig.

Parameters:

config - the RunnableConfig for which the checkpoint file should be cleared

Returns:

true if the file existed and was successfully deleted, false otherwise

list

public Collection<Checkpoint> list(RunnableConfig config)

Specified by:

list in interface BaseCheckpointSaver

Overrides:

list in class MemorySaver

get

public Optional<Checkpoint> get(RunnableConfig config)

Specified by:

get in interface BaseCheckpointSaver

Overrides:

get in class MemorySaver

put

public RunnableConfig put(RunnableConfig config,
 Checkpoint checkpoint)
                   throws Exception

Specified by:

put in interface BaseCheckpointSaver

Overrides:

put in class MemorySaver

Throws:

Exception