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

S

Sample - Class in org.eso.ias.plugin
A sample of the value read from the remote system.
Sample(Object) - Constructor for class org.eso.ias.plugin.Sample
Constructor
Sample(Object, long) - Constructor for class org.eso.ias.plugin.Sample
Constructor.
sampleAdded(Filter.EnrichedSample) - Method in class org.eso.ias.plugin.filter.AverageBySamples
Adds a new sample
sampleAdded(Filter.EnrichedSample) - Method in class org.eso.ias.plugin.filter.AverageByTime
Adds a new sample
sampleAdded(Filter.EnrichedSample) - Method in class org.eso.ias.plugin.filter.FilterBase
sampleAdded is executed after adding the sample to the history to let the implementation of a filter does any computation it might need.
sampleAdded(Filter.EnrichedSample) - Method in class org.eso.ias.plugin.filter.NoneFilter
 
samples - Variable in class org.eso.ias.plugin.filter.FilteredValue
The samples used by the filter to generate the filtered value.
sampleTime - Variable in class org.eso.ias.plugin.publisher.MonitorPointDataToBuffer
The point in time when the value has been provided by the monitored system.
SCALA - Enum constant in enum class org.eso.ias.cdb.pojos.TFLanguageDao
 
schedExecutorPoolSize - Static variable in class org.eso.ias.plugin.Plugin
The number of threads in the scheduled pool executor that get filtered values out of the monitored values
schedExecutorSvc - Static variable in class org.eso.ias.plugin.Plugin
The scheduled executor service
SCHEDULED_POOL_SIZE_PROPNAME - Static variable in class org.eso.ias.plugin.Plugin
The property to let the use set the number of threads in the scheduled thread executor
seekIfOlderThan - Variable in class org.eso.ias.kafkautils.SimpleKafkaIasiosConsumer
If the difference (millisecs) between the timestamp of the records read from kafka topic and the actual time is greater than seekIfOlderThan, then the consumer seek to the end of topic
SeekIfOlderThanProName - Static variable in class org.eso.ias.kafkautils.SimpleKafkaIasiosConsumer
The property to set the number of milliseconds between the actual time and the time of the records and seek to the end of the topic
seekTo(KafkaStringsConsumer.StreamPosition) - Method in class org.eso.ias.kafkautils.KafkaStringsConsumer
Seek the consumer to the passed postion.
sendAsync(String, CommandType, List<String>, Map<String, String>) - Method in class org.eso.ias.command.CommandSender
Send a command asynchronously This method sends the commands but do not wait for the reception of the reply
senderFullRunningId - Variable in class org.eso.ias.command.CommandSender
The full running id of the sender
senderId - Variable in class org.eso.ias.command.CommandSender
The id of the sender
senderID - Variable in class org.eso.ias.webserversender.WebServerSender
The identifier of the sender
SenderStats(long, long, long, long, long) - Constructor for class org.eso.ias.plugin.publisher.MonitorPointSender.SenderStats
Constructor
sendMonitoredPointsToIas() - Method in class org.eso.ias.plugin.publisher.BufferedPublisherBase
Send the monitor points to the core of the IAS.
sendMonitoredPointsToIas() - Method in class org.eso.ias.plugin.publisher.PublisherBase
Send the monitor points to the core of the IAS.
sendSync(String, CommandType, List<String>, Map<String, String>, long, TimeUnit) - Method in class org.eso.ias.command.CommandSender
Send a command synchronously This method sends the commands and holds until receives the replay or a timeout elapses.
sentToBsdbTStamp - Variable in class org.eso.ias.types.IASValue
The point in time when the value has been sent to the BSDB Note that this timestamp is set by the converter when it sends the converted value to the BSDB by the DASU when it publishes the output to the BSDB
sentToConverterTStamp - Variable in class org.eso.ias.types.IASValue
The point in time when the plugin sent the value to the converter
set() - Method in class org.eso.ias.types.Alarm
 
set() - Method in enum class org.eso.ias.types.AlarmState
The alarm is set (by the TF)
set(int, Number) - Method in class org.eso.ias.types.NumericArray
Return a new NumericArray with the passed value saved in the index position
set(String) - Method in enum class org.eso.ias.monitor.MonitorAlarm
Set an alarm This method can be called for each MonitorAlarm apart of GLOBAL whose clearing/setting is done by MonitorAlarm.getGlobalAlarm()
SET_ACK - Enum constant in enum class org.eso.ias.types.AlarmState
Alarm set and acknowledged
SET_LOG_LEVEL - Enum constant in enum class org.eso.ias.command.CommandType
 
