| Package | Description | 
|---|---|
| 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.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.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.source.file | |
| kieker.analysis.source.tcp | |
| kieker.analysisteetime.plugin.reader | 
 Contains reader implementations using several different technologies. 
 | 
| kieker.analysisteetime.plugin.reader.amqp | |
| kieker.analysisteetime.plugin.reader.filesystem.className | |
| kieker.common.record.io | 
 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.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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ReaderRegistry<java.lang.String> | 
StringRegistryCache.getOrCreateRegistry(java.lang.Long registryId)
Retrieves the registry with the given ID and creates a new one if necessary. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected com.google.common.cache.Cache<java.lang.Long,ReaderRegistry<java.lang.String>> | 
StringRegistryCache.createCache(long expirationDuration,
           java.util.concurrent.TimeUnit expirationTimeUnit)
Creates the underlying cache. 
 | 
| Constructor and Description | 
|---|
BinaryFileStreamProcessor(ReaderRegistry<java.lang.String> stringRegistry,
                         IMonitoringRecordReceiver recordReceiver)
Create a binary file stream processor. 
 | 
TextFileStreamProcessor(boolean ignoreUnknownRecordTypes,
                       ReaderRegistry<java.lang.String> stringRegistry,
                       IMonitoringRecordReceiver recordReceiver)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DeserializerStringRegistry
Rudimentary string registry for use by the binary format decoder. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected AbstractRecordTcpReader | 
DualSocketTcpReader.createTcpMonitoringRecordReader(int port,
                               int bufferCapacity,
                               org.slf4j.Logger logger,
                               ReaderRegistry<java.lang.String> registry)  | 
| Constructor and Description | 
|---|
AbstractRecordTcpReader(int port,
                       int bufferCapacity,
                       org.slf4j.Logger logger,
                       ReaderRegistry<java.lang.String> stringRegistry,
                       CachedRecordFactoryCatalog recordFactories)  | 
AbstractRecordTcpReader(org.slf4j.Logger logger,
                       ReaderRegistry<java.lang.String> stringRegistry)
Default constructor with  
port=10133 and bufferCapacity=65535 and new CachedRecordFactoryCatalog(). | 
| Constructor and Description | 
|---|
ByteBufferDeserializer(ReaderRegistry<java.lang.String> readerRegistry,
                      org.slf4j.Logger logger,
                      int bufferCapacity)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected ReaderRegistry<java.lang.String> | 
AbstractEventDeserializer.registry  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TextMapDeserializer.processDataStream(java.io.InputStream inputStream,
                 ReaderRegistry<java.lang.String> registry,
                 java.lang.String mapFileName)  | 
abstract void | 
AbstractMapDeserializer.processDataStream(java.io.InputStream inputStream,
                 ReaderRegistry<java.lang.String> registry,
                 java.lang.String mapFileName)
Read a string map from an input stream and initialize the specified registry with the values. 
 | 
| Constructor and Description | 
|---|
AbstractEventDeserializer(Configuration configuration,
                         ReaderRegistry<java.lang.String> registry)
Create an abstract event deserializer. 
 | 
BinaryEventDeserializer(Configuration configuration,
                       ReaderRegistry<java.lang.String> registry)  | 
DatEventDeserializer(Configuration configuration,
                    ReaderRegistry<java.lang.String> registry)  | 
| Modifier and Type | Method and Description | 
|---|---|
ReaderRegistry<java.lang.String> | 
Connection.getRegistry()  | 
| Constructor and Description | 
|---|
RecordDeserializer(IRecordReceivedListener listener,
                  ReaderRegistry<java.lang.String> registry)  | 
| Constructor and Description | 
|---|
RegistryRecordHandler(ReaderRegistry<java.lang.String> stringRegistry)
Creates a new registry record handler for the given registry. 
 | 
RegularRecordHandler(AMQPReader readerLogic,
                    ReaderRegistry<java.lang.String> stringRegistry)
Creates a new regular record handler. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ReaderRegistry<java.lang.String> | 
ClassNameRegistryRepository.get(java.io.File directory)
Deprecated.  
  | 
ReaderRegistry<java.lang.String> | 
MappingFileParser.parseFromStream(java.io.InputStream inputStream)
Deprecated.  
Closes the stream after reading. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClassNameRegistryRepository.put(java.io.File directory,
   ReaderRegistry<java.lang.String> registry)
Deprecated.  
  | 
| Modifier and Type | Method and Description | 
|---|---|
static BinaryValueDeserializer | 
BinaryValueDeserializer.create(java.nio.ByteBuffer buffer,
      ReaderRegistry<java.lang.String> stringRegistry)
Factory method to create a binary value deserializer. 
 | 
| Constructor and Description | 
|---|
BinaryValueDeserializer(java.nio.ByteBuffer buffer,
                       ReaderRegistry<java.lang.String> stringRegistry)
Create a binary value deserializer. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
RegistryRecord.registerRecordInRegistry(java.nio.ByteBuffer buffer,
                        ReaderRegistry<java.lang.String> stringRegistry)
Static function used to register strings stored in a byte buffer as string in the string registry with the proper id. 
 | 
Copyright 2020 Kieker Project, http://kieker-monitoring.net