Package org.nuxeo.audit.storage.stream
Class StreamAuditStorageWriter
java.lang.Object
org.nuxeo.audit.storage.stream.StreamAuditStorageWriter
- All Implemented Interfaces:
StreamProcessorTopology
Computation that consumes a stream of Json log entries and write them to the Directory Audit Storage.
- Since:
- 9.10
-
Nested Class Summary
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected int
getOptionAsInteger
(Map<String, String> options, String option, int defaultValue) getTopology
(Map<String, String> options) Returns a Stream computation topology.
-
Field Details
-
COMPUTATION_NAME
- See Also:
-
BATCH_SIZE_OPT
- See Also:
-
BATCH_THRESHOLD_MS_OPT
- See Also:
-
DEFAULT_BATCH_SIZE
public static final int DEFAULT_BATCH_SIZE- See Also:
-
DEFAULT_BATCH_THRESHOLD_MS
public static final int DEFAULT_BATCH_THRESHOLD_MS- See Also:
-
-
Constructor Details
-
StreamAuditStorageWriter
public StreamAuditStorageWriter()
-
-
Method Details
-
getTopology
Description copied from interface:StreamProcessorTopology
Returns a Stream computation topology.- Specified by:
getTopology
in interfaceStreamProcessorTopology
-
getOptionAsInteger
-