Package org.elasticsearch.action.support.replication

Class PendingReplicationActions

java.lang.Object

org.elasticsearch.action.support.replication.PendingReplicationActions

All Implemented Interfaces:

Closeable, AutoCloseable, Consumer<ReplicationGroup>, org.elasticsearch.core.Releasable

public class PendingReplicationActions
extends Object
implements Consumer<ReplicationGroup>, org.elasticsearch.core.Releasable

Constructor Summary

Constructors

Constructor	Description
PendingReplicationActions(ShardId shardId, ThreadPool threadPool)

Method Summary

Modifier and Type	Method	Description
void	accept(ReplicationGroup replicationGroup)
void	addPendingAction(String allocationId, RetryableAction<?> replicationAction)
void	close()
void	removeReplicationAction(String allocationId, RetryableAction<?> action)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Details

PendingReplicationActions

public PendingReplicationActions(ShardId shardId,
 ThreadPool threadPool)

Method Details

addPendingAction

public void addPendingAction(String allocationId,
 RetryableAction<?> replicationAction)

removeReplicationAction

public void removeReplicationAction(String allocationId,
 RetryableAction<?> action)

accept

public void accept(ReplicationGroup replicationGroup)

Specified by:

accept in interface Consumer<ReplicationGroup>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.elasticsearch.core.Releasable