Package | Description |
---|---|
kieker.analysis.plugin.filter.flow |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.analysis.plugin.filter.record |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.analysis.plugin.filter.select |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.analysis.plugin.reader |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.analysis.plugin.reader.amqp |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.analysis.plugin.reader.filesystem |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.analysis.plugin.reader.namedRecordPipe |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.analysis.plugin.reader.newio.deserializer |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.analysis.plugin.reader.tcp |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.analysis.plugin.reader.util |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.analysis.sink | |
kieker.analysis.source |
Containing all record/event source stages of Kieker based on TeeTime.
|
kieker.analysis.source.file | |
kieker.analysis.source.rewriter | |
kieker.analysisteetime.plugin.filter.forward | |
kieker.analysisteetime.plugin.filter.record | |
kieker.analysisteetime.plugin.filter.record.delayfilter | |
kieker.analysisteetime.plugin.filter.record.delayfilter.components | |
kieker.analysisteetime.plugin.filter.select.timestampfilter | |
kieker.analysisteetime.plugin.filter.select.timestampfilter.components | |
kieker.analysisteetime.plugin.filter.select.traceidfilter | |
kieker.analysisteetime.plugin.reader |
Contains reader implementations using several different technologies.
|
kieker.analysisteetime.plugin.reader.amqp | |
kieker.analysisteetime.plugin.reader.filesystem | |
kieker.analysisteetime.plugin.reader.filesystem.format.binary | |
kieker.analysisteetime.plugin.reader.filesystem.format.binary.file | |
kieker.analysisteetime.plugin.reader.filesystem.format.text.file | |
kieker.analysisteetime.plugin.reader.filesystem.fsReader | |
kieker.analysisteetime.plugin.reader.jms | |
kieker.analysisteetime.plugin.reader.namedRecordPipe | |
kieker.analysisteetime.plugin.reader.tcp.singlesocket | |
kieker.analysisteetime.recordreading | |
kieker.common.namedRecordPipe |
Copyright 2020 Kieker Project (https://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.common.record |
Copyright 2020 Kieker Project (https://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.common.record.controlflow | |
kieker.common.record.database | |
kieker.common.record.factory |
Copyright 2020 Kieker Project (https://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.common.record.flow | |
kieker.common.record.flow.thread | |
kieker.common.record.flow.trace | |
kieker.common.record.flow.trace.concurrency | |
kieker.common.record.flow.trace.concurrency.monitor | |
kieker.common.record.flow.trace.operation | |
kieker.common.record.flow.trace.operation.constructor | |
kieker.common.record.flow.trace.operation.constructor.object | |
kieker.common.record.flow.trace.operation.object | |
kieker.common.record.jvm | |
kieker.common.record.misc |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.common.record.remotecontrol | |
kieker.common.record.system | |
kieker.common.registry |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.monitoring.core.controller | |
kieker.monitoring.listener | |
kieker.monitoring.queue.behavior | |
kieker.monitoring.sampler.mxbean | |
kieker.monitoring.writer | |
kieker.monitoring.writer.amqp | |
kieker.monitoring.writer.collector | |
kieker.monitoring.writer.dump | |
kieker.monitoring.writer.explorviz | |
kieker.monitoring.writer.filesystem | |
kieker.monitoring.writer.jms | |
kieker.monitoring.writer.jmx | |
kieker.monitoring.writer.namedRecordPipe | |
kieker.monitoring.writer.print | |
kieker.monitoring.writer.serializer | |
kieker.monitoring.writer.tcp | |
kieker.tools.currentTimeEventGenerator |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
kieker.tools.source | |
kieker.toolsteetime.currentTimeEventGenerator |
Copyright 2020 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
Modifier and Type | Method and Description |
---|---|
void |
ThreadEvent2TraceEventFilter.readInput(IMonitoringRecord event) |
Modifier and Type | Method and Description |
---|---|
void |
MonitoringThroughputFilter.inputRecord(IMonitoringRecord record) |
void |
RealtimeRecordDelayFilter.inputRecord(IMonitoringRecord monitoringRecord)
This method represents the input port of this filter.
|
Modifier and Type | Method and Description |
---|---|
void |
TraceIdFilter.inputCombined(IMonitoringRecord record)
This method represents an input port for both operation execution and flow records.
|
void |
TimestampFilter.inputCombined(IMonitoringRecord record) |
void |
TimestampFilter.inputIMonitoringRecord(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractStringRegistryReaderPlugin.deliverRecord(IMonitoringRecord monitoringRecord)
Delivers the given record to the appropriate output port(s).
|
Modifier and Type | Method and Description |
---|---|
protected void |
AmqpReader.deliverRecord(IMonitoringRecord monitoringRecord) |
Modifier and Type | Method and Description |
---|---|
boolean |
FSReader.newMonitoringRecord(IMonitoringRecord record)
This method is called for each new record by each ReaderThread.
|
boolean |
AsciiLogReader.newMonitoringRecord(IMonitoringRecord record)
This method is called for each new record by each ReaderThread.
|
boolean |
BinaryLogReader.newMonitoringRecord(IMonitoringRecord record)
This method is called for each new record by each ReaderThread.
|
Modifier and Type | Method and Description |
---|---|
boolean |
PipeReader.newMonitoringRecord(IMonitoringRecord rec)
This method sends a given records directly to the output port.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.List<IMonitoringRecord> |
BinaryDeserializer.decodeRecords(java.nio.ByteBuffer buffer,
int dataSize) |
protected abstract java.util.List<IMonitoringRecord> |
AbstractContainerFormatDeserializer.decodeRecords(java.nio.ByteBuffer buffer,
int dataSize)
Decodes the records from the container's payload.
|
java.util.List<IMonitoringRecord> |
IMonitoringRecordDeserializer.deserializeRecords(java.nio.ByteBuffer buffer,
int dataSize)
Deserializes the records contained in the given buffer.
|
java.util.List<IMonitoringRecord> |
AbstractContainerFormatDeserializer.deserializeRecords(java.nio.ByteBuffer buffer,
int dataSize) |
Modifier and Type | Method and Description |
---|---|
void |
SingleSocketTcpReader.onRecordReceived(IMonitoringRecord record) |
protected abstract void |
AbstractRecordTcpReader.onRecordReceived(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
boolean |
IMonitoringRecordReceiver.newMonitoringRecord(IMonitoringRecord record)
This method is called for each new record by each ReaderThread.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.Class<? extends IMonitoringRecord>,java.lang.Integer> |
NullStage.getTypes() |
Modifier and Type | Method and Description |
---|---|
protected void |
DataSinkStage.execute(IMonitoringRecord record) |
protected void |
NullStage.execute(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
teetime.framework.OutputPort<IMonitoringRecord> |
ISourceCompositeStage.getOutputPort()
get the output port of a source composite stage.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractEventDeserializer.processDataStream(java.io.InputStream chainInputStream,
teetime.framework.OutputPort<IMonitoringRecord> outputPort)
Read an input stream of data, deserialize it and output proper monitoring records.
|
void |
BinaryEventDeserializer.processDataStream(java.io.InputStream chainInputStream,
teetime.framework.OutputPort<IMonitoringRecord> outputPort) |
void |
DatEventDeserializer.processDataStream(java.io.InputStream inputStream,
teetime.framework.OutputPort<IMonitoringRecord> outputPort) |
Modifier and Type | Method and Description |
---|---|
void |
ITraceMetadataRewriter.rewrite(Connection connection,
IMonitoringRecord record,
long loggingTimestamp,
teetime.framework.OutputPort<IMonitoringRecord> outputPort)
Rewrite a record if necessary.
|
void |
PlainTraceMetadataRewriter.rewrite(Connection connection,
IMonitoringRecord record,
long loggingTimestamp,
teetime.framework.OutputPort<IMonitoringRecord> outputPort)
Trace data records use unique ids for their respective host.
|
void |
NoneTraceMetadataRewriter.rewrite(Connection connection,
IMonitoringRecord record,
long loggingTimestamp,
teetime.framework.OutputPort<IMonitoringRecord> outputPort) |
Modifier and Type | Method and Description |
---|---|
void |
ITraceMetadataRewriter.rewrite(Connection connection,
IMonitoringRecord record,
long loggingTimestamp,
teetime.framework.OutputPort<IMonitoringRecord> outputPort)
Rewrite a record if necessary.
|
void |
PlainTraceMetadataRewriter.rewrite(Connection connection,
IMonitoringRecord record,
long loggingTimestamp,
teetime.framework.OutputPort<IMonitoringRecord> outputPort)
Trace data records use unique ids for their respective host.
|
void |
NoneTraceMetadataRewriter.rewrite(Connection connection,
IMonitoringRecord record,
long loggingTimestamp,
teetime.framework.OutputPort<IMonitoringRecord> outputPort) |
Modifier and Type | Method and Description |
---|---|
teetime.framework.InputPort<IMonitoringRecord> |
AnalysisThroughputFilter.getRecordsInputPort() |
teetime.framework.OutputPort<IMonitoringRecord> |
AnalysisThroughputFilter.getRecordsOutputPort() |
Modifier and Type | Method and Description |
---|---|
teetime.framework.OutputPort<IMonitoringRecord> |
MonitoringThroughputFilter.getRelayedRecordsOutputPort() |
teetime.framework.OutputPort<IMonitoringRecord> |
MonitoringThroughputFilter.getUncountedRecordsOutputPort() |
Modifier and Type | Method and Description |
---|---|
protected void |
MonitoringThroughputFilter.execute(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
teetime.framework.InputPort<IMonitoringRecord> |
RealtimeRecordDelayFilter.getInputPort() |
teetime.framework.OutputPort<IMonitoringRecord> |
RealtimeRecordDelayFilter.getOutputPort() |
Modifier and Type | Method and Description |
---|---|
protected void |
RealtimeRecordDelayConsumer.execute(IMonitoringRecord monitoringRecord) |
Modifier and Type | Method and Description |
---|---|
teetime.framework.InputPort<IMonitoringRecord> |
TimestampFilter.getMonitoringRecordsCombinedInputPort()
Returns the input port for the records.
|
teetime.framework.OutputPort<IMonitoringRecord> |
TimestampFilter.getRecordsOutsideTimePeriodOutputPort()
Returns the output port for the records whose timestamps are outside the defined time period.
|
teetime.framework.OutputPort<IMonitoringRecord> |
TimestampFilter.getRecordsWithinTimePeriodOutputPort()
Returns the output port for the records whose timestamps are within the defined time period.
|
Modifier and Type | Method and Description |
---|---|
protected long |
MonitioringRecordTimestampFilter.getRecordSpecificTimestamp(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
teetime.framework.OutputPort<IMonitoringRecord> |
TraceIdFilter.getMatchingTraceIdOutputPort() |
teetime.framework.OutputPort<IMonitoringRecord> |
TraceIdFilter.getMismatchingTraceIdOutputPort() |
teetime.framework.InputPort<IMonitoringRecord> |
TraceIdFilter.getMonitoringRecordsCombinedInputPort() |
Modifier and Type | Method and Description |
---|---|
void |
IRecordReceivedListener.onRecordReceived(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
void |
AMQPReader.deliverRecord(IMonitoringRecord monitoringRecord) |
void |
RegularRecordHandler.onRecordReceived(IMonitoringRecord record) |
Constructor and Description |
---|
AMQPReader(java.lang.String uri,
java.lang.String queueName,
int heartbeat,
java.util.function.Consumer<IMonitoringRecord> elementReceivedCallback)
Creates a new logic module for an AMQP reader.
|
Modifier and Type | Method and Description |
---|---|
teetime.framework.OutputPort<IMonitoringRecord> |
Dir2RecordsFilter.getOutputPort()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
teetime.framework.OutputPort<IMonitoringRecord> |
DirWithBin2RecordFilter.getOutputPort()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
teetime.framework.OutputPort<IMonitoringRecord> |
BinaryFile2RecordFilter.getOutputPort()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
RecordFromBinaryFileCreator.createRecordsFromBinaryFile(java.io.File binaryFile,
java.io.DataInputStream inputStream,
teetime.framework.OutputPort<IMonitoringRecord> outputPort)
Deprecated.
Create records from binary files.
|
Modifier and Type | Method and Description |
---|---|
IMonitoringRecord |
RecordFromTextLineCreator.createRecordFromLine(java.io.File textFile,
java.lang.String line)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
teetime.framework.OutputPort<IMonitoringRecord> |
TextLine2RecordFilter.getOutputPort()
Deprecated.
|
teetime.framework.OutputPort<IMonitoringRecord> |
DatFile2RecordFilter.getOutputPort()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
FSReader.newMonitoringRecord(IMonitoringRecord record)
Deprecated.
|
boolean |
AsciiLogReader.newMonitoringRecord(IMonitoringRecord record)
Deprecated.
This method is called for each new record by each ReaderThread.
|
boolean |
BinaryLogReader.newMonitoringRecord(IMonitoringRecord record)
Deprecated.
This method is called for each new record by each ReaderThread.
|
Constructor and Description |
---|
JMSReader(java.lang.String jmsProviderUrl,
java.lang.String jmsDestination,
java.lang.String jmsFactoryLookupName,
java.util.function.Consumer<IMonitoringRecord> elementReceivedCallback)
Creates a new logic module for the Consumer.
|
Modifier and Type | Method and Description |
---|---|
boolean |
PipeReader.newMonitoringRecord(IMonitoringRecord rec)
This method sends a given records directly to the output port.
|
Modifier and Type | Method and Description |
---|---|
void |
SingleSocketTcpReaderStage.onRecordReceived(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
teetime.framework.InputPort<IMonitoringRecord> |
AllowedRecordsFilter.getInputPort() |
teetime.framework.OutputPort<IMonitoringRecord> |
ReadingComposite.getOutputPort()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
BeginEndOfMonitoringDetector.execute(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
boolean |
IPipeReader.newMonitoringRecord(IMonitoringRecord record)
Called for each new record.
|
boolean |
Pipe.writeMonitoringRecord(IMonitoringRecord monitoringRecord)
Passes the monitoring record to the registered pipe reader.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMonitoringRecord |
Modifier and Type | Method and Description |
---|---|
static IMonitoringRecord |
AbstractMonitoringRecord.createFromDeserializer(java.lang.String recordClassName,
IValueDeserializer deserializer)
Create monitoring record based on class name and a given value deserializer.
|
Modifier and Type | Method and Description |
---|---|
static java.lang.Class<? extends IMonitoringRecord> |
AbstractMonitoringRecord.classForName(java.lang.String classname)
This method tries to find a monitoring record class with the given name.
|
Modifier and Type | Method and Description |
---|---|
int |
AbstractMonitoringRecord.compareTo(IMonitoringRecord otherRecord)
Provides an ordering of IMonitoringRecords by the loggingTimestamp.
|
void |
IRecordReceivedListener.onRecordReceived(IMonitoringRecord record)
Listener method.
|
Modifier and Type | Method and Description |
---|---|
static java.lang.Class<?>[] |
AbstractMonitoringRecord.typesForClass(java.lang.Class<? extends IMonitoringRecord> clazz)
This method delivers the types array of the given class, either by finding the declared field (in case of a factory record) or via the
getValueTypes
method. |
Modifier and Type | Class and Description |
---|---|
class |
BranchingRecord |
class |
OperationExecutionRecord |
Modifier and Type | Class and Description |
---|---|
class |
AfterDatabaseEvent |
class |
BeforeDatabaseEvent |
class |
DatabaseFailedEvent |
Modifier and Type | Method and Description |
---|---|
IRecordFactory<? extends IMonitoringRecord> |
CachedRecordFactoryCatalog.get(java.lang.String recordClassName)
Hint: This method uses convention over configuration when searching for a record factory class.
|
IRecordFactory<? extends IMonitoringRecord> |
RecordFactoryResolver.get(java.lang.String recordClassName) |
Modifier and Type | Interface and Description |
---|---|
interface |
ICallObjectRecord |
interface |
ICallRecord |
interface |
IClassSignature |
interface |
IConstructorRecord |
interface |
IEventRecord |
interface |
IExceptionRecord |
interface |
IFlowRecord |
interface |
IInterfaceRecord |
interface |
IObjectRecord |
interface |
IOperationRecord |
interface |
IOperationSignature |
interface |
IThreadBasedRecord |
interface |
ITraceRecord |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEvent |
Modifier and Type | Class and Description |
---|---|
class |
AbstractThreadBasedEvent |
class |
AfterFailedThreadBasedEvent |
class |
AfterThreadBasedEvent |
class |
BeforeThreadBasedEvent |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTraceEvent |
class |
ApplicationTraceMetadata |
class |
BeforeReceivedRemoteEvent |
class |
BeforeSentRemoteEvent |
class |
ConstructionEvent |
class |
TraceMetadata |
Modifier and Type | Class and Description |
---|---|
class |
JoinEvent |
class |
SplitEvent |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMonitorEvent |
class |
MonitorEntryEvent |
class |
MonitorExitEvent |
class |
MonitorNotifyAllEvent |
class |
MonitorNotifyEvent |
class |
MonitorRequestEvent |
class |
MonitorWaitEvent |
Modifier and Type | Class and Description |
---|---|
class |
AbstractOperationEvent |
class |
AfterOperationEvent |
class |
AfterOperationFailedEvent |
class |
BeforeOperationEvent |
class |
CallOperationEvent |
Modifier and Type | Class and Description |
---|---|
class |
AfterConstructorEvent |
class |
AfterConstructorFailedEvent |
class |
BeforeConstructorEvent |
class |
CallConstructorEvent |
Modifier and Type | Class and Description |
---|---|
class |
AfterConstructorFailedObjectEvent |
class |
AfterConstructorObjectEvent |
class |
BeforeConstructorObjectEvent |
class |
BeforeConstructorObjectInterfaceEvent |
class |
CallConstructorObjectEvent |
Modifier and Type | Class and Description |
---|---|
class |
AfterOperationFailedObjectEvent |
class |
AfterOperationObjectEvent |
class |
BeforeOperationObjectEvent |
class |
BeforeOperationObjectInterfaceEvent |
class |
CallOperationObjectEvent |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJVMRecord |
class |
ClassLoadingRecord |
class |
CompilationRecord |
class |
GCRecord |
class |
MemoryRecord |
class |
ThreadsStatusRecord |
class |
UptimeRecord |
Modifier and Type | Class and Description |
---|---|
class |
EmptyRecord |
class |
HostApplicationMetaData |
class |
KiekerMetadataRecord |
class |
RegistryRecord
Record used to associate Objects (typically Strings) with unique ids.
|
class |
ThreadMetaData |
class |
TimestampRecord |
Modifier and Type | Interface and Description |
---|---|
interface |
IParameterValueEvent |
interface |
IRemoteControlEvent |
interface |
IRemoteParameterControlEvent |
Modifier and Type | Class and Description |
---|---|
class |
ActivationEvent |
class |
ActivationParameterEvent |
class |
AddParameterValueEvent |
class |
DeactivationEvent |
class |
RemoveParameterValueEvent |
class |
UpdateParameterEvent |
Modifier and Type | Class and Description |
---|---|
class |
CPUUtilizationRecord |
class |
DiskUsageRecord |
class |
LoadAverageRecord |
class |
MemSwapUsageRecord |
class |
NetworkUtilizationRecord |
class |
ResourceUtilizationRecord |
Modifier and Type | Method and Description |
---|---|
boolean |
IMonitoringRecordReceiver.newMonitoringRecord(IMonitoringRecord record)
Called for each new record.
|
Modifier and Type | Method and Description |
---|---|
boolean |
WriterController.newMonitoringRecord(IMonitoringRecord record) |
boolean |
MonitoringController.newMonitoringRecord(IMonitoringRecord record) |
boolean |
IWriterController.newMonitoringRecord(IMonitoringRecord record)
Called for each new record to write it out to the pre-configured target (e.g., file system, database, or messaging queue).
|
Modifier and Type | Method and Description |
---|---|
void |
MonitoringCommandListener.onRecordReceived(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
boolean |
BypassQueueBehavior.insert(IMonitoringRecord element) |
Modifier and Type | Method and Description |
---|---|
protected IMonitoringRecord[] |
ThreadsStatusSampler.createNewMonitoringRecords(long timestamp,
java.lang.String hostname,
java.lang.String vmName,
IMonitoringController monitoringCtr) |
protected IMonitoringRecord[] |
CompilationSampler.createNewMonitoringRecords(long timestamp,
java.lang.String hostname,
java.lang.String vmName,
IMonitoringController monitoringCtr) |
protected IMonitoringRecord[] |
MemorySampler.createNewMonitoringRecords(long timestamp,
java.lang.String hostname,
java.lang.String vmName,
IMonitoringController monitoringCtr) |
protected abstract IMonitoringRecord[] |
AbstractMXBeanSampler.createNewMonitoringRecords(long timestamp,
java.lang.String hostname,
java.lang.String vmName,
IMonitoringController monitoringCtr)
Abstract method used as interface to realize concrete samplers.
|
protected IMonitoringRecord[] |
GCSampler.createNewMonitoringRecords(long timestamp,
java.lang.String hostname,
java.lang.String vmName,
IMonitoringController monitoringCtr) |
protected IMonitoringRecord[] |
ClassLoadingSampler.createNewMonitoringRecords(long timestamp,
java.lang.String hostname,
java.lang.String vmName,
IMonitoringController monitoringCtr) |
protected IMonitoringRecord[] |
UptimeSampler.createNewMonitoringRecords(long timestamp,
java.lang.String hostname,
java.lang.String vmName,
IMonitoringController monitoringCtr) |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractMonitoringWriter.writeMonitoringRecord(IMonitoringRecord record)
This event fires when Kieker has received a new record.
|
Constructor and Description |
---|
MonitoringWriterThread(AbstractMonitoringWriter writer,
java.util.concurrent.BlockingQueue<IMonitoringRecord> writerQueue) |
Modifier and Type | Method and Description |
---|---|
void |
AmqpWriter.writeMonitoringRecord(IMonitoringRecord monitoringRecord) |
Modifier and Type | Method and Description |
---|---|
java.util.Queue<IMonitoringRecord> |
ChunkingCollector.getRecordQueue() |
Modifier and Type | Method and Description |
---|---|
void |
ChunkingCollector.writeMonitoringRecord(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
void |
DumpWriter.writeMonitoringRecord(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
void |
ExplorVizTcpWriter.writeMonitoringRecord(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractLogStreamHandler.serialize(IMonitoringRecord record,
int id)
Serialize a record.
|
void |
BinaryLogStreamHandler.serialize(IMonitoringRecord record,
int id) |
void |
TextLogStreamHandler.serialize(IMonitoringRecord record,
int id) |
void |
FileWriter.writeMonitoringRecord(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
void |
JmsWriter.writeMonitoringRecord(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
boolean |
KiekerJmxMonitoringLog.newMonitoringRecord(IMonitoringRecord record)
Consumes the given record by sending a notification.
|
void |
JmxWriter.writeMonitoringRecord(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
void |
PipeWriter.writeMonitoringRecord(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
void |
PrintStreamWriter.writeMonitoringRecord(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
int |
AbstractContainerFormatSerializer.serializeRecord(IMonitoringRecord record,
java.nio.ByteBuffer buffer) |
int |
IMonitoringRecordSerializer.serializeRecord(IMonitoringRecord record,
java.nio.ByteBuffer buffer)
Serializes a single record into the given byte buffer.
|
int |
StringSerializer.serializeRecord(IMonitoringRecord record,
java.nio.ByteBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
int |
AbstractContainerFormatSerializer.serializeRecords(java.util.Collection<IMonitoringRecord> records,
java.nio.ByteBuffer buffer) |
int |
IMonitoringRecordSerializer.serializeRecords(java.util.Collection<IMonitoringRecord> records,
java.nio.ByteBuffer buffer)
Serializes multiple monitoring records into the given byte buffer.
|
int |
StringSerializer.serializeRecords(java.util.Collection<IMonitoringRecord> records,
java.nio.ByteBuffer buffer) |
protected abstract int |
AbstractContainerFormatSerializer.writeRecords(java.util.Collection<IMonitoringRecord> records,
java.nio.ByteBuffer buffer)
Write the given records to the given byte buffer.
|
protected int |
BinarySerializer.writeRecords(java.util.Collection<IMonitoringRecord> records,
java.nio.ByteBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
SingleSocketTcpWriter.writeMonitoringRecord(IMonitoringRecord monitoringRecord) |
void |
DualSocketTcpWriter.writeMonitoringRecord(IMonitoringRecord monitoringRecord) |
Modifier and Type | Method and Description |
---|---|
void |
CurrentTimeEventGenerationFilter.inputRecord(IMonitoringRecord record)
This method represents the input port for new records.
|
Modifier and Type | Method and Description |
---|---|
teetime.framework.OutputPort<IMonitoringRecord> |
MultipleConnectionTcpSourceCompositeStage.getOutputPort() |
teetime.framework.OutputPort<IMonitoringRecord> |
RestServiceCompositeStage.getOutputPort() |
teetime.framework.OutputPort<IMonitoringRecord> |
LogsReaderCompositeStage.getOutputPort() |
Modifier and Type | Method and Description |
---|---|
protected void |
RecordCurrentTimeEventGenerationFilter.execute(IMonitoringRecord record)
Evaluates the given timestamp internal current time which may lead to
newly generated events via currentTimeRecordOutputPort.
|
Copyright 2020 Kieker Project, http://kieker-monitoring.net