Uses of Class
io.confluent.dekregistry.storage.EncryptionKeyId
Packages that use EncryptionKeyId
-
Uses of EncryptionKeyId in io.confluent.dekregistry.storage
Subclasses of EncryptionKeyId in io.confluent.dekregistry.storageMethods in io.confluent.dekregistry.storage that return EncryptionKeyIdMethods in io.confluent.dekregistry.storage that return types with arguments of type EncryptionKeyIdModifier and TypeMethodDescriptionprotected io.kcache.CacheUpdateHandler<EncryptionKeyId,EncryptionKey> KafkaDekRegistry.getCacheUpdateHandler(DekRegistryConfig config) protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> AbstractDekRegistry.getDeks(String tenant, String kekName, String subject, DekFormat algorithm, boolean lookupDeleted) protected abstract List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> AbstractDekRegistry.getDeksFromStore(String tenant, String minKekName, String maxKekName, boolean lookupDeleted) Get all DEKs for a tenant within a KEK name range.protected abstract List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> AbstractDekRegistry.getDeksFromStore(String tenant, String kekName, String subject, DekFormat algorithm, boolean lookupDeleted) Get DEKs for a specific subject and algorithm.protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> KafkaDekRegistry.getDeksFromStore(String tenant, String minKekName, String maxKekName, boolean lookupDeleted) protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> KafkaDekRegistry.getDeksFromStore(String tenant, String kekName, String subject, DekFormat algorithm, boolean lookupDeleted) protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> protected abstract List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> AbstractDekRegistry.getKeksFromStore(String tenant, boolean lookupDeleted) Get all KEKs for a tenant.protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> KafkaDekRegistry.getKeksFromStore(String tenant, boolean lookupDeleted) io.kcache.Cache<EncryptionKeyId,EncryptionKey> AbstractDekRegistry.keys()Deprecated.io.kcache.Cache<EncryptionKeyId,EncryptionKey> KafkaDekRegistry.keys()io.kcache.KeyValueIterator<EncryptionKeyId,EncryptionKey> AbstractDekRegistry.rangeKeys(EncryptionKeyId start, boolean startInclusive, EncryptionKeyId end, boolean endInclusive) Returns an iterator over the encryption keys whose ids fall in the given range.Methods in io.confluent.dekregistry.storage with parameters of type EncryptionKeyIdModifier and TypeMethodDescriptionintDataEncryptionKeyId.compareTo(EncryptionKeyId o) intEncryptionKeyId.compareTo(EncryptionKeyId that) intKeyEncryptionKeyId.compareTo(EncryptionKeyId o) AbstractDekRegistry.getKey(EncryptionKeyId id) Returns the encryption key for the given id, ornullif not found.voidDefaultDekCacheUpdateHandler.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 storeprotected abstract voidAbstractDekRegistry.putKey(EncryptionKeyId id, EncryptionKey key) Store a key (KEK or DEK).protected voidKafkaDekRegistry.putKey(EncryptionKeyId id, EncryptionKey key) io.kcache.KeyValueIterator<EncryptionKeyId,EncryptionKey> AbstractDekRegistry.rangeKeys(EncryptionKeyId start, boolean startInclusive, EncryptionKeyId end, boolean endInclusive) Returns an iterator over the encryption keys whose ids fall in the given range.protected abstract voidAbstractDekRegistry.removeKey(EncryptionKeyId id) Remove a key from storage.protected voidKafkaDekRegistry.removeKey(EncryptionKeyId id) io.kcache.CacheUpdateHandler.ValidationStatusDefaultDekCacheUpdateHandler.validateUpdate(EncryptionKeyId key, EncryptionKey value, org.apache.kafka.common.TopicPartition tp, long offset, long timestamp) -
Uses of EncryptionKeyId in io.confluent.dekregistry.storage.serialization
Methods in io.confluent.dekregistry.storage.serialization that return EncryptionKeyIdModifier and TypeMethodDescriptionEncryptionKeyIdDeserializer.deserialize(String topic, byte[] key) Methods in io.confluent.dekregistry.storage.serialization that return types with arguments of type EncryptionKeyIdModifier and TypeMethodDescriptionorg.apache.kafka.common.serialization.Deserializer<EncryptionKeyId>EncryptionKeyIdSerde.deserializer()org.apache.kafka.common.serialization.Serializer<EncryptionKeyId>EncryptionKeyIdSerde.serializer()Methods in io.confluent.dekregistry.storage.serialization with parameters of type EncryptionKeyIdModifier and TypeMethodDescriptionbyte[]EncryptionKeyIdSerializer.serialize(String topic, EncryptionKeyId key)
AbstractDekRegistry.getKey(EncryptionKeyId)orAbstractDekRegistry.rangeKeys(EncryptionKeyId, boolean, EncryptionKeyId, boolean)instead.