org.elasticsearch.index.shard

Class PrimaryReplicaSyncer

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.index.shard.PrimaryReplicaSyncer

public class PrimaryReplicaSyncer
extends AbstractComponent

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PrimaryReplicaSyncer.ResyncRequest
static class	PrimaryReplicaSyncer.ResyncTask
static interface	PrimaryReplicaSyncer.SyncAction

Field Summary

Fields

Modifier and Type	Field and Description
static ByteSizeValue	DEFAULT_CHUNK_SIZE

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor and Description
PrimaryReplicaSyncer(Settings settings, TaskManager taskManager, PrimaryReplicaSyncer.SyncAction syncAction)
PrimaryReplicaSyncer(Settings settings, TransportService transportService, TransportResyncReplicationAction syncAction)

Method Summary

Modifier and Type	Method and Description
void	resync(IndexShard indexShard, ActionListener<PrimaryReplicaSyncer.ResyncTask> listener)

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CHUNK_SIZE

public static final ByteSizeValue DEFAULT_CHUNK_SIZE

Constructor Detail

PrimaryReplicaSyncer

@Inject
public PrimaryReplicaSyncer(Settings settings,
                                    TransportService transportService,
                                    TransportResyncReplicationAction syncAction)

PrimaryReplicaSyncer

public PrimaryReplicaSyncer(Settings settings,
                            TaskManager taskManager,
                            PrimaryReplicaSyncer.SyncAction syncAction)

Method Detail

resync

public void resync(IndexShard indexShard,
                   ActionListener<PrimaryReplicaSyncer.ResyncTask> listener)