io.druid.server.audit

Class SQLAuditManager

java.lang.Object

io.druid.server.audit.SQLAuditManager

All Implemented Interfaces:

AuditManager

public class SQLAuditManager
extends Object
implements AuditManager

Field Summary

Fields inherited from interface io.druid.audit.AuditManager

X_DRUID_AUTHOR, X_DRUID_COMMENT

Constructor Summary

Constructors

Constructor and Description
SQLAuditManager(SQLMetadataConnector connector, com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables, com.metamx.emitter.service.ServiceEmitter emitter, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, SQLAuditManagerConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
void	doAudit(AuditEntry auditEntry) inserts an audit Entry in the Audit Table
void	doAudit(AuditEntry auditEntry, org.skife.jdbi.v2.Handle handle) inserts an audit Entry in audit table using the handler provided used to do the audit in same transaction as the config changes
List<AuditEntry>	fetchAuditHistory(String key, String type, org.joda.time.Interval interval) provides audit history for given key, type and interval
String	getAuditTable()

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLAuditManager

@Inject
public SQLAuditManager(SQLMetadataConnector connector,
                      com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables,
                      com.metamx.emitter.service.ServiceEmitter emitter,
                      com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                      SQLAuditManagerConfig config)

Method Detail

getAuditTable

public String getAuditTable()

doAudit

public void doAudit(AuditEntry auditEntry)

Description copied from interface: AuditManager

inserts an audit Entry in the Audit Table

Specified by:

doAudit in interface AuditManager

doAudit

public void doAudit(AuditEntry auditEntry,
           org.skife.jdbi.v2.Handle handle)
             throws IOException

Description copied from interface: AuditManager

inserts an audit Entry in audit table using the handler provided used to do the audit in same transaction as the config changes

Specified by:

doAudit in interface AuditManager

Throws:

IOException

fetchAuditHistory

public List<AuditEntry> fetchAuditHistory(String key,
                                 String type,
                                 org.joda.time.Interval interval)

Description copied from interface: AuditManager

provides audit history for given key, type and interval

Specified by:

fetchAuditHistory in interface AuditManager

Returns:

list of AuditEntries satisfying the passed parameters