io.confluent.dekregistry.web.rest.resources

Class DekRegistryResource

java.lang.Object

io.confluent.dekregistry.web.rest.resources.SchemaRegistryResource

io.confluent.dekregistry.web.rest.resources.DekRegistryResource

@Path(value="/dek-registry/v1/keks")
 @Singleton
 @Produces(value={"application/vnd.schemaregistry.v1+json","application/vnd.schemaregistry+json; qs=0.9","application/json; qs=0.5"})
 @Consumes(value={"application/vnd.schemaregistry.v1+json","application/vnd.schemaregistry+json","application/json","application/octet-stream"})
public class DekRegistryResource
extends SchemaRegistryResource

Field Summary

Fields

Modifier and Type	Field and Description
static int	NAME_MAX_LENGTH

Constructor Summary

Constructors

Constructor and Description
DekRegistryResource(SchemaRegistry schemaRegistry, DekRegistry dekRegistry)

Method Summary

Modifier and Type	Method and Description
void	createDek(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, String kekName, @NotNull CreateDekRequest request) Deprecated.
void	createDekWithSubject(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, String kekName, String subject, boolean rewrap, @NotNull CreateDekRequest request)
void	createKek(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, boolean testSharing, @NotNull CreateKekRequest request)
void	deleteDekVersion(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, String kekName, String subject, String version, DekFormat algorithm, boolean permanentDelete)
void	deleteDekVersions(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, String kekName, String subject, DekFormat algorithm, boolean permanentDelete)
void	deleteKek(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, String name, boolean permanentDelete)
Dek	getDek(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted)
Dek	getDekByVersion(String kekName, String subject, String version, DekFormat algorithm, boolean lookupDeleted)
List<String>	getDekSubjects(String kekName, boolean lookupDeleted)
List<Integer>	getDekVersions(String kekName, String subject, DekFormat algorithm, boolean lookupDeleted)
Kek	getKek(String name, boolean lookupDeleted)
List<String>	getKekNames(List<String> subjectPrefix, boolean lookupDeleted)
void	putKek(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, String name, boolean testSharing, @NotNull UpdateKekRequest request)
void	testKek(javax.ws.rs.container.AsyncResponse asyncResponse, String kekName)
void	undeleteDekVersion(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, String kekName, String subject, String version, DekFormat algorithm)
void	undeleteDekVersions(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, String kekName, String subject, DekFormat algorithm)
void	undeleteKek(javax.ws.rs.container.AsyncResponse asyncResponse, javax.ws.rs.core.HttpHeaders headers, String name)

Methods inherited from class io.confluent.dekregistry.web.rest.resources.SchemaRegistryResource

getSchemaRegistry

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NAME_MAX_LENGTH

public static final int NAME_MAX_LENGTH

See Also:

Constant Field Values

Constructor Detail

DekRegistryResource

@Inject
public DekRegistryResource(SchemaRegistry schemaRegistry,
                                   DekRegistry dekRegistry)

Method Detail

getKekNames

@GET
 @PerformanceMetric(value="keks.list")
 @DocumentedName(value="getKekNames")
public List<String> getKekNames(@QueryParam(value="subjectPrefix")
                                                                                                                  List<String> subjectPrefix,
                                                                                                                  @QueryParam(value="deleted")
                                                                                                                  boolean lookupDeleted)

getKek

@GET
 @Path(value="/{name}")
 @PerformanceMetric(value="keks.get")
 @DocumentedName(value="getKek")
public Kek getKek(@PathParam(value="name")
                                                                                                                      String name,
                                                                                                                      @QueryParam(value="deleted")
                                                                                                                      boolean lookupDeleted)

getDekSubjects

@GET
 @Path(value="/{name}/deks")
 @PerformanceMetric(value="deks.list")
 @DocumentedName(value="getDekSubjects")
public List<String> getDekSubjects(@PathParam(value="name")
                                                                                                                                                     String kekName,
                                                                                                                                                     @QueryParam(value="deleted")
                                                                                                                                                     boolean lookupDeleted)

getDek

@GET
 @Path(value="/{name}/deks/{subject}")
 @PerformanceMetric(value="deks.get")
 @DocumentedName(value="getDek")
