Package io.confluent.dekregistry.client

Class CachedDekRegistryClient

java.lang.Object

io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

io.confluent.dekregistry.client.CachedDekRegistryClient

All Implemented Interfaces:

DekRegistryClient, SchemaRegistryClient, SchemaVersionFetcher, Closeable, AutoCloseable

public class CachedDekRegistryClient
extends CachedSchemaRegistryClient
implements DekRegistryClient

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CachedDekRegistryClient.DekId
static class	CachedDekRegistryClient.KekId

Field Summary

Fields inherited from class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

DEFAULT_REQUEST_PROPERTIES

Fields inherited from interface io.confluent.dekregistry.client.DekRegistryClient

LATEST_VERSION

Constructor Summary

Constructors

Constructor	Description
CachedDekRegistryClient(DekRegistryRestService restService, int cacheCapacity, int cacheExpirySecs, Map<String,?> configs, List<SchemaProvider> providers, Map<String,String> httpHeaders, com.google.common.base.Ticker ticker)
CachedDekRegistryClient(DekRegistryRestService restService, int cacheCapacity, int cacheExpirySecs, Map<String,?> configs, Map<String,String> httpHeaders)
CachedDekRegistryClient(DekRegistryRestService restService, int cacheCapacity, int cacheExpirySecs, Map<String,?> configs, Map<String,String> httpHeaders, com.google.common.base.Ticker ticker)
CachedDekRegistryClient(String baseUrls, int cacheCapacity, int cacheExpirySecs, Map<String,?> configs, List<SchemaProvider> providers, Map<String,String> httpHeaders)
CachedDekRegistryClient(List<String> baseUrls, int cacheCapacity, int cacheExpirySecs, Map<String,?> configs, List<SchemaProvider> providers, Map<String,String> httpHeaders)
CachedDekRegistryClient(List<String> baseUrls, int cacheCapacity, int cacheExpirySecs, Map<String,?> configs, Map<String,String> httpHeaders)

Method Summary

Modifier and Type	Method	Description
Dek	createDek(String kekName, String subject, int version, DekFormat algorithm, String encryptedKeyMaterial)
Dek	createDek(String kekName, String subject, int version, DekFormat algorithm, String encryptedKeyMaterial, boolean deleted)
Dek	createDek(String kekName, String subject, int version, DekFormat algorithm, String encryptedKeyMaterial, boolean deleted, boolean rewrap)
Dek	createDek(String kekName, String subject, DekFormat algorithm, String encryptedKeyMaterial)
Dek	createDek(Map<String,String> requestProperties, String kekName, String subject, Integer version, DekFormat algorithm, String encryptedKeyMaterial, boolean deleted)
Dek	createDek(Map<String,String> requestProperties, String kekName, String subject, Integer version, DekFormat algorithm, String encryptedKeyMaterial, boolean deleted, boolean rewrap)
Kek	createKek(String name, String kmsType, String kmsKeyId, Map<String,String> kmsProps, String doc, boolean shared)
Kek	createKek(String name, String kmsType, String kmsKeyId, Map<String,String> kmsProps, String doc, boolean shared, boolean deleted)
Kek	createKek(Map<String,String> requestProperties, String name, String kmsType, String kmsKeyId, Map<String,String> kmsProps, String doc, boolean shared, boolean deleted)
void	deleteDek(String kekName, String subject, DekFormat algorithm, boolean permanentDelete)
void	deleteDek(Map<String,String> requestProperties, String kekName, String subject, DekFormat algorithm, boolean permanentDelete)
void	deleteDekVersion(String kekName, String subject, int version, DekFormat algorithm, boolean permanentDelete)
void	deleteDekVersion(Map<String,String> requestProperties, String kekName, String subject, int version, DekFormat algorithm, boolean permanentDelete)
void	deleteKek(String kekName, boolean permanentDelete)
void	deleteKek(Map<String,String> requestProperties, String kekName, boolean permanentDelete)
Dek	getDek(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted)
Dek	getDekLatestVersion(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted)
Dek	getDekVersion(String kekName, String subject, int version, DekFormat algorithm, boolean lookupDeleted)
Kek	getKek(String name, boolean lookupDeleted)
List<String>	listDeks(String kekName, boolean lookupDeleted)
List<String>	listDeksWithPagination(String kekName, boolean lookupDeleted, int offset, int limit)
List<Integer>	listDekVersions(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted)
List<Integer>	listDekVersionsWithPagination(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted, int offset, int limit)
List<String>	listKeks(boolean lookupDeleted)
List<String>	listKeks(List<String> subjectPrefix, boolean lookupDeleted)
List<String>	listKeksWithPagination(List<String> subjectPrefix, boolean lookupDeleted, int offset, int limit)
void	reset()
void	testKek(String name)
com.google.common.base.Ticker	ticker()
void	undeleteDek(String kekName, String subject, DekFormat algorithm)
void	undeleteDek(Map<String,String> requestProperties, String kekName, String subject, DekFormat algorithm)
void	undeleteDekVersion(String kekName, String subject, int version, DekFormat algorithm)
void	undeleteDekVersion(Map<String,String> requestProperties, String kekName, String subject, int version, DekFormat algorithm)
void	undeleteKek(String kekName)
void	undeleteKek(Map<String,String> requestProperties, String kekName)
Kek	updateKek(String name, Map<String,String> kmsProps, String doc, Boolean shared)
Kek	updateKek(Map<String,String> requestProperties, String name, Map<String,String> kmsProps, String doc, Boolean shared)

