org.xbib.elasticsearch.plugin.jdbc.state

Class RiverStateService

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent<RiverStateService>

org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService

All Implemented Interfaces:

org.elasticsearch.cluster.ClusterStateListener, org.elasticsearch.common.component.CloseableComponent, org.elasticsearch.common.component.LifecycleComponent<RiverStateService>

public class RiverStateService
extends org.elasticsearch.common.component.AbstractLifecycleComponent<RiverStateService>
implements org.elasticsearch.cluster.ClusterStateListener

The RiverStateService manages reading and writing of river states in the cluster state

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RiverStateService.DeleteRiverStateRequest
static class	RiverStateService.RiverStateRequest

Field Summary

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, settings

Constructor Summary

Constructors

Constructor and Description
RiverStateService(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.cluster.ClusterService clusterService)

Method Summary

Methods

Modifier and Type	Method and Description
void	clusterChanged(org.elasticsearch.cluster.ClusterChangedEvent event)
void	deleteRiverState(RiverStateService.DeleteRiverStateRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.cluster.ack.ClusterStateUpdateResponse> listener) Delete river from river state management
protected void	doClose()
protected void	doStart()
protected void	doStop()
void	postRiverState(RiverStateService.RiverStateRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.cluster.ack.ClusterStateUpdateResponse> listener) Post a new river for river state management
void	putRiverState(RiverStateService.RiverStateRequest request, org.elasticsearch.action.ActionListener<org.elasticsearch.cluster.ack.ClusterStateUpdateResponse> listener) Put a new river into river state management

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

RiverStateService

@Inject
public RiverStateService(org.elasticsearch.common.settings.Settings settings,
                        org.elasticsearch.cluster.ClusterService clusterService)

Method Detail

doStart

protected void doStart()
                throws org.elasticsearch.ElasticsearchException

Specified by:

doStart in class org.elasticsearch.common.component.AbstractLifecycleComponent<RiverStateService>

Throws:

org.elasticsearch.ElasticsearchException

doStop

protected void doStop()
               throws org.elasticsearch.ElasticsearchException

Specified by:

doStop in class org.elasticsearch.common.component.AbstractLifecycleComponent<RiverStateService>

Throws:

org.elasticsearch.ElasticsearchException

doClose

protected void doClose()
                throws org.elasticsearch.ElasticsearchException

Specified by:

doClose in class org.elasticsearch.common.component.AbstractLifecycleComponent<RiverStateService>

Throws:

org.elasticsearch.ElasticsearchException

clusterChanged

public void clusterChanged(org.elasticsearch.cluster.ClusterChangedEvent event)

Specified by:

clusterChanged in interface org.elasticsearch.cluster.ClusterStateListener

putRiverState

public void putRiverState(RiverStateService.RiverStateRequest request,
                 org.elasticsearch.action.ActionListener<org.elasticsearch.cluster.ack.ClusterStateUpdateResponse> listener)

Put a new river into river state management

Parameters:

request - a river state register request

listener - listener for cluster state update response

postRiverState

public void postRiverState(RiverStateService.RiverStateRequest request,
                  org.elasticsearch.action.ActionListener<org.elasticsearch.cluster.ack.ClusterStateUpdateResponse> listener)

Post a new river for river state management

Parameters:

request - a river state register request

listener - listener for cluster state update response

deleteRiverState

public void deleteRiverState(RiverStateService.DeleteRiverStateRequest request,
                    org.elasticsearch.action.ActionListener<org.elasticsearch.cluster.ack.ClusterStateUpdateResponse> listener)

Delete river from river state management

Parameters:

request - the unregister river state request

listener - listener for cluster state updates