Index

A B C D E F G H I J K L M N O P R S T U V W Y
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

K

KAFKA_CONSUMER_GROUP_ID_PROP_NAME - Static variable in class org.eso.ias.converter.ConverterKafkaStream

The name of the property to customize the group id of the consumer

KAFKA_SERVERS_PROP_NAME - Static variable in class org.eso.ias.converter.ConverterKafkaStream

The name of the property to pass the kafka servers to connect to

KAFKA_TOPIC_PROP_NAME - Static variable in class org.eso.ias.plugin.publisher.impl.KafkaPublisher

The name of the java property to set the kafka topic.

KafkaHelper - Class in org.eso.ias.kafkautils

A helper class providing useful methods and constants for Kafka

KafkaHelper() - Constructor for class org.eso.ias.kafkautils.KafkaHelper

KafkaIasiosConsumer - Class in org.eso.ias.kafkautils

Extends SimpleKafkaIasiosConsumer providing filtering by IDs and types.

KafkaIasiosConsumer(String, String, String, Set<String>, Set<IASTypes>) - Constructor for class org.eso.ias.kafkautils.KafkaIasiosConsumer

Build a FilteredStringConsumer with the passed initial filters.

KafkaIasiosProducer - Class in org.eso.ias.kafkautils

KafkaIasioProducer writes IASValue in the kafka topic by delegating to SimpleStringProducer

KafkaIasiosProducer(SimpleStringProducer, String, IasValueStringSerializer) - Constructor for class org.eso.ias.kafkautils.KafkaIasiosProducer

Build a KafkaIasioProducer.

KafkaPublisher - Class in org.eso.ias.plugin.publisher.impl

The publisher of monitor point values through Kafka.

KafkaPublisher(String, String, SimpleStringProducer, ScheduledExecutorService) - Constructor for class org.eso.ias.plugin.publisher.impl.KafkaPublisher

Constructor

KafkaSinkConnectorConfig - Class in org.eso.ias.monitor

The configuration of kafka sink conenctor to monitor These kind of connectors do not pubish HBs and must be monitored with the REST API provided by kafka

KafkaSinkConnectorConfig() - Constructor for class org.eso.ias.monitor.KafkaSinkConnectorConfig

Empty constructor

KafkaSinkConnectorConfig(String, int, String) - Constructor for class org.eso.ias.monitor.KafkaSinkConnectorConfig

Construcotr

kafkaSinkConnectors - Variable in class org.eso.ias.monitor.IasMonitorConfig

The KAFKA Sink connectors to monitor These are monitored though the REST API

KafkaStringsConsumer - Class in org.eso.ias.kafkautils

A generic kafka consumer that forwards all the strings received in each message to the listener.

KafkaStringsConsumer(String, String, String) - Constructor for class org.eso.ias.kafkautils.KafkaStringsConsumer

Constructor

KafkaStringsConsumer.StreamPosition - Enum Class in org.eso.ias.kafkautils

The start position when connecting to a kafka topic for reading strings

KafkaStringsConsumer.StringsConsumer - Interface in org.eso.ias.kafkautils

The interface for the listener of strings

KafkaUtilsException - Exception in org.eso.ias.kafkautils

Exception retunrd by classes in KafkaUtils module

KafkaUtilsException() - Constructor for exception org.eso.ias.kafkautils.KafkaUtilsException

Constructor

KafkaUtilsException(String) - Constructor for exception org.eso.ias.kafkautils.KafkaUtilsException

KafkaUtilsException(String, Throwable) - Constructor for exception org.eso.ias.kafkautils.KafkaUtilsException

KafkaUtilsException(String, Throwable, boolean, boolean) - Constructor for exception org.eso.ias.kafkautils.KafkaUtilsException

KafkaUtilsException(Throwable) - Constructor for exception org.eso.ias.kafkautils.KafkaUtilsException

keepNewest(int) - Method in class org.eso.ias.plugin.filter.FilterBase

Remove the last nSamples from the history until it contains only nSamples samples.

A B C D E F G H I J K L M N O P R S T U V W Y
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form