Index
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 byMonitorAlarm.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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form