Package sk.iway.iwcm.system.cluster

Class ClusterDB

java.lang.Object
sk.iway.iwcm.system.cluster.ClusterDB
public class ClusterDB extends Object
ClusterDB.java - objekt pre podporu clustra riesi primarne refreshovanie instancii objektov na jednotlivych nodoch

  • Constructor Details

    • ClusterDB

      protected ClusterDB()

  • Method Details

    • addRefresh

      public static void addRefresh(Class<?> clas)
      Poznaci do databazy informaciu o refreshi objektu (=ziskanie getInstance())
      Parameters:
      clas -

    • addRefresh

      public static void addRefresh(Class<?> clas, Long id)

    • addRefresh

      public static void addRefresh(String className)
      Poznaci do databazy informaciu o refreshi objektu (=ziskanie getInstance())
      Parameters:
      className -

    • addRefresh

      public static void addRefresh(String className, Long id)
      Poznaci do databazy informaciu o refreshi objektu/zaznamu v DB
      Parameters:
      className - - trieda
      id - - id zaznamu alebo NULL pre refresh celej triedy

    • addCronTask

      public static boolean addCronTask(String configuredNode, Long taskId)
      Adds a request to run a cron task on its configured cluster node or node group.
      Parameters:
      configuredNode - configured node name, all, all-admin or all-public
      taskId - cron task ID
      Returns:
      true when all cluster requests were stored successfully

    • deleteStartsWith

      public static void deleteStartsWith(String className)
      Delete data from cluster_refresher table where class_name starts with given string It is usseful when we want to remove old refresh requests for the same object
      Parameters:
      className -

    • addRefreshClusterMonitoring

      public static void addRefreshClusterMonitoring(String nodeName, Class<?> clas)

    • cleanup

      public static void cleanup()
      Vymaze info o refreshoch pre aktualny objekt po inicializacii systemu

    • isServerRunningInClusterMode

      public static boolean isServerRunningInClusterMode()

    • getClusterNodeNames

      public static List<String> getClusterNodeNames()

    • getClusterNodeNamesExpandedAuto

      public static List<String> getClusterNodeNamesExpandedAuto()
      Vrati zoznam nodov expandnutych pre rezim auto (napr. pre vyber nodu v monitoringu) expand sa robi distinct selectom z databazy za posledny mesiac
      Returns:

    • getClusterNodeNamesExpandedAuto

      public static List<String> getClusterNodeNamesExpandedAuto(long dateFrom)

    • isPublicNode

      public static boolean isPublicNode()