程序包 com.alibaba.csp.sentinel.node

接口 Node

所有超级接口:
DebugSupport, OccupySupport
所有已知实现类:
ClusterNode, DefaultNode, EntranceNode, StatisticNode
public interface Node extends OccupySupport, DebugSupport
Holds real-time statistics for resources.
作者:
qinan.qn, leyou, Eric Zhao

  • 方法详细资料

    • totalRequest

      long totalRequest()
      Get incoming request per minute (pass + block).
      返回:
      total request count per minute

    • totalPass

      long totalPass()
      Get pass count per minute.
      返回:
      total passed request count per minute
      从以下版本开始:
      1.5.0

    • totalSuccess

      long totalSuccess()
      Get Entry.exit() count per minute.
      返回:
      total completed request count per minute

    • blockRequest

      long blockRequest()
      Get blocked request count per minute (totalBlockRequest).
      返回:
      total blocked request count per minute

    • totalException

      long totalException()
      Get exception count per minute.
      返回:
      total business exception count per minute

    • passQps

      double passQps()
      Get pass request per second.
      返回:
      QPS of passed requests

    • blockQps

      double blockQps()
      Get block request per second.
      返回:
      QPS of blocked requests

    • totalQps

      double totalQps()
      Get passQps() + blockQps() request per second.
      返回:
      QPS of passed and blocked requests

    • successQps

      double successQps()
      Get Entry.exit() request per second.
      返回:
      QPS of completed requests

    • maxSuccessQps

      double maxSuccessQps()
      Get estimated max success QPS till now.
      返回:
      max completed QPS

    • exceptionQps

      double exceptionQps()
      Get exception count per second.
      返回:
      QPS of exception occurs

    • avgRt

      double avgRt()
      Get average rt per second.
      返回:
      average response time per second

    • minRt

      double minRt()
      Get minimal response time.
      返回:
      recorded minimal response time

    • curThreadNum

      int curThreadNum()
      Get current active thread count.
      返回:
      current active thread count

    • previousBlockQps

      double previousBlockQps()
      Get last second block QPS.

    • previousPassQps

      double previousPassQps()
      Last window QPS.

    • metrics

      Map<Long,MetricNode> metrics()
      Fetch all valid metric nodes of resources.
      返回:
      valid metric nodes of resources

    • rawMetricsInMin

      List<MetricNode> rawMetricsInMin(Predicate<Long> timePredicate)
      Fetch all raw metric items that satisfies the time predicate.
      参数:
      timePredicate - time predicate
      返回:
      raw metric items that satisfies the time predicate
      从以下版本开始:
      1.7.0

    • addPassRequest

      void addPassRequest(int count)
      Add pass count.
      参数:
      count - count to add pass

    • addRtAndSuccess

      void addRtAndSuccess(long rt, int success)
      Add rt and success count.
      参数:
      rt - response time
      success - success count to add

    • increaseBlockQps

      void increaseBlockQps(int count)
      Increase the block count.
      参数:
      count - count to add

    • increaseExceptionQps

      void increaseExceptionQps(int count)
      Add the biz exception count.
      参数:
      count - count to add

    • increaseThreadNum

      void increaseThreadNum()
      Increase current thread count.

    • decreaseThreadNum

      void decreaseThreadNum()
      Decrease current thread count.

    • reset

      void reset()
      Reset the internal counter. Reset is needed when IntervalProperty.INTERVAL or SampleCountProperty.SAMPLE_COUNT is changed.