程序包 com.alibaba.csp.sentinel.cluster.server.config

类 ClusterServerConfigManager

java.lang.Object
com.alibaba.csp.sentinel.cluster.server.config.ClusterServerConfigManager
public final class ClusterServerConfigManager extends Object
从以下版本开始:
1.4.0
作者:
Eric Zhao

  • 方法详细资料

    • registerNamespaceSetProperty

      public static void registerNamespaceSetProperty(com.alibaba.csp.sentinel.property.SentinelProperty<Set<String>> property)
      Register cluster server namespace set dynamic property.
      参数:
      property - server namespace set dynamic property

    • registerServerTransportProperty

      public static void registerServerTransportProperty(com.alibaba.csp.sentinel.property.SentinelProperty<ServerTransportConfig> property)
      Register cluster server transport configuration dynamic property.
      参数:
      property - server transport configuration dynamic property

    • registerGlobalServerFlowProperty

      public static void registerGlobalServerFlowProperty(com.alibaba.csp.sentinel.property.SentinelProperty<ServerFlowConfig> property)
      Register cluster server global statistic (flow) configuration dynamic property.
      参数:
      property - server flow configuration dynamic property

    • loadServerNamespaceSet

      public static void loadServerNamespaceSet(Set<String> namespaceSet)
      Load provided server namespace set to property in memory.
      参数:
      namespaceSet - valid namespace set

    • loadGlobalTransportConfig

      public static void loadGlobalTransportConfig(ServerTransportConfig config)
      Load provided server transport configuration to property in memory.
      参数:
      config - valid cluster server transport configuration

    • loadGlobalFlowConfig

      public static void loadGlobalFlowConfig(ServerFlowConfig config)
      Load provided server global statistic (flow) configuration to property in memory.
      参数:
      config - valid cluster server flow configuration for global

    • loadFlowConfig

      public static void loadFlowConfig(String namespace, ServerFlowConfig config)
      Load server flow config for a specific namespace.
      参数:
      namespace - a valid namespace
      config - valid flow config for the namespace

    • addTransportConfigChangeObserver

      public static void addTransportConfigChangeObserver(ServerTransportConfigObserver observer)
      Add a transport config observer. The observers will be called as soon as there are some changes in transport config (e.g. token server port).
      参数:
      observer - a valid transport config observer

    • isValidTransportConfig

      public static boolean isValidTransportConfig(ServerTransportConfig config)

    • isValidFlowConfig

      public static boolean isValidFlowConfig(ServerFlowConfig config)

    • getExceedCount

      public static double getExceedCount(String namespace)

    • getMaxOccupyRatio

      public static double getMaxOccupyRatio(String namespace)

    • getIntervalMs

      public static int getIntervalMs(String namespace)

    • getSampleCount

      public static int getSampleCount(String namespace)
      Get sample count of provided namespace.
      参数:
      namespace - valid namespace
      返回:
      the sample count of namespace; if the namespace does not have customized value, use the global value

    • getMaxAllowedQps

      public static double getMaxAllowedQps()

    • getMaxAllowedQps

      public static double getMaxAllowedQps(String namespace)

    • getExceedCount

      public static double getExceedCount()

    • getMaxOccupyRatio

      public static double getMaxOccupyRatio()

    • getNamespaceSet

      public static Set<String> getNamespaceSet()

    • getPort

      public static int getPort()

    • getIdleSeconds

      public static int getIdleSeconds()

    • getIntervalMs

      public static int getIntervalMs()

    • getSampleCount

      public static int getSampleCount()

    • setNamespaceSet

      public static void setNamespaceSet(Set<String> namespaceSet)

    • isEmbedded

      public static boolean isEmbedded()

    • setEmbedded

      public static void setEmbedded(boolean embedded)

      Set the embedded mode flag for the token server.

      NOTE: developers SHOULD NOT manually invoke this method. The embedded flag should be initialized by Sentinel when starting token server.

      参数:
      embedded - whether the token server is currently running in embedded mode

    • setMaxAllowedQps

      public static void setMaxAllowedQps(double maxAllowedQps)