Package dev.getelements.elements.rt.transact

Interface TaskIndex

All Known Implementing Classes:

UnixFSTaskIndex

public interface TaskIndex

Indexes all of the TransactionalTask instances in the datastore.

Method Summary

Modifier and Type	Method	Description
void	applyChange(ResourceId resourceId, String transactionId)	Applies task changes with the supplied ResourceId and transaction id.
void	cleanup(ResourceId resourceId, String transactionId)	Cleans up the task changes with the supplied ResourceId and transaction id.
Optional<TaskEntry<ResourceId>>	findTaskEntry(Supplier<TaskEntry.OperationalStrategy<ResourceId>> ctor, ResourceId resourceId)	Finds the TaskEntry<ResourceId> for the supplied ResourceId.
TaskEntry<ResourceId>	getOrCreateTaskEntry(Supplier<TaskEntry.OperationalStrategy<ResourceId>> ctor, ResourceId resourceId)	Gets the TaskEntry<ResourceId> for the supplied ResourceId.
Stream<Function<TaskEntry.OperationalStrategy<ResourceId>,TaskEntry<ResourceId>>>	listAllEntriesByResource()	Gets all entries in the TaskIndex.
default Stream<TransactionalTask>	listAllTasks()	lists all tasks in the TransactionalTask.

Method Details

listAllTasks

default Stream<TransactionalTask> listAllTasks()

lists all tasks in the TransactionalTask. The returned Stream should be closed when it is finished as it may consume IO resources.

Returns:

a listing of TransactionalTask

listAllEntriesByResource

Stream<Function<TaskEntry.OperationalStrategy<ResourceId>,TaskEntry<ResourceId>>> listAllEntriesByResource()

Gets all entries in the TaskIndex.

Returns:

all entries

findTaskEntry

Optional<TaskEntry<ResourceId>> findTaskEntry(Supplier<TaskEntry.OperationalStrategy<ResourceId>> ctor,
 ResourceId resourceId)

Finds the TaskEntry<ResourceId> for the supplied ResourceId.

Parameters:

ctor - the constructor fo the operational strategy

resourceId - the ResourceId

Returns:

the TaskEntry<ResourceId>

getOrCreateTaskEntry

TaskEntry<ResourceId> getOrCreateTaskEntry(Supplier<TaskEntry.OperationalStrategy<ResourceId>> ctor,
 ResourceId resourceId)

Gets the TaskEntry<ResourceId> for the supplied ResourceId.

Parameters:

ctor - the constructor fo the operational strategy

resourceId - the ResourceId

Returns:

the TaskEntry<ResourceId>

cleanup

void cleanup(ResourceId resourceId,
 String transactionId)

Cleans up the task changes with the supplied ResourceId and transaction id.

Parameters:

resourceId -

transactionId -

applyChange

void applyChange(ResourceId resourceId,
 String transactionId)

Applies task changes with the supplied ResourceId and transaction id.

Parameters:

resourceId -

transactionId -