Package org.eso.ias.monitor

Class IasMonitorConfig

java.lang.Object
org.eso.ias.monitor.IasMonitorConfig
public class IasMonitorConfig extends Object
Java pojo with the configuration of the IASMonitor tool

  • Field Details

    • threshold

      public Long threshold
      The threshold to invalidate the HBs

    • excludedSupervisorIds

      public Set<String> excludedSupervisorIds
      The IDs of the supervisors that must NOT be monitored The Ids of the supervisors are read from the CDB and the monitor checks the HBs published by each of them unless their ID is in this set

    • pluginIds

      public Set<String> pluginIds
      The IDs of the plugins to monitor

    • converterIds

      public Set<String> converterIds
      The IDs of the converters to monitor

    • clientIds

      public Set<String> clientIds
      The IDs of the clients to monitor

    • sinkIds

      public Set<String> sinkIds
      The IDs of the sink client to monitor These are IAS clients not kafka sink connectors

    • coreToolsIds

      public Set<String> coreToolsIds

    • kafkaSinkConnectors

      public Set<KafkaSinkConnectorConfig> kafkaSinkConnectors
      The KAFKA Sink connectors to monitor These are monitored though the REST API

  • Constructor Details

    • IasMonitorConfig

      public IasMonitorConfig()
      Empty constructor

  • Method Details

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • getThreshold

      public Long getThreshold()

    • setThreshold

      public void setThreshold(Long threshold)

    • getExcludedSupervisorIds

      public Set<String> getExcludedSupervisorIds()

    • setExcludedSupervisorIds

      public void setExcludedSupervisorIds(Set<String> excludedSupervisorIds)

    • getPluginIds

      public Set<String> getPluginIds()

    • setPluginIds

      public void setPluginIds(Set<String> pluginIds)

    • getConverterIds

      public Set<String> getConverterIds()

    • setConverterIds

      public void setConverterIds(Set<String> converterIds)

    • getClientIds

      public Set<String> getClientIds()

    • setClientIds

      public void setClientIds(Set<String> clientIds)

    • getSinkIds

      public Set<String> getSinkIds()

    • setSinkIds

      public void setSinkIds(Set<String> sinkIds)

    • getKafkaSinkConnectors

      public Set<KafkaSinkConnectorConfig> getKafkaSinkConnectors()

    • setKafkaSinkConnectors

      public void setKafkaSinkConnectors(Set<KafkaSinkConnectorConfig> kafkaSinkConnectors)

    • getCoreToolsIds

      public Set<String> getCoreToolsIds()

    • setCoreToolsIds

      public void setCoreToolsIds(Set<String> coreToolsIds)

    • toJsonString

      public String toJsonString() throws Exception
      Serialize this configuration into a JSON string
      Throws:
      Exception

    • valueOf

      public static IasMonitorConfig valueOf(String jsonString) throws Exception
      Build the IasMonitorConfig from the passed JSON string
      Parameters:
      jsonString - The JSON string with the configuration
      Returns:
      The IasMonitorConfig object
      Throws:
      Exception - in case of error parsing the JSON string

    • configToJsonString

      public static String configToJsonString(IasMonitorConfig config) throws Exception
      Serialize the passed configuration into a JSON string
      Parameters:
      config - The configuration to serialize
      Returns:
      the JSON string representing the passed object
      Throws:
      Exception - in case of error serializing into a JSON string

    • fromFile

      public static IasMonitorConfig fromFile(File f) throws Exception
      Reads the configuration from the passed file
      Parameters:
      f - The file with the configuration
      Returns:
      The IasMonitorConfig object
      Throws:
      Exception - in case of error parsing the JSON string