Class WriteBehindCache.Builder<K,V>

java.lang.Object
cloud.opencode.base.cache.WriteBehindCache.Builder<K,V>
Type Parameters:
K - key type | 键类型
V - value type | 值类型
Enclosing class:
WriteBehindCache<K,V>
public static class WriteBehindCache.Builder<K,V> extends Object
Builder for WriteBehindCache WriteBehindCache 构建器
Since:
JDK 25, opencode-base-cache V1.0.0
Author:
Leon Soo www.LeonSoo.com

  • Method Details

    • writer

      public WriteBehindCache.Builder<K,V> writer(WriteBehindCache.BatchWriter<K,V> writer)
      Set the batch writer 设置批量写入器
      Parameters:
      writer - batch writer | 批量写入器
      Returns:
      this builder | 此构建器

    • writer

      public WriteBehindCache.Builder<K,V> writer(Consumer<Map<K,V>> consumer)
      Set writer using simple consumer (puts only) 使用简单消费者设置写入器（仅放入）
      Parameters:
      consumer - put consumer | 放入消费者
      Returns:
      this builder | 此构建器

    • batchSize

      public WriteBehindCache.Builder<K,V> batchSize(int batchSize)
      Set batch size before auto-flush 设置自动刷新前的批量大小
      Parameters:
      batchSize - batch size | 批量大小
      Returns:
      this builder | 此构建器

    • maxQueueSize

      public WriteBehindCache.Builder<K,V> maxQueueSize(int maxQueueSize)
      Set maximum queue size before synchronous fallback 设置同步回退前的最大队列大小
      Parameters:
      maxQueueSize - max queue size (default 10000) | 最大队列大小（默认10000）
      Returns:
      this builder | 此构建器

    • flushInterval

      public WriteBehindCache.Builder<K,V> flushInterval(Duration interval)
      Set flush interval 设置刷新间隔
      Parameters:
      interval - flush interval | 刷新间隔
      Returns:
      this builder | 此构建器

    • maxRetries

      public WriteBehindCache.Builder<K,V> maxRetries(int maxRetries)
      Set maximum retry attempts on failure 设置失败时的最大重试次数
      Parameters:
      maxRetries - max retries | 最大重试次数
      Returns:
      this builder | 此构建器

    • retryDelay

      public WriteBehindCache.Builder<K,V> retryDelay(Duration delay)
      Set delay between retries 设置重试间隔
      Parameters:
      delay - retry delay | 重试间隔
      Returns:
      this builder | 此构建器

    • onFailure

      public WriteBehindCache.Builder<K,V> onFailure(Consumer<WriteBehindCache.WriteFailure<K,V>> handler)
      Set failure handler for write failures after all retries 设置所有重试后写入失败的处理器
      Parameters:
      handler - failure handler | 失败处理器
      Returns:
      this builder | 此构建器

    • build

      public WriteBehindCache<K,V> build()
      Build the write-behind cache 构建写后缓存
      Returns:
      write-behind cache | 写后缓存