Uses of Class
dev.getelements.elements.sdk.cluster.id.TaskId

Packages that use TaskId

Package	Description
dev.getelements.elements.rt
dev.getelements.elements.rt.exception
dev.getelements.elements.rt.transact
dev.getelements.elements.rt.transact.unix
dev.getelements.elements.sdk.cluster.id

Uses of TaskId in dev.getelements.elements.rt

Methods in dev.getelements.elements.rt that return TaskId

Modifier and Type	Method	Description
TaskId	ResultAcceptor.dispatch(Consumer<T> tConsumer, Consumer<Throwable> throwableTConsumer)	Calling calling this method completes the dispatch tho th underlying Resource's method and will place the response of the method call into the provided Consumer<T>.
TaskId	RetainedHandlerService.perform(Consumer<Object> success, Consumer<Throwable> failure, long timeoutDelay, TimeUnit timeoutUnit, String module, Attributes attributes, String method, Object... args)	Creates a new Resource using the attributes and the module.
TaskId	SimpleRetainedHandlerService.perform(Consumer<Object> success, Consumer<Throwable> failure, long timeout, TimeUnit timeoutUnit, String module, Attributes attributes, String method, Object... args)
TaskId	SimpleSingleUseHandlerService.perform(Consumer<Object> success, Consumer<Throwable> failure, long timeoutDelay, TimeUnit timeoutUnit, String module, Attributes attributes, String method, Object... args)
TaskId	SingleUseHandlerService.perform(Consumer<Object> success, Consumer<Throwable> failure, long timeoutDelay, TimeUnit timeoutUnit, String module, Attributes attributes, String method, Object... args)	Performs an operation against this SingleUseHandlerService, reporting either success or failure to the code.

Methods in dev.getelements.elements.rt that return types with arguments of type TaskId

Modifier and Type	Method	Description
Set<TaskId>	Resource.getTasks()	Gets a Set<TaskId> representing active tasks at the current state.

Methods in dev.getelements.elements.rt with parameters of type TaskId

Modifier and Type	Method	Description
boolean	SimpleTaskContext.finishWithError(TaskId taskId, Throwable error)
boolean	SimpleTaskService.finishWithError(TaskId taskId, Throwable error)
boolean	TaskContext.finishWithError(TaskId taskId, Throwable error)	Finishes the task with associated TaskId with the provided Throwable error.
boolean	TaskService.finishWithError(TaskId taskId, Throwable error)	Fails a task with the supplied Throwable, indicating an error.
boolean	SimpleTaskContext.finishWithResult(TaskId taskId, Object result)
boolean	SimpleTaskService.finishWithResult(TaskId taskId, Object result)
boolean	TaskContext.finishWithResult(TaskId taskId, Object result)	Finishes the task with associated TaskId with the provided result.
boolean	TaskService.finishWithResult(TaskId taskId, Object result)	Finishes a task with the supplied result.
void	SimpleTaskContext.register(TaskId taskId, Consumer<Object> consumer, Consumer<Throwable> throwableTConsumer)
void	SimpleTaskService.register(TaskId taskId, Consumer<Object> consumer, Consumer<Throwable> throwableTConsumer)
void	TaskContext.register(TaskId taskId, Consumer<Object> tConsumer, Consumer<Throwable> throwableTConsumer)	Registers the supplied TaskId, result Consumer, and Consumer<Throwable> for the associated task.
void	TaskService.register(TaskId taskId, Consumer<Object> consumer, Consumer<Throwable> throwableTConsumer)	Registers a new TaskId and set of consumers to handle the results.
void	Resource.resume(TaskId taskId, Object... results)	Resumes the supplied task with the TaskId and the list of results.
void	SchedulerContext.resume(TaskId taskId, Object... results)	Resumes the supplied task with the TaskId supplying multiple results to the destination.
void	SimpleSchedulerContext.resume(TaskId taskId, Object... results)
default void	Resource.resumeFromNetwork(TaskId taskId, Object result)	Resumes a suspended task, accepting the task id.
void	SchedulerContext.resumeFromNetwork(TaskId taskId, Object result)	Resumes a task that was waiting on a network call.
void	SimpleSchedulerContext.resumeFromNetwork(TaskId taskId, Object result)
default void	Resource.resumeFromScheduler(TaskId taskId, double elapsedTime)	Resumes a suspended task, accepting the task id.
default Future<Void>	Scheduler.resumeTask(TaskId taskId, Consumer<Throwable> failure)	Resumes the task associated with the supplied TaskId.
default Future<Void>	Scheduler.resumeTaskAfterDelay(TaskId taskId, long time, TimeUnit timeUnit, Runnable resumed, Consumer<Throwable> failure)	Resumes the task associated with the supplied TaskId.
void	SchedulerContext.resumeTaskAfterDelay(TaskId taskId, long time, TimeUnit timeUnit)	Resumes the task associated with the supplied TaskId.
void	SimpleSchedulerContext.resumeTaskAfterDelay(long time, TimeUnit timeUnit, TaskId taskId, Runnable resumed)
void	SimpleSchedulerContext.resumeTaskAfterDelay(TaskId taskId, long time, TimeUnit timeUnit)
default void	Resource.resumeWithError(TaskId taskId, Throwable throwable)	Resumes a suspended task, accepting the task id.
void	SchedulerContext.resumeWithError(TaskId taskId, Throwable throwable)	Resumes a task that was waiting for any reason.
void	SimpleSchedulerContext.resumeWithError(TaskId taskId, Throwable throwable)

