CachedDekRegistryClient (dek-registry-client 7.9.8 API)

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 and Description

static class CachedDekRegistryClient.DekId

static class CachedDekRegistryClient.KekId

Nested Classes
Modifier and Type	Class and 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 and Description
`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(List<String> baseUrls, int cacheCapacity, int cacheExpirySecs, Map<String,?> configs, Map<String,String> httpHeaders)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`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)`
`Dek`	`createDek(String kekName, String subject, DekFormat algorithm, String encryptedKeyMaterial)`
`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)`
`Kek`	`createKek(Map<String,String> requestProperties, String name, String kmsType, String kmsKeyId, Map<String,String> kmsProps, String doc, boolean shared, boolean deleted)`
`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)`
`void`	`deleteDek(Map<String,String> requestProperties, String kekName, String subject, DekFormat algorithm, boolean permanentDelete)`
`void`	`deleteDek(String kekName, String subject, DekFormat algorithm, boolean permanentDelete)`
`void`	`deleteDekVersion(Map<String,String> requestProperties, String kekName, String subject, int version, DekFormat algorithm, boolean permanentDelete)`
`void`	`deleteDekVersion(String kekName, String subject, int version, DekFormat algorithm, boolean permanentDelete)`
`void`	`deleteKek(Map<String,String> requestProperties, String kekName, boolean permanentDelete)`
`void`	`deleteKek(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()`
`com.google.common.base.Ticker`	`ticker()`
`void`	`undeleteDek(Map<String,String> requestProperties, String kekName, String subject, DekFormat algorithm)`
`void`	`undeleteDek(String kekName, String subject, DekFormat algorithm)`
`void`	`undeleteDekVersion(Map<String,String> requestProperties, String kekName, String subject, int version, DekFormat algorithm)`
`void`	`undeleteDekVersion(String kekName, String subject, int version, DekFormat algorithm)`
`void`	`undeleteKek(Map<String,String> requestProperties, String kekName)`
`void`	`undeleteKek(String kekName)`
`Kek`	`updateKek(Map<String,String> requestProperties, String name, Map<String,String> kmsProps, String doc, Boolean shared)`
`Kek`	`updateKek(String name, Map<String,String> kmsProps, String doc, Boolean shared)`

Methods inherited from class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient
close, deleteConfig, deleteMode, deleteSchemaVersion, deleteSchemaVersion, deleteSubject, deleteSubject, getAllContexts, getAllSubjects, getAllSubjects, getAllSubjectsById, getAllSubjectsByPrefix, getAllVersions, getAllVersions, getAllVersionsById, getByVersion, getConfig, getConfig, getId, getId, getLatestSchemaMetadata, getLatestWithMetadata, getMode, getMode, getSchemaById, getSchemaByIdFromRegistry, getSchemaBySubjectAndId, getSchemaMetadata, getSchemaMetadata, getSchemaProviders, getSchemaRegistryDeployment, getSchemaRegistryServerVersion, getSchemas, getVersion, getVersion, parseSchema, parseSchema, 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 Detail

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)

Method Detail

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

reset
```
public void reset()
```
Specified by:

reset in interface DekRegistryClient

Specified by:

reset in interface SchemaRegistryClient

Overrides:

reset in class CachedSchemaRegistryClient

Class CachedDekRegistryClient

Nested Class Summary

Field Summary

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

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

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

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

Constructor Detail

CachedDekRegistryClient

CachedDekRegistryClient

CachedDekRegistryClient

Method Detail

ticker

listKeks

listKeks

listKeksWithPagination

getKek

listDeks

listDeksWithPagination

listDekVersions

listDekVersionsWithPagination

getDek

getDekVersion

getDekLatestVersion

createKek

createKek

createKek

createDek

createDek

createDek

createDek

createDek

createDek

updateKek

updateKek

deleteKek

deleteKek

deleteDek

deleteDek

deleteDekVersion

deleteDekVersion

undeleteKek

undeleteKek

undeleteDek

undeleteDek

undeleteDekVersion

undeleteDekVersion

reset