Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- AbstractDekRegistry - Class in io.confluent.dekregistry.storage
-
Abstract base class for DEK Registry implementations.
- AbstractDekRegistry(SchemaRegistry, MetricsManager, DekRegistryConfig) - Constructor for class io.confluent.dekregistry.storage.AbstractDekRegistry
- ALREADY_EXISTS_ERROR_CODE - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- ALREADY_EXISTS_MESSAGE_FORMAT - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- alreadyExistsException(String) - Static method in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- AlreadyExistsException - Exception in io.confluent.dekregistry.storage.exceptions
- AlreadyExistsException() - Constructor for exception io.confluent.dekregistry.storage.exceptions.AlreadyExistsException
- AlreadyExistsException(String) - Constructor for exception io.confluent.dekregistry.storage.exceptions.AlreadyExistsException
- AlreadyExistsException(String, Throwable) - Constructor for exception io.confluent.dekregistry.storage.exceptions.AlreadyExistsException
- AlreadyExistsException(Throwable) - Constructor for exception io.confluent.dekregistry.storage.exceptions.AlreadyExistsException
- AWS_KMS - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- AZURE_KMS - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
C
- cacheDestroyed() - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- cacheFlushed() - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- cacheInitialized(int, Map<TopicPartition, Long>) - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- cacheReset() - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- cacheSynchronized(int, Map<TopicPartition, Long>) - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- checkpoint(int) - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- close() - Method in class io.confluent.dekregistry.DekRegistryResourceExtension
- close() - Method in class io.confluent.dekregistry.metrics.MetricsManager
- close() - Method in class io.confluent.dekregistry.storage.DefaultDekCacheUpdateHandler
- close() - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- close() - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdSerde
- close() - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeySerde
- close() - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- compareTo(EncryptionKeyId) - Method in class io.confluent.dekregistry.storage.DataEncryptionKeyId
- compareTo(EncryptionKeyId) - Method in class io.confluent.dekregistry.storage.EncryptionKeyId
- compareTo(EncryptionKeyId) - Method in class io.confluent.dekregistry.storage.KeyEncryptionKeyId
- CompositeCacheUpdateHandler<K,
V> - Class in io.confluent.dekregistry.storage.utils - CompositeCacheUpdateHandler(List<? extends CacheUpdateHandler<K, V>>) - Constructor for class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- config() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- configure() - Method in class io.confluent.dekregistry.DekRegistryModule
- configure(Map<String, ?>) - Method in interface io.confluent.dekregistry.storage.DekCacheUpdateHandler
- configure(Map<String, ?>, boolean) - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeyDeserializer
- configure(Map<String, ?>, boolean) - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdDeserializer
- configure(Map<String, ?>, boolean) - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdSerde
- configure(Map<String, ?>, boolean) - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdSerializer
- configure(Map<String, ?>, boolean) - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeySerde
- configure(Map<String, ?>, boolean) - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeySerializer
- createCache(Serde<K>, Serde<V>, String, CacheUpdateHandler<K, V>) - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- createDek(AsyncResponse, HttpHeaders, String, CreateDekRequest) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
-
Deprecated.
- createDek(String, boolean, CreateDekRequest) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- createDekOrForward(String, boolean, CreateDekRequest, Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- createDekWithSubject(AsyncResponse, HttpHeaders, String, String, boolean, CreateDekRequest) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- createKek(CreateKekRequest) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- createKek(AsyncResponse, HttpHeaders, boolean, CreateKekRequest) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- createKekOrForward(CreateKekRequest, Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- cryptors - Variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
D
- DataEncryptionKey - Class in io.confluent.dekregistry.storage
- DataEncryptionKey(String, String, DekFormat, int, String, boolean) - Constructor for class io.confluent.dekregistry.storage.DataEncryptionKey
- DataEncryptionKeyId - Class in io.confluent.dekregistry.storage
- DataEncryptionKeyId(String, String, String, DekFormat, int) - Constructor for class io.confluent.dekregistry.storage.DataEncryptionKeyId
- decrementKeyCount(String, KeyType) - Method in class io.confluent.dekregistry.metrics.MetricsManager
- decrementSharedKeyCount(String) - Method in class io.confluent.dekregistry.metrics.MetricsManager
- DEFAULT_ERROR_CODE - Static variable in exception io.confluent.dekregistry.web.rest.exceptions.RestConflictException
- DefaultDekCacheUpdateHandler - Class in io.confluent.dekregistry.storage
- DefaultDekCacheUpdateHandler(AbstractDekRegistry) - Constructor for class io.confluent.dekregistry.storage.DefaultDekCacheUpdateHandler
- DEK_GENERATION_ERROR_CODE - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- DEK_REGISTRY - Static variable in interface io.confluent.dekregistry.storage.DekCacheUpdateHandler
- DEK_REGISTRY_MAX_KEYS_CONFIG - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_REGISTRY_MAX_KEYS_DEFAULT - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_REGISTRY_MAX_KEYS_DOC - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_REGISTRY_TOPIC_CONFIG - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_REGISTRY_TOPIC_DEFAULT - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_REGISTRY_TOPIC_DOC - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_REGISTRY_UPDATE_HANDLERS_CONFIG - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_REGISTRY_UPDATE_HANDLERS_DOC - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_SUBJECT_SEARCH_DEFAULT_LIMIT - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_SUBJECT_SEARCH_DEFAULT_LIMIT_CONFIG - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_SUBJECT_SEARCH_DEFAULT_LIMIT_DOC - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_SUBJECT_SEARCH_MAX_LIMIT_CONFIG - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_SUBJECT_SEARCH_MAX_LIMIT_DEFAULT - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_SUBJECT_SEARCH_MAX_LIMIT_DOC - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_TYPE - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- DEK_VERSION_SEARCH_DEFAULT_LIMIT - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_VERSION_SEARCH_DEFAULT_LIMIT_CONFIG - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_VERSION_SEARCH_DEFAULT_LIMIT_DOC - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_VERSION_SEARCH_MAX_LIMIT_CONFIG - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_VERSION_SEARCH_MAX_LIMIT_DEFAULT - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DEK_VERSION_SEARCH_MAX_LIMIT_DOC - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- DekCacheUpdateHandler - Interface in io.confluent.dekregistry.storage
- dekGenerationException(String) - Static method in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- DekGenerationException - Exception in io.confluent.dekregistry.storage.exceptions
- DekGenerationException() - Constructor for exception io.confluent.dekregistry.storage.exceptions.DekGenerationException
- DekGenerationException(String) - Constructor for exception io.confluent.dekregistry.storage.exceptions.DekGenerationException
- DekGenerationException(String, Throwable) - Constructor for exception io.confluent.dekregistry.storage.exceptions.DekGenerationException
- DekGenerationException(Throwable) - Constructor for exception io.confluent.dekregistry.storage.exceptions.DekGenerationException
- DekRegistry - Class in io.confluent.dekregistry.storage
-
Deprecated.
- DekRegistry(SchemaRegistry, MetricsManager) - Constructor for class io.confluent.dekregistry.storage.DekRegistry
-
Deprecated.
- DekRegistryConfig - Class in io.confluent.dekregistry.storage
- DekRegistryConfig(String) - Constructor for class io.confluent.dekregistry.storage.DekRegistryConfig
- DekRegistryConfig(Properties) - Constructor for class io.confluent.dekregistry.storage.DekRegistryConfig
- DekRegistryConfig(ConfigDef, Properties) - Constructor for class io.confluent.dekregistry.storage.DekRegistryConfig
- DekRegistryErrors - Class in io.confluent.dekregistry.web.rest.exceptions
- DekRegistryErrors() - Constructor for class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- DekRegistryModule - Class in io.confluent.dekregistry
- DekRegistryModule(SchemaRegistry) - Constructor for class io.confluent.dekregistry.DekRegistryModule
- DekRegistryResource - Class in io.confluent.dekregistry.web.rest.resources
- DekRegistryResource(SchemaRegistry, AbstractDekRegistry) - Constructor for class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- DekRegistryResourceExtension - Class in io.confluent.dekregistry
- DekRegistryResourceExtension() - Constructor for class io.confluent.dekregistry.DekRegistryResourceExtension
- dekSubjectSearchDefaultLimit - Variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- dekSubjectSearchMaxLimit - Variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- dekVersionSearchDefaultLimit - Variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- dekVersionSearchMaxLimit - Variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- deleted - Variable in class io.confluent.dekregistry.storage.EncryptionKey
- deleteDek(String, String, DekFormat, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- deleteDekOrForward(String, String, DekFormat, boolean, Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- deleteDekVersion(AsyncResponse, HttpHeaders, String, String, String, DekFormat, boolean) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- deleteDekVersion(String, String, int, DekFormat, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- deleteDekVersionOrForward(String, String, int, DekFormat, boolean, Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- deleteDekVersions(AsyncResponse, HttpHeaders, String, String, DekFormat, boolean) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- deleteKek(AsyncResponse, HttpHeaders, String, boolean) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- deleteKek(String, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- deleteKekOrForward(String, boolean, Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- deserialize(String, byte[]) - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeyDeserializer
- deserialize(String, byte[]) - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdDeserializer
- deserializer() - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdSerde
- deserializer() - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeySerde
E
- EMPTY_AAD - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- EncryptionKey - Class in io.confluent.dekregistry.storage
- EncryptionKey(KeyType, boolean) - Constructor for class io.confluent.dekregistry.storage.EncryptionKey
- EncryptionKeyDeserializer - Class in io.confluent.dekregistry.storage.serialization
- EncryptionKeyDeserializer() - Constructor for class io.confluent.dekregistry.storage.serialization.EncryptionKeyDeserializer
- EncryptionKeyId - Class in io.confluent.dekregistry.storage
- EncryptionKeyId(String, KeyType) - Constructor for class io.confluent.dekregistry.storage.EncryptionKeyId
- EncryptionKeyIdDeserializer - Class in io.confluent.dekregistry.storage.serialization
- EncryptionKeyIdDeserializer() - Constructor for class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdDeserializer
- EncryptionKeyIdSerde - Class in io.confluent.dekregistry.storage.serialization
- EncryptionKeyIdSerde() - Constructor for class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdSerde
- EncryptionKeyIdSerializer - Class in io.confluent.dekregistry.storage.serialization
- EncryptionKeyIdSerializer() - Constructor for class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdSerializer
- EncryptionKeySerde - Class in io.confluent.dekregistry.storage.serialization
- EncryptionKeySerde() - Constructor for class io.confluent.dekregistry.storage.serialization.EncryptionKeySerde
- EncryptionKeySerializer - Class in io.confluent.dekregistry.storage.serialization
- EncryptionKeySerializer() - Constructor for class io.confluent.dekregistry.storage.serialization.EncryptionKeySerializer
- EncryptionUpdateRequestHandler - Class in io.confluent.dekregistry.web.rest.handlers
- EncryptionUpdateRequestHandler() - Constructor for class io.confluent.dekregistry.web.rest.handlers.EncryptionUpdateRequestHandler
- endBatch(int) - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- equals(Object) - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- equals(Object) - Method in class io.confluent.dekregistry.storage.DataEncryptionKeyId
- equals(Object) - Method in class io.confluent.dekregistry.storage.EncryptionKey
- equals(Object) - Method in class io.confluent.dekregistry.storage.EncryptionKeyId
- equals(Object) - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
- equals(Object) - Method in class io.confluent.dekregistry.storage.KeyEncryptionKeyId
- ERROR_CODE - Static variable in exception io.confluent.dekregistry.web.rest.exceptions.RestDekGenerationException
- ERROR_CODE - Static variable in exception io.confluent.dekregistry.web.rest.exceptions.RestInvalidKeyException
- ERROR_CODE - Static variable in exception io.confluent.dekregistry.web.rest.exceptions.RestReferenceExistsException
F
- failBatch(int, Throwable) - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
G
- GCP_KMS - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- generateEncryptedDek(KeyEncryptionKey, DataEncryptionKey) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- generateRawDek(KeyEncryptionKey, DataEncryptionKey) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getAead(KeyEncryptionKey) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getAlgorithm() - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- getAlgorithm() - Method in class io.confluent.dekregistry.storage.DataEncryptionKeyId
- getCacheUpdateHandler(DekRegistryConfig) - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- getCryptor(DekFormat) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getDek(String, String, int, DekFormat, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getDek(String, String, DekFormat, boolean) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- getDekById(DataEncryptionKeyId) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Get a DEK by its ID.
- getDekById(DataEncryptionKeyId) - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- getDekByVersion(String, String, String, DekFormat, boolean) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- getDeks(String, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getDeks(String, String, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getDeks(String, String, String, DekFormat, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getDeksFromStore(String, String, String, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Get all DEKs for a tenant within a KEK name range.
- getDeksFromStore(String, String, String, boolean) - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- getDeksFromStore(String, String, String, DekFormat, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Get DEKs for a specific subject and algorithm.
- getDeksFromStore(String, String, String, DekFormat, boolean) - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- getDekSubjects(String, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getDekSubjects(String, boolean, int, int) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- getDekVersions(String, String, DekFormat, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getDekVersions(String, String, DekFormat, boolean, int, int) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- getDoc() - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
- getEncryptedKeyMaterial() - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- getKek(String, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getKek(String, boolean) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- getKekById(KeyEncryptionKeyId) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Get a KEK by its ID.
- getKekById(KeyEncryptionKeyId) - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- getKekName() - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- getKekName() - Method in class io.confluent.dekregistry.storage.DataEncryptionKeyId
- getKekNames(List<String>, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getKekNames(List<String>, boolean, int, int) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- getKeks(String, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getKeksFromStore(String, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Get all KEKs for a tenant.
- getKeksFromStore(String, boolean) - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- getKeyCount(String, KeyType) - Method in class io.confluent.dekregistry.metrics.MetricsManager
- getKeyMaterial() - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- getKmsKeyId() - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
- getKmsProps() - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
- getKmsType() - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
- getLatestDek(String, String, DekFormat, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getLatestDek(String, String, DekFormat, boolean, boolean) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getMetricsManager() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getName() - Method in exception io.confluent.dekregistry.storage.exceptions.KeyNotSoftDeletedException
- getName() - Method in exception io.confluent.dekregistry.storage.exceptions.KeySoftDeletedException
- getName() - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
- getName() - Method in class io.confluent.dekregistry.storage.KeyEncryptionKeyId
- getOffset() - Method in class io.confluent.dekregistry.storage.EncryptionKey
- getSchemaRegistry() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getSchemaRegistry() - Method in class io.confluent.dekregistry.web.rest.resources.SchemaRegistryResource
- getSharedKeys() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- getSubject() - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- getSubject() - Method in class io.confluent.dekregistry.storage.DataEncryptionKeyId
- getTenant() - Method in class io.confluent.dekregistry.storage.EncryptionKeyId
- getTimestamp() - Method in class io.confluent.dekregistry.storage.EncryptionKey
- getType() - Method in class io.confluent.dekregistry.storage.EncryptionKey
- getType() - Method in class io.confluent.dekregistry.storage.EncryptionKeyId
- getVersion() - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- getVersion() - Method in class io.confluent.dekregistry.storage.DataEncryptionKeyId
H
- handle(Schema, TagSchemaRequest) - Method in class io.confluent.dekregistry.web.rest.handlers.EncryptionUpdateRequestHandler
- handle(String, boolean, RegisterSchemaRequest) - Method in class io.confluent.dekregistry.web.rest.handlers.EncryptionUpdateRequestHandler
- handle(String, ConfigUpdateRequest) - Method in class io.confluent.dekregistry.web.rest.handlers.EncryptionUpdateRequestHandler
- handleUpdate(EncryptionKeyId, EncryptionKey, EncryptionKey, TopicPartition, long, long) - Method in class io.confluent.dekregistry.storage.DefaultDekCacheUpdateHandler
-
Invoked on every new schema written to the Kafka store
- handleUpdate(K, V, V, TopicPartition, long, long) - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- hashCode() - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- hashCode() - Method in class io.confluent.dekregistry.storage.DataEncryptionKeyId
- hashCode() - Method in class io.confluent.dekregistry.storage.EncryptionKey
- hashCode() - Method in class io.confluent.dekregistry.storage.EncryptionKeyId
- hashCode() - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
- hashCode() - Method in class io.confluent.dekregistry.storage.KeyEncryptionKeyId
I
- incrementKeyCount(String, KeyType) - Method in class io.confluent.dekregistry.metrics.MetricsManager
- incrementSharedKeyCount(String) - Method in class io.confluent.dekregistry.metrics.MetricsManager
- init() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- init() - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- initialized - Variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- initialized() - Method in class io.confluent.dekregistry.DekRegistryResourceExtension
- initialized() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- initLatch - Variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- initStore() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Perform any initialization required by the storage backend.
- initStore() - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- INVALID_KEY_ERROR_CODE - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- INVALID_OR_MISSING_KEY_MESSAGE_FORMAT - Static variable in exception io.confluent.dekregistry.web.rest.exceptions.RestInvalidKeyException
- InvalidKeyException - Exception in io.confluent.dekregistry.storage.exceptions
- InvalidKeyException() - Constructor for exception io.confluent.dekregistry.storage.exceptions.InvalidKeyException
- InvalidKeyException(String) - Constructor for exception io.confluent.dekregistry.storage.exceptions.InvalidKeyException
- InvalidKeyException(String, Throwable) - Constructor for exception io.confluent.dekregistry.storage.exceptions.InvalidKeyException
- InvalidKeyException(Throwable) - Constructor for exception io.confluent.dekregistry.storage.exceptions.InvalidKeyException
- invalidOrMissingKeyInfo(String) - Static method in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- io.confluent.dekregistry - package io.confluent.dekregistry
- io.confluent.dekregistry.metrics - package io.confluent.dekregistry.metrics
- io.confluent.dekregistry.storage - package io.confluent.dekregistry.storage
- io.confluent.dekregistry.storage.exceptions - package io.confluent.dekregistry.storage.exceptions
- io.confluent.dekregistry.storage.serialization - package io.confluent.dekregistry.storage.serialization
- io.confluent.dekregistry.storage.utils - package io.confluent.dekregistry.storage.utils
- io.confluent.dekregistry.web.rest.exceptions - package io.confluent.dekregistry.web.rest.exceptions
- io.confluent.dekregistry.web.rest.handlers - package io.confluent.dekregistry.web.rest.handlers
- io.confluent.dekregistry.web.rest.resources - package io.confluent.dekregistry.web.rest.resources
- isDeleted() - Method in class io.confluent.dekregistry.storage.EncryptionKey
- isEquivalent(DataEncryptionKey) - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- isEquivalent(KeyEncryptionKey) - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
- isLeader() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Check if this instance is the leader.
- isLeader(Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- isShared() - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
K
- KafkaDekRegistry - Class in io.confluent.dekregistry.storage
-
Kafka/KCache-backed implementation of DEK Registry.
- KafkaDekRegistry(SchemaRegistry, MetricsManager) - Constructor for class io.confluent.dekregistry.storage.KafkaDekRegistry
- KafkaDekRegistry(SchemaRegistry, MetricsManager, DekRegistryConfig) - Constructor for class io.confluent.dekregistry.storage.KafkaDekRegistry
- KEK_SEARCH_DEFAULT_LIMIT_CONFIG - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- KEK_SEARCH_DEFAULT_LIMIT_DEFAULT - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- KEK_SEARCH_DEFAULT_LIMIT_DOC - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- KEK_SEARCH_MAX_LIMIT_CONFIG - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- KEK_SEARCH_MAX_LIMIT_DEFAULT - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- KEK_SEARCH_MAX_LIMIT_DOC - Static variable in class io.confluent.dekregistry.storage.DekRegistryConfig
- KEK_TYPE - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- kekSearchDefaultLimit - Variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- kekSearchMaxLimit - Variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- KEY - Static variable in class io.confluent.dekregistry.metrics.MetricsManager
- KEY - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- KEY_NOT_FOUND_ERROR_CODE - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- KEY_NOT_FOUND_MESSAGE_FORMAT - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- KEY_NOT_SOFT_DELETED_ERROR_CODE - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- KEY_NOT_SOFT_DELETED_MESSAGE_FORMAT - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- KEY_SOFT_DELETED_ERROR_CODE - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- KEY_SOFT_DELETED_MESSAGE_FORMAT - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- KeyEncryptionKey - Class in io.confluent.dekregistry.storage
- KeyEncryptionKey(String, String, String, SortedMap<String, String>, String, boolean, boolean) - Constructor for class io.confluent.dekregistry.storage.KeyEncryptionKey
- KeyEncryptionKeyId - Class in io.confluent.dekregistry.storage
- KeyEncryptionKeyId(String, String) - Constructor for class io.confluent.dekregistry.storage.KeyEncryptionKeyId
- keyNotFoundException(String) - Static method in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- keyNotSoftDeletedException(String) - Static method in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- KeyNotSoftDeletedException - Exception in io.confluent.dekregistry.storage.exceptions
- KeyNotSoftDeletedException(String) - Constructor for exception io.confluent.dekregistry.storage.exceptions.KeyNotSoftDeletedException
- KeyReferenceExistsException - Exception in io.confluent.dekregistry.storage.exceptions
-
Indicates the key cannot be deleted because another key references it.
- KeyReferenceExistsException() - Constructor for exception io.confluent.dekregistry.storage.exceptions.KeyReferenceExistsException
- KeyReferenceExistsException(String) - Constructor for exception io.confluent.dekregistry.storage.exceptions.KeyReferenceExistsException
- KeyReferenceExistsException(String, Throwable) - Constructor for exception io.confluent.dekregistry.storage.exceptions.KeyReferenceExistsException
- KeyReferenceExistsException(Throwable) - Constructor for exception io.confluent.dekregistry.storage.exceptions.KeyReferenceExistsException
- keys() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Deprecated.
- keys() - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- keySoftDeletedException(String) - Static method in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- KeySoftDeletedException - Exception in io.confluent.dekregistry.storage.exceptions
- KeySoftDeletedException(String) - Constructor for exception io.confluent.dekregistry.storage.exceptions.KeySoftDeletedException
L
- LATEST_VERSION - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- lock(String, Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- lockFor(String) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
M
- maxKeys() - Method in class io.confluent.dekregistry.storage.DekRegistryConfig
- maybeGenerateRawDek(DataEncryptionKey) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- MetricsManager - Class in io.confluent.dekregistry.metrics
- MetricsManager(SchemaRegistry) - Constructor for class io.confluent.dekregistry.metrics.MetricsManager
- MIN_VERSION - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
N
- NAME_MAX_LENGTH - Static variable in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- normalizeDekSubjectLimit(int) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- normalizeDekVersionLimit(int) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- normalizeKekLimit(int) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- normalizeKmsType(String) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- normalizeLimit(int, int, int) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
O
- offset - Variable in class io.confluent.dekregistry.storage.EncryptionKey
P
- putKek(AsyncResponse, HttpHeaders, String, boolean, UpdateKekRequest) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- putKek(String, UpdateKekRequest) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- putKekOrForward(String, UpdateKekRequest, Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- putKey(EncryptionKeyId, EncryptionKey) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Store a key (KEK or DEK).
- putKey(EncryptionKeyId, EncryptionKey) - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
R
- REFERENCE_EXISTS_ERROR_CODE - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- REFERENCE_EXISTS_MESSAGE_FORMAT - Static variable in exception io.confluent.dekregistry.web.rest.exceptions.RestReferenceExistsException
- referenceExistsException(String) - Static method in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- register(Configurable<?>, SchemaRegistryConfig, SchemaRegistry) - Method in class io.confluent.dekregistry.DekRegistryResourceExtension
- removeKey(EncryptionKeyId) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Remove a key from storage.
- removeKey(EncryptionKeyId) - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
- RestConflictException - Exception in io.confluent.dekregistry.web.rest.exceptions
- RestConflictException(String, int) - Constructor for exception io.confluent.dekregistry.web.rest.exceptions.RestConflictException
- RestConflictException(String, int, Throwable) - Constructor for exception io.confluent.dekregistry.web.rest.exceptions.RestConflictException
- RestDekGenerationException - Exception in io.confluent.dekregistry.web.rest.exceptions
- RestDekGenerationException(String) - Constructor for exception io.confluent.dekregistry.web.rest.exceptions.RestDekGenerationException
- RestInvalidKeyException - Exception in io.confluent.dekregistry.web.rest.exceptions
- RestInvalidKeyException(String) - Constructor for exception io.confluent.dekregistry.web.rest.exceptions.RestInvalidKeyException
- RestReferenceExistsException - Exception in io.confluent.dekregistry.web.rest.exceptions
-
Indicates a reference exists to the given key, so it cannot be deleted.
- RestReferenceExistsException(String) - Constructor for exception io.confluent.dekregistry.web.rest.exceptions.RestReferenceExistsException
S
- SchemaRegistryResource - Class in io.confluent.dekregistry.web.rest.resources
- SchemaRegistryResource(SchemaRegistry) - Constructor for class io.confluent.dekregistry.web.rest.resources.SchemaRegistryResource
- serialize(String, EncryptionKey) - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeySerializer
- serialize(String, EncryptionKeyId) - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdSerializer
- serializer() - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeyIdSerde
- serializer() - Method in class io.confluent.dekregistry.storage.serialization.EncryptionKeySerde
- setKeyMaterial(String) - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- setOffset(Long) - Method in class io.confluent.dekregistry.storage.EncryptionKey
- setTimestamp(Long) - Method in class io.confluent.dekregistry.storage.EncryptionKey
- startBatch(int) - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- syncStore() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
-
Sync/refresh the store to ensure it's up-to-date.
- syncStore() - Method in class io.confluent.dekregistry.storage.KafkaDekRegistry
T
- tenantToLock - Variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- TEST_SUBJECT - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
- testKek(KeyEncryptionKey) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- testKek(AsyncResponse, String) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- timestamp - Variable in class io.confluent.dekregistry.storage.EncryptionKey
- toDekEntity() - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- toJson(Object) - Static method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- toKekEntity() - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
- toKekEntity(KeyEncryptionKey) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- toKey(String) - Method in class io.confluent.dekregistry.storage.DataEncryptionKey
- toKey(String) - Method in class io.confluent.dekregistry.storage.EncryptionKey
- toKey(String) - Method in class io.confluent.dekregistry.storage.KeyEncryptionKey
- TOO_MANY_KEYS_ERROR_CODE - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- TOO_MANY_KEYS_MESSAGE_FORMAT - Static variable in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- tooManyKeysException(int) - Static method in class io.confluent.dekregistry.web.rest.exceptions.DekRegistryErrors
- TooManyKeysException - Exception in io.confluent.dekregistry.storage.exceptions
- TooManyKeysException() - Constructor for exception io.confluent.dekregistry.storage.exceptions.TooManyKeysException
- TooManyKeysException(String) - Constructor for exception io.confluent.dekregistry.storage.exceptions.TooManyKeysException
- TooManyKeysException(String, Throwable) - Constructor for exception io.confluent.dekregistry.storage.exceptions.TooManyKeysException
- TooManyKeysException(Throwable) - Constructor for exception io.confluent.dekregistry.storage.exceptions.TooManyKeysException
- topic() - Method in class io.confluent.dekregistry.storage.DekRegistryConfig
- type - Variable in class io.confluent.dekregistry.storage.EncryptionKey
U
- undeleteDek(String, String, DekFormat) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- undeleteDekOrForward(String, String, DekFormat, Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- undeleteDekVersion(AsyncResponse, HttpHeaders, String, String, String, DekFormat) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- undeleteDekVersion(String, String, int, DekFormat) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- undeleteDekVersionOrForward(String, String, int, DekFormat, Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- undeleteDekVersions(AsyncResponse, HttpHeaders, String, String, DekFormat) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- undeleteKek(AsyncResponse, HttpHeaders, String) - Method in class io.confluent.dekregistry.web.rest.resources.DekRegistryResource
- undeleteKek(String) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- undeleteKekOrForward(String, Map<String, String>) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
- unlock(String) - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
V
- validateUpdate(EncryptionKeyId, EncryptionKey, TopicPartition, long, long) - Method in class io.confluent.dekregistry.storage.DefaultDekCacheUpdateHandler
- validateUpdate(Headers, K, V, TopicPartition, long, long, TimestampType, Optional<Integer>) - Method in class io.confluent.dekregistry.storage.utils.CompositeCacheUpdateHandler
- VOID_TYPE - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
W
- waitForInit() - Method in class io.confluent.dekregistry.storage.AbstractDekRegistry
X
- X_FORWARD_HEADER - Static variable in class io.confluent.dekregistry.storage.AbstractDekRegistry
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
KafkaDekRegistryinstead. This class is kept for backward compatibility.