public Dek getDek(@PathParam(value="name")
                                                                                                                                     String kekName,
                                                                                                                                     @PathParam(value="subject")
                                                                                                                                     String subject,
                                                                                                                                     @QueryParam(value="algorithm")
                                                                                                                                     DekFormat algorithm,
                                                                                                                                     @QueryParam(value="deleted")
                                                                                                                                     boolean lookupDeleted)

getDekVersions

@GET
 @Path(value="/{name}/deks/{subject}/versions")
 @PerformanceMetric(value="deks.versions.list")
 @DocumentedName(value="getAllDekVersions")
public List<Integer> getDekVersions(@PathParam(value="name")
                                                                                                                                                                                     String kekName,
                                                                                                                                                                                     @PathParam(value="subject")
                                                                                                                                                                                     String subject,
                                                                                                                                                                                     @QueryParam(value="algorithm")
                                                                                                                                                                                     DekFormat algorithm,
                                                                                                                                                                                     @QueryParam(value="deleted")
                                                                                                                                                                                     boolean lookupDeleted)

getDekByVersion

@GET
 @Path(value="/{name}/deks/{subject}/versions/{version}")
 @PerformanceMetric(value="deks.versions.get")
 @DocumentedName(value="getDekByVersion")
public Dek getDekByVersion(@PathParam(value="name")
                                                                                                                                                                                   String kekName,
                                                                                                                                                                                   @PathParam(value="subject")
                                                                                                                                                                                   String subject,
                                                                                                                                                                                   @PathParam(value="version")
                                                                                                                                                                                   String version,
                                                                                                                                                                                   @QueryParam(value="algorithm")
                                                                                                                                                                                   DekFormat algorithm,
                                                                                                                                                                                   @QueryParam(value="deleted")
                                                                                                                                                                                   boolean lookupDeleted)

createKek

@POST
 @PerformanceMetric(value="keks.create")
 @DocumentedName(value="registerKek")
public void createKek(@Suspended
                                                                                                           javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                           @Context
                                                                                                           javax.ws.rs.core.HttpHeaders headers,
                                                                                                           @QueryParam(value="testSharing")
                                                                                                           boolean testSharing,
                                                                                                           @NotNull
                                                                                                           @NotNull CreateKekRequest request)

testKek

@POST
 @Path(value="/{name}/test")
 @PerformanceMetric(value="keks.test")
 @DocumentedName(value="testKek")
public void testKek(@Suspended
                                                                                                                                javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                                                @PathParam(value="name")
                                                                                                                                String kekName)

createDek

@Deprecated
 @POST
 @Path(value="/{name}/deks")
 @PerformanceMetric(value="deks.create")
 @DocumentedName(value="registerDek")
public void createDek(@Suspended
                                                                                                                                                     javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                                                                     @Context
                                                                                                                                                     javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                     @PathParam(value="name")
                                                                                                                                                     String kekName,
                                                                                                                                                     @NotNull
                                                                                                                                                     @NotNull CreateDekRequest request)

Deprecated.

createDekWithSubject

@POST
 @Path(value="/{name}/deks/{subject}")
 @PerformanceMetric(value="deks.create")
 @DocumentedName(value="registerDekWithSubject")
public void createDekWithSubject(@Suspended
                                                                                                                                                                        javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                                                                                        @Context
                                                                                                                                                                        javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                        @PathParam(value="name")
                                                                                                                                                                        String kekName,
                                                                                                                                                                        @PathParam(value="subject")
                                                                                                                                                                        String subject,
                                                                                                                                                                        @QueryParam(value="rewrap")
                                                                                                                                                                        boolean rewrap,
                                                                                                                                                                        @NotNull
                                                                                                                                                                        @NotNull CreateDekRequest request)

putKek

@PUT
 @Path(value="/{name}")
 @PerformanceMetric(value="keks.put")
 @DocumentedName(value="updateKek")
public void putKek(@Suspended
                                                                                                                          javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                                          @Context
                                                                                                                          javax.ws.rs.core.HttpHeaders headers,
                                                                                                                          @PathParam(value="name")
                                                                                                                          String name,
                                                                                                                          @QueryParam(value="testSharing")
                                                                                                                          boolean testSharing,
                                                                                                                          @NotNull
                                                                                                                          @NotNull UpdateKekRequest request)

