Package dev.getelements.elements.rt.transact.unix

Class UnixFSTaskIndex

java.lang.Object

dev.getelements.elements.rt.transact.unix.UnixFSTaskIndex

All Implemented Interfaces:

TaskIndex

public class UnixFSTaskIndex
extends Object
implements TaskIndex

Constructor Summary

Constructors

Constructor	Description
UnixFSTaskIndex()

Method Summary

Modifier and Type	Method	Description
List<Path>	allTasks()
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.
UnixFSUtils	getUnixFSUtils()
Stream<Function<TaskEntry.OperationalStrategy<ResourceId>,TaskEntry<ResourceId>>>	listAllEntriesByResource()	Gets all entries in the TaskIndex.
void	setUnixFSUtils(UnixFSUtils unixFSUtils)

Methods inherited from class java.lang.Object

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

Methods inherited from interface dev.getelements.elements.rt.transact.TaskIndex

listAllTasks

Constructor Details

UnixFSTaskIndex

public UnixFSTaskIndex()

Method Details

listAllEntriesByResource

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

Description copied from interface: TaskIndex

Gets all entries in the TaskIndex.

Specified by:

listAllEntriesByResource in interface TaskIndex

Returns:

all entries

allTasks

public List<Path> allTasks()
                    throws IOException

Throws:

IOException

findTaskEntry

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

Description copied from interface: TaskIndex

Finds the TaskEntry<ResourceId> for the supplied ResourceId.

Specified by:

findTaskEntry in interface TaskIndex

Parameters:

ctor - the constructor fo the operational strategy

resourceId - the ResourceId

Returns:

the TaskEntry<ResourceId>

getOrCreateTaskEntry

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

Description copied from interface: TaskIndex

Gets the TaskEntry<ResourceId> for the supplied ResourceId.

Specified by:

getOrCreateTaskEntry in interface TaskIndex

Parameters:

ctor - the constructor fo the operational strategy

resourceId - the ResourceId

Returns:

the TaskEntry<ResourceId>

cleanup

public void cleanup(ResourceId resourceId,
 String transactionId)

Description copied from interface: TaskIndex

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

Specified by:

cleanup in interface TaskIndex

Parameters:

resourceId -

transactionId -

applyChange

public void applyChange(ResourceId resourceId,
 String transactionId)

Description copied from interface: TaskIndex

Applies task changes with the supplied ResourceId and transaction id.

Specified by:

applyChange in interface TaskIndex

Parameters:

resourceId -

transactionId -

getUnixFSUtils

public UnixFSUtils getUnixFSUtils()

setUnixFSUtils

@Inject
public void setUnixFSUtils(UnixFSUtils unixFSUtils)