SET_UNACK - Enum constant in enum class org.eso.ias.types.AlarmState
Alarm set and unacknowledged
setAsceIDs(Set<String>) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonDasuDao
Set the IDs of the ASCEs running in this DASU
setAutoSendTimeInterval(int) - Method in class org.eso.ias.plugin.config.PluginFileConfig
 
setBsdbUrl(String) - Method in class org.eso.ias.cdb.pojos.IasDao
 
setCanShelve(boolean) - Method in class org.eso.ias.cdb.pojos.IasioDao
 
setClassName(String) - Method in class org.eso.ias.cdb.pojos.TransferFunctionDao
 
setClientIds(Set<String>) - Method in class org.eso.ias.monitor.IasMonitorConfig
 
setCommand(CommandType) - Method in class org.eso.ias.command.CommandMessage
 
setCommand(CommandType) - Method in class org.eso.ias.command.ReplyMessage
 
setConfig(String) - Method in class org.eso.ias.cdb.pojos.ClientConfigDao
 
setConverterIds(Set<String>) - Method in class org.eso.ias.monitor.IasMonitorConfig
 
setCoreToolsIds(Set<String>) - Method in class org.eso.ias.monitor.IasMonitorConfig
 
setDasu(DasuDao) - Method in class org.eso.ias.cdb.pojos.AsceDao
 
setDasu(DasuDao) - Method in class org.eso.ias.cdb.pojos.DasuToDeployDao
 
