Package com.floragunn.signals.watch.state

Class WatchStateIndexWriter

java.lang.Object

com.floragunn.signals.watch.state.WatchStateIndexWriter

All Implemented Interfaces:

WatchStateWriter<org.elasticsearch.action.index.IndexResponse>

public class WatchStateIndexWriter
extends Object
implements WatchStateWriter<org.elasticsearch.action.index.IndexResponse>

Constructor Summary

Constructors

Constructor	Description
WatchStateIndexWriter(String watchIdPrefix, String indexName, org.elasticsearch.client.Client client)

Method Summary

Modifier and Type	Method	Description
void	put(String watchId, WatchState watchState)
void	put(String watchId, WatchState watchState, org.elasticsearch.action.ActionListener<org.elasticsearch.action.index.IndexResponse> actionListener)
void	putAll(Map<String,WatchState> idToStateMap)
void	putIfAbsent(String watchId, WatchState watchState)
void	putIfAbsent(String watchId, WatchState watchState, org.elasticsearch.action.ActionListener<org.elasticsearch.action.index.IndexResponse> actionListener)

Methods inherited from class java.lang.Object

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

Constructor Detail

WatchStateIndexWriter

public WatchStateIndexWriter(String watchIdPrefix,
                             String indexName,
                             org.elasticsearch.client.Client client)

Method Detail

put

public void put(String watchId,
                WatchState watchState)

Specified by:

put in interface WatchStateWriter<org.elasticsearch.action.index.IndexResponse>

put

public void put(String watchId,
                WatchState watchState,
                org.elasticsearch.action.ActionListener<org.elasticsearch.action.index.IndexResponse> actionListener)

Specified by:

put in interface WatchStateWriter<org.elasticsearch.action.index.IndexResponse>

putAll

public void putAll(Map<String,WatchState> idToStateMap)

Specified by:

putAll in interface WatchStateWriter<org.elasticsearch.action.index.IndexResponse>

putIfAbsent

public void putIfAbsent(String watchId,
                        WatchState watchState)

putIfAbsent

public void putIfAbsent(String watchId,
                        WatchState watchState,
                        org.elasticsearch.action.ActionListener<org.elasticsearch.action.index.IndexResponse> actionListener)