Module org.elasticsearch.server

Package org.elasticsearch.cluster.block

Class ClusterBlocks

java.lang.Object

org.elasticsearch.cluster.block.ClusterBlocks

All Implemented Interfaces:

Diffable<ClusterBlocks>, SimpleDiffable<ClusterBlocks>, Writeable

public class ClusterBlocks
extends Object
implements SimpleDiffable<ClusterBlocks>

Represents current cluster level blocks to block dirty operations done against the cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ClusterBlocks.Builder

Nested classes/interfaces inherited from interface org.elasticsearch.cluster.SimpleDiffable

SimpleDiffable.CompleteDiff<T extends Diffable<T>>

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields

Modifier and Type	Field	Description
static final ClusterBlocks	EMPTY_CLUSTER_BLOCK

Fields inherited from interface org.elasticsearch.cluster.SimpleDiffable

EMPTY

Method Summary

Modifier and Type	Method	Description
static ClusterBlocks.Builder	builder()
static ClusterBlocks.Builder	builder(ClusterBlocks blocks)	Convenience method, equivalent to: builder().blocks(blocks)
boolean	disableStatePersistence()	Returns true if one of the global blocks as its disable state persistence flag set.
ClusterBlock	getIndexBlockWithId(String index, int blockId)
Set<ClusterBlock>	global()
Set<ClusterBlock>	global(ClusterBlockLevel level)
ClusterBlockException	globalBlockedException(ClusterBlockLevel level)
void	globalBlockedRaiseException(ClusterBlockLevel level)
boolean	hasGlobalBlock(ClusterBlock block)
boolean	hasGlobalBlockWithId(int blockId)
boolean	hasGlobalBlockWithLevel(ClusterBlockLevel level)
boolean	hasGlobalBlockWithStatus(RestStatus status)	Is there a global block with the provided status?
boolean	hasIndexBlock(String index, ClusterBlock block)
boolean	hasIndexBlockWithId(String index, int blockId)
boolean	indexBlocked(ClusterBlockLevel level, String index)
ClusterBlockException	indexBlockedException(ClusterBlockLevel level, String index)
void	indexBlockedRaiseException(ClusterBlockLevel level, String index)
Map<String,Set<ClusterBlock>>	indices()
Map<String,Set<ClusterBlock>>	indices(ClusterBlockLevel level)
ClusterBlockException	indicesAllowReleaseResources(String[] indices)	Returns true iff non of the given have a ClusterBlockLevel.METADATA_WRITE in place where the ClusterBlock.isAllowReleaseResources() returns false.
ClusterBlockException	indicesBlockedException(ClusterBlockLevel level, String[] indices)
static Diff<ClusterBlocks>	readDiffFrom(StreamInput in)
static ClusterBlocks	readFrom(StreamInput in)
String	toString()
void	writeTo(StreamOutput out)	Write this into the StreamOutput.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.cluster.SimpleDiffable

diff

Field Details

EMPTY_CLUSTER_BLOCK

public static final ClusterBlocks EMPTY_CLUSTER_BLOCK

Method Details

global

public Set<ClusterBlock> global()

indices

public Map<String,Set<ClusterBlock>> indices()

global

public Set<ClusterBlock> global(ClusterBlockLevel level)

indices

public Map<String,Set<ClusterBlock>> indices(ClusterBlockLevel level)

disableStatePersistence

public boolean disableStatePersistence()

Returns true if one of the global blocks as its disable state persistence flag set.

hasGlobalBlock

public boolean hasGlobalBlock(ClusterBlock block)

hasGlobalBlockWithId

public boolean hasGlobalBlockWithId(int blockId)

hasGlobalBlockWithLevel

public boolean hasGlobalBlockWithLevel(ClusterBlockLevel level)

hasGlobalBlockWithStatus

public boolean hasGlobalBlockWithStatus(RestStatus status)

Is there a global block with the provided status?

hasIndexBlock

public boolean hasIndexBlock(String index,
 ClusterBlock block)

hasIndexBlockWithId

public boolean hasIndexBlockWithId(String index,
 int blockId)

getIndexBlockWithId

@Nullable
public ClusterBlock getIndexBlockWithId(String index,
 int blockId)

globalBlockedRaiseException

public void globalBlockedRaiseException(ClusterBlockLevel level)
                                 throws ClusterBlockException

Throws:

ClusterBlockException

globalBlockedException

public ClusterBlockException globalBlockedException(ClusterBlockLevel level)

indexBlockedRaiseException

public void indexBlockedRaiseException(ClusterBlockLevel level,
 String index)
                                throws ClusterBlockException

Throws:

ClusterBlockException

indexBlockedException

public ClusterBlockException indexBlockedException(ClusterBlockLevel level,
 String index)

indexBlocked

public boolean indexBlocked(ClusterBlockLevel level,
 String index)

indicesBlockedException

public ClusterBlockException indicesBlockedException(ClusterBlockLevel level,
 String[] indices)

indicesAllowReleaseResources

public ClusterBlockException indicesAllowReleaseResources(String[] indices)

Returns true iff non of the given have a ClusterBlockLevel.METADATA_WRITE in place where the ClusterBlock.isAllowReleaseResources() returns false. This is used in places where resources will be released like the deletion of an index to free up resources on nodes.

Parameters:

indices - the indices to check

toString

public String toString()

Overrides:

toString in class Object

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Description copied from interface: Writeable

Write this into the StreamOutput.

Specified by:

writeTo in interface Writeable

Throws:

IOException

readFrom

public static ClusterBlocks readFrom(StreamInput in)
                              throws IOException

Throws:

IOException

readDiffFrom

public static Diff<ClusterBlocks> readDiffFrom(StreamInput in)
                                        throws IOException

Throws:

IOException

builder

public static ClusterBlocks.Builder builder()

builder

public static ClusterBlocks.Builder builder(ClusterBlocks blocks)

Convenience method, equivalent to: builder().blocks(blocks)