org.opennms.plugins.elasticsearch.rest

Class EventToIndex

java.lang.Object

org.opennms.plugins.elasticsearch.rest.EventToIndex

public class EventToIndex
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	ALARM_ACK_TIME
static String	ALARM_ACK_USER
static String	ALARM_ACKNOWLEDGED_EVENT
static String	ALARM_CHANGED_EVENT
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_EVENT_INDEX_NAME
static String	ALARM_INDEX_NAME
static String	ALARM_INDEX_TYPE
static String	ALARM_NOTIFICATION_UEI_STEM
static String	ALARM_SEVERITY_CHANGED_EVENT
static String	ALARM_SUPPRESSED_EVENT
static String	ALARM_TROUBLETICKET_STATE_CHANGE_EVENT
static String	ALARM_UNACKNOWLEDGED_EVENT
static String	ALARM_UNSUPPRESSED_EVENT
static String	EVENT_INDEX_NAME
static String	EVENT_INDEX_TYPE
static String	EVENT_PARAMS
static String	INITIAL_SEVERITY
static String	INITIAL_SEVERITY_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
static String	NODE_LABEL
static String	OLD_ALARM_VALUES
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	destroy()
void	forwardEvent(Event event) this handles the incoming event and deals with it as an alarm change event or a normal event
boolean	getArchiveAlarmChangeEvents()
boolean	getArchiveAlarms()
boolean	getArchiveNewAlarmValues()
boolean	getArchiveOldAlarmValues()
boolean	getArchiveRawEvents()
IndexNameFunction	getIndexNameFunction()
NodeCache	getNodeCache()
RestClientFactory	getRestClientFactory()
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	setLogEventDescription(boolean logEventDescription)
void	setNodeCache(NodeCache cache)
void	setRestClientFactory(RestClientFactory restClientFactory)

Methods inherited from class java.lang.Object

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

Field Detail

ALARM_INDEX_NAME

public static final String ALARM_INDEX_NAME

See Also:

Constant Field Values

ALARM_EVENT_INDEX_NAME

public static final String ALARM_EVENT_INDEX_NAME

See Also:

Constant Field Values

EVENT_INDEX_NAME

public static final String EVENT_INDEX_NAME

See Also:

Constant Field Values

ALARM_INDEX_TYPE

public static final String ALARM_INDEX_TYPE

See Also:

Constant Field Values

EVENT_INDEX_TYPE

public static final String EVENT_INDEX_TYPE

See Also:

Constant Field Values

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

OLD_ALARM_VALUES

public static final String OLD_ALARM_VALUES

See Also:

Constant Field Values

NEW_ALARM_VALUES

public static final String NEW_ALARM_VALUES

See Also:

Constant Field Values

NODE_LABEL

public static final String NODE_LABEL

See Also:

Constant Field Values

INITIAL_SEVERITY

public static final String INITIAL_SEVERITY

See Also:

Constant Field Values

INITIAL_SEVERITY_TEXT

public static final String INITIAL_SEVERITY_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

EVENT_PARAMS

public static final String EVENT_PARAMS

See Also:

Constant Field Values

ALARM_ACK_TIME

public static final String ALARM_ACK_TIME

See Also:

Constant Field Values

ALARM_ACK_USER

public static final String ALARM_ACK_USER

See Also:

Constant Field Values

ALARM_CLEAR_TIME

public static final String ALARM_CLEAR_TIME

See Also:

Constant Field Values

ALARM_DELETED_TIME

public static final String ALARM_DELETED_TIME

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

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)

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)

destroy

public void destroy()

forwardEvent

public void forwardEvent(Event event)

this handles the incoming event and deals with it as an alarm change event or a normal event

Parameters:

event -

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 -