Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

* Rename: MetricsLeapArray -> BucketLeapArray
* Add implementation for `FutureBucketLeapArray`, a kind of `BucketLeapArray` that only reserves for future buckets, which is used for calculating occupied future tokens.
* Add OccupiableBucketLeapArray that combines common BucketLeapArray with FutureBucketLeapArray. The rollingNumberInSecond in StatisticNode now uses OccupiableBucketLeapArray by default.
* Add OccupySupport interface. Node now implements OccupySupport interface.
* Add occupy-related methods in Metric and ArrayMetric.
* Handle prioritized requests in default traffic shaping controller.
* Update default occupyTimeout to 500ms

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Carpenter Lee <hooleeucas@163.com>

- Update test cases (use assertEquals(e, a, delta) instead)
- Also add `totalPass` method in Node interface

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

This reverts commit 35371c1

Signed-off-by: Carpenter Lee <hooleeucas@163.com>

Signed-off-by: Carpenter Lee <hooleeucas@163.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

- The implementation leverages Sentinel Reactor Adapter. Two main components: SentinelWebFluxFilter and SentinelBlockExceptionHandler

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

- Regard the total inbound as a "virtual node" with the name `__total_inbound_traffic__`

Signed-off-by: Carpenter Lee <hooleeucas@163.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

- Add to unsubscribe config change event

- `Entry` class now implements `AutoCloseable` so it supports try-with-resources (`close` method adapts to `exit`)

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

* Add reactive adapter implementation for Project Reactor (Mono/Flux) including a reactor transformer and an experimental `ReactorSphU`
* Add an `InheritableBaseSubscriber` that derives from the original BaseSubscriber of reactor-core
* Add basic test cases for reactor adapter
* Add Sentinel context enter support for EntryConfig in reactor transformer

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Carpenter Lee <hooleeucas@163.com>

Signed-off-by: Carpenter Lee <hooleeucas@163.com>

Signed-off-by: Carpenter Lee <hooleeucas@163.com>

* Add spring-context-support 1.0.2 and netty-all 4.1.31.Final dependency, and remove spring-context 5.0.7.RELEASE dependency
* Add comment for dependency

* Allow negative paramIndex in ParamFlowRule

Signed-off-by: Carpenter Lee <hooleeucas@163.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

close → open: use `compareAndSet` to update for `cut` attribute (changed to an `AtomicBoolean`)

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

* Support removing unhealthy machine manually
* Auto removal support for dead machine
* Auto hidden for app if one have no healthy machine after some time(configurable)
* Auto removal for app if hidden status lasts(configurable).

By upgrading G2 lib to version 3.4.10

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

* Add a ApiCommandHandler which fetch all registered CommandHandlers so that user can get all available CommandHandlers by request /api
* Add a customized CommandHandler demo

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Carpenter Lee <hooleeucas@163.com>

- fix ConcurrentModificationException of listResourcesOfApp method

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>

Signed-off-by: Eric Zhao <sczyh16@gmail.com>