Package com.floragunn.searchguard.auditlog.sink

Class AuditLogSink

java.lang.Object

com.floragunn.searchguard.auditlog.sink.AuditLogSink

Direct Known Subclasses:

DebugSink, ExternalESSink, InternalESSink, KafkaSink, Log4JSink, NoopSink, WebhookSink

public abstract class AuditLogSink
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected AuditLogSink	fallbackSink
protected org.apache.logging.log4j.Logger	log
protected org.elasticsearch.common.settings.Settings	settings
protected String	settingsPrefix

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AuditLogSink(String name, org.elasticsearch.common.settings.Settings settings, String settingsPrefix, AuditLogSink fallbackSink)

Method Summary

Modifier and Type	Method	Description
void	close()
protected abstract boolean	doStore(AuditMessage msg)
boolean	equals(Object obj)
protected String	getExpandedIndexName(org.joda.time.format.DateTimeFormatter indexPattern, String index)
AuditLogSink	getFallbackSink()
String	getName()
protected org.elasticsearch.common.settings.Settings	getSinkSettings(String prefix)
int	hashCode()
boolean	isHandlingBackpressure()
void	store(AuditMessage msg)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

log

protected final org.apache.logging.log4j.Logger log

settings

protected final org.elasticsearch.common.settings.Settings settings

settingsPrefix

protected final String settingsPrefix

fallbackSink

protected final AuditLogSink fallbackSink

Constructor Detail

AuditLogSink

protected AuditLogSink(String name,
                       org.elasticsearch.common.settings.Settings settings,
                       String settingsPrefix,
                       AuditLogSink fallbackSink)

Method Detail

isHandlingBackpressure

public boolean isHandlingBackpressure()

getName

public String getName()

getFallbackSink

public AuditLogSink getFallbackSink()

store

public final void store(AuditMessage msg)

doStore

protected abstract boolean doStore(AuditMessage msg)

close

public void close()
           throws IOException

Throws:

IOException

getExpandedIndexName

protected String getExpandedIndexName(org.joda.time.format.DateTimeFormatter indexPattern,
                                      String index)

getSinkSettings

protected org.elasticsearch.common.settings.Settings getSinkSettings(String prefix)

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object