org.apache.solr.cloud

Class OverseerConfigSetMessageHandler

java.lang.Object

org.apache.solr.cloud.OverseerConfigSetMessageHandler

All Implemented Interfaces:

OverseerMessageHandler

public class OverseerConfigSetMessageHandler
extends Object
implements OverseerMessageHandler

A OverseerMessageHandler that handles ConfigSets API related overseer messages.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.solr.cloud.OverseerMessageHandler

OverseerMessageHandler.ExclusiveMarking

Field Summary

Fields

Modifier and Type	Field and Description
static String	BASE_CONFIGSET Name of the ConfigSet to copy from for CREATE
static String	CONFIGSETS_ACTION_PREFIX Prefix to specify an action should be handled by this handler.
static String	PROPERTY_PREFIX Prefix for properties that should be applied to the ConfigSet for CREATE

Constructor Summary

Constructors

Constructor and Description
OverseerConfigSetMessageHandler(ZkStateReader zkStateReader)

Method Summary

Modifier and Type	Method and Description
OverseerMessageHandler.ExclusiveMarking	checkExclusiveMarking(String configSetName, ZkNodeProps message)
String	getName()
String	getTaskKey(ZkNodeProps message)
String	getTimerName(String operation)
void	markExclusiveTask(String configSetName, ZkNodeProps message)
SolrResponse	processMessage(ZkNodeProps message, String operation)
void	unmarkExclusiveTask(String configSetName, String operation, ZkNodeProps message)

Methods inherited from class java.lang.Object

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

Field Detail

CONFIGSETS_ACTION_PREFIX

public static final String CONFIGSETS_ACTION_PREFIX

Prefix to specify an action should be handled by this handler.

See Also:

Constant Field Values

BASE_CONFIGSET

public static final String BASE_CONFIGSET

Name of the ConfigSet to copy from for CREATE

See Also:

Constant Field Values

PROPERTY_PREFIX

public static final String PROPERTY_PREFIX

Prefix for properties that should be applied to the ConfigSet for CREATE

See Also:

Constant Field Values

Constructor Detail

OverseerConfigSetMessageHandler

public OverseerConfigSetMessageHandler(ZkStateReader zkStateReader)

Method Detail

processMessage

public SolrResponse processMessage(ZkNodeProps message,
                                   String operation)

Specified by:

processMessage in interface OverseerMessageHandler

Parameters:

message - the message to process

operation - the operation to process

Returns:

response

getName

public String getName()

Specified by:

getName in interface OverseerMessageHandler

Returns:

the name of the OverseerMessageHandler

getTimerName

public String getTimerName(String operation)

Specified by:

getTimerName in interface OverseerMessageHandler

Parameters:

operation - the operation to be timed

Returns:

the name of the timer to use for the operation

getTaskKey

public String getTaskKey(ZkNodeProps message)

Specified by:

getTaskKey in interface OverseerMessageHandler

Parameters:

message - the message being processed

Returns:

the taskKey for the message for handling task exclusivity

markExclusiveTask

public void markExclusiveTask(String configSetName,
                              ZkNodeProps message)

Specified by:

markExclusiveTask in interface OverseerMessageHandler

Parameters:

configSetName - the key associated with the task, cached from getTaskKey

message - the message being processed

unmarkExclusiveTask

public void unmarkExclusiveTask(String configSetName,
                                String operation,
                                ZkNodeProps message)

Specified by:

unmarkExclusiveTask in interface OverseerMessageHandler

Parameters:

configSetName - the key associated with the task

operation - the operation being processed

message - the message being processed

checkExclusiveMarking

public OverseerMessageHandler.ExclusiveMarking checkExclusiveMarking(String configSetName,
                                                                     ZkNodeProps message)

Specified by:

checkExclusiveMarking in interface OverseerMessageHandler

Parameters:

configSetName - the key associated with the task

message - the message being processed

Returns:

the exclusive marking