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 |
TimestampFilter.inputCombined(IMonitoringRecord record) |
void |
TraceIdFilter.inputCombined(IMonitoringRecord record)
This method represents an input port for both operation execution and flow records.
|
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 |
---|---|
protected abstract void |
AbstractRecordTcpReader.onRecordReceived(IMonitoringRecord record) |
void |
SingleSocketTcpReader.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.
|
void |
IRecordReceivedListener.onRecordReceived(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.
|
void |
IPipeWriter.writeMonitoringRecord(IMonitoringRecord record)
Deprecated.
Called for each new record.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMonitoringRecord |
Modifier and Type | Method and Description |
---|---|
static IMonitoringRecord |
AbstractMonitoringRecord.createFromArray(java.lang.Class<? extends IMonitoringRecord> clazz,
java.lang.Object[] values)
This method creates a new monitoring record from the given data.
|
static IMonitoringRecord |
AbstractMonitoringRecord.createFromArray(java.lang.String recordClassName,
java.lang.Object[] values) |
static IMonitoringRecord |
AbstractMonitoringRecord.createFromDeserializer(java.lang.String recordClassName,
IValueDeserializer deserializer) |
static IMonitoringRecord |
AbstractMonitoringRecord.createFromStringArray(java.lang.Class<? extends IMonitoringRecord> clazz,
java.lang.String[] values)
This method creates a new monitoring record from the given data encoded in strings.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static IMonitoringRecord |
AbstractMonitoringRecord.createFromArray(java.lang.Class<? extends IMonitoringRecord> clazz,
java.lang.Object[] values)
This method creates a new monitoring record from the given data.
|
static IMonitoringRecord |
AbstractMonitoringRecord.createFromStringArray(java.lang.Class<? extends IMonitoringRecord> clazz,
java.lang.String[] values)
This method creates a new monitoring record from the given data encoded in strings.
|
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 | Method and Description |
---|---|
IRecordFactory<? extends IMonitoringRecord> |
RecordFactoryResolver.get(java.lang.String recordClassName) |
IRecordFactory<? extends IMonitoringRecord> |
CachedRecordFactoryCatalog.get(java.lang.String recordClassName)
Hint: This method uses convention over configuration when searching for a record factory class.
|
Modifier and Type | Method and Description |
---|---|
IMonitoringRecord |
RecordFactoryWrapper.create(IValueDeserializer deserializer) |
IMonitoringRecord |
RecordFactoryWrapper.create(java.lang.Object[] values) |
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 |
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 | 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 |
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).
|
boolean |
WriterController.newMonitoringRecord(IMonitoringRecord record) |
Modifier and Type | Method and Description |
---|---|
boolean |
BypassQueueBehavior.insert(IMonitoringRecord element) |
Modifier and Type | Method and Description |
---|---|
protected IMonitoringRecord[] |
GCSampler.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) |
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[] |
CompilationSampler.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[] |
ThreadsStatusSampler.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 |
---|---|
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 |
---|---|
void |
BinaryFileWriter.writeMonitoringRecord(IMonitoringRecord monitoringRecord) |
void |
AsciiFileWriter.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 |
StringSerializer.serializeRecord(IMonitoringRecord record,
java.nio.ByteBuffer buffer) |
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.
|
Modifier and Type | Method and Description |
---|---|
int |
StringSerializer.serializeRecords(java.util.Collection<IMonitoringRecord> records,
java.nio.ByteBuffer buffer) |
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.
|
protected int |
BinarySerializer.writeRecords(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.
|
Modifier and Type | Method and Description |
---|---|
void |
DualSocketTcpWriter.writeMonitoringRecord(IMonitoringRecord monitoringRecord) |
void |
SingleSocketTcpWriter.writeMonitoringRecord(IMonitoringRecord monitoringRecord) |
void |
TCPWriter.writeMonitoringRecord(IMonitoringRecord monitoringRecord)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
java.lang.reflect.Constructor<? extends IMonitoringRecord> |
LookupEntity.getConstructor() |
Constructor and Description |
---|
LookupEntity(java.lang.reflect.Constructor<? extends IMonitoringRecord> constructor,
java.lang.Class<?>[] parameterTypes)
Construct one new LookupEntry.
|
Modifier and Type | Method and Description |
---|---|
IMonitoringRecord |
IServiceConnector.deserializeNextRecord()
The deserialize method reads source data and returns an
IMonitoringRecord . |
Modifier and Type | Method and Description |
---|---|
static java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> |
ServiceConnectorFactory.createLookupEntityMap(java.util.concurrent.ConcurrentMap<java.lang.Integer,java.lang.Class<? extends IMonitoringRecord>> recordMap)
Calculates the lookup table from the record map.
|
Modifier and Type | Method and Description |
---|---|
IMonitoringRecord |
HTTPConnector.deserializeNextRecord() |
Modifier and Type | Method and Description |
---|---|
IMonitoringRecord |
JMSClientConnector.deserializeNextRecord()
Fetch a text or binary message from the JMS queue and use the correct
deserializer for the received message.
|
Modifier and Type | Method and Description |
---|---|
IMonitoringRecord |
TCPMultiServerConnector.deserializeNextRecord()
Implements the deserializeNextRecord interface.
|
IMonitoringRecord |
TCPSingleServerConnector.deserializeNextRecord()
De-serialize an object reading from the input stream.
|
IMonitoringRecord |
TCPClientConnector.deserializeNextRecord()
De-serialize an object reading from the input stream.
|
Constructor and Description |
---|
TCPMultiServerConnectionRunnable(java.net.Socket socket,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap,
java.util.concurrent.BlockingQueue<IMonitoringRecord> recordQueue)
Create a service thread.
|
TCPMultiServerPortListenerRunnable(int port,
java.util.concurrent.BlockingQueue<IMonitoringRecord> recordQueue,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap,
java.util.concurrent.ExecutorService executor)
Create a listener for the incoming port of the multi server.
|
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 |
---|---|
void |
MonitoringRecordLoggerFilter.inputIMonitoringRecord(IMonitoringRecord record)
This method represents the input port.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationWindow |
class |
ExtendedStorableDetectionResult |
class |
NamedDoubleRecord |
class |
NamedTSPoint |
class |
StorableDetectionResult |
Copyright 2017 Kieker Project, http://kieker-monitoring.net