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