org.opennms.plugins.elasticsearch.rest

Class EventToIndex

java.lang.Object

org.opennms.plugins.elasticsearch.rest.EventToIndex

All Implemented Interfaces:

AutoCloseable

public class EventToIndex
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EventToIndex.Indices

Field Summary

Fields

Modifier and Type	Field and Description
static String	ALARM_ACK_DURATION
static String	ALARM_ACK_TIME_PARAM
static String	ALARM_ACK_USER_PARAM
static String	ALARM_ACKNOWLEDGED_EVENT
static String	ALARM_CHANGED_EVENT
static String	ALARM_CLEAR_DURATION
static String	ALARM_CLEAR_TIME
static String	ALARM_CLEARED_EVENT
static String	ALARM_CREATED_EVENT
static String	ALARM_DELETED_EVENT
static String	ALARM_DELETED_TIME
static String	ALARM_NOTIFICATION_UEI_STEM
static String	ALARM_SEVERITY_CHANGED_EVENT
static String	ALARM_SEVERITY_PARAM
static String	ALARM_SUPPRESSED_EVENT
static String	ALARM_TROUBLETICKET_STATE_CHANGE_EVENT
static String	ALARM_UNACKNOWLEDGED_EVENT
static String	ALARM_UNSUPPRESSED_EVENT
static int	DEFAULT_NUMBER_OF_THREADS
static String	EVENT_PARAMS
static String	FIRST_EVENT_TIME
static EnumMap<EventToIndex.Indices,String>	INDEX_NAMES
static EnumMap<EventToIndex.Indices,String>	INDEX_TYPES
static String	INITIAL_SEVERITY_PARAM
static String	INITIAL_SEVERITY_PARAM_TEXT
static String	JOURNAL_MEMO_EVENT
static String	MEMO_ALARMID_PARAM
static String	MEMO_AUTHOR_PARAM
static String	MEMO_BODY_PARAM
static String	MEMO_REDUCTIONKEY_PARAM
static String	MEMO_VALUES_PARAM
static String	NEW_ALARM_VALUES_PARAM
static String	NODE_LABEL_PARAM
static String	OLD_ALARM_VALUES_PARAM
static String	SEVERITY
static String	SEVERITY_TEXT
static String	STICKY_MEMO_EVENT

Constructor Summary

Constructors

Constructor and Description
EventToIndex()

Method Summary

Modifier and Type	Method and Description
void	close()
void	forwardEvents(List<Event> events)
boolean	getArchiveAlarmChangeEvents()
boolean	getArchiveAlarms()
boolean	getArchiveNewAlarmValues()
boolean	getArchiveOldAlarmValues()
boolean	getArchiveRawEvents()
IndexNameFunction	getIndexNameFunction()
NodeCache	getNodeCache()
RestClientFactory	getRestClientFactory()
int	getThreads()
boolean	isLogAllEvents()
boolean	isLogEventDescription()
io.searchbox.core.Update	populateAlarmIndexBodyFromAlarmChangeEvent(Event event, String rootIndexName, String indexType) An alarm change event will have a payload corresponding to the json representation of the Alarms table row for this alarm id.
io.searchbox.core.Index	populateEventIndexBodyFromEvent(Event event, String rootIndexName, String indexType) utility method to populate a Map with the most import event attributes
void	setArchiveAlarmChangeEvents(boolean archiveAlarmChangeEvents)
void	setArchiveAlarms(boolean archiveAlarms)
void	setArchiveNewAlarmValues(boolean archiveNewAlarmValues)
void	setArchiveOldAlarmValues(boolean archiveOldAlarmValues)
void	setArchiveRawEvents(boolean archiveRawEvents)
void	setIndexNameFunction(IndexNameFunction indexNameFunction)
void	setLogAllEvents(boolean logAllEvents)
void	setLogEventDescription(boolean logEventDescription)
void	setNodeCache(NodeCache cache)
void	setRestClientFactory(RestClientFactory restClientFactory)
void	setThreads(int threads)

Methods inherited from class java.lang.Object

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

Field Detail

INDEX_NAMES

public static final EnumMap<EventToIndex.Indices,String> INDEX_NAMES

INDEX_TYPES

public static final EnumMap<EventToIndex.Indices,String> INDEX_TYPES

ALARM_NOTIFICATION_UEI_STEM

public static final String ALARM_NOTIFICATION_UEI_STEM

See Also:

Constant Field Values

ALARM_DELETED_EVENT

public static final String ALARM_DELETED_EVENT

See Also:

Constant Field Values

ALARM_CREATED_EVENT

public static final String ALARM_CREATED_EVENT

See Also:

Constant Field Values

ALARM_SEVERITY_CHANGED_EVENT

public static final String ALARM_SEVERITY_CHANGED_EVENT

See Also:

Constant Field Values

ALARM_CLEARED_EVENT

public static final String ALARM_CLEARED_EVENT

See Also:

Constant Field Values

ALARM_ACKNOWLEDGED_EVENT

public static final String ALARM_ACKNOWLEDGED_EVENT

See Also:

Constant Field Values

ALARM_UNACKNOWLEDGED_EVENT

public static final String ALARM_UNACKNOWLEDGED_EVENT

See Also:

Constant Field Values

ALARM_SUPPRESSED_EVENT

public static final String ALARM_SUPPRESSED_EVENT

See Also:

Constant Field Values

ALARM_UNSUPPRESSED_EVENT

public static final String ALARM_UNSUPPRESSED_EVENT

See Also:

Constant Field Values

ALARM_TROUBLETICKET_STATE_CHANGE_EVENT

public static final String ALARM_TROUBLETICKET_STATE_CHANGE_EVENT

See Also:

Constant Field Values

ALARM_CHANGED_EVENT

public static final String ALARM_CHANGED_EVENT

