cleanup spaces

MAIF · Jan 9, 2025 · 47c97e5 · 47c97e5
1 parent 3de48ca
commit 47c97e5
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/otoroshi/app/cluster/cluster.scala b/otoroshi/app/cluster/cluster.scala
@@ -1334,7 +1334,7 @@ class ClusterLeaderAgent(config: ClusterConfig, env: Env) {
       if (Cluster.logger.isDebugEnabled)
         Cluster.logger.debug(s"[${env.clusterConfig.mode.name}] Starting cluster state auto update")
       stateUpdaterRef.set(
-         env.otoroshiScheduler.scheduleAtFixedRate(1.second, env.clusterConfig.leader.cacheStateFor.millis)(
+        env.otoroshiScheduler.scheduleAtFixedRate(1.second, env.clusterConfig.leader.cacheStateFor.millis)(
           utils.SchedulerHelper.runnable(
             try {
               cacheState()
@@ -2577,7 +2577,6 @@ class ClusterAgent(config: ClusterConfig, env: Env) {
           )
           GlobalStatusUpdate.build()(env, env.otoroshiExecutionContext).map { stats =>
             val oldQuotasIncr = quotaIncrs.getAndSet(new UnboundedTrieMap[String, ClusterLeaderUpdateMessage]())
-
             queueRef
               .get()
               .offer(
@@ -2683,7 +2682,6 @@ class ClusterAgent(config: ClusterConfig, env: Env) {
     if (config.mode == ClusterMode.Worker) {
       if (Cluster.logger.isDebugEnabled)
         Cluster.logger.debug(s"[${env.clusterConfig.mode.name}] Starting cluster agent")
-
       if (config.worker.useWs) {
         // Cluster.logger.warn("USING CLUSTER API THROUGH WEBSOCKET: THIS IS NOT READY YET !!!!")
         callLeaderAkka(1)