Interface TaskAwareRequest

All Known Implementing Classes:
AbstractBulkByScrollRequest, AbstractBulkIndexByScrollRequest, AcknowledgedRequest, ActionRequest, AddIndexBlockRequest, AddVotingConfigExclusionsRequest, AnalyzeAction.Request, AnalyzeIndexDiskUsageRequest, ApplyCommitRequest, BaseNodeRequest, BaseNodesRequest, BaseTasksRequest, BasicReplicationRequest, BroadcastRequest, BroadcastShardRequest, BulkRequest, BulkShardRequest, BytesTransportRequest, CancelTasksRequest, CanMatchNodeRequest, CleanupRepositoryRequest, ClearIndicesCacheRequest, ClearScrollRequest, ClearVotingConfigExclusionsRequest, CloneSnapshotRequest, CloseIndexRequest, ClosePointInTimeRequest, ClusterAllocationExplainRequest, ClusterGetSettingsRequest, ClusterHealthRequest, ClusterInfoRequest, ClusterRerouteRequest, ClusterSearchShardsRequest, ClusterStateRequest, ClusterStatsRequest, ClusterUpdateSettingsRequest, CompletionPersistentTaskAction.Request, CreateIndexRequest, CreateSnapshotRequest, DeleteByQueryRequest, DeleteComponentTemplateAction.Request, DeleteComposableIndexTemplateAction.Request, DeleteDanglingIndexRequest, DeleteIndexRequest, DeleteIndexTemplateRequest, DeletePipelineRequest, DeleteRepositoryRequest, DeleteRequest, DeleteSnapshotRequest, DeleteStoredScriptRequest, ExplainRequest, FieldCapabilitiesIndexRequest, FieldCapabilitiesRequest, FieldUsageShardRequest, FieldUsageStatsRequest, FindDanglingIndexRequest, FlushRequest, FollowersChecker.FollowerCheckRequest, ForceMergeRequest, GetAliasesRequest, GetComponentTemplateAction.Request, GetComposableIndexTemplateAction.Request, GetFeatureUpgradeStatusRequest, GetFieldMappingsIndexRequest, GetFieldMappingsRequest, GetIndexRequest, GetIndexTemplatesRequest, GetMappingsRequest, GetPipelineRequest, GetRepositoriesRequest, GetRequest, GetScriptContextRequest, GetScriptLanguageRequest, GetSettingsRequest, GetShardSnapshotRequest, GetSnapshotsRequest, GetSnapshottableFeaturesRequest, GetStoredScriptRequest, GetTaskRequest, GlobalCheckpointSyncAction.Request, ImportDanglingIndexRequest, IndexRequest, IndicesAliasesRequest, IndicesExistsRequest, IndicesSegmentsRequest, IndicesShardStoresRequest, IndicesStatsRequest, InstanceShardOperationRequest, InternalScrollSearchRequest, JoinRequest, ListDanglingIndicesRequest, ListTasksRequest, LivenessRequest, LocalAllocateDangledIndices.AllocateDangledRequest, MainRequest, MasterFaultDetection.MasterPingRequest, MasterNodeReadRequest, MasterNodeRequest, MembershipAction.JoinRequest, MembershipAction.LeaveRequest, ModifyDataStreamsAction.Request, MultiGetRequest, MultiGetShardRequest, MultiSearchRequest, MultiTermVectorsRequest, MultiTermVectorsShardRequest, NodeFindDanglingIndexRequest, NodeListDanglingIndicesRequest, NodesFaultDetection.PingRequest, NodesHotThreadsRequest, NodesInfoRequest, NodesReloadSecureSettingsRequest, NodesStatsRequest, NodesUsageRequest, OpenIndexRequest, OpenPointInTimeRequest, PeersRequest, PendingClusterTasksRequest, PostFeatureUpgradeRequest, PreVoteRequest, PrimaryReplicaSyncer.ResyncRequest, PublishClusterStateAction.CommitClusterStateRequest, PutComponentTemplateAction.Request, PutComposableIndexTemplateAction.Request, PutIndexTemplateRequest, PutMappingRequest, PutPipelineRequest, PutRepositoryRequest, PutStoredScriptRequest, QuerySearchRequest, RecoveryCleanFilesRequest, RecoveryFileChunkRequest, RecoveryFilesInfoRequest, RecoveryRequest, RecoverySnapshotFileRequest, RecoveryTranslogOperationsRequest, RecoveryTransportRequest, ReestablishRecoveryRequest, RefreshRequest, ReindexRequest, RemoteInfoRequest, RemovePersistentTaskAction.Request, ReplicatedWriteRequest, ReplicationRequest, ResetFeatureStateRequest, ResizeRequest, ResolveIndexAction.Request, RestoreSnapshotRequest, ResyncReplicationRequest, RetentionLeaseActions.AddRequest, RetentionLeaseActions.RemoveRequest, RetentionLeaseActions.RenewRequest, RetentionLeaseBackgroundSyncAction.Request, RetentionLeaseSyncAction.Request, RolloverRequest, SearchRequest, SearchScrollRequest, ShardFetchRequest, ShardFetchSearchRequest, ShardFlushRequest, ShardSearchRequest, ShardStateAction.FailedShardEntry, ShardStateAction.StartedShardEntry, ShardUpgradeRequest, ShardValidateQueryRequest, SimulateIndexTemplateRequest, SimulatePipelineRequest, SimulateTemplateAction.Request, SingleShardRequest, SnapshotsStatusRequest, StartJoinRequest, StartPersistentTaskAction.Request, StartRecoveryRequest, SyncedFlushRequest, SyncedFlushService.InFlightOpsRequest, SyncedFlushService.PreShardSyncedFlushRequest, SyncedFlushService.ShardSyncedFlushRequest, TermVectorsRequest, TransportBroadcastByNodeAction.NodeRequest, TransportClusterStatsAction.ClusterStatsNodeRequest, TransportNodesHotThreadsAction.NodeRequest, TransportNodesInfoAction.NodeInfoRequest, TransportNodesListGatewayMetaState.NodeRequest, TransportNodesListGatewayMetaState.Request, TransportNodesListGatewayStartedShards.NodeRequest, TransportNodesListGatewayStartedShards.Request, TransportNodesListShardStoreMetadata.NodeRequest, TransportNodesListShardStoreMetadata.Request, TransportNodesReloadSecureSettingsAction.NodeRequest, TransportNodesSnapshotsStatus.NodeRequest, TransportNodesSnapshotsStatus.Request, TransportNodesStatsAction.NodeStatsRequest, TransportNodesUsageAction.NodeUsageRequest, TransportReplicationAction.ConcreteReplicaRequest, TransportReplicationAction.ConcreteShardRequest, TransportRequest, TransportRequest.Empty, TransportVerifyShardBeforeCloseAction.ShardRequest, TransportVerifyShardIndexBlockAction.ShardRequest, TypesExistsRequest, UnicastZenPing.UnicastPingRequest, UpdateByQueryRequest, UpdateIndexShardSnapshotStatusRequest, UpdatePersistentTaskStatusAction.Request, UpdateRequest, UpdateSettingsRequest, UpgradeRequest, UpgradeSettingsRequest, UpgradeStatusRequest, ValidateJoinRequest, ValidateQueryRequest, VerifyNodeRepositoryAction.VerifyNodeRepositoryRequest, VerifyRepositoryRequest, ZenDiscovery.RejoinClusterRequest

public interface TaskAwareRequest
An interface for a request that can be used to register a task manager task
  • Method Summary

    Modifier and Type
    Method
    Description
    default Task
    createTask(long id, String type, String action, TaskId parentTaskId, Map<String,String> headers)
    Returns the task object that should be used to keep track of the processing of the request.
    default String
    Returns optional description of the request to be displayed by the task manager
    Get a reference to the task that created this request.
    default void
    setParentTask(String parentTaskNode, long parentTaskId)
    Set a reference to task that caused this task to be run.
    void
    Set a reference to task that created this request.
  • Method Details

    • setParentTask

      default void setParentTask(String parentTaskNode, long parentTaskId)
      Set a reference to task that caused this task to be run.
    • setParentTask

      void setParentTask(TaskId taskId)
      Set a reference to task that created this request.
    • getParentTask

      TaskId getParentTask()
      Get a reference to the task that created this request. Implementers should default to TaskId.EMPTY_TASK_ID, meaning "there is no parent".
    • createTask

      default Task createTask(long id, String type, String action, TaskId parentTaskId, Map<String,String> headers)
      Returns the task object that should be used to keep track of the processing of the request.
    • getDescription

      default String getDescription()
      Returns optional description of the request to be displayed by the task manager