Module org.elasticsearch.server

Package org.elasticsearch.repositories.blobstore

Class ShardSnapshotTaskRunner

java.lang.Object

org.elasticsearch.repositories.blobstore.ShardSnapshotTaskRunner

public class ShardSnapshotTaskRunner
extends Object

ShardSnapshotTaskRunner performs snapshotting tasks, prioritizing ShardSnapshotTaskRunner.ShardSnapshotTask over ShardSnapshotTaskRunner.FileSnapshotTask. Each enqueued shard to snapshot results in one ShardSnapshotTaskRunner.ShardSnapshotTask and zero or more ShardSnapshotTaskRunner.FileSnapshotTasks.

Constructor Summary

Constructors

Constructor	Description
ShardSnapshotTaskRunner(int maxRunningTasks, Executor executor, Consumer<SnapshotShardContext> shardSnapshotter, CheckedBiConsumer<SnapshotShardContext,BlobStoreIndexShardSnapshot.FileInfo,IOException> fileSnapshotter)

Method Summary

Modifier and Type	Method	Description
void	enqueueFileSnapshot(SnapshotShardContext context, Supplier<BlobStoreIndexShardSnapshot.FileInfo> fileInfos, ActionListener<Void> listener)
void	enqueueShardSnapshot(SnapshotShardContext context)

Methods inherited from class java.lang.Object

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

Constructor Details

ShardSnapshotTaskRunner

public ShardSnapshotTaskRunner(int maxRunningTasks,
 Executor executor,
 Consumer<SnapshotShardContext> shardSnapshotter,
 CheckedBiConsumer<SnapshotShardContext,BlobStoreIndexShardSnapshot.FileInfo,IOException> fileSnapshotter)

Method Details

enqueueShardSnapshot

public void enqueueShardSnapshot(SnapshotShardContext context)

enqueueFileSnapshot

public void enqueueFileSnapshot(SnapshotShardContext context,
 Supplier<BlobStoreIndexShardSnapshot.FileInfo> fileInfos,
 ActionListener<Void> listener)