Package 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	Description
DefaultDekCacheUpdateHandler(KafkaDekRegistry dekRegistry)

Method Summary

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

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

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

configure

Constructor Details

DefaultDekCacheUpdateHandler

public DefaultDekCacheUpdateHandler(KafkaDekRegistry dekRegistry)

Method Details

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 AutoCloseable

Specified by:

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

Specified by:

close in interface Closeable