doc: Adding Comments

Author: codeba

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/CacheTemplateProvider.java

@@ -1,17 +1,17 @@
 /*
  * Copyright (c) 2024-2025, redis-keeper ([email protected])
  *
- *    Licensed under the Apache License, Version 2.0 (the "License");
- *    you may not use this file except in compliance with the License.
- *    You may obtain a copy of the License at
+ *     Licensed under the Apache License, Version 2.0 (the "License");
+ *     you may not use this file except in compliance with the License.
+ *     You may obtain a copy of the License at
  *
- *        http://www.apache.org/licenses/LICENSE-2.0
+ *         http://www.apache.org/licenses/LICENSE-2.0
  *
- *    Unless required by applicable law or agreed to in writing, software
- *    distributed under the License is distributed on an "AS IS" BASIS,
- *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *    See the License for the specific language governing permissions and
- *    limitations under the License.
+ *     Unless required by applicable law or agreed to in writing, software
+ *     distributed under the License is distributed on an "AS IS" BASIS,
+ *     WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *     See the License for the specific language governing permissions and
+ *     limitations under the License.
  */
 
 package org.codeba.redis.keeper.core;
@@ -34,16 +34,34 @@
  */
 public class CacheTemplateProvider<T> implements LoadBalanceProvider<T>, Serializable {
 
+    /**
+     * The Counter.
+     */
     private final AtomicInteger counter = new AtomicInteger(0);
 
+    /**
+     * The Random.
+     */
     private final ThreadLocalRandom random = ThreadLocalRandom.current();
 
+    /**
+     * The Status counter.
+     */
     private final AtomicInteger statusCounter = new AtomicInteger(0);
 
+    /**
+     * The Status random.
+     */
     private final ThreadLocalRandom statusRandom = ThreadLocalRandom.current();
 
+    /**
+     * The Datasource map.
+     */
     private final Map<String, T> datasourceMap;
 
+    /**
+     * The Datasources map.
+     */
     private final Map<String, List<T>> datasourcesMap;
 
     /**
@@ -112,6 +130,13 @@ public Optional<T> randomTemplate(String name, CacheDatasourceStatus status) {
         return random(list, statusRandom);
     }
 
+    /**
+     * Poll optional.
+     *
+     * @param list    the list
+     * @param counter the counter
+     * @return the optional
+     */
     private Optional<T> poll(List<T> list, AtomicInteger counter) {
         if (null == list || list.isEmpty()) {
             return Optional.empty();
@@ -123,6 +148,13 @@ private Optional<T> poll(List<T> list, AtomicInteger counter) {
         return Optional.ofNullable(list.get(index));
     }
 
+    /**
+     * Random optional.
+     *
+     * @param list              the list
+     * @param threadLocalRandom the thread local random
+     * @return the optional
+     */
     private Optional<T> random(List<T> list, ThreadLocalRandom threadLocalRandom) {
         if (null == list || list.isEmpty()) {
             return Optional.empty();

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/KBloomFilter.java

@@ -18,6 +18,9 @@
 
 import java.util.concurrent.CompletableFuture;
 
+/**
+ * The interface K bloom filter.
+ */
 public interface KBloomFilter {
     /**
      * Bf add boolean.

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/KGeneric.java

@@ -18,6 +18,9 @@
 
 import java.util.concurrent.TimeUnit;
 
+/**
+ * The interface K generic.
+ */
 public interface KGeneric extends KGenericAsync {
     /**
      * Exists long.

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/KGenericAsync.java

@@ -19,6 +19,9 @@
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 
+/**
+ * The interface K generic async.
+ */
 public interface KGenericAsync {
     /**
      * Exists async completable future.

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/KHyperLogLog.java

@@ -18,6 +18,9 @@
 
 import java.util.Collection;
 
+/**
+ * The interface K hyper log log.
+ */
 public interface KHyperLogLog extends KHyperLogLogAsync {
 
     /**

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/KHyperLogLogAsync.java

@@ -19,6 +19,9 @@
 import java.util.Collection;
 import java.util.concurrent.CompletableFuture;
 
+/**
+ * The interface K hyper log log async.
+ */
 public interface KHyperLogLogAsync {
     /**
      * Pf add async completable future.

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/KList.java

@@ -21,6 +21,9 @@
 import java.util.Optional;
 import java.util.concurrent.TimeUnit;
 
+/**
+ * The interface K list.
+ */
 public interface KList extends KListAsync {
     /**
      * Bl move optional.

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/KListAsync.java

@@ -21,6 +21,9 @@
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 
+/**
+ * The interface K list async.
+ */
 public interface KListAsync {
     /**
      * Bl move async completable future.

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/KLock.java

@@ -19,6 +19,9 @@
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 
+/**
+ * The interface K lock.
+ */
 public interface KLock {
     /**
      * Try lock boolean.

redis-keeper-core/src/main/java/org/codeba/redis/keeper/core/KRateLimiter.java

@@ -18,6 +18,9 @@
 
 import java.util.concurrent.CompletableFuture;
 
+/**
+ * The interface K rate limiter.
+ */
 public interface KRateLimiter {
     /**
      * Try set rate limiter boolean.