Methods inherited from class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

batchGetAssociations, close, createAssociation, createOrUpdateAssociation, deleteAssociations, deleteConfig, deleteMode, deleteSchemaVersion, deleteSchemaVersion, deleteSubject, deleteSubject, getAllContexts, getAllSubjects, getAllSubjects, getAllSubjectsById, getAllSubjectsByPrefix, getAllVersions, getAllVersions, getAllVersionsById, getAssociationsByResourceId, getAssociationsByResourceName, getAssociationsBySubject, getByVersion, getConfig, getConfig, getGuid, getGuid, getId, getId, getIdWithResponse, getLatestSchemaMetadata, getLatestWithMetadata, getMode, getMode, getSchemaByGuid, getSchemaByGuidFromRegistry, getSchemaById, getSchemaByIdFromRegistry, getSchemaBySubjectAndId, getSchemaEntityByIdFromRegistry, getSchemaEntityBySubjectAndId, getSchemaMetadata, getSchemaMetadata, getSchemaProviders, getSchemaRegistryDeployment, getSchemaRegistryServerVersion, getSchemas, getVersion, getVersion, mutateAssociations, parseSchema, parseSchema, parseSchemaOrElseThrow, register, register, register, registerWithResponse, setMode, setMode, setMode, testCompatibility, testCompatibilityVerbose, testCompatibilityVerbose, updateConfig

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.client.DekRegistryClient

close

Methods inherited from interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteCompatibility, deleteSchemaVersion, deleteSchemaVersion, deleteSubject, deleteSubject, getById, getByID, getBySubjectAndId, getBySubjectAndID, getCompatibility, getCompatibility, getId, getVersion, parseSchema, register, register, registerWithResponse, tenant, testCompatibility, updateCompatibility

Constructor Details

CachedDekRegistryClient

public CachedDekRegistryClient(String baseUrls,
 int cacheCapacity,
 int cacheExpirySecs,
 Map<String,?> configs,
 List<SchemaProvider> providers,
 Map<String,String> httpHeaders)

CachedDekRegistryClient

public CachedDekRegistryClient(List<String> baseUrls,
 int cacheCapacity,
 int cacheExpirySecs,
 Map<String,?> configs,
 List<SchemaProvider> providers,
 Map<String,String> httpHeaders)

CachedDekRegistryClient

public CachedDekRegistryClient(List<String> baseUrls,
 int cacheCapacity,
 int cacheExpirySecs,
 Map<String,?> configs,
 Map<String,String> httpHeaders)

CachedDekRegistryClient

public CachedDekRegistryClient(DekRegistryRestService restService,
 int cacheCapacity,
 int cacheExpirySecs,
 Map<String,?> configs,
 Map<String,String> httpHeaders)

CachedDekRegistryClient

public CachedDekRegistryClient(DekRegistryRestService restService,
 int cacheCapacity,
 int cacheExpirySecs,
 Map<String,?> configs,
 Map<String,String> httpHeaders,
 com.google.common.base.Ticker ticker)

CachedDekRegistryClient

public CachedDekRegistryClient(DekRegistryRestService restService,
 int cacheCapacity,
 int cacheExpirySecs,
 Map<String,?> configs,
 List<SchemaProvider> providers,
 Map<String,String> httpHeaders,
 com.google.common.base.Ticker ticker)

Method Details

ticker

public com.google.common.base.Ticker ticker()

Specified by:

ticker in interface DekRegistryClient

Specified by:

ticker in interface SchemaRegistryClient

Overrides:

ticker in class CachedSchemaRegistryClient

listKeks

public List<String> listKeks(boolean lookupDeleted)
                      throws IOException,
RestClientException

Specified by:

listKeks in interface DekRegistryClient

Throws:

IOException

RestClientException

listKeks

public List<String> listKeks(List<String> subjectPrefix,
 boolean lookupDeleted)
                      throws IOException,
RestClientException

Specified by:

listKeks in interface DekRegistryClient

Throws:

IOException

RestClientException

listKeksWithPagination

public List<String> listKeksWithPagination(List<String> subjectPrefix,
 boolean lookupDeleted,
 int offset,
 int limit)
                                    throws IOException,
RestClientException

Throws:

IOException

RestClientException

getKek

public Kek getKek(String name,
 boolean lookupDeleted)
           throws IOException,
RestClientException

Specified by:

getKek in interface DekRegistryClient

Throws:

IOException

RestClientException

listDeks

public List<String> listDeks(String kekName,
 boolean lookupDeleted)
                      throws IOException,
RestClientException

Specified by:

listDeks in interface DekRegistryClient

Throws:

IOException

RestClientException

listDeksWithPagination

public List<String> listDeksWithPagination(String kekName,
 boolean lookupDeleted,
 int offset,
 int limit)
                                    throws IOException,
RestClientException

Throws:

IOException

RestClientException

listDekVersions

public List<Integer> listDekVersions(String kekName,
 String subject,
 DekFormat algorithm,
 boolean lookupDeleted)
                              throws IOException,
RestClientException

Specified by:

listDekVersions in interface DekRegistryClient

Throws:

IOException

RestClientException

listDekVersionsWithPagination

public List<Integer> listDekVersionsWithPagination(String kekName,
 String subject,
 DekFormat algorithm,
 boolean lookupDeleted,
 int offset,
 int limit)
                                            throws IOException,
RestClientException

Throws:

IOException

RestClientException

getDek

public Dek getDek(String kekName,
 String subject,
 DekFormat algorithm,
 boolean lookupDeleted)
           throws IOException,
RestClientException

Specified by:

getDek in interface DekRegistryClient

Throws:

IOException

RestClientException

getDekVersion

public Dek getDekVersion(String kekName,
 String subject,
 int version,
 DekFormat algorithm,
 boolean lookupDeleted)
                  throws IOException,
RestClientException

Specified by:

getDekVersion in interface DekRegistryClient

Throws:

IOException

RestClientException

getDekLatestVersion

public Dek getDekLatestVersion(String kekName,
 String subject,
 DekFormat algorithm,
 boolean lookupDeleted)
                        throws IOException,
RestClientException

Specified by:

getDekLatestVersion in interface DekRegistryClient

Throws:

IOException

RestClientException

createKek

public Kek createKek(String name,
 String kmsType,
 String kmsKeyId,
 Map<String,String> kmsProps,
 String doc,
 boolean shared)
              throws IOException,
RestClientException

Specified by:

createKek in interface DekRegistryClient

Throws:

IOException

RestClientException

createKek

public Kek createKek(String name,
 String kmsType,
 String kmsKeyId,
 Map<String,String> kmsProps,
 String doc,
 boolean shared,
 boolean deleted)
              throws IOException,
RestClientException

Specified by:

createKek in interface DekRegistryClient

Throws:

IOException

RestClientException

createKek

public Kek createKek(Map<String,String> requestProperties,
 String name,
 String kmsType,
 String kmsKeyId,
 Map<String,String> kmsProps,
 String doc,
 boolean shared,
 boolean deleted)
              throws IOException,
RestClientException

Throws:

IOException

RestClientException

createDek

public Dek createDek(String kekName,
 String subject,
 DekFormat algorithm,
 String encryptedKeyMaterial)
              throws IOException,
RestClientException

Specified by:

createDek in interface DekRegistryClient

Throws:

IOException

RestClientException

createDek

public Dek createDek(String kekName,
 String subject,
 int version,
 DekFormat algorithm,
 String encryptedKeyMaterial)
              throws IOException,
RestClientException

Specified by:

createDek in interface DekRegistryClient

Throws:

IOException

RestClientException

createDek

public Dek createDek(String kekName,
 String subject,
 int version,
 DekFormat algorithm,
 String encryptedKeyMaterial,
 boolean deleted)
              throws IOException,
RestClientException

Specified by:

createDek in interface DekRegistryClient

Throws:

IOException

RestClientException

createDek