See Also:

Constant Field Values

STICKY_MEMO_EVENT

public static final String STICKY_MEMO_EVENT

See Also:

Constant Field Values

JOURNAL_MEMO_EVENT

public static final String JOURNAL_MEMO_EVENT

See Also:

Constant Field Values

MEMO_VALUES_PARAM

public static final String MEMO_VALUES_PARAM

See Also:

Constant Field Values

MEMO_ALARMID_PARAM

public static final String MEMO_ALARMID_PARAM

See Also:

Constant Field Values

MEMO_BODY_PARAM

public static final String MEMO_BODY_PARAM

See Also:

Constant Field Values

MEMO_AUTHOR_PARAM

public static final String MEMO_AUTHOR_PARAM

See Also:

Constant Field Values

MEMO_REDUCTIONKEY_PARAM

public static final String MEMO_REDUCTIONKEY_PARAM

See Also:

Constant Field Values

OLD_ALARM_VALUES_PARAM

public static final String OLD_ALARM_VALUES_PARAM

See Also:

Constant Field Values

NEW_ALARM_VALUES_PARAM

public static final String NEW_ALARM_VALUES_PARAM

See Also:

Constant Field Values

NODE_LABEL_PARAM

public static final String NODE_LABEL_PARAM

See Also:

Constant Field Values

INITIAL_SEVERITY_PARAM

public static final String INITIAL_SEVERITY_PARAM

See Also:

Constant Field Values

INITIAL_SEVERITY_PARAM_TEXT

public static final String INITIAL_SEVERITY_PARAM_TEXT

See Also:

Constant Field Values

SEVERITY_TEXT

public static final String SEVERITY_TEXT

See Also:

Constant Field Values

SEVERITY

public static final String SEVERITY

See Also:

Constant Field Values

ALARM_SEVERITY_PARAM

public static final String ALARM_SEVERITY_PARAM

See Also:

Constant Field Values

FIRST_EVENT_TIME

public static final String FIRST_EVENT_TIME

See Also:

Constant Field Values

EVENT_PARAMS

public static final String EVENT_PARAMS

See Also:

Constant Field Values

ALARM_ACK_TIME_PARAM

public static final String ALARM_ACK_TIME_PARAM

See Also:

Constant Field Values

ALARM_ACK_USER_PARAM

public static final String ALARM_ACK_USER_PARAM

See Also:

Constant Field Values

ALARM_ACK_DURATION

public static final String ALARM_ACK_DURATION

See Also:

Constant Field Values

ALARM_CLEAR_TIME

public static final String ALARM_CLEAR_TIME

See Also:

Constant Field Values

ALARM_CLEAR_DURATION

public static final String ALARM_CLEAR_DURATION

See Also:

Constant Field Values

ALARM_DELETED_TIME

public static final String ALARM_DELETED_TIME

See Also:

Constant Field Values

DEFAULT_NUMBER_OF_THREADS

public static final int DEFAULT_NUMBER_OF_THREADS

Constructor Detail

EventToIndex

public EventToIndex()

Method Detail

getIndexNameFunction

public IndexNameFunction getIndexNameFunction()

setIndexNameFunction

public void setIndexNameFunction(IndexNameFunction indexNameFunction)

isLogEventDescription

public boolean isLogEventDescription()

setLogEventDescription

public void setLogEventDescription(boolean logEventDescription)

isLogAllEvents

public boolean isLogAllEvents()

setLogAllEvents

public void setLogAllEvents(boolean logAllEvents)

getThreads

public int getThreads()

setThreads

public void setThreads(int threads)

getNodeCache

public NodeCache getNodeCache()

setNodeCache

public void setNodeCache(NodeCache cache)

getRestClientFactory

public RestClientFactory getRestClientFactory()

setRestClientFactory

public void setRestClientFactory(RestClientFactory restClientFactory)

getArchiveAlarms

public boolean getArchiveAlarms()

setArchiveAlarms

public void setArchiveAlarms(boolean archiveAlarms)

getArchiveAlarmChangeEvents

public boolean getArchiveAlarmChangeEvents()

setArchiveAlarmChangeEvents

public void setArchiveAlarmChangeEvents(boolean archiveAlarmChangeEvents)

getArchiveRawEvents

public boolean getArchiveRawEvents()

setArchiveRawEvents

public void setArchiveRawEvents(boolean archiveRawEvents)

getArchiveOldAlarmValues

public boolean getArchiveOldAlarmValues()

setArchiveOldAlarmValues

public void setArchiveOldAlarmValues(boolean archiveOldAlarmValues)

getArchiveNewAlarmValues

public boolean getArchiveNewAlarmValues()

setArchiveNewAlarmValues

public void setArchiveNewAlarmValues(boolean archiveNewAlarmValues)

close

public void close()

Specified by:

close in interface AutoCloseable

forwardEvents

public void forwardEvents(List<Event> events)

Parameters:

events -

populateEventIndexBodyFromEvent

public io.searchbox.core.Index populateEventIndexBodyFromEvent(Event event,
                                                               String rootIndexName,
                                                               String indexType)

utility method to populate a Map with the most import event attributes

Parameters:

body - the map

event - the event object

populateAlarmIndexBodyFromAlarmChangeEvent

public io.searchbox.core.Update populateAlarmIndexBodyFromAlarmChangeEvent(Event event,
                                                                           String rootIndexName,
                                                                           String indexType)

An alarm change event will have a payload corresponding to the json representation of the Alarms table row for this alarm id. Both "oldalarmvalues" and "newalarmvalues" params may be populated The alarm index body will be populated with the "newalarmvalues" but if "newalarmvalues" is null then the "oldalarmvalues" json string will be used If cannot parse event into alarm then null index is returned

Parameters:

body -

event -