org.apache.ranger.audit.destination

Class ElasticSearchAuditDestination

java.lang.Object

org.apache.ranger.audit.provider.BaseAuditHandler

org.apache.ranger.audit.destination.AuditDestination

org.apache.ranger.audit.destination.ElasticSearchAuditDestination

All Implemented Interfaces:

AuditHandler

public class ElasticSearchAuditDestination
extends AuditDestination

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIG_INDEX
static String	CONFIG_PORT
static String	CONFIG_PREFIX
static String	CONFIG_PROTOCOL
static String	CONFIG_PWRD
static String	CONFIG_URLS
static String	CONFIG_USER
static String	DEFAULT_INDEX

Fields inherited from class org.apache.ranger.audit.provider.BaseAuditHandler

configProps, FAILED_TO_LOG_AUDIT_EVENT, failedRetrySleep, failedRetryTimes, parentPath, PROP_CLASS_NAME, PROP_CONFIG, PROP_DEFAULT_PREFIX, PROP_NAME, propPrefix, props, providerName, RANGER_POLICYMGR_CLIENT_KEY_FILE, RANGER_POLICYMGR_CLIENT_KEY_FILE_CREDENTIAL, RANGER_POLICYMGR_CLIENT_KEY_FILE_CREDENTIAL_ALIAS, RANGER_POLICYMGR_CLIENT_KEY_FILE_TYPE, RANGER_POLICYMGR_CLIENT_KEY_FILE_TYPE_DEFAULT, RANGER_POLICYMGR_TRUSTSTORE_FILE, RANGER_POLICYMGR_TRUSTSTORE_FILE_CREDENTIAL, RANGER_POLICYMGR_TRUSTSTORE_FILE_CREDENTIAL_ALIAS, RANGER_POLICYMGR_TRUSTSTORE_FILE_TYPE, RANGER_POLICYMGR_TRUSTSTORE_FILE_TYPE_DEFAULT, RANGER_SSL_CONTEXT_ALGO_TYPE, RANGER_SSL_KEYMANAGER_ALGO_TYPE, RANGER_SSL_TRUSTMANAGER_ALGO_TYPE

Constructor Summary

Constructors

Constructor and Description
ElasticSearchAuditDestination()

Method Summary

Modifier and Type	Method and Description
void	flush()
static org.elasticsearch.client.RestClientBuilder	getRestClientBuilder(String urls, String protocol, String user, String password, int port)
void	init(Properties props, String propPrefix)
boolean	isAsync()
boolean	log(Collection<AuditEventBase> events)
void	stop()

Methods inherited from class org.apache.ranger.audit.destination.AuditDestination

start, waitToComplete, waitToComplete

Methods inherited from class org.apache.ranger.audit.provider.BaseAuditHandler

addDeferredCount, addFailedCount, addStashedCount, addSuccessCount, addTotalCount, formatIntervalForLog, getFinalPath, getLastDeferredCount, getLastStashedCount, getName, getParentPath, getTimeDiffStr, getTotalCount, getTotalDeferredCount, getTotalFailedCount, getTotalStashedCount, getTotalSuccessCount, init, isStatusLogEnabled, log, logError, logError, logFailedEvent, logFailedEvent, logFailedEvent, logFailedEvent, logFailedEvent, logFailedEvent, logFailedEventJSON, logFailedEventJSON, logFile, logJSON, logJSON, logStatus, logStatusIfRequired, setName, setParentPath

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_URLS

public static final String CONFIG_URLS

See Also:

Constant Field Values

CONFIG_PORT

public static final String CONFIG_PORT

See Also:

Constant Field Values

CONFIG_USER

public static final String CONFIG_USER

See Also:

Constant Field Values

CONFIG_PWRD

public static final String CONFIG_PWRD

See Also:

Constant Field Values

CONFIG_PROTOCOL

public static final String CONFIG_PROTOCOL

See Also:

Constant Field Values

CONFIG_INDEX

public static final String CONFIG_INDEX

See Also:

Constant Field Values

CONFIG_PREFIX

public static final String CONFIG_PREFIX

See Also:

Constant Field Values

DEFAULT_INDEX

public static final String DEFAULT_INDEX

See Also:

Constant Field Values

Constructor Detail

ElasticSearchAuditDestination

public ElasticSearchAuditDestination()

Method Detail

init

public void init(Properties props,
                 String propPrefix)

Specified by:

init in interface AuditHandler

Overrides:

init in class AuditDestination

stop

public void stop()

Specified by:

stop in interface AuditHandler

Overrides:

stop in class AuditDestination

log

public boolean log(Collection<AuditEventBase> events)

flush

public void flush()

Specified by:

flush in interface AuditHandler

Overrides:

flush in class AuditDestination

isAsync

public boolean isAsync()

getRestClientBuilder

public static org.elasticsearch.client.RestClientBuilder getRestClientBuilder(String urls,
                                                                              String protocol,
                                                                              String user,
                                                                              String password,
                                                                              int port)