Uses of TaskId in dev.getelements.elements.rt.exception

Methods in dev.getelements.elements.rt.exception that return TaskId

Modifier and Type	Method	Description
TaskId	DuplicateTaskException.getTaskId()
TaskId	NoSuchTaskException.getTaskId()
TaskId	TaskKilledException.getTaskId()

Constructors in dev.getelements.elements.rt.exception with parameters of type TaskId

Modifier	Constructor	Description
	DuplicateTaskException(TaskId taskId)
	NoSuchTaskException(TaskId taskId)
	TaskKilledException(TaskId taskId)

Uses of TaskId in dev.getelements.elements.rt.transact

Methods in dev.getelements.elements.rt.transact that return TaskId

Modifier and Type	Method	Description
TaskId	TransactionalTask.getTaskId()	Gets the TaskId.

Methods in dev.getelements.elements.rt.transact that return types with arguments of type TaskId

Modifier and Type	Method	Description
default Map<TaskId,TransactionalTask>	TaskEntry.OperationalStrategy.doGetTasksImmutable(TaskEntry<ScopeT> taskEntry)	Gets the TransactionalTasks associated with this entry.
Map<TaskId,TransactionalTask>	NullTaskEntry.getOriginalTasksImmutable()
Map<TaskId,TransactionalTask>	TaskEntry.getOriginalTasksImmutable()	Gets all of hte original tasks in this TaskEntry.
Set<TaskId>	TransactionalResource.getTasks()
Map<TaskId,TransactionalTask>	AbstractTaskEntry.getTasksImmutable()
Map<TaskId,TransactionalTask>	TaskEntry.getTasksImmutable()	Gets the tasks associated with this TaskEntry.

Methods in dev.getelements.elements.rt.transact with parameters of type TaskId

Modifier and Type	Method	Description
boolean	AbstractTaskEntry.addTask(TaskId taskId, long timestamp)
boolean	TaskEntry.addTask(TaskId taskId, long timestamp)	Adds a TaskId and timestamp to the TaskIndex.
void	ReadWriteTransaction.createTask(TaskId taskId, long timestamp)	Schedules the supplied TaskId to the supplied timestamp.
boolean	AbstractTaskEntry.deleteTask(TaskId taskId)
void	ReadWriteTransaction.deleteTask(TaskId taskId)	Deletes the TaskId from the datastore.
boolean	TaskEntry.deleteTask(TaskId taskId)	Deletes a TaskId and timestamp from this TaskIndex.
default boolean	TaskEntry.OperationalStrategy.doAddTask(TaskEntry<ScopeT> taskEntry, TaskId taskId, long timestamp)	Implements the add task operation.
default boolean	TaskEntry.OperationalStrategy.doDeleteTask(TaskEntry<ScopeT> taskEntry, TaskId taskId)	Deletes the task with the supplied TaskId.
void	TransactionalResource.resume(TaskId taskId, Object... results)
void	TransactionalSchedulerContext.resume(TaskId taskId, Object... results)
void	TransactionalResource.resumeFromNetwork(TaskId taskId, Object result)
void	TransactionalSchedulerContext.resumeFromNetwork(TaskId taskId, Object result)
void	TransactionalResource.resumeFromScheduler(TaskId taskId, double elapsedTime)
void	TransactionalSchedulerContext.resumeTaskAfterDelay(TaskId taskId, long time, TimeUnit timeUnit)
void	TransactionalResource.resumeWithError(TaskId taskId, Throwable throwable)
void	TransactionalSchedulerContext.resumeWithError(TaskId taskId, Throwable throwable)

Uses of TaskId in dev.getelements.elements.rt.transact.unix

Methods in dev.getelements.elements.rt.transact.unix that return TaskId

Modifier and Type	Method	Description
TaskId	UnixFSTask.getTaskId()

Methods in dev.getelements.elements.rt.transact.unix that return types with arguments of type TaskId

Modifier and Type	Method	Description
Map<TaskId,TransactionalTask>	UnixFSTaskEntryExisting.getOriginalTasksImmutable()
Map<TaskId,TransactionalTask>	UnixFSTaskEntryNew.getOriginalTasksImmutable()

Uses of TaskId in dev.getelements.elements.sdk.cluster.id

Methods in dev.getelements.elements.sdk.cluster.id that return TaskId

Modifier and Type	Method	Description
static TaskId	TaskId.taskIdFromByteBuffer(ByteBuffer byteBufferRepresentation, int byteBufferPosition)	Reads a TaskId from the supplied ByteBuffer and position, ensuring that the buffer's mark, limit, and position are unaffected.