Package dev.tachyonmcp.core.server.features.tasks

Class DefaultTaskRegistry

java.lang.Object

dev.tachyonmcp.core.server.features.AbstractRegistry<TaskDescriptor,TaskEntry>

dev.tachyonmcp.core.server.features.tasks.DefaultTaskRegistry

All Implemented Interfaces:

Tasks, TaskRegistry

@InternalApi
public class DefaultTaskRegistry
extends AbstractRegistry<TaskDescriptor,TaskEntry>
implements TaskRegistry

Constructor Summary

Constructors

Constructor	Description
DefaultTaskRegistry(ServerEngine server, TasksConfig config)

Method Summary

Modifier and Type	Method	Description
void	add(TaskEntry entry)
boolean	cancelTask(String taskId)
boolean	completeTask(String taskId, @Nullable String resultJson)
Task	create()
Task	create(TaskOptions options)
TaskEntry	createSessionTask(@Nullable Duration ttl, @Nullable Map<String,Object> meta, @Nullable String sessionId, @Nullable ProgressToken progressToken)
boolean	failTask(String taskId, @Nullable String resultJson)
@Nullable TaskEntry	getAndCancelTask(String taskId)
@Nullable TaskEntry	getById(String taskId)
void	registerRunning(String taskId, Future<?> future)
boolean	remove(String taskId)	Removes a task from the registry, e.g. because it was removed on the caller's side.
void	startTtlJanitor()
void	stopTtlJanitor()
void	unregisterRunning(String taskId)
boolean	updateStatus(String taskId, TaskState newStatus, @Nullable String statusMessage)

Methods inherited from class dev.tachyonmcp.core.server.features.AbstractRegistry

addItem, addItemIfAbsent, defaultPageSize, fireOnChange, get, getAll, isEmpty, list, list, listItems, onChange, removeItem

Methods inherited from class java.lang.Object

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

Methods inherited from interface dev.tachyonmcp.api.server.features.tasks.Tasks

get

Constructor Details

DefaultTaskRegistry

public DefaultTaskRegistry(ServerEngine server,
 TasksConfig config)

Method Details

getById

public @Nullable TaskEntry getById(String taskId)

Specified by:

getById in interface TaskRegistry

add

public void add(TaskEntry entry)

Specified by:

add in interface TaskRegistry

remove

public boolean remove(String taskId)

Description copied from interface: Tasks

Removes a task from the registry, e.g. because it was removed on the caller's side. A non-terminal task is cancelled first (firing a final status notification) so its Task.completion() doesn't hang forever.

Specified by:

remove in interface Tasks

Returns:

true if a task with this id existed and was removed

create

public Task create()

Specified by:

create in interface Tasks

create

public Task create(TaskOptions options)

Specified by:

create in interface Tasks

createSessionTask

public TaskEntry createSessionTask(@Nullable Duration ttl,
 @Nullable Map<String,Object> meta,
 @Nullable String sessionId,
 @Nullable ProgressToken progressToken)

Specified by:

createSessionTask in interface TaskRegistry

registerRunning

public void registerRunning(String taskId,
 Future<?> future)

Specified by:

registerRunning in interface TaskRegistry

unregisterRunning

public void unregisterRunning(String taskId)

Specified by:

unregisterRunning in interface TaskRegistry

completeTask

public boolean completeTask(String taskId,
 @Nullable String resultJson)

failTask

public boolean failTask(String taskId,
 @Nullable String resultJson)

cancelTask

public boolean cancelTask(String taskId)

getAndCancelTask

public @Nullable TaskEntry getAndCancelTask(String taskId)

updateStatus

public boolean updateStatus(String taskId,
 TaskState newStatus,
 @Nullable String statusMessage)

Specified by:

updateStatus in interface TaskRegistry

startTtlJanitor

public void startTtlJanitor()

stopTtlJanitor

public void stopTtlJanitor()