This is an automated email from the ASF dual-hosted git repository.
randgalt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/curator.git.
from 973cb0b Merge branch 'CURATOR-498'
add 7f1c0dd CURATOR-505
add 96f186a CURATOR-505 - interim checking - refactoring,
simplifications, more testing, and documentation
add a162f5b CURATOR-505 - decoration of ConnectionStateListeners is now
automatic (a backdoor is provided)
add c9e3cf6 CURATOR-505 - refactoring/refining a new listener container
that doesn't rely on Guava and supports mapping. We need for this PR anyway.
add 7458a20 CURATOR-505 ctor should be private
add b18af51 CURATOR-505 - Some refactoring and more doc
add 2e980e7 CURATOR-505 - didn't mean to check this in
add 6e4466f CURATOR-505 - fix elapsed calculation in the circuit breaker
new 48bd767 Merge branch 'CURATOR-505'
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../curator/framework/CuratorFrameworkFactory.java | 24 +++
.../framework/imps/CuratorFrameworkImpl.java | 8 +-
.../curator/framework/imps/EnsembleTracker.java | 6 +
.../framework/listen/ListenerContainer.java | 9 +-
.../Watchable.java => listen/ListenerManager.java} | 27 ++-
.../framework/listen/MappingListenerManager.java | 108 ++++++++++
.../framework/listen/StandardListenerManager.java | 96 +++++++++
.../curator/framework/state/CircuitBreaker.java | 99 +++++++++
.../CircuitBreakingConnectionStateListener.java | 194 ++++++++++++++++++
.../framework/state/ConnectionStateListener.java | 15 +-
.../state/ConnectionStateListenerDecorator.java | 81 ++++++++
.../framework/state/ConnectionStateManager.java | 35 ++--
.../framework/state/TestCircuitBreaker.java | 98 +++++++++
...TestCircuitBreakingConnectionStateListener.java | 227 +++++++++++++++++++++
.../framework/recipes/leader/TestLeaderLatch.java | 42 ++++
.../org/apache/curator/test/BaseClassForTests.java | 5 +
src/site/confluence/utilities.confluence | 28 +++
17 files changed, 1068 insertions(+), 34 deletions(-)
copy
curator-framework/src/main/java/org/apache/curator/framework/{api/Watchable.java
=> listen/ListenerManager.java} (64%)
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/listen/MappingListenerManager.java
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/listen/StandardListenerManager.java
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/state/CircuitBreaker.java
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/state/CircuitBreakingConnectionStateListener.java
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/state/ConnectionStateListenerDecorator.java
create mode 100644
curator-framework/src/test/java/org/apache/curator/framework/state/TestCircuitBreaker.java
create mode 100644
curator-framework/src/test/java/org/apache/curator/framework/state/TestCircuitBreakingConnectionStateListener.java
