public class LogsReaderCompositeStage extends teetime.framework.CompositeStage implements ISourceCompositeStage
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DATA_BUFFER_SIZE |
static java.lang.String |
LOG_DIRECTORIES |
static java.lang.String |
PREFIX |
static java.lang.String |
VERBOSE |
Constructor and Description |
---|
LogsReaderCompositeStage(Configuration configuration)
Creates a composite stage to scan and read a set of Kieker log directories.
|
LogsReaderCompositeStage(java.util.List<java.io.File> directories,
boolean verbose,
java.lang.Integer dataBufferSize)
Creates a composite stage to scan and read a set of Kieker log directories.
|
Modifier and Type | Method and Description |
---|---|
teetime.framework.OutputPort<IMonitoringRecord> |
getOutputPort()
get the output port of a source composite stage.
|
public static final java.lang.String PREFIX
public static final java.lang.String LOG_DIRECTORIES
public static final java.lang.String DATA_BUFFER_SIZE
public static final java.lang.String VERBOSE
public LogsReaderCompositeStage(Configuration configuration)
configuration
- configuration for the enclosed filterspublic LogsReaderCompositeStage(java.util.List<java.io.File> directories, boolean verbose, java.lang.Integer dataBufferSize)
directories
- list of directories to readverbose
- report on every read log filedataBufferSize
- buffer size of the data file reader (null == use default setting)public teetime.framework.OutputPort<IMonitoringRecord> getOutputPort()
ISourceCompositeStage
getOutputPort
in interface ISourceCompositeStage
Copyright 2021 Kieker Project, http://kieker-monitoring.net