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

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 type, int limit) Provides last N entries of audit history for given type
List<AuditEntry>	fetchAuditHistory(String type, org.joda.time.Interval interval) provides audit history for given type and interval
List<AuditEntry>	fetchAuditHistory(String key, String type, int limit) Provides last N entries of audit history for given key, type
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

fetchAuditHistory

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

Description copied from interface: AuditManager

provides audit history for given type and interval

Specified by:

fetchAuditHistory in interface AuditManager

Parameters:

type - type of auditEntry

interval - interval for which to fetch auditHistory

Returns:

list of AuditEntries satisfying the passed parameters

fetchAuditHistory

public List<AuditEntry> fetchAuditHistory(String key,
                                          String type,
                                          int limit)
                                   throws IllegalArgumentException

Description copied from interface: AuditManager

Provides last N entries of audit history for given key, type

Specified by:

fetchAuditHistory in interface AuditManager

Returns:

list of AuditEntries satisfying the passed parameters

Throws:

IllegalArgumentException

fetchAuditHistory

public List<AuditEntry> fetchAuditHistory(String type,
                                          int limit)
                                   throws IllegalArgumentException

Description copied from interface: AuditManager

Provides last N entries of audit history for given type

Specified by:

fetchAuditHistory in interface AuditManager

Parameters:

type - type of auditEntry

Returns:

list of AuditEntries satisfying the passed parameters

Throws:

IllegalArgumentException