Package org.elasticsearch.index.seqno

Class RetentionLeaseSyncer

java.lang.Object

org.elasticsearch.index.seqno.RetentionLeaseSyncer

public class RetentionLeaseSyncer
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	RetentionLeaseSyncer.BackgroundSyncAction	Represents an action that is invoked periodically to sync retention leases to replica shards after some retention lease has been renewed or expired.
static interface	RetentionLeaseSyncer.SyncAction	Represents an action that is invoked to sync retention leases to replica shards after a retention lease is added or removed on the primary.

Field Summary

Fields

Modifier and Type	Field	Description
static RetentionLeaseSyncer	EMPTY

Constructor Summary

Constructors

Constructor	Description
RetentionLeaseSyncer(RetentionLeaseSyncAction syncAction, RetentionLeaseBackgroundSyncAction backgroundSyncAction)
RetentionLeaseSyncer(RetentionLeaseSyncer.SyncAction syncAction, RetentionLeaseSyncer.BackgroundSyncAction backgroundSyncAction)

Method Summary

Modifier and Type	Method	Description
void	backgroundSync(ShardId shardId, String primaryAllocationId, long primaryTerm, RetentionLeases retentionLeases)
void	sync(ShardId shardId, String primaryAllocationId, long primaryTerm, RetentionLeases retentionLeases, ActionListener<ReplicationResponse> listener)

Methods inherited from class java.lang.Object

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

Field Details

EMPTY

public static final RetentionLeaseSyncer EMPTY

Constructor Details

RetentionLeaseSyncer

@Inject
public RetentionLeaseSyncer(RetentionLeaseSyncAction syncAction,
 RetentionLeaseBackgroundSyncAction backgroundSyncAction)

RetentionLeaseSyncer

public RetentionLeaseSyncer(RetentionLeaseSyncer.SyncAction syncAction,
 RetentionLeaseSyncer.BackgroundSyncAction backgroundSyncAction)

Method Details

sync

public void sync(ShardId shardId,
 String primaryAllocationId,
 long primaryTerm,
 RetentionLeases retentionLeases,
 ActionListener<ReplicationResponse> listener)

backgroundSync

public void backgroundSync(ShardId shardId,
 String primaryAllocationId,
 long primaryTerm,
 RetentionLeases retentionLeases)