org.nuxeo.ecm.platform.audit.impl

Class StreamAuditWriter.AuditLogWriterComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.ecm.platform.audit.impl.StreamAuditWriter.AuditLogWriterComputation

All Implemented Interfaces:

Computation

Enclosing class:

StreamAuditWriter

public static class StreamAuditWriter.AuditLogWriterComputation
extends AbstractComputation

Field Summary

Fields

Modifier and Type	Field and Description
protected int	batchSize
protected int	batchThresholdMs
protected List<LogEntry>	logEntries

Fields inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

metadata

Constructor Summary

Constructors

Constructor and Description
AuditLogWriterComputation(String name, int batchSize, int batchThresholdMs)

Method Summary

Modifier and Type	Method and Description
void	destroy() Called when the framework is ready to shutdown the computation.
protected LogEntry	getLogEntryFromJson(byte[] data)
void	init(ComputationContext context) Called when the framework has registered the computation successfully.
void	processRecord(ComputationContext context, String inputStreamName, Record record) Process an incoming record on one of the computation's input streams.
void	processTimer(ComputationContext context, String key, long timestamp) Process a timer callback previously set via ComputationContext.setTimer(String, long).
protected void	writeEntriesToAudit(ComputationContext context)

Methods inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

metadata

Methods inherited from class java.lang.Object

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

Field Detail

batchSize

protected final int batchSize

batchThresholdMs

protected final int batchThresholdMs

logEntries

protected final List<LogEntry> logEntries

Constructor Detail

AuditLogWriterComputation

public AuditLogWriterComputation(String name,
                                 int batchSize,
                                 int batchThresholdMs)

Method Detail

init

public void init(ComputationContext context)

Description copied from interface: Computation

Called when the framework has registered the computation successfully. Gives users a first opportunity to schedule timer callbacks and produce records.

Specified by:

init in interface Computation

Overrides:

init in class AbstractComputation

Parameters:

context - The computation context object provided by the system.

processTimer

public void processTimer(ComputationContext context,
                         String key,
                         long timestamp)

Description copied from interface: Computation

Process a timer callback previously set via ComputationContext.setTimer(String, long).

Specified by:

processTimer in interface Computation

Overrides:

processTimer in class AbstractComputation

Parameters:

context - The computation context object provided by the system.

key - The name of the timer.

timestamp - The timestamp (in ms) for which the callback was scheduled.

processRecord

public void processRecord(ComputationContext context,
                          String inputStreamName,
                          Record record)

Description copied from interface: Computation

Process an incoming record on one of the computation's input streams.

Parameters:

context - The computation context object provided by the system.

inputStreamName - Name of the input stream that provides the record.

record - The record.

destroy

public void destroy()

Description copied from interface: Computation

Called when the framework is ready to shutdown the computation. Gives users a chance to perform some cleanup before the process is killed.

writeEntriesToAudit

protected void writeEntriesToAudit(ComputationContext context)

getLogEntryFromJson

protected LogEntry getLogEntryFromJson(byte[] data)