Package io.confluent.dekregistry.storage.utils

Class CompositeCacheUpdateHandler<K,V>

java.lang.Object
io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler<K,V>
All Implemented Interfaces:
io.kcache.CacheUpdateHandler<K,V>, Closeable, AutoCloseable, org.apache.kafka.common.Configurable
public class CompositeCacheUpdateHandler<K,V> extends Object implements io.kcache.CacheUpdateHandler<K,V>

  • Nested Class Summary

    Nested classes/interfaces inherited from interface io.kcache.CacheUpdateHandler

    io.kcache.CacheUpdateHandler.ValidationStatus

  • Constructor Summary

    Constructors
    Constructor
    Description
    CompositeCacheUpdateHandler(List<? extends io.kcache.CacheUpdateHandler<K,V>> handlers)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    cacheDestroyed()
     
    void
    cacheFlushed()
     
    void
    cacheInitialized(int count, Map<org.apache.kafka.common.TopicPartition,Long> checkpoints)
     
    void
    cacheReset()
     
    void
    cacheSynchronized(int count, Map<org.apache.kafka.common.TopicPartition,Long> checkpoints)
     
    Map<org.apache.kafka.common.TopicPartition,Long>
    checkpoint(int count)
     
    void
    close()
     
    void
    endBatch(int count)
     
    void
    failBatch(int count, Throwable t)
     
    void
    handleUpdate(K key, V value, V oldValue, org.apache.kafka.common.TopicPartition tp, long offset, long ts)
     
    void
    startBatch(int count)
     
    io.kcache.CacheUpdateHandler.ValidationStatus
    validateUpdate(org.apache.kafka.common.header.Headers headers, K key, V value, org.apache.kafka.common.TopicPartition tp, long offset, long ts, org.apache.kafka.common.record.TimestampType tsType, Optional<Integer> leaderEpoch)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface io.kcache.CacheUpdateHandler

    configure, handleUpdate, validateUpdate

  • Constructor Details

    • CompositeCacheUpdateHandler

      public CompositeCacheUpdateHandler(List<? extends io.kcache.CacheUpdateHandler<K,V>> handlers)

  • Method Details

    • cacheInitialized

      public void cacheInitialized(int count, Map<org.apache.kafka.common.TopicPartition,Long> checkpoints)
      Specified by:
      cacheInitialized in interface io.kcache.CacheUpdateHandler<K,V>

    • cacheReset

      public void cacheReset()
      Specified by:
      cacheReset in interface io.kcache.CacheUpdateHandler<K,V>

    • cacheSynchronized

      public void cacheSynchronized(int count, Map<org.apache.kafka.common.TopicPartition,Long> checkpoints)
      Specified by:
      cacheSynchronized in interface io.kcache.CacheUpdateHandler<K,V>

    • startBatch

      public void startBatch(int count)
      Specified by:
      startBatch in interface io.kcache.CacheUpdateHandler<K,V>

    • validateUpdate

      public io.kcache.CacheUpdateHandler.ValidationStatus validateUpdate(org.apache.kafka.common.header.Headers headers, K key, V value, org.apache.kafka.common.TopicPartition tp, long offset, long ts, org.apache.kafka.common.record.TimestampType tsType, Optional<Integer> leaderEpoch)
      Specified by:
      validateUpdate in interface io.kcache.CacheUpdateHandler<K,V>

    • handleUpdate

      public void handleUpdate(K key, V value, V oldValue, org.apache.kafka.common.TopicPartition tp, long offset, long ts)
      Specified by:
      handleUpdate in interface io.kcache.CacheUpdateHandler<K,V>

    • checkpoint

      public Map<org.apache.kafka.common.TopicPartition,Long> checkpoint(int count)
      Specified by:
      checkpoint in interface io.kcache.CacheUpdateHandler<K,V>

    • endBatch

      public void endBatch(int count)
      Specified by:
      endBatch in interface io.kcache.CacheUpdateHandler<K,V>

    • failBatch

      public void failBatch(int count, Throwable t)
      Specified by:
      failBatch in interface io.kcache.CacheUpdateHandler<K,V>

    • cacheFlushed

      public void cacheFlushed()
      Specified by:
      cacheFlushed in interface io.kcache.CacheUpdateHandler<K,V>

    • close

      public void close() throws IOException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface io.kcache.CacheUpdateHandler<K,V>
      Specified by:
      close in interface Closeable
      Throws:
      IOException

    • cacheDestroyed

      public void cacheDestroyed()
      Specified by:
      cacheDestroyed in interface io.kcache.CacheUpdateHandler<K,V>