io.confluent.dekregistry.storage

Class DefaultDekCacheUpdateHandler

java.lang.Object

io.confluent.dekregistry.storage.DefaultDekCacheUpdateHandler

All Implemented Interfaces:

DekCacheUpdateHandler, io.kcache.CacheUpdateHandler<EncryptionKeyId,EncryptionKey>, Closeable, AutoCloseable, org.apache.kafka.common.Configurable

public class DefaultDekCacheUpdateHandler
extends Object
implements DekCacheUpdateHandler

Nested Class Summary

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

io.kcache.CacheUpdateHandler.ValidationStatus

Field Summary

Fields inherited from interface io.confluent.dekregistry.storage.DekCacheUpdateHandler

DEK_REGISTRY

Constructor Summary

Constructors

Constructor and Description
DefaultDekCacheUpdateHandler(DekRegistry dekRegistry)

Method Summary

Modifier and Type	Method and Description
void	close()
void	handleUpdate(EncryptionKeyId key, EncryptionKey value, EncryptionKey oldValue, org.apache.kafka.common.TopicPartition tp, long offset, long timestamp) Invoked on every new schema written to the Kafka store
io.kcache.CacheUpdateHandler.ValidationStatus	validateUpdate(EncryptionKeyId key, EncryptionKey value, org.apache.kafka.common.TopicPartition tp, long offset, long timestamp)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.confluent.dekregistry.storage.DekCacheUpdateHandler

configure

Methods inherited from interface io.kcache.CacheUpdateHandler

cacheDestroyed, cacheFlushed, cacheInitialized, cacheReset, cacheSynchronized, checkpoint, endBatch, failBatch, handleUpdate, startBatch, validateUpdate

Constructor Detail

DefaultDekCacheUpdateHandler

public DefaultDekCacheUpdateHandler(DekRegistry dekRegistry)

Method Detail

validateUpdate

public io.kcache.CacheUpdateHandler.ValidationStatus validateUpdate(EncryptionKeyId key,
                                                                    EncryptionKey value,
                                                                    org.apache.kafka.common.TopicPartition tp,
                                                                    long offset,
                                                                    long timestamp)

Specified by:

validateUpdate in interface io.kcache.CacheUpdateHandler<EncryptionKeyId,EncryptionKey>

handleUpdate

public void handleUpdate(EncryptionKeyId key,
                         EncryptionKey value,
                         EncryptionKey oldValue,
                         org.apache.kafka.common.TopicPartition tp,
                         long offset,
                         long timestamp)

Invoked on every new schema written to the Kafka store

Specified by:

handleUpdate in interface io.kcache.CacheUpdateHandler<EncryptionKeyId,EncryptionKey>

Parameters:

key - Key associated with the schema.

value - Value written to the Kafka lookupCache

close

public void close()

Specified by:

close in interface io.kcache.CacheUpdateHandler<EncryptionKeyId,EncryptionKey>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable