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

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 and Description
CompositeCacheUpdateHandler(List<? extends io.kcache.CacheUpdateHandler<K,V>> handlers)

Method Summary

Modifier and Type	Method and 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

handleUpdate, validateUpdate

Constructor Detail

CompositeCacheUpdateHandler

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

Method Detail

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 io.kcache.CacheUpdateHandler<K,V>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

cacheDestroyed

public void cacheDestroyed()

Specified by:

cacheDestroyed in interface io.kcache.CacheUpdateHandler<K,V>