This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 2eb250c Regen for commit 2a5166309755a564228fa7365f2473a69ec9b73d
add 8cc227b Rebalancing cluster service
No new revisions were added by this update.
Summary of changes:
components/camel-kubernetes/pom.xml | 5 +
.../cluster/KubernetesClusterService.java | 54 +++-
.../kubernetes/cluster/KubernetesClusterView.java | 18 +-
.../kubernetes/cluster/LeaseResourceType.java | 29 +++
.../cluster/lock/ConfigMapLockUtils.java | 101 --------
.../lock/KubernetesLeadershipController.java | 229 +++++++++++++----
.../lock/KubernetesLeaseResourceManager.java | 79 ++++++
.../cluster/lock/KubernetesLockConfiguration.java | 61 ++++-
.../kubernetes/cluster/lock/LeaderInfo.java | 14 +-
.../cluster/lock/TimedLeaderNotifier.java | 16 +-
.../lock/impl/ConfigMapLeaseResourceManager.java | 144 +++++++++++
.../lock/impl/NativeLeaseResourceManager.java | 164 +++++++++++++
.../cluster/KubernetesClusterServiceTest.java | 273 ++++++++++++++++-----
.../cluster/utils/ConfigMapLockSimulator.java | 68 ++---
.../cluster/utils/LeaseLockSimulator.java | 56 +++++
.../kubernetes/cluster/utils/LockTestServer.java | 200 +++++++++------
...ckSimulator.java => ResourceLockSimulator.java} | 50 ++--
.../cluster/CamelPreemptiveClusterService.java | 28 +++
.../camel/cluster/CamelPreemptiveClusterView.java | 35 +++
.../cluster/RebalancingCamelClusterService.java | 267 ++++++++++++++++++++
20 files changed, 1506 insertions(+), 385 deletions(-)
create mode 100644
components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/LeaseResourceType.java
delete mode 100644
components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/ConfigMapLockUtils.java
create mode 100644
components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLeaseResourceManager.java
create mode 100644
components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/impl/ConfigMapLeaseResourceManager.java
create mode 100644
components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/impl/NativeLeaseResourceManager.java
create mode 100644
components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/LeaseLockSimulator.java
copy
components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/utils/{ConfigMapLockSimulator.java
=> ResourceLockSimulator.java} (53%)
create mode 100644
core/camel-api/src/main/java/org/apache/camel/cluster/CamelPreemptiveClusterService.java
create mode 100644
core/camel-api/src/main/java/org/apache/camel/cluster/CamelPreemptiveClusterView.java
create mode 100644
core/camel-support/src/main/java/org/apache/camel/support/cluster/RebalancingCamelClusterService.java