deleteKek

@DELETE
 @Path(value="/{name}")
 @PerformanceMetric(value="keks.delete")
 @DocumentedName(value="deregisterKek")
public void deleteKek(@Suspended
                                                                                                                                       javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                                                       @Context
                                                                                                                                       javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                       @PathParam(value="name")
                                                                                                                                       String name,
                                                                                                                                       @QueryParam(value="permanent")
                                                                                                                                       boolean permanentDelete)

deleteDekVersions

@DELETE
 @Path(value="/{name}/deks/{subject}")
 @PerformanceMetric(value="deks.delete")
 @DocumentedName(value="deregisterDekVersions")
public void deleteDekVersions(@Suspended
                                                                                                                                                                      javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                                                                                      @Context
                                                                                                                                                                      javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                      @PathParam(value="name")
                                                                                                                                                                      String kekName,
                                                                                                                                                                      @PathParam(value="subject")
                                                                                                                                                                      String subject,
                                                                                                                                                                      @QueryParam(value="algorithm")
                                                                                                                                                                      DekFormat algorithm,
                                                                                                                                                                      @QueryParam(value="permanent")
                                                                                                                                                                      boolean permanentDelete)

deleteDekVersion

@DELETE
 @Path(value="/{name}/deks/{subject}/versions/{version}")
 @PerformanceMetric(value="deks.versions.delete")
 @DocumentedName(value="deregisterDekVersion")
public void deleteDekVersion(@Suspended
                                                                                                                                                                                                javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                                                                                                                @Context
                                                                                                                                                                                                javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                                                @PathParam(value="name")
                                                                                                                                                                                                String kekName,
                                                                                                                                                                                                @PathParam(value="subject")
                                                                                                                                                                                                String subject,
                                                                                                                                                                                                @PathParam(value="version")
                                                                                                                                                                                                String version,
                                                                                                                                                                                                @QueryParam(value="algorithm")
                                                                                                                                                                                                DekFormat algorithm,
                                                                                                                                                                                                @QueryParam(value="permanent")
                                                                                                                                                                                                boolean permanentDelete)

undeleteKek

@POST
 @Path(value="/{name}/undelete")
 @PerformanceMetric(value="keks.undelete")
 @DocumentedName(value="undeleteKek")
public void undeleteKek(@Suspended
                                                                                                                                                javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                                                                @Context
                                                                                                                                                javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                @PathParam(value="name")
                                                                                                                                                String name)

undeleteDekVersions

@POST
 @Path(value="/{name}/deks/{subject}/undelete")
 @PerformanceMetric(value="deks.undelete")
 @DocumentedName(value="undeleteDekVersions")
public void undeleteDekVersions(@Suspended
                                                                                                                                                                               javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                                                                                               @Context
                                                                                                                                                                               javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                               @PathParam(value="name")
                                                                                                                                                                               String kekName,
                                                                                                                                                                               @PathParam(value="subject")
                                                                                                                                                                               String subject,
                                                                                                                                                                               @QueryParam(value="algorithm")
                                                                                                                                                                               DekFormat algorithm)

undeleteDekVersion

@POST
 @Path(value="/{name}/deks/{subject}/versions/{version}/undelete")
 @PerformanceMetric(value="deks.versions.undelete")
 @DocumentedName(value="undeleteDekVersion")
public void undeleteDekVersion(@Suspended
                                                                                                                                                                                                         javax.ws.rs.container.AsyncResponse asyncResponse,
                                                                                                                                                                                                         @Context
                                                                                                                                                                                                         javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                                                         @PathParam(value="name")
                                                                                                                                                                                                         String kekName,
                                                                                                                                                                                                         @PathParam(value="subject")
                                                                                                                                                                                                         String subject,
                                                                                                                                                                                                         @PathParam(value="version")
                                                                                                                                                                                                         String version,
                                                                                                                                                                                                         @QueryParam(value="algorithm")
                                                                                                                                                                                                         DekFormat algorithm)