setDasuId(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonDasuToDeployDao
 
setDasuID(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonAsceDao
Set the ID of the DASU
setDasusToDeploy(Set<DasuToDeployDao>) - Method in class org.eso.ias.cdb.pojos.SupervisorDao
 
setDasusToDeploy(Set<JsonDasuToDeployDao>) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonSupervisorDao
 
setDefaultFilter(String) - Method in class org.eso.ias.cdb.pojos.PluginConfigDao
 
setDefaultFilterOptions(String) - Method in class org.eso.ias.cdb.pojos.PluginConfigDao
 
setDepsFullRunningIds(Set<String>) - Method in class org.eso.ias.types.IasValueJsonPojo
 
setDestFullRunningId(String) - Method in class org.eso.ias.command.ReplyMessage
 
setDestId(String) - Method in class org.eso.ias.command.CommandMessage
 
setDocUrl(String) - Method in class org.eso.ias.cdb.pojos.IasioDao
 
setEmails(String) - Method in class org.eso.ias.cdb.pojos.IasioDao
 
setExcludedSupervisorIds(Set<String>) - Method in class org.eso.ias.monitor.IasMonitorConfig
 
setExitStatus(CommandExitStatus) - Method in class org.eso.ias.command.ReplyMessage
 
setFilter(String) - Method in class org.eso.ias.cdb.pojos.ValueDao
 
setFilter(Set<String>, Set<IASTypes>) - Method in class org.eso.ias.kafkautils.KafkaIasiosConsumer
Set the filtering to the passed set of IDs, discarding the existing filters, if any.
setFilteredTime(String) - Method in class org.eso.ias.plugin.publisher.MonitorPointDataToBuffer
Set the filtered timestamp
setFilterOptions(String) - Method in class org.eso.ias.cdb.pojos.ValueDao
 
setFullRunningId(String) - Method in class org.eso.ias.types.IasValueJsonPojo
 
setHbFrequency(int) - Method in class org.eso.ias.cdb.pojos.IasDao
 
setHbFrequency(int) - Method in class org.eso.ias.plugin.config.PluginFileConfig
 
setHbStringrepresentation(String) - Method in class org.eso.ias.heartbeat.serializer.HeartbeatMessagePojo
 
setHostName(String) - Method in class org.eso.ias.cdb.pojos.SupervisorDao
 
setHostName(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonSupervisorDao
 
setHostName(String) - Method in class org.eso.ias.monitor.KafkaSinkConnectorConfig
 
setIasio(IasioDao) - Method in class org.eso.ias.cdb.pojos.TemplateInstanceIasioDao
 
setIasioId(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonTemplatedInputsDao
Setter
setIasType(IasTypeDao) - Method in class org.eso.ias.cdb.pojos.IasioDao
 
setIasValidity(IasValidity) - Method in class org.eso.ias.types.IasValueJsonPojo
 
setId(long) - Method in class org.eso.ias.command.CommandMessage
 
setId(long) - Method in class org.eso.ias.command.ReplyMessage
 
setId(String) - Method in class org.eso.ias.cdb.pojos.AsceDao
 
setId(String) - Method in class org.eso.ias.cdb.pojos.ClientConfigDao
 
setId(String) - Method in class org.eso.ias.cdb.pojos.DasuDao
 
setId(String) - Method in class org.eso.ias.cdb.pojos.IasioDao
 
setId(String) - Method in class org.eso.ias.cdb.pojos.PluginConfigDao
Setter
setId(String) - Method in class org.eso.ias.cdb.pojos.SupervisorDao
 
setId(String) - Method in class org.eso.ias.cdb.pojos.TemplateDao
 
setId(String) - Method in class org.eso.ias.cdb.pojos.ValueDao
 
setId(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonAsceDao
 
setId(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonDasuDao
Set the ID of the DASU
setId(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonSupervisorDao
 
setId(String) - Method in class org.eso.ias.monitor.KafkaSinkConnectorConfig
 
setId(String) - Method in class org.eso.ias.plugin.publisher.MonitorPointDataToBuffer
Set the ID of the monitor point
setIf(boolean) - Method in class org.eso.ias.types.Alarm
Set or clear the alarm depending on the passed condition
setImplLang(TFLanguageDao) - Method in class org.eso.ias.cdb.pojos.TransferFunctionDao
 
setInputIDs(Set<String>) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonAsceDao
 
setInstance(int) - Method in class org.eso.ias.cdb.pojos.TemplateInstanceIasioDao
 
setInstance(Integer) - Method in class org.eso.ias.cdb.pojos.DasuToDeployDao
 
setInstance(Integer) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonDasuToDeployDao
 
setInstanceNum(int) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonTemplatedInputsDao
Setter
setKafkaSinkConnectors(Set<KafkaSinkConnectorConfig>) - Method in class org.eso.ias.monitor.IasMonitorConfig
 
setLogLevel(LogLevelDao) - Method in class org.eso.ias.cdb.pojos.DasuDao
 
setLogLevel(LogLevelDao) - Method in class org.eso.ias.cdb.pojos.IasDao
 
setLogLevel(LogLevelDao) - Method in class org.eso.ias.cdb.pojos.SupervisorDao
 
setLogLevel(LogLevelDao) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonDasuDao
Set the log level
setLogLevel(LogLevelDao) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonSupervisorDao
 
setLogLevel(CommandMessage) - Method in class org.eso.ias.command.DefaultCommandExecutor
The default implementation of the SET_LOG_LEVEL.
setMax(int) - Method in class org.eso.ias.cdb.pojos.TemplateDao
 
setMin(int) - Method in class org.eso.ias.cdb.pojos.TemplateDao
 
setMode(OperationalMode) - Method in class org.eso.ias.types.IasValueJsonPojo
 
setMonitoredSystemId(String) - Method in class org.eso.ias.cdb.pojos.PluginConfigDao
Setter
setMonitoredSystemID(String) - Method in class org.eso.ias.plugin.publisher.BufferedMonitoredSystemData
Setter
setMonitoredSystemID(String) - Method in class org.eso.ias.plugin.publisher.MonitorPointData
 
setMonitorPointId(String) - Method in class org.eso.ias.plugin.network.MessageDao
 
setMonitorPointRefreshRate(String, long) - Method in class org.eso.ias.plugin.Plugin
Change the refresh rate of the monitor point with the passed ID.
setMonitorPoints(Collection<MonitorPointDataToBuffer>) - Method in class org.eso.ias.plugin.publisher.BufferedMonitoredSystemData
 
setName(String) - Method in class org.eso.ias.cdb.pojos.PropertyDao
 
setOperationalMode(String) - Method in class org.eso.ias.plugin.publisher.MonitorPointDataToBuffer
 
setOperationalMode(String, OperationalMode) - Method in class org.eso.ias.plugin.Plugin
Set the operational mode of a monitor point value.
setOperationalMode(OperationalMode) - Method in class org.eso.ias.plugin.MonitoredValue
Set the operational mode of this monitor point value.
setOperMode(String) - Method in class org.eso.ias.plugin.network.MessageDao
 
setOutput(IasioDao) - Method in class org.eso.ias.cdb.pojos.AsceDao
 
setOutput(IasioDao) - Method in class org.eso.ias.cdb.pojos.DasuDao
 
setOutputId(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonDasuDao
 
setOutputID(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonAsceDao
Set the ID of the output
setParams(List<String>) - Method in class org.eso.ias.command.CommandMessage
 
setPluginID(String) - Method in class org.eso.ias.plugin.publisher.MonitorPointData
 
setPluginIds(Set<String>) - Method in class org.eso.ias.monitor.IasMonitorConfig
 
setPluginOperationalMode(OperationalMode) - Method in class org.eso.ias.plugin.Plugin
Set the operational mode of the plugin overriding the operational mode set in the monitor point values
setPort(int) - Method in class org.eso.ias.monitor.KafkaSinkConnectorConfig
 
setPriority(Priority) - Method in enum class org.eso.ias.monitor.MonitorAlarm
Set the priority of the alarm
setPriority(Priority) - Method in class org.eso.ias.types.Alarm
Assign a priority to the alarm
setProcessedTStamp(String) - Method in class org.eso.ias.command.ReplyMessage
 
setProcessedTStampMillis(long) - Method in class org.eso.ias.command.ReplyMessage
 
setProducedByPluginTime(String) - Method in class org.eso.ias.plugin.publisher.MonitorPointData
Setter
setProperties(Map<String, String>) - Method in class org.eso.ias.command.CommandMessage
 
setProperties(Map<String, String>) - Method in class org.eso.ias.command.ReplyMessage
 
setProps(Map<String, String>) - Method in class org.eso.ias.heartbeat.serializer.HeartbeatMessagePojo
 
setProps(Map<String, String>) - Method in class org.eso.ias.types.IasValueJsonPojo
 
setPublishTime(String) - Method in class org.eso.ias.plugin.publisher.BufferedMonitoredSystemData
 
setPublishTime(String) - Method in class org.eso.ias.plugin.publisher.MonitorPointData
 
setReceptionTStamp(String) - Method in class org.eso.ias.command.ReplyMessage
 
setReceptionTStampMillis(long) - Method in class org.eso.ias.command.ReplyMessage
 
setReconnectionInverval(int) - Method in class org.eso.ias.webserversender.WebServerSender
Set the time to wait before attempt to reconnect
setRefreshRate(int) - Method in class org.eso.ias.cdb.pojos.IasDao
 
setRefreshRate(long) - Method in class org.eso.ias.plugin.MonitoredValue
Set the new refresh rate for the monitored value with the given identifier.
setRefreshTime(int) - Method in class org.eso.ias.cdb.pojos.ValueDao
 
setSampleTime(String) - Method in class org.eso.ias.plugin.publisher.MonitorPointDataToBuffer
Set the time of the sample
setSenderFullRunningId(String) - Method in class org.eso.ias.command.CommandMessage
 
setSenderFullRunningId(String) - Method in class org.eso.ias.command.ReplyMessage
 
setShortDesc(String) - Method in class org.eso.ias.cdb.pojos.IasioDao
 
setSinkIds(Set<String>) - Method in class org.eso.ias.monitor.IasMonitorConfig
 
setSinkPort(int) - Method in class org.eso.ias.plugin.config.PluginFileConfig
 
setSinkServer(String) - Method in class org.eso.ias.plugin.config.PluginFileConfig
 
setSmtp(String) - Method in class org.eso.ias.cdb.pojos.IasDao
 
setSound(SoundTypeDao) - Method in class org.eso.ias.cdb.pojos.IasioDao
 
setState(HeartbeatStatus) - Method in class org.eso.ias.heartbeat.serializer.HeartbeatMessagePojo
 
setSupervisor(SupervisorDao) - Method in class org.eso.ias.cdb.pojos.DasuToDeployDao
 
setSystemID(String) - Method in class org.eso.ias.plugin.publisher.BufferedMonitoredSystemData
 
setTemplate(TemplateDao) - Method in class org.eso.ias.cdb.pojos.DasuToDeployDao
 
setTemplatedInputs(Set<JsonTemplatedInputsDao>) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonAsceDao
 
setTemplatedInstanceInputs(Set<TemplateInstanceIasioDao>) - Method in class org.eso.ias.cdb.pojos.AsceDao
Setter
setTemplateId(String) - Method in class org.eso.ias.cdb.pojos.AsceDao
 
setTemplateId(String) - Method in class org.eso.ias.cdb.pojos.DasuDao
 
setTemplateId(String) - Method in class org.eso.ias.cdb.pojos.IasioDao
 
setTemplateId(String) - Method in class org.eso.ias.cdb.pojos.TemplateInstanceIasioDao
 
setTemplateId(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonAsceDao
 
setTemplateId(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonDasuDao
 
setTemplateId(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonDasuToDeployDao
 
setTemplateId(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonTemplatedInputsDao
Setter
setTemplateInstance(Optional<Integer>) - Method in class org.eso.ias.asce.transfer.TransferExecutor
Set the instance of the template, if any
setThreshold(Long) - Method in class org.eso.ias.monitor.IasMonitorConfig
 
setTimestamp(String) - Method in class org.eso.ias.command.CommandMessage
Set the timestamp to the passed ISO 8601 timestamp
setTimestamp(String) - Method in class org.eso.ias.heartbeat.serializer.HeartbeatMessagePojo
 
setTimestamp(String) - Method in class org.eso.ias.plugin.network.MessageDao
Setter
setTimestampMillis(long) - Method in class org.eso.ias.command.CommandMessage
 
setTransferFunction(TransferFunctionDao) - Method in class org.eso.ias.cdb.pojos.AsceDao
 
setTransferFunctionID(String) - Method in class org.eso.ias.cdb.structuredtext.pojos.JsonAsceDao
 
setUp() - Method in class org.eso.ias.command.CommandSender
 
setUp() - Method in class org.eso.ias.converter.config.Cache
Initialize the DAO.
setUp() - Method in class org.eso.ias.converter.config.ConfigurationDaoBase
Setup the DAO: the implementer user provider initialization of the DAO.
setUp() - Method in class org.eso.ias.converter.Converter
Initialize the converter and start the loop
setUp() - Method in class org.eso.ias.kafkautils.KafkaIasiosProducer
Initialize the producer with default properties
setUp() - Method in class org.eso.ias.kafkautils.KafkaStringsConsumer
Initializes the consumer with default kafka properties
setUp() - Method in class org.eso.ias.kafkautils.SimpleKafkaIasiosConsumer
Initializes the consumer with default kafka properties
setUp() - Method in class org.eso.ias.kafkautils.SimpleStringProducer
Initialize the producer with default properties
setUp() - Method in class org.eso.ias.plugin.network.UdpPlugin
Starts the UdpPlugin
setUp() - Method in class org.eso.ias.plugin.publisher.BufferedPublisherBase
 
setUp() - Method in interface org.eso.ias.plugin.publisher.MonitorPointSender
Initialization method to allocate the resources needed to send messages to the core of the IAS.
setUp() - Method in class org.eso.ias.plugin.publisher.PublisherBase
Initialize the publisher
setUp() - Method in class org.eso.ias.webserversender.WebServerSender
Initialize the WSS
setUp(Properties) - Method in class org.eso.ias.kafkautils.KafkaIasiosProducer
Initialize the producer with the given properties
setUp(Properties) - Method in class org.eso.ias.kafkautils.KafkaStringsConsumer
Initializes the consumer with the passed kafka properties.
setUp(Properties) - Method in class org.eso.ias.kafkautils.SimpleKafkaIasiosConsumer
Initializes the consumer with the passed kafka properties.
setUp(Properties) - Method in class org.eso.ias.kafkautils.SimpleStringProducer
Initialize the producer with the given properties
setValidity(String) - Method in class org.eso.ias.plugin.publisher.MonitorPointDataToBuffer
param validity the validity
setValidityConstraint(Set<String>) - Method in class org.eso.ias.asce.transfer.IasIOJ
Set the validity constraints to the passed set of IDs of inputs.
setValidityThreshold(int) - Method in class org.eso.ias.cdb.pojos.IasDao
 
setValue(String) - Method in class org.eso.ias.cdb.pojos.PropertyDao
 
setValue(String) - Method in class org.eso.ias.plugin.network.MessageDao
Setter
setValue(String) - Method in class org.eso.ias.plugin.publisher.MonitorPointDataToBuffer
Set the value of th emonitor point
setValue(String) - Method in class org.eso.ias.types.IasValueJsonPojo
 
setValues(Set<ValueDao>) - Method in class org.eso.ias.cdb.pojos.PluginConfigDao
 
setValueType(String) - Method in class org.eso.ias.plugin.network.MessageDao
Setter
setValueType(IASTypes) - Method in class org.eso.ias.types.IasValueJsonPojo
 
SHORT - Enum constant in enum class org.eso.ias.cdb.pojos.IasTypeDao
 
SHORT - Enum constant in enum class org.eso.ias.types.IASTypes
 
shutdown() - Method in class org.eso.ias.asce.transfer.impls.MinMaxThresholdTFJava
 
shutdown() - Method in class org.eso.ias.asce.transfer.PythonExecutorTF
 
shutdown() - Method in class org.eso.ias.asce.transfer.TransferExecutor
Shuts down the BehaviorRunner when the IAS does not need it anymore.
shutdown() - Method in interface org.eso.ias.cdb.CdbReader
Close the CDB and release the associated resources
shutdown() - Method in interface org.eso.ias.cdb.CdbWriter
Close the CDB and release the associated resources
shutdown() - Method in class org.eso.ias.cdb.rdb.RdbReader
Deprecated.
Close the CDB and release the associated resources
shutdown() - Method in class org.eso.ias.cdb.rdb.RdbWriter
Deprecated.
Close the CDB and release the associated resources
shutdown() - Method in class org.eso.ias.cdb.structuredtext.StructuredTextReader
Close the CDB and release the associated resources
shutdown() - Method in class org.eso.ias.cdb.structuredtext.StructuredTextWriter
Close the CDB and release the associated resources
shutdown() - Method in class org.eso.ias.plugin.MonitoredValue
Stops the periodic thread and release all the resources
shutdown() - Method in class org.eso.ias.plugin.network.UdpPlugin
Shuts down the the thread and closes the plugin
shutdown() - Method in class org.eso.ias.plugin.publisher.impl.BufferedFilePublisherBase
Performs the cleanup.
shutdown() - Method in class org.eso.ias.plugin.publisher.impl.BufferedListenerPublisher
Performs the cleanup.
shutdown() - Method in class org.eso.ias.plugin.publisher.impl.KafkaPublisher
Close the kafka producer: does nothing because the kafka producer is shared and the initialization and closed will be done by the owner
shutdown() - Method in class org.eso.ias.plugin.publisher.impl.ListenerPublisher
Performs the cleanup.
shutdown() - Method in class org.eso.ias.plugin.publisher.PublisherBase
Performs the cleanup of the implementers of this abstract class
shutdown(CommandMessage) - Method in class org.eso.ias.command.DefaultCommandExecutor
The method called when a SHUTDOWN command has been executed.
SHUTDOWN - Enum constant in enum class org.eso.ias.command.CommandType
 
shutdownExecutorSvc() - Method in class org.eso.ias.plugin.Plugin
This method must be called when finished using the executor service to free the allocated resources.
SHUTTEDDOWN - Enum constant in enum class org.eso.ias.types.OperationalMode
Shut down
SimpleKafkaIasiosConsumer - Class in org.eso.ias.kafkautils
KafkaIasiosConsumer gets the strings from the passed IASIO kafka topic from the KafkaStringsConsumer and forwards the IASIOs to the listener.
SimpleKafkaIasiosConsumer(String, String, String) - Constructor for class org.eso.ias.kafkautils.SimpleKafkaIasiosConsumer
Build a FilteredStringConsumer with no filters (i.e.
SimpleKafkaIasiosConsumer.IasioListener - Interface in org.eso.ias.kafkautils
The listener to be notified of Iasios read from the kafka topic.
SimpleStringConsumer - Class in org.eso.ias.kafkautils
/** Generic Kafka consumer to get strings from a kafka topic.
SimpleStringConsumer(String, String, String) - Constructor for class org.eso.ias.kafkautils.SimpleStringConsumer
Constructor
SimpleStringConsumer.KafkaConsumerListener - Interface in org.eso.ias.kafkautils
The listener to be notified of strings read from the kafka topic.
SimpleStringProducer - Class in org.eso.ias.kafkautils
SimpleStringProducer pushes strings on a Kafka topic.
SimpleStringProducer(String, String) - Constructor for class org.eso.ias.kafkautils.SimpleStringProducer
Constructor
SINK - Enum constant in enum class org.eso.ias.heartbeat.HeartbeatProducerType
A consumer of IASIOs
SINK_DEAD - Enum constant in enum class org.eso.ias.monitor.MonitorAlarm
 
sinkIds - Variable in class org.eso.ias.monitor.IasMonitorConfig
The IDs of the sink client to monitor These are IAS clients not kafka sink connectors
size() - Method in class org.eso.ias.types.NumericArray
 
socketConnected - Variable in class org.eso.ias.webserversender.WebServerSender
A flag set to true if the socket is connected
SoundTypeDao - Enum Class in org.eso.ias.cdb.pojos
The type of the sound to play when a alarm becomes set
SqlRunner - Class in org.eso.ias.cdb.rdb
Deprecated.
SqlRunner(Reader) - Constructor for class org.eso.ias.cdb.rdb.SqlRunner
Deprecated.
Constructor
SqlRunner(String) - Constructor for class org.eso.ias.cdb.rdb.SqlRunner
Deprecated.
Constructor
start() - Method in class org.eso.ias.converter.ConverterStream
Start streaming data from the input to the output stream in a dedicated thread.
start() - Method in class org.eso.ias.plugin.MonitoredValue
Start the MonitorValue basically activating the timer thread
start() - Method in class org.eso.ias.plugin.Plugin
This method must be called at the beginning to acquire the needed resources.
start() - Method in class org.eso.ias.plugin.publisher.impl.BufferedFilePublisherBase
Performs the initialization.
start() - Method in class org.eso.ias.plugin.publisher.impl.BufferedListenerPublisher
Performs the initialization.
start() - Method in class org.eso.ias.plugin.publisher.impl.KafkaPublisher
Initializes the kafka producer: does nothing because the kafka producer is shared and the initialization and closed will be done by the owner
start() - Method in class org.eso.ias.plugin.publisher.impl.ListenerPublisher
Performs the initialization.
start() - Method in class org.eso.ias.plugin.publisher.PublisherBase
Performs the initialization of the implementers of this abstract class.
start(String, String, long) - Method in class org.eso.ias.sink.ltdb.CassandraLtdbFeeder
Connect to cassandra and allocate resources
start(Map<String, String>) - Method in class org.eso.ias.sink.ltdb.LtdbKafkaConnector
 
start(Map<String, String>) - Method in class org.eso.ias.sink.ltdb.LtdbKafkaTask
 
start(Optional<String>) - Method in class org.eso.ias.sink.ltdb.CassandraUtils
Establish the conenction witht the database and, optionall, use the passed keyspace
start(CommandListener, AutoCloseable) - Method in class org.eso.ias.command.CommandManager
Start getting events from the command topic and send them to the passed listener.
start(CommandListener, AutoCloseable) - Method in class org.eso.ias.command.kafka.CommandManagerKafkaImpl
Start getting events from the command topic and send them to the passed listener.
startGettingEvents(KafkaStringsConsumer.StreamPosition, SimpleKafkaIasiosConsumer.IasioListener) - Method in class org.eso.ias.kafkautils.SimpleKafkaIasiosConsumer
Start processing received by the SimpleStringConsumer from the kafka channel.
startGettingEvents(KafkaStringsConsumer.StringsConsumer, KafkaStringsConsumer.StreamPosition) - Method in class org.eso.ias.kafkautils.KafkaStringsConsumer
Start polling events from the kafka channel.
startGettingReplies(KafkaStringsConsumer.StreamPosition, ReplyListener) - Method in class org.eso.ias.command.kafka.ReplyKafkaConsumer
Start getting events from the repluy topic
startGettingStrings(KafkaStringsConsumer.StreamPosition, SimpleStringConsumer.KafkaConsumerListener) - Method in class org.eso.ias.kafkautils.SimpleStringConsumer
Start polling events from the kafka channel.
STARTING_UP - Enum constant in enum class org.eso.ias.heartbeat.HeartbeatStatus
The tool is starting up.
startSending() - Method in interface org.eso.ias.plugin.publisher.MonitorPointSender
Publishing of messages begins after calling this method.
startSending() - Method in class org.eso.ias.plugin.publisher.PublisherBase
 
startStreaming() - Method in class org.eso.ias.converter.ConverterKafkaStream
Start streaming data from the kafka input topic to the kafka output topic
startStreaming() - Method in class org.eso.ias.converter.ConverterStream
Start streaming data from the input to the output stream in a dedicated thread.
STARTUP - Enum constant in enum class org.eso.ias.types.OperationalMode
Starting up
StatData(String) - Constructor for class org.eso.ias.plugin.DetailedStatsCollector.StatData
The constructor for a given monitor point
STATISTIC_TIME_INTERVAL_PROP_NAME - Static variable in class org.eso.ias.webserversender.WebServerSender
The property to set the time interval for the generation of statistics in minutes
Statistics - Class in org.eso.ias.plugin
Collects and publishes detailed statistics.
Statistics() - Constructor for class org.eso.ias.plugin.Statistics
 
status - Variable in class org.eso.ias.command.CommandListener.CmdExecutionResult
The execution status of the command
stop() - Method in class org.eso.ias.converter.ConverterStream
Stops getting data from the input stream
stop() - Method in class org.eso.ias.sink.ltdb.CassandraLtdbFeeder
Close the connection with cassandra
stop() - Method in class org.eso.ias.sink.ltdb.CassandraUtils
Close the connection with cassandra
stop() - Method in class org.eso.ias.sink.ltdb.LtdbKafkaConnector
 
stop() - Method in class org.eso.ias.sink.ltdb.LtdbKafkaTask
 
stopSending() - Method in interface org.eso.ias.plugin.publisher.MonitorPointSender
Stop sending messages to the core of the IAS.
stopSending() - Method in class org.eso.ias.plugin.publisher.PublisherBase
 
stopStreaming() - Method in class org.eso.ias.converter.ConverterKafkaStream
Stop streaming data
stopStreaming() - Method in class org.eso.ias.converter.ConverterStream
Stops getting data from the input stream
store(String) - Method in class org.eso.ias.sink.ltdb.CassandraLtdbFeeder
Store the IASValue encoded by the passed JSON string by delegating to CassandraLtdbFeeder.store(IASValue)
store(Collection<String>) - Method in class org.eso.ias.sink.ltdb.CassandraLtdbFeeder
Store the IASValues encoded by the passed JSON strings by delegating to CassandraLtdbFeeder.store(IASValue)
STRING - Enum constant in enum class org.eso.ias.cdb.pojos.IasTypeDao
 
STRING - Enum constant in enum class org.eso.ias.types.IASTypes
 
stringEventReceived(String) - Method in class org.eso.ias.command.kafka.CommandManagerKafkaImpl
Get the JSON strings representing commands.
stringEventReceived(String) - Method in class org.eso.ias.command.kafka.ReplyKafkaConsumer
A string has bene received from the reply topic
stringEventReceived(String) - Method in interface org.eso.ias.kafkautils.SimpleStringConsumer.KafkaConsumerListener
Process an event (a String) received from the kafka topic
stringEventSent(String) - Method in interface org.eso.ias.webserversender.WebServerSender.WebServerSenderListener
 
StringSerializerException - Exception in org.eso.ias.command
Th eexception generated when marshalling or unmarshalling commands and replies to and from strings.
StringSerializerException() - Constructor for exception org.eso.ias.command.StringSerializerException
 
StringSerializerException(String) - Constructor for exception org.eso.ias.command.StringSerializerException
 
StringSerializerException(String, Throwable) - Constructor for exception org.eso.ias.command.StringSerializerException
 
StringSerializerException(String, Throwable, boolean, boolean) - Constructor for exception org.eso.ias.command.StringSerializerException
 
StringSerializerException(Throwable) - Constructor for exception org.eso.ias.command.StringSerializerException
 
stringsReceived(Collection<String>) - Method in interface org.eso.ias.kafkautils.KafkaStringsConsumer.StringsConsumer
Sends the strings received from the kafka topic to the listener
stringsReceived(Collection<String>) - Method in class org.eso.ias.kafkautils.SimpleKafkaIasiosConsumer
Receive the string consumed from the kafka topic and forward the IASIOs to the listener
stringsReceived(Collection<String>) - Method in class org.eso.ias.kafkautils.SimpleStringConsumer
Sends the strings received from the kafka topic to the listener
StructuredTextReader - Class in org.eso.ias.cdb.structuredtext
 
StructuredTextReader(File) - Constructor for class org.eso.ias.cdb.structuredtext.StructuredTextReader
Constructor that guesses the type of the folder from the content of the CDB folder from the content of the parentFolder.
StructuredTextReader(CdbFiles) - Constructor for class org.eso.ias.cdb.structuredtext.StructuredTextReader
Constructor
StructuredTextWriter - Class in org.eso.ias.cdb.structuredtext
 
StructuredTextWriter(File) - Constructor for class org.eso.ias.cdb.structuredtext.StructuredTextWriter
 
StructuredTextWriter(CdbFiles) - Constructor for class org.eso.ias.cdb.structuredtext.StructuredTextWriter
Constructor
sTxtCdbCmdLineParamLong - Static variable in class org.eso.ias.cdb.CdbReaderFactory
The long parameter to set in the command line to build a JSON/YAML CdbReader
sTxtCdbCmdLineParamShort - Static variable in class org.eso.ias.cdb.CdbReaderFactory
The short parameter to set in the command line to build a JSON/YAML CdbReader
submitSample(Sample) - Method in class org.eso.ias.plugin.MonitoredValue
Adds a new sample to this monitor point.
SUPERVISOR - Enum constant in enum class org.eso.ias.cdb.structuredtext.CdbFolders
 
SUPERVISOR - Enum constant in enum class org.eso.ias.heartbeat.HeartbeatProducerType
Supervisor
SUPERVISOR - Enum constant in enum class org.eso.ias.types.IdentifierType
The type of a supervisor identifier
SUPERVISOR_DEAD - Enum constant in enum class org.eso.ias.monitor.MonitorAlarm
 
SupervisorDao - Class in org.eso.ias.cdb.pojos
The Supervisor is the container of DASUs needed to run more then one DASU in the same java process.
SupervisorDao() - Constructor for class org.eso.ias.cdb.pojos.SupervisorDao
 
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