Package io.confluent.kafka.schemaregistry.rest.resources

Class AssociationsResource

java.lang.Object

io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource

@Path("/")
@Produces({"application/vnd.schemaregistry.v1+json","application/vnd.schemaregistry+json; qs=0.9","application/json; qs=0.5"})
@Consumes({"application/vnd.schemaregistry.v1+json","application/vnd.schemaregistry+json","application/json","application/octet-stream"})
public class AssociationsResource
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	apiTag
static final String	DEFAULT_RESOURCE_TYPE

Constructor Summary

Constructors

Constructor	Description
AssociationsResource(SchemaRegistry schemaRegistry)

Method Summary

Modifier and Type	Method	Description
void	createAssociation(jakarta.ws.rs.container.AsyncResponse asyncResponse, jakarta.ws.rs.core.HttpHeaders headers, String context, boolean dryRun, @NotNull AssociationCreateOrUpdateRequest request)
void	createOrUpdateAssociation(jakarta.ws.rs.container.AsyncResponse asyncResponse, jakarta.ws.rs.core.HttpHeaders headers, String resourceId, String context, boolean dryRun, @NotNull AssociationCreateOrUpdateRequest request)
void	deleteAssociations(jakarta.ws.rs.container.AsyncResponse asyncResponse, jakarta.ws.rs.core.HttpHeaders headers, String resourceId, String resourceType, List<String> associationTypes, boolean cascadeLifecycle, boolean dryRun)
List<Association>	getAssociationsByResourceId(String resourceId, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle, int offset, int limit)
List<Association>	getAssociationsByResourceName(String resourceName, String resourceNamespace, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle, int offset, int limit)
List<Association>	getAssociationsBySubject(String subject, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle, int offset, int limit)
void	mutateAssociations(jakarta.ws.rs.container.AsyncResponse asyncResponse, jakarta.ws.rs.core.HttpHeaders headers, String context, boolean dryRun, @NotNull AssociationBatchRequest request)

Methods inherited from class java.lang.Object

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

Field Details

apiTag

public static final String apiTag

See Also:

• Constant Field Values

DEFAULT_RESOURCE_TYPE

public static final String DEFAULT_RESOURCE_TYPE

See Also:

• Constant Field Values

Constructor Details

AssociationsResource

public AssociationsResource(SchemaRegistry schemaRegistry)

Method Details

getAssociationsBySubject

@Path("/associations/subjects/{subject}")
@GET
@PerformanceMetric("associations.by-subject")
@DocumentedName("getAssociationsBySubject")
public List<Association> getAssociationsBySubject(@PathParam("subject")
 String subject,
 @QueryParam("resourceType")
 String resourceType,
 @QueryParam("associationType")
 List<String> associationTypes,
 @QueryParam("lifecycle")
 LifecyclePolicy lifecycle,
 @DefaultValue("0") @QueryParam("offset")
 int offset,
 @DefaultValue("-1") @QueryParam("limit")
 int limit)

getAssociationsByResourceName

@Path("/associations/resources/{resourceNamespace}/{resourceName}")
@GET
@PerformanceMetric("associations.by-resource-name")
@DocumentedName("getAssociationsByResourceName")
public List<Association> getAssociationsByResourceName(@PathParam("resourceName")
 String resourceName,
 @PathParam("resourceNamespace")
 String resourceNamespace,
 @QueryParam("resourceType")
 String resourceType,
 @QueryParam("associationType")
 List<String> associationTypes,
 @QueryParam("lifecycle")
 LifecyclePolicy lifecycle,
 @DefaultValue("0") @QueryParam("offset")
 int offset,
 @DefaultValue("-1") @QueryParam("limit")
 int limit)

getAssociationsByResourceId

@Path("/associations/resources/{resourceId}")
@GET
@PerformanceMetric("associations.by-resource-id")
@DocumentedName("getAssociationsByResourceId")
public List<Association> getAssociationsByResourceId(@PathParam("resourceId")
 String resourceId,
 @QueryParam("resourceType")
 String resourceType,
 @QueryParam("associationType")
 List<String> associationTypes,
 @QueryParam("lifecycle")
 LifecyclePolicy lifecycle,
 @DefaultValue("0") @QueryParam("offset")
 int offset,
 @DefaultValue("-1") @QueryParam("limit")
 int limit)

createAssociation

@Path("/associations")
@POST
@PerformanceMetric("association.create")
@DocumentedName("createAssociation")
public void createAssociation(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @Context
 jakarta.ws.rs.core.HttpHeaders headers,
 @QueryParam("context")
 String context,
 @QueryParam("dryRun")
 boolean dryRun,
 @NotNull
 @NotNull AssociationCreateOrUpdateRequest request)

createOrUpdateAssociation

@Path("/associations/resources/{resourceId}")
@PUT
@PerformanceMetric("association.upsert")
@DocumentedName("createOrUpdateAssociation")
public void createOrUpdateAssociation(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @Context
 jakarta.ws.rs.core.HttpHeaders headers,
 @PathParam("resourceId")
 String resourceId,
 @QueryParam("context")
 String context,
 @QueryParam("dryRun")
 boolean dryRun,
 @NotNull
 @NotNull AssociationCreateOrUpdateRequest request)

mutateAssociations

@Path("/associations:batch")
@POST
@PerformanceMetric("associations.mutate")
@DocumentedName("mutateAssociations")
public void mutateAssociations(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @Context
 jakarta.ws.rs.core.HttpHeaders headers,
 @QueryParam("context")
 String context,
 @QueryParam("dryRun")
 boolean dryRun,
 @NotNull
 @NotNull AssociationBatchRequest request)

deleteAssociations

@Path("/associations/resources/{resourceId}")
@DELETE
@PerformanceMetric("associations.delete")
@DocumentedName("deleteAssociations")
public void deleteAssociations(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @Context
 jakarta.ws.rs.core.HttpHeaders headers,
 @PathParam("resourceId")
 String resourceId,
 @QueryParam("resourceType")
 String resourceType,
 @QueryParam("associationType")
 List<String> associationTypes,
 @QueryParam("cascadeLifecycle")
 boolean cascadeLifecycle,
 @QueryParam("dryRun")
 boolean dryRun)