Package io.confluent.dekregistry.client

Class MockDekRegistryClient

java.lang.Object

io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

io.confluent.dekregistry.client.MockDekRegistryClient

All Implemented Interfaces:

DekRegistryClient, SchemaRegistryClient, SchemaVersionFetcher, Closeable, AutoCloseable

public class MockDekRegistryClient
extends MockSchemaRegistryClient
implements DekRegistryClient

Field Summary

Fields

Modifier and Type	Field	Description
static final byte[]	EMPTY_AAD

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

LATEST_VERSION

Constructor Summary

Constructors

Constructor	Description
MockDekRegistryClient(Map<String,?> configs)
MockDekRegistryClient(Map<String,?> configs, List<SchemaProvider> providers)

Method Summary

Modifier and Type	Method	Description
void	close()
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)
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(String kekName, String subject, DekFormat algorithm, boolean permanentDelete)
void	deleteDekVersion(String kekName, String subject, int version, DekFormat algorithm, boolean permanentDelete)
void	deleteKek(String kekName, boolean permanentDelete)
protected Cryptor	getCryptor(DekFormat dekFormat)
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<Integer>	listDekVersions(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted)
List<String>	listKeks(boolean lookupDeleted)
List<String>	listKeks(List<String> subjectPrefix, boolean lookupDeleted)
protected Dek	maybeGenerateEncryptedDek(Dek key)
protected Dek	maybeGenerateRawDek(Dek key)
void	reset()
com.google.common.base.Ticker	ticker()
void	undeleteDek(String kekName, String subject, DekFormat algorithm)
void	undeleteDekVersion(String kekName, String subject, int version, DekFormat algorithm)
void	undeleteKek(String kekName)
Kek	updateKek(String name, Map<String,String> kmsProps, String doc, Boolean shared)

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

addProviders, createAssociation, createOrUpdateAssociation, deleteAssociations, deleteSchemaVersion, deleteSchemaVersion, deleteSubject, deleteSubject, getAllContexts, getAllSubjects, getAllSubjectsById, getAllSubjectsByPrefix, getAllVersions, getAllVersionsById, getAssociationsByResourceId, getAssociationsByResourceName, getAssociationsBySubject, getByVersion, getConfig, getGuid, getGuid, getId, getId, getIdWithResponse, getLatestSchemaMetadata, getLatestWithMetadata, getMode, getMode, getProviders, getSchemaByGuid, getSchemaById, getSchemaBySubjectAndId, getSchemaMetadata, getSchemaMetadata, getSchemaRegistryDeployment, getSchemas, getVersion, getVersion, parseSchema, parseSchema, register, register, register, registerWithResponse, setMode, setMode, setMode, testCompatibility, 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

testKek

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

deleteCompatibility, deleteConfig, deleteMode, deleteSchemaVersion, deleteSchemaVersion, deleteSubject, deleteSubject, getAllSubjects, getAllVersions, getById, getByID, getBySubjectAndId, getBySubjectAndID, getCompatibility, getId, getSchemaRegistryServerVersion, getVersion, mutateAssociations, parseSchema, parseSchemaOrElseThrow, register, register, registerWithResponse, tenant, testCompatibility, testCompatibilityVerbose, updateCompatibility

Field Details

EMPTY_AAD

public static final byte[] EMPTY_AAD

Constructor Details

MockDekRegistryClient

public MockDekRegistryClient(Map<String,?> configs)

MockDekRegistryClient

public MockDekRegistryClient(Map<String,?> configs,
 List<SchemaProvider> providers)

Method Details

getCryptor

protected Cryptor getCryptor(DekFormat dekFormat)

ticker

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

Specified by:

ticker in interface DekRegistryClient

Specified by:

ticker in interface SchemaRegistryClient

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

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

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

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

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

maybeGenerateEncryptedDek

protected Dek maybeGenerateEncryptedDek(Dek key)
                                 throws IOException,
RestClientException

Throws:

IOException

RestClientException

maybeGenerateRawDek

protected Dek maybeGenerateRawDek(Dek key)
                           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

deleteKek

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

Specified by:

deleteKek in interface DekRegistryClient

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

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

undeleteKek

public void undeleteKek(String kekName)
                 throws IOException,
RestClientException

Specified by:

undeleteKek in interface DekRegistryClient

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

undeleteDekVersion

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

Specified by:

undeleteDekVersion 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 MockSchemaRegistryClient

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface DekRegistryClient

Specified by:

close in interface SchemaRegistryClient