Module org.elasticsearch.xcore
Package org.elasticsearch.license
Class LicensedAllocatedPersistentTask
java.lang.Object
org.elasticsearch.tasks.Task
org.elasticsearch.tasks.CancellableTask
org.elasticsearch.persistent.AllocatedPersistentTask
org.elasticsearch.license.LicensedAllocatedPersistentTask
- All Implemented Interfaces:
Traceable
An AllocatedPersistentTask which automatically tracks as a licensed feature usage.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.persistent.AllocatedPersistentTask
AllocatedPersistentTask.StateNested classes/interfaces inherited from class org.elasticsearch.tasks.CancellableTask
CancellableTask.CancellationListenerNested classes/interfaces inherited from class org.elasticsearch.tasks.Task
Task.Status -
Field Summary
Fields inherited from class org.elasticsearch.tasks.Task
APM_TRACE_CONTEXT, HEADERS_TO_COPY, TRACE_ID, TRACE_PARENT, TRACE_PARENT_HTTP_HEADER, TRACE_START_TIME, TRACE_STATE, X_ELASTIC_PRODUCT_ORIGIN_HTTP_HEADER, X_OPAQUE_ID_HTTP_HEADER -
Constructor Summary
ConstructorsConstructorDescriptionLicensedAllocatedPersistentTask(long id, String type, String action, String description, TaskId parentTask, Map<String, String> headers, LicensedFeature.Persistent feature, String featureContext, XPackLicenseState licenseState) -
Method Summary
Modifier and TypeMethodDescriptionprotected booleanprotected voidprotected voidprotected voiddoMarkAsLocallyAborted(String localAbortReason) final voidinit(PersistentTasksService persistentTasksService, TaskManager taskManager, String persistentTaskId, long allocationId) protected final booleanfinal voidfinal voidfinal voidmarkAsLocallyAborted(String localAbortReason) Methods inherited from class org.elasticsearch.persistent.AllocatedPersistentTask
getAllocationId, getFailure, getPersistentTaskId, getStatus, isCompleted, updatePersistentTaskState, waitForPersistentTaskMethods inherited from class org.elasticsearch.tasks.CancellableTask
addListener, ensureNotCancelled, getReasonCancelled, isCancelled, notifyIfCancelled, onCancelled, shouldCancelChildrenOnCancellation, toStringMethods inherited from class org.elasticsearch.tasks.Task
getAction, getDescription, getHeader, getId, getParentTaskId, getSpanId, getStartTime, getStartTimeNanos, getType, headers, result, result, taskInfo, taskInfo
-
Constructor Details
-
LicensedAllocatedPersistentTask
public LicensedAllocatedPersistentTask(long id, String type, String action, String description, TaskId parentTask, Map<String, String> headers, LicensedFeature.Persistent feature, String featureContext, XPackLicenseState licenseState)
-
-
Method Details
-
markAsCancelled
protected final boolean markAsCancelled()- Overrides:
markAsCancelledin classAllocatedPersistentTask
-
doMarkAsCancelled
protected boolean doMarkAsCancelled() -
markAsCompleted
public final void markAsCompleted()- Overrides:
markAsCompletedin classAllocatedPersistentTask
-
doMarkAsCompleted
protected void doMarkAsCompleted() -
markAsFailed
- Overrides:
markAsFailedin classAllocatedPersistentTask
-
doMarkAsFailed
-
markAsLocallyAborted
- Overrides:
markAsLocallyAbortedin classAllocatedPersistentTask
-
doMarkAsLocallyAborted
-
init
public final void init(PersistentTasksService persistentTasksService, TaskManager taskManager, String persistentTaskId, long allocationId) - Overrides:
initin classAllocatedPersistentTask
-