public Dek createDek(String kekName,
 String subject,
 int version,
 DekFormat algorithm,
 String encryptedKeyMaterial,
 boolean deleted,
 boolean rewrap)
              throws IOException,
RestClientException

Specified by:

createDek in interface DekRegistryClient

Throws:

IOException

RestClientException

createDek

public Dek createDek(Map<String,String> requestProperties,
 String kekName,
 String subject,
 Integer version,
 DekFormat algorithm,
 String encryptedKeyMaterial,
 boolean deleted)
              throws IOException,
RestClientException

Throws:

IOException

RestClientException

createDek

public Dek createDek(Map<String,String> requestProperties,
 String kekName,
 String subject,
 Integer version,
 DekFormat algorithm,
 String encryptedKeyMaterial,
 boolean deleted,
 boolean rewrap)
              throws IOException,
RestClientException

Throws:

IOException

RestClientException

updateKek

public Kek updateKek(String name,
 Map<String,String> kmsProps,
 String doc,
 Boolean shared)
              throws IOException,
RestClientException

Specified by:

updateKek in interface DekRegistryClient

Throws:

IOException

RestClientException

updateKek

public Kek updateKek(Map<String,String> requestProperties,
 String name,
 Map<String,String> kmsProps,
 String doc,
 Boolean shared)
              throws IOException,
RestClientException

Throws:

IOException

RestClientException

deleteKek

public void deleteKek(String kekName,
 boolean permanentDelete)
               throws IOException,
RestClientException

Specified by:

deleteKek in interface DekRegistryClient

Throws:

IOException

RestClientException

deleteKek

public void deleteKek(Map<String,String> requestProperties,
 String kekName,
 boolean permanentDelete)
               throws IOException,
RestClientException

Throws:

IOException

RestClientException

deleteDek

public void deleteDek(String kekName,
 String subject,
 DekFormat algorithm,
 boolean permanentDelete)
               throws IOException,
RestClientException

Specified by:

deleteDek in interface DekRegistryClient

Throws:

IOException

RestClientException

deleteDek

public void deleteDek(Map<String,String> requestProperties,
 String kekName,
 String subject,
 DekFormat algorithm,
 boolean permanentDelete)
               throws IOException,
RestClientException

Throws:

IOException

RestClientException

deleteDekVersion

public void deleteDekVersion(String kekName,
 String subject,
 int version,
 DekFormat algorithm,
 boolean permanentDelete)
                      throws IOException,
RestClientException

Specified by:

deleteDekVersion in interface DekRegistryClient

Throws:

IOException

RestClientException

deleteDekVersion

public void deleteDekVersion(Map<String,String> requestProperties,
 String kekName,
 String subject,
 int version,
 DekFormat algorithm,
 boolean permanentDelete)
                      throws IOException,
RestClientException

Throws:

IOException

RestClientException

undeleteKek

public void undeleteKek(String kekName)
                 throws IOException,
RestClientException

Specified by:

undeleteKek in interface DekRegistryClient

Throws:

IOException

RestClientException

undeleteKek

public void undeleteKek(Map<String,String> requestProperties,
 String kekName)
                 throws IOException,
RestClientException

Throws:

IOException

RestClientException

undeleteDek

public void undeleteDek(String kekName,
 String subject,
 DekFormat algorithm)
                 throws IOException,
RestClientException

Specified by:

undeleteDek in interface DekRegistryClient

Throws:

IOException

RestClientException

undeleteDek

public void undeleteDek(Map<String,String> requestProperties,
 String kekName,
 String subject,
 DekFormat algorithm)
                 throws IOException,
RestClientException

Throws:

IOException

RestClientException

undeleteDekVersion

public void undeleteDekVersion(String kekName,
 String subject,
 int version,
 DekFormat algorithm)
                        throws IOException,
RestClientException

Specified by:

undeleteDekVersion in interface DekRegistryClient

Throws:

IOException

RestClientException

undeleteDekVersion

public void undeleteDekVersion(Map<String,String> requestProperties,
 String kekName,
 String subject,
 int version,
 DekFormat algorithm)
                        throws IOException,
RestClientException

Throws:

IOException

RestClientException

testKek

public void testKek(String name)
             throws IOException,
RestClientException

Specified by:

testKek in interface DekRegistryClient

Throws:

IOException

RestClientException

reset

public void reset()

Specified by:

reset in interface DekRegistryClient

Specified by:

reset in interface SchemaRegistryClient

Overrides:

reset in class CachedSchemaRegistryClient