Package org.elasticsearch.snapshots

Class SnapshotStressTestsHelper

java.lang.Object

org.elasticsearch.snapshots.SnapshotStressTestsHelper

public class SnapshotStressTestsHelper
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SnapshotStressTestsHelper.ReleasableClient	A client to a node that is blocked from restarting; close this Releasable to release the block.
static class	SnapshotStressTestsHelper.TrackedCluster	Test harness for snapshot stress tests.
static class	SnapshotStressTestsHelper.TrackedNode	Tracks a node in the cluster.
static class	SnapshotStressTestsHelper.TrackedSnapshot	Tracks a snapshot taken by the cluster.
static class	SnapshotStressTestsHelper.TransferableReleasables	Encapsulates a common pattern of trying to acquire a bunch of resources and then transferring ownership elsewhere on success, but releasing them on failure.

Constructor Summary

Constructors

Constructor	Description
SnapshotStressTestsHelper()

Method Summary

Modifier and Type	Method	Description
static void	logAndFailTest(Exception e)
static <T> ActionListener<T>	mustSucceed(org.elasticsearch.core.CheckedConsumer<T,Exception> consumer)
static AbstractRunnable	mustSucceed(org.elasticsearch.core.CheckedRunnable<Exception> runnable)
static Set<String>	nodeNames(Map<String,DiscoveryNode> nodesMap)
static ClusterHealthRequestBuilder	prepareClusterHealthRequest(String... targetIndexNames)
static String	stringFromSnapshotInfo(SnapshotInfo snapshotInfo)
static org.elasticsearch.core.Releasable	tryAcquireAllPermits(Semaphore permits)
static org.elasticsearch.core.Releasable	tryAcquirePermit(Semaphore permits)

Methods inherited from class java.lang.Object

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

Constructor Details

SnapshotStressTestsHelper

public SnapshotStressTestsHelper()

Method Details

nodeNames

public static Set<String> nodeNames(Map<String,DiscoveryNode> nodesMap)

tryAcquirePermit

@Nullable
public static org.elasticsearch.core.Releasable tryAcquirePermit(Semaphore permits)

tryAcquireAllPermits

@Nullable
public static org.elasticsearch.core.Releasable tryAcquireAllPermits(Semaphore permits)

mustSucceed

public static AbstractRunnable mustSucceed(org.elasticsearch.core.CheckedRunnable<Exception> runnable)

mustSucceed

public static <T> ActionListener<T> mustSucceed(org.elasticsearch.core.CheckedConsumer<T,Exception> consumer)

logAndFailTest

public static void logAndFailTest(Exception e)

prepareClusterHealthRequest

public static ClusterHealthRequestBuilder prepareClusterHealthRequest(String... targetIndexNames)

stringFromSnapshotInfo

public static String stringFromSnapshotInfo(SnapshotInfo snapshotInfo)