Package org.odpi.openmetadata.adapters.connectors.integration.kafkaaudit

Class AuditLogDestinationCatalogTargetProcessor

java.lang.Object

org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipProperties

org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipBeanProperties

org.odpi.openmetadata.frameworks.openmetadata.properties.assets.processes.connectors.CatalogTargetProperties

org.odpi.openmetadata.frameworks.opengovernance.properties.CatalogTarget

org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

org.odpi.openmetadata.adapters.connectors.integration.kafkaaudit.AuditLogDestinationCatalogTargetProcessor

public class AuditLogDestinationCatalogTargetProcessor
extends CatalogTargetProcessorBase

Distributes audit log events from one or more embedded topic connectors to one or more embedded audit log destinations.

Field Summary

Fields inherited from class org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

auditLog, connectorName, propertyHelper

Fields inherited from class org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

connectorToTarget, integrationContext

Constructor Summary

Constructors

Constructor	Description
AuditLogDestinationCatalogTargetProcessor(CatalogTarget template, CatalogTargetContext catalogTargetContext, Connector connectorToTarget, String connectorName, AuditLog auditLog)	Copy/clone constructor

Method Summary

Modifier and Type	Method	Description
void	refresh()	Requests that the connector does a comparison of the metadata in the third party technology and open metadata repositories.
void	storeLogRecord(OMRSAuditLogRecord logRecord)	Store the audit log record in the audit log store.

Methods inherited from class org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

getDateConfigurationProperty, getStringConfigurationProperty

Methods inherited from class org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

equals, getConnectorToTarget, getIntegrationContext, hashCode, toString

Methods inherited from class org.odpi.openmetadata.frameworks.opengovernance.properties.CatalogTarget

getCatalogTargetElement, getRelationshipGUID, getRelationshipVersions, setCatalogTargetElement, setRelationshipGUID, setRelationshipVersions

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.assets.processes.connectors.CatalogTargetProperties

getCatalogTargetName, getConfigurationProperties, getConnectionName, getDeleteMethod, getMetadataSourceQualifiedName, getPermittedSynchronization, getTemplates, setCatalogTargetName, setConfigurationProperties, setConnectionName, setDeleteMethod, setMetadataSourceQualifiedName, setPermittedSynchronization, setTemplates

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipBeanProperties

getExtendedProperties, getTypeName, setExtendedProperties, setTypeName

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipProperties

getEffectiveFrom, getEffectiveTo, setEffectiveFrom, setEffectiveTo

Methods inherited from class java.lang.Object

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

Constructor Details

AuditLogDestinationCatalogTargetProcessor

public AuditLogDestinationCatalogTargetProcessor(CatalogTarget template,
 CatalogTargetContext catalogTargetContext,
 Connector connectorToTarget,
 String connectorName,
 AuditLog auditLog)

Copy/clone constructor

Parameters:

template - object to copy

catalogTargetContext - specialized context for this catalog target

connectorToTarget - connector to access the target resource

connectorName - name of this integration connector

auditLog - logging destination

Method Details

storeLogRecord

public void storeLogRecord(OMRSAuditLogRecord logRecord)

Store the audit log record in the audit log store.

Parameters:

logRecord - log record to store

refresh

public void refresh()

Requests that the connector does a comparison of the metadata in the third party technology and open metadata repositories. Refresh is called when the integration connector first starts and then at intervals defined in the connector's configuration as well as any external REST API calls to explicitly refresh the connector.

Specified by:

refresh in class CatalogTargetProcessorBase