Class DekRegistryRestService
java.lang.Object
io.confluent.kafka.schemaregistry.client.rest.RestService
io.confluent.dekregistry.client.rest.DekRegistryRestService
- All Implemented Interfaces:
Closeable,AutoCloseable,org.apache.kafka.common.Configurable
public class DekRegistryRestService
extends RestService
implements org.apache.kafka.common.Configurable
-
Field Summary
Fields inherited from class io.confluent.kafka.schemaregistry.client.rest.RestService
ACCEPT_UNKNOWN_PROPERTIES, CONFLUENT_CLIENT_VERSION, DEFAULT_REQUEST_PROPERTIES, VERSION_8_0, X_FORWARD_HEADER -
Constructor Summary
ConstructorsConstructorDescriptionDekRegistryRestService(UrlList baseUrls) DekRegistryRestService(String baseUrlConfig) DekRegistryRestService(List<String> baseUrls) -
Method Summary
Modifier and TypeMethodDescriptioncreateDek(String kekName, boolean rewrap, CreateDekRequest request) createDek(String kekName, CreateDekRequest request) createDek(Map<String, String> requestProperties, String kekName, boolean rewrap, CreateDekRequest request) createKek(CreateKekRequest request) createKek(Map<String, String> requestProperties, CreateKekRequest request) voidvoidvoiddeleteDek(Map<String, String> requestProperties, String name, String subject, DekFormat algorithm, boolean permanentDelete) voiddeleteDekVersion(String name, String subject, int version, boolean permanentDelete) voiddeleteDekVersion(String name, String subject, int version, DekFormat algorithm, boolean permanentDelete) voiddeleteDekVersion(Map<String, String> requestProperties, String name, String subject, int version, DekFormat algorithm, boolean permanentDelete) voidvoidgetDek(Map<String, String> requestProperties, String kekName, String subject, DekFormat algorithm, boolean lookupDeleted) getDekVersion(String name, String subject, int version, boolean lookupDeleted) getDekVersion(String name, String subject, int version, DekFormat algorithm, boolean lookupDeleted) getDekVersion(Map<String, String> requestProperties, String kekName, String subject, int version, DekFormat algorithm, boolean lookupDeleted) listDeksWithPagination(String kekName, boolean lookupDeleted, int offset, int limit) listDekVersions(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted) listDekVersions(Map<String, String> requestProperties, String kekName, String subject, DekFormat algorithm, boolean lookupDeleted) listDekVersionsWithPagination(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted, int offset, int limit) listKeks(boolean lookupDeleted) listKeksWithPagination(List<String> subjectPrefix, boolean lookupDeleted, int offset, int limit) voidvoidundeleteDek(String name, String subject, DekFormat algorithm) voidvoidundeleteDekVersion(String name, String subject, int version, DekFormat algorithm) voidundeleteDekVersion(Map<String, String> requestProperties, String name, String subject, int version, DekFormat algorithm) voidundeleteKek(String name) voidundeleteKek(Map<String, String> requestProperties, String name) updateKek(String name, UpdateKekRequest request) Methods inherited from class io.confluent.kafka.schemaregistry.client.rest.RestService
buildConnection, close, configure, createAssociation, createOrUpdateAssociation, deleteAssociations, deleteConfig, deleteConfig, deleteContext, deleteSchemaVersion, deleteSchemaVersion, deleteSubject, deleteSubject, deleteSubjectMode, deleteSubjectMode, deleteSubjectMode, getAllContextIds, getAllContextIds, getAllContexts, getAllContexts, getAllContexts, getAllContexts, getAllContextsWithPagination, getAllSubjects, getAllSubjects, getAllSubjects, getAllSubjects, getAllSubjects, getAllSubjects, getAllSubjectsById, getAllSubjectsById, getAllSubjectsById, getAllSubjectsById, getAllSubjectsById, getAllSubjectsById, getAllSubjectsByIdWithPagination, getAllSubjectsWithPagination, getAllSubjectsWithPagination, getAllVersions, getAllVersions, getAllVersions, getAllVersions, getAllVersionsById, getAllVersionsById, getAllVersionsById, getAllVersionsById, getAllVersionsById, getAllVersionsById, getAllVersionsByIdWithPagination, getAllVersionsWithPagination, getAssociationsByResourceId, getAssociationsByResourceName, getAssociationsBySubject, getBaseUrls, getByGuid, getByGuid, getClusterId, getClusterId, getConfig, getConfig, getConfig, getDeletedOnlySubjects, getDeletedOnlyVersions, getId, getId, getId, getId, getId, getId, getId, getId, getId, getId, getLatestVersion, getLatestVersion, getLatestVersion, getLatestVersion, getLatestVersionSchemaOnly, getLatestWithMetadata, getLatestWithMetadata, getLatestWithMetadata, getMode, getMode, getMode, getOnlySchemaById, getOnlySchemaById, getReferencedBy, getReferencedBy, getReferencedByWithPagination, getSchemaRegistryDeployment, getSchemaRegistryServerVersion, getSchemas, getSchemas, getSchemas, getSchemaTypes, getSchemaTypes, getVersion, getVersion, getVersion, getVersion, getVersion, getVersion, getVersionSchemaOnly, httpRequest, isForward, isRestClientExceptionRetriable, lookUpSubjectVersion, lookUpSubjectVersion, lookUpSubjectVersion, lookUpSubjectVersion, lookUpSubjectVersion, lookUpSubjectVersion, lookUpSubjectVersion, lookUpSubjectVersion, modifySchemaTags, mutateAssociations, registerSchema, registerSchema, registerSchema, registerSchema, registerSchema, registerSchema, registerSchema, registerSchema, registerSchema, registerSchema, registerSchema, setBasicAuthCredentialProvider, setBearerAuthCredentialProvider, setHostnameVerifier, setHttpConnectTimeoutMs, setHttpHeaders, setHttpReadTimeoutMs, setMode, setMode, setMode, setMode, setProxy, setSslSocketFactory, testCompatibility, testCompatibility, testCompatibility, testCompatibility, testCompatibility, updateCompatibility, updateConfig, updateConfigMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.kafka.common.Configurable
configure
-
Constructor Details
-
DekRegistryRestService
-
DekRegistryRestService
-
DekRegistryRestService
-
-
Method Details
-
listKeks
- Throws:
IOExceptionRestClientException
-
listKeks
public List<String> listKeks(List<String> subjectPrefix, boolean lookupDeleted) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
listKeks
public List<String> listKeks(Map<String, String> requestProperties, List<String> subjectPrefix, boolean lookupDeleted) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
listKeksWithPagination
public List<String> listKeksWithPagination(List<String> subjectPrefix, boolean lookupDeleted, int offset, int limit) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
getKek
- Throws:
IOExceptionRestClientException
-
getKek
public Kek getKek(Map<String, String> requestProperties, String name, boolean lookupDeleted) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
listDeks
public List<String> listDeks(String kekName, boolean lookupDeleted) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
listDeks
public List<String> listDeks(Map<String, String> requestProperties, String kekName, boolean lookupDeleted) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
listDeksWithPagination
public List<String> listDeksWithPagination(String kekName, boolean lookupDeleted, int offset, int limit) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
listDekVersions
public List<Integer> listDekVersions(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
listDekVersions
public List<Integer> listDekVersions(Map<String, String> requestProperties, String kekName, String subject, DekFormat algorithm, boolean lookupDeleted) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
listDekVersionsWithPagination
public List<Integer> listDekVersionsWithPagination(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted, int offset, int limit) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
getDek
public Dek getDek(String name, String subject, boolean lookupDeleted) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
getDek
public Dek getDek(String name, String subject, DekFormat algorithm, boolean lookupDeleted) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
getDek
public Dek getDek(Map<String, String> requestProperties, String kekName, String subject, DekFormat algorithm, boolean lookupDeleted) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
getDekVersion
public Dek getDekVersion(String name, String subject, int version, boolean lookupDeleted) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
getDekVersion
public Dek getDekVersion(String name, String subject, int version, DekFormat algorithm, boolean lookupDeleted) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
getDekVersion
public Dek getDekVersion(Map<String, String> requestProperties, String kekName, String subject, int version, DekFormat algorithm, boolean lookupDeleted) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
createKek
- Throws:
IOExceptionRestClientException
-
createKek
public Kek createKek(Map<String, String> requestProperties, CreateKekRequest request) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
createDek
public Dek createDek(String kekName, CreateDekRequest request) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
createDek
public Dek createDek(String kekName, boolean rewrap, CreateDekRequest request) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
createDek
public Dek createDek(Map<String, String> requestProperties, String kekName, boolean rewrap, CreateDekRequest request) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
updateKek
- Throws:
IOExceptionRestClientException
-
updateKek
public Kek updateKek(Map<String, String> requestProperties, String name, UpdateKekRequest request) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
deleteKek
- Throws:
IOExceptionRestClientException
-
deleteKek
public void deleteKek(Map<String, String> requestProperties, String name, boolean permanentDelete) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
deleteDek
public void deleteDek(String name, String subject, boolean permanentDelete) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
deleteDek
public void deleteDek(String name, String subject, DekFormat algorithm, boolean permanentDelete) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
deleteDek
public void deleteDek(Map<String, String> requestProperties, String name, String subject, DekFormat algorithm, boolean permanentDelete) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
deleteDekVersion
public void deleteDekVersion(String name, String subject, int version, boolean permanentDelete) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
deleteDekVersion
public void deleteDekVersion(String name, String subject, int version, DekFormat algorithm, boolean permanentDelete) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
deleteDekVersion
public void deleteDekVersion(Map<String, String> requestProperties, String name, String subject, int version, DekFormat algorithm, boolean permanentDelete) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
undeleteKek
- Throws:
IOExceptionRestClientException
-
undeleteKek
public void undeleteKek(Map<String, String> requestProperties, String name) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
undeleteDek
public void undeleteDek(String name, String subject, DekFormat algorithm) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
undeleteDek
public void undeleteDek(Map<String, String> requestProperties, String name, String subject, DekFormat algorithm) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
undeleteDekVersion
public void undeleteDekVersion(String name, String subject, int version, DekFormat algorithm) throws IOException, RestClientException - Throws:
IOExceptionRestClientException
-
undeleteDekVersion
public void undeleteDekVersion(Map<String, String> requestProperties, String name, String subject, int version, DekFormat algorithm) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-
testKek
public void testKek(Map<String, String> requestProperties, String name) throws IOException, RestClientException- Throws:
IOExceptionRestClientException
-