Package org.odpi.openmetadata.adapters.repositoryservices.auditlogstore.file

Class FileBasedAuditLogStoreConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

org.odpi.openmetadata.repositoryservices.connectors.stores.auditlogstore.OMRSAuditLogStoreConnectorBase

org.odpi.openmetadata.adapters.repositoryservices.auditlogstore.file.FileBasedAuditLogStoreConnector

All Implemented Interfaces:

SecureConnectorExtension, VirtualConnectorExtension, OMRSAuditLogStore

public class FileBasedAuditLogStoreConnector
extends OMRSAuditLogStoreConnectorBase

FileBasedAuditLogStoreConnector provides a connector implementation for a file based audit log. The audit log is stored in a directory and each audit log record is stored as a file with a filename build from the record's unique identifier (guid).

Nested Class Summary

Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

ConnectorBase.ProtectedConnection

Field Summary

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

auditLog, connectedAssetProperties, connectionBean, connectionProperties, connectorInstanceId, embeddedConnectors, messageFormatter, secretsStoreConnectorMap

Constructor Summary

Constructors

Constructor	Description
FileBasedAuditLogStoreConnector()	Default constructor used by the connector provider.

Method Summary

Modifier and Type	Method	Description
void	disconnect()	Free up any resources held since the connector is no longer needed.
OMRSAuditLogRecord	getAuditLogRecord(String logRecordId)	Retrieve a specific audit log record.
List<OMRSAuditLogRecord>	getAuditLogRecordsByComponent(String component, Date startDate, Date endDate, int offset, int maximumRecords)	Retrieve a list of log records written by a specific component.
List<OMRSAuditLogRecord>	getAuditLogRecordsBySeverity(String severity, Date startDate, Date endDate, int offset, int maximumRecords)	Retrieve a list of log records that have specific severity.
List<OMRSAuditLogRecord>	getAuditLogRecordsByTimeStamp(Date startDate, Date endDate, int offset, int maximumRecords)	Retrieve a list of log records written in a specified time period.
void	start()	Set up the name of the file store
String	storeLogRecord(OMRSAuditLogRecord logRecord)	Store the audit log record in the audit log store.

Methods inherited from class org.odpi.openmetadata.repositoryservices.connectors.stores.auditlogstore.OMRSAuditLogStoreConnectorBase

getDestinationName, getJSONLogRecord, getSupportedSeverities, initialize, isSupportedSeverity, storeLogRecord, validateLogRecord

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

combineConfigurationProperties, disconnectConnectors, equals, getArrayConfigurationProperty, getAssetTypeName, getBooleanConfigurationProperty, getConnectedAssetProperties, getConnection, getConnectorInstanceId, getDateConfigurationProperty, getIntConfigurationProperty, getLongConfigurationProperty, getNetworkAddresses, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initializeConnectedAssetProperties, initializeEmbeddedConnectors, initializeSecretsStoreConnector, isActive, logExceptionRecord, logRecord, logRecord, throwMissingConfigurationProperty, throwMissingResource, throwNoAsset, throwWrongTypeOfAsset, throwWrongTypeOfResource, throwWrongTypeOfRootSchema, toString

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector

clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, setStatisticProperty, setStatisticTimestamp

Methods inherited from class java.lang.Object

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

Constructor Details

FileBasedAuditLogStoreConnector

public FileBasedAuditLogStoreConnector()

Default constructor used by the connector provider.

Method Details

start

public void start()
           throws ConnectorCheckedException

Set up the name of the file store

Overrides:

start in class ConnectorBase

Throws:

ConnectorCheckedException - something went wrong

storeLogRecord

public String storeLogRecord(OMRSAuditLogRecord logRecord)
                      throws InvalidParameterException

Store the audit log record in the audit log store.

Specified by:

storeLogRecord in interface OMRSAuditLogStore

Specified by:

storeLogRecord in class OMRSAuditLogStoreConnectorBase

Parameters:

logRecord - log record to store

Returns:

unique identifier assigned to the log record

Throws:

InvalidParameterException - indicates that the logRecord parameter is invalid.

getAuditLogRecord

public OMRSAuditLogRecord getAuditLogRecord(String logRecordId)
                                     throws InvalidParameterException,
RepositoryErrorException

Retrieve a specific audit log record.

Specified by:

getAuditLogRecord in interface OMRSAuditLogStore

Overrides:

getAuditLogRecord in class OMRSAuditLogStoreConnectorBase

Parameters:

logRecordId - unique identifier for the log record

Returns:

requested audit log record

Throws:

InvalidParameterException - indicates that the logRecordId parameter is invalid.

RepositoryErrorException - indicates that the audit log store is not available or has an error.

getAuditLogRecordsByTimeStamp

public List<OMRSAuditLogRecord> getAuditLogRecordsByTimeStamp(Date startDate,
 Date endDate,
 int offset,
 int maximumRecords)
                                                       throws InvalidParameterException,
PagingErrorException,
RepositoryErrorException

Retrieve a list of log records written in a specified time period. The offset and maximumRecords parameters support a paging

Specified by:

getAuditLogRecordsByTimeStamp in interface OMRSAuditLogStore

Overrides:

getAuditLogRecordsByTimeStamp in class OMRSAuditLogStoreConnectorBase

Parameters:

startDate - start of time period

endDate - end of time period

offset - offset of full collection to begin the return results

maximumRecords - maximum number of log records to return

Returns:

list of log records from the specified time period

Throws:

InvalidParameterException - indicates that the start and/or end date parameters are invalid.

PagingErrorException - indicates that the offset or the maximumRecords parameters are invalid.

RepositoryErrorException - indicates that the audit log store is not available or has an error.

getAuditLogRecordsBySeverity

public List<OMRSAuditLogRecord> getAuditLogRecordsBySeverity(String severity,
 Date startDate,
 Date endDate,
 int offset,
 int maximumRecords)
                                                      throws InvalidParameterException,
PagingErrorException,
RepositoryErrorException

Retrieve a list of log records that have specific severity. The offset and maximumRecords parameters support a paging model.

Specified by:

getAuditLogRecordsBySeverity in interface OMRSAuditLogStore

Overrides:

getAuditLogRecordsBySeverity in class OMRSAuditLogStoreConnectorBase

Parameters:

severity - the severity value of messages to return

startDate - start of time period

endDate - end of time period

offset - offset of full collection to begin the return results

maximumRecords - maximum number of log records to return

Returns:

list of log records from the specified time period

Throws:

InvalidParameterException - indicates that the severity, start and/or end date parameters are invalid.

PagingErrorException - indicates that the offset or the maximumRecords parameters are invalid.

RepositoryErrorException - indicates that the audit log store is not available or has an error.

getAuditLogRecordsByComponent

public List<OMRSAuditLogRecord> getAuditLogRecordsByComponent(String component,
 Date startDate,
 Date endDate,
 int offset,
 int maximumRecords)
                                                       throws InvalidParameterException,
PagingErrorException,
RepositoryErrorException

Retrieve a list of log records written by a specific component. The offset and maximumRecords parameters support a paging model.

Specified by:

getAuditLogRecordsByComponent in interface OMRSAuditLogStore

Overrides:

getAuditLogRecordsByComponent in class OMRSAuditLogStoreConnectorBase

Parameters:

component - name of the component to retrieve events from

startDate - start of time period

endDate - end of time period

offset - offset of full collection to begin the return results

maximumRecords - maximum number of log records to return

Returns:

list of log records from the specified time period

Throws:

InvalidParameterException - indicates that the component, start and/or end date parameters are invalid.

PagingErrorException - indicates that the offset or the maximumRecords parameters are invalid.

RepositoryErrorException - indicates that the audit log store is not available or has an error.

disconnect

public void disconnect()
                throws ConnectorCheckedException

Free up any resources held since the connector is no longer needed.

Overrides:

disconnect in class ConnectorBase

Throws:

ConnectorCheckedException - there is a problem within the connector.